pass linter

aggoracle/oracle.go

@@ -6,6 +6,7 @@ import (
 	"math/big"
 	"time"
 
+	"github.com/0xPolygon/cdk/db"
 	"github.com/0xPolygon/cdk/etherman"
 	"github.com/0xPolygon/cdk/l1infotreesync"
 	"github.com/0xPolygon/cdk/log"
@@ -65,7 +66,7 @@ func (a *AggOracle) Start(ctx context.Context) {
 			if err != nil {
 				if errors.Is(err, l1infotreesync.ErrBlockNotProcessed) {
 					log.Debugf("syncer is not ready for the block %d", blockNumToFetch)
-				} else if errors.Is(err, l1infotreesync.ErrNotFound) {
+				} else if errors.Is(err, db.ErrNotFound) {
 					blockNumToFetch = 0
 					log.Debugf("syncer has not found any GER until block %d", blockNumToFetch)
 				} else {

bridgesync/downloader.go

@@ -9,6 +9,7 @@ import (
 	"github.com/0xPolygon/cdk-contracts-tooling/contracts/etrog/polygonzkevmbridge"
 	"github.com/0xPolygon/cdk-contracts-tooling/contracts/etrog/polygonzkevmbridgev2"
 	rpcTypes "github.com/0xPolygon/cdk-rpc/types"
+	"github.com/0xPolygon/cdk/db"
 	"github.com/0xPolygon/cdk/sync"
 	tree "github.com/0xPolygon/cdk/tree/types"
 	"github.com/ethereum/go-ethereum"
@@ -181,7 +182,7 @@ func setClaimCalldata(client EthClienter, bridge common.Address, txHash common.H
 			callStack.Push(c)
 		}
 	}
-	return ErrNotFound
+	return db.ErrNotFound
 }
 
 func setClaimIfFoundOnInput(input []byte, claim *Claim) (bool, error) {

bridgesync/processor.go

@@ -23,7 +23,6 @@ import (
 var (
 	// ErrBlockNotProcessed indicates that the given block(s) have not been processed yet.
 	ErrBlockNotProcessed = errors.New("given block(s) have not been processed yet")
-	ErrNotFound          = errors.New("not found")
 )
 
 // Bridge is the representation of a bridge event
@@ -184,7 +183,7 @@ func (p *processor) queryBlockRange(tx db.Querier, fromBlock, toBlock uint64, ta
 	`, table), fromBlock, toBlock)
 	if err != nil {
 		if errors.Is(err, sql.ErrNoRows) {
-			return nil, ErrNotFound
+			return nil, db.ErrNotFound
 		}
 		return nil, err
 	}

claimsponsor/claimsponsor.go

@@ -9,6 +9,7 @@ import (
 	"time"
 
 	dbCommon "github.com/0xPolygon/cdk/common"
+	"github.com/0xPolygon/cdk/db"
 	"github.com/0xPolygon/cdk/log"
 	"github.com/0xPolygon/cdk/sync"
 	"github.com/ethereum/go-ethereum/common"
@@ -31,7 +32,6 @@ const (
 
 var (
 	ErrInvalidClaim = errors.New("invalid claim")
-	ErrNotFound     = errors.New("not found")
 )
 
 // Claim representation of a claim event
@@ -129,7 +129,7 @@ func (c *ClaimSponsor) Start(ctx context.Context) {
 		if err2 != nil {
 			err = err2
 			tx.Rollback()
-			if errors.Is(err, ErrNotFound) {
+			if errors.Is(err, db.ErrNotFound) {
 				log.Debugf("queue is empty")
 				err = nil
 				time.Sleep(c.waitOnEmptyQueue)
@@ -250,7 +250,7 @@ func (c *ClaimSponsor) AddClaimToQueue(ctx context.Context, claim *Claim) error
 	}
 
 	_, err = getClaim(tx, claim.GlobalIndex)
-	if !errors.Is(err, ErrNotFound) {
+	if !errors.Is(err, db.ErrNotFound) {
 		if err != nil {
 			tx.Rollback()
 
@@ -271,7 +271,7 @@ func (c *ClaimSponsor) AddClaimToQueue(ctx context.Context, claim *Claim) error
 
 	var queuePosition uint64
 	lastQueuePosition, _, err := getLastQueueIndex(tx)
-	if errors.Is(err, ErrNotFound) {
+	if errors.Is(err, db.ErrNotFound) {
 		queuePosition = 0
 	} else if err != nil {
 		tx.Rollback()
@@ -311,7 +311,7 @@ func (c *ClaimSponsor) getClaimByQueueIndex(ctx context.Context, queueIndex uint
 		return nil, err
 	}
 	if globalIndexBytes == nil {
-		return nil, ErrNotFound
+		return nil, db.ErrNotFound
 	}
 
 	return getClaim(tx, new(big.Int).SetBytes(globalIndexBytes))
@@ -349,7 +349,7 @@ func getIndex(iter iter.KV) (uint64, *big.Int, error) {
 		return 0, nil, err
 	}
 	if k == nil {
-		return 0, nil, ErrNotFound
+		return 0, nil, db.ErrNotFound
 	}
 	globalIndex := new(big.Int).SetBytes(v)
 
@@ -372,7 +372,7 @@ func getClaim(tx kv.Tx, globalIndex *big.Int) (*Claim, error) {
 		return nil, err
 	}
 	if claimBytes == nil {
-		return nil, ErrNotFound
+		return nil, db.ErrNotFound
 	}
 	claim := &Claim{}
 	err = json.Unmarshal(claimBytes, claim)

cmd/run.go

@@ -79,7 +79,9 @@ func start(cliCtx *cli.Context) error {
 	claimSponsor := runClaimSponsorIfNeeded(cliCtx.Context, components, l2Client, c.ClaimSponsor)
 	l1BridgeSync := runBridgeSyncL1IfNeeded(cliCtx.Context, components, c.BridgeL1Sync, reorgDetectorL1, l1Client)
 	l2BridgeSync := runBridgeSyncL2IfNeeded(cliCtx.Context, components, c.BridgeL2Sync, reorgDetectorL2, l2Client)
-	lastGERSync := runLastGERSyncIfNeeded(cliCtx.Context, components, c.LastGERSync, reorgDetectorL2, l2Client, l1InfoTreeSync)
+	lastGERSync := runLastGERSyncIfNeeded(
+		cliCtx.Context, components, c.LastGERSync, reorgDetectorL2, l2Client, l1InfoTreeSync,
+	)
 
 	for _, component := range components {
 		switch component {

db/meddler.go

@@ -22,7 +22,7 @@ func initMeddler() {
 	meddler.Register("address", AddressMeddler{})
 }
 
-func SQLiteErr(err error) (sqlite.Error, bool) {
+func SQLiteErr(err error) (*sqlite.Error, bool) {
 	sqliteErr := &sqlite.Error{}
 	if ok := errors.As(err, sqliteErr); ok {
 		return sqliteErr, true
@@ -189,7 +189,10 @@ func (b AddressMeddler) PreRead(fieldAddr interface{}) (scanTarget interface{},
 
 // PostRead is called after a Scan operation for fields that have the ProofMeddler
 func (b AddressMeddler) PostRead(fieldPtr, scanTarget interface{}) error {
-	ptr := scanTarget.(*string)
+	ptr, ok := scanTarget.(*string)
+	if !ok {
+		return errors.New("scanTarget is not *string")
+	}
 	if ptr == nil {
 		return errors.New("AddressMeddler.PostRead: nil pointer")
 	}

db/sqlite.go

@@ -7,6 +7,10 @@ import (
 	_ "github.com/mattn/go-sqlite3"
 )
 
+const (
+	UniqueConstrain = 1555
+)
+
 var (
 	ErrNotFound = errors.New("not found")
 )