Merge pull request #21 from kauxam/feature/checkconsistency

Feature/checkconsistency

Tangle.Net.Standard/Tangle.Net.Standard/Tangle.Net.Standard.csproj

@@ -65,6 +65,7 @@
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Client\RestIotaClient.cs" Link="Repository\Client\RestIotaClient.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\CommandType.cs" Link="Repository\CommandType.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\DataTransfer\AddressWithBalances.cs" Link="Repository\DataTransfer\AddressWithBalances.cs" />
+    <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\DataTransfer\ConsistencyInfo.cs" Link="Repository\DataTransfer\ConsistencyInfo.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\DataTransfer\InclusionStates.cs" Link="Repository\DataTransfer\InclusionStates.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\DataTransfer\Neighbor.cs" Link="Repository\DataTransfer\Neighbor.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\DataTransfer\NeighborList.cs" Link="Repository\DataTransfer\NeighborList.cs" />
@@ -83,6 +84,7 @@
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\InvalidBundleException.cs" Link="Repository\InvalidBundleException.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Responses\AddNeighborsResponse.cs" Link="Repository\Responses\AddNeighborsResponse.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Responses\AttachToTangleResponse.cs" Link="Repository\Responses\AttachToTangleResponse.cs" />
+    <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Responses\CheckConsistencyResponse.cs" Link="Repository\Responses\CheckConsistencyResponse.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Responses\FindUsedAddressesResponse.cs" Link="Repository\Responses\FindUsedAddressesResponse.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Responses\GetAccountDataResponse.cs" Link="Repository\Responses\GetAccountDataResponse.cs" />
     <Compile Include="..\..\Tangle.Net\Tangle.Net\Repository\Responses\GetBalanceResponse.cs" Link="Repository\Responses\GetBalanceResponse.cs" />

Tangle.Net/Tangle.Net/Repository/CommandType.cs

@@ -82,6 +82,11 @@ public static class CommandType
     /// </summary>
     public const string WereAddressesSpentFrom = "wereAddressesSpentFrom";
 
+    /// <summary>
+    /// The check consistency.
+    /// </summary>
+    public const string CheckConsistency = "checkConsistency";
+
     #endregion
   }
 }

Tangle.Net/Tangle.Net/Repository/DataTransfer/ConsistencyInfo.cs

@@ -0,0 +1,27 @@
+namespace Tangle.Net.Repository.DataTransfer
+{
+  /// <summary>
+  /// The consistency info.
+  /// </summary>
+  public class ConsistencyInfo
+  {
+    #region Public Properties
+
+    /// <summary>
+    /// Gets or sets the duration.
+    /// </summary>
+    public int Duration { get; set; }
+
+    /// <summary>
+    /// Gets or sets the state.
+    /// </summary>
+    public bool State { get; set; }
+
+    /// <summary>
+    /// Gets or sets the info.
+    /// </summary>
+    public string Info { get; set; }
+
+    #endregion
+  }
+}

Tangle.Net/Tangle.Net/Repository/IIotaCoreRepository.cs

@@ -360,6 +360,28 @@ public interface IIotaCoreRepository
     /// </returns>
     Task<List<Address>> WereAddressesSpentFromAsync(List<Address> addresses);
 
+    /// <summary>
+    /// The check consistency.
+    /// </summary>
+    /// <param name="tailHashes">
+    /// The tail hashes.
+    /// </param>
+    /// <returns>
+    /// The <see cref="ConsistencyInfo"/>.
+    /// </returns>
+    ConsistencyInfo CheckConsistency(List<Hash> tailHashes);
+
+    /// <summary>
+    /// The check consistency async.
+    /// </summary>
+    /// <param name="tailHashes">
+    /// The tail hashes.
+    /// </param>
+    /// <returns>
+    /// The <see cref="Task"/>.
+    /// </returns>
+    Task<ConsistencyInfo> CheckConsistencyAsync(List<Hash> tailHashes);
+
     #endregion
   }
 }

Tangle.Net/Tangle.Net/Repository/Responses/CheckConsistencyResponse.cs

@@ -0,0 +1,9 @@
+namespace Tangle.Net.Repository.Responses
+{
+    public class CheckConsistencyResponse
+    {
+        public int Duration { get; set; }
+        public bool State { get; set; }
+        public string Info { get; set; }
+    }
+}

Tangle.Net/Tangle.Net/Repository/RestIotaCoreRepository.cs

@@ -200,13 +200,13 @@ public AddressWithBalances GetBalances(List<Address> addresses, int threshold =
       }
 
       return new AddressWithBalances
-               {
-                 Addresses = addresses,
-                 Duration = result.Duration,
-                 MilestoneIndex = result.MilestoneIndex,
-                 References =
+      {
+        Addresses = addresses,
+        Duration = result.Duration,
+        MilestoneIndex = result.MilestoneIndex,
+        References =
                    result.References.ConvertAll(reference => new TryteString(reference))
-               };
+      };
     }
 
     /// <inheritdoc />
@@ -226,13 +226,13 @@ public async Task<AddressWithBalances> GetBalancesAsync(List<Address> addresses,
       }
 
       return new AddressWithBalances
