У меня есть проект арбитражного бота, который ищет прибыльные сделки на дексах соланы. На данный момент я пытаюсь протестировать его работоспособность в devnet перед тем как запустить в mainnet. У меня возникли трудности с тестированием работы бота в тестовых пулах Meteora DLMM, Raydium AMM, Raydium CLMM, Raydium CPMM. На данный момент логи моего бота выглядят так: 2025-10-21T16:04:26.959130Z INFO 📋 Загрузка конфигурации... 2025-10-21T16:04:26.959335Z INFO ✅ Конфигурация загружена 2025-10-21T16:04:26.959382Z INFO 🔑 Загрузка кошелька... 2025-10-21T16:04:26.965052Z INFO Публичный ключ: swEvd2CzTQPktkYeLCUKAhefDho5dKzSxziVVSctoDY 2025-10-21T16:04:26.965109Z INFO 🌐 Подключение к Solana RPC... 2025-10-21T16:04:27.563937Z INFO Подключено к кластеру: https://api.devnet.solana.com (Solana 3.0.6) 2025-10-21T16:04:27.712258Z INFO 💰 Баланс кошелька: 8.152192159 SOL 2025-10-21T16:04:27.712310Z INFO 🔧 Инициализация компонентов бота... 2025-10-21T16:04:27.712407Z INFO 🚀 Инициализация Raydium AMM сканера с program_id: DRaya7Kj3aMWQSy19kSjvmuwq9docCHofyP9kanQGaav 2025-10-21T16:04:27.712493Z INFO 🔧 Инициализация TransactionBuilder с program_id: HXccYBQu47LExrec1CAUBybYsXQL2pkEEdTaSD9emRY9 2025-10-21T16:04:27.712538Z INFO ✅ Все компоненты инициализированы 2025-10-21T16:04:27.712613Z INFO 🚀 Запуск главного цикла бота... 2025-10-21T16:04:27.712647Z INFO ════════════════════════════════════════════════════════════════════════════════ 2025-10-21T16:04:27.712832Z INFO ⏰ Итерация #1 - 19:04:27 2025-10-21T16:04:27.712870Z INFO 🔍 Запуск параллельного сканирования всех DEX... 2025-10-21T16:04:27.712903Z INFO 📡 Начинаем сканирование Raydium AMM V4 пулов... 2025-10-21T16:04:27.712931Z INFO 🎯 Program ID: DRaya7Kj3aMWQSy19kSjvmuwq9docCHofyP9kanQGaav 2025-10-21T16:04:27.712964Z INFO 🔍 Выполняем getProgramAccounts с фильтрами... 2025-10-21T16:04:28.176295Z INFO 📊 Найдено 313 потенциальных аккаунтов пулов 2025-10-21T16:04:28.176374Z WARN ⚠️ Не удалось распарсить пул BVdohP61d38C9fL5Yv9fEhaLeHTMm5YSWxrDnS2kUW7C: Пул BVdohP61d38C9fL5Yv9fEhaLeHTMm5YSWxrDnS2kUW7C имеет невалидный market_program_id 2025-10-21T16:04:28.176423Z WARN ⚠️ Не удалось распарсить пул 7tqQsncP6PdZ5TpcMmsA2piNtecGUGG3e7iSD3zL7FZW: Пул 7tqQsncP6PdZ5TpcMmsA2piNtecGUGG3e7iSD3zL7FZW имеет невалидный market_program_id 2025-10-21T16:04:28.176466Z WARN ⚠️ Не удалось распарсить пул AnBPrF5SWjS3ery8yQDRdg1bo4XWeo2T1ivpXzdZ3q18: Пул AnBPrF5SWjS3ery8yQDRdg1bo4XWeo2T1ivpXzdZ3q18 имеет невалидный market_program_id 2025-10-21T16:04:28.176509Z WARN ⚠️ Не удалось распарсить пул GyEpLHsm1yUMGTMQzro5CTVQrbjQ6z8tqdagDF4E2j9m: Пул GyEpLHsm1yUMGTMQzro5CTVQrbjQ6z8tqdagDF4E2j9m имеет невалидный market_program_id 2025-10-21T16:04:28.176551Z WARN ⚠️ Не удалось распарсить пул apXj248NYNqk5jmxFkqQnqNGcEkVGEbeb5gqEL9jhrB: Пул apXj248NYNqk5jmxFkqQnqNGcEkVGEbeb5gqEL9jhrB имеет невалидный market_program_id 2025-10-21T16:04:28.176593Z WARN ⚠️ Не удалось распарсить пул 9UuvGrp85Y2WzFYurWxTxCwNW7A9CKZnCU3JVNZV7wka: Пул 9UuvGrp85Y2WzFYurWxTxCwNW7A9CKZnCU3JVNZV7wka имеет невалидный market_program_id 2025-10-21T16:04:28.176635Z WARN ⚠️ Не удалось распарсить пул 68rAyZzm5Y7gmUaYCMKZe8wmxX9mR92oyBHKmmpgJc7U: Пул 68rAyZzm5Y7gmUaYCMKZe8wmxX9mR92oyBHKmmpgJc7U имеет невалидный market_program_id 2025-10-21T16:04:28.176677Z WARN ⚠️ Не удалось распарсить пул Bh7uTrpBt4D3CkLVTziwf6VhpXgL4TbBhB1kC2kseDPu: Пул Bh7uTrpBt4D3CkLVTziwf6VhpXgL4TbBhB1kC2kseDPu имеет невалидный market_program_id 2025-10-21T16:04:28.176719Z WARN ⚠️ Не удалось распарсить пул Befvr7VNETS5aUL9qVi7qz2nLT2oi2KVAchJGoF5ffuk: Пул Befvr7VNETS5aUL9qVi7qz2nLT2oi2KVAchJGoF5ffuk имеет невалидный market_program_id 2025-10-21T16:04:28.176761Z WARN ⚠️ Не удалось распарсить пул 7DoD1t7eUEcRheuhqBaXSohgRooxV7XiXUD5iSWhuYjm: Пул 7DoD1t7eUEcRheuhqBaXSohgRooxV7XiXUD5iSWhuYjm имеет невалидный market_program_id 2025-10-21T16:04:28.176802Z WARN ⚠️ Не удалось распарсить пул FD5uUmSv5Q25CYtgyMAK8FyWc7XUvTS6w4k7X3VBEw8d: Пул FD5uUmSv5Q25CYtgyMAK8FyWc7XUvTS6w4k7X3VBEw8d имеет невалидный market_program_id 2025-10-21T16:04:28.176844Z WARN ⚠️ Не удалось распарсить пул 8MaRvPhJiF3jjUafpLcpjFrfYkijV3mYgQnC5B5KFnLZ: Пул 8MaRvPhJiF3jjUafpLcpjFrfYkijV3mYgQnC5B5KFnLZ имеет невалидный market_program_id 2025-10-21T16:04:28.176887Z WARN ⚠️ Не удалось распарсить пул 6UF3JfFSkF3CRqerFpYHD4UqDv5hhDh7NoK8jpYfBkRv: Пул 6UF3JfFSkF3CRqerFpYHD4UqDv5hhDh7NoK8jpYfBkRv имеет невалидный market_program_id 2025-10-21T16:04:28.176929Z WARN ⚠️ Не удалось распарсить пул Ec2Uer6VXpHsw9ZmPVGMMZgzJLZRgzyYqoPtDStgPC7k: Пул Ec2Uer6VXpHsw9ZmPVGMMZgzJLZRgzyYqoPtDStgPC7k имеет невалидный market_program_id 2025-10-21T16:04:28.176971Z WARN ⚠️ Не удалось распарсить пул ETJDQeRe3C3d5NptHQA4mruqfMmPqmCjyniHGh7Jivzd: Пул ETJDQeRe3C3d5NptHQA4mruqfMmPqmCjyniHGh7Jivzd имеет невалидный market_program_id 2025-10-21T16:04:28.177014Z WARN ⚠️ Не удалось распарсить пул 2TfkZrxNtbdCL2XeLkTmQc5m82Hs5heEjTF86Tn8zW5K: Пул 2TfkZrxNtbdCL2XeLkTmQc5m82Hs5heEjTF86Tn8zW5K имеет невалидный market_program_id 2025-10-21T16:04:28.177056Z WARN ⚠️ Не удалось распарсить пул Fj5znVTZtbLxPHmvKbBL9FcrdDNs7DMCDyZPkWx2N2jE: Пул Fj5znVTZtbLxPHmvKbBL9FcrdDNs7DMCDyZPkWx2N2jE имеет невалидный market_program_id 2025-10-21T16:04:28.177102Z WARN ⚠️ Не удалось распарсить пул GaJVBDN8yUZEbfbk3cCdfKYDfTKo7yp1j1hGLs58KAfT: Пул GaJVBDN8yUZEbfbk3cCdfKYDfTKo7yp1j1hGLs58KAfT имеет невалидный market_program_id 2025-10-21T16:04:28.177175Z WARN ⚠️ Не удалось распарсить пул EEF5RPtbJ3jkzCCpmnsVXCJnfLikLEshSh5E3padt2in: Пул EEF5RPtbJ3jkzCCpmnsVXCJnfLikLEshSh5E3padt2in имеет невалидный market_program_id 2025-10-21T16:04:28.177230Z WARN ⚠️ Не удалось распарсить пул 4hvvGBaZasaqoSuqB5LhuNzcyERkdCDgqGFZA5FPjjQ1: Пул 4hvvGBaZasaqoSuqB5LhuNzcyERkdCDgqGFZA5FPjjQ1 имеет невалидный market_program_id 2025-10-21T16:04:28.177273Z WARN ⚠️ Не удалось распарсить пул NSG6L5QPYuDi2c7MKjPnYQaoVtUntgF6suujC1L4MqV: Пул NSG6L5QPYuDi2c7MKjPnYQaoVtUntgF6suujC1L4MqV имеет невалидный market_program_id 2025-10-21T16:04:28.177316Z WARN ⚠️ Не удалось распарсить пул DwiY9VgXkrGBpcYKWyN8txuNZESfCaEnjcpQuEnxG58R: Пул DwiY9VgXkrGBpcYKWyN8txuNZESfCaEnjcpQuEnxG58R имеет невалидный market_program_id 2025-10-21T16:04:28.177357Z WARN ⚠️ Не удалось распарсить пул 7wufH1YySC2r16kX12ZpYNjuychiEiUcPmHxMRWHNHZE: Пул 7wufH1YySC2r16kX12ZpYNjuychiEiUcPmHxMRWHNHZE имеет невалидный market_program_id 2025-10-21T16:04:28.177399Z WARN ⚠️ Не удалось распарсить пул 8cUt2JmccRLtTkBRs4JRhyjb5FWaYm5dz2g5UB6mWPtu: Пул 8cUt2JmccRLtTkBRs4JRhyjb5FWaYm5dz2g5UB6mWPtu имеет невалидный market_program_id 2025-10-21T16:04:28.177441Z WARN ⚠️ Не удалось распарсить пул 4mV1wP8YzEfYc2bccqNfjXTryJjp7RYHGVT5MmjDeyNN: Пул 4mV1wP8YzEfYc2bccqNfjXTryJjp7RYHGVT5MmjDeyNN имеет невалидный market_program_id 2025-10-21T16:04:28.177482Z WARN ⚠️ Не удалось распарсить пул 79XjcvHE8jGC2zdC6mDaYkeWkcMN43jw6MrtSP41LJ1Z: Пул 79XjcvHE8jGC2zdC6mDaYkeWkcMN43jw6MrtSP41LJ1Z имеет невалидный market_program_id 2025-10-21T16:04:28.177523Z WARN ⚠️ Не удалось распарсить пул CATdaBxcy8gDWa1nKhhAQRYH785WEfQJuciUQG6htC1P: Пул CATdaBxcy8gDWa1nKhhAQRYH785WEfQJuciUQG6htC1P имеет невалидный market_program_id 2025-10-21T16:04:28.177565Z WARN ⚠️ Не удалось распарсить пул HL9aeSibg8SXo36LvaBet7i3iLqCFQ9Kcor65QTwCFwY: Пул HL9aeSibg8SXo36LvaBet7i3iLqCFQ9Kcor65QTwCFwY имеет невалидный market_program_id 2025-10-21T16:04:28.177607Z WARN ⚠️ Не удалось распарсить пул 3q6s1g1p2iEmUV1NP4WtkEHi5SHWMUtgjxKsT5E5xc8W: Пул 3q6s1g1p2iEmUV1NP4WtkEHi5SHWMUtgjxKsT5E5xc8W имеет невалидный market_program_id 2025-10-21T16:04:28.177648Z WARN ⚠️ Не удалось распарсить пул HekX7Cruczfrv77JX71h1hRArozC5aJWnjD7DwCChumt: Пул HekX7Cruczfrv77JX71h1hRArozC5aJWnjD7DwCChumt имеет невалидный market_program_id 2025-10-21T16:04:28.177690Z WARN ⚠️ Не удалось распарсить пул BB8FznUA3y5XMhgNfwMT6aBx2CSehAiTfqaje18KkW38: Пул BB8FznUA3y5XMhgNfwMT6aBx2CSehAiTfqaje18KkW38 имеет невалидный market_program_id 2025-10-21T16:04:28.177732Z WARN ⚠️ Не удалось распарсить пул 7rKE33g1bYtDSqhaKfXv7qBqyZPw5og8Vfc2NBsiudE9: Пул 7rKE33g1bYtDSqhaKfXv7qBqyZPw5og8Vfc2NBsiudE9 имеет невалидный market_program_id 2025-10-21T16:04:28.177774Z WARN ⚠️ Не удалось распарсить пул BLwrvxVKbJfrh8bnrSSbe64RgVGbsDrztkgemY73Lp69: Пул BLwrvxVKbJfrh8bnrSSbe64RgVGbsDrztkgemY73Lp69 имеет невалидный market_program_id 2025-10-21T16:04:28.177816Z WARN ⚠️ Не удалось распарсить пул 2fmxkBqQeU7vAReBoYf2oRdJa123VWLjAyH8MQaNEQ17: Пул 2fmxkBqQeU7vAReBoYf2oRdJa123VWLjAyH8MQaNEQ17 имеет невалидный market_program_id 2025-10-21T16:04:28.177858Z WARN ⚠️ Не удалось распарсить пул Ez7m42nJKit8PrWFTB5fd4VGsxh2ZGrdHxdP7TUZj4yQ: Пул Ez7m42nJKit8PrWFTB5fd4VGsxh2ZGrdHxdP7TUZj4yQ имеет невалидный market_program_id 2025-10-21T16:04:28.177899Z WARN ⚠️ Не удалось распарсить пул R7YULWMhpoZUGsYVnRsFHDMY5up6wR9yjC6NqWmCfBU: Пул R7YULWMhpoZUGsYVnRsFHDMY5up6wR9yjC6NqWmCfBU имеет невалидный market_program_id 2025-10-21T16:04:28.177941Z WARN ⚠️ Не удалось распарсить пул CwNyDzHgWY4WZUTkqdKYcqCKcZcYUavQqroFA5Z1Tw7h: Пул CwNyDzHgWY4WZUTkqdKYcqCKcZcYUavQqroFA5Z1Tw7h имеет невалидный market_program_id 2025-10-21T16:04:28.177983Z WARN ⚠️ Не удалось распарсить пул ZH7UDXDp1zUwtKdnhdgH3UMt8f8p7YsWczRCXxvzvKq: Пул ZH7UDXDp1zUwtKdnhdgH3UMt8f8p7YsWczRCXxvzvKq имеет невалидный market_program_id 2025-10-21T16:04:28.178025Z WARN ⚠️ Не удалось распарсить пул HhK3GsSuNYhgokgHLnDqRQE5Z1NqMZnRxXX5Pdq6UF6K: Пул HhK3GsSuNYhgokgHLnDqRQE5Z1NqMZnRxXX5Pdq6UF6K имеет невалидный market_program_id 2025-10-21T16:04:28.178067Z WARN ⚠️ Не удалось распарсить пул 7jntWEBPpugFCptp6bNgFFobM9Za1DcZjYPdEvzhZ5V5: Пул 7jntWEBPpugFCptp6bNgFFobM9Za1DcZjYPdEvzhZ5V5 имеет невалидный market_program_id 2025-10-21T16:04:28.178109Z WARN ⚠️ Не удалось распарсить пул D7Gdqvzm5k4fDEsBhbCUCtDnAgK8tikXjqssxs19nuV5: Пул D7Gdqvzm5k4fDEsBhbCUCtDnAgK8tikXjqssxs19nuV5 имеет невалидный market_program_id 2025-10-21T16:04:28.178160Z WARN ⚠️ Не удалось распарсить пул FWdykTDaFiFJgmnBrfVYqXvsQwqJobEnGJLSjHMW6GSo: Пул FWdykTDaFiFJgmnBrfVYqXvsQwqJobEnGJLSjHMW6GSo имеет невалидный market_program_id 2025-10-21T16:04:28.178331Z WARN ⚠️ Не удалось распарсить пул 8Rc8AXsKxrXH4C7MtWCwq9jot6NHTqRgWmpYTn9N8kaw: Пул 8Rc8AXsKxrXH4C7MtWCwq9jot6NHTqRgWmpYTn9N8kaw имеет невалидный market_program_id 2025-10-21T16:04:28.178423Z WARN ⚠️ Не удалось распарсить пул 3UmhHnwnLzfvi2KUT7CUGjy7WmV6W5eC72mVaTQknUKv: Пул 3UmhHnwnLzfvi2KUT7CUGjy7WmV6W5eC72mVaTQknUKv имеет невалидный market_program_id 2025-10-21T16:04:28.178483Z WARN ⚠️ Не удалось распарсить пул CYrKEBeTqutussLCUimAfJLAiV6AHSL1B1JFuYShDihV: Пул CYrKEBeTqutussLCUimAfJLAiV6AHSL1B1JFuYShDihV имеет невалидный market_program_id 2025-10-21T16:04:28.178540Z WARN ⚠️ Не удалось распарсить пул HaCp2ShGLwY9bPsfvNdip7dTur3WqRmK3J1wdGZBizHF: Пул HaCp2ShGLwY9bPsfvNdip7dTur3WqRmK3J1wdGZBizHF имеет невалидный market_program_id 2025-10-21T16:04:28.178596Z WARN ⚠️ Не удалось распарсить пул 4jx9WSyKh3pVLAvVgKrTu9JyBJXaBfhPsZ4YmWcNFnft: Пул 4jx9WSyKh3pVLAvVgKrTu9JyBJXaBfhPsZ4YmWcNFnft имеет невалидный market_program_id 2025-10-21T16:04:28.178652Z WARN ⚠️ Не удалось распарсить пул 4soAvqdDDzHHqrbT5tjTyTzbTAE9dSM997H1DHHCpcFT: Пул 4soAvqdDDzHHqrbT5tjTyTzbTAE9dSM997H1DHHCpcFT имеет невалидный market_program_id 2025-10-21T16:04:28.178706Z WARN ⚠️ Не удалось распарсить пул 2669SjVyYp7d4oBxMmvyVELPHDdADznDJFLoDdcEXPn3: Пул 2669SjVyYp7d4oBxMmvyVELPHDdADznDJFLoDdcEXPn3 имеет невалидный market_program_id 2025-10-21T16:04:28.178796Z WARN ⚠️ Не удалось распарсить пул HcBYvpKqCV15qvwWTvYoWctSn8Y1TkmivmrfgvRxGpWu: Пул HcBYvpKqCV15qvwWTvYoWctSn8Y1TkmivmrfgvRxGpWu имеет невалидный market_program_id 2025-10-21T16:04:28.178883Z WARN ⚠️ Не удалось распарсить пул 8yvLposgBjrKDpF4FQWmVJxFUg3xTnCcGnmhdfRMvKBq: Пул 8yvLposgBjrKDpF4FQWmVJxFUg3xTnCcGnmhdfRMvKBq имеет невалидный market_program_id 2025-10-21T16:04:28.178971Z WARN ⚠️ Не удалось распарсить пул D1R3PWJx5LgbXMvhgga6MXUWJDnzJq2NdPgziXE9T6KX: Пул D1R3PWJx5LgbXMvhgga6MXUWJDnzJq2NdPgziXE9T6KX имеет невалидный market_program_id 2025-10-21T16:04:28.179059Z WARN ⚠️ Не удалось распарсить пул JEEvWR58maTREX7eot6Po5ojq1S8L9oGDhKTTi5UotoG: Пул JEEvWR58maTREX7eot6Po5ojq1S8L9oGDhKTTi5UotoG имеет невалидный market_program_id 2025-10-21T16:04:28.179146Z WARN ⚠️ Не удалось распарсить пул 2BBhFyotrRRj4VahtgcZuKx5a9HK3CFNj2NyzhzXNceM: Пул 2BBhFyotrRRj4VahtgcZuKx5a9HK3CFNj2NyzhzXNceM имеет невалидный market_program_id 2025-10-21T16:04:28.179210Z WARN ⚠️ Не удалось распарсить пул 4L9gcDG8PWnAwyLKLp5HcyfuDLK3prTmJ4UpaS65r17D: Пул 4L9gcDG8PWnAwyLKLp5HcyfuDLK3prTmJ4UpaS65r17D имеет невалидный market_program_id 2025-10-21T16:04:28.179264Z WARN ⚠️ Не удалось распарсить пул 8yRPxtgiZscjfbDQW3E329Q5dmfS8TP4AXN1q6giQE46: Пул 8yRPxtgiZscjfbDQW3E329Q5dmfS8TP4AXN1q6giQE46 имеет невалидный market_program_id 2025-10-21T16:04:28.179321Z WARN ⚠️ Не удалось распарсить пул 7PRrHMyBGJaFZ1mU99fTWAEmdDKzhyMuAn9u88PAxYFW: Пул 7PRrHMyBGJaFZ1mU99fTWAEmdDKzhyMuAn9u88PAxYFW имеет невалидный market_program_id 2025-10-21T16:04:28.179356Z WARN ⚠️ Не удалось распарсить пул 5bqYnV9NFKTvUopaJHWzbtKaAffcFWv1HySdh6A53q1Q: Пул 5bqYnV9NFKTvUopaJHWzbtKaAffcFWv1HySdh6A53q1Q имеет невалидный market_program_id 2025-10-21T16:04:28.179440Z WARN ⚠️ Не удалось распарсить пул FQQHcEtVmEAHkUPxKpFrm3u5TsC3fRTxkUYHG3mhFHnz: Пул FQQHcEtVmEAHkUPxKpFrm3u5TsC3fRTxkUYHG3mhFHnz имеет невалидный market_program_id 2025-10-21T16:04:28.179529Z WARN ⚠️ Не удалось распарсить пул 4R1g93J9zjwLBsvv7Y8gpFsCx9K32mcgaaKN3obQUWGz: Пул 4R1g93J9zjwLBsvv7Y8gpFsCx9K32mcgaaKN3obQUWGz имеет невалидный market_program_id 2025-10-21T16:04:28.179619Z WARN ⚠️ Не удалось распарсить пул AmFKEcJajBSM5pW5B8Q7YH2zneCbGJ7Z3WsmtUNd9PvG: Пул AmFKEcJajBSM5pW5B8Q7YH2zneCbGJ7Z3WsmtUNd9PvG имеет невалидный market_program_id 2025-10-21T16:04:28.179673Z WARN ⚠️ Не удалось распарсить пул 5Et4WYAFXfYuJ6hTNAx3k7ewi56U13XQPD5Sbqo4pCze: Пул 5Et4WYAFXfYuJ6hTNAx3k7ewi56U13XQPD5Sbqo4pCze имеет невалидный market_program_id 2025-10-21T16:04:28.179762Z WARN ⚠️ Не удалось распарсить пул 3ZmmvYsZ8fCiqNqrhBMNMEnRoYA52GkQpbRuZWWxzBT9: Пул 3ZmmvYsZ8fCiqNqrhBMNMEnRoYA52GkQpbRuZWWxzBT9 имеет невалидный market_program_id 2025-10-21T16:04:28.179818Z WARN ⚠️ Не удалось распарсить пул G91CWUEhtBa7EHvYxKQUtpJG4cZwAVmAin3po1oLQHER: Пул G91CWUEhtBa7EHvYxKQUtpJG4cZwAVmAin3po1oLQHER имеет невалидный market_program_id 2025-10-21T16:04:28.179907Z WARN ⚠️ Не удалось распарсить пул 7jfMXzVX4Frruyq94EfYS2okF1CtW74hKQ3HPZHzt3B4: Пул 7jfMXzVX4Frruyq94EfYS2okF1CtW74hKQ3HPZHzt3B4 имеет невалидный market_program_id 2025-10-21T16:04:28.179961Z WARN ⚠️ Не удалось распарсить пул BhbSPE9W7eDtLoARDTciyFqUBwJdTSysgqmfi9DTEfv9: Пул BhbSPE9W7eDtLoARDTciyFqUBwJdTSysgqmfi9DTEfv9 имеет невалидный market_program_id 2025-10-21T16:04:28.180017Z WARN ⚠️ Не удалось распарсить пул FSi2z99nj1N957fQDxaUJcQVy2KK3B4YueqJymYoRFKD: Пул FSi2z99nj1N957fQDxaUJcQVy2KK3B4YueqJymYoRFKD имеет невалидный market_program_id 2025-10-21T16:04:28.180073Z WARN ⚠️ Не удалось распарсить пул 7fBJMaCURTseiZgViH1CfjrPDDZ2vTCsyx5xViEVCKjD: Пул 7fBJMaCURTseiZgViH1CfjrPDDZ2vTCsyx5xViEVCKjD имеет невалидный market_program_id 2025-10-21T16:04:28.180128Z WARN ⚠️ Не удалось распарсить пул EP2X1CQb87fU5EF8iSXpKtgggCvRpsF2kCqjvYe1kAKC: Пул EP2X1CQb87fU5EF8iSXpKtgggCvRpsF2kCqjvYe1kAKC имеет невалидный market_program_id 2025-10-21T16:04:28.180188Z WARN ⚠️ Не удалось распарсить пул 6r8GT13RP2EkMqt4EJJASV5BRrFSj2fS8uejUFxLvbKK: Пул 6r8GT13RP2EkMqt4EJJASV5BRrFSj2fS8uejUFxLvbKK имеет невалидный market_program_id 2025-10-21T16:04:28.180281Z WARN ⚠️ Не удалось распарсить пул 8qgQRsbv55HgQ4suTU5xHoC5Vx53NpbfC44wfrSnw8gW: Пул 8qgQRsbv55HgQ4suTU5xHoC5Vx53NpbfC44wfrSnw8gW имеет невалидный market_program_id 2025-10-21T16:04:28.180337Z WARN ⚠️ Не удалось распарсить пул 4xsKr6UR5ExVqhDrPr31k92e4JxnVN4buSvVHuHqyoXh: Пул 4xsKr6UR5ExVqhDrPr31k92e4JxnVN4buSvVHuHqyoXh имеет невалидный market_program_id 2025-10-21T16:04:28.180390Z WARN ⚠️ Не удалось распарсить пул GjvDpEr1XbdN3t4j41F7vgQesWnVc1yZ4M2QW8CxnZea: Пул GjvDpEr1XbdN3t4j41F7vgQesWnVc1yZ4M2QW8CxnZea имеет невалидный market_program_id 2025-10-21T16:04:28.180445Z WARN ⚠️ Не удалось распарсить пул 22RrWJn4FfF5pKBWR4dx2osbhVjqafkoS8aCjWEYyrJh: Пул 22RrWJn4FfF5pKBWR4dx2osbhVjqafkoS8aCjWEYyrJh имеет невалидный market_program_id 2025-10-21T16:04:28.180501Z WARN ⚠️ Не удалось распарсить пул 96mA9PUc2Y99mZj5E2tQ98ENfuyc85qL63t5Y58DNZp6: Пул 96mA9PUc2Y99mZj5E2tQ98ENfuyc85qL63t5Y58DNZp6 имеет невалидный market_program_id 2025-10-21T16:04:28.180557Z WARN ⚠️ Не удалось распарсить пул 26XNmgzN7fAXwc7w6wJxivv5Kv4K4Ccy81oZtbpiCfNj: Пул 26XNmgzN7fAXwc7w6wJxivv5Kv4K4Ccy81oZtbpiCfNj имеет невалидный market_program_id 2025-10-21T16:04:28.180612Z WARN ⚠️ Не удалось распарсить пул BuU1BYAMTHAsmn7d3jeyY6hyhDDMzdGof3pqZZQHGom9: Пул BuU1BYAMTHAsmn7d3jeyY6hyhDDMzdGof3pqZZQHGom9 имеет невалидный market_program_id 2025-10-21T16:04:28.180667Z WARN ⚠️ Не удалось распарсить пул 6CNpNJHD9LsNkHcoH8hLj9THmyyAtWcjeNiED837KKEk: Пул 6CNpNJHD9LsNkHcoH8hLj9THmyyAtWcjeNiED837KKEk имеет невалидный market_program_id 2025-10-21T16:04:28.180720Z WARN ⚠️ Не удалось распарсить пул 3pw2MDgY4bSUNsKYVy1xnJ6rHDRC3CRK93si4PavgPsP: Пул 3pw2MDgY4bSUNsKYVy1xnJ6rHDRC3CRK93si4PavgPsP имеет невалидный market_program_id 2025-10-21T16:04:28.180775Z WARN ⚠️ Не удалось распарсить пул 9iCZ9ZTwc7cYGnSTJz8ZNRxhMT3aT7Hpe81Uhek5D9A5: Пул 9iCZ9ZTwc7cYGnSTJz8ZNRxhMT3aT7Hpe81Uhek5D9A5 имеет невалидный market_program_id 2025-10-21T16:04:28.180829Z WARN ⚠️ Не удалось распарсить пул CAtvbmwVNYhx7fVtk6ExG3jPvYU6Lw4kfucPehbxNzH5: Пул CAtvbmwVNYhx7fVtk6ExG3jPvYU6Lw4kfucPehbxNzH5 имеет невалидный market_program_id 2025-10-21T16:04:28.180884Z WARN ⚠️ Не удалось распарсить пул 7Wxd8HGimNtD4yqYCuRqA3zrNgEm5g2F324S2dLotW42: Пул 7Wxd8HGimNtD4yqYCuRqA3zrNgEm5g2F324S2dLotW42 имеет невалидный market_program_id 2025-10-21T16:04:28.180939Z WARN ⚠️ Не удалось распарсить пул NWGDNf45zpiT1bAgZBH2LPGZCWwEKfwMd4o7VzR8WSE: Пул NWGDNf45zpiT1bAgZBH2LPGZCWwEKfwMd4o7VzR8WSE имеет невалидный market_program_id 2025-10-21T16:04:28.180994Z WARN ⚠️ Не удалось распарсить пул GpWfMKCZ5xpXj3FNZ3uYavbT8MqTSjQyvarPhduBtDdo: Пул GpWfMKCZ5xpXj3FNZ3uYavbT8MqTSjQyvarPhduBtDdo имеет невалидный market_program_id 2025-10-21T16:04:28.181049Z WARN ⚠️ Не удалось распарсить пул 5zseWHNxWp1b3aChp96jsLGgHz3ZEVDynDzniSm2ki3q: Пул 5zseWHNxWp1b3aChp96jsLGgHz3ZEVDynDzniSm2ki3q имеет невалидный market_program_id 2025-10-21T16:04:28.181104Z WARN ⚠️ Не удалось распарсить пул 5TWQwaKEx2LpJZeCRQPR569Kfq2efyYB2M3aPsF8gtMk: Пул 5TWQwaKEx2LpJZeCRQPR569Kfq2efyYB2M3aPsF8gtMk имеет невалидный market_program_id 2025-10-21T16:04:28.181168Z WARN ⚠️ Не удалось распарсить пул 8rKNnYdjxA9EYVDMKr8U6aaajgfsUmEe9QuuQCE3ZmGC: Пул 8rKNnYdjxA9EYVDMKr8U6aaajgfsUmEe9QuuQCE3ZmGC имеет невалидный market_program_id 2025-10-21T16:04:28.181225Z WARN ⚠️ Не удалось распарсить пул Asdf9uFsazXpBCZhcgXcYUwKM9vjwxSZ4A61MX37X9xv: Пул Asdf9uFsazXpBCZhcgXcYUwKM9vjwxSZ4A61MX37X9xv имеет невалидный market_program_id 2025-10-21T16:04:28.181270Z WARN ⚠️ Не удалось распарсить пул wkusdddtETsXAMtmLEQw29pfKkH8wb6nnkWN8UAcfTd: Пул wkusdddtETsXAMtmLEQw29pfKkH8wb6nnkWN8UAcfTd имеет невалидный market_program_id 2025-10-21T16:04:28.181323Z WARN ⚠️ Не удалось распарсить пул FvUDyFrqfHBVrks34QCVG8QTZ19fnxkHkEQKqfPstBnk: Пул FvUDyFrqfHBVrks34QCVG8QTZ19fnxkHkEQKqfPstBnk имеет невалидный market_program_id 2025-10-21T16:04:28.181378Z WARN ⚠️ Не удалось распарсить пул R49GiAe5G1mb687AgYbkhuS1EExVVz4qEiXeaEcfajn: Пул R49GiAe5G1mb687AgYbkhuS1EExVVz4qEiXeaEcfajn имеет невалидный market_program_id 2025-10-21T16:04:28.181434Z WARN ⚠️ Не удалось распарсить пул 4mJDRyq6h94dUQau14h6hCWLR9gAx1za1iDYK1zLvhJ6: Пул 4mJDRyq6h94dUQau14h6hCWLR9gAx1za1iDYK1zLvhJ6 имеет невалидный market_program_id 2025-10-21T16:04:28.181489Z WARN ⚠️ Не удалось распарсить пул 518QdRHYftCY1fmWUtGLjJ4BLnZANXnxrFRS3mMWGCr5: Пул 518QdRHYftCY1fmWUtGLjJ4BLnZANXnxrFRS3mMWGCr5 имеет невалидный market_program_id 2025-10-21T16:04:28.181545Z WARN ⚠️ Не удалось распарсить пул GGiJ8ePAjQ3iaAYCsx8srQLNhmxeGusdr7ZYfzDrDbmD: Пул GGiJ8ePAjQ3iaAYCsx8srQLNhmxeGusdr7ZYfzDrDbmD имеет невалидный market_program_id 2025-10-21T16:04:28.181602Z WARN ⚠️ Не удалось распарсить пул 7rRGN7iG43mxZ99ySoSkEX96eiMquBjxd1eyQadFJdLR: Пул 7rRGN7iG43mxZ99ySoSkEX96eiMquBjxd1eyQadFJdLR имеет невалидный market_program_id 2025-10-21T16:04:28.181657Z WARN ⚠️ Не удалось распарсить пул GPTqcWPENW2eDkGTVYeU8gjwFAWvb2teAYcUSpx33rGL: Пул GPTqcWPENW2eDkGTVYeU8gjwFAWvb2teAYcUSpx33rGL имеет невалидный market_program_id 2025-10-21T16:04:28.181714Z WARN ⚠️ Не удалось распарсить пул HptADbrmbgbmZM3jkD8dtMxqQYqt2JbdWFusUURaMYZ4: Пул HptADbrmbgbmZM3jkD8dtMxqQYqt2JbdWFusUURaMYZ4 имеет невалидный market_program_id 2025-10-21T16:04:28.181768Z WARN ⚠️ Не удалось распарсить пул GS4ycntU62BjbzC6G8hm2V3jheXweF7dXVbFK1aQvKPP: Пул GS4ycntU62BjbzC6G8hm2V3jheXweF7dXVbFK1aQvKPP имеет невалидный market_program_id 2025-10-21T16:04:28.181823Z WARN ⚠️ Не удалось распарсить пул FNKo7cA7VCRyNk3t3YD8KtkZrB6hfadoTjrNfM7fTTbR: Пул FNKo7cA7VCRyNk3t3YD8KtkZrB6hfadoTjrNfM7fTTbR имеет невалидный market_program_id 2025-10-21T16:04:28.181878Z WARN ⚠️ Не удалось распарсить пул BQBozkCJdELJx2RSB9tF1BX3Edfm8sbmwUCGicLrxZbe: Пул BQBozkCJdELJx2RSB9tF1BX3Edfm8sbmwUCGicLrxZbe имеет невалидный market_program_id 2025-10-21T16:04:28.181946Z WARN ⚠️ Не удалось распарсить пул FNtz7kb56stdzdphYtd7roQjkUjcBR73AznsAVPxRAac: Пул FNtz7kb56stdzdphYtd7roQjkUjcBR73AznsAVPxRAac имеет невалидный market_program_id 2025-10-21T16:04:28.182000Z WARN ⚠️ Не удалось распарсить пул 9D7RY3MQdtdsz6BW4FMSAvrNQvWvetM8kpcbn2xM6uDc: Пул 9D7RY3MQdtdsz6BW4FMSAvrNQvWvetM8kpcbn2xM6uDc имеет невалидный market_program_id 2025-10-21T16:04:28.182052Z WARN ⚠️ Не удалось распарсить пул 2wCxkJ6fx4MaFbEpjwkU1FUnQLSx1a1vu8D96cgokN4G: Пул 2wCxkJ6fx4MaFbEpjwkU1FUnQLSx1a1vu8D96cgokN4G имеет невалидный market_program_id 2025-10-21T16:04:28.182127Z WARN ⚠️ Не удалось распарсить пул 4tH17ptdN3k36VtYxVkDBUfQ4qmeohYKCbjxUwQXv1hc: Пул 4tH17ptdN3k36VtYxVkDBUfQ4qmeohYKCbjxUwQXv1hc имеет невалидный market_program_id 2025-10-21T16:04:28.182191Z WARN ⚠️ Не удалось распарсить пул BHSq4sq6xGr327vAmrxwLT9jF5BffRv7YrzUdyYPTL1R: Пул BHSq4sq6xGr327vAmrxwLT9jF5BffRv7YrzUdyYPTL1R имеет невалидный market_program_id 2025-10-21T16:04:28.182256Z WARN ⚠️ Не удалось распарсить пул J5y2qyq1o4ea8z4so2Twb7J7KbjfRqfPtFFPbyFM6R9f: Пул J5y2qyq1o4ea8z4so2Twb7J7KbjfRqfPtFFPbyFM6R9f имеет невалидный market_program_id 2025-10-21T16:04:28.182313Z WARN ⚠️ Не удалось распарсить пул 66GGjvDLFktPe95T4Kzj3E53GvSQNbUeguPSk6LZohSn: Пул 66GGjvDLFktPe95T4Kzj3E53GvSQNbUeguPSk6LZohSn имеет невалидный market_program_id 2025-10-21T16:04:28.182375Z WARN ⚠️ Не удалось распарсить пул 4Wu1tJFPfsYmnBRETUypzth2yvH9HuFA3wJ9W8zuR2Dh: Пул 4Wu1tJFPfsYmnBRETUypzth2yvH9HuFA3wJ9W8zuR2Dh имеет невалидный market_program_id 2025-10-21T16:04:28.182471Z WARN ⚠️ Не удалось распарсить пул 52qq9FB8n2BDQa1FmGpLymJRKVRiRoeT6X1WGz3ngRSj: Пул 52qq9FB8n2BDQa1FmGpLymJRKVRiRoeT6X1WGz3ngRSj имеет невалидный market_program_id 2025-10-21T16:04:28.182528Z WARN ⚠️ Не удалось распарсить пул BsZ7K9Sc3hzDnw1WP2LvNSeik5CtPXbgjYJ7dvS2LX3Z: Пул BsZ7K9Sc3hzDnw1WP2LvNSeik5CtPXbgjYJ7dvS2LX3Z имеет невалидный market_program_id 2025-10-21T16:04:28.182564Z WARN ⚠️ Не удалось распарсить пул 3dAjNSPUz1C4yhiwfWTripabi57k2yhvTHQ288LUMNqT: Пул 3dAjNSPUz1C4yhiwfWTripabi57k2yhvTHQ288LUMNqT имеет невалидный market_program_id 2025-10-21T16:04:28.182616Z WARN ⚠️ Не удалось распарсить пул Z7EYsRWPZucyddBoLibS4rpcRSsd6C1BWTmpbg18ieh: Пул Z7EYsRWPZucyddBoLibS4rpcRSsd6C1BWTmpbg18ieh имеет невалидный market_program_id 2025-10-21T16:04:28.182675Z WARN ⚠️ Не удалось распарсить пул DrGFCzis1aSdfaB9zLb6KAwKnMWzVLGp7eb8RnRqYWCa: Пул DrGFCzis1aSdfaB9zLb6KAwKnMWzVLGp7eb8RnRqYWCa имеет невалидный market_program_id 2025-10-21T16:04:28.182730Z WARN ⚠️ Не удалось распарсить пул 9bcpTX5mzFPoMDAsSDate78XHakWiUAyznWjiePwFfD1: Пул 9bcpTX5mzFPoMDAsSDate78XHakWiUAyznWjiePwFfD1 имеет невалидный market_program_id 2025-10-21T16:04:28.182785Z WARN ⚠️ Не удалось распарсить пул 9YREG8NeyYQ1YnkZbBUcca1bbnFg9Y5FTcD43Ace91tL: Пул 9YREG8NeyYQ1YnkZbBUcca1bbnFg9Y5FTcD43Ace91tL имеет невалидный market_program_id 2025-10-21T16:04:28.182841Z WARN ⚠️ Не удалось распарсить пул BVNqUattcrPH3Z5rZtWvDH577pJtxvbD19b4WS8kaKqa: Пул BVNqUattcrPH3Z5rZtWvDH577pJtxvbD19b4WS8kaKqa имеет невалидный market_program_id 2025-10-21T16:04:28.182902Z WARN ⚠️ Не удалось распарсить пул BCw9cQHdCjaZPni7izf2affN3tc4zHPf4h9A8HGygNCe: Пул BCw9cQHdCjaZPni7izf2affN3tc4zHPf4h9A8HGygNCe имеет невалидный market_program_id 2025-10-21T16:04:28.182956Z WARN ⚠️ Не удалось распарсить пул 8Nds2PzLZbGn86mHCkE1VBkybVQcSzhsfZpYzePLEH7t: Пул 8Nds2PzLZbGn86mHCkE1VBkybVQcSzhsfZpYzePLEH7t имеет невалидный market_program_id 2025-10-21T16:04:28.183012Z WARN ⚠️ Не удалось распарсить пул 6HKPghsPZDd9veD7PjMu4VF1HDB9bT5SN3Zo4CcSQ9Mm: Пул 6HKPghsPZDd9veD7PjMu4VF1HDB9bT5SN3Zo4CcSQ9Mm имеет невалидный market_program_id 2025-10-21T16:04:28.183231Z WARN ⚠️ Не удалось распарсить пул ELN5YLxU4eL5GczXUc43guV5iM8ySpFGrEnX6Av9Kxbi: Пул ELN5YLxU4eL5GczXUc43guV5iM8ySpFGrEnX6Av9Kxbi имеет невалидный market_program_id 2025-10-21T16:04:28.183288Z WARN ⚠️ Не удалось распарсить пул 4gYUqP6HeDtwx1P6FxnHU7YAd9DwE76hBA9MUABWk112: Пул 4gYUqP6HeDtwx1P6FxnHU7YAd9DwE76hBA9MUABWk112 имеет невалидный market_program_id 2025-10-21T16:04:28.183374Z WARN ⚠️ Не удалось распарсить пул 3xrTGVk7vGsa8LDEBds5wn31zbeJFYTwzAyfeUzXSNjf: Пул 3xrTGVk7vGsa8LDEBds5wn31zbeJFYTwzAyfeUzXSNjf имеет невалидный market_program_id 2025-10-21T16:04:28.183433Z WARN ⚠️ Не удалось распарсить пул 3zK6i8t22VgA35JsBvzJJc7DckqqyrHVPbb19jGGA5B2: Пул 3zK6i8t22VgA35JsBvzJJc7DckqqyrHVPbb19jGGA5B2 имеет невалидный market_program_id 2025-10-21T16:04:28.183491Z WARN ⚠️ Не удалось распарсить пул C2yQNeXYeKMQmfQfXiSGRYb3dVZowz9iY9UrNvGkoKUa: Пул C2yQNeXYeKMQmfQfXiSGRYb3dVZowz9iY9UrNvGkoKUa имеет невалидный market_program_id 2025-10-21T16:04:28.183548Z WARN ⚠️ Не удалось распарсить пул HyiRdSc43A63zLC4c3U14hLn19h5UHmGRRkJbd4Kj2q3: Пул HyiRdSc43A63zLC4c3U14hLn19h5UHmGRRkJbd4Kj2q3 имеет невалидный market_program_id 2025-10-21T16:04:28.183601Z WARN ⚠️ Не удалось распарсить пул 7v886osQBmNNQsxdj6PNu59qfkrvfsYq5XaqN7obEBVg: Пул 7v886osQBmNNQsxdj6PNu59qfkrvfsYq5XaqN7obEBVg имеет невалидный market_program_id 2025-10-21T16:04:28.183672Z WARN ⚠️ Не удалось распарсить пул Bd9qJc8qatoVAanYjaQLeVrHZHGCC8eEWeNrqx6pfwrf: Пул Bd9qJc8qatoVAanYjaQLeVrHZHGCC8eEWeNrqx6pfwrf имеет невалидный market_program_id 2025-10-21T16:04:28.183732Z WARN ⚠️ Не удалось распарсить пул ABmm4epTUUrbC7jPWYrFZwA3BUK8Ne77C8pL7bLHU1s8: Пул ABmm4epTUUrbC7jPWYrFZwA3BUK8Ne77C8pL7bLHU1s8 имеет невалидный market_program_id 2025-10-21T16:04:28.183782Z WARN ⚠️ Не удалось распарсить пул EpEnjf9TBwDjwgV6jVroNXqpqap1nfwCRhEPaKqhy1C7: Пул EpEnjf9TBwDjwgV6jVroNXqpqap1nfwCRhEPaKqhy1C7 имеет невалидный market_program_id 2025-10-21T16:04:28.183824Z WARN ⚠️ Не удалось распарсить пул Hj2x2bRGoA6TaAyCNd6k2DBuYD9Nc1S1SkehqYdV6YKf: Пул Hj2x2bRGoA6TaAyCNd6k2DBuYD9Nc1S1SkehqYdV6YKf имеет невалидный market_program_id 2025-10-21T16:04:28.183866Z WARN ⚠️ Не удалось распарсить пул 9CcBwn4HqMuepgpTBSaSJeShVPTPxcATC4ohBStjaQVf: Пул 9CcBwn4HqMuepgpTBSaSJeShVPTPxcATC4ohBStjaQVf имеет невалидный market_program_id 2025-10-21T16:04:28.183907Z WARN ⚠️ Не удалось распарсить пул 6N2V3f4tL3HDczrsW2X7rkFCpuRNqgEyJ5qcvA2mzZVG: Пул 6N2V3f4tL3HDczrsW2X7rkFCpuRNqgEyJ5qcvA2mzZVG имеет невалидный market_program_id 2025-10-21T16:04:28.183948Z WARN ⚠️ Не удалось распарсить пул D1Py5YAWKAJyvtY7r2zFTxHT8HdpLSeWqN2e39vFExAV: Пул D1Py5YAWKAJyvtY7r2zFTxHT8HdpLSeWqN2e39vFExAV имеет невалидный market_program_id 2025-10-21T16:04:28.183990Z WARN ⚠️ Не удалось распарсить пул AuoNh9MFEigg4VdZVsVdSYKGKnW2ZHRA73CcooNsQeD7: Пул AuoNh9MFEigg4VdZVsVdSYKGKnW2ZHRA73CcooNsQeD7 имеет невалидный market_program_id 2025-10-21T16:04:28.184032Z WARN ⚠️ Не удалось распарсить пул 5RMKUJ28Xj37NXazRCczLcWTQJgSo173AEcj6jM4gqn9: Пул 5RMKUJ28Xj37NXazRCczLcWTQJgSo173AEcj6jM4gqn9 имеет невалидный market_program_id 2025-10-21T16:04:28.184073Z WARN ⚠️ Не удалось распарсить пул CY4pTetgMpNutknE7KTx3YBh5JpzKiXJhAWbjNuHYSEK: Пул CY4pTetgMpNutknE7KTx3YBh5JpzKiXJhAWbjNuHYSEK имеет невалидный market_program_id 2025-10-21T16:04:28.184115Z WARN ⚠️ Не удалось распарсить пул ChSWGctuTF5hkCowPDhYWxeJvmEscED95iKrSr9FQ1Wf: Пул ChSWGctuTF5hkCowPDhYWxeJvmEscED95iKrSr9FQ1Wf имеет невалидный market_program_id 2025-10-21T16:04:28.184156Z WARN ⚠️ Не удалось распарсить пул 3jum9B5KbLaL11srfYZ36h2zzmniUBFR29kWeHnmGJrm: Пул 3jum9B5KbLaL11srfYZ36h2zzmniUBFR29kWeHnmGJrm имеет невалидный market_program_id 2025-10-21T16:04:28.184198Z WARN ⚠️ Не удалось распарсить пул EbQRTz85cdL7dQxgTktwRcjF3YdYD8qEYCuwfMJV5e9q: Пул EbQRTz85cdL7dQxgTktwRcjF3YdYD8qEYCuwfMJV5e9q имеет невалидный market_program_id 2025-10-21T16:04:28.184239Z WARN ⚠️ Не удалось распарсить пул 24UERHEgHXVWbqv96C7W6xe1F2MZuxDPvv6XVD9Nvv5X: Пул 24UERHEgHXVWbqv96C7W6xe1F2MZuxDPvv6XVD9Nvv5X имеет невалидный market_program_id 2025-10-21T16:04:28.184281Z WARN ⚠️ Не удалось распарсить пул 3PBBM2wt6PvbWiLojRWmemkYJi3gxRYPNNpP1maqknoZ: Пул 3PBBM2wt6PvbWiLojRWmemkYJi3gxRYPNNpP1maqknoZ имеет невалидный market_program_id 2025-10-21T16:04:28.184322Z WARN ⚠️ Не удалось распарсить пул 7zJLUrHHtzuxPk1BBeBtKqa2KcFYzGGgpCTqqfbSrDtC: Пул 7zJLUrHHtzuxPk1BBeBtKqa2KcFYzGGgpCTqqfbSrDtC имеет невалидный market_program_id 2025-10-21T16:04:28.184364Z WARN ⚠️ Не удалось распарсить пул 2gte7fkVzjqAeHn7vAaMo7UGUYzK4E6UUvTqcudCjmu2: Пул 2gte7fkVzjqAeHn7vAaMo7UGUYzK4E6UUvTqcudCjmu2 имеет невалидный market_program_id 2025-10-21T16:04:28.184408Z WARN ⚠️ Не удалось распарсить пул Ci9FJogpanhxYNQE8yQqjmrxzrzRbGgrdeUBE1Gk9UD2: Пул Ci9FJogpanhxYNQE8yQqjmrxzrzRbGgrdeUBE1Gk9UD2 имеет невалидный market_program_id 2025-10-21T16:04:28.184464Z WARN ⚠️ Не удалось распарсить пул AGCKtgac4sPnHzQB2byMgLMEPXUkLuKJibVVhyNVpH4c: Пул AGCKtgac4sPnHzQB2byMgLMEPXUkLuKJibVVhyNVpH4c имеет невалидный market_program_id 2025-10-21T16:04:28.184522Z WARN ⚠️ Не удалось распарсить пул Fs52ShoHW9jFC9N68RXPwitgoqLaBk5PLisdp6AaUgUj: Пул Fs52ShoHW9jFC9N68RXPwitgoqLaBk5PLisdp6AaUgUj имеет невалидный market_program_id 2025-10-21T16:04:28.184579Z WARN ⚠️ Не удалось распарсить пул 6fxjEvxvYv2xBNvsdBoVfMvzU4otpjv8NfKuRzYVCiGP: Пул 6fxjEvxvYv2xBNvsdBoVfMvzU4otpjv8NfKuRzYVCiGP имеет невалидный market_program_id 2025-10-21T16:04:28.184634Z WARN ⚠️ Не удалось распарсить пул 8dmfMP3ADXGiuxQLHFwABGJb391oJvv7upjUDJQ7CGvY: Пул 8dmfMP3ADXGiuxQLHFwABGJb391oJvv7upjUDJQ7CGvY имеет невалидный market_program_id 2025-10-21T16:04:28.184691Z WARN ⚠️ Не удалось распарсить пул 3EbDDX9bR2Gnc4BpXZzPTKMjbUUJwcejZUMCdaAszvF7: Пул 3EbDDX9bR2Gnc4BpXZzPTKMjbUUJwcejZUMCdaAszvF7 имеет невалидный market_program_id 2025-10-21T16:04:28.184749Z WARN ⚠️ Не удалось распарсить пул Cjj8gBhZKy2gHKyqLW4QSSnDNSEGEWMK44FahLTVJwxF: Пул Cjj8gBhZKy2gHKyqLW4QSSnDNSEGEWMK44FahLTVJwxF имеет невалидный market_program_id 2025-10-21T16:04:28.184806Z WARN ⚠️ Не удалось распарсить пул HCnbfzLLt8QAS2jaAidpoTpQfhk9xvvbaPQzxtXAVzFn: Пул HCnbfzLLt8QAS2jaAidpoTpQfhk9xvvbaPQzxtXAVzFn имеет невалидный market_program_id 2025-10-21T16:04:28.184866Z WARN ⚠️ Не удалось распарсить пул 7fyBquLnmwPPNUDnWs6bh64M3qmznWitYfSNi5TjjCYQ: Пул 7fyBquLnmwPPNUDnWs6bh64M3qmznWitYfSNi5TjjCYQ имеет невалидный market_program_id 2025-10-21T16:04:28.184924Z WARN ⚠️ Не удалось распарсить пул GKrLMiugMPXAir8Jm77YVLk7krJdrjKZPvruQgPJebzb: Пул GKrLMiugMPXAir8Jm77YVLk7krJdrjKZPvruQgPJebzb имеет невалидный market_program_id 2025-10-21T16:04:28.184981Z WARN ⚠️ Не удалось распарсить пул 57ibTAGYb2gExKmGxz2onu2xuVY8yJKWAzWX3cNYmq73: Пул 57ibTAGYb2gExKmGxz2onu2xuVY8yJKWAzWX3cNYmq73 имеет невалидный market_program_id 2025-10-21T16:04:28.185039Z WARN ⚠️ Не удалось распарсить пул DLsB2ojPjBNMUYRfhDpkoNtBei3MSgJXuh38Dyo7BpAK: Пул DLsB2ojPjBNMUYRfhDpkoNtBei3MSgJXuh38Dyo7BpAK имеет невалидный market_program_id 2025-10-21T16:04:28.185097Z WARN ⚠️ Не удалось распарсить пул GVNzVnnDjyzh9sLrXBbmuHr8uSx1G16yWfnkzSdSd1QV: Пул GVNzVnnDjyzh9sLrXBbmuHr8uSx1G16yWfnkzSdSd1QV имеет невалидный market_program_id 2025-10-21T16:04:28.185154Z WARN ⚠️ Не удалось распарсить пул C7NNx4VR7oDUiXe2rahU43VchpJ1MCq3mSfiHoGAonMn: Пул C7NNx4VR7oDUiXe2rahU43VchpJ1MCq3mSfiHoGAonMn имеет невалидный market_program_id 2025-10-21T16:04:28.185204Z WARN ⚠️ Не удалось распарсить пул DtcPMALiFGdTba3hB1sM2hawYqHG3pP7178wgteDh8zD: Пул DtcPMALiFGdTba3hB1sM2hawYqHG3pP7178wgteDh8zD имеет невалидный market_program_id 2025-10-21T16:04:28.185247Z WARN ⚠️ Не удалось распарсить пул DB1r78iHsyoCKnAkLnQ5xBDdj9VKC4vTZ9V84CEyCQP9: Пул DB1r78iHsyoCKnAkLnQ5xBDdj9VKC4vTZ9V84CEyCQP9 имеет невалидный market_program_id 2025-10-21T16:04:28.185288Z WARN ⚠️ Не удалось распарсить пул EBsAfUaE9o5jmQBj5FjcJMGCb2KdsfUvCAwZWXNQ4UAg: Пул EBsAfUaE9o5jmQBj5FjcJMGCb2KdsfUvCAwZWXNQ4UAg имеет невалидный market_program_id 2025-10-21T16:04:28.185330Z WARN ⚠️ Не удалось распарсить пул 4Ek4jkWg8nZj4vkz95e5dWM369Xxz2A9xE9QweKH9oUT: Пул 4Ek4jkWg8nZj4vkz95e5dWM369Xxz2A9xE9QweKH9oUT имеет невалидный market_program_id 2025-10-21T16:04:28.185372Z WARN ⚠️ Не удалось распарсить пул BUAKV9G5dy7JPkukE4gy5dK2CKFFbFsAyyGADv7hgn3V: Пул BUAKV9G5dy7JPkukE4gy5dK2CKFFbFsAyyGADv7hgn3V имеет невалидный market_program_id 2025-10-21T16:04:28.185447Z WARN ⚠️ Не удалось распарсить пул Gg8PHKgR7FWzcjEKjGLLFgjshzAWQC1gB6RQcmJMN81N: Пул Gg8PHKgR7FWzcjEKjGLLFgjshzAWQC1gB6RQcmJMN81N имеет невалидный market_program_id 2025-10-21T16:04:28.185523Z WARN ⚠️ Не удалось распарсить пул BddCQt4gozCp7Wpi2Mn95yj2kiJjDNQAZbmxftfZtRD7: Пул BddCQt4gozCp7Wpi2Mn95yj2kiJjDNQAZbmxftfZtRD7 имеет невалидный market_program_id 2025-10-21T16:04:28.185579Z WARN ⚠️ Не удалось распарсить пул 1wC1zR8PVk11jZubwGhYH2ecxfHkMDFj2XEsFeR7FV4: Пул 1wC1zR8PVk11jZubwGhYH2ecxfHkMDFj2XEsFeR7FV4 имеет невалидный market_program_id 2025-10-21T16:04:28.185626Z WARN ⚠️ Не удалось распарсить пул 26KJJUgXASUy3ZD2Q6LgfDPyGPVFtwcpZ5eGygZ2MZ5Q: Пул 26KJJUgXASUy3ZD2Q6LgfDPyGPVFtwcpZ5eGygZ2MZ5Q имеет невалидный market_program_id 2025-10-21T16:04:28.185706Z WARN ⚠️ Не удалось распарсить пул J74Fv9Va6ebhKwnRKs1MqB5WhGrU71BPQykCnjVMYknT: Пул J74Fv9Va6ebhKwnRKs1MqB5WhGrU71BPQykCnjVMYknT имеет невалидный market_program_id 2025-10-21T16:04:28.185944Z WARN ⚠️ Не удалось распарсить пул D1WtjKLDse6pmRRXd5E3ZgqHBtK6awuhnKUxf7kwr7hH: Пул D1WtjKLDse6pmRRXd5E3ZgqHBtK6awuhnKUxf7kwr7hH имеет невалидный market_program_id 2025-10-21T16:04:28.186027Z WARN ⚠️ Не удалось распарсить пул 9WUd1XigxKQzoQuPNjb5WK1vHdNR1VFy5HemdDmuyFMM: Пул 9WUd1XigxKQzoQuPNjb5WK1vHdNR1VFy5HemdDmuyFMM имеет невалидный market_program_id 2025-10-21T16:04:28.186074Z WARN ⚠️ Не удалось распарсить пул HnAjnyZeiGfrrNQXpv13FDs9v7LVNt5DiKW478bS9QHY: Пул HnAjnyZeiGfrrNQXpv13FDs9v7LVNt5DiKW478bS9QHY имеет невалидный market_program_id 2025-10-21T16:04:28.186116Z WARN ⚠️ Не удалось распарсить пул EBb2VxNqVVgQSjXrjGgpFRgi1PAjeUAVLhHwVtMdRsyh: Пул EBb2VxNqVVgQSjXrjGgpFRgi1PAjeUAVLhHwVtMdRsyh имеет невалидный market_program_id 2025-10-21T16:04:28.186157Z WARN ⚠️ Не удалось распарсить пул gb5oCCfaFLGkit1JzhRX9U4yVskJ89z2iJWxHboLfDn: Пул gb5oCCfaFLGkit1JzhRX9U4yVskJ89z2iJWxHboLfDn имеет невалидный market_program_id 2025-10-21T16:04:28.186198Z WARN ⚠️ Не удалось распарсить пул ErNiF1yrEThf1Eadn1Bse8YCEQAKmYo7L2uFRXjDNCoR: Пул ErNiF1yrEThf1Eadn1Bse8YCEQAKmYo7L2uFRXjDNCoR имеет невалидный market_program_id 2025-10-21T16:04:28.186239Z WARN ⚠️ Не удалось распарсить пул cvveZFWWJ2QjMTUj1MykiTciQtTu9oiGepVJJArj5Ld: Пул cvveZFWWJ2QjMTUj1MykiTciQtTu9oiGepVJJArj5Ld имеет невалидный market_program_id 2025-10-21T16:04:28.186280Z WARN ⚠️ Не удалось распарсить пул FmK8ed2uABbkfN6q9nSuGHekEigi2gCgBD9VgsX5z4Jc: Пул FmK8ed2uABbkfN6q9nSuGHekEigi2gCgBD9VgsX5z4Jc имеет невалидный market_program_id 2025-10-21T16:04:28.186321Z WARN ⚠️ Не удалось распарсить пул DhFCJuzba9hASw2UGr8e5dz4c7Pv9Nu7kZXRWN7xWAk8: Пул DhFCJuzba9hASw2UGr8e5dz4c7Pv9Nu7kZXRWN7xWAk8 имеет невалидный market_program_id 2025-10-21T16:04:28.186397Z WARN ⚠️ Не удалось распарсить пул 7p5kHW8reZFBYJ9CUUCC18c7qp7sJAUpifxZ72NSXKVa: Пул 7p5kHW8reZFBYJ9CUUCC18c7qp7sJAUpifxZ72NSXKVa имеет невалидный market_program_id 2025-10-21T16:04:28.186439Z WARN ⚠️ Не удалось распарсить пул WpA2ZNG7uTsSGa3o3Tacv3rAqwWtz3rvDDMSv8MQKQw: Пул WpA2ZNG7uTsSGa3o3Tacv3rAqwWtz3rvDDMSv8MQKQw имеет невалидный market_program_id 2025-10-21T16:04:28.186514Z WARN ⚠️ Не удалось распарсить пул 8pFodrQ9St5oQwgigqAiXmQRgdRytbWM4RUAwq7dGJDd: Пул 8pFodrQ9St5oQwgigqAiXmQRgdRytbWM4RUAwq7dGJDd имеет невалидный market_program_id 2025-10-21T16:04:28.186555Z WARN ⚠️ Не удалось распарсить пул JzJeTk27F19UJH9hU4DDc47F5YqR8fs1R6xbof2htUE: Пул JzJeTk27F19UJH9hU4DDc47F5YqR8fs1R6xbof2htUE имеет невалидный market_program_id 2025-10-21T16:04:28.186630Z WARN ⚠️ Не удалось распарсить пул CfmhzWqVBwoXjMpDj27AQAxHELw5tYMdag87JCKus4CS: Пул CfmhzWqVBwoXjMpDj27AQAxHELw5tYMdag87JCKus4CS имеет невалидный market_program_id 2025-10-21T16:04:28.186713Z WARN ⚠️ Не удалось распарсить пул 926hZ4Nyym18ZjYTb1J6h4Soc1T746dTzeufubbfSNkp: Пул 926hZ4Nyym18ZjYTb1J6h4Soc1T746dTzeufubbfSNkp имеет невалидный market_program_id 2025-10-21T16:04:28.186738Z WARN ⚠️ Не удалось распарсить пул CeoGd9a4XYWxqntX1qofDmzPKD4a5c2NG5CsCHjVwnnf: Пул CeoGd9a4XYWxqntX1qofDmzPKD4a5c2NG5CsCHjVwnnf имеет невалидный market_program_id 2025-10-21T16:04:28.186777Z WARN ⚠️ Не удалось распарсить пул Bz1kGp5mmR1ruKE2MS2ekLkXbmb89ckHkowW5mD53Njk: Пул Bz1kGp5mmR1ruKE2MS2ekLkXbmb89ckHkowW5mD53Njk имеет невалидный market_program_id 2025-10-21T16:04:28.186818Z WARN ⚠️ Не удалось распарсить пул 3gUuRRdxJRUkAy2LuNgST9aaXSjbGGAPuB1EWN77uHJE: Пул 3gUuRRdxJRUkAy2LuNgST9aaXSjbGGAPuB1EWN77uHJE имеет невалидный market_program_id 2025-10-21T16:04:28.186859Z WARN ⚠️ Не удалось распарсить пул 9xPnTkGF1bPN5LjttY6U3cX8vxDJM2ooYjKnu9xTSQCC: Пул 9xPnTkGF1bPN5LjttY6U3cX8vxDJM2ooYjKnu9xTSQCC имеет невалидный market_program_id 2025-10-21T16:04:28.186900Z WARN ⚠️ Не удалось распарсить пул GvhPCYvzYgouW78xELnqbAeAAZPkBdHpV1PGXeD4CYTh: Пул GvhPCYvzYgouW78xELnqbAeAAZPkBdHpV1PGXeD4CYTh имеет невалидный market_program_id 2025-10-21T16:04:28.186942Z WARN ⚠️ Не удалось распарсить пул jn99smVxBpXzgXjCFHdBRktnKywLyPp2iaFkriaTHcw: Пул jn99smVxBpXzgXjCFHdBRktnKywLyPp2iaFkriaTHcw имеет невалидный market_program_id 2025-10-21T16:04:28.186983Z WARN ⚠️ Не удалось распарсить пул 5eDJD64vWkeiWWKaLUQedsdphSkBu6KUurV4hWxt6XBp: Пул 5eDJD64vWkeiWWKaLUQedsdphSkBu6KUurV4hWxt6XBp имеет невалидный market_program_id 2025-10-21T16:04:28.187024Z WARN ⚠️ Не удалось распарсить пул H4CXnfk4Spn6onVcehZSJNykXu7hbDzEySuuz1AuNnTR: Пул H4CXnfk4Spn6onVcehZSJNykXu7hbDzEySuuz1AuNnTR имеет невалидный market_program_id 2025-10-21T16:04:28.187065Z WARN ⚠️ Не удалось распарсить пул FCXWK5SWpcEMY7pxtsf81ovz3L4kACLH5K4sri1eEBXN: Пул FCXWK5SWpcEMY7pxtsf81ovz3L4kACLH5K4sri1eEBXN имеет невалидный market_program_id 2025-10-21T16:04:28.187107Z WARN ⚠️ Не удалось распарсить пул 2XUQZNDGpxGnAK7BXDsYwz1WkZPvEaDEsshwCgoQEA3F: Пул 2XUQZNDGpxGnAK7BXDsYwz1WkZPvEaDEsshwCgoQEA3F имеет невалидный market_program_id 2025-10-21T16:04:28.187149Z WARN ⚠️ Не удалось распарсить пул C9yw2nGHdKWMHH1ATnXsaXMtCb9z24LRtTDWZqNGEd6D: Пул C9yw2nGHdKWMHH1ATnXsaXMtCb9z24LRtTDWZqNGEd6D имеет невалидный market_program_id 2025-10-21T16:04:28.187190Z WARN ⚠️ Не удалось распарсить пул DBDcY4XFxQDFBHGMf7DcmPNJCvZkxPDbaEQHGV3ufBzB: Пул DBDcY4XFxQDFBHGMf7DcmPNJCvZkxPDbaEQHGV3ufBzB имеет невалидный market_program_id 2025-10-21T16:04:28.187231Z WARN ⚠️ Не удалось распарсить пул 9sBmcZeHok5kwBuhP2iDQ3X4i5ooJLqgWe64vfVuCnrH: Пул 9sBmcZeHok5kwBuhP2iDQ3X4i5ooJLqgWe64vfVuCnrH имеет невалидный market_program_id 2025-10-21T16:04:28.187273Z WARN ⚠️ Не удалось распарсить пул D8nLHGu11oS6URKjoVk5wQ2JkpV1ibpWD7ceBHA3YoA9: Пул D8nLHGu11oS6URKjoVk5wQ2JkpV1ibpWD7ceBHA3YoA9 имеет невалидный market_program_id 2025-10-21T16:04:28.187314Z WARN ⚠️ Не удалось распарсить пул D8hkA6yk7CBFZQ7GG86vH7Tf4GrQvFsZXUfGqdM4DicW: Пул D8hkA6yk7CBFZQ7GG86vH7Tf4GrQvFsZXUfGqdM4DicW имеет невалидный market_program_id 2025-10-21T16:04:28.187338Z WARN ⚠️ Не удалось распарсить пул CL1NhVzAAcWawd74EacnfnhNSZ9M1ShFtfvt3m9H7GLt: Пул CL1NhVzAAcWawd74EacnfnhNSZ9M1ShFtfvt3m9H7GLt имеет невалидный market_program_id 2025-10-21T16:04:28.187376Z WARN ⚠️ Не удалось распарсить пул k6wBUcCUYLUiQDEnT8F4X647VaubLrSRYBgWxLtJ1GD: Пул k6wBUcCUYLUiQDEnT8F4X647VaubLrSRYBgWxLtJ1GD имеет невалидный market_program_id 2025-10-21T16:04:28.187417Z WARN ⚠️ Не удалось распарсить пул F6xji3h32yp7UBNCixnQcF8qN1nycgn6rkQgQgybv1Wm: Пул F6xji3h32yp7UBNCixnQcF8qN1nycgn6rkQgQgybv1Wm имеет невалидный market_program_id 2025-10-21T16:04:28.187458Z WARN ⚠️ Не удалось распарсить пул J9MxGWNuw8SmpJP2MBnJK4GT3BRuYjA3hKCv4C3uH5Tr: Пул J9MxGWNuw8SmpJP2MBnJK4GT3BRuYjA3hKCv4C3uH5Tr имеет невалидный market_program_id 2025-10-21T16:04:28.187499Z WARN ⚠️ Не удалось распарсить пул 4c2nNGTx8w7GaZDZq639j2tCZXWYEocaPGhd2RB2JGqM: Пул 4c2nNGTx8w7GaZDZq639j2tCZXWYEocaPGhd2RB2JGqM имеет невалидный market_program_id 2025-10-21T16:04:28.187542Z WARN ⚠️ Не удалось распарсить пул 9aV4fKLWjVdXmavHj36eaybB6dQ8ogMsbnxkL4vrkdmZ: Пул 9aV4fKLWjVdXmavHj36eaybB6dQ8ogMsbnxkL4vrkdmZ имеет невалидный market_program_id 2025-10-21T16:04:28.187583Z WARN ⚠️ Не удалось распарсить пул 8zAK5sMmeFkKZU5GpFtmDQwRsmxoEHK8DnsHnN8mzumN: Пул 8zAK5sMmeFkKZU5GpFtmDQwRsmxoEHK8DnsHnN8mzumN имеет невалидный market_program_id 2025-10-21T16:04:28.187624Z WARN ⚠️ Не удалось распарсить пул CnJ5VKMNQ1ErnbsZBxMZjuNVzMNgayEr43U3wp7J3Jya: Пул CnJ5VKMNQ1ErnbsZBxMZjuNVzMNgayEr43U3wp7J3Jya имеет невалидный market_program_id 2025-10-21T16:04:28.187673Z WARN ⚠️ Не удалось распарсить пул 95JXZW3Aa2CKZ6jwfR6qBcuMrDRvYCHuRq19xG62GHaN: Пул 95JXZW3Aa2CKZ6jwfR6qBcuMrDRvYCHuRq19xG62GHaN имеет невалидный market_program_id 2025-10-21T16:04:28.187716Z WARN ⚠️ Не удалось распарсить пул 74dvgnqbqTgApn9fc91hw2ASez82HuUd6LVEC7SzPPqn: Пул 74dvgnqbqTgApn9fc91hw2ASez82HuUd6LVEC7SzPPqn имеет невалидный market_program_id 2025-10-21T16:04:28.187757Z WARN ⚠️ Не удалось распарсить пул B6ayKDYFgrkesscQXHt9e6YsnRD7A7jHdmaFCApyaNFb: Пул B6ayKDYFgrkesscQXHt9e6YsnRD7A7jHdmaFCApyaNFb имеет невалидный market_program_id 2025-10-21T16:04:28.187799Z WARN ⚠️ Не удалось распарсить пул Ebbxrb6kMVR5VydSYS3xwFNYxVxsearzxjcV3XJV1YbA: Пул Ebbxrb6kMVR5VydSYS3xwFNYxVxsearzxjcV3XJV1YbA имеет невалидный market_program_id 2025-10-21T16:04:28.187840Z WARN ⚠️ Не удалось распарсить пул 8YrhozRND6w7AUKR81E3H8m8tQu9iSy9goRMz4yf5fbG: Пул 8YrhozRND6w7AUKR81E3H8m8tQu9iSy9goRMz4yf5fbG имеет невалидный market_program_id 2025-10-21T16:04:28.187881Z WARN ⚠️ Не удалось распарсить пул FZxAj5cbArVwAyxDmXv3AztPpZJmmf2uxiyVxsh6hwrB: Пул FZxAj5cbArVwAyxDmXv3AztPpZJmmf2uxiyVxsh6hwrB имеет невалидный market_program_id 2025-10-21T16:04:28.187923Z WARN ⚠️ Не удалось распарсить пул 6P3uVH81GFbsGU17vW2EijvrceZsZhAVZ5rXMgVG6zQj: Пул 6P3uVH81GFbsGU17vW2EijvrceZsZhAVZ5rXMgVG6zQj имеет невалидный market_program_id 2025-10-21T16:04:28.187965Z WARN ⚠️ Не удалось распарсить пул 4sQBtmaB3wQK1upjQ9smFeV8RS4TjCaVHsufhtDqkdo5: Пул 4sQBtmaB3wQK1upjQ9smFeV8RS4TjCaVHsufhtDqkdo5 имеет невалидный market_program_id 2025-10-21T16:04:28.187988Z WARN ⚠️ Не удалось распарсить пул GgZrTiVwPvTka3QZpjyxjEs8uqk3EieSKg63WBQCRBi7: Пул GgZrTiVwPvTka3QZpjyxjEs8uqk3EieSKg63WBQCRBi7 имеет невалидный market_program_id 2025-10-21T16:04:28.188026Z WARN ⚠️ Не удалось распарсить пул HJYqjY7N7ochxmvZxBWPNvQKEnMSTbdXv2PsioJ6n5RB: Пул HJYqjY7N7ochxmvZxBWPNvQKEnMSTbdXv2PsioJ6n5RB имеет невалидный market_program_id 2025-10-21T16:04:28.188067Z WARN ⚠️ Не удалось распарсить пул GS1HfLGHTuwkLnazeHfp2PUJwHFJw8LPiYqxokdNdDXc: Пул GS1HfLGHTuwkLnazeHfp2PUJwHFJw8LPiYqxokdNdDXc имеет невалидный market_program_id 2025-10-21T16:04:28.188109Z WARN ⚠️ Не удалось распарсить пул FwS6wp7qYgULCQYrMpA6dFEtupiqiJ7H1K2zF8fRczDo: Пул FwS6wp7qYgULCQYrMpA6dFEtupiqiJ7H1K2zF8fRczDo имеет невалидный market_program_id 2025-10-21T16:04:28.188150Z WARN ⚠️ Не удалось распарсить пул 2pe2vrTBR9HY48uLdRA76zviVQWP5wazn6rgSu5UDFWx: Пул 2pe2vrTBR9HY48uLdRA76zviVQWP5wazn6rgSu5UDFWx имеет невалидный market_program_id 2025-10-21T16:04:28.188192Z WARN ⚠️ Не удалось распарсить пул 4jW6ZCJt6Jud6PjVYNuntt9UY5npNKoiQ8t8i62Pj9mT: Пул 4jW6ZCJt6Jud6PjVYNuntt9UY5npNKoiQ8t8i62Pj9mT имеет невалидный market_program_id 2025-10-21T16:04:28.188233Z WARN ⚠️ Не удалось распарсить пул GnajiDU7UcHnRzREBNd2qBn8C8SGaeeFzws5Waf7VFdJ: Пул GnajiDU7UcHnRzREBNd2qBn8C8SGaeeFzws5Waf7VFdJ имеет невалидный market_program_id 2025-10-21T16:04:28.188275Z WARN ⚠️ Не удалось распарсить пул 3w6sQqNWqDtdPsAcaEwsmNi6uebtt8RrEXptfqNorMiN: Пул 3w6sQqNWqDtdPsAcaEwsmNi6uebtt8RrEXptfqNorMiN имеет невалидный market_program_id 2025-10-21T16:04:28.188316Z WARN ⚠️ Не удалось распарсить пул F6HJLrnv5Krxs1uBgiDeKBKWsvh8ms32EUkdPLqU9c6: Пул F6HJLrnv5Krxs1uBgiDeKBKWsvh8ms32EUkdPLqU9c6 имеет невалидный market_program_id 2025-10-21T16:04:28.188357Z WARN ⚠️ Не удалось распарсить пул C1JLfvzVHRfQkioo2vVHBR5mi61KbMNLsxang3MzhoNs: Пул C1JLfvzVHRfQkioo2vVHBR5mi61KbMNLsxang3MzhoNs имеет невалидный market_program_id 2025-10-21T16:04:28.188398Z WARN ⚠️ Не удалось распарсить пул DssBoVquDNpf8aeTF75YkY3z8k3jfUim33noicWdyhbL: Пул DssBoVquDNpf8aeTF75YkY3z8k3jfUim33noicWdyhbL имеет невалидный market_program_id 2025-10-21T16:04:28.188439Z WARN ⚠️ Не удалось распарсить пул 4D4XeEVdgPJGZnoBncBhijz1bNa3JjLKyk38HVRvAzTQ: Пул 4D4XeEVdgPJGZnoBncBhijz1bNa3JjLKyk38HVRvAzTQ имеет невалидный market_program_id 2025-10-21T16:04:28.188487Z WARN ⚠️ Не удалось распарсить пул BwzoNS1dsY7RzmZJX4btbhMgw24JX7cNAeJRMP1k4VRQ: Пул BwzoNS1dsY7RzmZJX4btbhMgw24JX7cNAeJRMP1k4VRQ имеет невалидный market_program_id 2025-10-21T16:04:28.188532Z WARN ⚠️ Не удалось распарсить пул 37Es8E2PSf1ub4pMNa7BsozQgu2h4MgfhjgKFkJQCBpZ: Пул 37Es8E2PSf1ub4pMNa7BsozQgu2h4MgfhjgKFkJQCBpZ имеет невалидный market_program_id 2025-10-21T16:04:28.188588Z WARN ⚠️ Не удалось распарсить пул SSgRRBHWRpbHu4LgdXNC5nrwMDNCBSEh4Tyb2524ixo: Пул SSgRRBHWRpbHu4LgdXNC5nrwMDNCBSEh4Tyb2524ixo имеет невалидный market_program_id 2025-10-21T16:04:28.188623Z WARN ⚠️ Не удалось распарсить пул 51UV5KBU1mSTxDpb46JsLEeVwBNRBUZcViACVQgUq4Z3: Пул 51UV5KBU1mSTxDpb46JsLEeVwBNRBUZcViACVQgUq4Z3 имеет невалидный market_program_id 2025-10-21T16:04:28.188652Z WARN ⚠️ Не удалось распарсить пул 2kBtaUHfcZ4JdajfLeXn3m2qaL9gCSH57TEQeAYowcV1: Пул 2kBtaUHfcZ4JdajfLeXn3m2qaL9gCSH57TEQeAYowcV1 имеет невалидный market_program_id 2025-10-21T16:04:28.188702Z WARN ⚠️ Не удалось распарсить пул C4aj2SxLq7nL7eN3xkw25Ugc1h1Z76CP886vo2KTRnNx: Пул C4aj2SxLq7nL7eN3xkw25Ugc1h1Z76CP886vo2KTRnNx имеет невалидный market_program_id 2025-10-21T16:04:28.188726Z WARN ⚠️ Не удалось распарсить пул ANzbszQodL1rRUZrVwoAwG6HhEcPhBg7FfDK8wxegut5: Пул ANzbszQodL1rRUZrVwoAwG6HhEcPhBg7FfDK8wxegut5 имеет невалидный market_program_id 2025-10-21T16:04:28.189619Z WARN ⚠️ Не удалось распарсить пул E6jqHjckYFLMkqo4D643JHnPup2TPjRqg2qvXPpSHgYP: Пул E6jqHjckYFLMkqo4D643JHnPup2TPjRqg2qvXPpSHgYP имеет невалидный market_program_id 2025-10-21T16:04:28.189692Z WARN ⚠️ Не удалось распарсить пул HeU53Vyjw3KCZZafvQXohnhuXz1aBXxWYE5UYJe8QXbG: Пул HeU53Vyjw3KCZZafvQXohnhuXz1aBXxWYE5UYJe8QXbG имеет невалидный market_program_id 2025-10-21T16:04:28.189751Z WARN ⚠️ Не удалось распарсить пул FUsfJqC2UTLYEjwtFshqe64aFqxfpcPDYSanFChWo4Bc: Пул FUsfJqC2UTLYEjwtFshqe64aFqxfpcPDYSanFChWo4Bc имеет невалидный market_program_id 2025-10-21T16:04:28.189808Z WARN ⚠️ Не удалось распарсить пул FNKZWnou5sh1CEXgAsHpBWWzBvqUAsJ64BY5kgUo7aWg: Пул FNKZWnou5sh1CEXgAsHpBWWzBvqUAsJ64BY5kgUo7aWg имеет невалидный market_program_id 2025-10-21T16:04:28.189865Z WARN ⚠️ Не удалось распарсить пул Fpe2eJEnjaSgAn2BMbGffUtbndKaZ4c5zDwKjr9A3Jjt: Пул Fpe2eJEnjaSgAn2BMbGffUtbndKaZ4c5zDwKjr9A3Jjt имеет невалидный market_program_id 2025-10-21T16:04:28.189921Z WARN ⚠️ Не удалось распарсить пул 7LTtut9QvzsYx5RT2AosQr9kgjq1hEohMrZHtK473Cod: Пул 7LTtut9QvzsYx5RT2AosQr9kgjq1hEohMrZHtK473Cod имеет невалидный market_program_id 2025-10-21T16:04:28.189978Z WARN ⚠️ Не удалось распарсить пул D77u6h6ArqP31dAuz5dK7ay794C1SUpCqZW6LCBeTAdA: Пул D77u6h6ArqP31dAuz5dK7ay794C1SUpCqZW6LCBeTAdA имеет невалидный market_program_id 2025-10-21T16:04:28.190034Z WARN ⚠️ Не удалось распарсить пул G36oqvBpR6rT6zY3XK3qrfi1p22J2pmQtDnekbr1KuoS: Пул G36oqvBpR6rT6zY3XK3qrfi1p22J2pmQtDnekbr1KuoS имеет невалидный market_program_id 2025-10-21T16:04:28.190090Z WARN ⚠️ Не удалось распарсить пул 83p2BwkGfMm8qtuddYShaJEjSDjMgjrhgQb33eFwY3Fr: Пул 83p2BwkGfMm8qtuddYShaJEjSDjMgjrhgQb33eFwY3Fr имеет невалидный market_program_id 2025-10-21T16:04:28.190146Z WARN ⚠️ Не удалось распарсить пул GRu65qozjZkx6z3GmbQuVgfCpewZgFcdSixX18qfwwF7: Пул GRu65qozjZkx6z3GmbQuVgfCpewZgFcdSixX18qfwwF7 имеет невалидный market_program_id 2025-10-21T16:04:28.190201Z WARN ⚠️ Не удалось распарсить пул 9kbL2vpRc64pr3HbsBzS3Ds6qxuJkEpopDoUEdMLUdea: Пул 9kbL2vpRc64pr3HbsBzS3Ds6qxuJkEpopDoUEdMLUdea имеет невалидный market_program_id 2025-10-21T16:04:28.190259Z WARN ⚠️ Не удалось распарсить пул GYVuewXzCxahr5AAcUqdPCUAXwM4SLFt7oyQprffnyTp: Пул GYVuewXzCxahr5AAcUqdPCUAXwM4SLFt7oyQprffnyTp имеет невалидный market_program_id 2025-10-21T16:04:28.190316Z WARN ⚠️ Не удалось распарсить пул 4ZyywLpohAcqn8qtoXPiT2Z17DGammDwvuDXTZEZxT7B: Пул 4ZyywLpohAcqn8qtoXPiT2Z17DGammDwvuDXTZEZxT7B имеет невалидный market_program_id 2025-10-21T16:04:28.190372Z WARN ⚠️ Не удалось распарсить пул 5YsEjNU1p5wLAXM6UoT4vjsFhTWUTRSY31tgULJqEYov: Пул 5YsEjNU1p5wLAXM6UoT4vjsFhTWUTRSY31tgULJqEYov имеет невалидный market_program_id 2025-10-21T16:04:28.190427Z WARN ⚠️ Не удалось распарсить пул 8Wj6336idGaxGacsnzZ4SNb2DCUodniATJ2X7zd9Qga2: Пул 8Wj6336idGaxGacsnzZ4SNb2DCUodniATJ2X7zd9Qga2 имеет невалидный market_program_id 2025-10-21T16:04:28.190483Z WARN ⚠️ Не удалось распарсить пул 3AoBDbSSzRwa1hK6i2hoMqpKD3qatYwanB1nJHH9L9GS: Пул 3AoBDbSSzRwa1hK6i2hoMqpKD3qatYwanB1nJHH9L9GS имеет невалидный market_program_id 2025-10-21T16:04:28.190540Z WARN ⚠️ Не удалось распарсить пул HPk94pxknqkd28XCyFFDSYSuffweiy5BgtAk4Fmts1Zm: Пул HPk94pxknqkd28XCyFFDSYSuffweiy5BgtAk4Fmts1Zm имеет невалидный market_program_id 2025-10-21T16:04:28.190596Z WARN ⚠️ Не удалось распарсить пул k7As8639j6PwkQi1B4kj55wHN5k9ko3xJFqUkpzpsjA: Пул k7As8639j6PwkQi1B4kj55wHN5k9ko3xJFqUkpzpsjA имеет невалидный market_program_id 2025-10-21T16:04:28.190631Z WARN ⚠️ Не удалось распарсить пул HRcE9yPaRTZRkV9BMJ2r2ZGXM9YxpnXjcvxjEWkZVHdD: Пул HRcE9yPaRTZRkV9BMJ2r2ZGXM9YxpnXjcvxjEWkZVHdD имеет невалидный market_program_id 2025-10-21T16:04:28.190693Z WARN ⚠️ Не удалось распарсить пул 5VWBFPTLE7zAXczcYSdSaBkS2cGbjvKGo6QvV1ygBCGv: Пул 5VWBFPTLE7zAXczcYSdSaBkS2cGbjvKGo6QvV1ygBCGv имеет невалидный market_program_id 2025-10-21T16:04:28.190748Z WARN ⚠️ Не удалось распарсить пул UzQPezHkQfqS2RZKJyuEoWvParEidfkVaeaBdXdf6Ny: Пул UzQPezHkQfqS2RZKJyuEoWvParEidfkVaeaBdXdf6Ny имеет невалидный market_program_id 2025-10-21T16:04:28.190803Z WARN ⚠️ Не удалось распарсить пул gbStTJFmvXpt2X8qEVbkWccaZ2BVhgU6S7kCjnLzMMQ: Пул gbStTJFmvXpt2X8qEVbkWccaZ2BVhgU6S7kCjnLzMMQ имеет невалидный market_program_id 2025-10-21T16:04:28.190858Z WARN ⚠️ Не удалось распарсить пул 5PzbFoYDLoxnfY8Pp6EvmkKZjrrpo7X151q1paGu4siS: Пул 5PzbFoYDLoxnfY8Pp6EvmkKZjrrpo7X151q1paGu4siS имеет невалидный market_program_id 2025-10-21T16:04:28.190913Z WARN ⚠️ Не удалось распарсить пул A8RDp5bHCJQbepWeWZgm35e8F6LQU9Vg5Yjup8cw65FP: Пул A8RDp5bHCJQbepWeWZgm35e8F6LQU9Vg5Yjup8cw65FP имеет невалидный market_program_id 2025-10-21T16:04:28.190969Z WARN ⚠️ Не удалось распарсить пул 3yKdBLv5NfwN6yL8XDfkXKCeYnG1Fk6bCxse72QB7NfA: Пул 3yKdBLv5NfwN6yL8XDfkXKCeYnG1Fk6bCxse72QB7NfA имеет невалидный market_program_id 2025-10-21T16:04:28.191024Z WARN ⚠️ Не удалось распарсить пул 6je843kXbMLTftqEyG6kjJgs2fqos6YQGFhXR23wCkMV: Пул 6je843kXbMLTftqEyG6kjJgs2fqos6YQGFhXR23wCkMV имеет невалидный market_program_id 2025-10-21T16:04:28.191081Z WARN ⚠️ Не удалось распарсить пул 8MbFv4bx7pxCFDT2ujJmXswuW2Erksj3zemtAJnGNLMj: Пул 8MbFv4bx7pxCFDT2ujJmXswuW2Erksj3zemtAJnGNLMj имеет невалидный market_program_id 2025-10-21T16:04:28.191138Z WARN ⚠️ Не удалось распарсить пул CDc5E4TuSgjHrRunR9TY3PWkzZw7UAJSVwTvPthAhTrL: Пул CDc5E4TuSgjHrRunR9TY3PWkzZw7UAJSVwTvPthAhTrL имеет невалидный market_program_id 2025-10-21T16:04:28.191195Z WARN ⚠️ Не удалось распарсить пул ZqGaeMkRKzJBaRvT5MJSApwDrr4XUJfHDC6Pr6FYJWY: Пул ZqGaeMkRKzJBaRvT5MJSApwDrr4XUJfHDC6Pr6FYJWY имеет невалидный market_program_id 2025-10-21T16:04:28.191250Z WARN ⚠️ Не удалось распарсить пул DgCJg1YtRC9T8fANZSZ2CBJFYLtrmdANTSt3VzY3rGhK: Пул DgCJg1YtRC9T8fANZSZ2CBJFYLtrmdANTSt3VzY3rGhK имеет невалидный market_program_id 2025-10-21T16:04:28.191305Z WARN ⚠️ Не удалось распарсить пул 7sorhA5e6Jou35hMrE2cLgm6WeudkqCA5GqsxTNvFyQd: Пул 7sorhA5e6Jou35hMrE2cLgm6WeudkqCA5GqsxTNvFyQd имеет невалидный market_program_id 2025-10-21T16:04:28.191360Z WARN ⚠️ Не удалось распарсить пул 2BdQJeENa7MLjbXDZGQDiAxzo6PHuzDVBereiC4RAZMd: Пул 2BdQJeENa7MLjbXDZGQDiAxzo6PHuzDVBereiC4RAZMd имеет невалидный market_program_id 2025-10-21T16:04:28.191415Z WARN ⚠️ Не удалось распарсить пул Fbf8SFKDCALKmpCrrpPErE4vxi6njAj9dwgHYohnCn4E: Пул Fbf8SFKDCALKmpCrrpPErE4vxi6njAj9dwgHYohnCn4E имеет невалидный market_program_id 2025-10-21T16:04:28.191470Z WARN ⚠️ Не удалось распарсить пул 83teax7QSBscNCug66NVzGTRw3Nd9qK3kqkfhMFiwpiz: Пул 83teax7QSBscNCug66NVzGTRw3Nd9qK3kqkfhMFiwpiz имеет невалидный market_program_id 2025-10-21T16:04:28.191527Z WARN ⚠️ Не удалось распарсить пул 43bmngdV2eSYAQYwkVCgd5fTpGB4kQ2vNNNZ4f1QQpgk: Пул 43bmngdV2eSYAQYwkVCgd5fTpGB4kQ2vNNNZ4f1QQpgk имеет невалидный market_program_id 2025-10-21T16:04:28.191582Z WARN ⚠️ Не удалось распарсить пул 5N1kEEMnRTQpZuM1xhu6qzS92HVGp3CEx7G9MvtncbXo: Пул 5N1kEEMnRTQpZuM1xhu6qzS92HVGp3CEx7G9MvtncbXo имеет невалидный market_program_id 2025-10-21T16:04:28.191648Z WARN ⚠️ Не удалось распарсить пул 5cvNkNC9rJnmYMvJrsCNEott4qKMnb2vhZaa2jNDeged: Пул 5cvNkNC9rJnmYMvJrsCNEott4qKMnb2vhZaa2jNDeged имеет невалидный market_program_id 2025-10-21T16:04:28.191719Z WARN ⚠️ Не удалось распарсить пул 97p3acpjRH9kZJ189fRHzVzmWiTSsSoGZeCwFNmHDQhf: Пул 97p3acpjRH9kZJ189fRHzVzmWiTSsSoGZeCwFNmHDQhf имеет невалидный market_program_id 2025-10-21T16:04:28.191777Z WARN ⚠️ Не удалось распарсить пул 5LhbzzHuM8KmrgpMSG2x4LT3LkQr7mqggM7kPVBhU16H: Пул 5LhbzzHuM8KmrgpMSG2x4LT3LkQr7mqggM7kPVBhU16H имеет невалидный market_program_id 2025-10-21T16:04:28.191832Z WARN ⚠️ Не удалось распарсить пул 8pmaE9t2i6UocYQ5ruQNB4yd8EEAhgRa99pwKvfi3cpW: Пул 8pmaE9t2i6UocYQ5ruQNB4yd8EEAhgRa99pwKvfi3cpW имеет невалидный market_program_id 2025-10-21T16:04:28.191890Z WARN ⚠️ Не удалось распарсить пул 38s2X3yfrqeSVuoJEv1LBfxzCXt2DSwD1mwWExSPpjbM: Пул 38s2X3yfrqeSVuoJEv1LBfxzCXt2DSwD1mwWExSPpjbM имеет невалидный market_program_id 2025-10-21T16:04:28.191946Z WARN ⚠️ Не удалось распарсить пул HKk6Xg7Hh9tp92LXRxMMSoGd4KM562p7BbzE95razuyY: Пул HKk6Xg7Hh9tp92LXRxMMSoGd4KM562p7BbzE95razuyY имеет невалидный market_program_id 2025-10-21T16:04:28.191983Z WARN ⚠️ Не удалось распарсить пул CwrwTpSzWfLTLfmW8M89wrmfcz5yFPZbLsx1mXFdRdfi: Пул CwrwTpSzWfLTLfmW8M89wrmfcz5yFPZbLsx1mXFdRdfi имеет невалидный market_program_id 2025-10-21T16:04:28.192034Z WARN ⚠️ Не удалось распарсить пул CQqkQEFNFatvoj38b4VpygFFix52MGLsApeAzGYJBbhn: Пул CQqkQEFNFatvoj38b4VpygFFix52MGLsApeAzGYJBbhn имеет невалидный market_program_id 2025-10-21T16:04:28.192090Z WARN ⚠️ Не удалось распарсить пул 8v6E43SsBAqMwNJqgSx6t3c2QoX1MfgenrYdALV2yue8: Пул 8v6E43SsBAqMwNJqgSx6t3c2QoX1MfgenrYdALV2yue8 имеет невалидный market_program_id 2025-10-21T16:04:28.192144Z WARN ⚠️ Не удалось распарсить пул GDvkYJNvu8FvvwXJaHZVKp5sT42ewCDDRjok29hioi9x: Пул GDvkYJNvu8FvvwXJaHZVKp5sT42ewCDDRjok29hioi9x имеет невалидный market_program_id 2025-10-21T16:04:28.192199Z WARN ⚠️ Не удалось распарсить пул FRQx3aGyi9DPs7ykNtDyifXcDLrSehvitS1fMzxCLu85: Пул FRQx3aGyi9DPs7ykNtDyifXcDLrSehvitS1fMzxCLu85 имеет невалидный market_program_id 2025-10-21T16:04:28.192254Z WARN ⚠️ Не удалось распарсить пул 6YkrTbeyLZmM63xpuni13cKppRSaVcQQ1FV6b9cLmCBG: Пул 6YkrTbeyLZmM63xpuni13cKppRSaVcQQ1FV6b9cLmCBG имеет невалидный market_program_id 2025-10-21T16:04:28.192311Z WARN ⚠️ Не удалось распарсить пул 6xF6MYmSKq418xo9PCWALqARuhRr9oqyLXMsFWimaGf3: Пул 6xF6MYmSKq418xo9PCWALqARuhRr9oqyLXMsFWimaGf3 имеет невалидный market_program_id 2025-10-21T16:04:28.192366Z WARN ⚠️ Не удалось распарсить пул 97uHcsMfunbszngY99rRCbiZzjPLeiQULnhHADEacsLa: Пул 97uHcsMfunbszngY99rRCbiZzjPLeiQULnhHADEacsLa имеет невалидный market_program_id 2025-10-21T16:04:28.192421Z WARN ⚠️ Не удалось распарсить пул 2DWFQVcSb9DjHX3faL5G9BwCX8cXrcW9ZXV5zcyMmNnb: Пул 2DWFQVcSb9DjHX3faL5G9BwCX8cXrcW9ZXV5zcyMmNnb имеет невалидный market_program_id 2025-10-21T16:04:28.192476Z WARN ⚠️ Не удалось распарсить пул FuBgVRmeHHj14Vt5xgcVX6wCPimKYZsYtitAxGhY3R5n: Пул FuBgVRmeHHj14Vt5xgcVX6wCPimKYZsYtitAxGhY3R5n имеет невалидный market_program_id 2025-10-21T16:04:28.192532Z WARN ⚠️ Не удалось распарсить пул 35HKvgE6UrKdYrjXjAvSwEucdC1vRN7y9aQGrV9HjqDS: Пул 35HKvgE6UrKdYrjXjAvSwEucdC1vRN7y9aQGrV9HjqDS имеет невалидный market_program_id 2025-10-21T16:04:28.192596Z WARN ⚠️ Не удалось распарсить пул BvdCHHS6CP3Uc73ib2XkrnTM43ZTjeN2Fk4YXeiD5mHu: Пул BvdCHHS6CP3Uc73ib2XkrnTM43ZTjeN2Fk4YXeiD5mHu имеет невалидный market_program_id 2025-10-21T16:04:28.192653Z WARN ⚠️ Не удалось распарсить пул 4n8W7qCTeMqVPBECHSaNuHSKjXvo8joRBRNJUwU8UBUq: Пул 4n8W7qCTeMqVPBECHSaNuHSKjXvo8joRBRNJUwU8UBUq имеет невалидный market_program_id 2025-10-21T16:04:28.192718Z WARN ⚠️ Не удалось распарсить пул B3AisLsG9yK5sfCjqz2HuYMAHiz8mBtUBv9kVtkxyUDT: Пул B3AisLsG9yK5sfCjqz2HuYMAHiz8mBtUBv9kVtkxyUDT имеет невалидный market_program_id 2025-10-21T16:04:28.192774Z WARN ⚠️ Не удалось распарсить пул 6MrMzTc6Q2D1iU3gjxtJVVuyAmWnSvZ3GDQNuC3vuN2c: Пул 6MrMzTc6Q2D1iU3gjxtJVVuyAmWnSvZ3GDQNuC3vuN2c имеет невалидный market_program_id 2025-10-21T16:04:28.192830Z WARN ⚠️ Не удалось распарсить пул 9yH2jSmcnD3BVk2JcoSPjEzfwSu9fYCKgTMSrbVB1XZY: Пул 9yH2jSmcnD3BVk2JcoSPjEzfwSu9fYCKgTMSrbVB1XZY имеет невалидный market_program_id 2025-10-21T16:04:28.192887Z WARN ⚠️ Не удалось распарсить пул DiaBbjfJ1yYDuNvNmuc5sdni69PYxzzAkUecBdsfJmSQ: Пул DiaBbjfJ1yYDuNvNmuc5sdni69PYxzzAkUecBdsfJmSQ имеет невалидный market_program_id 2025-10-21T16:04:28.192943Z WARN ⚠️ Не удалось распарсить пул N16yDRAZqBGe8qwiebaW31o4jBTKXfUrGUpYDZhfYp9: Пул N16yDRAZqBGe8qwiebaW31o4jBTKXfUrGUpYDZhfYp9 имеет невалидный market_program_id 2025-10-21T16:04:28.192999Z WARN ⚠️ Не удалось распарсить пул FzytLbAGqhschYmjPdLHEZkeXmKPGN3QuchPbjjFGGCM: Пул FzytLbAGqhschYmjPdLHEZkeXmKPGN3QuchPbjjFGGCM имеет невалидный market_program_id 2025-10-21T16:04:28.193055Z WARN ⚠️ Не удалось распарсить пул 83KtdsfcyB336kH8b3JRoWMLngc9q9MfAUcd8SdQegJn: Пул 83KtdsfcyB336kH8b3JRoWMLngc9q9MfAUcd8SdQegJn имеет невалидный market_program_id 2025-10-21T16:04:28.193260Z WARN ⚠️ Не удалось распарсить пул 4RFUqTvf6ggBxKAbpjSeVk3NgDk1kqEBJyAcHLePi9Ck: Пул 4RFUqTvf6ggBxKAbpjSeVk3NgDk1kqEBJyAcHLePi9Ck имеет невалидный market_program_id 2025-10-21T16:04:28.193326Z WARN ⚠️ Не удалось распарсить пул 5EhMmP5TGZUD5vcT8X2jGbBanMkpLZqpv8BnFpAr34rx: Пул 5EhMmP5TGZUD5vcT8X2jGbBanMkpLZqpv8BnFpAr34rx имеет невалидный market_program_id 2025-10-21T16:04:28.193384Z WARN ⚠️ Не удалось распарсить пул D3ffq5vpsW7GtF3wkUao6eqw7Cicz7vnkNPKMWZJBPUW: Пул D3ffq5vpsW7GtF3wkUao6eqw7Cicz7vnkNPKMWZJBPUW имеет невалидный market_program_id 2025-10-21T16:04:28.193440Z WARN ⚠️ Не удалось распарсить пул DMqtJdPNSnpoDgR3b2CnGmPLHauFZ9R9wEByJSVZbd68: Пул DMqtJdPNSnpoDgR3b2CnGmPLHauFZ9R9wEByJSVZbd68 имеет невалидный market_program_id 2025-10-21T16:04:28.193496Z WARN ⚠️ Не удалось распарсить пул FJ2TYMP4Y1PBk3DiMoDiP2wCxJ92rK6ET7rJxKBra9qM: Пул FJ2TYMP4Y1PBk3DiMoDiP2wCxJ92rK6ET7rJxKBra9qM имеет невалидный market_program_id 2025-10-21T16:04:28.193553Z WARN ⚠️ Не удалось распарсить пул CJ4QrBTBEqzfwY5AREiz6BAQiYCcCAsZXFdRorUDamSA: Пул CJ4QrBTBEqzfwY5AREiz6BAQiYCcCAsZXFdRorUDamSA имеет невалидный market_program_id 2025-10-21T16:04:28.193609Z WARN ⚠️ Не удалось распарсить пул HuAYofrQeqtBdcq5o2ycFoc6Jrt2idEAUan2RTWWak9G: Пул HuAYofrQeqtBdcq5o2ycFoc6Jrt2idEAUan2RTWWak9G имеет невалидный market_program_id 2025-10-21T16:04:28.193665Z WARN ⚠️ Не удалось распарсить пул RXBFt1pULfns7WPtnzKsG49zeuWLXgacXNTWj7wMUd2: Пул RXBFt1pULfns7WPtnzKsG49zeuWLXgacXNTWj7wMUd2 имеет невалидный market_program_id 2025-10-21T16:04:28.193741Z WARN ⚠️ Не удалось распарсить пул pe87ELnRECdw3Gr5Hmmnf7fgdbqNAuhojzM9sJC2X8G: Пул pe87ELnRECdw3Gr5Hmmnf7fgdbqNAuhojzM9sJC2X8G имеет невалидный market_program_id 2025-10-21T16:04:28.193797Z WARN ⚠️ Не удалось распарсить пул GRiyq2WUwrahzyPUNtWtGyBpD6544fxsbWemV6xm58Wp: Пул GRiyq2WUwrahzyPUNtWtGyBpD6544fxsbWemV6xm58Wp имеет невалидный market_program_id 2025-10-21T16:04:28.193852Z WARN ⚠️ Не удалось распарсить пул EyudGznd6Zh2ENdSSsLJAXUt1iyVHLFaYP3Sm35vnn2A: Пул EyudGznd6Zh2ENdSSsLJAXUt1iyVHLFaYP3Sm35vnn2A имеет невалидный market_program_id 2025-10-21T16:04:28.193940Z WARN ⚠️ Не удалось распарсить пул DUUUFpKK7cZ6d4e1v16madEEnRxN3hU9LnpAgM3ipYM1: Пул DUUUFpKK7cZ6d4e1v16madEEnRxN3hU9LnpAgM3ipYM1 имеет невалидный market_program_id 2025-10-21T16:04:28.194027Z WARN ⚠️ Не удалось распарсить пул 4QVD1qqiqr3WYrvDjcmHEVH96UVgmNduBXsFFzCgGaUf: Пул 4QVD1qqiqr3WYrvDjcmHEVH96UVgmNduBXsFFzCgGaUf имеет невалидный market_program_id 2025-10-21T16:04:28.194082Z WARN ⚠️ Не удалось распарсить пул 3AchjHmMujJW4HRiYLztLFyK5w8QFY7oiteZa4ASHdV9: Пул 3AchjHmMujJW4HRiYLztLFyK5w8QFY7oiteZa4ASHdV9 имеет невалидный market_program_id 2025-10-21T16:04:28.194136Z WARN ⚠️ Не удалось распарсить пул 4RTnTVc3Y14geycFGeDUfs3t2W2TgbgCwwQidabxxCXE: Пул 4RTnTVc3Y14geycFGeDUfs3t2W2TgbgCwwQidabxxCXE имеет невалидный market_program_id 2025-10-21T16:04:28.194190Z WARN ⚠️ Не удалось распарсить пул DpU3oYfeQbbH5M7sgNDzYYaRRRJucGQoXJcgvifrpFB5: Пул DpU3oYfeQbbH5M7sgNDzYYaRRRJucGQoXJcgvifrpFB5 имеет невалидный market_program_id 2025-10-21T16:04:28.194245Z WARN ⚠️ Не удалось распарсить пул 4RNPXsyHE3PJn4cuHb41WdECUJ2ipoXRcXRBD3kn12a5: Пул 4RNPXsyHE3PJn4cuHb41WdECUJ2ipoXRcXRBD3kn12a5 имеет невалидный market_program_id 2025-10-21T16:04:28.194588Z WARN ⚠️ Не удалось распарсить пул 8P1DZrmPEdwhGo2e6rgitX7RB1Hj2XPeoo3RTZcwcE4P: Пул 8P1DZrmPEdwhGo2e6rgitX7RB1Hj2XPeoo3RTZcwcE4P имеет невалидный market_program_id 2025-10-21T16:04:28.194648Z WARN ⚠️ Не удалось распарсить пул 3PRvwtB6F3iPKmPM3HJKojp5CVVnVDU35pRLFx2pgNZE: Пул 3PRvwtB6F3iPKmPM3HJKojp5CVVnVDU35pRLFx2pgNZE имеет невалидный market_program_id 2025-10-21T16:04:28.194709Z INFO ✅ Сканирование завершено: 0 успешных, 313 ошибок, всего пулов: 0 2025-10-21T16:04:28.194742Z WARN ⚠️ Не найдено ни одного валидного пула! 2025-10-21T16:04:28.194821Z INFO 📡 Сканирование Raydium CPMM пулов на devnet... 2025-10-21T16:04:28.194854Z WARN ⚠️ Нет известных Raydium CPMM пулов на devnet. 2025-10-21T16:04:28.194888Z INFO 📡 Сканирование Raydium CLMM пулов на devnet... 2025-10-21T16:04:28.194920Z WARN ⚠️ Нет известных Raydium CLMM пулов на devnet. 2025-10-21T16:04:28.194954Z INFO 📡 Сканирование Meteora DLMM пулов через API... Видно что бот работает, но он не может получить информацию из пулов чтобы запустить программу на поиск арбитражных возможностей чтобы совершить прибыльную сделку. Мне необходимо сделать рабочие пулы AMM, CLMM, CPMM, DLMM для того чтобы в каждом из пулов была возможность совершить прибыльный свап если он найдется, и не совершить свап если такого нет. 1) Основная цель воссоздать приближенные к mainnet условия в devnet для тестирования бота. 2) Внести все необходимые улучшения в бота, тот же параллельный поиск по пулам через rayon 3) Проанализируй весь код моего проекта который я прикрепил в файле arbitrage-bot-rust.txt, и дай свою оценку по улучшениям и исправлениям ПОЛНЫЙ КОД МОЕГО ПРОЕКТА: --- File: /home/newvovi5/arbitrage-bot-rust/debug-pool-structure.js --- // debug-pool-structure.js const { Connection, PublicKey } = require('@solana/web3.js'); const connection = new Connection('https://api.devnet.solana.com', 'confirmed'); async function debugPoolStructure() { console.log('🔍 Анализ структуры пулов Raydium AMM V4...'); const RAYDIUM_AMM = new PublicKey('DRaya7Kj3aMWQSy19kSjvmuwq9docCHofyP9kanQGaav'); try { const accounts = await connection.getProgramAccounts(RAYDIUM_AMM, { filters: [{ dataSize: 752 }], dataSlice: { offset: 0, length: 100 } // Берем только первые 100 байт для анализа }); console.log(`📊 Найдено ${accounts.length} пулов размером 752 байта`); if (accounts.length > 0) { const firstPool = accounts[0]; console.log('🎯 Анализ первого пула:', firstPool.pubkey.toString()); console.log('📁 Размер данных:', firstPool.account.data.length); // Выводим hex-dump первых 100 байт const hex = Buffer.from(firstPool.account.data).toString('hex'); console.log('🔍 Первые 100 байт (hex):'); for (let i = 0; i < Math.min(hex.length, 200); i += 64) { const offset = i / 2; const chunk = hex.substr(i, 64); console.log(` ${offset.toString().padStart(3, '0')}: ${chunk}`); } } // Проверим также полный размер const fullAccounts = await connection.getProgramAccounts(RAYDIUM_AMM, { filters: [] // Без фильтров размера }); if (fullAccounts.length > 0) { const sizes = fullAccounts.map(acc => acc.account.data.length); const uniqueSizes = [...new Set(sizes)].sort((a, b) => a - b); console.log('\n📐 Найденные размеры аккаунтов:'); uniqueSizes.forEach(size => { const count = sizes.filter(s => s === size).length; console.log(` ${size} байт: ${count} аккаунтов`); }); } } catch (error) { console.error('❌ Ошибка:', error); } } debugPoolStructure(); --- End File: /home/newvovi5/arbitrage-bot-rust/debug-pool-structure.js --- --- File: /home/newvovi5/arbitrage-bot-rust/.cargo/config.toml --- # .cargo/config.toml [build] rustflags = [ "-A", "dead_code", "-A", "unused_imports", "-A", "unused_variables", "-A", "unexpected_cfgs" ] --- End File: /home/newvovi5/arbitrage-bot-rust/.cargo/config.toml --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/raydium_clmm.rs --- // bot/src/scanner/raydium_clmm.rs use anyhow::Result; use solana_sdk::pubkey::Pubkey; use std::str::FromStr; use tracing::{info, warn}; use crate::config::BotConfig; use crate::types::{PoolState, DexProtocol}; use super::DexScanner; #[derive(Clone)] pub struct RaydiumClmmScanner { config: std::sync::Arc, program_id: Pubkey, } impl RaydiumClmmScanner { pub fn new(config: std::sync::Arc) -> Self { let program_id = Pubkey::from_str("DRayAUgENGQBKVaX8owNhgzkEDyoHTGVEGHVJT1E9pfH") .expect("Invalid Raydium CLMM program ID"); Self { config, program_id } } /// Парсинг данных пула Raydium CLMM fn parse_pool_account(&self, pool_id: Pubkey, data: &[u8]) -> Result { if data.len() < 1544 { anyhow::bail!("Недостаточно данных для парсинга пула CLMM"); } let token_a = Pubkey::new_from_array(data[73..105].try_into()?); let token_b = Pubkey::new_from_array(data[105..137].try_into()?); let reserve_a = 1_000_000_000; let reserve_b = 1_000_000_000; Ok(PoolState { id: pool_id, protocol: DexProtocol::RaydiumClmm, token_a, token_b, reserve_a, reserve_b, fee_bps: 25, last_updated: chrono::Utc::now().timestamp(), full_state_data: data.to_vec(), }) } } #[async_trait::async_trait] impl DexScanner for RaydiumClmmScanner { fn protocol(&self) -> DexProtocol { DexProtocol::RaydiumClmm } async fn scan_pools(&self) -> Result> { info!("📡 Сканирование Raydium CLMM пулов на devnet..."); let known_pools: Vec<&str> = vec![ // Добавьте адреса тестовых CLMM пулов ]; if known_pools.is_empty() { warn!("⚠️ Нет известных Raydium CLMM пулов на devnet."); return Ok(vec![]); } let pools = Vec::new(); info!("✅ Raydium CLMM: найдено {} пулов", pools.len()); Ok(pools) } fn clone_box(&self) -> Box { Box::new(self.clone()) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/raydium_clmm.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/pool_monitor.rs --- // bot/src/scanner/pool_monitor.rs // Мониторинг изменений в пулах в реальном времени // use anyhow::Result; use dashmap::DashMap; use solana_sdk::pubkey::Pubkey; use std::sync::Arc; use tokio::time::{interval, Duration}; use tracing::{info, debug}; use crate::types::PoolState; /// Кэш состояний пулов с автообновлением pub struct PoolMonitor { /// Кэш пулов: pool_id -> PoolState cache: Arc>, /// Интервал обновления в миллисекундах update_interval_ms: u64, } impl PoolMonitor { pub fn new(update_interval_ms: u64) -> Self { Self { cache: Arc::new(DashMap::new()), update_interval_ms, } } /// Обновление состояния пула pub fn update_pool(&self, pool: PoolState) { let pool_id = pool.id; // Проверяем значительность изменения if let Some(old_pool) = self.cache.get(&pool_id) { let price_change = self.calculate_price_change(&old_pool, &pool); if price_change > 0.5 { debug!("Значительное изменение цены в пуле {}: {:.2}%", pool_id, price_change); } } self.cache.insert(pool_id, pool); } /// Получение всех пулов из кэша pub fn get_all_pools(&self) -> Vec { self.cache.iter() .map(|entry| entry.value().clone()) .collect() } /// Получение конкретного пула pub fn get_pool(&self, pool_id: &Pubkey) -> Option { self.cache.get(pool_id).map(|entry| entry.value().clone()) } /// Количество пулов в кэше pub fn pool_count(&self) -> usize { self.cache.len() } /// Расчёт изменения цены в процентах fn calculate_price_change(&self, old: &PoolState, new: &PoolState) -> f64 { let old_price = old.price_a_to_b(); let new_price = new.price_a_to_b(); if old_price == 0.0 { return 0.0; } ((new_price - old_price) / old_price).abs() * 100.0 } /// Очистка устаревших пулов (старше threshold_seconds) pub fn cleanup_stale_pools(&self, threshold_seconds: i64) { let now = chrono::Utc::now().timestamp(); self.cache.retain(|_pool_id, pool| { let age = now - pool.last_updated; age < threshold_seconds }); } } /// Фоновая задача периодической очистки кэша pub async fn start_cache_cleanup_task(monitor: Arc) { let mut cleanup_interval = interval(Duration::from_secs(60)); // Каждую минуту loop { cleanup_interval.tick().await; let count_before = monitor.pool_count(); monitor.cleanup_stale_pools(300); // Удаляем старше 5 минут let count_after = monitor.pool_count(); if count_before != count_after { info!("🧹 Очистка кэша: удалено {} устаревших пулов", count_before - count_after); } } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/pool_monitor.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/raydium_amm.rs --- // bot/src/scanner/raydium_amm.rs use anyhow::{Result, Context}; use solana_client::rpc_client::RpcClient; use solana_client::rpc_config::{RpcAccountInfoConfig, RpcProgramAccountsConfig}; use solana_client::rpc_filter::RpcFilterType; use solana_sdk::commitment_config::CommitmentConfig; use solana_sdk::pubkey::Pubkey; use solana_program_pack::Pack; use spl_token::state::Account as TokenAccount; use std::sync::Arc; use tracing::{info, warn, debug}; use crate::config::BotConfig; use crate::dex_structs::AmmInfo; use crate::types::{DexProtocol, PoolState}; use super::DexScanner; #[derive(Clone)] pub struct RaydiumAmmScanner { rpc_client: Arc, program_id: Pubkey, } impl RaydiumAmmScanner { pub fn new(config: Arc, rpc_client: Arc) -> Result { let program_id = config.dex.raydium_amm_v4.to_pubkey() .context("Некорректный Raydium AMM program ID в конфигурации")?; info!("🚀 Инициализация Raydium AMM сканера с program_id: {}", program_id); Ok(Self { rpc_client, program_id, }) } async fn parse_pool_account(&self, pool_id: Pubkey, data: Vec) -> Result { const MIN_DATA_SIZE: usize = 752; if data.len() < MIN_DATA_SIZE { anyhow::bail!( "Недостаточно данных для пула {}: {} байт, минимум {}", pool_id, data.len(), MIN_DATA_SIZE ); } debug!("🔍 Парсинг пула {} (размер данных: {} байт)", pool_id, data.len()); // ИСПРАВЛЕНИЕ: Используем наш упрощенный парсер let amm_info = match AmmInfo::try_from_slice(&data) { Ok(info) => info, Err(e) => { // Если не удалось распарсить, создаем заглушку с минимальными данными warn!("⚠️ Не удалось полностью распарсить пул {}: {}. Создаем заглушку.", pool_id, e); // Пытаемся хотя бы получить базовые токены let base_mint = if data.len() >= 432 { let mut bytes = [0u8; 32]; bytes.copy_from_slice(&data[400..432]); Pubkey::new_from_array(bytes) } else { Pubkey::default() }; let quote_mint = if data.len() >= 464 { let mut bytes = [0u8; 32]; bytes.copy_from_slice(&data[432..464]); Pubkey::new_from_array(bytes) } else { Pubkey::default() }; return Ok(PoolState { id: pool_id, protocol: DexProtocol::RaydiumAmmV4, token_a: base_mint, token_b: quote_mint, reserve_a: 0, // Заглушка reserve_b: 0, // Заглушка fee_bps: 25, // Стандартная комиссия Raydium (0.25%) last_updated: chrono::Utc::now().timestamp(), full_state_data: data, }); } }; self.validate_amm_info(&amm_info, pool_id)?; let (reserve_a, reserve_b) = self.fetch_vault_reserves(&amm_info, pool_id).await?; let fee_bps = self.calculate_fee_bps(&amm_info)?; debug!( "✅ Успешно обработан пул {}: {} / {}, резервы: {}/{}, комиссия: {}bps", pool_id, amm_info.base_mint, amm_info.quote_mint, reserve_a, reserve_b, fee_bps ); Ok(PoolState { id: pool_id, protocol: DexProtocol::RaydiumAmmV4, token_a: amm_info.base_mint, token_b: amm_info.quote_mint, reserve_a, reserve_b, fee_bps, last_updated: chrono::Utc::now().timestamp(), full_state_data: data, }) } fn validate_amm_info(&self, amm_info: &AmmInfo, pool_id: Pubkey) -> Result<()> { if amm_info.market_program_id == Pubkey::default() { anyhow::bail!("Пул {} имеет невалидный market_program_id", pool_id); } if amm_info.base_mint == Pubkey::default() { anyhow::bail!("Пул {} имеет невалидный base_mint", pool_id); } if amm_info.quote_mint == Pubkey::default() { anyhow::bail!("Пул {} имеет невалидный quote_mint", pool_id); } if amm_info.base_vault == Pubkey::default() { anyhow::bail!("Пул {} имеет невалидный base_vault", pool_id); } if amm_info.quote_vault == Pubkey::default() { anyhow::bail!("Пул {} имеет невалидный quote_vault", pool_id); } if amm_info.base_mint == amm_info.quote_mint { anyhow::bail!("Пул {} имеет одинаковые base_mint и quote_mint", pool_id); } Ok(()) } async fn fetch_vault_reserves(&self, amm_info: &AmmInfo, pool_id: Pubkey) -> Result<(u64, u64)> { let vaults = [amm_info.base_vault, amm_info.quote_vault]; debug!("📊 Получение данных vault'ов для пула {}: {:?}", pool_id, vaults); let vault_accounts = self.rpc_client .get_multiple_accounts(&vaults) .with_context(|| format!("Ошибка получения vault аккаунтов для пула {}", pool_id))?; let reserve_a = match &vault_accounts[0] { Some(account) => { TokenAccount::unpack(&account.data) .with_context(|| format!("Ошибка десериализации base vault {} для пула {}", amm_info.base_vault, pool_id))? .amount } None => { warn!("⚠️ Base vault {} не найден для пула {}", amm_info.base_vault, pool_id); 0 } }; let reserve_b = match &vault_accounts[1] { Some(account) => { TokenAccount::unpack(&account.data) .with_context(|| format!("Ошибка десериализации quote vault {} для пула {}", amm_info.quote_vault, pool_id))? .amount } None => { warn!("⚠️ Quote vault {} не найден для пула {}", amm_info.quote_vault, pool_id); 0 } }; if reserve_a == 0 && reserve_b == 0 { anyhow::bail!("Пул {} имеет нулевые резервы в обоих vault'ах", pool_id); } Ok((reserve_a, reserve_b)) } fn calculate_fee_bps(&self, amm_info: &AmmInfo) -> Result { if amm_info.fees.swap_fee_denominator == 0 { anyhow::bail!("Деление на ноль: swap_fee_denominator = 0"); } let fee_ratio = amm_info.fees.swap_fee_numerator as f64 / amm_info.fees.swap_fee_denominator as f64; let fee_bps = (fee_ratio * 10000.0) as u16; if fee_bps > 1000 { warn!("⚠️ Необычно высокая комиссия: {}bps", fee_bps); } Ok(fee_bps) } fn create_program_filters(&self) -> Vec { const AMM_INFO_DATA_SIZE: u64 = 752; vec![ RpcFilterType::DataSize(AMM_INFO_DATA_SIZE), ] } } #[async_trait::async_trait] impl DexScanner for RaydiumAmmScanner { fn protocol(&self) -> DexProtocol { DexProtocol::RaydiumAmmV4 } async fn scan_pools(&self) -> Result> { info!("📡 Начинаем сканирование Raydium AMM V4 пулов..."); info!(" 🎯 Program ID: {}", self.program_id); let config = RpcProgramAccountsConfig { filters: Some(self.create_program_filters()), account_config: RpcAccountInfoConfig { encoding: Some(solana_account_decoder::UiAccountEncoding::Base64), commitment: Some(CommitmentConfig::confirmed()), data_slice: None, min_context_slot: None, }, with_context: None, sort_results: None, }; info!("🔍 Выполняем getProgramAccounts с фильтрами..."); let accounts = self.rpc_client .get_program_accounts_with_config(&self.program_id, config) .with_context(|| format!("Ошибка получения аккаунтов программы {}", self.program_id))?; info!(" 📊 Найдено {} потенциальных аккаунтов пулов", accounts.len()); let mut pools = Vec::new(); let mut successful_parses = 0; let mut failed_parses = 0; for (i, (pubkey, account)) in accounts.iter().enumerate() { debug!(" 🔄 Обработка аккаунта {}/{}: {}", i + 1, accounts.len(), pubkey); match self.parse_pool_account(*pubkey, account.data.clone()).await { Ok(pool) => { pools.push(pool); successful_parses += 1; } Err(e) => { failed_parses += 1; warn!(" ⚠️ Не удалось распарсить пул {}: {}", pubkey, e); if failed_parses <= 3 { debug!(" 🔍 Размер данных: {} байт", account.data.len()); debug!(" 🔍 Owner: {}", account.owner); debug!(" 🔍 Executable: {}", account.executable); debug!(" 🔍 Lamports: {}", account.lamports); } } } } info!( "✅ Сканирование завершено: {} успешных, {} ошибок, всего пулов: {}", successful_parses, failed_parses, pools.len() ); if pools.is_empty() { warn!("⚠️ Не найдено ни одного валидного пула!"); } else { let mut token_pairs = std::collections::HashSet::new(); for pool in &pools { token_pairs.insert((pool.token_a, pool.token_b)); } info!(" 📈 Уникальных торговых пар: {}", token_pairs.len()); } Ok(pools) } fn clone_box(&self) -> Box { Box::new(self.clone()) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/raydium_amm.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/mod.rs --- // bot/src/scanner/mod.rs pub mod pool_monitor; pub mod raydium_amm; pub mod raydium_cpmm; pub mod raydium_clmm; pub mod meteora_dlmm; use futures::future::join_all; use anyhow::Result; use async_trait::async_trait; use std::sync::Arc; use tracing::info; use solana_client::rpc_client::RpcClient; use crate::config::BotConfig; use crate::types::{PoolState, DexProtocol}; use raydium_amm::RaydiumAmmScanner; use raydium_cpmm::RaydiumCpmmScanner; use raydium_clmm::RaydiumClmmScanner; use meteora_dlmm::MeteoraDlmmScanner; #[async_trait] pub trait DexScanner: Send + Sync { fn protocol(&self) -> DexProtocol; async fn scan_pools(&self) -> Result>; fn clone_box(&self) -> Box; } pub struct MultiDexScanner { scanners: Vec>, } impl MultiDexScanner { pub fn new(config: Arc, rpc_client: Arc) -> Self { let scanners: Vec> = vec![ // ИСПРАВЛЕНИЕ: обрабатываем Result из RaydiumAmmScanner::new Box::new(RaydiumAmmScanner::new(config.clone(), rpc_client.clone()).unwrap()), Box::new(RaydiumCpmmScanner::new(config.clone())), Box::new(RaydiumClmmScanner::new(config.clone())), Box::new(MeteoraDlmmScanner::new(config.clone())), ]; Self { scanners } } pub async fn scan_all_dex(&self) -> Result> { info!("🔍 Запуск параллельного сканирования всех DEX..."); let scan_futures = self.scanners.iter().map(|scanner| { scanner.scan_pools() }); let results = join_all(scan_futures).await; let mut all_pools = Vec::new(); for (i, result) in results.into_iter().enumerate() { let protocol = self.scanners[i].protocol(); match result { Ok(pools) => { info!(" {:?}: найдено {} пулов", protocol, pools.len()); all_pools.extend(pools); } Err(e) => { tracing::warn!(" {:?}: ошибка сканирования - {}", protocol, e); } } } info!("✅ Всего пулов найдено: {}", all_pools.len()); Ok(all_pools) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/mod.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/meteora_dlmm.rs --- // bot/src/scanner/meteora_dlmm.rs use anyhow::Result; use serde::Deserialize; use solana_sdk::pubkey::Pubkey; use std::str::FromStr; use tracing::{info}; use std::sync::Arc; use crate::config::BotConfig; use crate::types::{PoolState, DexProtocol}; use super::DexScanner; #[derive(Clone)] pub struct MeteoraDlmmScanner { _config: Arc, // _config для будущего использования } // Добавляем Deserialize для struct MeteoraPair #[derive(Deserialize)] struct MeteoraPair { address: String, mint_x: String, mint_y: String, reserve_x_amount: u64, reserve_y_amount: u64, base_fee_percentage: String, } impl MeteoraDlmmScanner { pub fn new(config: Arc) -> Self { Self { _config: config } } fn convert_api_pool_to_pool_state(&self, api_pool: MeteoraPair) -> Result { let id = Pubkey::from_str(&api_pool.address)?; let token_a = Pubkey::from_str(&api_pool.mint_x)?; let token_b = Pubkey::from_str(&api_pool.mint_y)?; let fee_pct: f64 = api_pool.base_fee_percentage.parse()?; let fee_bps = (fee_pct * 100.0) as u16; Ok(PoolState { id, protocol: DexProtocol::MeteoraDlmm, token_a, token_b, reserve_a: api_pool.reserve_x_amount, reserve_b: api_pool.reserve_y_amount, fee_bps, last_updated: chrono::Utc::now().timestamp(), full_state_data: Vec::new(), // Исправляем пустой vec! }) } } #[async_trait::async_trait] impl DexScanner for MeteoraDlmmScanner { fn protocol(&self) -> DexProtocol { DexProtocol::MeteoraDlmm } async fn scan_pools(&self) -> Result> { info!("📡 Сканирование Meteora DLMM пулов через API..."); let api_url = "https://dlmm-api.meteora.ag/pair/all"; let response = reqwest::get(api_url).await?; // Исправляем синтаксис условия if !response.status().is_success() { anyhow::bail!("API Meteora вернуло ошибку: {}", response.status()); } let api_pools: Vec = response.json().await?; info!(" 📊 Получено {} пулов от API Meteora", api_pools.len()); let mut pools = Vec::new(); for api_pool in api_pools { if let Ok(pool) = self.convert_api_pool_to_pool_state(api_pool) { pools.push(pool); } } Ok(pools) } fn clone_box(&self) -> Box { Box::new(self.clone()) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/meteora_dlmm.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/raydium_cpmm.rs --- // bot/src/scanner/raydium_cpmm.rs use anyhow::Result; use solana_sdk::pubkey::Pubkey; use std::str::FromStr; use tracing::{info, warn}; use crate::config::BotConfig; use crate::types::{PoolState, DexProtocol}; use super::DexScanner; #[derive(Clone)] pub struct RaydiumCpmmScanner { config: std::sync::Arc, program_id: Pubkey, } impl RaydiumCpmmScanner { pub fn new(config: std::sync::Arc) -> Self { let program_id = Pubkey::from_str("DRaycpLY18LhpbydsBWbVJtxpNv9oXPgjRSfpF2bWpYb") .expect("Invalid Raydium CPMM program ID"); Self { config, program_id } } /// Парсинг данных пула Raydium CPMM fn parse_pool_account(&self, pool_id: Pubkey, data: &[u8]) -> Result { if data.len() < 324 { anyhow::bail!("Недостаточно данных для парсинга пула CPMM"); } let token_a = Pubkey::new_from_array(data[8..40].try_into()?); let token_b = Pubkey::new_from_array(data[40..72].try_into()?); let reserve_a = 1_000_000_000; let reserve_b = 1_000_000_000; Ok(PoolState { id: pool_id, protocol: DexProtocol::RaydiumCpmm, token_a, token_b, reserve_a, reserve_b, fee_bps: 25, last_updated: chrono::Utc::now().timestamp(), full_state_data: data.to_vec(), }) } } #[async_trait::async_trait] impl DexScanner for RaydiumCpmmScanner { fn protocol(&self) -> DexProtocol { DexProtocol::RaydiumCpmm } async fn scan_pools(&self) -> Result> { info!("📡 Сканирование Raydium CPMM пулов на devnet..."); // ИСПРАВЛЕНИЕ: Явно указываем тип let known_pools: Vec<&str> = vec![ // Добавьте адреса ваших тестовых CPMM пулов ]; if known_pools.is_empty() { warn!("⚠️ Нет известных Raydium CPMM пулов на devnet."); return Ok(vec![]); } let pools = Vec::new(); info!("✅ Raydium CPMM: найдено {} пулов", pools.len()); Ok(pools) } fn clone_box(&self) -> Box { Box::new(self.clone()) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/scanner/raydium_cpmm.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/main.rs --- // bot/src/main.rs // Точка входа арбитражного бота mod config; mod types; mod scanner; mod arbitrage; mod executor; mod utils; pub mod dex_structs; use solana_sdk::signature::Signer; use anyhow::Result; use solana_client::rpc_client::RpcClient; use solana_sdk::commitment_config::CommitmentConfig; use std::sync::Arc; use tokio::time::{interval, Duration}; use tracing::{info, error, warn}; use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt}; use config::BotConfig; use scanner::{MultiDexScanner, pool_monitor::PoolMonitor}; use arbitrage::ArbitrageFinder; use executor::TransactionExecutor; use utils::load_keypair_from_file; #[tokio::main] async fn main() -> Result<()> { // Инициализация логирования init_logging(); println!("╔════════════════════════════════════════════════════════════════╗"); println!("║ SOLANA ARBITRAGE BOT - RUST EDITION (DEVNET) ║"); println!("║ Высокопроизводительный поиск и исполнение арбитража ║"); println!("╚════════════════════════════════════════════════════════════════╝\n"); // Загрузка конфигурации info!("📋 Загрузка конфигурации..."); let config = Arc::new(BotConfig::load()?); info!("✅ Конфигурация загружена"); // Загрузка кошелька info!("🔑 Загрузка кошелька..."); let wallet_path = config.wallet.path.to_str() .ok_or_else(|| anyhow::anyhow!("Неверный путь к кошельку"))?; let keypair = Arc::new(load_keypair_from_file(wallet_path)?); info!(" Публичный ключ: {}", keypair.pubkey()); // Инициализация RPC клиента info!("🌐 Подключение к Solana RPC..."); let rpc_client = Arc::new(RpcClient::new_with_commitment( config.rpc.url.clone(), CommitmentConfig::confirmed(), )); // Проверка подключения let cluster_version = rpc_client.get_version()?; info!(" Подключено к кластеру: {} (Solana {})", config.rpc.url, cluster_version.solana_core); // Проверка баланса let balance = rpc_client.get_balance(&keypair.pubkey())?; let balance_sol = balance as f64 / 1_000_000_000.0; info!("💰 Баланс кошелька: {:.9} SOL", balance_sol); if balance_sol < 0.1 { warn!("⚠️ НИЗКИЙ БАЛАНС! Пополните через фоссет: https://faucet.solana.com/"); warn!(" Адрес: {}", keypair.pubkey()); } // Инициализация компонентов info!("🔧 Инициализация компонентов бота..."); let pool_monitor = Arc::new(PoolMonitor::new(5000)); // 5 секунд TTL let dex_scanner = MultiDexScanner::new(config.clone(), rpc_client.clone()); let arbitrage_finder = ArbitrageFinder::new(config.clone()); let executor = TransactionExecutor::new( rpc_client.clone(), keypair.clone(), config.clone(), )?; info!("✅ Все компоненты инициализированы\n"); // Запуск фоновой очистки кэша let monitor_clone = pool_monitor.clone(); tokio::spawn(async move { scanner::pool_monitor::start_cache_cleanup_task(monitor_clone).await; }); // Главный цикл бота info!("🚀 Запуск главного цикла бота..."); info!("{}", "═".repeat(80)); let mut scan_interval = interval(Duration::from_millis(config.rpc.timeout_seconds * 1000)); let mut iteration = 0u64; loop { scan_interval.tick().await; iteration += 1; info!("\n⏰ Итерация #{} - {}", iteration, chrono::Local::now().format("%H:%M:%S")); // Шаг 1: Сканирование пулов match dex_scanner.scan_all_dex().await { Ok(pools) => { if pools.is_empty() { warn!(" ⚠️ Пулы не найдены. Убедитесь что тестовые пулы созданы на devnet."); continue; } // Обновление кэша for pool in &pools { pool_monitor.update_pool(pool.clone()); } info!(" 📊 Активных пулов: {}", pools.len()); // Шаг 2: Поиск арбитражных возможностей match arbitrage_finder.find_opportunities(&pools) { Ok(opportunities) => { if opportunities.is_empty() { info!(" ⏳ Прибыльных возможностей не найдено"); continue; } info!(" 🔥 Найдено возможностей: {}", opportunities.len()); // Берём лучшую возможность let best = &opportunities[0]; info!(" 💎 Лучшая возможность:"); info!(" Прибыль: {:.9} SOL ({:.4}%)", best.net_profit as f64 / 1_000_000_000.0, best.profit_percentage); info!(" Шагов: {}", best.legs.len()); // Шаг 3: Исполнение арбитража info!(" 🔧 Исполнение арбитража..."); match executor.execute(best).await { Ok(signature) => { info!(" ✅ АРБИТРАЖ УСПЕШЕН!"); info!(" Транзакция: {}", signature); info!(" Explorer: https://explorer.solana.com/tx/{}?cluster=devnet", signature); } Err(e) => { error!(" ❌ Ошибка исполнения: {}", e); } } } Err(e) => { error!(" ❌ Ошибка поиска возможностей: {}", e); } } } Err(e) => { error!(" ❌ Ошибка сканирования пулов: {}", e); } } } } /// Инициализация системы логирования fn init_logging() { let log_level = std::env::var("LOG_LEVEL").unwrap_or_else(|_| "info".to_string()); let filter = tracing_subscriber::EnvFilter::try_from_default_env() .unwrap_or_else(|_| tracing_subscriber::EnvFilter::new(log_level)); tracing_subscriber::registry() .with(filter) .with(tracing_subscriber::fmt::layer() .with_target(false) .with_thread_ids(false) .with_line_number(false)) .init(); } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/main.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/jito_client.rs --- // bot/src/executor/jito_client.rs // Клиент для интеграции с Jito Block Engine (MEV защита) // bot/src/executor/jito_client.rs use anyhow::{Result, Context}; use solana_sdk::{ pubkey::Pubkey, transaction::Transaction, // УДАЛИТЕ эту строку: signature::Signature, }; use reqwest::Client; use serde::{Deserialize, Serialize}; use std::str::FromStr; use tracing::{info, warn, debug}; // УДАЛИТЕ эту строку - она дублирует импорт: // use solana_sdk::pubkey::Pubkey; /// Конфигурация Jito pub struct JitoConfig { pub block_engine_url: String, pub tip_account: Pubkey, pub tip_lamports: u64, } impl Default for JitoConfig { fn default() -> Self { Self { block_engine_url: "https://mainnet.block-engine.jito.wtf".to_string(), tip_account: Pubkey::from_str("96gYZGLnJYVFmbjzopPSU6QiEV5fGqZNyN9nmNhvrZU5") .expect("Invalid Jito tip account"), tip_lamports: 300_000, // 0.0003 SOL минимальный tip } } } /// Клиент Jito Block Engine pub struct JitoClient { config: JitoConfig, http_client: Client, } impl JitoClient { pub fn new(config: JitoConfig) -> Self { Self { config, http_client: Client::new(), } } /// Отправка bundle транзакций в Jito /// /// ВАЖНО: Jito Block Engine недоступен на devnet! /// Эта функция работает только на mainnet. pub async fn send_bundle(&self, transactions: Vec) -> Result { // Проверка devnet if self.config.block_engine_url.contains("devnet") { warn!("⚠️ Jito Block Engine недоступен на devnet. Используйте обычную отправку."); anyhow::bail!("Jito не поддерживается на devnet"); } info!("📦 Отправка bundle из {} транзакций в Jito...", transactions.len()); // Сериализация транзакций в base64 let encoded_txs: Vec = transactions .iter() .map(|tx| { let serialized = bincode::serialize(tx).expect("Failed to serialize tx"); bs58::encode(serialized).into_string() }) .collect(); debug!(" Сериализовано {} транзакций", encoded_txs.len()); // Подготовка JSON-RPC запроса let request = SendBundleRequest { jsonrpc: "2.0".to_string(), id: 1, method: "sendBundle".to_string(), params: vec![encoded_txs], }; // Отправка POST запроса к Jito API let endpoint = format!("{}/api/v1/bundles", self.config.block_engine_url); debug!(" Endpoint: {}", endpoint); let response = self.http_client .post(&endpoint) .json(&request) .send() .await .context("Не удалось отправить bundle в Jito")?; // Проверка статуса ответа let status = response.status(); if !status.is_success() { let error_text = response.text().await.unwrap_or_else(|_| "Unknown error".to_string()); anyhow::bail!("Jito вернул ошибку {}: {}", status, error_text); } // Парсинг ответа let bundle_response: SendBundleResponse = response .json() .await .context("Не удалось распарсить ответ Jito")?; if let Some(error) = bundle_response.error { anyhow::bail!("Jito RPC ошибка: {:?}", error); } let bundle_id = bundle_response.result .ok_or_else(|| anyhow::anyhow!("Нет bundle_id в ответе Jito"))?; info!(" ✅ Bundle отправлен, ID: {}", bundle_id); Ok(bundle_id) } /// Проверка статуса bundle pub async fn get_bundle_status(&self, bundle_id: &str) -> Result { let request = GetBundleStatusRequest { jsonrpc: "2.0".to_string(), id: 1, method: "getBundleStatuses".to_string(), params: vec![vec![bundle_id.to_string()]], }; let endpoint = format!("{}/api/v1/bundles", self.config.block_engine_url); let response = self.http_client .post(&endpoint) .json(&request) .send() .await .context("Не удалось получить статус bundle")?; let status_response: GetBundleStatusResponse = response .json() .await .context("Не удалось распарсить статус bundle")?; let statuses = status_response.result.value .ok_or_else(|| anyhow::anyhow!("Нет статусов в ответе"))?; let status = statuses.first() .ok_or_else(|| anyhow::anyhow!("Пустой массив статусов"))?; Ok(status.clone()) } /// Ожидание подтверждения bundle (с таймаутом) pub async fn wait_for_confirmation( &self, bundle_id: &str, timeout_seconds: u64, ) -> Result { use tokio::time::{sleep, Duration}; let start = std::time::Instant::now(); let timeout = Duration::from_secs(timeout_seconds); loop { if start.elapsed() > timeout { anyhow::bail!("Таймаут ожидания подтверждения bundle"); } let status = self.get_bundle_status(bundle_id).await?; match status.confirmation_status.as_str() { "confirmed" | "finalized" => { info!(" ✅ Bundle подтверждён: {}", status.confirmation_status); return Ok(status); } "failed" => { anyhow::bail!("Bundle провалился: {:?}", status.err); } "pending" => { debug!(" Bundle в ожидании... ({}s)", start.elapsed().as_secs()); sleep(Duration::from_millis(500)).await; } _ => { debug!(" Неизвестный статус: {}", status.confirmation_status); sleep(Duration::from_millis(500)).await; } } } } } // ============================================================================ // JSON-RPC СТРУКТУРЫ // ============================================================================ #[derive(Serialize)] struct SendBundleRequest { jsonrpc: String, id: u64, method: String, params: Vec>, } #[derive(Deserialize)] struct SendBundleResponse { result: Option, error: Option, } #[derive(Serialize)] struct GetBundleStatusRequest { jsonrpc: String, id: u64, method: String, params: Vec>, } #[derive(Deserialize)] struct GetBundleStatusResponse { result: BundleStatusResult, } #[derive(Deserialize)] struct BundleStatusResult { value: Option>, } #[derive(Debug, Clone, Deserialize)] pub struct BundleStatus { pub bundle_id: String, pub confirmation_status: String, pub err: Option, pub slot: Option, } #[derive(Debug, Deserialize)] struct JsonRpcError { code: i32, message: String, } // ============================================================================ // ВСПОМОГАТЕЛЬНЫЕ ФУНКЦИИ // ============================================================================ /// Создание tip транзакции для Jito pub fn create_tip_instruction( from: &Pubkey, tip_account: &Pubkey, lamports: u64, ) -> solana_sdk::instruction::Instruction { solana_sdk::system_instruction::transfer(from, tip_account, lamports) } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/jito_client.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/transaction_builder.rs --- // bot/src/executor/transaction_builder.rs use anchor_spl::{associated_token, token}; use anyhow::{Context, Result}; use solana_client::rpc_client::RpcClient; use solana_sdk::{ compute_budget::ComputeBudgetInstruction, hash::Hash, instruction::{AccountMeta, Instruction}, pubkey::Pubkey, signature::{Keypair, Signer}, transaction::Transaction, }; use std::sync::Arc; use tracing::{info, debug, warn}; use anchor_lang::prelude::*; use crate::config::BotConfig; use crate::dex_structs::AmmInfo; use crate::types::{ArbitrageOpportunity, DexProtocol, SwapLeg}; pub struct TransactionBuilder { rpc_client: Arc, keypair: Arc, config: Arc, program_id: Pubkey, } #[derive(AnchorSerialize, AnchorDeserialize, Clone, Debug)] struct ProgramSwapLeg { protocol: u8, pool_id: Pubkey, input_mint: Pubkey, output_mint: Pubkey, amount_in: u64, minimum_amount_out: u64, accounts_len: u8, } #[derive(AnchorSerialize, AnchorDeserialize, Clone, Debug)] struct ExecuteArbitrageParams { swap_legs: Vec, min_profit_lamports: u64, } impl TransactionBuilder { pub fn new( rpc_client: Arc, keypair: Arc, config: Arc, ) -> Result { let program_id = config.trading.executor_program_id.to_pubkey()?; info!("🔧 Инициализация TransactionBuilder с program_id: {}", program_id); Ok(Self { rpc_client, keypair, config, program_id, }) } fn get_recent_blockhash(&self) -> Result { Ok(self.rpc_client.get_latest_blockhash()?) } fn build_instruction_data(&self, swap_legs: Vec, min_profit: u64) -> Result> { let discriminator: [u8; 8] = [0x3f, 0x39, 0x4c, 0x8f, 0x29, 0x34, 0x70, 0xd0]; let mut data = discriminator.to_vec(); let params = ExecuteArbitrageParams { swap_legs, min_profit_lamports: min_profit, }; let serialized = params.try_to_vec().context("Не удалось сериализовать параметры")?; data.extend_from_slice(&serialized); debug!("📦 Размер данных инструкции: {} байт", data.len()); Ok(data) } pub async fn build_arbitrage_transaction( &self, opportunity: &ArbitrageOpportunity, ) -> Result { info!("🔨 Построение транзакции арбитража для {} свопов", opportunity.legs.len()); let recent_blockhash = self.get_recent_blockhash()?; let mut instructions = Vec::new(); let mut all_accounts_for_cpi = Vec::new(); instructions.push(ComputeBudgetInstruction::set_compute_unit_limit( self.config.trading.compute_unit_limit )); instructions.push(ComputeBudgetInstruction::set_compute_unit_price( self.config.trading.priority_fee_micro_lamports )); let mut program_swap_legs = Vec::new(); for (i, leg) in opportunity.legs.iter().enumerate() { debug!("🔄 Обработка swap leg {}/{}: {:?}", i + 1, opportunity.legs.len(), leg.protocol); let (leg_accounts, program_leg) = self.get_accounts_for_leg(leg).await?; all_accounts_for_cpi.extend(leg_accounts); program_swap_legs.push(program_leg); } let arbitrage_ix = self.build_execute_instruction( program_swap_legs, opportunity.net_profit, all_accounts_for_cpi )?; instructions.push(arbitrage_ix); let mut transaction = Transaction::new_with_payer( &instructions, Some(&self.keypair.pubkey()) ); transaction.sign(&[self.keypair.as_ref()], recent_blockhash); info!("✅ Транзакция построена с {} инструкциями", instructions.len()); Ok(transaction) } async fn get_accounts_for_leg(&self, leg: &SwapLeg) -> Result<(Vec, ProgramSwapLeg)> { match leg.protocol { DexProtocol::RaydiumAmmV4 => self.get_raydium_amm_v4_accounts(leg).await, DexProtocol::RaydiumCpmm => { warn!("⚠️ RaydiumCpmm не реализован"); unimplemented!("RaydiumCpmm не реализован") }, DexProtocol::RaydiumClmm => { warn!("⚠️ RaydiumClmm не реализован"); unimplemented!("RaydiumClmm не реализован") }, DexProtocol::MeteoraDlmm => { warn!("⚠️ MeteoraDlmm не реализован"); unimplemented!("MeteoraDlmm не реализован") }, } } async fn get_raydium_amm_v4_accounts(&self, leg: &SwapLeg) -> Result<(Vec, ProgramSwapLeg)> { debug!("📊 Получение аккаунтов для Raydium AMM V4 пула: {}", leg.pool_id); let pool_account = self.rpc_client.get_account(&leg.pool_id)?; // ИСПРАВЛЕНИЕ: Используем новый метод try_from_slice let amm_info = AmmInfo::try_from_slice(&pool_account.data) .map_err(|e| anyhow::anyhow!("Ошибка десериализации AmmInfo: {}", e))?; let raydium_program_id = self.config.dex.raydium_amm_v4.to_pubkey()?; let (amm_authority, _) = Pubkey::find_program_address( &[b"amm authority"], &raydium_program_id ); let (market_authority, _) = Pubkey::find_program_address( &[amm_info.market_id.as_ref()], &amm_info.market_program_id, ); let user_source_ata = associated_token::get_associated_token_address( &self.keypair.pubkey(), &leg.input_mint ); let user_dest_ata = associated_token::get_associated_token_address( &self.keypair.pubkey(), &leg.output_mint ); let accounts = vec![ AccountMeta::new(leg.pool_id, false), AccountMeta::new_readonly(amm_authority, false), AccountMeta::new_readonly(amm_info.open_orders, false), AccountMeta::new(amm_info.target_orders, false), AccountMeta::new(amm_info.base_vault, false), AccountMeta::new(amm_info.quote_vault, false), AccountMeta::new_readonly(amm_info.market_program_id, false), AccountMeta::new_readonly(amm_info.market_id, false), AccountMeta::new(amm_info.market_bids, false), AccountMeta::new(amm_info.market_asks, false), AccountMeta::new(amm_info.market_event_queue, false), AccountMeta::new(amm_info.market_base_vault, false), AccountMeta::new(amm_info.market_quote_vault, false), AccountMeta::new_readonly(market_authority, false), AccountMeta::new(user_source_ata, false), AccountMeta::new(user_dest_ata, false), AccountMeta::new_readonly(self.keypair.pubkey(), true), AccountMeta::new_readonly(token::ID, false), ]; debug!(" ✅ Подготовлено {} аккаунтов для Raydium AMM V4", accounts.len()); let program_leg = ProgramSwapLeg { protocol: leg.protocol as u8, pool_id: leg.pool_id, input_mint: leg.input_mint, output_mint: leg.output_mint, amount_in: leg.amount_in, minimum_amount_out: leg.minimum_amount_out, accounts_len: accounts.len() as u8, }; Ok((accounts, program_leg)) } fn build_execute_instruction( &self, swap_legs: Vec, min_profit: u64, mut remaining_accounts: Vec, ) -> Result { let first_token_mint = swap_legs .first() .context("Нет свопов")? .input_mint; let user_token_account = associated_token::get_associated_token_address( &self.keypair.pubkey(), &first_token_mint ); let mut accounts = vec![ AccountMeta::new(self.keypair.pubkey(), true), AccountMeta::new(user_token_account, false), AccountMeta::new_readonly(first_token_mint, false), AccountMeta::new_readonly(token::ID, false), // ИСПРАВЛЕНИЕ: Используем правильный system program ID AccountMeta::new_readonly(solana_sdk::system_program::ID, false), ]; accounts.append(&mut remaining_accounts); let instruction_data = self.build_instruction_data(swap_legs, min_profit)?; info!("🎯 Создание execute_arbitrage инструкции с {} аккаунтами", accounts.len()); Ok(Instruction { program_id: self.program_id, accounts, data: instruction_data, }) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/transaction_builder.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/mod.rs --- // bot/src/executor/mod.rs pub mod transaction_builder; pub mod jito_client; pub mod simulator; use anyhow::Result; use solana_sdk::signature::{Keypair, Signature}; use solana_client::rpc_client::RpcClient; use std::sync::Arc; use tracing::info; use crate::config::BotConfig; use crate::types::ArbitrageOpportunity; use transaction_builder::TransactionBuilder; use simulator::TransactionSimulator; pub struct TransactionExecutor { rpc_client: Arc, builder: TransactionBuilder, simulator: TransactionSimulator, } impl TransactionExecutor { pub fn new( rpc_client: Arc, keypair: Arc, config: Arc, ) -> Result { Ok(Self { builder: TransactionBuilder::new( rpc_client.clone(), keypair.clone(), config.clone(), )?, simulator: TransactionSimulator::new(rpc_client.clone()), rpc_client, }) } pub async fn execute(&self, opportunity: &ArbitrageOpportunity) -> Result { let transaction = self.builder.build_arbitrage_transaction(opportunity).await?; info!("🧪 Симуляция транзакции..."); let simulation = self.simulator.simulate(&transaction).await?; if let Some(err) = simulation.err { anyhow::bail!("Симуляция провалилась: {}\nЛоги:\n{:#?}", err, simulation.logs); } info!("✅ Симуляция успешна (CU: {})", simulation.units_consumed.unwrap_or(0)); info!("📤 Отправка транзакции..."); let signature = self.rpc_client.send_and_confirm_transaction(&transaction)?; Ok(signature) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/mod.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/simulator.rs --- // bot/src/executor/simulator.rs (завершение) use tracing::debug; use solana_sdk::transaction::Transaction; use crate::types::SimulationResult; use anyhow::Result; use solana_client::rpc_client::RpcClient; use std::sync::Arc; pub struct TransactionSimulator { rpc_client: Arc, } /// Симуляция транзакции impl TransactionSimulator { pub fn new(rpc_client: Arc) -> Self { Self { rpc_client } } pub async fn simulate(&self, transaction: &Transaction) -> Result { let simulation = self.rpc_client .simulate_transaction(transaction) .map_err(|e| anyhow::anyhow!("Ошибка симуляции: {}", e))?; let result = SimulationResult { err: simulation.value.err.map(|e| format!("{:?}", e)), logs: simulation.value.logs.clone().unwrap_or_default(), units_consumed: simulation.value.units_consumed, }; if let Some(ref err) = result.err { debug!("Симуляция завершилась с ошибкой: {}", err); if let Some(logs) = &simulation.value.logs { for log in logs { debug!(" Log: {}", log); } } } Ok(result) } /// Оценка compute units для транзакции pub async fn estimate_compute_units(&self, transaction: &Transaction) -> Result { let simulation = self.simulate(transaction).await?; simulation.units_consumed .ok_or_else(|| anyhow::anyhow!("Не удалось определить compute units")) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/executor/simulator.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/config.rs --- // bot/src/config.rs use anyhow::{Context, Result}; use serde::{Deserialize, Serialize}; use std::path::PathBuf; use std::str::FromStr; use solana_sdk::pubkey::Pubkey; #[derive(Debug, Clone, Serialize, Deserialize)] pub struct BotConfig { pub rpc: RpcConfig, pub wallet: WalletConfig, pub trading: TradingConfig, pub dex: DexConfig, pub jito: Option, pub monitoring: MonitoringConfig, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct RpcConfig { pub url: String, pub ws_url: String, pub commitment: String, pub timeout_seconds: u64, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct WalletConfig { pub path: PathBuf, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct TradingConfig { pub executor_program_id: PubkeyString, pub min_profit_lamports: u64, pub min_profit_bps: u16, pub max_slippage_bps: u16, pub initial_amount_sol: f64, pub max_legs: u8, pub compute_unit_limit: u32, pub priority_fee_micro_lamports: u64, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct DexConfig { pub raydium_amm_v4: PubkeyString, pub raydium_cpmm: PubkeyString, pub raydium_clmm: PubkeyString, pub meteora_dlmm: PubkeyString, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct JitoConfig { pub block_engine_url: String, pub tip_account: PubkeyString, pub tip_lamports: u64, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct MonitoringConfig { pub log_level: String, pub telemetry_enabled: bool, } #[derive(Debug, Clone, Serialize, Deserialize)] pub struct PubkeyString(pub String); impl PubkeyString { pub fn to_pubkey(&self) -> Result { Pubkey::from_str(&self.0).context("Invalid pubkey") } } impl BotConfig { pub fn load() -> Result { dotenv::dotenv().ok(); let config = Self { rpc: RpcConfig { url: std::env::var("SOLANA_RPC_URL") .unwrap_or_else(|_| "https://api.devnet.solana.com".to_string()), ws_url: std::env::var("SOLANA_WS_URL") .unwrap_or_else(|_| "wss://api.devnet.solana.com".to_string()), commitment: "confirmed".to_string(), timeout_seconds: 30, }, wallet: WalletConfig { path: std::env::var("WALLET_PATH") .unwrap_or_else(|_| "~/.config/solana/id.json".to_string()) .into(), }, trading: TradingConfig { executor_program_id: PubkeyString( std::env::var("ARBITRAGE_EXECUTOR_PROGRAM_ID") .context("ARBITRAGE_EXECUTOR_PROGRAM_ID не найден в .env")?, ), min_profit_lamports: std::env::var("MIN_PROFIT_LAMPORTS") .unwrap_or_else(|_| "1000".to_string()) .parse() .context("Invalid MIN_PROFIT_LAMPORTS")?, min_profit_bps: std::env::var("MIN_PROFIT_BPS") .unwrap_or_else(|_| "10".to_string()) .parse() .context("Invalid MIN_PROFIT_BPS")?, max_slippage_bps: std::env::var("MAX_SLIPPAGE_BPS") .unwrap_or_else(|_| "500".to_string()) .parse() .context("Invalid MAX_SLIPPAGE_BPS")?, initial_amount_sol: std::env::var("INITIAL_AMOUNT_SOL") .unwrap_or_else(|_| "0.01".to_string()) .parse() .context("Invalid INITIAL_AMOUNT_SOL")?, max_legs: 5, compute_unit_limit: 400_000, priority_fee_micro_lamports: 100_000, }, dex: DexConfig { // ИСПРАВЛЕНИЕ: Правильные devnet адреса raydium_amm_v4: PubkeyString("DRaya7Kj3aMWQSy19kSjvmuwq9docCHofyP9kanQGaav".to_string()), raydium_cpmm: PubkeyString("DRaycpLY18LhpbydsBWbVJtxpNv9oXPgjRSfpF2bWpYb".to_string()), raydium_clmm: PubkeyString("DRayAUgENGQBKVaX8owNhgzkEDyoHTGVEGHVJT1E9pfH".to_string()), meteora_dlmm: PubkeyString("LBUZKhRxPF3XUpBCjp4YzTKgLccjZhTSDM9YuVaPwxo".to_string()), }, jito: None, // Отключаем Jito на devnet monitoring: MonitoringConfig { log_level: std::env::var("LOG_LEVEL").unwrap_or_else(|_| "info".to_string()), telemetry_enabled: std::env::var("TELEMETRY_ENABLED") .unwrap_or_else(|_| "false".to_string()) .parse() .unwrap_or(false), }, }; Ok(config) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/config.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/pool_math.rs --- // bot/src/arbitrage/pool_math.rs use anyhow::Result; /// Расчет выхода для пула CPMM (Constant Product Market Maker) pub fn calculate_cpmm_output( reserve_in: u64, reserve_out: u64, amount_in: u64, fee_bps: u16, ) -> Result { if reserve_in == 0 || reserve_out == 0 { anyhow::bail!("Нулевые резервы в CPMM пуле"); } let fee_multiplier = 1.0 - (fee_bps as f64 / 10000.0); let amount_in_with_fee = (amount_in as f64) * fee_multiplier; let numerator = (reserve_out as f64) * amount_in_with_fee; let denominator = (reserve_in as f64) + amount_in_with_fee; let amount_out = numerator / denominator; Ok(amount_out as u64) } /// Расчет выхода для пула CLMM (Concentrated Liquidity) pub fn calculate_clmm_output( liquidity: u128, sqrt_price_current: u128, sqrt_price_next: u128, amount_in: u64, fee_bps: u16, ) -> Result { if liquidity == 0 { anyhow::bail!("Нулевая ликвидность в CLMM пуле"); } let fee_multiplier = 1.0 - (fee_bps as f64 / 10000.0); let _amount_in_with_fee = (amount_in as f64) * fee_multiplier; let l_f64 = liquidity as f64; let sqrt_p_current = sqrt_price_current as f64; let sqrt_p_next = sqrt_price_next as f64; let delta_y = l_f64 * (sqrt_p_next - sqrt_p_current) / (sqrt_p_current * sqrt_p_next); let amount_out = delta_y * fee_multiplier; Ok(amount_out as u64) } /// Расчет выхода для пула DLMM (Dynamic Liquidity Market Maker) pub fn calculate_dlmm_output( bin_liquidity: u64, bin_price: f64, composition: f64, amount_in: u64, base_fee_bps: u16, variable_fee_bps: u16, ) -> Result { if bin_liquidity == 0 { anyhow::bail!("Нулевая ликвидность в DLMM бине"); } let total_fee_bps = base_fee_bps + variable_fee_bps; let fee_multiplier = 1.0 - (total_fee_bps as f64 / 10000.0); let l_f64 = bin_liquidity as f64; let reserve_y = composition * l_f64; let reserve_x = l_f64 / (bin_price * (1.0 - composition)); let amount_in_with_fee = (amount_in as f64) * fee_multiplier; let numerator = reserve_y * amount_in_with_fee; let denominator = reserve_x + amount_in_with_fee; let amount_out = numerator / denominator; Ok(amount_out as u64) } /// Расчет минимального выхода с учетом slippage pub fn calculate_minimum_amount_out( expected_amount: u64, slippage_bps: u16, ) -> u64 { let slippage_multiplier = 1.0 - (slippage_bps as f64 / 10000.0); ((expected_amount as f64) * slippage_multiplier) as u64 } #[cfg(test)] mod tests { use super::*; #[test] fn test_cpmm_calculation() { let output = calculate_cpmm_output( 1_000_000_000, 1_000_000_000, 100_000_000, 25, ).unwrap(); assert!(output > 90_000_000 && output < 100_000_000); } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/pool_math.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/opportunity.rs --- // bot/src/arbitrage/opportunity.rs // Оценка и валидация арбитражных возможностей use tracing::info; use anyhow::Result; use std::sync::Arc; use crate::config::BotConfig; use crate::types::{PoolState, ArbitrageOpportunity, SwapLeg, DexProtocol}; use super::bellman_ford::ArbitrageCycle; use super::profit_calculator::ProfitCalculator; pub struct OpportunityEvaluator { config: Arc, profit_calc: ProfitCalculator, } impl OpportunityEvaluator { pub fn new(config: Arc) -> Self { Self { profit_calc: ProfitCalculator::new(config.clone()), config, } } /// Оценка цикла и создание ArbitrageOpportunity /// Оценка цикла и создание ArbitrageOpportunity /// Оценка цикла и создание ArbitrageOpportunity pub fn evaluate_cycle( &self, cycle: &ArbitrageCycle, pools: &[PoolState], ) -> Result> { if cycle.tokens.len() < 3 { return Ok(None); } info!("🔍 === ДЕТАЛЬНАЯ ДИАГНОСТИКА ЦИКЛА ==="); info!("Токенов в цикле: {}", cycle.tokens.len()); // Построение swap legs с детальным логированием let mut legs: Vec = Vec::new(); let mut current_amount = (self.config.trading.initial_amount_sol * 1_000_000_000.0) as u64; info!("💰 Начальная сумма: {} lamports ({} SOL)", current_amount, current_amount as f64 / 1_000_000_000.0); for i in 0..cycle.tokens.len() - 1 { let input_mint = cycle.tokens[i]; let output_mint = cycle.tokens[i + 1]; info!("🔄 === СВОП #{} ===", i + 1); info!("От: {}", input_mint); info!("К: {}", output_mint); // Находим пул для этой пары let pool = pools.iter() .find(|p| { (p.token_a == input_mint && p.token_b == output_mint) || (p.token_a == output_mint && p.token_b == input_mint) }) .ok_or_else(|| anyhow::anyhow!("Пул не найден для пары токенов"))?; info!("📊 Найден пул: {}", pool.id); info!(" Token A: {} (резерв: {})", pool.token_a, pool.reserve_a); info!(" Token B: {} (резерв: {})", pool.token_b, pool.reserve_b); // Определяем направление свопа let a_to_b = input_mint == pool.token_a; info!("🔀 Направление: {}", if a_to_b { "A→B" } else { "B→A" }); // Рассчитываем ожидаемый выход let (estimated_out, min_out) = self.calculate_swap_amounts( pool, current_amount, a_to_b, )?; info!("💸 Входная сумма: {} lamports", current_amount); info!("💰 Ожидаемый выход: {} lamports", estimated_out); info!("📉 Минимальный выход: {} lamports", min_out); let exchange_rate = estimated_out as f64 / current_amount as f64; info!("💹 Обменный курс: {:.6}", exchange_rate); if estimated_out > current_amount { info!("✅ Прибыльный своп (+{} lamports)", estimated_out - current_amount); } else { info!("❌ Убыточный своп (-{} lamports)", current_amount - estimated_out); } let leg = SwapLeg { protocol: pool.protocol, pool_id: pool.id, input_mint, output_mint, amount_in: current_amount, minimum_amount_out: min_out, estimated_amount_out: estimated_out, fee_bps: pool.fee_bps, pool_state_data: pool.full_state_data.clone(), }; legs.push(leg); current_amount = estimated_out; // Для следующего свопа } // Расчёт чистой прибыли let initial_amount = legs[0].amount_in; let final_amount = legs.last().unwrap().estimated_amount_out; info!("📊 === ИТОГОВЫЙ РАСЧЕТ ==="); info!("🏁 Начальная сумма: {} lamports ({} SOL)", initial_amount, initial_amount as f64 / 1_000_000_000.0); info!("🎯 Финальная сумма: {} lamports ({} SOL)", final_amount, final_amount as f64 / 1_000_000_000.0); let (gross_profit, net_profit) = self.profit_calc.calculate_net_profit( initial_amount, final_amount, &legs, )?; info!("💎 Валовая прибыль: {} lamports", gross_profit); info!("🏦 Чистая прибыль: {} lamports", net_profit); info!("📊 Минимальный порог: {} lamports", self.config.trading.min_profit_lamports); // Проверка прибыльности if net_profit < self.config.trading.min_profit_lamports { info!("❌ ОТКЛОНЕНО: Прибыль {} < {} (порог)", net_profit, self.config.trading.min_profit_lamports); info!("💡 Попробуйте понизить MIN_PROFIT_LAMPORTS в .env файле"); return Ok(None); } let profit_percentage = (net_profit as f64 / initial_amount as f64) * 100.0; info!("✅ ПРИНЯТО: Арбитражная возможность одобрена!"); info!("📈 Процент прибыли: {:.4}%", profit_percentage); let opportunity = ArbitrageOpportunity { legs, initial_amount, expected_final_amount: final_amount, gross_profit, net_profit, profit_percentage, discovered_at: chrono::Utc::now().timestamp(), }; Ok(Some(opportunity)) } /// Расчёт ожидаемого и минимального выхода свопа /// Расчёт ожидаемого и минимального выхода свопа fn calculate_swap_amounts( &self, pool: &PoolState, amount_in: u64, a_to_b: bool, ) -> Result<(u64, u64)> { let (reserve_in, reserve_out) = if a_to_b { (pool.reserve_a, pool.reserve_b) } else { (pool.reserve_b, pool.reserve_a) }; // Выбор формулы в зависимости от типа протокола let estimated_out = match pool.protocol { DexProtocol::RaydiumAmmV4 | DexProtocol::RaydiumCpmm => { // Используем CPMM формулу use crate::arbitrage::pool_math::calculate_cpmm_output; calculate_cpmm_output(reserve_in, reserve_out, amount_in, pool.fee_bps)? } DexProtocol::RaydiumClmm => { // Для CLMM нужны дополнительные данные из full_state_data // Упрощенная версия использует CPMM как аппроксимацию use crate::arbitrage::pool_math::calculate_cpmm_output; calculate_cpmm_output(reserve_in, reserve_out, amount_in, pool.fee_bps)? // TODO: Реализовать полный CLMM расчет с tick данными } DexProtocol::MeteoraDlmm => { // Для DLMM используем упрощенную версию use crate::arbitrage::pool_math::calculate_dlmm_output; let bin_price = reserve_out as f64 / reserve_in as f64; let composition = 0.5; // Предполагаем сбалансированный бин calculate_dlmm_output( reserve_in + reserve_out, // Общая ликвидность bin_price, composition, amount_in, pool.fee_bps, 0, // Переменная комиссия (упрощение) )? } }; // Минимальный выход с учётом slippage use crate::arbitrage::pool_math::calculate_minimum_amount_out; let min_out = calculate_minimum_amount_out( estimated_out, self.config.trading.max_slippage_bps, ); Ok((estimated_out, min_out)) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/opportunity.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/profit_calculator.rs --- // bot/src/arbitrage/profit_calculator.rs // Расчёт чистой прибыли с учётом всех комиссий use anyhow::Result; use std::sync::Arc; use crate::config::BotConfig; use crate::types::SwapLeg; pub struct ProfitCalculator { config: Arc, } impl ProfitCalculator { pub fn new(config: Arc) -> Self { Self { config } } /// Расчёт чистой прибыли с учётом всех комиссий pub fn calculate_net_profit( &self, initial_amount: u64, final_amount: u64, _legs: &[SwapLeg], // Добавьте подчеркивание ) -> Result<(u64, u64)> { // Валовая прибыль let gross_profit = final_amount.saturating_sub(initial_amount); // Комиссии Solana let tx_base_fee = 5000_u64; let priority_fee = self.config.trading.priority_fee_micro_lamports; // Jito tip (если настроен) let jito_tip = if let Some(jito_config) = &self.config.jito { jito_config.tip_lamports } else { 0 }; // Общие комиссии let total_fees = tx_base_fee + priority_fee + jito_tip; // Чистая прибыль let net_profit = gross_profit.saturating_sub(total_fees); Ok((gross_profit, net_profit)) } /// Оценка максимально допустимого slippage для прибыльности pub fn calculate_max_slippage( &self, initial_amount: u64, expected_profit: u64, ) -> f64 { let _min_required_final = initial_amount + self.config.trading.min_profit_lamports; // Добавьте подчеркивание let max_loss = expected_profit.saturating_sub(self.config.trading.min_profit_lamports); (max_loss as f64 / expected_profit as f64) * 100.0 } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/profit_calculator.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/graph.rs --- // bot/src/arbitrage/graph.rs // Построение графа цен для поиска арбитража use anyhow::Result; use solana_sdk::pubkey::Pubkey; use std::collections::HashMap; use tracing::debug; use crate::types::{PoolState, PriceEdge}; /// Граф цен между токенами pub struct PriceGraph { /// Соответствие токен -> индекс в графе token_to_index: HashMap, /// Соответствие индекс -> токен index_to_token: Vec, /// Матрица смежности: adjacency[from][to] = vec![PriceEdge] adjacency: Vec>>, } impl PriceGraph { pub fn new() -> Self { Self { token_to_index: HashMap::new(), index_to_token: Vec::new(), adjacency: Vec::new(), } } /// Построение графа из списка пулов pub fn build_from_pools(&self, pools: &[PoolState]) -> Result { let mut graph = PriceGraph::new(); // Шаг 1: Собираем все уникальные токены for pool in pools { graph.add_token_if_new(pool.token_a); graph.add_token_if_new(pool.token_b); } let max_pools = 2000; let pools = if pools.len() > max_pools { tracing::warn!("⚠️ Ограничение пулов с {} до {}", pools.len(), max_pools); &pools[..max_pools] } else { pools }; // Собираем токены и считаем, сколько будет узлов // ... let n = graph.token_count(); // Если токенов слишком много — останавливаемся заранее let max_tokens = 2000; if n > max_tokens { anyhow::bail!("Слишком большой граф: {} токенов (> {})", n, max_tokens); } // Инициализация матрицы смежности let n = graph.token_count(); graph.adjacency = vec![vec![Vec::new(); n]; n]; // Шаг 2: Добавляем рёбра для каждого пула for pool in pools { // Направление A -> B let edge_ab = PriceEdge { from_token: pool.token_a, to_token: pool.token_b, pool_id: pool.id, protocol: pool.protocol, weight: Self::calculate_edge_weight(pool, true)?, fee_bps: pool.fee_bps, }; // Направление B -> A let edge_ba = PriceEdge { from_token: pool.token_b, to_token: pool.token_a, pool_id: pool.id, protocol: pool.protocol, weight: Self::calculate_edge_weight(pool, false)?, fee_bps: pool.fee_bps, }; graph.add_edge(edge_ab)?; graph.add_edge(edge_ba)?; } debug!("Граф построен: {} токенов, {} рёбер", n, graph.edge_count()); Ok(graph) } /// Вычисление веса ребра (отрицательный логарифм обменного курса) /// Bellman-Ford находит минимальные пути, отрицательный цикл = прибыль fn calculate_edge_weight(pool: &PoolState, a_to_b: bool) -> Result { let (reserve_in, reserve_out) = if a_to_b { (pool.reserve_a as f64, pool.reserve_b as f64) } else { (pool.reserve_b as f64, pool.reserve_a as f64) }; if reserve_in <= 0.0 || reserve_out <= 0.0 { anyhow::bail!("Нулевые резервы в пуле"); } // Учёт комиссии (fee_bps / 10000) let fee_multiplier = 1.0 - (pool.fee_bps as f64 / 10000.0); // Обменный курс с учётом комиссии let exchange_rate = (reserve_out / reserve_in) * fee_multiplier; // Вес = -log(exchange_rate) // Отрицательный цикл означает произведение курсов > 1 (прибыль) let weight = -(exchange_rate.ln()); Ok(weight) } /// Добавление токена если ещё не существует fn add_token_if_new(&mut self, token: Pubkey) { if !self.token_to_index.contains_key(&token) { let index = self.index_to_token.len(); self.token_to_index.insert(token, index); self.index_to_token.push(token); } } /// Добавление ребра в граф fn add_edge(&mut self, edge: PriceEdge) -> Result<()> { let from_idx = self.token_to_index.get(&edge.from_token) .ok_or_else(|| anyhow::anyhow!("Токен не найден в графе"))?; let to_idx = self.token_to_index.get(&edge.to_token) .ok_or_else(|| anyhow::anyhow!("Токен не найден в графе"))?; self.adjacency[*from_idx][*to_idx].push(edge); Ok(()) } /// Получение токена по индексу pub fn get_token(&self, index: usize) -> Option<&Pubkey> { self.index_to_token.get(index) } /// Получение индекса токена pub fn get_index(&self, token: &Pubkey) -> Option { self.token_to_index.get(token).copied() } /// Получение всех рёбер между двумя токенами pub fn get_edges(&self, from: usize, to: usize) -> &[PriceEdge] { &self.adjacency[from][to] } /// Количество токенов в графе pub fn token_count(&self) -> usize { self.index_to_token.len() } /// Количество рёбер в графе pub fn edge_count(&self) -> usize { self.adjacency.iter() .flat_map(|row| row.iter()) .map(|edges| edges.len()) .sum() } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/graph.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/mod.rs --- // bot/src/arbitrage/mod.rs // Оркестратор поиска арбитражных возможностей pub mod graph; pub mod bellman_ford; pub mod opportunity; pub mod profit_calculator; pub mod pool_math; use anyhow::Result; use std::sync::Arc; use tracing::{info, debug}; use crate::config::BotConfig; use crate::types::{PoolState, ArbitrageOpportunity}; use graph::PriceGraph; use bellman_ford::BellmanFordSolver; use opportunity::OpportunityEvaluator; pub struct ArbitrageFinder { config: Arc, graph_builder: PriceGraph, solver: BellmanFordSolver, evaluator: OpportunityEvaluator, } impl ArbitrageFinder { pub fn new(config: Arc) -> Self { Self { config: config.clone(), graph_builder: PriceGraph::new(), solver: BellmanFordSolver::new(), evaluator: OpportunityEvaluator::new(config), } } /// Поиск всех арбитражных возможностей в заданных пулах pub fn find_opportunities(&self, pools: &[PoolState]) -> Result> { if pools.is_empty() { return Ok(vec![]); } info!("🔍 Построение графа цен из {} пулов...", pools.len()); // Шаг 1: Построение графа цен let graph = self.graph_builder.build_from_pools(pools)?; debug!(" Граф содержит {} токенов, {} рёбер", graph.token_count(), graph.edge_count()); // Шаг 2: Поиск отрицательных циклов через Bellman-Ford info!("🧮 Применение алгоритма Bellman-Ford для поиска циклов..."); let cycles = self.solver.find_negative_cycles(&graph, self.config.trading.max_legs as usize)?; if cycles.is_empty() { debug!(" Отрицательных циклов не найдено"); return Ok(vec![]); } info!(" Найдено потенциальных циклов: {}", cycles.len()); // ДИАГНОСТИКА: Показать информацию о каждом цикле for (i, cycle) in cycles.iter().enumerate() { info!("🔄 Цикл #{}: {} токенов, вес {:.6}", i + 1, cycle.tokens.len(), cycle.total_weight); info!(" Токены: {:?}", cycle.tokens.iter() .map(|t| format!("{}...", &t.to_string()[..8])) .collect::>()); } // Шаг 3: Оценка прибыльности каждого цикла let mut opportunities = Vec::new(); for (i, cycle) in cycles.iter().enumerate() { info!("🧮 === АНАЛИЗ ЦИКЛА #{} ===", i + 1); match self.evaluator.evaluate_cycle(cycle, pools) { Ok(Some(opp)) => { info!("✅ Цикл #{} ПРИБЫЛЕН!", i + 1); // Проверка минимальной прибыли if opp.net_profit >= self.config.trading.min_profit_lamports { opportunities.push(opp); } } Ok(None) => { info!("❌ Цикл #{} отклонен", i + 1); } Err(e) => { info!("⚠️ Ошибка анализа цикла #{}: {}", i + 1, e); } } } // Сортировка по убыванию прибыли opportunities.sort_by(|a, b| b.net_profit.cmp(&a.net_profit)); info!("✅ Найдено прибыльных возможностей: {}", opportunities.len()); Ok(opportunities) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/mod.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/bellman_ford.rs --- // bot/src/arbitrage/bellman_ford.rs use anyhow::Result; use solana_sdk::pubkey::Pubkey; // ИСПРАВЛЕНИЕ: Удаляем неиспользуемый HashMap use std::collections::HashSet; use tracing::{info, debug}; use super::graph::PriceGraph; #[derive(Debug, Clone)] pub struct ArbitrageCycle { pub tokens: Vec, pub total_weight: f64, } pub struct BellmanFordSolver; impl BellmanFordSolver { pub fn new() -> Self { Self } /// ИСПРАВЛЕННЫЙ поиск арбитражных циклов pub fn find_negative_cycles( &self, graph: &PriceGraph, _max_legs: usize, // ИСПРАВЛЕНИЕ: Добавили префикс _ ) -> Result> { let n = graph.token_count(); info!("🔍 === ДИАГНОСТИКА ГРАФА ==="); info!("Токенов в графе: {}", n); // Диагностика: показать все рёбра графа let mut total_edges = 0; for from in 0..n { for to in 0..n { let edges = graph.get_edges(from, to); if !edges.is_empty() { total_edges += edges.len(); if let (Some(from_token), Some(to_token)) = (graph.get_token(from), graph.get_token(to)) { info!(" Ребро: {}... -> {}... ({} вариантов)", &from_token.to_string()[..8], &to_token.to_string()[..8], edges.len()); } } } } info!("Всего рёбер: {}", total_edges); if total_edges == 0 { info!("❌ ГРАФ ПУСТОЙ! Нет рёбер между токенами!"); return Ok(vec![]); } // Ищем циклы методом прямого поиска let mut cycles = Vec::new(); let mut found_cycles = HashSet::new(); info!("🔄 === ПОИСК ТРЕУГОЛЬНЫХ АРБИТРАЖЕЙ ==="); // Перебираем все возможные треугольники for start_idx in 0..n { for mid_idx in 0..n { if mid_idx == start_idx { continue; } for end_idx in 0..n { if end_idx == start_idx || end_idx == mid_idx { continue; } // Проверяем путь: start → mid → end → start if let Some(cycle) = self.check_triangle_arbitrage( graph, start_idx, mid_idx, end_idx )? { let cycle_signature = self.get_cycle_signature(&cycle); if !found_cycles.contains(&cycle_signature) { found_cycles.insert(cycle_signature); info!("🎯 НАЙДЕН ТРЕУГОЛЬНЫЙ АРБИТРАЖ!"); info!(" Путь: {} → {} → {} → {}", &cycle.tokens[0].to_string()[..8], &cycle.tokens[1].to_string()[..8], &cycle.tokens[2].to_string()[..8], &cycle.tokens[3].to_string()[..8]); info!(" Общий вес: {:.6}", cycle.total_weight); if cycle.total_weight < -0.001 { // Прибыльный info!(" ✅ ПРИБЫЛЬНЫЙ!"); cycles.push(cycle); } else { info!(" ❌ Не прибыльный"); } } } } } } info!("🏁 Найдено арбитражных циклов: {}", cycles.len()); Ok(cycles) } /// Проверяем треугольный арбитраж A→B→C→A fn check_triangle_arbitrage( &self, graph: &PriceGraph, a_idx: usize, b_idx: usize, c_idx: usize, ) -> Result> { // Проверяем существование всех трёх рёбер let edges_ab = graph.get_edges(a_idx, b_idx); let edges_bc = graph.get_edges(b_idx, c_idx); let edges_ca = graph.get_edges(c_idx, a_idx); if edges_ab.is_empty() || edges_bc.is_empty() || edges_ca.is_empty() { return Ok(None); // Нет полного пути } // Берём первое доступное ребро для каждого перехода let edge_ab = &edges_ab[0]; let edge_bc = &edges_bc[0]; let edge_ca = &edges_ca[0]; // Вычисляем общий вес цикла let total_weight = edge_ab.weight + edge_bc.weight + edge_ca.weight; debug!(" Проверка цикла {}->{}->{} = {:.6}", a_idx, b_idx, c_idx, total_weight); let tokens = vec![ edge_ab.from_token, edge_ab.to_token, edge_bc.to_token, edge_ca.to_token, // Возврат к началу ]; Ok(Some(ArbitrageCycle { tokens, total_weight, })) } /// Получение подписи цикла для дедупликации fn get_cycle_signature(&self, cycle: &ArbitrageCycle) -> String { let mut tokens_str: Vec = cycle.tokens[..cycle.tokens.len()-1] .iter() .map(|t| t.to_string()) .collect(); tokens_str.sort(); // Сортируем для нормализации tokens_str.join("-") } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/arbitrage/bellman_ford.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/dex_structs.rs --- // bot/src/dex_structs.rs use solana_sdk::pubkey::Pubkey; use std::convert::TryFrom; // Упрощенная структура для парсинга только нужных полей #[derive(Debug, Clone)] pub struct AmmInfo { pub base_mint: Pubkey, pub quote_mint: Pubkey, pub base_vault: Pubkey, pub quote_vault: Pubkey, pub market_program_id: Pubkey, pub market_id: Pubkey, pub open_orders: Pubkey, pub target_orders: Pubkey, pub market_bids: Pubkey, pub market_asks: Pubkey, pub market_event_queue: Pubkey, pub market_base_vault: Pubkey, pub market_quote_vault: Pubkey, pub market_authority: Pubkey, pub fees: Fees, } #[derive(Debug, Clone)] pub struct Fees { pub swap_fee_numerator: u64, pub swap_fee_denominator: u64, } impl AmmInfo { pub fn try_from_slice(data: &[u8]) -> Result> { if data.len() < 752 { return Err("Недостаточно данных для парсинга AmmInfo".into()); } // Парсим только нужные поля по известным офсетам // Основываемся на документации Raydium AMM V4 let base_mint = Self::read_pubkey(data, 400)?; // Офсет базового токена let quote_mint = Self::read_pubkey(data, 432)?; // Офсет котировочного токена let lp_mint = Self::read_pubkey(data, 464)?; // LP токен (не используем, но пропускаем) // Ключевые аккаунты let open_orders = Self::read_pubkey(data, 496)?; let target_orders = Self::read_pubkey(data, 528)?; let base_vault = Self::read_pubkey(data, 560)?; let quote_vault = Self::read_pubkey(data, 592)?; // Market аккаунты let market_program_id = Self::read_pubkey(data, 656)?; let market_id = Self::read_pubkey(data, 688)?; let market_authority = Self::read_pubkey(data, 720)?; let market_base_vault = Self::read_pubkey(data, 720)?; // Примерные офсеты let market_quote_vault = Self::read_pubkey(data, 720)?; // Будем использовать как заглушки let market_bids = Self::read_pubkey(data, 720)?; let market_asks = Self::read_pubkey(data, 720)?; let market_event_queue = Self::read_pubkey(data, 720)?; // Комиссии (упрощенно) let swap_fee_numerator = Self::read_u64(data, 200)?; // Примерные офсеты let swap_fee_denominator = Self::read_u64(data, 208)?; let fees = Fees { swap_fee_numerator, swap_fee_denominator, }; Ok(AmmInfo { base_mint, quote_mint, base_vault, quote_vault, market_program_id, market_id, open_orders, target_orders, market_bids, market_asks, market_event_queue, market_base_vault, market_quote_vault, market_authority, fees, }) } fn read_pubkey(data: &[u8], offset: usize) -> Result> { if data.len() < offset + 32 { return Err("Недостаточно данных для чтения Pubkey".into()); } let mut key_bytes = [0u8; 32]; key_bytes.copy_from_slice(&data[offset..offset + 32]); Ok(Pubkey::new_from_array(key_bytes)) } fn read_u64(data: &[u8], offset: usize) -> Result> { if data.len() < offset + 8 { return Err("Недостаточно данных для чтения u64".into()); } let mut bytes = [0u8; 8]; bytes.copy_from_slice(&data[offset..offset + 8]); Ok(u64::from_le_bytes(bytes)) } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/dex_structs.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/utils/rpc.rs --- // bot/src/utils/rpc.rs // Утилиты для работы с RPC клиентами Solana use anyhow::Result; use solana_client::{ rpc_client::RpcClient, rpc_config::RpcSendTransactionConfig, // УДАЛИТЕ неиспользуемые импорты: // rpc_config::{RpcSendTransactionConfig, RpcSimulateTransactionConfig}, // client_error::ClientError, }; use solana_sdk::{ commitment_config::CommitmentConfig, transaction::Transaction, signature::Signature, }; use std::time::Duration; use tokio::time::sleep; use tracing::{warn, debug}; /// Конфигурация ретраев для RPC запросов pub struct RetryConfig { pub max_retries: usize, pub base_delay_ms: u64, pub exponential_backoff: bool, } impl Default for RetryConfig { fn default() -> Self { Self { max_retries: 3, base_delay_ms: 500, exponential_backoff: true, } } } /// RPC клиент с множественными endpoints и ретраями pub struct MultiRpcClient { primary: RpcClient, fallbacks: Vec, retry_config: RetryConfig, } impl MultiRpcClient { pub fn new(primary_url: String, fallback_urls: Vec) -> Self { let primary = RpcClient::new_with_commitment( primary_url, CommitmentConfig::confirmed(), ); let fallbacks: Vec = fallback_urls .into_iter() .map(|url| RpcClient::new_with_commitment(url, CommitmentConfig::confirmed())) .collect(); Self { primary, fallbacks, retry_config: RetryConfig::default(), } } /// Отправка транзакции с ретраями pub async fn send_transaction_with_retry( &self, transaction: &Transaction, ) -> Result { let config = RpcSendTransactionConfig { skip_preflight: false, preflight_commitment: Some(CommitmentConfig::confirmed().commitment), ..Default::default() }; let mut last_error = None; // Попытка через primary RPC for attempt in 0..self.retry_config.max_retries { match self.primary.send_transaction_with_config(transaction, config) { Ok(signature) => { debug!("Транзакция отправлена: {} (попытка {})", signature, attempt + 1); return Ok(signature); } Err(e) => { warn!("Ошибка отправки (попытка {}): {}", attempt + 1, e); last_error = Some(e); if attempt < self.retry_config.max_retries - 1 { let delay = self.calculate_delay(attempt); sleep(Duration::from_millis(delay)).await; } } } } // Попытка через fallback RPCs for (idx, fallback) in self.fallbacks.iter().enumerate() { match fallback.send_transaction_with_config(transaction, config) { Ok(signature) => { debug!("Транзакция отправлена через fallback #{}: {}", idx + 1, signature); return Ok(signature); } Err(e) => { warn!("Fallback #{} провалился: {}", idx + 1, e); last_error = Some(e); } } } Err(anyhow::anyhow!( "Не удалось отправить транзакцию после {} попыток: {:?}", self.retry_config.max_retries, last_error )) } /// Симуляция транзакции с ретраями pub async fn simulate_transaction_with_retry( &self, transaction: &Transaction, ) -> Result { let mut last_error = None; for attempt in 0..self.retry_config.max_retries { match self.primary.simulate_transaction(transaction) { Ok(result) => return Ok(result.value), Err(e) => { warn!("Симуляция провалилась (попытка {}): {}", attempt + 1, e); last_error = Some(e); if attempt < self.retry_config.max_retries - 1 { let delay = self.calculate_delay(attempt); sleep(Duration::from_millis(delay)).await; } } } } Err(anyhow::anyhow!( "Симуляция провалилась после {} попыток: {:?}", self.retry_config.max_retries, last_error )) } /// Расчёт задержки с exponential backoff fn calculate_delay(&self, attempt: usize) -> u64 { if self.retry_config.exponential_backoff { self.retry_config.base_delay_ms * (2_u64.pow(attempt as u32)) } else { self.retry_config.base_delay_ms } } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/utils/rpc.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/utils/mod.rs --- // bot/src/utils/mod.rs pub mod math; pub mod rpc; use anyhow::{Context, Result}; use solana_sdk::signature::Keypair; use std::fs; use std::str::FromStr; use solana_sdk::pubkey::Pubkey; /// Загрузка keypair из файла pub fn load_keypair_from_file(path: &str) -> Result { let expanded_path = shellexpand::tilde(path).into_owned(); let keypair_bytes = fs::read(&expanded_path) .context(format!("Не удалось прочитать файл кошелька: {}", expanded_path))?; let keypair_data: Vec = serde_json::from_slice(&keypair_bytes) .context("Неверный формат файла кошелька (ожидается JSON массив байт)")?; // ИСПРАВЛЕНИЕ: используем try_from вместо устаревшего from_bytes let keypair = Keypair::try_from(&keypair_data[..]) .map_err(|e| anyhow::anyhow!("Не удалось создать keypair из байтов: {}. Убедитесь, что файл содержит 64 байта.", e))?; Ok(keypair) } /// Форматирование lamports в SOL с заданной точностью pub fn lamports_to_sol(lamports: u64, decimals: usize) -> String { let sol = lamports as f64 / 1_000_000_000.0; format!("{:.decimals$}", sol, decimals = decimals) } /// Конвертация SOL в lamports pub fn sol_to_lamports(sol: f64) -> u64 { (sol * 1_000_000_000.0) as u64 } /// Проверка валидности Pubkey pub fn is_valid_pubkey(address: &str) -> bool { Pubkey::from_str(address).is_ok() } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/utils/mod.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/utils/math.rs --- // bot/src/utils/math.rs // Математические утилиты для расчётов арбитража use anyhow::Result; /// Расчёт выхода свопа по формуле постоянного произведения (AMM) /// /// # Формула /// amount_out = (reserve_out * amount_in) / (reserve_in + amount_in) /// /// # Параметры /// - reserve_in: Резерв входного токена /// - reserve_out: Резерв выходного токена /// - amount_in: Количество входного токена /// - fee_bps: Комиссия в базисных пунктах (25 = 0.25%) pub fn calculate_amm_swap_output( reserve_in: u64, reserve_out: u64, amount_in: u64, fee_bps: u16, ) -> Result { if reserve_in == 0 || reserve_out == 0 { anyhow::bail!("Нулевые резервы в пуле"); } // Применение комиссии к входной сумме let fee_multiplier = 1.0 - (fee_bps as f64 / 10000.0); let amount_in_with_fee = (amount_in as f64) * fee_multiplier; // Формула постоянного произведения let numerator = (reserve_out as f64) * amount_in_with_fee; let denominator = (reserve_in as f64) + amount_in_with_fee; let amount_out = numerator / denominator; Ok(amount_out as u64) } /// Расчёт минимального выхода с учётом slippage /// /// # Параметры /// - expected_amount: Ожидаемая сумма /// - slippage_bps: Допустимый slippage в базисных пунктах (100 = 1%) pub fn calculate_minimum_amount_out( expected_amount: u64, slippage_bps: u16, ) -> u64 { let slippage_multiplier = 1.0 - (slippage_bps as f64 / 10000.0); ((expected_amount as f64) * slippage_multiplier) as u64 } /// Расчёт цены токена A в терминах токена B pub fn calculate_price_a_to_b(reserve_a: u64, reserve_b: u64) -> f64 { if reserve_b == 0 { return 0.0; } reserve_a as f64 / reserve_b as f64 } /// Расчёт изменения цены в процентах pub fn calculate_price_change_percent(old_price: f64, new_price: f64) -> f64 { if old_price == 0.0 { return 0.0; } ((new_price - old_price) / old_price) * 100.0 } /// Расчёт прибыли в процентах pub fn calculate_profit_percentage(initial: u64, final_amount: u64) -> f64 { if initial == 0 { return 0.0; } ((final_amount as f64 - initial as f64) / initial as f64) * 100.0 } /// Проверка прибыльности с учётом минимального порога pub fn is_profitable( initial_amount: u64, final_amount: u64, min_profit_lamports: u64, ) -> bool { final_amount >= initial_amount + min_profit_lamports } /// Расчёт общих комиссий транзакции pub fn calculate_total_transaction_fees( base_fee: u64, priority_fee: u64, jito_tip: u64, ) -> u64 { base_fee + priority_fee + jito_tip } /// Расчёт точки безубыточности (breakeven) для арбитража /// /// Возвращает минимальную финальную сумму для достижения нулевой прибыли pub fn calculate_breakeven_amount( initial_amount: u64, transaction_fees: u64, ) -> u64 { initial_amount + transaction_fees } /// Расчёт эффективной APY для арбитража /// /// # Параметры /// - profit_lamports: Прибыль за одну сделку /// - capital_lamports: Использованный капитал /// - trades_per_day: Среднее количество сделок в день pub fn calculate_effective_apy( profit_lamports: u64, capital_lamports: u64, trades_per_day: f64, ) -> f64 { if capital_lamports == 0 { return 0.0; } let daily_return = (profit_lamports as f64 / capital_lamports as f64) * trades_per_day; let annual_return = daily_return * 365.0; annual_return * 100.0 // В процентах } /// Расчёт impact на пул (price impact от свопа) pub fn calculate_price_impact( reserve_in: u64, reserve_out: u64, amount_in: u64, ) -> f64 { let price_before = reserve_out as f64 / reserve_in as f64; let new_reserve_in = reserve_in + amount_in; let price_after = reserve_out as f64 / new_reserve_in as f64; ((price_after - price_before) / price_before).abs() * 100.0 } #[cfg(test)] mod tests { use super::*; #[test] fn test_amm_swap_output() { // Пул: 1000 USDC, 1000 SOL, комиссия 0.25% let output = calculate_amm_swap_output( 1_000_000_000, // 1000 USDC 1_000_000_000, // 1000 SOL 100_000_000, // 100 USDC in 25, // 0.25% fee ).unwrap(); // Ожидаем ~90.7 SOL (с учётом комиссии и slippage) assert!(output > 90_000_000 && output < 100_000_000); } #[test] fn test_minimum_amount_out() { let expected = 1_000_000_000; // 1 SOL let min_out = calculate_minimum_amount_out(expected, 100); // 1% slippage assert_eq!(min_out, 990_000_000); // 0.99 SOL } #[test] fn test_price_change() { let change = calculate_price_change_percent(100.0, 110.0); assert!((change - 10.0).abs() < 0.01); let change_down = calculate_price_change_percent(100.0, 90.0); assert!((change_down + 10.0).abs() < 0.01); } #[test] fn test_profitability_check() { assert!(is_profitable(1_000_000, 1_100_000, 50_000)); // Прибыльно assert!(!is_profitable(1_000_000, 1_040_000, 50_000)); // Не прибыльно } #[test] fn test_apy_calculation() { // Прибыль 0.01 SOL с капитала 1 SOL, 10 сделок в день let apy = calculate_effective_apy( 10_000_000, // 0.01 SOL profit 1_000_000_000, // 1 SOL capital 10.0, // 10 trades/day ); // Ожидаем ~36.5% годовых assert!((apy - 36.5).abs() < 1.0); } #[test] fn test_price_impact() { let impact = calculate_price_impact( 1_000_000_000, // 1000 tokens in reserve 1_000_000_000, // 1000 tokens out reserve 100_000_000, // 100 tokens swap ); // Impact должен быть ~9.09% assert!(impact > 9.0 && impact < 10.0); } } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/utils/math.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/src/types.rs --- // bot/src/types.rs // Shared types and structures use serde::{Deserialize, Serialize}; use solana_sdk::pubkey::Pubkey; use std::fmt; #[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)] pub enum DexProtocol { RaydiumAmmV4, RaydiumCpmm, RaydiumClmm, MeteoraDlmm, } impl fmt::Display for DexProtocol { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { match self { DexProtocol::RaydiumAmmV4 => write!(f, "Raydium AMM V4"), DexProtocol::RaydiumCpmm => write!(f, "Raydium CPMM"), DexProtocol::RaydiumClmm => write!(f, "Raydium CLMM"), DexProtocol::MeteoraDlmm => write!(f, "Meteora DLMM"), } } } /// Pool state data #[derive(Debug, Clone, Serialize, Deserialize)] pub struct PoolState { pub id: Pubkey, pub protocol: DexProtocol, pub token_a: Pubkey, pub token_b: Pubkey, pub reserve_a: u64, pub reserve_b: u64, pub fee_bps: u16, pub last_updated: i64, pub full_state_data: Vec, } impl PoolState { pub fn price_a_to_b(&self) -> f64 { if self.reserve_b == 0 { return 0.0; } self.reserve_a as f64 / self.reserve_b as f64 } pub fn price_b_to_a(&self) -> f64 { if self.reserve_a == 0 { return 0.0; } self.reserve_b as f64 / self.reserve_a as f64 } } /// Single swap leg in arbitrage route #[derive(Debug, Clone, Serialize, Deserialize)] pub struct SwapLeg { pub protocol: DexProtocol, pub pool_id: Pubkey, pub input_mint: Pubkey, pub output_mint: Pubkey, pub amount_in: u64, pub minimum_amount_out: u64, pub estimated_amount_out: u64, pub fee_bps: u16, pub pool_state_data: Vec, } /// Complete arbitrage opportunity #[derive(Debug, Clone, Serialize, Deserialize)] pub struct ArbitrageOpportunity { pub legs: Vec, pub initial_amount: u64, pub expected_final_amount: u64, pub gross_profit: u64, pub net_profit: u64, pub profit_percentage: f64, pub discovered_at: i64, } impl ArbitrageOpportunity { pub fn is_profitable(&self, min_profit: u64) -> bool { self.net_profit >= min_profit } } /// Price edge in graph #[derive(Debug, Clone, Copy)] pub struct PriceEdge { pub from_token: Pubkey, pub to_token: Pubkey, pub pool_id: Pubkey, pub protocol: DexProtocol, pub weight: f64, // -log(exchange_rate) for Bellman-Ford pub fee_bps: u16, } pub struct SimulationResult { pub err: Option, pub logs: Vec, pub units_consumed: Option, } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/src/types.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/bot/Cargo.toml --- # bot/Cargo.toml [package] name = "arbitrage-bot" version = "0.1.0" edition = "2021" [dependencies] arbitrage-executor = { path = "../programs/arbitrage-executor" } solana-program = { workspace = true } solana-sdk = { workspace = true } solana-client = { workspace = true } solana-account-decoder = { workspace = true } solana-transaction-status = { workspace = true } solana-program-pack = { workspace = true } anchor-client = { workspace = true } anchor-spl = { workspace = true } borsh = { workspace = true } anchor-lang = { workspace = true } solana-system-interface = { version = "2.0.0" } tokio = { workspace = true } futures = "0.3" async-trait = "0.1" serde = { workspace = true } serde_json = { workspace = true } bincode = { workspace = true } tracing = { workspace = true } tracing-subscriber = { workspace = true } anyhow = { workspace = true } reqwest = { workspace = true } dotenv = "0.15" bs58 = { workspace = true } rayon = { workspace = true } dashmap = { workspace = true } chrono = { workspace = true } shellexpand = { workspace = true } once_cell = { workspace = true } lru = { workspace = true } spl-token = { workspace = true } spl-associated-token-account = { workspace = true } bytemuck = { version = "1.14", features = ["derive"] } --- End File: /home/newvovi5/arbitrage-bot-rust/bot/Cargo.toml --- --- File: /home/newvovi5/arbitrage-bot-rust/Cargo.toml --- [workspace] members = [ "programs/arbitrage-executor", "bot", ] resolver = "2" [workspace.dependencies] # Современные версии для nightly Rust solana-sdk = "2.3.0" solana-client = "2.3.0" solana-program = "2.3.0" solana-account-decoder = "2.3.0" solana-transaction-status = "2.3.0" solana-system-interface = "2.0.0" solana-program-pack = "2.2.1" anchor-lang = "0.31.0" anchor-spl = "0.31.0" anchor-client = "0.31.0" # --- ОБНОВЛЕННЫЕ ВЕРСИИ --- borsh = "1.5.1" spl-token = "6.0.0" spl-associated-token-account = "6.0.0" # --- РАСКОММЕНТИРОВАННЫЕ ЗАВИСИМОСТИ БОТА --- tokio = { version = "1.38", features = ["full"] } serde = { version = "1.0", features = ["derive"] } serde_json = "1.0" bincode = "1.3" tracing = "0.1" tracing-subscriber = { version = "0.3", features = ["env-filter"] } anyhow = "1.0" reqwest = { version = "0.11", features = ["json", "rustls-tls"] } bs58 = "0.5" rayon = "1.10" dashmap = "5.5" chrono = "0.4" shellexpand = "3.1" once_cell = "1.21.3" lru = "0.12" futures = "0.3" async-trait = "0.1" bytemuck = { version = "1.14", features = ["derive"] } [profile.release] overflow-checks = true --- End File: /home/newvovi5/arbitrage-bot-rust/Cargo.toml --- --- File: /home/newvovi5/arbitrage-bot-rust/create-test-pool.js --- // create-test-pool.js const { Connection, Keypair, PublicKey, Transaction } = require('@solana/web3.js'); const { createMint, createAccount, mintTo, TOKEN_PROGRAM_ID } = require('@solana/spl-token'); const { AmmV4, ApiPoolInfoV4, LiquidityPoolKeys, MARKET_STATE_LAYOUT_V3, Market, TOKEN_PROGRAM_ID: RAYDIUM_TOKEN_PROGRAM_ID } = require('@raydium-io/raydium-sdk-v2'); const fs = require('fs'); const RPC_ENDPOINT = 'https://api.devnet.solana.com'; const connection = new Connection(RPC_ENDPOINT, 'confirmed'); // Загружаем кошелек const keypairData = JSON.parse(fs.readFileSync(process.env.HOME + '/.config/solana/id.json')); const wallet = Keypair.fromSecretKey(new Uint8Array(keypairData)); console.log('🔑 Кошелек:', wallet.publicKey.toString()); async function createTestPool() { try { console.log('🏗️ Создание тестового пула на devnet...'); // Шаг 1: Создание тестовых токенов console.log('📄 Создание тестовых токенов...'); const tokenA = await createMint( connection, wallet, wallet.publicKey, null, 9, // decimals TOKEN_PROGRAM_ID ); const tokenB = await createMint( connection, wallet, wallet.publicKey, null, 6, // decimals (как USDC) TOKEN_PROGRAM_ID ); console.log('🪙 Token A:', tokenA.toString()); console.log('🪙 Token B:', tokenB.toString()); // Шаг 2: Создание токен аккаунтов const tokenAccountA = await createAccount( connection, wallet, tokenA, wallet.publicKey ); const tokenAccountB = await createAccount( connection, wallet, tokenB, wallet.publicKey ); // Шаг 3: Минтинг токенов console.log('💰 Минтинг тестовых токенов...'); await mintTo( connection, wallet, tokenA, tokenAccountA, wallet, 1000 * 10**9 // 1000 токенов A ); await mintTo( connection, wallet, tokenB, tokenAccountB, wallet, 1000 * 10**6 // 1000 токенов B ); console.log('✅ Тестовые токены созданы и заминчены'); console.log('📝 Сохраните эти адреса:'); console.log(' Token A:', tokenA.toString()); console.log(' Token B:', tokenB.toString()); console.log(' Token Account A:', tokenAccountA.toString()); console.log(' Token Account B:', tokenAccountB.toString()); // Примечание: Для создания полноценного AMM пула нужно больше кода // Это базовая настройка для тестирования сканера } catch (error) { console.error('❌ Ошибка:', error); } } // Альтернативный простой метод для тестирования async function findExistingPools() { console.log('🔍 Поиск существующих пулов на devnet...'); const RAYDIUM_AMM_PROGRAM = new PublicKey('DRaya7Kj3aMWQSy19kSjvmuwq9docCHofyP9kanQGaav'); try { const accounts = await connection.getProgramAccounts(RAYDIUM_AMM_PROGRAM, { filters: [ { dataSize: 752 } // Размер AmmInfo структуры ] }); console.log(`📊 Найдено ${accounts.length} пулов Raydium AMM на devnet`); accounts.slice(0, 5).forEach((account, i) => { console.log(` Пул ${i + 1}: ${account.pubkey.toString()}`); }); return accounts; } catch (error) { console.error('❌ Ошибка поиска пулов:', error); return []; } } // Запускаем async function main() { console.log('🚀 Настройка тестовой среды для арбитражного бота'); // Проверяем баланс const balance = await connection.getBalance(wallet.publicKey); console.log('💰 Баланс SOL:', balance / 10**9); if (balance < 10**9) { // Меньше 1 SOL console.log('⚠️ Низкий баланс! Получите devnet SOL:'); console.log(' solana airdrop 2'); return; } // Сначала проверим существующие пулы const existingPools = await findExistingPools(); if (existingPools.length > 0) { console.log('✅ На devnet есть пулы для тестирования'); } else { console.log('⚠️ Пулов не найдено, создаем тестовые токены...'); await createTestPool(); } } main().catch(console.error); --- End File: /home/newvovi5/arbitrage-bot-rust/create-test-pool.js --- --- File: /home/newvovi5/arbitrage-bot-rust/Anchor.toml --- # arbitrage-bot-rust/Anchor.toml [toolchain] anchor_version = "0.31.0" solana_version = "2.3.0" [features] seeds = false skip-lint = false resolution = true [programs.localnet] arbitrage_executor = "HXccYBQu47LExrec1CAUBybYsXQL2pkEEdTaSD9emRY9" [programs.devnet] arbitrage_executor = "HXccYBQu47LExrec1CAUBybYsXQL2pkEEdTaSD9emRY9" [programs.mainnet] arbitrage_executor = "HXccYBQu47LExrec1CAUBybYsXQL2pkEEdTaSD9emRY9" [registry] url = "https://api.apr.dev" [provider] cluster = "devnet" wallet = "~/.config/solana/id.json" [scripts] test = "cargo test-sbf" build = "anchor build" deploy-devnet = "anchor deploy --provider.cluster devnet" deploy-mainnet = "anchor deploy --provider.cluster mainnet-beta" [test] startup_wait = 10000 [[test.genesis]] address = "44SMYSDatw9DU6amM4d3Yv9SkxzBRphtoftLP6ep5M7T" program = "./target/deploy/arbitrage_executor.so" [test.validator] bind_address = "0.0.0.0" url = "https://api.devnet.solana.com" --- End File: /home/newvovi5/arbitrage-bot-rust/Anchor.toml --- --- File: /home/newvovi5/arbitrage-bot-rust/programs/arbitrage-executor/src/lib.rs --- // programs/arbitrage-executor/src/lib.rs // Smart Contract "Executor" for Atomic Multi-Hop Swaps via CPI use anchor_lang::prelude::*; use anchor_lang::solana_program::{ instruction::{AccountMeta, Instruction}, program::invoke, }; use anchor_spl::token::{Token, TokenAccount, Mint}; use anchor_lang::solana_program::pubkey; declare_id!("HXccYBQu47LExrec1CAUBybYsXQL2pkEEdTaSD9emRY9"); // ============================================================================ // DEX PROGRAM IDS (MAINNET) // ============================================================================ pub const RAYDIUM_AMM_V4: Pubkey = pubkey!("DRaya7Kj3aMWQSy19kSjvmuwq9docCHofyP9kanQGaav"); pub const RAYDIUM_CPMM: Pubkey = pubkey!("DRaycpLY18LhpbydsBWbVJtxpNv9oXPgjRSfpF2bWpYb"); pub const RAYDIUM_CLMM: Pubkey = pubkey!("DRayAUgENGQBKVaX8owNhgzkEDyoHTGVEGHVJT1E9pfH"); pub const METEORA_DLMM: Pubkey = pubkey!("LBUZKhRxPF3XUpBCjp4YzTKgLccjZhTSDM9YuVaPwxo"); // ============================================================================ // TYPES & ENUMS // ============================================================================ #[derive(AnchorSerialize, AnchorDeserialize, Clone, Copy, PartialEq, Eq, Debug)] pub enum DexProtocol { RaydiumAmmV4, RaydiumCpmm, RaydiumClmm, MeteoraDlmm, } impl DexProtocol { pub fn program_id(&self) -> Pubkey { match self { DexProtocol::RaydiumAmmV4 => RAYDIUM_AMM_V4, DexProtocol::RaydiumCpmm => RAYDIUM_CPMM, DexProtocol::RaydiumClmm => RAYDIUM_CLMM, DexProtocol::MeteoraDlmm => METEORA_DLMM, } } } /// Single swap leg in multi-hop route #[derive(AnchorSerialize, AnchorDeserialize, Clone, Debug)] pub struct SwapLeg { pub protocol: DexProtocol, pub pool_id: Pubkey, pub input_mint: Pubkey, pub output_mint: Pubkey, pub amount_in: u64, pub minimum_amount_out: u64, /// Number of accounts needed for CPI (extracted from remaining_accounts) pub accounts_len: u8, } // ============================================================================ // ERRORS // ============================================================================ #[error_code] pub enum ArbitrageError { #[msg("Insufficient profit - arbitrage not profitable")] InsufficientProfit, #[msg("Slippage tolerance exceeded")] SlippageExceeded, #[msg("Invalid number of accounts provided")] InvalidAccountsCount, #[msg("Invalid DEX protocol specified")] InvalidDexProtocol, #[msg("Math overflow during calculation")] MathOverflow, #[msg("Unauthorized user")] Unauthorized, #[msg("Too many swap legs (max 5)")] TooManyLegs, #[msg("Insufficient balance")] InsufficientBalance, #[msg("CPI call failed")] CpiCallFailed, #[msg("Invalid token account")] InvalidTokenAccount, } // ============================================================================ // PROGRAM MODULE // ============================================================================ #[program] pub mod arbitrage_executor { use super::*; /// Execute atomic multi-hop arbitrage swap /// /// # Parameters /// - `swap_legs`: Sequence of swaps to execute /// - `min_profit_lamports`: Minimum required profit in lamports /// /// # Logic /// 1. Record initial balance /// 2. Execute each swap via CPI to respective DEX /// 3. Verify final balance >= initial + min_profit /// 4. If profit insufficient - transaction reverts pub fn execute_arbitrage<'a, 'b, 'c, 'info>( ctx: Context<'a, 'b, 'c, 'info, ExecuteArbitrage<'info>>, swap_legs: Vec, min_profit_lamports: u64, ) -> Result<()> where 'c: 'info, { // Validate swap legs count (max 5 to limit compute units) require!( !swap_legs.is_empty() && swap_legs.len() <= 5, ArbitrageError::TooManyLegs ); msg!( "🚀 Starting arbitrage: {} legs, min profit {} lamports", swap_legs.len(), min_profit_lamports ); // Record initial balance let initial_balance = ctx.accounts.user_token_account.amount; msg!("💰 Initial balance: {} lamports", initial_balance); // Validate sufficient balance require!( initial_balance >= swap_legs[0].amount_in, ArbitrageError::InsufficientBalance ); // Execute each swap leg let mut account_cursor = 0_usize; for (idx, leg) in swap_legs.iter().enumerate() { msg!( "📊 Leg {}/{}: {:?} on pool {}", idx + 1, swap_legs.len(), leg.protocol, leg.pool_id ); // Extract accounts for current leg from remaining_accounts let accounts_end = account_cursor .checked_add(leg.accounts_len as usize) .ok_or(ArbitrageError::MathOverflow)?; require!( accounts_end <= ctx.remaining_accounts.len(), ArbitrageError::InvalidAccountsCount ); let leg_accounts = &ctx.remaining_accounts[account_cursor..accounts_end]; // Execute swap via CPI execute_swap_cpi(leg, leg_accounts, &ctx.accounts.user)?; account_cursor = accounts_end; // Reload balance after intermediate step if idx < swap_legs.len() - 1 { ctx.accounts.user_token_account.reload()?; msg!(" Intermediate balance: {}", ctx.accounts.user_token_account.amount); } } // Final profitability check ctx.accounts.user_token_account.reload()?; let final_balance = ctx.accounts.user_token_account.amount; msg!("💎 Final balance: {} lamports", final_balance); // Calculate net profit let profit = final_balance .checked_sub(initial_balance) .ok_or(ArbitrageError::MathOverflow)?; msg!( "📈 Profit: {} lamports ({:.4}%)", profit, (profit as f64 / initial_balance as f64) * 100.0 ); // Verify minimum profit (CRITICAL: reverts if insufficient) require!( profit >= min_profit_lamports, ArbitrageError::InsufficientProfit ); msg!("✅ ARBITRAGE SUCCESSFUL"); // Emit event for monitoring emit!(ArbitrageExecutedEvent { user: ctx.accounts.user.key(), initial_balance, final_balance, profit, legs_count: swap_legs.len() as u8, timestamp: Clock::get()?.unix_timestamp, }); Ok(()) } } // ============================================================================ // ACCOUNT STRUCTURES // ============================================================================ #[derive(Accounts)] pub struct ExecuteArbitrage<'info> { #[account(mut)] pub user: Signer<'info>, #[account( mut, constraint = user_token_account.owner == user.key() @ ArbitrageError::Unauthorized )] pub user_token_account: Account<'info, TokenAccount>, #[account( constraint = user_token_account.mint == token_mint.key() @ ArbitrageError::InvalidTokenAccount )] pub token_mint: Account<'info, Mint>, pub token_program: Program<'info, Token>, pub system_program: Program<'info, System>, } // ============================================================================ // EVENTS // ============================================================================ #[event] pub struct ArbitrageExecutedEvent { pub user: Pubkey, pub initial_balance: u64, pub final_balance: u64, pub profit: u64, pub legs_count: u8, pub timestamp: i64, } // ============================================================================ // CPI HELPER FUNCTIONS // ============================================================================ /// Execute swap via CPI to DEX fn execute_swap_cpi<'info>( leg: &SwapLeg, accounts: &'info [AccountInfo<'info>], user: &Signer<'info>, ) -> Result<()> { match leg.protocol { DexProtocol::RaydiumAmmV4 => raydium_amm_swap(leg, accounts, user), DexProtocol::RaydiumCpmm => raydium_cpmm_swap(leg, accounts, user), DexProtocol::RaydiumClmm => raydium_clmm_swap(leg, accounts, user), DexProtocol::MeteoraDlmm => meteora_dlmm_swap(leg, accounts, user), } } /// Raydium AMM V4 swap_base_in CPI fn raydium_amm_swap<'info>( leg: &SwapLeg, accounts: &'info [AccountInfo<'info>], _user: &Signer<'info>, ) -> Result<()> { require!(accounts.len() == 18, ArbitrageError::InvalidAccountsCount); // Raydium AMM V4 swap_base_in discriminator: 0x09 let mut data = vec![0x09]; data.extend_from_slice(&leg.amount_in.to_le_bytes()); data.extend_from_slice(&leg.minimum_amount_out.to_le_bytes()); let account_metas: Vec = accounts .iter() .map(|acc| AccountMeta { pubkey: *acc.key, is_signer: acc.is_signer, is_writable: acc.is_writable, }) .collect(); let ix = Instruction { program_id: RAYDIUM_AMM_V4, accounts: account_metas, data, }; invoke(&ix, accounts).map_err(|_| error!(ArbitrageError::CpiCallFailed))?; msg!(" ✅ Raydium AMM swap executed"); Ok(()) } /// Raydium CPMM swap CPI fn raydium_cpmm_swap<'info>( leg: &SwapLeg, accounts: &'info [AccountInfo<'info>], _user: &Signer<'info>, ) -> Result<()> { require!(accounts.len() >= 10, ArbitrageError::InvalidAccountsCount); // CPMM swap discriminator (verify from SDK documentation) let mut data = vec![0xf8, 0xc6, 0x9e, 0x91, 0xe1, 0x75, 0x87, 0xc8]; data.extend_from_slice(&leg.amount_in.to_le_bytes()); data.extend_from_slice(&leg.minimum_amount_out.to_le_bytes()); let account_metas: Vec = accounts .iter() .map(|acc| AccountMeta { pubkey: *acc.key, is_signer: acc.is_signer, is_writable: acc.is_writable, }) .collect(); let ix = Instruction { program_id: RAYDIUM_CPMM, accounts: account_metas, data, }; invoke(&ix, accounts).map_err(|_| error!(ArbitrageError::CpiCallFailed))?; msg!(" ✅ Raydium CPMM swap executed"); Ok(()) } /// Raydium CLMM swap CPI fn raydium_clmm_swap<'info>( leg: &SwapLeg, accounts: &'info [AccountInfo<'info>], _user: &Signer<'info>, ) -> Result<()> { require!(accounts.len() >= 12, ArbitrageError::InvalidAccountsCount); // CLMM swap discriminator let mut data = vec![0x7c, 0x1c, 0x97, 0xce, 0x3b, 0x8f, 0x8d, 0x6e]; data.extend_from_slice(&leg.amount_in.to_le_bytes()); data.extend_from_slice(&leg.minimum_amount_out.to_le_bytes()); data.extend_from_slice(&(160 as u128).to_le_bytes()); // sqrt_price_limit let account_metas: Vec = accounts .iter() .map(|acc| AccountMeta { pubkey: *acc.key, is_signer: acc.is_signer, is_writable: acc.is_writable, }) .collect(); let ix = Instruction { program_id: RAYDIUM_CLMM, accounts: account_metas, data, }; invoke(&ix, accounts).map_err(|_| error!(ArbitrageError::CpiCallFailed))?; msg!(" ✅ Raydium CLMM swap executed"); Ok(()) } /// Meteora DLMM swap CPI fn meteora_dlmm_swap<'info>( leg: &SwapLeg, accounts: &'info [AccountInfo<'info>], _user: &Signer<'info>, ) -> Result<()> { require!(accounts.len() >= 10, ArbitrageError::InvalidAccountsCount); // Meteora DLMM swap discriminator let mut data = vec![0x13, 0x98, 0xa2, 0x5f, 0x5e, 0x8f, 0x2d, 0x7c]; data.extend_from_slice(&leg.amount_in.to_le_bytes()); data.extend_from_slice(&leg.minimum_amount_out.to_le_bytes()); let account_metas: Vec = accounts .iter() .map(|acc| AccountMeta { pubkey: *acc.key, is_signer: acc.is_signer, is_writable: acc.is_writable, }) .collect(); let ix = Instruction { program_id: METEORA_DLMM, accounts: account_metas, data, }; invoke(&ix, accounts).map_err(|_| error!(ArbitrageError::CpiCallFailed))?; msg!(" ✅ Meteora DLMM swap executed"); Ok(()) } --- End File: /home/newvovi5/arbitrage-bot-rust/programs/arbitrage-executor/src/lib.rs --- --- File: /home/newvovi5/arbitrage-bot-rust/programs/arbitrage-executor/Cargo.toml --- # programs/arbitrage-executor/Cargo.toml [package] name = "arbitrage-executor" version = "0.1.0" description = "Solana Arbitrage Executor Smart Contract" edition = "2021" [lib] crate-type = ["cdylib", "lib"] name = "arbitrage_executor" [features] no-entrypoint = [] no-idl = [] no-log-ix-name = [] cpi = ["no-entrypoint"] default = [] custom-heap = [] custom-panic = [] anchor-debug = [] idl-build = ["anchor-lang/idl-build", "anchor-spl/idl-build"] [dependencies] anchor-lang = { workspace = true, features = ["init-if-needed"] } anchor-spl = { workspace = true } --- End File: /home/newvovi5/arbitrage-bot-rust/programs/arbitrage-executor/Cargo.toml --- --- File: /home/newvovi5/arbitrage-bot-rust/programs/arbitrage-executor/Xargo.toml --- # programs/arbitrage-executor/Xargo.toml # Конфигурация кросс-компиляции для BPF [target.bpfel-unknown-unknown.dependencies.std] features = [] [target.bpfel-unknown-unknown.dependencies.core] features = [] [target.bpfel-unknown-unknown.dependencies.compiler_builtins] features = [] --- End File: /home/newvovi5/arbitrage-bot-rust/programs/arbitrage-executor/Xargo.toml --- --- File: /home/newvovi5/arbitrage-bot-rust/.env --- # Создайте файл .env в корне проекта SOLANA_RPC_URL=https://api.devnet.solana.com SOLANA_WS_URL=wss://api.devnet.solana.com WALLET_PATH=~/.config/solana/id.json ARBITRAGE_EXECUTOR_PROGRAM_ID=HXccYBQu47LExrec1CAUBybYsXQL2pkEEdTaSD9emRY9 MIN_PROFIT_LAMPORTS=1000 MIN_PROFIT_BPS=10 MAX_SLIPPAGE_BPS=500 INITIAL_AMOUNT_SOL=0.01 LOG_LEVEL=info TELEMETRY_ENABLED=false --- End File: /home/newvovi5/arbitrage-bot-rust/.env ---