lisa99 сказал(а):
отправка газа и одновременно снятие, чтобы не дать вклиниться другому запросу в мемпуле ?
Да. Вот готовый код на js для трансфера токена
JavaScript:
Скопировать в буфер обмена
const { ethers } = require('ethers');
const { FlashbotsBundleProvider, FlashbotsBundleResolution } = require('@flashbots/ethers-provider-bundle');
const readline = require('readline');
const { exit } = require('process');
const myrivateKey = '...' // донатер газа aka твоя приватка
const provider = new ethers.providers.JsonRpcProvider('
https://rpc.ankr.com/eth');
const mywallet = new ethers.Wallet(myrivateKey, provider);
let flashbotsProvider;
async function setupFlashbotsProvider() {
flashbotsProvider = await FlashbotsBundleProvider.create(provider, mywallet)
// Дополнительный код, зависящий от flashbotsProvider
}
const rl = readline.createInterface({
input: process.stdin,
output: process.stdout
});
// Функция для запроса ввода от пользователя
function askQuestion(question) {
return new Promise((resolve) => {
rl.question(question, (input) => resolve(input.trim()));
});
}
async function main() {
await setupFlashbotsProvider()
const privateKey = await askQuestion("Введите приватный ключ отправителя токена: ");
const wallet = new ethers.Wallet(privateKey, provider);
console.log("Адрес отправителя:", wallet.address);
const tokenAddressInput = await askQuestion("Введите адрес контракта токена: ");
const tokenAddress = ethers.utils.getAddress(tokenAddressInput);
const ERC20_ABI = [
"function balanceOf(address owner) view returns (uint256)",
"function transfer(address to, uint amount) returns (bool)"
];
const tokenContract = new ethers.Contract(tokenAddress, ERC20_ABI, provider);
const tokenBalance = await tokenContract.balanceOf(wallet.address);
console.log(`Баланс токена: ${tokenBalance} wei`);
const gasLimitInput = await askQuestion("Введите gas limit для токена: ");
const gasLimit = Number(gasLimitInput) || 65000;
const gasPrice = await provider.getGasPrice();
const gasPriceWithIncrease = gasPrice.add(gasPrice.div(10));
const totalCostEth = ethers.utils.formatEther(gasPriceWithIncrease.mul(gasLimit));
console.log(`Текущая стоимость транзакции: ${totalCostEth} ETH`);
const answer = await new Promise((resolve) => {
rl.question('Продолжить? (y/n): ', (input) => resolve(input.trim().toLowerCase()));
});
if (answer === 'y') {
// Пользователь согласен, продолжаем выполнение
console.log('Продолжаем операцию...');
} else {
// Пользователь не согласен, завершаем программу
console.log('Отмена операции.');
rl.close();
process.exit();
}
const data = tokenContract.interface.encodeFunctionData("transfer", [mywallet.address, tokenBalance]);
const bundle = [
{
transaction: {
chainId: 1,
to:wallet.address,
value: gasPriceWithIncrease.mul(gasLimit),
type: 1,
gasPrice: gasPriceWithIncrease,
gasLimit: 21000,
},
signer: mywallet
},
{
transaction: {
chainId: 1,
to: tokenAddress,
type: 1,
data: data,
gasPrice: gasPriceWithIncrease,
gasLimit: gasLimit,
},
signer: wallet
},
]
provider.on('block', async (blockNumber) => {
console.log(blockNumber);
try {
const flashbotsTransactionResponse = await flashbotsProvider.sendBundle(bundle, blockNumber + 1);
const bundleResolution = await flashbotsTransactionResponse.wait();
if (bundleResolution === FlashbotsBundleResolution.BundleIncluded) {
console.log(`Congrats, included in ${blockNumber + 1}`);
process.exit(0);
} else if (bundleResolution === FlashbotsBundleResolution.BlockPassedWithoutInclusion) {
console.log(`Not included in ${blockNumber + 1}`);
} else if (bundleResolution === FlashbotsBundleResolution.AccountNonceTooHigh) {
console.log("Nonce too high, bailing");
process.exit(0);
}
if ('error' in flashbotsTransactionResponse) {
console.warn(flashbotsTransactionResponse.error.message);
return;
}
const simulate = await flashbotsTransactionResponse.simulate();
if (simulate.firstRevert === undefined) {
console.log("Транзакция будет успешно выполнена. Ожидайте");
} else {
console.log(simulate.firstRevert );
//exit()
}
} catch (error) {
console.warn(`Error sending transaction to block ${blockNumber + 1}: ${error.message}`);
}
});
rl.close();
}
main().catch((error) => {
console.error(error);
process.exit(1);
});
Последнее редактирование: 22.02.2024
