[Server] Add admin RPCs to manage queue of tx requests (#442)

* add admin RPCs: GetTxRequestQueue & DeleteTxRequests

* update permissions

* add arkd commands

* Move types to types.proto & add request ids filter for getter

* Add filter to get tx requests by id

---------

Co-authored-by: altafan <[email protected]>

Author: louisinger

api-spec/openapi/swagger/ark/v1/admin.swagger.json

@@ -100,6 +100,72 @@
         ]
       }
     },
+    "/v1/admin/queue": {
+      "get": {
+        "operationId": "AdminService_GetTxRequestQueue",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/v1GetTxRequestQueueResponse"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "requestIds",
+            "in": "query",
+            "required": false,
+            "type": "array",
+            "items": {
+              "type": "string"
+            },
+            "collectionFormat": "multi"
+          }
+        ],
+        "tags": [
+          "AdminService"
+        ]
+      }
+    },
+    "/v1/admin/queue/delete": {
+      "post": {
+        "operationId": "AdminService_DeleteTxRequests",
+        "responses": {
+          "200": {
+            "description": "A successful response.",
+            "schema": {
+              "$ref": "#/definitions/v1DeleteTxRequestsResponse"
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/rpcStatus"
+            }
+          }
+        },
+        "parameters": [
+          {
+            "name": "body",
+            "in": "body",
+            "required": true,
+            "schema": {
+              "$ref": "#/definitions/v1DeleteTxRequestsRequest"
+            }
+          }
+        ],
+        "tags": [
+          "AdminService"
+        ]
+      }
+    },
     "/v1/admin/round/{roundId}": {
       "get": {
         "operationId": "AdminService_GetRoundDetails",
@@ -270,6 +336,20 @@
         }
       }
     },
+    "v1DeleteTxRequestsRequest": {
+      "type": "object",
+      "properties": {
+        "requestIds": {
+          "type": "array",
+          "items": {
+            "type": "string"
+          }
+        }
+      }
+    },
+    "v1DeleteTxRequestsResponse": {
+      "type": "object"
+    },
     "v1GetMarketHourConfigResponse": {
       "type": "object",
       "properties": {
@@ -355,6 +435,18 @@
         }
       }
     },
+    "v1GetTxRequestQueueResponse": {
+      "type": "object",
+      "properties": {
+        "requests": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/v1TxRequestInfo"
+          }
+        }
+      }
+    },
     "v1MarketHourConfig": {
       "type": "object",
       "properties": {
@@ -374,6 +466,36 @@
         }
       }
     },
+    "v1Output": {
+      "type": "object",
+      "properties": {
+        "address": {
+          "type": "string",
+          "title": "onchain or off-chain"
+        },
+        "amount": {
+          "type": "string",
+          "format": "uint64",
+          "description": "Amount to send in satoshis."
+        }
+      }
+    },
+    "v1RequestInput": {
+      "type": "object",
+      "properties": {
+        "txid": {
+          "type": "string"
+        },
+        "vout": {
+          "type": "integer",
+          "format": "int64"
+        },
+        "amount": {
+          "type": "string",
+          "format": "uint64"
+        }
+      }
+    },
     "v1ScheduledSweep": {
       "type": "object",
       "properties": {
@@ -408,6 +530,58 @@
         }
       }
     },
