persist collected fees

.github/workflows/unit.yaml

@@ -47,7 +47,7 @@ jobs:
       - name: check code integrity
         uses: securego/gosec@master
         with:
-          args: '-severity high -quiet -exclude=G115 ./...'
+          args: '-severity high -quiet -exclude=G115,G118 ./...'
 
       - name: Arkd unit tests
         run: make test

Makefile

@@ -89,7 +89,7 @@ help:
 ## integrationtest: run integration tests
 integrationtest:
 	@echo "Running integration tests..."
-	@go test -v -count 1 -timeout 800s github.com/arkade-os/arkd/internal/test/e2e
+	@go test -v -count 1 -timeout 1200s github.com/arkade-os/arkd/internal/test/e2e
 
 ## lint: lint codebase
 lint:

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

@@ -311,6 +311,56 @@
         }
       }
     },
+    "/v1/admin/fees/collected": {
+      "get": {
+        "tags": [
+          "AdminService"
+        ],
+        "operationId": "AdminService_GetCollectedFees",
+        "parameters": [
+          {
+            "name": "after",
+            "in": "query",
+            "description": "Unix timestamp (UTC, exclusive). Only include rounds starting after this time. 0 means no lower bound.",
+            "schema": {
+              "type": "integer",
+              "format": "int64"
+            }
+          },
+          {
+            "name": "before",
+            "in": "query",
+            "description": "Unix timestamp (UTC, exclusive). Only include rounds starting before this time. 0 means no upper bound.",
+            "schema": {
+              "type": "integer",
+              "format": "int64"
+            }
+          }
+        ],
+        "responses": {
+          "200": {
+            "description": "a successful response.",
+            "content": {
+              "application/json": {
+                "schema": {
+                  "$ref": "#/components/schemas/GetCollectedFeesResponse"
+                }
+              }
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "content": {
+              "application/json": {
+                "schema": {
+                  "$ref": "#/components/schemas/Status"
+                }
+              }
+            }
+          }
+        }
+      }
+    },
     "/v1/admin/intentFees": {
       "get": {
         "tags": [
@@ -1089,6 +1139,33 @@
           }
         }
       },
+      "GetCollectedFeesRequest": {
+        "title": "GetCollectedFeesRequest",
+        "type": "object",
+        "properties": {
+          "after": {
+            "type": "integer",
+            "description": "Unix timestamp (UTC, exclusive). Only include rounds starting after this time. 0 means no lower bound.",
+            "format": "int64"
+          },
+          "before": {
+            "type": "integer",
+            "description": "Unix timestamp (UTC, exclusive). Only include rounds starting before this time. 0 means no upper bound.",
+            "format": "int64"
+          }
+        }
+      },
+      "GetCollectedFeesResponse": {
+        "title": "GetCollectedFeesResponse",
+        "type": "object",
+        "properties": {
+          "collectedFees": {
+            "type": "integer",
+            "description": "Total collected fees in satoshis.",
+            "format": "uint64"
+          }
+        }
+      },
       "GetConvictionsByRoundRequest": {
         "title": "GetConvictionsByRoundRequest",
         "type": "object",

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

@@ -120,6 +120,11 @@ service AdminService {
       get: "/v1/admin/liquidity/recoverable"
     };
   }
+  rpc GetCollectedFees(GetCollectedFeesRequest) returns (GetCollectedFeesResponse) {
+    option (meshapi.gateway.http) = {
+      get: "/v1/admin/fees/collected"
+    };
+  }
   rpc Sweep(SweepRequest) returns (SweepResponse) {
     option (meshapi.gateway.http) = {
       post: "/v1/admin/sweep"
@@ -352,6 +357,14 @@ message GetRecoverableLiquidityResponse {
   uint64 amount = 1;
 }
 
+message GetCollectedFeesRequest {
+  int64 after = 1; // Unix timestamp (UTC, exclusive). Only include rounds starting after this time. 0 means no lower bound.
+  int64 before = 2; // Unix timestamp (UTC, exclusive). Only include rounds starting before this time. 0 means no upper bound.
+}
+message GetCollectedFeesResponse {
+  uint64 collected_fees = 1; // Total collected fees in satoshis.
+}
+
 message SweepRequest {
   bool connectors = 1;
   repeated string commitment_txids = 2;