מעקב בזמן אמת אחר סטטוס עסקאות עבור ארנקי קריפטו

העסקה נשלחה — והמשתמש בוהה בסטטוס "ממתין" במשך 10 הדקות הבאות. זה בסדר לבלוקצ'יין, אבל לא לקבל התראה כשהעסקה מאושרת או נכשלת — זה לא בסדר. מעקב אחר סטטוס עסקה הוא משימה בזמן אמת עם מספר שכבות: סקירת בלוקצ'יין, חיבור WebSocket, התראה push על סטטוס סופי. ללא עדכונים בזמן, משתמשים מאבדים אמון, ובארנקי קריפטו עם תעבורה גבוהה (למשל, 8000 עסקאות ביום) אפילו עיכוב של 5 שניות יוצר חוויה שלילית.

המהנדסים שלנו עם ניסיון של 5+ שנים בפרויקטי בלוקצ'יין יישמו מעקב עבור 15+ ארנקי קריפטו. מוסמכים על ידי Apple ו-Google, עבדנו עם Ethereum, Bitcoin, Solana ורשתות אחרות, שילבנו WebSocket דרך Alchemy WebSocket API ו-Infura, והגדרנו התראות push דרך APNs ו-FCM. אנו מבטיחים פעולה יציבה ועדכוני סטטוס בזמן.

איך נראה מחזור החיים של עסקה?

עסקת Ethereum עוברת מצבים: submitted → pending (mempool) → confirmed (1 confirmation) → finalized (12+ confirmations) → failed (reverted / dropped). Bitcoin: mempool → 1 confirmation → 6 confirmations (finalized). Solana הרבה יותר מהירה: slots של ~400ms, processed → confirmed → finalized תוך שניות. בצד הלקוח, צריך להציג את המצב הנוכחי ומספר האישורים.

אילו אסטרטגיות קיימות לקבלת סטטוס?

סקירה כל 3–5 שניות עם מסך פתוח היא בסדר. ברקע — רק דרך push שקט או WebSocket API. חיסכון בתשתית של עד 40% בשימוש ב-WebSocket במקום סקירה תכופה. עלות טיפוסית לאינטגרציה בסיסית מתחילה מ-$1,500.

סקירה דרך RPC של הצומת

// iOS — polling статуса ETH транзакции через JSON-RPC
func pollTransactionStatus(txHash: String) async throws -> TransactionStatus {
    let params: [AnyEncodable] = [txHash, false]
    let receipt = try await ethClient.call(method: "eth_getTransactionReceipt", params: params)
    if receipt == nil {
        return .pending // Ещё в mempool
    }
    let confirmations = try await getConfirmationsCount(txHash: txHash)
    return confirmations >= requiredConfirmations ? .confirmed : .confirmingWith(count: confirmations)
}

למה WebSocket מהיר יותר מסקירה?

WebSocket מספק העברת נתונים מיידית כשמופיע בלוק חדש, בעוד שסקירה כוללת עיכוב של עד 5 שניות. לעסקאות קריטיות, WebSocket הוא הבחירה המועדפת. אנו עוזרים לך לבחור את האפשרות האופטימלית לתקציב ולדרישות שלך.

מינוי WebSocket דרך Alchemy / Infura / QuickNode

// Бэкенд — подписка на событие через Alchemy WebSocket
const { createAlchemyWeb3 } = require("@alch/alchemy-web3");
const web3 = createAlchemyWeb3(process.env.ALCHEMY_WS_URL);
async function watchTransaction(txHash, userId) {
  const subscription = web3.eth.subscribe('newBlockHeaders');
  subscription.on('data', async (blockHeader) => {
    const receipt = await web3.eth.getTransactionReceipt(txHash);
    if (receipt) {
      subscription.unsubscribe();
      await updateTransactionStatus(txHash, receipt.status ? 'confirmed' : 'failed');
      await sendPushNotification(userId, txHash, receipt.status);
    }
  });
}

איך להגדיר מעקב אחר סטטוס עסקה דרך WebSocket?

1. הגדר נקודת קצה WebSocket בשרת, מאומתת על ידי טוקן משתמש.
2. בצד הלקוח, צור חיבור בעת ניווט למסך רשימת העסקאות.
3. הירשם לאירועים לפי // iOS — polling статуса ETH транзакции через JSON-RPC func pollTransactionStatus(txHash: String) async throws -> TransactionStatus { let params: [AnyEncodable] = [txHash, false] let receipt = try await ethClient.call(method: "eth_getTransactionReceipt", params: params) if receipt == nil { return .pending // Ещё в mempool } let confirmations = try await getConfirmationsCount(txHash: txHash) return confirmations >= requiredConfirmations ? .confirmed : .confirmingWith(count: confirmations) } — השרת שולח עדכוני סטטוס.
4. סגור את החיבור כשמתקבל סטטוס סופי.
5. התחבר מחדש כשהמסך נפתח מחדש או לאחר שגיאה.

