feat: use sqlite on claimsponsor

claimsponsor/e2e_test.go

@@ -31,7 +31,7 @@ func TestE2EL1toEVML2(t *testing.T) {
 	go bridgeSyncL1.Start(ctx)
 
 	// start claim sponsor
-	dbPathClaimSponsor := t.TempDir()
+	dbPathClaimSponsor := path.Join(t.TempDir(), "file::memory:?cache=shared")
 	claimer, err := claimsponsor.NewEVMClaimSponsor(
 		log.GetDefaultLogger(),
 		dbPathClaimSponsor,
@@ -71,7 +71,7 @@ func TestE2EL1toEVML2(t *testing.T) {
 
 		// Request to sponsor claim
 		globalIndex := bridgesync.GenerateGlobalIndex(true, 0, uint32(i))
-		err = claimer.AddClaimToQueue(ctx, &claimsponsor.Claim{
+		err = claimer.AddClaimToQueue(&claimsponsor.Claim{
 			LeafType:            0,
 			ProofLocalExitRoot:  localProof,
 			ProofRollupExitRoot: rollupProof,
@@ -90,7 +90,7 @@ func TestE2EL1toEVML2(t *testing.T) {
 		// Wait until success
 		succeed := false
 		for i := 0; i < 10; i++ {
-			claim, err := claimer.GetClaim(ctx, globalIndex)
+			claim, err := claimer.GetClaim(globalIndex)
 			require.NoError(t, err)
 			if claim.Status == claimsponsor.FailedClaimStatus {
 				require.NoError(t, errors.New("claim failed"))

claimsponsor/evmclaimsponsor.go

@@ -168,7 +168,7 @@ func (c *EVMClaimSponsor) claimStatus(ctx context.Context, id string) (ClaimStat
 	switch res.Status {
 	case ethtxtypes.MonitoredTxStatusCreated,
 		ethtxtypes.MonitoredTxStatusSent:
-		return WIPStatus, nil
+		return WIPClaimStatus, nil
 	case ethtxtypes.MonitoredTxStatusFailed:
 		return FailedClaimStatus, nil
 	case ethtxtypes.MonitoredTxStatusMined,

claimsponsor/migrations/claimsponsor0001.sql

@@ -0,0 +1,20 @@
+-- +migrate Down
+DROP TABLE IF EXISTS claim;
+
+-- +migrate Up
+CREATE TABLE claim (
+	leaf_type              INT NOT NULL,
+	proof_local_exit_root  VARCHAR NOT NULL,
+	proof_rollup_exit_root VARCHAR NOT NULL, 
+	global_index           VARCHAR NOT NULL,
+	mainnet_exit_root      VARCHAR NOT NULL,
+	rollup_exit_root       VARCHAR NOT NULL,
+	origin_network         INT NOT NULL,
+	origin_token_address   VARCHAR NOT NULL,
+	destination_network    INT NOT NULL,
+	destination_address    VARCHAR NOT NULL,
+	amount                 VARCHAR NOT NULL,
+	metadata               VARCHAR,
+	status                 VARCHAR NOT NULL,
+	tx_id                  VARCHAR NOT NULL
+);

claimsponsor/migrations/migrations.go

@@ -0,0 +1,21 @@
+package migrations
+
+import (
+	_ "embed"
+
+	"github.com/0xPolygon/cdk/db"
+	"github.com/0xPolygon/cdk/db/types"
+)
+
+//go:embed claimsponsor0001.sql
+var mig001 string
+
+func RunMigrations(dbPath string) error {
+	migrations := []types.Migration{
+		{
+			ID:  "claimsponsor0001",
+			SQL: mig001,
+		},
+	}
+	return db.RunMigrations(dbPath, migrations)
+}

rpc/bridge.go

@@ -229,7 +229,7 @@ func (b *BridgeEndpoints) SponsorClaim(claim claimsponsor.Claim) (interface{}, r
 			fmt.Sprintf("this client only sponsors claims for network %d", b.networkID),
 		)
 	}
-	if err := b.sponsor.AddClaimToQueue(ctx, &claim); err != nil {
+	if err := b.sponsor.AddClaimToQueue(&claim); err != nil {
 		return zeroHex, rpc.NewRPCError(rpc.DefaultErrorCode, fmt.Sprintf("error adding claim to the queue %s", err))
 	}
 	return nil, nil
@@ -250,7 +250,7 @@ func (b *BridgeEndpoints) GetSponsoredClaimStatus(globalIndex *big.Int) (interfa
 	if b.sponsor == nil {
 		return zeroHex, rpc.NewRPCError(rpc.DefaultErrorCode, "this client does not support claim sponsoring")
 	}
-	claim, err := b.sponsor.GetClaim(ctx, globalIndex)
+	claim, err := b.sponsor.GetClaim(globalIndex)
 	if err != nil {
 		return zeroHex, rpc.NewRPCError(rpc.DefaultErrorCode, fmt.Sprintf("failed to get claim status, error: %s", err))
 	}

rpc/bridge_interfaces.go

@@ -35,6 +35,6 @@ type L1InfoTreer interface {
 }
 
 type ClaimSponsorer interface {
-	AddClaimToQueue(ctx context.Context, claim *claimsponsor.Claim) error
-	GetClaim(ctx context.Context, globalIndex *big.Int) (*claimsponsor.Claim, error)
+	AddClaimToQueue(claim *claimsponsor.Claim) error
+	GetClaim(globalIndex *big.Int) (*claimsponsor.Claim, error)
 }