feat: implement SearchUtxosAsync method in QueryServiceClient (#23)

utxorpc · Nov 24, 2024 · e998f15 · e998f15
1 parent 0bdd47b
commit e998f15
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 2 deletions.
diff --git a/src/Utxorpc.Sdk/QueryServiceClient.cs b/src/Utxorpc.Sdk/QueryServiceClient.cs
@@ -1,3 +1,4 @@
+using Google.Protobuf;
 using Grpc.Net.Client;
 using Utxorpc.V1alpha.Query;
 
@@ -28,6 +29,31 @@ public QueryServiceClient(string url, IDictionary<string, string>? headers = nul
         var channel = GrpcChannel.ForAddress(url, channelOptions);
         _client = new QueryService.QueryServiceClient(channel);
     }
+
+    public async Task<SearchUtxosResponse> SearchUtxosAsync(byte[] address, string? start_token = null)
+    {
+        SearchUtxosRequest request = new()
+        {
+            Predicate = new()
+            {
+                Match = new()
+                {
+                    Cardano = new()
+                    {
+                        Address = new ()
+                        {
+                            ExactAddress = ByteString.CopyFrom(address)
+                        }
+                    }
+                }
+            },
+        };
 
-    // TODO: Implement ReadData, ReadParams, ReadUtxos, SearchUtxos methods
+        if (start_token != null)
+        {
+            request.StartToken = start_token;
+        }
+
+        return await _client.SearchUtxosAsync(request);
+    }
 }
diff --git a/src/Utxorpc.Sdk/SubmitServiceClient.cs b/src/Utxorpc.Sdk/SubmitServiceClient.cs
@@ -28,5 +28,4 @@ public SubmitServiceClient(string url, IDictionary<string, string>? headers = nu
         var channel = GrpcChannel.ForAddress(url, channelOptions);
         _client = new SubmitService.SubmitServiceClient(channel);
     }
-    // TODO: Implement EvalTx, ReadMempool, SubmitTx, WaitForTx, WatchMempool methods
 }