add filter by bids support

OpenAgentsInc · Jun 6, 2024 · 6865684 · 6865684
1 parent 7fff7f0
commit 6865684
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 1 deletion.
diff --git a/src/OpenAgentsNode.ts b/src/OpenAgentsNode.ts
@@ -3,7 +3,7 @@ import {NodeMetaData} from "./NodeConfig";
 import NodeConfig from "./NodeConfig";
 import JobRunner from "./JobRunner";
 import Logger from "./Logger";
-import { PoolConnectorClient  } from "openagents-grpc-proto";
+import {  PoolConnectorClient  } from "openagents-grpc-proto";
 import * as GRPC from "@grpc/grpc-js";
 import type { UnaryCall, RpcOutputStream, ServerStreamingCall, RpcOptions, ClientStreamingCall, RpcInputStream } from "@protobuf-ts/runtime-rpc";
 import { GrpcTransport } from "@protobuf-ts/grpc-transport";
@@ -216,6 +216,15 @@ export default class OpenAgentsNode {
                     filterByKind: filter.filterByKind,
                     wait: 60000,
                     excludeId: this.lockedJobs.map((j) => j.jobId),
+                    filterByBids: filter.filterByBids
+                        ? filter.filterByBids
+                        : [
+                              {
+                                  amount: 0,
+                                  currency: "bitcoin",
+                                  protocol: "lightning",
+                              }
+                          ],
                 })
             );
             jobs.push(...res.jobs);

diff --git a/src/RunnerConfig.ts b/src/RunnerConfig.ts
@@ -17,6 +17,11 @@ export type JobFilter = {
     filterByDescription?: string;
     filterById?: string;
     filterByKind?: string;
+    filterByBids?: [{
+        amount: number;
+        currency: string;
+        protocol: string;
+    }];
 };
 
 export type SocketsSchema = {