added wait for the nft verifier to sync, via channels, added a new transaction called polygon_checkpoint to the prepare block and added verification for it in process block

Author: harshu4

config.yml

@@ -1,10 +1,19 @@
+
 p2p:
   # 0.0.0.0 = localhost
   addr: 0.0.0.0
   # 0 = random port
   port: 0
   groupName: xnode
   peerLimit: 50
+nft:
+  rpcAddress: https://rpc.ankr.com/eth_sepolia
+  unlimitedRPC: false
+  eventSignature: Redeemed(uint256,bytes32)
+  searchLimit: 3000
+  deployBlock: 5618691
+  confirmations: 20
+  timing: 90
 bft:
   homeDir: cbft-home
 db:
@@ -30,7 +39,5 @@ log:
     maxSize: 10
     maxAge: 7
     maxBackups: 10
-nft:
-  trackerData: ./cbft/data/nft-tracked
-  rpcAddress: https://rpc.ankr.com/eth_sepolia
-  unlimitedRPC: false
+
+  

go.mod

@@ -1,8 +1,11 @@
 module github.com/openmesh-network/core
 
-go 1.21
+go 1.22.1
+
+toolchain go1.22.2
 
 require (
+	github.com/Openmesh-Network/nft-authorise v0.0.0-20240509074056-66765710e7e3
 	github.com/cometbft/cometbft v0.38.6
 	github.com/dgraph-io/badger/v3 v3.2103.5
 	github.com/ethereum/go-ethereum v1.13.14

go.sum

@@ -20,6 +20,8 @@ github.com/Nvveen/Gotty v0.0.0-20120604004816-cd527374f1e5 h1:TngWCqHvy9oXAN6lEV
 github.com/Nvveen/Gotty v0.0.0-20120604004816-cd527374f1e5/go.mod h1:lmUJ/7eu/Q8D7ML55dXQrVaamCz2vxCfdQBasLZfHKk=
 github.com/OneOfOne/xxhash v1.2.2 h1:KMrpdQIwFcEqXDklaen+P1axHaj9BSKzvpUUfnHldSE=
 github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
+github.com/Openmesh-Network/nft-authorise v0.0.0-20240509074056-66765710e7e3 h1:taqsq0MvVecbZAGNDLhfdj9pHNVaET7VRbUu3I6EG8Y=
+github.com/Openmesh-Network/nft-authorise v0.0.0-20240509074056-66765710e7e3/go.mod h1:UTMg2S2HcIGf8+XOIow8bXyYOcPZS2CgKRIHdZthaJg=
 github.com/StackExchange/wmi v1.2.1 h1:VIkavFPXSjcnS+O8yTq7NI32k0R5Aj+v39y29VYDOSA=
 github.com/StackExchange/wmi v1.2.1/go.mod h1:rcmrprowKIVzvc+NUiLncP2uuArMWLCbu9SBzvHz7e8=
 github.com/VictoriaMetrics/fastcache v1.12.1 h1:i0mICQuojGDL3KblA7wUNlY5lOK6a4bwt3uRKnkZU40=

internal/bft/abci/abci.go

@@ -3,8 +3,10 @@ package verificationApp
 import (
 	"context"
 	"encoding/base64"
+	"fmt"
 	"sort"
 
+	validatorpass_tracker "github.com/Openmesh-Network/nft-authorise/tracker"
 	abcitypes "github.com/cometbft/cometbft/abci/types"
 	nm "github.com/cometbft/cometbft/node"
 	comettype "github.com/cometbft/cometbft/types"
@@ -31,6 +33,8 @@ type VerificationApp struct {
 	Node                   *nm.Node
 	CurrentMempool         []comettype.Tx
 	Currblockno            int64
+	PolygonCheckpoint      uint64
+	Tracker                *validatorpass_tracker.Tracker
 }
 
 const VALIDATOR_PREALLOCATED_COUNT = 2000
@@ -96,8 +100,26 @@ func (app *VerificationApp) PrepareProposal(_ context.Context, proposal *abcityp
 	}
 	log.Debug("Marshaling Done")
 	transactions := comettype.Tx(transactionBytes[:])
-	proposal.Txs = append(othertx, transactions)
 
+	transactionMessage_checkpoint := types.Transaction{
+		Owner:     "trial",
+		Signature: "",
+		Type:      *types.TransactionType_PolygonCheckpointTransaction.Enum(),
+	}
+	transactionMessage_checkpoint.Data = &types.Transaction_PolygonCheckpointTransactionData{
+		PolygonCheckpointTransactionData: &types.PolygonCheckpointTransactionData{
+			Blockno:   uint64(app.Tracker.LastTrackerHeight),
+			Blockhash: "xyz", //not a necessary field just nice to have for record keeping
+		},
+	}
+	transactionBytes_Checkpoint, err := proto.Marshal(&transactionMessage_checkpoint)
+	if err != nil {
+		panic(err)
+	}
+
+	transactions_checkpoint := comettype.Tx(transactionBytes_Checkpoint[:])
+	proposal.Txs = append(othertx, transactions, transactions_checkpoint)
+	log.Debug(proposal.Txs)
 	return &abcitypes.ResponsePrepareProposal{Txs: proposal.Txs}, nil
 }
 func (app *VerificationApp) ProcessProposal(_ context.Context, proposal *abcitypes.RequestProcessProposal) (*abcitypes.ResponseProcessProposal, error) {
@@ -143,6 +165,7 @@ func (app *VerificationApp) ProcessProposal(_ context.Context, proposal *abcityp
 
 		if code := app.isValid(tx); code != 0 {
 			// log.Error("Error: invalid transaction index %v", i)
+			log.Error("A transaction got error")
 			return &abcitypes.ResponseProcessProposal{Status: abcitypes.ResponseProcessProposal_REJECT}, nil
 		} else {
 			var transaction types.Transaction
@@ -151,8 +174,9 @@ func (app *VerificationApp) ProcessProposal(_ context.Context, proposal *abcityp
 				log.Error("Error unmarshaling transaction data:", err)
 				return &abcitypes.ResponseProcessProposal{Status: abcitypes.ResponseProcessProposal_REJECT}, nil
 			}
-
+			log.Debug(transaction.Type)
 			switch transaction.Type {
+
 			case types.TransactionType_SummaryTransaction:
 
 				summaryData := &types.SummaryTransactionData{}
@@ -168,6 +192,20 @@ func (app *VerificationApp) ProcessProposal(_ context.Context, proposal *abcityp
 				}
 				log.Debug("they are similar")
 
+			case types.TransactionType_PolygonCheckpointTransaction:
+				log.Debug("polygon tx found")
+				checkpointData := &types.PolygonCheckpointTransactionData{}
+				checkpointData = transaction.GetPolygonCheckpointTransactionData()
+
+				if err != nil {
+					log.Error("Cannot decode tx")
+					return &abcitypes.ResponseProcessProposal{Status: abcitypes.ResponseProcessProposal_REJECT}, nil
+				}
+
+				if checkpointData.Blockno > uint64(app.Tracker.LastTrackerHeight) {
+					return &abcitypes.ResponseProcessProposal{Status: abcitypes.ResponseProcessProposal_REJECT}, nil
+				}
+				log.Debug("the height is okay,the proposed height is ", checkpointData.Blockno, "the current height is", app.Tracker.LastTrackerHeight)
 			default:
 				log.Debug(transaction.Type)
 				log.Debug("Unknown transaction type")
@@ -286,6 +324,12 @@ func (app *VerificationApp) FinalizeBlock(_ context.Context, req *abcitypes.Requ
 				log.Debug("Node succesfully registered: ", len(validatorupdates))
 				// log.Debug("Node Registration Transaction Data:", registrationData)
 
+			case types.TransactionType_PolygonCheckpointTransaction:
+				polygonData := &types.PolygonCheckpointTransactionData{}
+				polygonData = transaction.GetPolygonCheckpointTransactionData()
+				app.PolygonCheckpoint = polygonData.Blockno
+				fmt.Println("The polygon checkpoint is ", app.PolygonCheckpoint)
+				txs[i] = &abcitypes.ExecTxResult{}
 			case types.TransactionType_SummaryTransaction:
 				txs[i] = &abcitypes.ExecTxResult{}
 			default:
@@ -485,6 +529,17 @@ func (app *VerificationApp) isValid(tx []byte) uint32 {
 		// log.Debug("Resource Transaction Data:", nodeRegistrationData)
 		return 0
 
+	case types.TransactionType_PolygonCheckpointTransaction:
+		polygonData := &types.PolygonCheckpointTransactionData{}
+		polygonData = transaction.GetPolygonCheckpointTransactionData()
+
+		if polygonData == nil {
+			log.Error("Error unmarshaling resource transaction data:", err)
+			return 1
+		}
+		// log.Debug("Resource Transaction Data:", nodeRegistrationData)
+		return 0
+
 	default:
 		log.Error("Unknown transaction type")
 		return 1

internal/bft/cometbft.go

@@ -8,6 +8,7 @@ import (
 	"os"
 	"time"
 
+	validatorpass_tracker "github.com/Openmesh-Network/nft-authorise/tracker"
 	cfg "github.com/cometbft/cometbft/config"
 	cmtflags "github.com/cometbft/cometbft/libs/cli/flags"
 	cmtlog "github.com/cometbft/cometbft/libs/log"
@@ -269,6 +270,11 @@ func (inst *Instance) Start(ctx context.Context) {
 	}()
 }
 
+func (i *Instance) SetTracker(tracker *validatorpass_tracker.Tracker) error {
+	i.app.Tracker = tracker
+	return nil
+}
+
 // Stop the CometBFT node
 func (i *Instance) Stop() error {
 	err := i.BftNode.Stop()