Parallel decrypts: sync decryption results

Dockerfile

@@ -73,9 +73,11 @@ COPY nitro-overrides/precompiles/FheOps.go precompiles/FheOps.go
 COPY nitro-overrides/precompiles/precompile.go precompiles/precompile.go
 COPY nitro-overrides/arbos/block_processor.go arbos/block_processor.go
 COPY nitro-overrides/arbos/parallel_tx_processor.go arbos/parallel_tx_processor.go
+COPY nitro-overrides/arbos/parse_l2.go arbos/parse_l2.go
 COPY nitro-overrides/gethhook/geth-hook.go gethhook/geth-hook.go
 COPY nitro-overrides/execution/gethexec/sequencer.go execution/gethexec/sequencer.go
 COPY nitro-overrides/execution/gethexec/tx_ops_graph.go execution/gethexec/tx_ops_graph.go
+COPY nitro-overrides/execution/gethexec/executionengine.go execution/gethexec/executionengine.go
 
 RUN go mod tidy
 

nitro-overrides/arbos/block_processor.go

@@ -125,9 +125,9 @@ type SequencingHooks struct {
 	ConditionalOptionsForTx []*arbitrum_types.ConditionalOptions
 
 	// Fhenix specific
-	NotifyCt         func(*types.Transaction, *arbitrum_types.ConditionalOptions, *fheos.PendingDecryption)
-	NotifyDecryptRes func(*fheos.PendingDecryption) error
-	OnTxSuccess      func(*types.Transaction)
+	NotifyCt              func(*types.Transaction, *arbitrum_types.ConditionalOptions, *fheos.PendingDecryption)
+	NotifyDecryptRes      func(*fheos.PendingDecryption) error
+	SerializeTxDecryptRes func(*types.Transaction) ([]byte, error)
 }
 
 func NoopSequencingHooks() *SequencingHooks {
@@ -143,7 +143,7 @@ func NoopSequencingHooks() *SequencingHooks {
 		nil,
 		func(*types.Transaction, *arbitrum_types.ConditionalOptions, *fheos.PendingDecryption) {},
 		func(*fheos.PendingDecryption) error { return nil },
-		func(*types.Transaction) {},
+		func(*types.Transaction) ([]byte, error) { return nil, nil },
 	}
 }
 
@@ -403,8 +403,6 @@ func ProduceBlockAdvanced(
 				}
 			}
 			continue
-		} else {
-			hooks.OnTxSuccess(tx)
 		}
 
 		if tx.Type() == types.ArbitrumInternalTxType && result.Err != nil {