allow pool to be blocked

db/migrations/pool/0006.sql

@@ -0,0 +1,8 @@
+-- +migrate Up
+CREATE TABLE pool.blocked
+(
+    addr varchar NOT NULL PRIMARY KEY
+);
+
+-- +migrate Down
+DROP TABLE pool.blocked;

pool/errors.go

@@ -27,6 +27,9 @@ var (
 	// ErrInvalidSender is returned if the transaction contains an invalid signature.
 	ErrInvalidSender = errors.New("invalid sender")
 
+	// ErrInvalidSender is returned if the transaction is sent by a blocked account.
+	ErrBlockedSender = errors.New("blocked sender")
+
 	// ErrNonceTooLow is returned if the nonce of a transaction is lower than the
 	// one present in the local chain.
 	ErrNonceTooLow = errors.New("nonce too low")

pool/interfaces.go

@@ -32,6 +32,7 @@ type storage interface {
 	GetTxZkCountersByHash(ctx context.Context, hash common.Hash) (*state.ZKCounters, error)
 	DeleteTransactionByHash(ctx context.Context, hash common.Hash) error
 	MarkWIPTxsAsPending(ctx context.Context) error
+	IsAddressBlocked(ctx context.Context, address common.Address) (bool, error)
 }
 
 type stateInterface interface {

pool/pgpoolstorage/pgpoolstorage.go

@@ -622,3 +622,19 @@ func (p *PostgresPoolStorage) UpdateTxWIPStatus(ctx context.Context, hash common
 	}
 	return nil
 }
+
+// IsAddressBlocked check if an address is added to the blocked table
+func (p *PostgresPoolStorage) IsAddressBlocked(ctx context.Context, address common.Address) (bool, error) {
+	sql := `SELECT addr FROM pool.blocked WHERE addr = $1`
+	var addr string
+	err := p.db.QueryRow(ctx, sql, address.String()).Scan(&addr)
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return false, nil
+		} else {
+			return false, err
+		}
+	}
+
+	return true, nil
+}

pool/pool.go

@@ -197,6 +197,14 @@ func (p *Pool) validateTx(ctx context.Context, tx types.Transaction) error {
 		return ErrInvalidSender
 	}
 
+	// check if sender is blocked
+	blocked, err := p.storage.IsAddressBlocked(ctx, from)
+	if err != nil {
+		return err
+	} else if blocked {
+		return ErrBlockedSender
+	}
+
 	lastL2BlockNumber, err := p.state.GetLastL2BlockNumber(ctx, nil)
 	if err != nil {
 		return err