diff --git a/proto/Bid.proto b/proto/Bid.proto
deleted file mode 100644
index 5051cdd..0000000
--- a/proto/Bid.proto
+++ /dev/null
@@ -1,10 +0,0 @@
-
-syntax = "proto3";
-option php_namespace = 'App\\Grpc\\nostr';
-option php_metadata_namespace = 'App\\Grpc\\nostr\\GPBMetadata';
-
-message Bid {
-    uint64 amount = 1;
-    string currency = 2;
-    string protocol = 3;
-}
diff --git a/proto/Job.proto b/proto/Job.proto
index 375f6e2..777575e 100644
--- a/proto/Job.proto
+++ b/proto/Job.proto
@@ -5,7 +5,6 @@ import "JobInput.proto";
 import "JobState.proto";
 import "JobResult.proto";
 import "Payment.proto";
-import "Bid.proto";
 
 option php_namespace = 'App\\Grpc\\nostr';
 option php_metadata_namespace = 'App\\Grpc\\nostr\\GPBMetadata';
@@ -44,7 +43,7 @@ message Job {
   string outputFormat = 16;
   optional bool encrypted = 17;
   
-  optional Bid bid = 19;
+  optional Payment bid = 19;
 
 
 
diff --git a/proto/Payment.proto b/proto/Payment.proto
index 8e2fe67..af67c8f 100644
--- a/proto/Payment.proto
+++ b/proto/Payment.proto
@@ -5,7 +5,7 @@ option php_metadata_namespace = 'App\\Grpc\\nostr\\GPBMetadata';
 import "PaymentStatus.proto";
 
 message Payment {
-    string id = 1;
+    optional string id = 1;
     uint64 amount = 2;
     string currency = 3;
     string protocol = 4;
diff --git a/proto/PaymentStatus.proto b/proto/PaymentStatus.proto
index 5b551ad..27c9d9d 100644
--- a/proto/PaymentStatus.proto
+++ b/proto/PaymentStatus.proto
@@ -4,10 +4,11 @@ option php_namespace = 'App\\Grpc\\nostr';
 option php_metadata_namespace = 'App\\Grpc\\nostr\\GPBMetadata';
 
 enum PaymentStatus {
-    PAYMENT_SENT = 0;
-    PAYMENT_RECEIVED = 1;
-    PAYMENT_REFUNDED = 2;
-    PAYMENT_FAILED = 3;
-    PAYMENT_PENDING = 4;
+    PAYMENT_REQUESTED = 0;
+    PAYMENT_SENT = 1;
+    PAYMENT_RECEIVED = 2;
+    PAYMENT_REFUNDED = 3;
+    PAYMENT_FAILED = 4;
+    PAYMENT_PENDING = 5;
     PAYMENT_UNKNOWN_STATUS = 99;
 }
\ No newline at end of file
diff --git a/proto/rpc.proto b/proto/rpc.proto
index 9440c83..1be6ed8 100644
--- a/proto/rpc.proto
+++ b/proto/rpc.proto
@@ -1,15 +1,10 @@
 syntax = "proto3";
 
-import "Log.proto";
-import "JobStatus.proto";
-import "JobState.proto";
 import "JobParam.proto";
 import "JobInput.proto";
-import "JobResult.proto";
 import "Job.proto";
 import "Payment.proto";
 import "PaymentStatus.proto";
-import "Bid.proto";
 
 option php_namespace = 'App\\Grpc\\nostr';
 option php_metadata_namespace = 'App\\Grpc\\nostr\\GPBMetadata';
@@ -25,7 +20,7 @@ message RpcRequestJob {
     optional bool encrypted = 10;
     optional string userId = 11;
     optional uint32 minWorkers = 12;
-    optional Bid bid = 13;
+    optional Payment bid = 13;
 }
 
 message RpcGetJob {
@@ -43,7 +38,7 @@ message RpcGetPendingJobs {
     optional string filterByDescription = 3;
     optional string filterById = 4;
     optional string filterByKind = 5;
-    repeated Bid filterByBids = 6;
+    repeated Payment filterByBids = 6;
     repeated string excludeId = 98; // which job ids to exclude, optional
     optional uint32 wait = 99; // max time to wait in ms , 0 or unset means no wait
 
@@ -76,6 +71,17 @@ message RpcJobComplete{
   string jobId = 1;
   string output = 2;
   optional string info = 3;
+  optional Payment cost = 4;
+}
+
+message RpcRequestPayment{
+  optional Payment payment = 1;
+  optional bool waitForPayments = 2  ;
+
+}
+
+message RpcRequestPaymentResponse{
+  PaymentStatus status=1;
 }
 
 message RpcJobLog {
@@ -320,6 +326,7 @@ service PoolConnector {
     rpc completeJob(RpcJobComplete) returns (Job);
     rpc logForJob(RpcJobLog) returns (Job);
     rpc payJob(RpcPayJobRequest) returns (Job);
+    rpc requestPayment(RpcRequestPayment) returns (RpcRequestPaymentResponse);
 
 
     // discovery
@@ -357,13 +364,6 @@ service PoolConnector {
     rpc cacheGet(RpcCacheGetRequest) returns (stream RpcCacheGetResponse);
 
 
-    // pay
-    // rpc requestPayment(RpcRequestPayment) returns (RpcRequestPaymentResponse);
-    // rpc cancelAndRefundPayment(RpcCancelAndRefundPayment) returns (RpcCancelAndRefundPaymentResponse);
-    
-    // rpc getPayment(RpcGetPayment) returns (RpcGetPaymentResponse);
-    // rpc sendPayment(RpcSendPayment) returns (RpcSendPaymentResponse);
-