Added Blockheight and Version

internal/light-client/event-listener/listener.go

@@ -99,6 +99,7 @@ func (el *EventListener) ProcessLogs() {
 
 		log.Debugf("Event ChainID: %v", event.ChainId)
 		log.Debugf("Event StorageURL: %v", event.StorageURL)
+		log.Debugf("Event BlockHeight: %v", event.BlockHeight)
 
 		// strip the ipfs://
 		parsedURL, err := url.Parse(event.StorageURL)
@@ -107,6 +108,6 @@ func (el *EventListener) ProcessLogs() {
 			continue
 		}
 
-		el.sampler.ProcessEvent(parsedURL.Host)
+		el.sampler.ProcessEvent(parsedURL.Host, event.BlockHeight)
 	}
 }

internal/light-client/publisher/publisher.go

@@ -1,15 +1,16 @@
 package publisher
 
 import (
+	"cloud.google.com/go/pubsub"
 	"context"
 	"encoding/base64"
 	"encoding/json"
+	"fmt"
+	"github.com/covalenthq/das-ipfs-pinner/common"
+	"google.golang.org/api/option"
 	"io"
 	"os"
 	"time"
-
-	"cloud.google.com/go/pubsub"
-	"google.golang.org/api/option"
 )
 
 type Publisher struct {
@@ -29,6 +30,8 @@ type message struct {
 	Commitment  string    `json:"commitment"`
 	Proof       string    `json:"proof"`
 	Cell        string    `json:"cell"`
+	BlockHeight uint64    `json:"block_height"`
+	Version     string    `json:"version"`
 }
 
 // Define a struct with only the `project_id` field
@@ -66,7 +69,7 @@ func NewPublisher(topicID, credsFile, clientId string) (*Publisher, error) {
 }
 
 // Publish to Pubsub
-func (p *Publisher) PublishToCS(cid string, rowIndex int, colIndex int, status bool, commitment []byte, proof []byte, cell []byte) error {
+func (p *Publisher) PublishToCS(cid string, rowIndex int, colIndex int, status bool, commitment []byte, proof []byte, cell []byte, blockHeight uint64) error {
 	ctx := context.Background()
 
 	// Create a Pub/Sub client using the credentials
@@ -89,6 +92,8 @@ func (p *Publisher) PublishToCS(cid string, rowIndex int, colIndex int, status b
 		Commitment:  base64.StdEncoding.EncodeToString(commitment),
 		Proof:       base64.StdEncoding.EncodeToString(proof),
 		Cell:        base64.StdEncoding.EncodeToString(cell),
+		BlockHeight: blockHeight,
+		Version:     fmt.Sprintf("%s-%s", common.Version, common.GitCommit),
 	}
 
 	// Marshal the message into JSON.

internal/light-client/sampler/sampler.go

@@ -112,7 +112,7 @@ func NewSampler(ipfsAddr string, samplingDelay uint, pub *publisher.Publisher) (
 }
 
 // ProcessEvent handles events asynchronously by processing the provided CID.
-func (s *Sampler) ProcessEvent(cidStr string) {
+func (s *Sampler) ProcessEvent(cidStr string, blockHeight uint64) {
 	go func(cidStr string) {
 		rawCid, err := cid.Decode(cidStr)
 		if err != nil {
@@ -160,7 +160,7 @@ func (s *Sampler) ProcessEvent(cidStr string) {
 
 		log.Infof("Verification result for [%d, %d]: %v", rowindex, colindex, res)
 
-		if err := s.pub.PublishToCS(cidStr, rowindex, colindex, res, commitment, proof, cell); err != nil {
+		if err := s.pub.PublishToCS(cidStr, rowindex, colindex, res, commitment, proof, cell, blockHeight); err != nil {
 			log.Errorf("Failed to publish to Cloud Storage: %v", err)
 			return
 		}