Create RELAY_TX handler for OmniProtocol

[tcsenpai]

Create the RELAY_TX handler following the existing transaction handler pattern.

File to modify

src/libs/omniprotocol/protocol/handlers/transaction.ts

Pattern to follow

See existing handleConfirm or handleBroadcast handlers in same file.

Handler logic

interface RelayTxRequest {
    transactions: ValidityData[]
}

export const handleRelayTx: OmniHandler<Buffer> = async ({ message, context }) => {
    if (!message.payload || !Buffer.isBuffer(message.payload) || message.payload.length === 0) {
        return encodeResponse(errorResponse(400, "Missing payload for relay_tx"))
    }

    try {
        const request = decodeJsonRequest<RelayTxRequest>(message.payload)
        
        if (!request.transactions || !Array.isArray(request.transactions)) {
            return encodeResponse(errorResponse(400, "transactions array is required"))
        }

        // Import DTRManager and call receiveRelayedTransactions
        const { DTRManager } = await import("../../../network/dtr/dtrmanager")
        const result = await DTRManager.receiveRelayedTransactions(request.transactions)

        if (result.result === 200) {
            return encodeResponse(successResponse(result.response))
        } else {
            return encodeResponse(errorResponse(result.result, "Relay failed", result.extra))
        }
    } catch (error) {
        return encodeResponse(errorResponse(500, "Internal error", error))
    }
}

Reference

• DTR branch handler in manageNodeCall.ts: case "RELAY_TX": return await DTRManager.receiveRelayedTransactions(data as ValidityData[])

[Beads: node-wcw]

[coderabbitai]

📝 CodeRabbit Plan Mode

Generate an implementation plan and prompts that you can use with your favorite coding agent.

• Create Plan

Examples

• Example 1
• Example 2

---

🔗 Similar Issues

Related Issues

• DTR (Distributed Transaction Relay) on OmniProtocol #539

👤 Suggested Assignees

• tcsenpai

---

🧪 Issue enrichment is currently in open beta.

You can configure auto-planning by selecting labels in the issue_enrichment configuration.

To disable automatic issue enrichment, add the following to your .coderabbit.yaml:

issue_enrichment:
  auto_enrich:
    enabled: false

💬 Have feedback or questions? Drop into our discord or schedule a call!