mirror of
https://github.com/Such-Software/wownerogue.git
synced 2026-10-17 22:31:26 +02:00
243 lines
8.7 KiB
JavaScript
Executable File
243 lines
8.7 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
/**
|
|
* splitOutputs.js — Split wallet outputs for concurrent payout capacity.
|
|
*
|
|
* Wownero/Monero lock change outputs for several blocks after spending.
|
|
* Pre-splitting one large output into many smaller ones allows the wallet
|
|
* to handle multiple concurrent payouts without "not enough unlocked balance".
|
|
*
|
|
* Usage:
|
|
* node scripts/splitOutputs.js [options]
|
|
*
|
|
* Options:
|
|
* --amount <WOW> Target output size in WOW (default: 10)
|
|
* --count <N> Number of outputs to create (default: 20)
|
|
* --dry-run Show what would happen without sending
|
|
* --endpoint <url> Wallet RPC endpoint (overrides PRIMARY_WALLET_ENDPOINT)
|
|
*/
|
|
|
|
const path = require('path');
|
|
const fs = require('fs');
|
|
const http = require('http');
|
|
|
|
// Parse .env manually — no external dependencies needed
|
|
function loadEnv() {
|
|
const envPath = path.resolve(__dirname, '..', 'src', '.env');
|
|
try {
|
|
const lines = fs.readFileSync(envPath, 'utf8').split('\n');
|
|
for (const line of lines) {
|
|
const trimmed = line.trim();
|
|
if (!trimmed || trimmed.startsWith('#')) continue;
|
|
const eq = trimmed.indexOf('=');
|
|
if (eq === -1) continue;
|
|
const key = trimmed.substring(0, eq).trim();
|
|
const val = trimmed.substring(eq + 1).trim().replace(/^['"]|['"]$/g, '');
|
|
if (!process.env[key]) process.env[key] = val;
|
|
}
|
|
} catch (e) {
|
|
// .env not found — that's fine, user can pass --endpoint
|
|
}
|
|
}
|
|
loadEnv();
|
|
|
|
const ATOMIC_DIVISOR = 1e11; // Wownero: 11 decimal places
|
|
|
|
function parseArgs() {
|
|
const args = process.argv.slice(2);
|
|
const opts = {
|
|
amount: 10,
|
|
count: 20,
|
|
dryRun: false,
|
|
endpoint: process.env.PRIMARY_WALLET_ENDPOINT || 'http://127.0.0.1:34570'
|
|
};
|
|
|
|
for (let i = 0; i < args.length; i++) {
|
|
switch (args[i]) {
|
|
case '--amount':
|
|
opts.amount = parseFloat(args[++i]);
|
|
if (!opts.amount || opts.amount <= 0) {
|
|
console.error('Error: --amount must be a positive number');
|
|
process.exit(1);
|
|
}
|
|
break;
|
|
case '--count':
|
|
opts.count = parseInt(args[++i], 10);
|
|
if (!opts.count || opts.count <= 0) {
|
|
console.error('Error: --count must be a positive integer');
|
|
process.exit(1);
|
|
}
|
|
break;
|
|
case '--dry-run':
|
|
opts.dryRun = true;
|
|
break;
|
|
case '--endpoint':
|
|
opts.endpoint = args[++i];
|
|
break;
|
|
case '--help':
|
|
case '-h':
|
|
console.log(`
|
|
splitOutputs.js — Split wallet outputs for concurrent payout capacity.
|
|
|
|
Usage: node scripts/splitOutputs.js [options]
|
|
|
|
Options:
|
|
--amount <WOW> Target output size in WOW (default: 10)
|
|
--count <N> Number of outputs to create (default: 20)
|
|
--dry-run Show what would happen without sending
|
|
--endpoint <url> Wallet RPC endpoint (default: PRIMARY_WALLET_ENDPOINT env)
|
|
--help Show this help message
|
|
|
|
Example:
|
|
node scripts/splitOutputs.js --amount 10 --count 30
|
|
Creates 30 outputs of 10 WOW each (requires 300+ WOW unlocked balance).
|
|
`);
|
|
process.exit(0);
|
|
break;
|
|
default:
|
|
console.error(`Unknown option: ${args[i]}`);
|
|
process.exit(1);
|
|
}
|
|
}
|
|
|
|
return opts;
|
|
}
|
|
|
|
function rpcCall(endpoint, method, params = {}) {
|
|
return new Promise((resolve, reject) => {
|
|
const body = JSON.stringify({ jsonrpc: '2.0', id: '0', method, params });
|
|
const parsed = new URL(`${endpoint}/json_rpc`);
|
|
const options = {
|
|
hostname: parsed.hostname,
|
|
port: parsed.port,
|
|
path: parsed.pathname,
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(body) }
|
|
};
|
|
|
|
const req = http.request(options, (res) => {
|
|
let data = '';
|
|
res.on('data', chunk => { data += chunk; });
|
|
res.on('end', () => {
|
|
try {
|
|
const json = JSON.parse(data);
|
|
if (json.error) {
|
|
reject(new Error(`RPC error (${method}): ${json.error.message}`));
|
|
} else {
|
|
resolve(json);
|
|
}
|
|
} catch (e) {
|
|
reject(new Error(`Invalid JSON response from ${method}: ${data.substring(0, 200)}`));
|
|
}
|
|
});
|
|
});
|
|
req.on('error', (err) => reject(new Error(`RPC connection error (${method}): ${err.message}`)));
|
|
req.write(body);
|
|
req.end();
|
|
});
|
|
}
|
|
|
|
async function main() {
|
|
const opts = parseArgs();
|
|
const amountAtomic = Math.round(opts.amount * ATOMIC_DIVISOR);
|
|
const totalNeeded = amountAtomic * opts.count;
|
|
|
|
console.log('=== Wownero Output Splitter ===');
|
|
console.log(`Endpoint: ${opts.endpoint}`);
|
|
console.log(`Output size: ${opts.amount} WOW (${amountAtomic} atomic)`);
|
|
console.log(`Count: ${opts.count} outputs`);
|
|
console.log(`Total: ${(totalNeeded / ATOMIC_DIVISOR).toFixed(4)} WOW (+ fees)`);
|
|
if (opts.dryRun) console.log('Mode: DRY RUN');
|
|
console.log('');
|
|
|
|
// Step 1: Get wallet address
|
|
let ownAddress;
|
|
try {
|
|
const addrResp = await rpcCall(opts.endpoint, 'get_address', {
|
|
account_index: 0,
|
|
address_index: [0]
|
|
});
|
|
ownAddress = addrResp.result.address;
|
|
console.log(`Wallet: ${ownAddress.substring(0, 12)}...${ownAddress.substring(ownAddress.length - 6)}`);
|
|
} catch (err) {
|
|
console.error(`Failed to get wallet address: ${err.message}`);
|
|
console.error('Make sure wownero-wallet-rpc is running on', opts.endpoint);
|
|
process.exit(1);
|
|
}
|
|
|
|
// Step 2: Check balance
|
|
let balance;
|
|
try {
|
|
const balResp = await rpcCall(opts.endpoint, 'get_balance', { account_index: 0 });
|
|
balance = balResp.result;
|
|
console.log(`Balance: ${(balance.balance / ATOMIC_DIVISOR).toFixed(4)} WOW`);
|
|
console.log(`Unlocked: ${(balance.unlocked_balance / ATOMIC_DIVISOR).toFixed(4)} WOW`);
|
|
console.log('');
|
|
} catch (err) {
|
|
console.error(`Failed to get balance: ${err.message}`);
|
|
process.exit(1);
|
|
}
|
|
|
|
// Rough fee estimate: ~0.01 WOW per output
|
|
const estimatedFees = Math.round(0.01 * ATOMIC_DIVISOR * opts.count);
|
|
const totalWithFees = totalNeeded + estimatedFees;
|
|
|
|
if (balance.unlocked_balance < totalWithFees) {
|
|
console.error(`Insufficient unlocked balance!`);
|
|
console.error(` Need: ~${(totalWithFees / ATOMIC_DIVISOR).toFixed(4)} WOW (including estimated fees)`);
|
|
console.error(` Have: ${(balance.unlocked_balance / ATOMIC_DIVISOR).toFixed(4)} WOW unlocked`);
|
|
process.exit(1);
|
|
}
|
|
|
|
// Step 3: Build destinations (all to own address)
|
|
const destinations = [];
|
|
for (let i = 0; i < opts.count; i++) {
|
|
destinations.push({
|
|
amount: amountAtomic,
|
|
address: ownAddress
|
|
});
|
|
}
|
|
|
|
console.log(`Splitting into ${opts.count} outputs of ${opts.amount} WOW each...`);
|
|
|
|
if (opts.dryRun) {
|
|
console.log('');
|
|
console.log('DRY RUN — no transaction sent.');
|
|
console.log(`Would create ${opts.count} outputs of ${amountAtomic} atomic units each.`);
|
|
console.log(`Estimated total (with fees): ~${(totalWithFees / ATOMIC_DIVISOR).toFixed(4)} WOW`);
|
|
console.log('Remaining balance would be a change output.');
|
|
process.exit(0);
|
|
}
|
|
|
|
// Step 4: Send transfer_split to self
|
|
try {
|
|
const txResp = await rpcCall(opts.endpoint, 'transfer_split', {
|
|
destinations,
|
|
account_index: 0,
|
|
priority: 1,
|
|
get_tx_key: true
|
|
});
|
|
|
|
const result = txResp.result;
|
|
const totalFee = (result.fee_list || []).reduce((a, b) => a + b, 0);
|
|
|
|
console.log('');
|
|
console.log('=== Split Complete ===');
|
|
console.log(`Transactions: ${result.tx_hash_list.length}`);
|
|
for (const txHash of result.tx_hash_list) {
|
|
console.log(` tx: ${txHash}`);
|
|
}
|
|
console.log(`Total fee: ${(totalFee / ATOMIC_DIVISOR).toFixed(6)} WOW`);
|
|
console.log(`Outputs created: ${opts.count}`);
|
|
console.log('');
|
|
console.log('Outputs will be spendable after 4 block confirmations (~8 minutes).');
|
|
} catch (err) {
|
|
console.error(`Failed to split outputs: ${err.message}`);
|
|
process.exit(1);
|
|
}
|
|
}
|
|
|
|
main().catch(err => {
|
|
console.error('Unexpected error:', err.message);
|
|
process.exit(1);
|
|
});
|