-
Notifications
You must be signed in to change notification settings - Fork 31
/
collectAll.js
74 lines (66 loc) · 2.9 KB
/
collectAll.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
import {
QueryClient, setupDistributionExtension, setupBankExtension, setupStakingExtension, setupTxExtension, setupGovExtension
} from "@cosmjs/stargate";
import { Tendermint34Client } from '@cosmjs/tendermint-rpc';
import fs from "fs";
import SigningClient from "./utils/SigningClient.js";
import { getSigner } from "./utils/helpers.js";
import { coins } from '@cosmjs/launchpad';
const loadJSON = (path) => JSON.parse(fs.readFileSync(new URL(path, import.meta.url)));
const chainsMap = loadJSON('./assets/chains.json');
async function getQueryClient(rpcEndpoint) {
const tendermint34Client = await Tendermint34Client.connect(rpcEndpoint);
const queryClient = QueryClient.withExtensions(
tendermint34Client,
setupBankExtension,
setupStakingExtension,
setupTxExtension,
setupGovExtension,
setupDistributionExtension
);
return queryClient;
}
async function transfer(client, chain, from, recipient, amount) {
let ops = [];
let msg = {
typeUrl: "/cosmos.bank.v1beta1.MsgSend",
value: {
fromAddress: from,
toAddress: recipient,
amount: coins(amount, chain.denom)
},
};
ops.push(msg);
let result = await client.signAndBroadcast(from, ops, '', '');
return result;
}
async function start(chain, mnemonicOrKey, recipient) {
try {
const rpcEndpoint = chain.rpc;
let wallet = await getSigner(chain, mnemonicOrKey);
let client = new SigningClient(chain, wallet);
const [account] = await wallet.getAccounts();
const queryClient = await getQueryClient(rpcEndpoint);
let balances = await queryClient.bank.balance(account.address, chain.denom);
console.log(`${account.address} has ${balances.amount / Math.pow(10, chain.exponent)} ${chain.symbol}`);
if (balances.amount > 0) {
let transferAmount = balances.amount - chain.collect_min * Math.pow(10, chain.exponent);
console.log(`Transferring ${transferAmount / Math.pow(10, chain.exponent)} ${chain.symbol} to ${recipient}`);
let result = await transfer(client, chain, account.address, recipient,transferAmount);
let code = result.code;
if (code == 0) {
console.log(`${account.address} transferred ${transferAmount / Math.pow(10, chain.exponent)} ${chain.symbol} to ${recipient}: ${result.transactionHash}`)
} else {
console.log(`${account.address} FAILED to transfer ${transferAmount / Math.pow(10, chain.exponent)} ${chain.symbol} to ${recipient}. Reason: ${result.rawLog}`);
}
}
} catch (err) {
console.log(err)
console.log("Error in start: " + err);
}
}
const mnemonicOrKey = 'Put mnemonic or private key here';
const recipient = ''; //Recipient
for (let chainName in chainsMap) {
start(chainsMap[chainName], mnemonicOrKey, recipient, collectMin);
}