feat: add dataMarket field to SnapshotSubmission proto definition

PowerLoom · Dec 13, 2024 · ad41c2b · ad41c2b
1 parent 5cbdac2
commit ad41c2b
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 34 deletions.
diff --git a/pkgs/proto/submission.proto b/pkgs/proto/submission.proto
@@ -16,6 +16,7 @@ message SnapshotSubmission {
   Request request = 1;
   string signature = 2;
   string header = 3;
+  string dataMarket = 4;
 }
 
 service Submission {

diff --git a/pkgs/service/msg_server.go b/pkgs/service/msg_server.go
@@ -71,9 +71,6 @@ func (s *server) SubmitSnapshot(ctx context.Context, submission *pkgs.SnapshotSu
 	log.Debugln("Sending submission with ID: ", submissionId.String())
 
 	submissionBytes := submissionIdBytes
-	if config.SettingsObj.DataMarketInRequest {
-		submissionBytes = append(submissionBytes, []byte(config.SettingsObj.DataMarketAddress)...)
-	}
 	submissionBytes = append(submissionBytes, subBytes...)
 
 	// Track received submission for this epoch
@@ -172,7 +169,7 @@ func (s *server) getOrCreateEpochMetrics(epochID uint64) *epochMetrics {
 		received:  atomic.Uint64{},
 		succeeded: atomic.Uint64{},
 	})
-	
+
 	// Type assert and return the metrics object
 	metrics := metricsValue.(*epochMetrics)
 

diff --git a/pkgs/submission.pb.go b/pkgs/submission.pb.go