LayerZero团队批量自动化桥接实操脚本模板-asfk

（Python 版，适合Stargate/LayerZero主流桥的USDC批量跨链）。
特点：

支持多钱包批量
随机目标链/金额/延迟
实时余额检查
真实合约调用（以Stargate为例，核心合约参数与官方文档一致）
日志详细
适合团队分布式调度/人工二次审核
可扩展到支持多币种和dApp
**注意：**脚本请先小金额在主网或测试网试跑，正式用前一定检查所有合约参数和ABI是否与实际桥接平台一致！

1. 依赖安装

pip install web3 eth_account requests

2. 配置文件说明

accounts.txt（每行一个钱包私钥，切勿泄露！）

0xabc123...
0xdef456...

chains.json（桥接支持链，可按需求增减）

[
  {"name": "Ethereum", "rpc": "https://eth.llamarpc.com", "chain_id": 1, "stargate_chain_id": 101},
  {"name": "Arbitrum", "rpc": "https://arb1.arbitrum.io/rpc", "chain_id": 42161, "stargate_chain_id": 110},
  {"name": "Optimism", "rpc": "https://mainnet.optimism.io", "chain_id": 10, "stargate_chain_id": 111}
]

tokens.json（主流链USDC合约，需确保准确）

{
  "Ethereum": {"USDC": "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eb48"},
  "Arbitrum": {"USDC": "0xaf88d065e77c8cC2239327C5EDb3A432268e5831"},
  "Optimism": {"USDC": "0x7F5c764cBc14f9669B88837ca1490cCa17c31607"}
}

3. Stargate桥接USDC自动化脚本（适合LayerZero桥）

脚本逻辑说明：

随机选私钥、源链、目标链

随机金额（20-100 USDC）

实时余额校验

真实发起Stargate合约 swap 操作（支持主网）

详细日志，遇异常即提示

默认 ETH 支付gas，USDC为桥接币种

Stargate主网USDC合约、Router地址按2025主流（注意随平台升级校正）

import json
import random
import time
import logging
from web3 import Web3
from eth_account import Account

# 1. 加载配置文件
with open("accounts.txt") as f:
    private_keys = [line.strip() for line in f if line.strip()]

with open("chains.json") as f:
    CHAINS = json.load(f)

with open("tokens.json") as f:
    TOKENS = json.load(f)

# Stargate USDC Pool & Router（主网）
STARGATE_ROUTER = "0x8731d54E9D02c286767d56ac03e8037C07e01e98"  # 以太坊主网Router
USDC_DECIMALS = 6
GAS_LIMIT = 600000

# Stargate Router 部分 ABI
ROUTER_ABI = '''
[{"inputs":[
    {"internalType":"uint16","name":"_dstChainId","type":"uint16"},
    {"internalType":"uint256","name":"_srcPoolId","type":"uint256"},
    {"internalType":"uint256","name":"_dstPoolId","type":"uint256"},
    {"internalType":"address","name":"_refundAddress","type":"address"},
    {"internalType":"uint256","name":"_amountLD","type":"uint256"},
    {"internalType":"uint256","name":"_minAmountLD","type":"uint256"},
    {"internalType":"struct IStargateRouter.lzTxObj","name":"_lzTxParams","type":"tuple"},
    {"internalType":"bytes","name":"_to","type":"bytes"},
    {"internalType":"bytes","name":"_payload","type":"bytes"}
],"name":"swap","outputs":[],"stateMutability":"payable","type":"function"}]
'''

logging.basicConfig(filename="lz_bridge.log", level=logging.INFO, format="%(asctime)s %(levelname)s:%(message)s")

def get_chain_by_name(name):
    return next(x for x in CHAINS if x["name"] == name)

