SDK for use any functions of Moveflow
npm install @moveflow/sdk.jsbash
yarn add @moveflow/sdk.js
`
$3
`
const sdk = new SDK(Network.TESTNET)
`
$3
1. create a stream
`
const payload = sdk.stream.create({
recipientAddr: '0x20f0cbe21cb340fe56500e0889cad03f8a9e54a33e3c4acfc24ce2bdfabc4180',
depositAmount: 1,
startTime: start_time,
stopTime: stop_time,
// coinType: AptosCoin,
interval: 1000,
// name: '1',
// remark: '1',
// canPause: true,
// closeable: true,
// recipientModifiable: true
})
const txid = await SignAndSubmitTransaction(payload)
`
2. batch create streams
`javascript
const batchCreate = async () => {
const start_time = Math.floor(Date.now() / 1000).toString();
const stop_time = Math.floor(Date.now() / 1000 + 60 60 24).toString();
const payload = sdk.stream.batchCreate({
recipientAddrs: [
"0x20f0cbe21cb340fe56500e0889cad03f8a9e54a33e3c4acfc24ce2bdfabc4180",
"0x20f0cbe21cb340fe56500e0889cad03f8a9e54a33e3c4acfc24ce2bdfabc4180",
],
depositAmounts: [0.1, 0.2],
startTime: start_time,
stopTime: stop_time,
name: "batch_create_0x2",
remark: "batch_create_0x2",
interval: 1000,
});
const txid = await SignAndSubmitTransaction(payload);
};
`
3. pause a stream
`
const payload = sdk.stream.pause({
id: 29,
coinType: AptosCoin,
})
const txid = await SignAndSubmitTransaction(payload)
`
4. resume a stream
`
const payload = sdk.stream.resume({
id: 29,
coinType: AptosCoin,
})
const txid = await SignAndSubmitTransaction(payload)
`
5. close a stream
`
const payload = sdk.stream.close({ id: 29 })
const txid = await SignAndSubmitTransaction(payload)
`
6. extend a stream
`
const payload = sdk.stream.extend({
id: 30,
extraAmount: 300,
stopTime: '1635724800',
ratePerInterval: '100',
interval: '1000',
coinType: AptosCoin,
})
const txid = await SignAndSubmitTransaction(payload)
`
$3
1. query incoming streams
`
const address = 0x20f0cbe21cb340fe56500e0889cad03f8a9e54a33e3c4acfc24ce2bdfabc4180
const res = await sdk.stream.getIncomingStreams(address);
`
2. query outgoing streams
`
const address = 0x20f0cbe21cb340fe56500e0889cad03f8a9e54a33e3c4acfc24ce2bdfabc4180
const res = await sdk.stream.getOutgoingStreams(address)
``