feat(blockchain-service): KAVA EVM address derivation and system accounts support
## Address Derivation Changes - Change KAVA from Cosmos bech32 (kava1...) to EVM format (0x...) - KAVA now uses same EVM address as BSC for deposit monitoring - Add KAVA to evmChains set for automatic monitoring registration ## Database Schema Updates (Migration: 20241208000000) - MonitoredAddress: add address_type, account_sequence, system_account_type, system_account_id, region_code columns - DepositTransaction: add address_type, account_sequence, system_account_type, system_account_id columns - Make user_id nullable for system account support - Create recovery_mnemonics table for account recovery - Add indexes: idx_account_sequence, idx_type_active, idx_system_account_type, idx_deposit_account, and recovery_mnemonics indexes ## New Features - Withdrawal request handler and Kafka consumer - Test USDT deployment scripts for KAVA and BSC - Smart contracts for TestUSDT token ## Infrastructure Updates - Update mappers for new schema fields - Update application and infrastructure modules 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
parent
78304801f5
commit
cf7230457f
|
|
@ -0,0 +1,59 @@
|
|||
// SPDX-License-Identifier: MIT
|
||||
pragma solidity ^0.8.20;
|
||||
|
||||
import "@openzeppelin/contracts/token/ERC20/ERC20.sol";
|
||||
import "@openzeppelin/contracts/access/Ownable.sol";
|
||||
|
||||
/**
|
||||
* @title TestUSDT
|
||||
* @dev 测试网专用 USDT 代币，任何人都可以免费 mint
|
||||
*
|
||||
* 部署步骤:
|
||||
* 1. 使用 Remix IDE (https://remix.ethereum.org)
|
||||
* 2. 连接 MetaMask 到 BSC Testnet (Chain ID: 97) 或 KAVA Testnet (Chain ID: 2221)
|
||||
* 3. 部署此合约
|
||||
* 4. 调用 mint() 函数给自己铸造代币
|
||||
*/
|
||||
contract TestUSDT is ERC20, Ownable {
|
||||
uint8 private _decimals;
|
||||
|
||||
constructor() ERC20("Test USDT", "USDT") Ownable(msg.sender) {
|
||||
_decimals = 6; // USDT 标准是 6 位小数
|
||||
// 初始铸造 1,000,000 USDT 给部署者
|
||||
_mint(msg.sender, 1_000_000 * 10 ** _decimals);
|
||||
}
|
||||
|
||||
function decimals() public view virtual override returns (uint8) {
|
||||
return _decimals;
|
||||
}
|
||||
|
||||
/**
|
||||
* @dev 任何人都可以给自己 mint 代币 (仅限测试网使用!)
|
||||
* @param amount 铸造数量 (注意: 需要乘以 10^6, 例如 1000 USDT = 1000000000)
|
||||
*/
|
||||
function mint(uint256 amount) external {
|
||||
_mint(msg.sender, amount);
|
||||
}
|
||||
|
||||
/**
|
||||
* @dev 便捷函数: 直接输入 USDT 数量，自动处理精度
|
||||
* @param usdtAmount USDT 数量 (例如输入 1000 就是 1000 USDT)
|
||||
*/
|
||||
function mintUsdt(uint256 usdtAmount) external {
|
||||
_mint(msg.sender, usdtAmount * 10 ** _decimals);
|
||||
}
|
||||
|
||||
/**
|
||||
* @dev Owner 可以给任意地址 mint
|
||||
*/
|
||||
function mintTo(address to, uint256 amount) external onlyOwner {
|
||||
_mint(to, amount);
|
||||
}
|
||||
|
||||
/**
|
||||
* @dev 水龙头功能: 一次性领取 10000 USDT
|
||||
*/
|
||||
function faucet() external {
|
||||
_mint(msg.sender, 10_000 * 10 ** _decimals);
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,142 @@
|
|||
// SPDX-License-Identifier: MIT
|
||||
pragma solidity ^0.8.20;
|
||||
|
||||
/**
|
||||
* @title TestUSDT (Flattened)
|
||||
* @dev 测试网专用 USDT，可直接在 Remix 部署，无需额外依赖
|
||||
*
|
||||
* 部署网络:
|
||||
* - BSC Testnet: Chain ID 97, RPC: https://data-seed-prebsc-1-s1.binance.org:8545
|
||||
* - KAVA Testnet: Chain ID 2221, RPC: https://evm.testnet.kava.io
|
||||
*/
|
||||
|
||||
abstract contract Context {
|
||||
function _msgSender() internal view virtual returns (address) {
|
||||
return msg.sender;
|
||||
}
|
||||
}
|
||||
|
||||
interface IERC20 {
|
||||
event Transfer(address indexed from, address indexed to, uint256 value);
|
||||
event Approval(address indexed owner, address indexed spender, uint256 value);
|
||||
function totalSupply() external view returns (uint256);
|
||||
function balanceOf(address account) external view returns (uint256);
|
||||
function transfer(address to, uint256 value) external returns (bool);
|
||||
function allowance(address owner, address spender) external view returns (uint256);
|
||||
function approve(address spender, uint256 value) external returns (bool);
|
||||
function transferFrom(address from, address to, uint256 value) external returns (bool);
|
||||
}
|
||||
|
||||
interface IERC20Metadata is IERC20 {
|
||||
function name() external view returns (string memory);
|
||||
function symbol() external view returns (string memory);
|
||||
function decimals() external view returns (uint8);
|
||||
}
|
||||
|
||||
abstract contract ERC20 is Context, IERC20, IERC20Metadata {
|
||||
mapping(address => uint256) private _balances;
|
||||
mapping(address => mapping(address => uint256)) private _allowances;
|
||||
uint256 private _totalSupply;
|
||||
string private _name;
|
||||
string private _symbol;
|
||||
|
||||
constructor(string memory name_, string memory symbol_) {
|
||||
_name = name_;
|
||||
_symbol = symbol_;
|
||||
}
|
||||
|
||||
function name() public view virtual returns (string memory) { return _name; }
|
||||
function symbol() public view virtual returns (string memory) { return _symbol; }
|
||||
function decimals() public view virtual returns (uint8) { return 18; }
|
||||
function totalSupply() public view virtual returns (uint256) { return _totalSupply; }
|
||||
function balanceOf(address account) public view virtual returns (uint256) { return _balances[account]; }
|
||||
|
||||
function transfer(address to, uint256 value) public virtual returns (bool) {
|
||||
_transfer(_msgSender(), to, value);
|
||||
return true;
|
||||
}
|
||||
|
||||
function allowance(address owner, address spender) public view virtual returns (uint256) {
|
||||
return _allowances[owner][spender];
|
||||
}
|
||||
|
||||
function approve(address spender, uint256 value) public virtual returns (bool) {
|
||||
_approve(_msgSender(), spender, value);
|
||||
return true;
|
||||
}
|
||||
|
||||
function transferFrom(address from, address to, uint256 value) public virtual returns (bool) {
|
||||
address spender = _msgSender();
|
||||
uint256 currentAllowance = allowance(from, spender);
|
||||
if (currentAllowance != type(uint256).max) {
|
||||
require(currentAllowance >= value, "ERC20: insufficient allowance");
|
||||
unchecked { _approve(from, spender, currentAllowance - value); }
|
||||
}
|
||||
_transfer(from, to, value);
|
||||
return true;
|
||||
}
|
||||
|
||||
function _transfer(address from, address to, uint256 value) internal {
|
||||
require(from != address(0), "ERC20: transfer from zero address");
|
||||
require(to != address(0), "ERC20: transfer to zero address");
|
||||
uint256 fromBalance = _balances[from];
|
||||
require(fromBalance >= value, "ERC20: insufficient balance");
|
||||
unchecked {
|
||||
_balances[from] = fromBalance - value;
|
||||
_balances[to] += value;
|
||||
}
|
||||
emit Transfer(from, to, value);
|
||||
}
|
||||
|
||||
function _mint(address account, uint256 value) internal {
|
||||
require(account != address(0), "ERC20: mint to zero address");
|
||||
_totalSupply += value;
|
||||
unchecked { _balances[account] += value; }
|
||||
emit Transfer(address(0), account, value);
|
||||
}
|
||||
|
||||
function _approve(address owner, address spender, uint256 value) internal {
|
||||
require(owner != address(0) && spender != address(0), "ERC20: zero address");
|
||||
_allowances[owner][spender] = value;
|
||||
emit Approval(owner, spender, value);
|
||||
}
|
||||
}
|
||||
|
||||
contract TestUSDT is ERC20 {
|
||||
uint8 private constant _decimals = 6;
|
||||
address public owner;
|
||||
|
||||
modifier onlyOwner() {
|
||||
require(msg.sender == owner, "Not owner");
|
||||
_;
|
||||
}
|
||||
|
||||
constructor() ERC20("Test USDT", "USDT") {
|
||||
owner = msg.sender;
|
||||
_mint(msg.sender, 1_000_000 * 10 ** _decimals);
|
||||
}
|
||||
|
||||
function decimals() public pure override returns (uint8) {
|
||||
return _decimals;
|
||||
}
|
||||
|
||||
/// @dev 任何人可以 mint (测试网专用)
|
||||
function mint(uint256 amount) external {
|
||||
_mint(msg.sender, amount);
|
||||
}
|
||||
|
||||
/// @dev 便捷函数: 输入 USDT 数量，自动处理精度
|
||||
function mintUsdt(uint256 usdtAmount) external {
|
||||
_mint(msg.sender, usdtAmount * 10 ** _decimals);
|
||||
}
|
||||
|
||||
/// @dev Owner 给任意地址 mint
|
||||
function mintTo(address to, uint256 amount) external onlyOwner {
|
||||
_mint(to, amount);
|
||||
}
|
||||
|
||||
/// @dev 水龙头: 一次领 10000 USDT
|
||||
function faucet() external {
|
||||
_mint(msg.sender, 10_000 * 10 ** _decimals);
|
||||
}
|
||||
}
|
||||
|
|
@ -49,6 +49,7 @@
|
|||
"jest": "^29.5.0",
|
||||
"prettier": "^3.0.0",
|
||||
"prisma": "^5.7.0",
|
||||
"solc": "^0.8.17",
|
||||
"source-map-support": "^0.5.21",
|
||||
"supertest": "^6.3.3",
|
||||
"ts-jest": "^29.1.0",
|
||||
|
|
@ -4087,6 +4088,13 @@
|
|||
"node": ">= 0.8"
|
||||
}
|
||||
},
|
||||
"node_modules/command-exists": {
|
||||
"version": "1.2.9",
|
||||
"resolved": "https://registry.npmjs.org/command-exists/-/command-exists-1.2.9.tgz",
|
||||
"integrity": "sha512-LTQ/SGc+s0Xc0Fu5WaKnR0YiygZkm9eKFvyS+fRsU7/ZWFF8ykFM6Pc9aCVf1+xasOOZpO3BAVgVrKvsqKHV7w==",
|
||||
"dev": true,
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/commander": {
|
||||
"version": "4.1.1",
|
||||
"resolved": "https://registry.npmjs.org/commander/-/commander-4.1.1.tgz",
|
||||
|
|
@ -7053,6 +7061,13 @@
|
|||
"url": "https://github.com/chalk/supports-color?sponsor=1"
|
||||
}
|
||||
},
|
||||
"node_modules/js-sha3": {
|
||||
"version": "0.8.0",
|
||||
"resolved": "https://registry.npmjs.org/js-sha3/-/js-sha3-0.8.0.tgz",
|
||||
"integrity": "sha512-gF1cRrHhIzNfToc802P800N8PpXS+evLLXfsVpowqmAFR9uwbi89WvXg2QspOmXL8QL86J4T1EpFu+yUkwJY3Q==",
|
||||
"dev": true,
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/js-tokens": {
|
||||
"version": "4.0.0",
|
||||
"resolved": "https://registry.npmjs.org/js-tokens/-/js-tokens-4.0.0.tgz",
|
||||
|
|
@ -7388,6 +7403,15 @@
|
|||
"node": ">= 4.0.0"
|
||||
}
|
||||
},
|
||||
"node_modules/memorystream": {
|
||||
"version": "0.3.1",
|
||||
"resolved": "https://registry.npmjs.org/memorystream/-/memorystream-0.3.1.tgz",
|
||||
"integrity": "sha512-S3UwM3yj5mtUSEfP41UZmt/0SCoVYUcU1rkXv+BQ5Ig8ndL4sPoJNBUJERafdPb5jjHJGuMgytgKvKIf58XNBw==",
|
||||
"dev": true,
|
||||
"engines": {
|
||||
"node": ">= 0.10.0"
|
||||
}
|
||||
},
|
||||
"node_modules/merge-descriptors": {
|
||||
"version": "1.0.3",
|
||||
"resolved": "https://registry.npmjs.org/merge-descriptors/-/merge-descriptors-1.0.3.tgz",
|
||||
|
|
@ -8917,6 +8941,48 @@
|
|||
"node": ">=8"
|
||||
}
|
||||
},
|
||||
"node_modules/solc": {
|
||||
"version": "0.8.17",
|
||||
"resolved": "https://registry.npmjs.org/solc/-/solc-0.8.17.tgz",
|
||||
"integrity": "sha512-Dtidk2XtTTmkB3IKdyeg6wLYopJnBVxdoykN8oP8VY3PQjN16BScYoUJTXFm2OP7P0hXNAqWiJNmmfuELtLf8g==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"command-exists": "^1.2.8",
|
||||
"commander": "^8.1.0",
|
||||
"follow-redirects": "^1.12.1",
|
||||
"js-sha3": "0.8.0",
|
||||
"memorystream": "^0.3.1",
|
||||
"semver": "^5.5.0",
|
||||
"tmp": "0.0.33"
|
||||
},
|
||||
"bin": {
|
||||
"solcjs": "solc.js"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=10.0.0"
|
||||
}
|
||||
},
|
||||
"node_modules/solc/node_modules/commander": {
|
||||
"version": "8.3.0",
|
||||
"resolved": "https://registry.npmjs.org/commander/-/commander-8.3.0.tgz",
|
||||
"integrity": "sha512-OkTL9umf+He2DZkUq8f8J9of7yL6RJKI24dVITBmNfZBmri9zYZQrKkuXiKhyfPSu8tUhnVBB1iKXevvnlR4Ww==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"engines": {
|
||||
"node": ">= 12"
|
||||
}
|
||||
},
|
||||
"node_modules/solc/node_modules/semver": {
|
||||
"version": "5.7.2",
|
||||
"resolved": "https://registry.npmjs.org/semver/-/semver-5.7.2.tgz",
|
||||
"integrity": "sha512-cBznnQ9KjJqU67B52RMC65CMarK2600WFnbkcaiwWq3xy/5haFJlshgnpjovMVJ+Hff49d8GEn0b87C5pDQ10g==",
|
||||
"dev": true,
|
||||
"license": "ISC",
|
||||
"bin": {
|
||||
"semver": "bin/semver"
|
||||
}
|
||||
},
|
||||
"node_modules/source-map": {
|
||||
"version": "0.7.4",
|
||||
"resolved": "https://registry.npmjs.org/source-map/-/source-map-0.7.4.tgz",
|
||||
|
|
|
|||
|
|
@ -68,6 +68,7 @@
|
|||
"jest": "^29.5.0",
|
||||
"prettier": "^3.0.0",
|
||||
"prisma": "^5.7.0",
|
||||
"solc": "^0.8.17",
|
||||
"source-map-support": "^0.5.21",
|
||||
"supertest": "^6.3.3",
|
||||
"ts-jest": "^29.1.0",
|
||||
|
|
|
|||
|
|
@ -0,0 +1,65 @@
|
|||
-- =============================================
|
||||
-- Migration: Add system accounts support and recovery mnemonics
|
||||
-- =============================================
|
||||
|
||||
-- AlterTable: monitored_addresses
|
||||
-- Add new columns for system accounts and account_sequence
|
||||
ALTER TABLE "monitored_addresses" ADD COLUMN "address_type" VARCHAR(20) NOT NULL DEFAULT 'USER';
|
||||
ALTER TABLE "monitored_addresses" ADD COLUMN "account_sequence" BIGINT;
|
||||
ALTER TABLE "monitored_addresses" ADD COLUMN "system_account_type" VARCHAR(50);
|
||||
ALTER TABLE "monitored_addresses" ADD COLUMN "system_account_id" BIGINT;
|
||||
ALTER TABLE "monitored_addresses" ADD COLUMN "region_code" VARCHAR(10);
|
||||
|
||||
-- Make user_id nullable (system accounts don't have user_id)
|
||||
ALTER TABLE "monitored_addresses" ALTER COLUMN "user_id" DROP NOT NULL;
|
||||
|
||||
-- AlterTable: deposit_transactions
|
||||
-- Add new columns for system accounts and account_sequence
|
||||
ALTER TABLE "deposit_transactions" ADD COLUMN "address_type" VARCHAR(20) NOT NULL DEFAULT 'USER';
|
||||
ALTER TABLE "deposit_transactions" ADD COLUMN "account_sequence" BIGINT;
|
||||
ALTER TABLE "deposit_transactions" ADD COLUMN "system_account_type" VARCHAR(50);
|
||||
ALTER TABLE "deposit_transactions" ADD COLUMN "system_account_id" BIGINT;
|
||||
|
||||
-- Make user_id nullable (system account deposits don't have user_id)
|
||||
ALTER TABLE "deposit_transactions" ALTER COLUMN "user_id" DROP NOT NULL;
|
||||
|
||||
-- CreateTable: recovery_mnemonics
|
||||
CREATE TABLE "recovery_mnemonics" (
|
||||
"id" BIGSERIAL NOT NULL,
|
||||
"account_sequence" INTEGER NOT NULL,
|
||||
"public_key" VARCHAR(130) NOT NULL,
|
||||
"encrypted_mnemonic" TEXT NOT NULL,
|
||||
"mnemonic_hash" VARCHAR(64) NOT NULL,
|
||||
"status" VARCHAR(20) NOT NULL DEFAULT 'ACTIVE',
|
||||
"is_backed_up" BOOLEAN NOT NULL DEFAULT false,
|
||||
"revoked_at" TIMESTAMP(3),
|
||||
"revoked_reason" VARCHAR(200),
|
||||
"replaced_by_id" BIGINT,
|
||||
"created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
||||
|
||||
CONSTRAINT "recovery_mnemonics_pkey" PRIMARY KEY ("id")
|
||||
);
|
||||
|
||||
-- =============================================
|
||||
-- CreateIndex: monitored_addresses (new indexes)
|
||||
-- =============================================
|
||||
CREATE INDEX "idx_account_sequence" ON "monitored_addresses"("account_sequence");
|
||||
CREATE INDEX "idx_type_active" ON "monitored_addresses"("address_type", "is_active");
|
||||
CREATE INDEX "idx_system_account_type" ON "monitored_addresses"("system_account_type");
|
||||
|
||||
-- Rename unique constraint to match schema
|
||||
DROP INDEX IF EXISTS "monitored_addresses_chain_type_address_key";
|
||||
CREATE UNIQUE INDEX "uk_chain_address" ON "monitored_addresses"("chain_type", "address");
|
||||
|
||||
-- =============================================
|
||||
-- CreateIndex: deposit_transactions (new indexes)
|
||||
-- =============================================
|
||||
CREATE INDEX "idx_deposit_account" ON "deposit_transactions"("account_sequence");
|
||||
|
||||
-- =============================================
|
||||
-- CreateIndex: recovery_mnemonics
|
||||
-- =============================================
|
||||
CREATE UNIQUE INDEX "uk_account_active_mnemonic" ON "recovery_mnemonics"("account_sequence", "status");
|
||||
CREATE INDEX "idx_recovery_account" ON "recovery_mnemonics"("account_sequence");
|
||||
CREATE INDEX "idx_recovery_public_key" ON "recovery_mnemonics"("public_key");
|
||||
CREATE INDEX "idx_recovery_status" ON "recovery_mnemonics"("status");
|
||||
|
|
@ -12,7 +12,7 @@ datasource db {
|
|||
|
||||
// ============================================
|
||||
// 监控地址表
|
||||
// 存储需要监听充值的地址
|
||||
// 存储需要监听充值的地址（用户地址和系统账户地址）
|
||||
// ============================================
|
||||
model MonitoredAddress {
|
||||
id BigInt @id @default(autoincrement()) @map("address_id")
|
||||
|
|
@ -20,10 +20,17 @@ model MonitoredAddress {
|
|||
chainType String @map("chain_type") @db.VarChar(20) // KAVA, BSC
|
||||
address String @db.VarChar(42) // 0x地址
|
||||
|
||||
// 使用 accountSequence 作为跨服务关联标识 (全局唯一业务ID)
|
||||
accountSequence BigInt @map("account_sequence")
|
||||
// 保留 userId 用于兼容，但主要使用 accountSequence
|
||||
userId BigInt @map("user_id")
|
||||
// 地址类型: USER (用户钱包) 或 SYSTEM (系统账户)
|
||||
addressType String @default("USER") @map("address_type") @db.VarChar(20)
|
||||
|
||||
// 用户地址关联 (addressType = USER 时使用)
|
||||
accountSequence BigInt? @map("account_sequence") // 跨服务关联标识
|
||||
userId BigInt? @map("user_id") // 保留兼容
|
||||
|
||||
// 系统账户关联 (addressType = SYSTEM 时使用)
|
||||
systemAccountType String? @map("system_account_type") @db.VarChar(50) // COST_ACCOUNT, OPERATION_ACCOUNT, etc.
|
||||
systemAccountId BigInt? @map("system_account_id")
|
||||
regionCode String? @map("region_code") @db.VarChar(10) // 省市代码（省市账户用）
|
||||
|
||||
isActive Boolean @default(true) @map("is_active") // 是否激活监听
|
||||
|
||||
|
|
@ -35,7 +42,9 @@ model MonitoredAddress {
|
|||
@@unique([chainType, address], name: "uk_chain_address")
|
||||
@@index([accountSequence], name: "idx_account_sequence")
|
||||
@@index([userId], name: "idx_user")
|
||||
@@index([addressType, isActive], name: "idx_type_active")
|
||||
@@index([chainType, isActive], name: "idx_chain_active")
|
||||
@@index([systemAccountType], name: "idx_system_account_type")
|
||||
@@map("monitored_addresses")
|
||||
}
|
||||
|
||||
|
|
@ -66,8 +75,15 @@ model DepositTransaction {
|
|||
|
||||
// 关联 - 使用 accountSequence 作为跨服务主键
|
||||
addressId BigInt @map("address_id")
|
||||
accountSequence BigInt @map("account_sequence") // 跨服务关联标识
|
||||
userId BigInt @map("user_id") // 保留兼容
|
||||
addressType String @default("USER") @map("address_type") @db.VarChar(20) // USER 或 SYSTEM
|
||||
|
||||
// 用户地址关联
|
||||
accountSequence BigInt? @map("account_sequence") // 跨服务关联标识
|
||||
userId BigInt? @map("user_id") // 保留兼容
|
||||
|
||||
// 系统账户关联（当 addressType = SYSTEM 时）
|
||||
systemAccountType String? @map("system_account_type") @db.VarChar(50)
|
||||
systemAccountId BigInt? @map("system_account_id")
|
||||
|
||||
// 通知状态
|
||||
notifiedAt DateTime? @map("notified_at")
|
||||
|
|
|
|||
|
|
@ -0,0 +1,134 @@
|
|||
/**
|
||||
* Deploy TestUSDT to KAVA Testnet using inline Solidity compilation
|
||||
*/
|
||||
import { ethers } from 'ethers';
|
||||
// eslint-disable-next-line @typescript-eslint/no-var-requires
|
||||
const solc = require('solc');
|
||||
|
||||
const KAVA_TESTNET_RPC = 'https://evm.testnet.kava.io';
|
||||
const KAVA_TESTNET_CHAIN_ID = 2221;
|
||||
const privateKey = '0xd42a6e6021ebd884f3f179d3793a32e97b9f1001db6ff44441ec455d748b9aa6';
|
||||
|
||||
const sourceCode = `
|
||||
// SPDX-License-Identifier: MIT
|
||||
pragma solidity 0.8.17;
|
||||
|
||||
contract TestUSDT {
|
||||
string public constant name = "Test USDT";
|
||||
string public constant symbol = "USDT";
|
||||
uint8 public constant decimals = 6;
|
||||
uint256 public totalSupply;
|
||||
mapping(address => uint256) public balanceOf;
|
||||
mapping(address => mapping(address => uint256)) public allowance;
|
||||
|
||||
event Transfer(address indexed from, address indexed to, uint256 value);
|
||||
event Approval(address indexed owner, address indexed spender, uint256 value);
|
||||
|
||||
constructor() {
|
||||
_mint(msg.sender, 1000000 * 1e6);
|
||||
}
|
||||
|
||||
function _mint(address to, uint256 amount) internal {
|
||||
totalSupply += amount;
|
||||
balanceOf[to] += amount;
|
||||
emit Transfer(address(0), to, amount);
|
||||
}
|
||||
|
||||
function transfer(address to, uint256 amount) public returns (bool) {
|
||||
balanceOf[msg.sender] -= amount;
|
||||
balanceOf[to] += amount;
|
||||
emit Transfer(msg.sender, to, amount);
|
||||
return true;
|
||||
}
|
||||
|
||||
function approve(address spender, uint256 amount) public returns (bool) {
|
||||
allowance[msg.sender][spender] = amount;
|
||||
emit Approval(msg.sender, spender, amount);
|
||||
return true;
|
||||
}
|
||||
|
||||
function transferFrom(address from, address to, uint256 amount) public returns (bool) {
|
||||
allowance[from][msg.sender] -= amount;
|
||||
balanceOf[from] -= amount;
|
||||
balanceOf[to] += amount;
|
||||
emit Transfer(from, to, amount);
|
||||
return true;
|
||||
}
|
||||
|
||||
function mint(uint256 amount) external {
|
||||
_mint(msg.sender, amount);
|
||||
}
|
||||
|
||||
function faucet() external {
|
||||
_mint(msg.sender, 10000 * 1e6);
|
||||
}
|
||||
}
|
||||
`;
|
||||
|
||||
async function deploy() {
|
||||
console.log('🔨 Compiling contract...');
|
||||
|
||||
const input = {
|
||||
language: 'Solidity',
|
||||
sources: { 'TestUSDT.sol': { content: sourceCode } },
|
||||
settings: { outputSelection: { '*': { '*': ['abi', 'evm.bytecode'] } } },
|
||||
};
|
||||
|
||||
const output = JSON.parse(solc.compile(JSON.stringify(input)));
|
||||
|
||||
if (output.errors) {
|
||||
const errors = output.errors.filter((e: any) => e.severity === 'error');
|
||||
if (errors.length > 0) {
|
||||
console.error('❌ Compilation errors:', errors);
|
||||
process.exit(1);
|
||||
}
|
||||
}
|
||||
|
||||
const contract = output.contracts['TestUSDT.sol']['TestUSDT'];
|
||||
const bytecode = contract.evm.bytecode.object;
|
||||
const compiledAbi = contract.abi;
|
||||
|
||||
console.log('🌐 Connecting to KAVA Testnet...');
|
||||
const provider = new ethers.JsonRpcProvider(KAVA_TESTNET_RPC, {
|
||||
chainId: KAVA_TESTNET_CHAIN_ID,
|
||||
name: 'kava-testnet',
|
||||
});
|
||||
|
||||
const wallet = new ethers.Wallet(privateKey, provider);
|
||||
console.log(`📍 Deployer: ${wallet.address}`);
|
||||
|
||||
const balance = await provider.getBalance(wallet.address);
|
||||
console.log(`💰 Balance: ${ethers.formatEther(balance)} TKAVA`);
|
||||
|
||||
if (balance < ethers.parseEther('0.01')) {
|
||||
console.error('❌ Insufficient TKAVA');
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
console.log('📦 Deploying...');
|
||||
const factory = new ethers.ContractFactory(compiledAbi, bytecode, wallet);
|
||||
const deployedContract = await factory.deploy({
|
||||
gasLimit: 5000000,
|
||||
});
|
||||
|
||||
console.log(`⏳ Waiting for confirmation...`);
|
||||
console.log(` TX: https://testnet.kavascan.com/tx/${deployedContract.deploymentTransaction()?.hash}`);
|
||||
|
||||
await deployedContract.waitForDeployment();
|
||||
|
||||
const address = await deployedContract.getAddress();
|
||||
console.log('');
|
||||
console.log('='.repeat(60));
|
||||
console.log(`✅ SUCCESS! TestUSDT deployed on KAVA Testnet`);
|
||||
console.log(`📋 Contract Address: ${address}`);
|
||||
console.log('='.repeat(60));
|
||||
console.log('');
|
||||
console.log(`🔗 KavaScan: https://testnet.kavascan.com/address/${address}`);
|
||||
console.log('');
|
||||
console.log('Next: Update KAVA_USDT_CONTRACT in .env');
|
||||
}
|
||||
|
||||
deploy().catch((e) => {
|
||||
console.error('❌ Error:', e.message);
|
||||
process.exit(1);
|
||||
});
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
|
|
@ -0,0 +1,26 @@
|
|||
/**
|
||||
* Generate a new wallet for BSC Testnet deployment
|
||||
*
|
||||
* Usage: npx ts-node scripts/generate-wallet.ts
|
||||
*/
|
||||
|
||||
import { ethers } from 'ethers';
|
||||
|
||||
const wallet = ethers.Wallet.createRandom();
|
||||
|
||||
console.log(`
|
||||
🔐 New Wallet Generated for BSC Testnet
|
||||
========================================
|
||||
|
||||
Address: ${wallet.address}
|
||||
Private Key: ${wallet.privateKey}
|
||||
Mnemonic: ${wallet.mnemonic?.phrase}
|
||||
|
||||
Next steps:
|
||||
1. Go to https://www.bnbchain.org/en/testnet-faucet
|
||||
2. Paste your address: ${wallet.address}
|
||||
3. Get 0.1 tBNB
|
||||
4. Run: npx ts-node scripts/deploy-test-usdt.ts ${wallet.privateKey}
|
||||
|
||||
⚠️ SAVE YOUR PRIVATE KEY! You'll need it for future contract interactions.
|
||||
`);
|
||||
|
|
@ -7,7 +7,7 @@ import {
|
|||
BalanceQueryService,
|
||||
MnemonicVerificationService,
|
||||
} from './services';
|
||||
import { MpcKeygenCompletedHandler } from './event-handlers';
|
||||
import { MpcKeygenCompletedHandler, WithdrawalRequestedHandler } from './event-handlers';
|
||||
|
||||
@Module({
|
||||
imports: [InfrastructureModule, DomainModule],
|
||||
|
|
@ -20,6 +20,7 @@ import { MpcKeygenCompletedHandler } from './event-handlers';
|
|||
|
||||
// 事件处理器
|
||||
MpcKeygenCompletedHandler,
|
||||
WithdrawalRequestedHandler,
|
||||
],
|
||||
exports: [
|
||||
AddressDerivationService,
|
||||
|
|
@ -27,6 +28,7 @@ import { MpcKeygenCompletedHandler } from './event-handlers';
|
|||
BalanceQueryService,
|
||||
MnemonicVerificationService,
|
||||
MpcKeygenCompletedHandler,
|
||||
WithdrawalRequestedHandler,
|
||||
],
|
||||
})
|
||||
export class ApplicationModule {}
|
||||
|
|
|
|||
|
|
@ -1 +1,2 @@
|
|||
export * from './mpc-keygen-completed.handler';
|
||||
export * from './withdrawal-requested.handler';
|
||||
|
|
|
|||
|
|
@ -0,0 +1,120 @@
|
|||
import { Injectable, Logger, OnModuleInit } from '@nestjs/common';
|
||||
import {
|
||||
WithdrawalEventConsumerService,
|
||||
WithdrawalRequestedPayload,
|
||||
} from '@/infrastructure/kafka/withdrawal-event-consumer.service';
|
||||
import { EventPublisherService } from '@/infrastructure/kafka/event-publisher.service';
|
||||
|
||||
/**
|
||||
* Withdrawal Requested Event Handler
|
||||
*
|
||||
* Handles withdrawal requests from wallet-service.
|
||||
* For now, logs the event and publishes a status update.
|
||||
*
|
||||
* Future implementation will:
|
||||
* 1. Create TransactionRequest record
|
||||
* 2. Request MPC signing
|
||||
* 3. Broadcast to blockchain
|
||||
* 4. Monitor confirmation
|
||||
*/
|
||||
@Injectable()
|
||||
export class WithdrawalRequestedHandler implements OnModuleInit {
|
||||
private readonly logger = new Logger(WithdrawalRequestedHandler.name);
|
||||
|
||||
constructor(
|
||||
private readonly withdrawalEventConsumer: WithdrawalEventConsumerService,
|
||||
private readonly eventPublisher: EventPublisherService,
|
||||
) {}
|
||||
|
||||
onModuleInit() {
|
||||
this.withdrawalEventConsumer.onWithdrawalRequested(
|
||||
this.handleWithdrawalRequested.bind(this),
|
||||
);
|
||||
this.logger.log(`[INIT] WithdrawalRequestedHandler registered`);
|
||||
}
|
||||
|
||||
/**
|
||||
* Handle withdrawal requested event from wallet-service
|
||||
*
|
||||
* Current implementation: Log and acknowledge
|
||||
* TODO: Implement full blockchain transaction flow
|
||||
*/
|
||||
private async handleWithdrawalRequested(
|
||||
payload: WithdrawalRequestedPayload,
|
||||
): Promise<void> {
|
||||
this.logger.log(`[HANDLE] Received WithdrawalRequested event`);
|
||||
this.logger.log(`[HANDLE] orderNo: ${payload.orderNo}`);
|
||||
this.logger.log(`[HANDLE] accountSequence: ${payload.accountSequence}`);
|
||||
this.logger.log(`[HANDLE] userId: ${payload.userId}`);
|
||||
this.logger.log(`[HANDLE] chainType: ${payload.chainType}`);
|
||||
this.logger.log(`[HANDLE] toAddress: ${payload.toAddress}`);
|
||||
this.logger.log(`[HANDLE] amount: ${payload.amount}`);
|
||||
this.logger.log(`[HANDLE] fee: ${payload.fee}`);
|
||||
this.logger.log(`[HANDLE] netAmount: ${payload.netAmount}`);
|
||||
|
||||
try {
|
||||
// TODO: Full implementation steps:
|
||||
// 1. Validate the withdrawal request
|
||||
// 2. Get system hot wallet address for the chain
|
||||
// 3. Create TransactionRequest record
|
||||
// 4. Request MPC signing
|
||||
// 5. After signed, broadcast to blockchain
|
||||
// 6. Monitor for confirmation
|
||||
// 7. Publish status updates back to wallet-service
|
||||
|
||||
// For now, just log that we received it
|
||||
this.logger.log(
|
||||
`[PROCESS] Withdrawal ${payload.orderNo} received for processing`,
|
||||
);
|
||||
this.logger.log(
|
||||
`[PROCESS] Chain: ${payload.chainType}, To: ${payload.toAddress}, Amount: ${payload.netAmount} USDT`,
|
||||
);
|
||||
|
||||
// Publish acknowledgment event (wallet-service can listen for status updates)
|
||||
await this.eventPublisher.publish({
|
||||
eventType: 'blockchain.withdrawal.received',
|
||||
toPayload: () => ({
|
||||
orderNo: payload.orderNo,
|
||||
accountSequence: payload.accountSequence,
|
||||
status: 'RECEIVED',
|
||||
message: 'Withdrawal request received by blockchain-service',
|
||||
}),
|
||||
eventId: `wd-received-${payload.orderNo}-${Date.now()}`,
|
||||
occurredAt: new Date(),
|
||||
});
|
||||
|
||||
this.logger.log(
|
||||
`[COMPLETE] Withdrawal ${payload.orderNo} acknowledged`,
|
||||
);
|
||||
|
||||
// NOTE: Actual blockchain transaction implementation would go here
|
||||
// This would involve:
|
||||
// - Creating a TransactionRequest aggregate
|
||||
// - Calling MPC service for signing
|
||||
// - Broadcasting the signed transaction
|
||||
// - Monitoring for confirmations
|
||||
// - Publishing final status (CONFIRMED or FAILED)
|
||||
|
||||
} catch (error) {
|
||||
this.logger.error(
|
||||
`[ERROR] Failed to process withdrawal ${payload.orderNo}`,
|
||||
error,
|
||||
);
|
||||
|
||||
// Publish failure event
|
||||
await this.eventPublisher.publish({
|
||||
eventType: 'blockchain.withdrawal.failed',
|
||||
toPayload: () => ({
|
||||
orderNo: payload.orderNo,
|
||||
accountSequence: payload.accountSequence,
|
||||
status: 'FAILED',
|
||||
error: error instanceof Error ? error.message : 'Unknown error',
|
||||
}),
|
||||
eventId: `wd-failed-${payload.orderNo}-${Date.now()}`,
|
||||
occurredAt: new Date(),
|
||||
});
|
||||
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -34,20 +34,20 @@ export interface DeriveAddressResult {
|
|||
* 处理从 MPC 公钥派生钱包地址的业务逻辑
|
||||
*
|
||||
* 派生策略：
|
||||
* - KAVA: Cosmos bech32 格式 (kava1...)
|
||||
* - KAVA: EVM 格式 (0x...) - Kava EVM 兼容链
|
||||
* - DST: Cosmos bech32 格式 (dst1...)
|
||||
* - BSC: EVM 格式 (0x...)
|
||||
*
|
||||
* 监控策略：
|
||||
* - 只有 EVM 链 (BSC) 的地址会被注册到监控列表用于充值检测
|
||||
* - Cosmos 链 (KAVA, DST) 需要不同的监控机制
|
||||
* - EVM 链 (BSC, KAVA) 的地址会被注册到监控列表用于充值检测
|
||||
* - Cosmos 链 (DST) 需要不同的监控机制
|
||||
*/
|
||||
@Injectable()
|
||||
export class AddressDerivationService {
|
||||
private readonly logger = new Logger(AddressDerivationService.name);
|
||||
|
||||
// EVM 链类型列表，用于判断是否需要注册监控
|
||||
private readonly evmChains = new Set([ChainTypeEnum.BSC]);
|
||||
private readonly evmChains = new Set([ChainTypeEnum.BSC, ChainTypeEnum.KAVA]);
|
||||
|
||||
constructor(
|
||||
private readonly addressDerivation: AddressDerivationAdapter,
|
||||
|
|
|
|||
|
|
@ -125,7 +125,7 @@ export class DepositDetectionService implements OnModuleInit {
|
|||
|
||||
const chainType = ChainType.fromEnum(event.chainType);
|
||||
|
||||
// 查找监控地址以获取用户ID
|
||||
// 查找监控地址以获取用户ID或系统账户信息
|
||||
const monitoredAddress = await this.monitoredAddressRepo.findByChainAndAddress(
|
||||
chainType,
|
||||
EvmAddress.fromUnchecked(event.to),
|
||||
|
|
@ -136,7 +136,7 @@ export class DepositDetectionService implements OnModuleInit {
|
|||
return;
|
||||
}
|
||||
|
||||
// 创建充值记录 - 使用 accountSequence 作为跨服务关联键
|
||||
// 创建充值记录 - 用户地址
|
||||
const deposit = DepositTransaction.create({
|
||||
chainType,
|
||||
txHash,
|
||||
|
|
@ -162,7 +162,7 @@ export class DepositDetectionService implements OnModuleInit {
|
|||
deposit.clearDomainEvents();
|
||||
|
||||
this.logger.log(
|
||||
`New deposit saved: ${txHash.toShort()} -> ${event.to} (${deposit.amount.formatted} USDT)`,
|
||||
`User deposit saved: ${txHash.toShort()} -> ${event.to} (${deposit.amount.formatted} USDT)`,
|
||||
);
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -31,8 +31,8 @@ export default registerAs('blockchain', () => {
|
|||
// KAVA Testnet
|
||||
rpcUrl: process.env.KAVA_RPC_URL || 'https://evm.testnet.kava.io',
|
||||
chainId: parseInt(process.env.KAVA_CHAIN_ID || '2221', 10),
|
||||
// 测试网 USDT 合约 (需要部署或使用已有的)
|
||||
usdtContract: process.env.KAVA_USDT_CONTRACT || '0x0000000000000000000000000000000000000000',
|
||||
// 测试网 USDT 合约 (自定义部署的 TestUSDT)
|
||||
usdtContract: process.env.KAVA_USDT_CONTRACT || '0xc12f6A4A7Fd0965085B044A67a39CcA2ff7fe0dF',
|
||||
confirmations: parseInt(process.env.KAVA_CONFIRMATIONS || '3', 10),
|
||||
}
|
||||
: {
|
||||
|
|
|
|||
|
|
@ -147,13 +147,12 @@ export class AddressDerivationAdapter {
|
|||
const evmAddress = this.deriveEvmAddress(compressedPublicKey);
|
||||
this.logger.log(`[DERIVE] EVM address derived: ${evmAddress}`);
|
||||
|
||||
// KAVA (Cosmos bech32 格式 - kava1...)
|
||||
const kavaAddress = this.deriveCosmosAddress(compressedPublicKey, 'kava');
|
||||
// KAVA (EVM 格式 - 0x...) - Kava EVM 兼容链
|
||||
addresses.push({
|
||||
chainType: ChainTypeEnum.KAVA,
|
||||
address: kavaAddress,
|
||||
address: evmAddress,
|
||||
});
|
||||
this.logger.log(`[DERIVE] KAVA address (Cosmos): ${kavaAddress}`);
|
||||
this.logger.log(`[DERIVE] KAVA address (EVM): ${evmAddress}`);
|
||||
|
||||
// DST (Cosmos bech32 格式 - dst1...)
|
||||
const dstAddress = this.deriveCosmosAddress(compressedPublicKey, 'dst');
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
import { Global, Module } from '@nestjs/common';
|
||||
import { PrismaService } from './persistence/prisma/prisma.service';
|
||||
import { RedisService, AddressCacheService } from './redis';
|
||||
import { EventPublisherService, MpcEventConsumerService } from './kafka';
|
||||
import { EventPublisherService, MpcEventConsumerService, WithdrawalEventConsumerService } from './kafka';
|
||||
import { EvmProviderAdapter, AddressDerivationAdapter, MnemonicDerivationAdapter, RecoveryMnemonicAdapter, BlockScannerService } from './blockchain';
|
||||
import { DomainModule } from '@/domain/domain.module';
|
||||
import {
|
||||
|
|
@ -26,6 +26,7 @@ import {
|
|||
RedisService,
|
||||
EventPublisherService,
|
||||
MpcEventConsumerService,
|
||||
WithdrawalEventConsumerService,
|
||||
|
||||
// 区块链适配器
|
||||
EvmProviderAdapter,
|
||||
|
|
@ -60,6 +61,7 @@ import {
|
|||
RedisService,
|
||||
EventPublisherService,
|
||||
MpcEventConsumerService,
|
||||
WithdrawalEventConsumerService,
|
||||
EvmProviderAdapter,
|
||||
AddressDerivationAdapter,
|
||||
MnemonicDerivationAdapter,
|
||||
|
|
|
|||
|
|
@ -1,3 +1,4 @@
|
|||
export * from './event-publisher.service';
|
||||
export * from './event-consumer.controller';
|
||||
export * from './mpc-event-consumer.service';
|
||||
export * from './withdrawal-event-consumer.service';
|
||||
|
|
|
|||
|
|
@ -0,0 +1,147 @@
|
|||
/**
|
||||
* Withdrawal Event Consumer Service for Blockchain Service
|
||||
*
|
||||
* Consumes withdrawal request events from wallet-service via Kafka.
|
||||
* Creates transaction requests for MPC signing and blockchain broadcasting.
|
||||
*/
|
||||
|
||||
import { Injectable, Logger, OnModuleInit, OnModuleDestroy } from '@nestjs/common';
|
||||
import { ConfigService } from '@nestjs/config';
|
||||
import { Kafka, Consumer, logLevel, EachMessagePayload } from 'kafkajs';
|
||||
|
||||
export const WITHDRAWAL_TOPICS = {
|
||||
WITHDRAWAL_REQUESTED: 'wallet.withdrawals',
|
||||
} as const;
|
||||
|
||||
export interface WithdrawalRequestedPayload {
|
||||
orderNo: string;
|
||||
accountSequence: string;
|
||||
userId: string;
|
||||
walletId: string;
|
||||
amount: string;
|
||||
fee: string;
|
||||
netAmount: string;
|
||||
assetType: string;
|
||||
chainType: string;
|
||||
toAddress: string;
|
||||
}
|
||||
|
||||
export type WithdrawalEventHandler = (payload: WithdrawalRequestedPayload) => Promise<void>;
|
||||
|
||||
@Injectable()
|
||||
export class WithdrawalEventConsumerService implements OnModuleInit, OnModuleDestroy {
|
||||
private readonly logger = new Logger(WithdrawalEventConsumerService.name);
|
||||
private kafka: Kafka;
|
||||
private consumer: Consumer;
|
||||
private isConnected = false;
|
||||
|
||||
private withdrawalRequestedHandler?: WithdrawalEventHandler;
|
||||
|
||||
constructor(private readonly configService: ConfigService) {}
|
||||
|
||||
async onModuleInit() {
|
||||
const brokers = this.configService.get<string>('KAFKA_BROKERS')?.split(',') || ['localhost:9092'];
|
||||
const clientId = this.configService.get<string>('KAFKA_CLIENT_ID') || 'blockchain-service';
|
||||
const groupId = 'blockchain-service-withdrawal-events';
|
||||
|
||||
this.logger.log(`[INIT] Withdrawal Event Consumer initializing...`);
|
||||
this.logger.log(`[INIT] ClientId: ${clientId}`);
|
||||
this.logger.log(`[INIT] GroupId: ${groupId}`);
|
||||
this.logger.log(`[INIT] Brokers: ${brokers.join(', ')}`);
|
||||
this.logger.log(`[INIT] Topics: ${Object.values(WITHDRAWAL_TOPICS).join(', ')}`);
|
||||
|
||||
this.kafka = new Kafka({
|
||||
clientId,
|
||||
brokers,
|
||||
logLevel: logLevel.WARN,
|
||||
retry: {
|
||||
initialRetryTime: 100,
|
||||
retries: 8,
|
||||
},
|
||||
});
|
||||
|
||||
this.consumer = this.kafka.consumer({
|
||||
groupId,
|
||||
sessionTimeout: 30000,
|
||||
heartbeatInterval: 3000,
|
||||
});
|
||||
|
||||
try {
|
||||
this.logger.log(`[CONNECT] Connecting Withdrawal Event consumer...`);
|
||||
await this.consumer.connect();
|
||||
this.isConnected = true;
|
||||
this.logger.log(`[CONNECT] Withdrawal Event consumer connected successfully`);
|
||||
|
||||
await this.consumer.subscribe({
|
||||
topics: Object.values(WITHDRAWAL_TOPICS),
|
||||
fromBeginning: false,
|
||||
});
|
||||
this.logger.log(`[SUBSCRIBE] Subscribed to withdrawal topics`);
|
||||
|
||||
await this.startConsuming();
|
||||
} catch (error) {
|
||||
this.logger.error(`[ERROR] Failed to connect Withdrawal Event consumer`, error);
|
||||
}
|
||||
}
|
||||
|
||||
async onModuleDestroy() {
|
||||
if (this.isConnected) {
|
||||
await this.consumer.disconnect();
|
||||
this.logger.log('Withdrawal Event consumer disconnected');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Register handler for withdrawal requested events
|
||||
*/
|
||||
onWithdrawalRequested(handler: WithdrawalEventHandler): void {
|
||||
this.withdrawalRequestedHandler = handler;
|
||||
this.logger.log(`[REGISTER] WithdrawalRequested handler registered`);
|
||||
}
|
||||
|
||||
private async startConsuming(): Promise<void> {
|
||||
await this.consumer.run({
|
||||
eachMessage: async ({ topic, partition, message }: EachMessagePayload) => {
|
||||
const offset = message.offset;
|
||||
this.logger.log(`[RECEIVE] Message received: topic=${topic}, partition=${partition}, offset=${offset}`);
|
||||
|
||||
try {
|
||||
const value = message.value?.toString();
|
||||
if (!value) {
|
||||
this.logger.warn(`[RECEIVE] Empty message received on ${topic}`);
|
||||
return;
|
||||
}
|
||||
|
||||
this.logger.log(`[RECEIVE] Raw message: ${value.substring(0, 500)}...`);
|
||||
|
||||
const parsed = JSON.parse(value);
|
||||
const eventType = parsed.eventType;
|
||||
const payload = parsed.payload || parsed;
|
||||
|
||||
this.logger.log(`[RECEIVE] Event type: ${eventType}`);
|
||||
|
||||
if (eventType === 'wallet.withdrawal.requested') {
|
||||
this.logger.log(`[HANDLE] Processing WithdrawalRequested event`);
|
||||
this.logger.log(`[HANDLE] orderNo: ${payload.orderNo}`);
|
||||
this.logger.log(`[HANDLE] chainType: ${payload.chainType}`);
|
||||
this.logger.log(`[HANDLE] toAddress: ${payload.toAddress}`);
|
||||
this.logger.log(`[HANDLE] amount: ${payload.amount}`);
|
||||
|
||||
if (this.withdrawalRequestedHandler) {
|
||||
await this.withdrawalRequestedHandler(payload as WithdrawalRequestedPayload);
|
||||
this.logger.log(`[HANDLE] WithdrawalRequested handler completed`);
|
||||
} else {
|
||||
this.logger.warn(`[HANDLE] No handler registered for WithdrawalRequested`);
|
||||
}
|
||||
} else {
|
||||
this.logger.warn(`[RECEIVE] Unknown event type: ${eventType}`);
|
||||
}
|
||||
} catch (error) {
|
||||
this.logger.error(`[ERROR] Error processing withdrawal event from ${topic}`, error);
|
||||
}
|
||||
},
|
||||
});
|
||||
|
||||
this.logger.log(`[START] Started consuming withdrawal events`);
|
||||
}
|
||||
}
|
||||
|
|
@ -7,7 +7,16 @@ import { ChainType, TxHash, EvmAddress, TokenAmount, BlockNumber } from '@/domai
|
|||
import { DepositStatus } from '@/domain/enums';
|
||||
|
||||
export class DepositTransactionMapper {
|
||||
/**
|
||||
* Map from Prisma to Domain (only for USER deposits)
|
||||
* System account deposits are handled separately
|
||||
*/
|
||||
static toDomain(prisma: PrismaDepositTransaction): DepositTransaction {
|
||||
// For USER deposits, accountSequence and userId must exist
|
||||
if (!prisma.accountSequence || !prisma.userId) {
|
||||
throw new Error(`DepositTransaction ${prisma.id} missing accountSequence or userId`);
|
||||
}
|
||||
|
||||
const props: DepositTransactionProps = {
|
||||
id: prisma.id,
|
||||
chainType: ChainType.create(prisma.chainType),
|
||||
|
|
@ -52,8 +61,11 @@ export class DepositTransactionMapper {
|
|||
confirmations: domain.confirmations,
|
||||
status: domain.status,
|
||||
addressId: domain.addressId,
|
||||
addressType: 'USER',
|
||||
accountSequence: domain.accountSequence,
|
||||
userId: domain.userId,
|
||||
systemAccountType: null,
|
||||
systemAccountId: null,
|
||||
notifiedAt: domain.notifiedAt ?? null,
|
||||
notifyAttempts: domain.notifyAttempts,
|
||||
lastNotifyError: domain.lastNotifyError ?? null,
|
||||
|
|
|
|||
|
|
@ -3,7 +3,16 @@ import { MonitoredAddress, MonitoredAddressProps } from '@/domain/aggregates/mon
|
|||
import { ChainType, EvmAddress } from '@/domain/value-objects';
|
||||
|
||||
export class MonitoredAddressMapper {
|
||||
/**
|
||||
* Map from Prisma to Domain (only for USER addresses)
|
||||
* System addresses are handled separately
|
||||
*/
|
||||
static toDomain(prisma: PrismaMonitoredAddress): MonitoredAddress {
|
||||
// For USER addresses, accountSequence and userId must exist
|
||||
if (!prisma.accountSequence || !prisma.userId) {
|
||||
throw new Error(`MonitoredAddress ${prisma.id} missing accountSequence or userId`);
|
||||
}
|
||||
|
||||
const props: MonitoredAddressProps = {
|
||||
id: prisma.id,
|
||||
chainType: ChainType.create(prisma.chainType),
|
||||
|
|
@ -25,8 +34,12 @@ export class MonitoredAddressMapper {
|
|||
id: domain.id,
|
||||
chainType: domain.chainType.toString(),
|
||||
address: domain.address.lowercase,
|
||||
addressType: 'USER',
|
||||
accountSequence: domain.accountSequence,
|
||||
userId: domain.userId,
|
||||
systemAccountType: null,
|
||||
systemAccountId: null,
|
||||
regionCode: null,
|
||||
isActive: domain.isActive,
|
||||
};
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue