processing

💡 Overview

DV Processing is the blockchain engine behind the DV.net ecosystem — a high-performance, multi-chain service that creates wallets, executes transfers, and tracks on-chain activity across 11 blockchains. Written in Go, it exposes a ConnectRPC/gRPC API and is designed to run on your own infrastructure.

🔒 Non-custodial — private keys and mnemonics never leave your server

⚡ High-performance — ConnectRPC/gRPC, PostgreSQL, River queue

🌐 Multi-chain — 11 blockchains: EVM, UTXO and Tron

🧱 Modular — FSM workflows, clean service layer, event-driven architecture

✨ Highlights

🎯 Blockchain capabilities

• ✅ Hot, cold, and processing wallet management per owner
• ✅ Transfer processing with per-chain finite state machines
• ✅ Tron resource delegation (energy & bandwidth) and activation contracts
• ✅ EVM gas price limits and fee control per network
• ✅ Bitcoin-family UTXO management with configurable fee-per-byte
• ✅ Block scanning and explorer proxy integration

🔧 Technical features

• ✅ ConnectRPC/gRPC API with request signing and authentication interceptors
• ✅ Background job processing via River queue
• ✅ Webhook delivery with retries, cleanup workers, and configurable TTL
• ✅ PostgreSQL storage with type-safe queries (sqlc + pgxgen)
• ✅ Protobuf-first API design with buf code generation
• ✅ Systemd deployment out of the box

🧭 Architecture at a Glance

cmd/                  CLI entrypoints (server, webhooks)
internal/
  handler/            ConnectRPC request handlers
  services/           Business logic (clients, owners, wallets, transfers, webhooks)
  fsm/                Finite state machines per blockchain (tron, evm, btc, ltc, bch, doge)
  workflow/           Workflow engine with stages, steps, and retries
  store/              PostgreSQL repositories (sqlc-generated)
  dispatcher/         Event dispatching
  taskmanager/        Background jobs (River)
  eproxy/             Explorer proxy client
  rmanager/           Resource manager (Tron delegation)
  watcher/            Blockchain watcher integration
  tscanner/           Transfer scanner
  escanner/           Explorer scanner
pkg/
  walletsdk/          Blockchain wallet SDKs (btc, ltc, bch, doge, evm, tron)
  postgres/           Database connection management
  encryption/         Encryption utilities
  retry/              Retry policies
schema/               Protobuf service definitions
sql/                  Migrations and SQL queries
artifacts/            Deployment configs (systemd, scripts)

🚀 Getting Started

Build from source

git clone https://github.com/dv-net/dv-processing.git
cd dv-processing

make build

The binary will appear at bin/processing.

Run locally

cp config.template.yaml config.yaml
# edit config.yaml with your database and node settings

make migrate up
make start

ℹ️ Full deployment guide and Docker Compose setup are available in the dv-bundle repo and at https://docs.dv.net.

🛠 CLI Commands

• dv-processing start — start the gRPC/ConnectRPC server.
• dv-processing migrate — run database migrations (up / down / drop).
• dv-processing blockchain — blockchain tools (e.g. tron reclaim-resource).
• dv-processing config — validate config, generate envs and flags.
• dv-processing utils — utilities (systemd install, readme generation).
• dv-processing version — print the current version.

💡 Example — reclaim Tron resources

./dv-processing blockchain tron reclaim-resource \
  -pa TQ6DkBmxz3Zk7neh8mwmmkfJsVjrE9wwjY \
  -da TAoG3QdbgZ7saGBHiXVHRgdNJVpwUGqZZh \
  -type bandwidth

🧪 Development & Testing

📦 Install dev tools

make install-dev-tools

⚙️ Code generation

make gen          # run all generators (sql, proto, envs, abi)
make gensql       # regenerate sqlc queries
make genproto     # regenerate protobuf & ConnectRPC stubs
make genenvs      # regenerate environment variable docs

🔍 Linting & formatting

make lint
make fmt

🔄 Live reload

make watch        # uses air for hot reloading

📋 Configuration

The service is configured via config.yaml (see config.template.yaml) and/or environment variables.

All environment variables are prefixed with PROCESSING_ and follow this structure:

ℹ️ Full environment variable reference is auto-generated via make genenvs.

📦 Deployment

Systemd

./dv-processing utils systemd

This generates and installs a systemd unit file for production deployments on Linux.

🔐 Security

1. 🔓 Non-custodial — mnemonics and private keys are encrypted at rest and never leave the server.
2. ✍️ Request signing — all API calls are authenticated via signature-based interceptors.
3. 🛡️ Two-factor authentication — TOTP-based 2FA for sensitive owner operations.
4. 🔑 Encrypted storage — mnemonics and OTP secrets are encrypted in the database.

📡 API Services

The ConnectRPC API exposes the following services on port 9000:

• 👤 ClientService — merchant/client management and callback URLs
• 🏠 OwnerService — owner creation, mnemonic management, 2FA
• 💳 WalletService — hot, cold, and processing wallet operations
• 💸 TransferService — transfer creation and status tracking
• ⚙️ SystemService — system info, version checking, logs

Proto definitions are located in schema/processing/ and compiled with buf.

💝 Donations

Support the development of the project with crypto:

USDT (Tron) — TCB4bYYN5x1z9Z4bBZ7p3XxcMwdtCfmNdN

Bitcoin — bc1qemvhkgzr4r7ksgxl8lv0lw7mnnthfc6990v3c2

TRON (TRX) — TCB4bYYN5x1z9Z4bBZ7p3XxcMwdtCfmNdN

Ethereum — 0xf1e4c7b968a20aae891cc18b1d5836b806691d47

🔗 Other networks and tokens (BNB Chain, Arbitrum, Polygon, Litecoin, Dogecoin, Bitcoin Cash, etc.) are available at payment form

📞 Contact