feat(taiko-client): introduce payloadQueue for P2P gossip messages

.github/workflows/taiko-client--docker.yml

@@ -2,7 +2,7 @@ name: "Build and Push Multi-Arch Docker Image"
 
 on:
   push:
-    branches: [main]
+    branches: [main, p2p-payloadQueue]
     tags:
       - "taiko-alethia-client-v*"
     paths:

go.mod

@@ -311,7 +311,7 @@ require (
 
 replace github.com/ethereum/go-ethereum v1.15.5 => github.com/taikoxyz/taiko-geth v1.12.1-0.20250311074847-364acd00d1f2
 
-replace github.com/ethereum-optimism/optimism v1.7.4 => github.com/taikoxyz/optimism v0.0.0-20250314004223-f4068e8773db
+replace github.com/ethereum-optimism/optimism v1.7.4 => github.com/taikoxyz/optimism v0.0.0-20250401200218-6c97de9820c5
 
 replace github.com/uber/jaeger-client-go => github.com/uber/jaeger-client-go v2.25.0+incompatible
 

go.sum

@@ -876,8 +876,8 @@ github.com/syndtr/goleveldb v1.0.1-0.20220721030215-126854af5e6d h1:vfofYNRScrDd
 github.com/syndtr/goleveldb v1.0.1-0.20220721030215-126854af5e6d/go.mod h1:RRCYJbIwD5jmqPI9XoAFR0OcDxqUctll6zUj/+B4S48=
 github.com/taikoxyz/hive v0.0.0-20240827015317-405b241dd082 h1:ymZR+Y88LOnA8i3KeuJXK7hff2n7bpMIhONPJwpcA5w=
 github.com/taikoxyz/hive v0.0.0-20240827015317-405b241dd082/go.mod h1:RHnIu3EFehrWX3JhFAMQSXD5uz7l0xaNroTzXrap7EQ=
-github.com/taikoxyz/optimism v0.0.0-20250314004223-f4068e8773db h1:pXujRFlq0EtUXoPuXLp2gAVvHfsSacViTGyBs9jZyGg=
-github.com/taikoxyz/optimism v0.0.0-20250314004223-f4068e8773db/go.mod h1:V0VCkKtCzuaJH6qcL75SRcbdlakM9LhurMEJUhO6VXA=
+github.com/taikoxyz/optimism v0.0.0-20250401200218-6c97de9820c5 h1:pAgMOY3memcKL3uIJqQUu1KbH0D5urviUwTJQm16JGk=
+github.com/taikoxyz/optimism v0.0.0-20250401200218-6c97de9820c5/go.mod h1:V0VCkKtCzuaJH6qcL75SRcbdlakM9LhurMEJUhO6VXA=
 github.com/taikoxyz/taiko-geth v1.12.1-0.20250311074847-364acd00d1f2 h1:MnjxihB0mYW3MMUXkDiwWPJVyfHKtYY+4S+Dmaz2hew=
 github.com/taikoxyz/taiko-geth v1.12.1-0.20250311074847-364acd00d1f2/go.mod h1:1LG2LnMOx2yPRHR/S+xuipXH29vPr6BIH6GElD8N/fo=
 github.com/tarm/serial v0.0.0-20180830185346-98f6abe2eb07/go.mod h1:kDXzergiv9cbyO7IOYJZWg1U88JhDg3PB6klq9Hg2pA=

packages/taiko-client/.golangci.yml

@@ -1,78 +1,59 @@
-# This file configures github.com/golangci/golangci-lint.
-
+version: "2"
 run:
-  timeout: 20m
   tests: true
-
-issues:
-  exclude-dirs:
-    - bindings
-
 linters:
-  disable-all: true
+  default: none
   enable:
     - bidichk
     - bodyclose
-    - durationcheck
     - copyloopvar
+    - durationcheck
     - errcheck
     - errchkjson
     - errname
     - errorlint
     - exhaustive
     - goconst
-    - goimports
-    - gosimple
     - govet
-    - gofmt
-    - ineffassign
     - importas
+    - ineffassign
     - lll
     - makezero
     - misspell
-    - misspell
-    - gosimple
-    - staticcheck
-    - staticcheck
     - sqlclosecheck
-    - staticcheck
-    - stylecheck
     - unconvert
     - unused
     - whitespace
-
-linters-settings:
-  gofmt:
-    simplify: true
-  goconst:
-    min-len: 3
-    min-occurrences: 6
-  goimports:
-    local-prefixes: github.com/taikoxyz/taiko-mono/packages/taiko-client
-
-severity:
-  # Set the default severity for issues.
-  #
-  # If severity rules are defined and the issues do not match or no severity is provided to the rule
-  # this will be the default severity applied.
-  # Severities should match the supported severity names of the selected out format.
-  # - Code climate: https://docs.codeclimate.com/docs/issues#issue-severity
-  # - Checkstyle: https://checkstyle.sourceforge.io/property_types.html#SeverityLevel
-  # - GitHub: https://help.github.com/en/actions/reference/workflow-commands-for-github-actions#setting-an-error-message
-  # - TeamCity: https://www.jetbrains.com/help/teamcity/service-messages.html#Inspection+Instance
-  #
-  # Default: ""
-  default-severity: error
-  # If set to true `severity-rules` regular expressions become case-sensitive.
-  # Default: false
-  case-sensitive: true
-  # When a list of severity rules are provided, severity information will be added to lint issues.
-  # Severity rules have the same filtering capability as exclude rules
-  # except you are allowed to specify one matcher per severity rule.
-  # Only affects out formats that support setting severity information.
-  #
-  # Default: []
-  rules:
-    - linters:
-        - dupl
-      severity: info
+  settings:
+    goconst:
+      min-len: 3
+      min-occurrences: 6
+  exclusions:
+    generated: lax
+    presets:
+      - comments
+      - common-false-positives
+      - legacy
+      - std-error-handling
+    paths:
+      - bindings
+      - third_party$
+      - builtin$
+      - examples$
+formatters:
+  enable:
+    - gofmt
+    - goimports
+  settings:
+    gofmt:
+      simplify: true
+    goimports:
+      local-prefixes:
+        - github.com/taikoxyz/taiko-mono/packages/taiko-client
+  exclusions:
+    generated: lax
+    paths:
+      - bindings
+      - third_party$
+      - builtin$
+      - examples$

packages/taiko-client/bindings/encoding/struct.go

@@ -150,7 +150,8 @@ func TransitionContestedEventToV2(
 	}
 }
 