-               {
-                 Addresses = addresses,
-                 Duration = result.Duration,
-                 MilestoneIndex = result.MilestoneIndex,
-                 References =
+      {
+        Addresses = addresses,
+        Duration = result.Duration,
+        MilestoneIndex = result.MilestoneIndex,
+        References =
                    result.References.ConvertAll(reference => new TryteString(reference))
-               };
+      };
     }
 
     /// <inheritdoc />
@@ -281,10 +281,10 @@ public TipHashList GetTips()
       var response = this.Client.ExecuteParameterlessCommand<GetTipsResponse>(CommandType.GetTips);
 
       return new TipHashList
-               {
-                 Duration = response.Duration,
-                 Hashes = response.Hashes.Select(h => new Hash(h)).ToList()
-               };
+      {
+        Duration = response.Duration,
+        Hashes = response.Hashes.Select(h => new Hash(h)).ToList()
+      };
     }
 
     /// <inheritdoc />
@@ -293,10 +293,10 @@ public async Task<TipHashList> GetTipsAsync()
       var response = await this.Client.ExecuteParameterlessCommandAsync<GetTipsResponse>(CommandType.GetTips);
 
       return new TipHashList
-               {
-                 Duration = response.Duration,
-                 Hashes = response.Hashes.Select(h => new Hash(h)).ToList()
-               };
+      {
+        Duration = response.Duration,
+        Hashes = response.Hashes.Select(h => new Hash(h)).ToList()
+      };
     }
 
     /// <inheritdoc />
@@ -306,11 +306,11 @@ public TransactionsToApprove GetTransactionsToApprove(int depth = 27)
         new Dictionary<string, object> { { "command", CommandType.GetTransactionsToApprove }, { "depth", depth } });
 
       return new TransactionsToApprove
-               {
-                 BranchTransaction = new Hash(result.BranchTransaction),
-                 TrunkTransaction = new Hash(result.TrunkTransaction),
-                 Duration = result.Duration
-               };
+      {
+        BranchTransaction = new Hash(result.BranchTransaction),
+        TrunkTransaction = new Hash(result.TrunkTransaction),
+        Duration = result.Duration
+      };
     }
 
     /// <inheritdoc />
@@ -320,11 +320,11 @@ public async Task<TransactionsToApprove> GetTransactionsToApproveAsync(int depth
                      new Dictionary<string, object> { { "command", CommandType.GetTransactionsToApprove }, { "depth", depth } });
 
       return new TransactionsToApprove
-               {
-                 BranchTransaction = new Hash(result.BranchTransaction),
-                 TrunkTransaction = new Hash(result.TrunkTransaction),
-                 Duration = result.Duration
-               };
+      {
+        BranchTransaction = new Hash(result.BranchTransaction),
+        TrunkTransaction = new Hash(result.TrunkTransaction),
+        Duration = result.Duration
+      };
     }
 
     /// <inheritdoc />
@@ -444,6 +444,42 @@ public async Task<List<Address>> WereAddressesSpentFromAsync(List<Address> addre
       return addresses;
     }
 
+    /// <inheritdoc />
+    public ConsistencyInfo CheckConsistency(List<Hash> tailHashes)
+    {
+      var response = Client.ExecuteParameterizedCommand<CheckConsistencyResponse>(
+        new Dictionary<string, object>
+          {
+            { "command", CommandType.CheckConsistency },
+            { "tails", tailHashes.Select(h => h.Value).ToList() }
+          });
+
+      return new ConsistencyInfo
+      {
+        Duration = response.Duration,
+        State = response.State,
+        Info = response.Info
+      };
+    }
+
+    /// <inheritdoc />
+    public async Task<ConsistencyInfo> CheckConsistencyAsync(List<Hash> tailHashes)
+    {
+      var response = await Client.ExecuteParameterizedCommandAsync<CheckConsistencyResponse>(
+        new Dictionary<string, object>
+          {
+            { "command", CommandType.CheckConsistency },
+            { "tails", tailHashes.Select(h => h.Value).ToList() }
+          });
+
+      return new ConsistencyInfo
+      {
+        Duration = response.Duration,
+        State = response.State,
+        Info = response.Info
+      };
+    }
+
     /// <summary>
     /// The create find transactions parameters.
     /// </summary>

Tangle.Net/Tangle.Net/Tangle.Net.csproj

@@ -86,6 +86,7 @@
     <Compile Include="ProofOfWork\Utils\TrinaryDemultiplexer.cs" />
     <Compile Include="Repository\Client\IIotaClient.cs" />
     <Compile Include="Repository\Client\RestIotaClient.cs" />
+    <Compile Include="Repository\DataTransfer\ConsistencyInfo.cs" />
     <Compile Include="Repository\DataTransfer\InclusionStates.cs" />
     <Compile Include="Repository\DataTransfer\TipHashList.cs" />
     <Compile Include="Repository\DataTransfer\TransactionHashList.cs" />
@@ -130,6 +131,7 @@
     <Compile Include="Repository\Responses\GetTrytesResponse.cs" />
     <Compile Include="Repository\Responses\RemoveNeighborsResponse.cs" />
     <Compile Include="Repository\Responses\WereAddressesSpentFromResponse.cs" />
+    <Compile Include="Repository\Responses\CheckConsistencyResponse.cs" />
     <Compile Include="Repository\RestIotaCoreRepository.cs" />
     <Compile Include="Repository\RestIotaNodeRepository.cs" />
     <Compile Include="Repository\RestIotaExtendedRepository.cs" />