feat: ETH compatibility in Filecoin : Support Homestead and EIP-155 Ethereum transactions("legacy" transactions) in Filecoin

.circleci/config.yml

@@ -747,6 +747,12 @@ workflows:
  - build
  suite: itest-eth_hash_lookup
  target: "./itests/eth_hash_lookup_test.go"
+ - test:
+ name: test-itest-eth_legacy_transactions
+ requires:
+ - build
+ suite: itest-eth_legacy_transactions
+ target: "./itests/eth_legacy_transactions_test.go"
  - test:
  name: test-itest-eth_transactions
  requires:

build/openrpc/full.json

@@ -6543,6 +6543,7 @@
  "gas": "0x5",
  "maxFeePerGas": "0x0",
  "maxPriorityFeePerGas": "0x0",
+ "gasPrice": "0x0",
  "accessList": [
  "0x37690cfec6c1bf4c3b9288c7a5d783e98731e90b0a4c177c2a374c7a9427355e"
  ],
@@ -6598,6 +6599,10 @@
  "title": "number",
  "type": "number"
  },
+ "gasPrice": {
+ "additionalProperties": false,
+ "type": "object"
+ },
  "hash": {
  "items": {
  "description": "Number is a number",
@@ -6738,6 +6743,7 @@
  "gas": "0x5",
  "maxFeePerGas": "0x0",
  "maxPriorityFeePerGas": "0x0",
+ "gasPrice": "0x0",
  "accessList": [
  "0x37690cfec6c1bf4c3b9288c7a5d783e98731e90b0a4c177c2a374c7a9427355e"
  ],
@@ -6793,6 +6799,10 @@
  "title": "number",
  "type": "number"
  },
+ "gasPrice": {
+ "additionalProperties": false,
+ "type": "object"
+ },
  "hash": {
  "items": {
  "description": "Number is a number",
@@ -6925,6 +6935,7 @@
  "gas": "0x5",
  "maxFeePerGas": "0x0",
  "maxPriorityFeePerGas": "0x0",
+ "gasPrice": "0x0",
  "accessList": [
  "0x37690cfec6c1bf4c3b9288c7a5d783e98731e90b0a4c177c2a374c7a9427355e"
  ],
@@ -6980,6 +6991,10 @@
  "title": "number",
  "type": "number"
  },
+ "gasPrice": {
+ "additionalProperties": false,
+ "type": "object"
+ },
  "hash": {
  "items": {
  "description": "Number is a number",
@@ -7129,6 +7144,7 @@
  "gas": "0x5",
  "maxFeePerGas": "0x0",
  "maxPriorityFeePerGas": "0x0",
+ "gasPrice": "0x0",
  "accessList": [
  "0x37690cfec6c1bf4c3b9288c7a5d783e98731e90b0a4c177c2a374c7a9427355e"
  ],
@@ -7184,6 +7200,10 @@
  "title": "number",
  "type": "number"
  },
+ "gasPrice": {
+ "additionalProperties": false,
+ "type": "object"
+ },
  "hash": {
  "items": {
  "description": "Number is a number",

build/openrpc/gateway.json

@@ -3077,6 +3077,7 @@
  "gas": "0x5",
  "maxFeePerGas": "0x0",
  "maxPriorityFeePerGas": "0x0",
+ "gasPrice": "0x0",
  "accessList": [
  "0x37690cfec6c1bf4c3b9288c7a5d783e98731e90b0a4c177c2a374c7a9427355e"
  ],
@@ -3132,6 +3133,10 @@
  "title": "number",
  "type": "number"
  },
+ "gasPrice": {
+ "additionalProperties": false,
+ "type": "object"
+ },
  "hash": {
  "items": {
  "description": "Number is a number",
@@ -3281,6 +3286,7 @@
  "gas": "0x5",
  "maxFeePerGas": "0x0",
  "maxPriorityFeePerGas": "0x0",
+ "gasPrice": "0x0",
  "accessList": [
  "0x37690cfec6c1bf4c3b9288c7a5d783e98731e90b0a4c177c2a374c7a9427355e"
  ],
@@ -3336,6 +3342,10 @@
  "title": "number",
  "type": "number"
  },
+ "gasPrice": {
+ "additionalProperties": false,
+ "type": "object"
+ },
  "hash": {
  "items": {
  "description": "Number is a number",

chain/consensus/common.go

@@ -287,7 +287,7 @@ func checkBlockMessages(ctx context.Context, sm *stmgr.StateManager, cs *store.C
  return xerrors.Errorf("failed to resolve key addr: %w", err)
  }
 
- if err := AuthenticateMessage(m, kaddr); err != nil {
+ if err := AuthenticateMessage(m, kaddr, nv); err != nil {
  return xerrors.Errorf("failed to validate signature: %w", err)
  }
 

chain/consensus/signatures.go

@@ -16,36 +16,51 @@ import (
 // SignedMessage was signed by the indicated Address, computing the correct
 // signature payload depending on the signature type. The supplied Address type
 // must be recognized by the registered verifier for the signature type.
-func AuthenticateMessage(msg *types.SignedMessage, signer address.Address) error {
+func AuthenticateMessage(msg *types.SignedMessage, signer address.Address, nv network.Version) error {
  var digest []byte
+ signatureType := msg.Signature.Type
+ signatureCopy := msg.Signature
 
- typ := msg.Signature.Type
- switch typ {
+ switch signatureType {
  case crypto.SigTypeDelegated:
- txArgs, err := ethtypes.EthTxArgsFromUnsignedEthMessage(&msg.Message)
+ signatureCopy.Data = make([]byte, len(msg.Signature.Data))
+ copy(signatureCopy.Data, msg.Signature.Data)
+ ethTx, err := ethtypes.EthTransactionFromSignedFilecoinMessage(msg)
  if err != nil {
- return xerrors.Errorf("failed to reconstruct eth transaction: %w", err)
+ return xerrors.Errorf("failed to reconstruct Ethereum transaction: %w", err)
  }
- roundTripMsg, err := txArgs.ToUnsignedMessage(msg.Message.From)
+
+ if ethTx.Type() != ethtypes.EIP1559TxType {
+ if nv < network.Version23 {
+ return xerrors.Errorf("Legacy ETH tx message not supported in network version %d,"+
+ "need version %d", nv, network.Version23)
+ }
+ }
+
+ filecoinMsg, err := ethTx.ToUnsignedFilecoinMessage(msg.Message.From)
  if err != nil {
- return xerrors.Errorf("failed to reconstruct filecoin msg: %w", err)
+ return xerrors.Errorf("failed to reconstruct Filecoin message: %w", err)
  }
 
- if !msg.Message.Equals(roundTripMsg) {
- return xerrors.New("ethereum tx failed to roundtrip")
+ if !msg.Message.Equals(filecoinMsg) {
+ return xerrors.New("Ethereum transaction roundtrip mismatch")
  }
 
- rlpEncodedMsg, err := txArgs.ToRlpUnsignedMsg()
+ rlpEncodedMsg, err := ethTx.ToRlpUnsignedMsg()
  if err != nil {
- return xerrors.Errorf("failed to repack eth rlp message: %w", err)
+ return xerrors.Errorf("failed to encode RLP message: %w", err)
  }
  digest = rlpEncodedMsg
+ signatureCopy.Data, err = ethTx.ToVerifiableSignature(signatureCopy.Data)
+ if err != nil {
+ return xerrors.Errorf("failed to verify signature: %w", err)
+ }
  default:
  digest = msg.Message.Cid().Bytes()
  }
 
- if err := sigs.Verify(&msg.Signature, signer, digest); err != nil {
- return xerrors.Errorf("message %s has invalid signature (type %d): %w", msg.Cid(), typ, err)
+ if err := sigs.Verify(&signatureCopy, signer, digest); err != nil {
+ return xerrors.Errorf("invalid signature for message %s (type %d): %w", msg.Cid(), signatureType, err)
  }
  return nil
 }

chain/messagepool/messagepool.go

@@ -824,7 +824,16 @@ func (mp *MessagePool) VerifyMsgSig(m *types.SignedMessage) error {
  return nil
  }
 
- if err := consensus.AuthenticateMessage(m, m.Message.From); err != nil {
+ mp.curTsLk.RLock()
+ curTs := mp.curTs
+ mp.curTsLk.RUnlock()
+ epoch := curTs.Height() + 1
+ nv, err := mp.getNtwkVersion(epoch)
+ if err != nil {
+ return xerrors.Errorf("failed to get network version: %w", err)
+ }
+
+ if err := consensus.AuthenticateMessage(m, m.Message.From, nv); err != nil {
  return xerrors.Errorf("failed to validate signature: %w", err)
  }
 

chain/messagesigner/messagesigner.go

@@ -196,7 +196,7 @@ func (ms *MessageSigner) dstoreKey(addr address.Address) datastore.Key {
 
 func SigningBytes(msg *types.Message, sigType address.Protocol) ([]byte, error) {
  if sigType == address.Delegated {
- txArgs, err := ethtypes.EthTxArgsFromUnsignedEthMessage(msg)
+ txArgs, err := ethtypes.Eth1559TxArgsFromUnsignedFilecoinMessage(msg)
  if err != nil {
  return nil, xerrors.Errorf("failed to reconstruct eth transaction: %w", err)
  }