+    "v1TxRequestInfo": {
+      "type": "object",
+      "properties": {
+        "id": {
+          "type": "string"
+        },
+        "createdAt": {
+          "type": "string",
+          "format": "int64"
+        },
+        "receivers": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/v1Output"
+          }
+        },
+        "inputs": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/v1RequestInput"
+          }
+        },
+        "boardingInputs": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/v1RequestInput"
+          }
+        },
+        "notes": {
+          "type": "array",
+          "items": {
+            "type": "string"
+          }
+        },
+        "signingType": {
+          "type": "string"
+        },
+        "cosignersPublicKeys": {
+          "type": "array",
+          "items": {
+            "type": "string"
+          }
+        },
+        "lastPing": {
+          "type": "string",
+          "format": "int64"
+        }
+      }
+    },
     "v1UpdateMarketHourConfigRequest": {
       "type": "object",
       "properties": {

api-spec/protobuf/ark/v1/admin.proto

@@ -5,6 +5,7 @@ package ark.v1;
 import "google/api/annotations.proto";
 import "google/protobuf/timestamp.proto";
 import "google/protobuf/duration.proto";
+import "ark/v1/types.proto";
 
 service AdminService {
   rpc GetScheduledSweep(GetScheduledSweepRequest) returns (GetScheduledSweepResponse) {
@@ -40,6 +41,17 @@ service AdminService {
       body: "*"
     };
   }
+  rpc GetTxRequestQueue(GetTxRequestQueueRequest) returns (GetTxRequestQueueResponse) {
+    option (google.api.http) = {
+      get: "/v1/admin/queue"
+    };
+  }
+  rpc DeleteTxRequests(DeleteTxRequestsRequest) returns (DeleteTxRequestsResponse) {
+    option (google.api.http) = {
+      post: "/v1/admin/queue/delete"
+      body: "*"
+    };
+  }
   rpc Withdraw(WithdrawRequest) returns (WithdrawResponse) {
     option (google.api.http) = {
       post: "/v1/admin/withdraw"
@@ -53,22 +65,9 @@ message GetScheduledSweepResponse {
   repeated ScheduledSweep sweeps = 1;
 }
 
-message SweepableOutput {
-  string txid = 1;
-  uint32 vout = 2;
-  string amount = 3;
-  int64 scheduled_at = 4;
-}
-
-message ScheduledSweep {
-  string round_id = 1;
-  repeated SweepableOutput outputs = 2;
-}
-
 message GetRoundDetailsRequest {
   string round_id = 1;
 }
-
 message GetRoundDetailsResponse {
   string round_id = 1;
   string txid = 2;
@@ -85,7 +84,6 @@ message GetRoundsRequest {
   int64 after = 1;
   int64 before = 2;
 }
-
 message GetRoundsResponse {
   repeated string rounds = 1;
 }
@@ -94,21 +92,18 @@ message CreateNoteRequest {
   uint32 amount = 1;
   uint32 quantity = 2;
 }
-
 message CreateNoteResponse {
   repeated string notes = 1;
 }
 
 message GetMarketHourConfigRequest {}
-
 message GetMarketHourConfigResponse {
     MarketHourConfig config = 1;
 }
 
 message UpdateMarketHourConfigRequest {
     MarketHourConfig config = 1;
 }
-
 message UpdateMarketHourConfigResponse {}
 
 message MarketHourConfig {
@@ -118,11 +113,22 @@ message MarketHourConfig {
   google.protobuf.Duration round_interval = 4;
 }
 
+message GetTxRequestQueueRequest {
+  repeated string request_ids = 1;
+}
+message GetTxRequestQueueResponse {
+  repeated TxRequestInfo requests = 1;
+}
+
+message DeleteTxRequestsRequest {
+  repeated string request_ids = 1;
+}
+message DeleteTxRequestsResponse {}
 message WithdrawRequest {
   string address = 1;
   uint64 amount = 2;
 }
 
 message WithdrawResponse {
   string txid = 1;
-}
+}

api-spec/protobuf/ark/v1/types.proto

@@ -105,6 +105,36 @@ message MarketHour {
   int64 round_interval = 4;
 }
 
+message SweepableOutput {
+  string txid = 1;
+  uint32 vout = 2;
+  string amount = 3;
+  int64 scheduled_at = 4;
+}
+
+message ScheduledSweep {
+  string round_id = 1;
+  repeated SweepableOutput outputs = 2;
+}
+
+message TxRequestInfo {
+  string id = 1;
+  int64 created_at = 2;
+  repeated Output receivers = 3;
+  repeated RequestInput inputs = 4;
+  repeated RequestInput boarding_inputs = 5;
+  repeated string notes = 6;
+  string signing_type = 7;
+  repeated string cosigners_public_keys = 8;
+  int64 last_ping = 9;
+}
+
+message RequestInput {
+  string txid = 1;
+  uint32 vout = 2;
+  uint64 amount = 3;
+}
+
 /* Events */
 
 message RoundFinalizationEvent {