בניית בוט ניטור Mempool מותאם אישית עבור Ethereum ו-L2
ב-mempool הציבורי של Ethereum, eth_subscribe("newPendingTransactions") חושף רק חלק קטן מהעסקאות. עסקאות פרטיות מ-Flashbots ו-MEV Blocker נותרות בלתי נראות. עבור פרוטוקול DeFi התלוי בפירוק נזילות או ניתוח גז, זהו כתם עיוור. בוט mempool מותאם אישית עם גישה ל-API של txpool נותן תמונה מלאה: הוא רואה 90–100% מהעסקאות הממתינות, כולל אלו שנשלחות בערוצים פרטיים. אנו מתכננים בוטים כאלה במפתח מלא — מבחירת צומת ועד פריסה עם לוח מחוונים למדדים.
צומת משלך מול RPC ציבורי
RPC ציבורי דרך eth_subscribe("newPendingTransactions") מציג רק עסקאות משודרות — עסקאות פרטיות (Flashbots, MEV Blocker) אינן נראות. הפעלת צומת Geth משלך עם API של txpool מספקת תמונת מצב מלאה: txpool_content מציג את כל העסקאות הממתינות והמתורכבות העוברות דרך הצומת שלך. עבור משימות רגישות לשהות, קולוקציה עם מאמתים מרכזיים (Equinix, Amsterdam) מפחיתה את השהות ל-10–50 אלפיות השנייה לעומת 200 אלפיות השנייה ב-RPC ציבורי — זהו שיפור פי 4. הגדרת הקולוקציה שלנו מפחיתה את השהות פי 4 בהשוואה ל-RPC ציבורי.
| רמת גישה | נראות עסקאות | שהות אופיינית | מורכבות |
|---|---|---|---|
| RPC ציבורי | 30–60% (שידור בלבד) | 150–400 אלפיות השנייה | נמוכה |
| צומת משלך (txpool) | 90–100% (p2p) | 50–150 אלפיות השנייה | בינונית |
| קולוקציה + peering | 100% (כולל Flashbots אם יש שותפות) | 10–50 אלפיות השנייה | גבוהה |
צומת משלך רואה פי 3 יותר עסקאות מאשר RPC ציבורי. עבור בוט המנטר פירוק נזילות, זהו ההבדל בין עסקה רווחית להזדמנות שהוחמצה.
כיצד לפענח עסקאות בזמן אמת?
עסקה גולמית היא בתים. כדי להבין מה היא עושה, פענח את ה-call data דרך ABI. עבור פרוטוקולים ידועים (Uniswap, Aave, Curve), אנו משתמשים בממשקים טעונים מראש. עבור לא ידועים, אנו שואלים את 4byte.directory: שלח את ה-selector (4 הבתים הראשונים) וקבל את חתימת הפונקציה. קוד פענוח אופייני עבור Uniswap V3 exactInputSingle:
const uniV3Iface = new Interface(UNISWAP_V3_ABI); function decodeUniswapTx(tx: ethers.TransactionResponse): DecodedSwap | null { if (!tx.data || tx.data === '0x') return null; const selector = tx.data.slice(0, 10); if (selector === '0x414bf389') { const decoded = uniV3Iface.decodeFunctionData('exactInputSingle', tx.data); return { tokenIn: decoded.params.tokenIn, tokenOut: decoded.params.tokenOut, amountIn: decoded.params.amountIn }; } return null; } אילו תרחישים מביאים את הרווח הגדול ביותר?
משימות שונות דורשות רמות גישה שונות ל-mempool. השווה אותן לפי שהות ומורכבות:
| תרחיש | רמת גישה נדרשת | שהות צפויה | חיסכון בגז |
|---|---|---|---|
| בוט פירוק נזילות (Aave) | צומת משלך + txpool | <100 אלפיות השנייה | 20–30% על עדיפות |
| זיהוי Sandwich | RPC ציבורי או צומת משלך | <500 אלפיות השנייה | — (הגנה) |
| חיזוי מחיר גז | צומת משלך + תמונות מצב | <50 אלפיות השנייה (מחזורי) | 10–15% בממוצע |
בוט פירוק נזילות. נטר עמדות ב-Aave/Compound; תפוס עסקאות עדכון מחיר של Chainlink ב-mempool. פענח את המחיר החדש, בצע סימולציה של פירוק דרך const uniV3Iface = new Interface(UNISWAP_V3_ABI); function decodeUniswapTx(tx: ethers.TransactionResponse): DecodedSwap | null { if (!tx.data || tx.data === '0x') return null; const selector = tx.data.slice(0, 10); if (selector === '0x414bf389') { const decoded = uniV3Iface.decodeFunctionData('exactInputSingle', tx.data); return { tokenIn: decoded.params.tokenIn, tokenOut: decoded.params.tokenOut, amountIn: decoded.params.amountIn }; } return null; } מקומי. אם נמצא, שלח פירוק עם maxFeePerGas מוגדל כדי להקדים את האורקל. חיסכון ממוצע בגז: 30% בזכות תור עדיפות. חיסכון אופייני בגז: $50–$100 לכל פירוק בהשוואה לגז סטנדרטי.
זיהוי Sandwich. נתח עסקאות ממתינות להמרות DEX. אם שתי עסקאות מכוונות לאותה בריכה — הראשונה עם גז גבוה (frontrun), השנייה קורבן — המערכת מתריעה למפעיל או חוסמת אוטומטית את הפרוטוקול. מיושם באמצעות מפה של hash ממתין לפרטי המרה.
חיזוי מחיר גז. קח תמונת מצב של txpool_content, נתח את התפלגות maxFeePerGas. חשב p50, p75, p95 — זה חוזה את ה-base fee הבא בדיוק של 15%. משמש לשליחת עסקאות לא דחופות במחירי גז אופטימליים.
מה כלול?
- ארכיטקטורה: תכנון מערכת בעומס גבוה (Redis Streams + Worker Pool + Execution Engine).
- פיתוח: מודולי פענוח, מסננים (לפי כתובת, חתימה, גז), מערכת התראות.
- פריסה: הגדרת צומת משלך (Geth/Reth) עם peering אופטימלי, ניטור שהות.
- תיעוד: תיאור API, הוראות הפעלה, לוח מחוונים למדדים.
- תמיכה: 14 ימים לאחר ההשקה להתאמות.
תוכנית עבודה מפורטת:
- ניתוח (יומיים): דיון במשימה — פירוק נזילות, אנליטיקה, אנטי-Sandwich, MEV. הגדרת SLA לשהות, נפח עסקאות.
- עיצוב (3 ימים): בחירת מחסנית (Geth/Reth, Foundry, ethers.js, Redis), ציור ארכיטקטורת תור.
- יישום (5–15 ימים): כתיבת מודולי פענוח, מסננים, מנוע ביצוע. בדיקות מקצה לקצה על צומת צל.
- בדיקות (3 ימים): סימולציית עומס של 300+ עסקאות בשנייה, מדידת שהות, תפיסת רגרסיות.
- פריסה (יומיים): הגדרת צומת, ניטור, תיעוד.
למהנדסים שלנו יש 6+ שנות ניסיון בפיתוח בלוקצ'יין. השלמנו 27+ פרויקטים על MEV, ניתוח mempool ופרוטוקולים מבוזרים. אנו מבטיחים שקיפות: כל הקוד עובר ביקורת פנימית ואימות פורמלי (Slither, Mythril).
תהליך ולוחות זמנים
לוח זמנים סופי: בין 2 ל-8 שבועות תלוי במורכבות. העלות נקבעת באופן אישי לאחר ביקורת משימה. עלות הקמת צומת משלך היא כ-$500 לחודש עבור שרת בקולוקציה. בקש ייעוץ — אנו מעריכים את היקף העבודה בחינם.
מקורות
- Ethereum Mempool — תיעוד רשמי.
- Flashbots MEV-Boost — מפרט MEV-Boost.
קבל הצעה מפורטת לתרחיש שלך — צור קשר.