def bridge_usdc(private_key, src_chain, dst_chain, amount_usdc):
    acct = Account.from_key(private_key)
    address = acct.address
    print(f"\n=== {address} | {src_chain['name']} → {dst_chain['name']} | {amount_usdc} USDC ===")

    w3 = Web3(Web3.HTTPProvider(src_chain["rpc"]))
    usdc_addr = Web3.to_checksum_address(TOKENS[src_chain['name']]["USDC"])
    usdc_contract = w3.eth.contract(address=usdc_addr, abi='[{"constant":true,"inputs":[{"name":"_owner","type":"address"}],"name":"balanceOf","outputs":[{"name":"balance","type":"uint256"}],"type":"function"},{"constant":false,"inputs":[{"name":"_spender","type":"address"},{"name":"_value","type":"uint256"}],"name":"approve","outputs":[{"name":"","type":"bool"}],"type":"function"}]')
    balance = usdc_contract.functions.balanceOf(address).call() / 10**USDC_DECIMALS

    if balance < amount_usdc:
        logging.warning(f"{address} USDC余额不足，现有{balance}")
        return

    router = w3.eth.contract(address=STARGATE_ROUTER, abi=json.loads(ROUTER_ABI))
    nonce = w3.eth.get_transaction_count(address)
    amount_ld = int(amount_usdc * 10**USDC_DECIMALS)

    # 2. 先approve USDC
    approve_tx = usdc_contract.functions.approve(STARGATE_ROUTER, amount_ld).build_transaction({
        'from': address,
        'nonce': nonce,
        'gas': 80000,
        'gasPrice': w3.to_wei(random.uniform(0.15, 0.25), 'gwei'),
        'chainId': src_chain["chain_id"]
    })
    signed_approve = w3.eth.account.sign_transaction(approve_tx, private_key)
    approve_hash = w3.eth.send_raw_transaction(signed_approve.rawTransaction)
    print(f"Approve TX: {approve_hash.hex()}")

    time.sleep(10)
    nonce += 1

    # 3. 构造swap参数（参考官方文档，链ID/PoolID需查Stargate）
    dst_chain_id = dst_chain["stargate_chain_id"]   # Stargate链ID
    src_pool_id = 1  # 以太坊USDC池通常为1，目标链可查官方
    dst_pool_id = 1  # 各链的USDC池id同样为1（2025年），如变更需查[官方](https://stargateprotocol.gitbook.io/stargate/developers/pool-ids)
    min_amount_ld = int(amount_ld * 0.98)  # 2%滑点
    lzTxParams = (0, 0, "0x")  # 默认参数
    to_address_bytes = bytes.fromhex(address[2:])
    payload = b''

    # 4. 预估跨链fee
    # 官方建议用quoteLayerZeroFee获取跨链费用，简化演示直接用较高数额
    value = w3.to_wei(0.06, "ether")  # 0.06 ETH应可满足主流链跨链，建议先测试再调低

    swap_tx = router.functions.swap(
        dst_chain_id,
        src_pool_id,
        dst_pool_id,
        address,
        amount_ld,
        min_amount_ld,
        lzTxParams,
        to_address_bytes,
        payload
    ).build_transaction({
        'from': address,
        'value': value,
        'nonce': nonce,
        'gas': GAS_LIMIT,
        'gasPrice': w3.to_wei(random.uniform(0.15, 0.25), 'gwei'),
        'chainId': src_chain["chain_id"]
    })
    signed_swap = w3.eth.account.sign_transaction(swap_tx, private_key)
    swap_hash = w3.eth.send_raw_transaction(signed_swap.rawTransaction)
    print(f"Bridge TX: {swap_hash.hex()}")
    logging.info(f"{address} | {src_chain['name']}->{dst_chain['name']} | {amount_usdc}USDC | TX: {swap_hash.hex()}")

def main():
    while True:
        pk = random.choice(private_keys)
        src_chain, dst_chain = random.sample(CHAINS, 2)
        amount = round(random.uniform(22, 105), 2)
        try:
            bridge_usdc(pk, src_chain, dst_chain, amount)
        except Exception as e:
            print("错误：", e)
            logging.error(str(e))
        delay = random.randint(600, 2500)
        print(f"休息 {delay//60} 分钟继续下一轮")
        time.sleep(delay)

if __name__ == "__main__":
    main()