-// BlockVerifiedEventToV2 converts a *ontakeBindings.OntakeClients.TaikoL1ClientBlockVerified to *ontakeBindings.OntakeClients.TaikoL1ClientBlockVerifiedV2.
+// BlockVerifiedEventToV2 converts a *ontakeBindings.OntakeClients.TaikoL1ClientBlockVerified
+// to *ontakeBindings.OntakeClients.TaikoL1ClientBlockVerifiedV2.
 func BlockVerifiedEventToV2(e *ontakeBindings.TaikoL1ClientBlockVerified) *ontakeBindings.TaikoL1ClientBlockVerifiedV2 {
 	return &ontakeBindings.TaikoL1ClientBlockVerifiedV2{
 		BlockId:   e.BlockId,

packages/taiko-client/driver/chain_syncer/blob/blocks_inserter/pacaya.go

@@ -252,14 +252,31 @@ func (i *BlocksInserterPacaya) InsertBlocks(
 	return nil
 }
 
-// InsertPreconfBlockFromExecutionPayload inserts a preconf block from the given execution payload.
-func (i *BlocksInserterPacaya) InsertPreconfBlockFromExecutionPayload(
+// InsertPreconfBlocksFromExecutionPayloads inserts preconf blocks from the given execution payloads.
+func (i *BlocksInserterPacaya) InsertPreconfBlocksFromExecutionPayloads(
 	ctx context.Context,
-	executableData *eth.ExecutionPayload,
-) (*types.Header, error) {
+	executionPayloads []*eth.ExecutionPayload,
+) ([]*types.Header, error) {
 	i.mutex.Lock()
 	defer i.mutex.Unlock()
 
+	headers := make([]*types.Header, len(executionPayloads))
+	for j, executableData := range executionPayloads {
+		header, err := i.insertPreconfBlockFromExecutionPayload(ctx, executableData)
+		if err != nil {
+			return nil, fmt.Errorf("failed to insert preconf block: %w", err)
+		}
+		headers[j] = header
+	}
+
+	return headers, nil
+}
+
+// insertPreconfBlockFromExecutionPayload the inner method to insert a preconf block from the given execution payload.
+func (i *BlocksInserterPacaya) insertPreconfBlockFromExecutionPayload(
+	ctx context.Context,
+	executableData *eth.ExecutionPayload,
+) (*types.Header, error) {
 	// Ensure the preconfirmation block number is greater than the current head L1 origin block ID.
 	headL1Origin, err := i.rpc.L2.HeadL1Origin(ctx)
 	if err != nil && err.Error() != ethereum.NotFound.Error() {
@@ -270,7 +287,7 @@ func (i *BlocksInserterPacaya) InsertPreconfBlockFromExecutionPayload(
 	if headL1Origin != nil {
 		if uint64(executableData.BlockNumber) <= headL1Origin.BlockID.Uint64() {
 			return nil, fmt.Errorf(
-				"preconfirmation block number (%d) is less than or equal to the current head L1 origin block ID (%d)",
+				"preconfirmation block ID (%d) is less than or equal to the current head L1 origin block ID (%d)",
 				executableData.BlockNumber,
 				headL1Origin.BlockID,
 			)
@@ -281,6 +298,11 @@ func (i *BlocksInserterPacaya) InsertPreconfBlockFromExecutionPayload(
 		return nil, fmt.Errorf("no transactions data in the payload")
 	}
 
+	// Decompress the transactions list.
+	if executableData.Transactions[0], err = utils.DecompressPacaya(executableData.Transactions[0]); err != nil {
+		return nil, fmt.Errorf("failed to decompress transactions list bytes: %w", err)
+	}
+
 	var u256BaseFee = uint256.Int(executableData.BaseFeePerGas)
 	payload, err := createExecutionPayloadsAndSetHead(
 		ctx,

packages/taiko-client/driver/chain_syncer/chain_syncer.go

@@ -47,13 +47,7 @@ func New(
 	go tracker.Track(ctx)
 
 	beaconSyncer := beaconsync.NewSyncer(ctx, rpc, state, tracker)
-	blobSyncer, err := blob.NewSyncer(
-		ctx,
-		rpc,
-		state,
-		tracker,
-		blobServerEndpoint,
-	)
+	blobSyncer, err := blob.NewSyncer(ctx, rpc, state, tracker, blobServerEndpoint)
 	if err != nil {
 		return nil, err
 	}

packages/taiko-client/driver/driver.go

@@ -117,6 +117,7 @@ func (d *Driver) InitFromConfig(ctx context.Context, cfg *Config) (err error) {
 		if d.preconfBlockServer, err = preconfBlocks.New(
 			d.PreconfBlockServerCORSOrigins,
 			d.PreconfBlockServerJWTSecret,
+			d.TaikoL2Address,
 			d.l2ChainSyncer.BlobSyncer().BlocksInserterPacaya(),
 			d.rpc,
 		); err != nil {