Add Realtime Video Payment Mechanism

It split the payment mechanism from media transport by creating a new endpoint '/payment' dedicated just for payments.

core/orchestrator.go

@@ -404,6 +404,13 @@ func (orch *orchestrator) DebitFees(addr ethcommon.Address, manifestID ManifestI
 	orch.node.Balances.Debit(addr, manifestID, priceRat.Mul(priceRat, big.NewRat(pixels, 1)))
 }
 
+func (orch *orchestrator) Balance(addr ethcommon.Address, manifestID ManifestID) *big.Rat {
+	if orch.node == nil || orch.node.Balances == nil {
+		return nil
+	}
+	return orch.node.Balances.Balance(addr, manifestID)
+}
+
 func (orch *orchestrator) Capabilities() *net.Capabilities {
 	if orch.node == nil {
 		return nil

net/lp_rpc.proto

@@ -132,10 +132,10 @@ message Capabilities {
         uint32 capacity = 2;
       }
 
-      map<string, ModelConstraint> models = 1; 
+      map<string, ModelConstraint> models = 1;
     }
 
-    
+
 }
 
 // The orchestrator sends this in response to `GetOrchestrator`, containing
@@ -338,6 +338,12 @@ message TranscodeResult {
     OrchestratorInfo info = 16;
 }
 
+// Response that an orchestrator sends after processing a payment.
+message PaymentResult {
+    // Used to notify a broadcaster of updated orchestrator information
+    OrchestratorInfo info = 16;
+}
+
 // Sent by the transcoder to register itself to the orchestrator.
 message RegisterRequest {
 
@@ -390,7 +396,7 @@ message RegisterAIWorkerRequest {
 }
 
 // Data included by the gateway when submitting a AI job.
-message AIJobData {  
+message AIJobData {
     // pipeline to use for the job
     string pipeline = 1;
 
@@ -399,7 +405,7 @@ message AIJobData {
 }
 
 // Sent by the orchestrator to the aiworker
-message NotifyAIJob {    
+message NotifyAIJob {
     // Configuration for the AI job
     AIJobData AIJobData = 1;