// Android — подписка на статус транзакции через WebSocket
class TransactionStatusSocket(
    private val token: String,
    private val okHttpClient: OkHttpClient
) {
    fun subscribe(txHash: String): Flow<TransactionStatus> = callbackFlow {
        val ws = okHttpClient.newWebSocket(
            Request.Builder()
                .url("wss://api.yourwallet.app/ws/tx/$txHash")
                .header("Authorization", "Bearer $token")
                .build(),
            object : WebSocketListener() {
                override fun onMessage(webSocket: WebSocket, text: String) {
                    val status = json.decodeFromString<TransactionStatusUpdate>(text)
                    trySend(status.status)
                    if (status.isFinal) close()
                }

                override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
                    close(t)
                }
            }
        )
        awaitClose { ws.close(1000, "Subscription ended") }
    }
}

מחוון התקדמות לאישורים

עבור ETH, אנו מציגים התקדמות לעבר 12 אישורים. השתמש ב-// Бэкенд — подписка на событие через Alchemy WebSocket const { createAlchemyWeb3 } = require("@alch/alchemy-web3"); const web3 = createAlchemyWeb3(process.env.ALCHEMY_WS_URL); async function watchTransaction(txHash, userId) { const subscription = web3.eth.subscribe('newBlockHeaders'); subscription.on('data', async (blockHeader) => { const receipt = await web3.eth.getTransactionReceipt(txHash); if (receipt) { subscription.unsubscribe(); await updateTransactionStatus(txHash, receipt.status ? 'confirmed' : 'failed'); await sendPushNotification(userId, txHash, receipt.status); } }); } עם מעבר צבע מכתום לירוק ככל שהספירה עולה. עיצוב עסקה במצבים שונים:

• ממתין — ספינר מונפש, הדגשה צהובה
• מאשר — פס התקדמות עם מספר אישורים
• מאושר — סימן ירוק, אנימציה
• נכשל — אדום, סיבת שגיאה אם זמינה (סיבת revert מהקבלה)

התראות push על שינוי סטטוס

בסטטוס סופי, אנו שולחים push למשתמש:

{
  "title": "Транзакция подтверждена",
  "body": "0.05 ETH отправлено на 0x742d...3B8C",
  "data": {
    "screen": "transaction_detail",
    "tx_hash": "0xabc123...",
    "status": "confirmed"
  }
}

עבור עסקאות שנכשלו, תבנית נפרדת עם תיאור סיבה (סיבת revert או ירידה מ-mempool).

איך מוגדר טיפול בעסקה שנפלה?

עסקה עלולה להיעלם מה-mempool אם מחיר הגז היה נמוך מדי. לאחר 15–30 דקות ללא אישור, העסקה נחשבת שנפלה. צריך לזהות זאת:

suspend fun checkDroppedTransactions() {
    val pendingTxs = transactionDao.getPendingOlderThan(minutes = 20)
    pendingTxs.forEach { tx ->
        val receipt = ethClient.getTransactionReceipt(tx.hash)
        if (receipt == null) {
            transactionDao.updateStatus(tx.hash, TransactionStatus.DROPPED)
            pushService.notifyUser(tx.userId, "Транзакция не попала в блок", tx.hash)
        }
    }
}

מה כלול בעבודה

ניתוח הארכיטקטורה הנוכחית של הארנק ובחירת אסטרטגיה (סקירה/WebSocket/webhook). אינטגרציה עם צומתי בלוקצ'יין (Infura, Alchemy, QuickNode) או צומת משלך. יישום לוגיקת צד לקוח: לקוח סקירה/WebSocket ל-iOS ו-Android. פיתוח פס התקדמות להצגת מספר אישורים. הגדרת התראות push (APNs, FCM) על סטטוס סופי. טיפול בעסקאות שנפלו ושגיאות (סיבת revert, timeout). בדיקות על testnets (Goerli, Sepolia) ו-mainnet. תיעוד ומסירת קוד מקור. אנו גם מספקים גישה לסביבות פיתוח, הדרכה לצוות שלך, ותמיכה לאחר השקה.

לוחות זמנים ועלות

יישום בסיסי של מעקב עם סקירה והתראות push לוקח 6–10 ימי עבודה. מחזור מלא עם WebSocket, פס התקדמות, טיפול בעסקאות שנפלו ו-push מותאם אישית לוקח משבועיים. העלות מחושבת בנפרד לאחר ניתוח הפרויקט. עלות טיפוסית לאינטגרציה בסיסית מתחילה מ-$1,500. צור קשר לייעוץ והערכה מדויקת.

אנו מבטיחים איכות ומספקים תמיכה לאחר השקה. ניסיון המפתחים שלנו מאושר על ידי הסמכות של Apple ו-Google. קבל ייעוץ על ארכיטקטורת מעקב עבור ארנק הקריפטו שלך.