pstake-rewards-swapper/tx.js at main · persistenceOne/pstake-rewards-swapper · GitHub

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
import {CreateSigningClientFromAddress} from "./helper.js";
import {assertIsDeliverTxSuccess} from "@cosmjs/stargate";
import { MsgTransfer } from "cosmjs-types/ibc/applications/transfer/v1/tx.js";
import { MsgExecuteContract } from "cosmjs-types/cosmwasm/wasm/v1/tx.js";

export async function IBCRoute(senderAddress, receiverAddress, senderIBCInfo, forwardIBCInfo, coin) {
    let memo = "{\"forward\":{\"receiver\":\"" + receiverAddress.address + "\",\"port\":\"" + forwardIBCInfo.port + "\"," +
        "\"channel\":\"" + forwardIBCInfo.channelId + "\",\"timeout\":\"1m\",\"retries\":2}}"

    const msgIBCTransfer = {
        typeUrl: "/ibc.applications.transfer.v1.MsgTransfer", value: MsgTransfer.fromPartial({
            sourcePort: senderIBCInfo.port,
            sourceChannel: senderIBCInfo.channelId,
            token: coin,
            sender: senderAddress.address,
            receiver: receiverAddress.address,
            timeoutTimestamp: (Date.now() + 60 * 1000) * 1e6,
            memo: memo
        })
    }
    //console.log("MsgTransfer: ", JSON.stringify(msgIBCTransfer))

    return await SendTx(senderAddress, [msgIBCTransfer], 1.5, "")
}

export async function IBCSend(senderAddress, receiverAddress, senderIBCInfo, coin) {
    const msgIBCTransfer = {
        typeUrl: "/ibc.applications.transfer.v1.MsgTransfer", value: MsgTransfer.fromPartial({
            sourcePort: senderIBCInfo.port,
            sourceChannel: senderIBCInfo.channelId,
            token: coin,
            sender: senderAddress.address,
            receiver: receiverAddress.address,
            timeoutTimestamp: (Date.now() + 60 * 1000) * 1e6,
            memo: ""
        })
    }

    return await SendTx(senderAddress, [msgIBCTransfer], 1.5, "")
}

export async function ExecuteContract(senderAddress, contractAddress, msg, funds) {
    const msgExecuteContract = {
        typeUrl: "/cosmwasm.wasm.v1.MsgExecuteContract", value: MsgExecuteContract.fromPartial({
            sender: senderAddress.address,
            contract: contractAddress,
            msg: new TextEncoder().encode(JSON.stringify(msg)),
            funds: funds,
            memo: ""
        })
    }

    return await SendTx(senderAddress, [msgExecuteContract], 1.5, "")
}

async function SendTx(senderAddress, msgs, fee, memo) {
    const signingPersistenceClient = await CreateSigningClientFromAddress(senderAddress)
    const response = await signingPersistenceClient.signAndBroadcast(senderAddress.address, msgs, fee, memo)

    assertIsDeliverTxSuccess(response)

    return response.transactionHash
}