Docs: https://streamflow.finance/js-sdk/
Streamflow is a token distribution platform powered by a streaming payments' protocol.
There are several ways to use Streamflow:
- (easiest) app.streamflow.finance (React application that uses JS SDK directly)
- JS SDK to interact with the protocol => NPM package
- Rust SDK to integrate within a Solana program => Rust Crate
Security audit passed ✅
Protocol audit available here. Partner oracle audit available here here.
This package allows you to create, createMultiple, withdraw, cancel, topup and transfer SPL token stream.
You can also getOne stream and get multiple streams.
npm i @streamflow/stream @solana/web3.js @project-serum/anchor
Anchor is needed for the
Wallettype. We plan on removing this dependency in upcoming releases.
Most common imports:
import {
StreamClient,
Stream,
CreateParams,
CreateMultiParams,
WithdrawParams,
TransferParams,
TopupParams,
CancelParams,
GetAllParams,
StreamDirection,
StreamType,
Cluster,
TxResponse,
CreateResponse,
BN,
getBN,
getNumberFromBN,
} from "@streamflow/stream";Check the SDK for other types and utility functions.
Before creating and manipulating streams StreamClient instance must be created. All streams functions are methods on this instance.
import { StreamClient } from "@streamflow/stream";
const StreamClient = new StreamClient(
"https://api.mainnet-beta.solana.com",
Cluster.Mainnet,
"confirmed"
);const createStreamParams = {
sender: wallet, // Wallet/Keypair signing the transaction, creating and sending the stream.
recipient: "4ih00075bKjVg000000tLdk4w42NyG3Mv0000dc0M00", // Solana recipient address.
mint: "DNw99999M7e24g99999999WJirKeZ5fQc6KY999999gK", // SPL Token mint.
start: 1643363040, // Timestamp (in seconds) when the stream/token vesting starts.
depositedAmount: getBN(1000000000000, 9), // Deposited amount of tokens (using smallest denomination).
period: 1, // Time step (period) in seconds per which the unlocking occurs.
cliff: 1643363160, // Vesting contract "cliff" timestamp in seconds.
cliffAmount: new BN(100000000000), // Amount (smallest denomination) unlocked at the "cliff" timestamp.
amountPerPeriod: getBN(5000000000, 9), // Release rate: how many tokens are unlocked per each period.
name: "Transfer to Jane Doe.", // The stream name or subject.
canTopup: false, // setting to FALSE will effectively create a vesting contract.
cancelableBySender: true, // Whether or not sender can cancel the stream.
cancelableByRecipient: false, // Whether or not recipient can cancel the stream.
transferableBySender: true, // Whether or not sender can transfer the stream.
transferableByRecipient: false, // Whether or not recipient can transfer the stream.
automaticWithdrawal: true, // [WIP] Whether or not a 3rd party (e.g. cron job, "cranker") can initiate a token withdraw/transfer.
withdrawalFrequency: 10, // [WIP] Relevant when automatic withdrawal is enabled. If greater than 0 our withdrawor will take care of withdrawals. If equal to 0 our withdrawor will skip, but everyone else can initiate withdrawals.
partner: null, // (optional) Partner's wallet address (string | null).
};
try {
const { ixs, tx, metadata } = await StreamClient.create(createStreamParams);
} catch (exception) {
// handle exception
}const recipients = [
{
recipient: "4ih00075bKjVg000000tLdk4w42NyG3Mv0000dc0M00", // Solana recipient address.
depositedAmount: getBN(1000000000000, 9), // Deposited amount of tokens (in the smallest units).
name: "January Payroll", // The stream name/subject.
},
];
const createMultiStreamsParams = {
sender: wallet, // Wallet/Keypair signing the transaction, creating and sending the stream.
recipientsData: recipients, // Array of Solana recipient address.
mint: "DNw99999M7e24g99999999WJirKeZ5fQc6KY999999gK", // SPL Token mint.
start: 1643363040, // Timestamp (in seconds) when the stream/token vesting starts.
period: 1, // Time step (period) in seconds per which the unlocking occurs.
cliff: 1643363160, // Vesting contract "cliff" timestamp in seconds.
cliffAmount: getBN(100000000000, 9), // Amount unlocked at the "cliff" timestamp.
amountPerPeriod: getBN(5000000000, 9), // Release rate: how many tokens are unlocked per each period.
canTopup: true, // setting to FALSE will effectively create a vesting contract.
cancelableBySender: true, // Whether or not sender can cancel the stream.
cancelableByRecipient: false, // Whether or not recipient can cancel the stream.
transferableBySender: true, // Whether or not sender can transfer the stream.
transferableByRecipient: false, // Whether or not recipient can transfer the stream.
automaticWithdrawal: false, // Whether or not a 3rd party can initiate withdraw in the name of recipient (currently not used, set it to FALSE).
partner: null, // (optional) Partner's wallet address (string | null).
};
try {
const { txs } = await StreamClient.createMultiple(createMultiStreamsParams);
} catch (exception) {
// handle exception
}_Disclaimer: Support for scheduled, automatic token withdrawals/transfers is under development and scheduled to launch in Q1. Once launched, it will be enabled retroactively for all streams that have automaticWithdrawal set to true.
Please note that transaction fees for the scheduled transfers are paid upfront by the stream creator (sender)._
const withdrawStreamParams = {
invoker: wallet, // Wallet/Keypair signing the transaction.
id: "AAAAyotqTZZMAAAAmsD1JAgksT8NVAAAASfrGB5RAAAA", // Identifier of a stream to be withdrawn from.
amount: getBN(100000000000, 9), // Requested amount to withdraw. If stream is completed, the whole amount will be withdrawn.
};
try {
const { ixs, tx } = await StreamClient.withdraw(withdrawStreamParams);
} catch (exception) {
// handle exception
}const topupStreamParams = {
invoker: wallet, // Wallet/Keypair signing the transaction.
id: "AAAAyotqTZZMAAAAmsD1JAgksT8NVAAAASfrGB5RAAAA", // Identifier of a stream to be topped up.
amount: getBN(100000000000, 9), // Specified amount to topup (increases deposited amount).
};
try {
const { ixs, tx } = await StreamClient.topup(topupStreamParams);
} catch (exception) {
// handle exception
}const data = {
invoker: wallet, // Wallet/Keypair signing the transaction.
id: "AAAAyotqTZZMAAAAmsD1JAgksT8NVAAAASfrGB5RAAAA",
recipientId: "99h00075bKjVg000000tLdk4w42NyG3Mv0000dc0M99", // Identifier of a stream to be transferred.
};
try {
const { tx } = await StreamClient.transfer(data);
} catch (exception) {
// handle exception
}const cancelStreamParams = {
invoker: wallet, // Wallet/Keypair signing the transaction.
id: "AAAAyotqTZZMAAAAmsD1JAgksT8NVAAAASfrGB5RAAAA", // Identifier of a stream to be canceled.
};
try {
const { ixs, tx } = await StreamClient.cancel(cancelStreamParams);
} catch (exception) {
// handle exception
}try {
const stream = await StreamClient.getOne(
"AAAAyotqTZZMAAAAmsD1JAgksT8NVAAAASfrGB5RAAAA" // Identifier of a stream that is fetched.
);
} catch (exception) {
// handle exception
}try {
const streams = StreamClient.get({
wallet: wallet, // Wallet signing the transaction.
type: StreamType.All, // (optional) Type, default is StreamType.All
direction: StreamDirection.All, // (optional) Direction, default is StreamDirection.All)
});
} catch (exception) {
// handle exception
}Default import import Stream from '@streamflow/stream' is an import of older SDK version that uses Anchor and doesn't support raw instructions, nor multi streams creation.
Streamflow protocol program ID (devnet): HqDGZjaVRXJ9MGRQEw7qDc2rAr6iH1n1kAQdCZaCMfMZ
Streamflow protocol program ID (mainnet): strmRqUCoQUgGUan5YhzUZa6KqdzwX5L6FpUxfmKg5m
All BN amounts are denominated in their smallest units.
E.g, if the amount is 1 SOL than this amount in lamports is 1000 \* 10^9 = 1_000_000_000.
And new BN(1_000_000_000) is used.
Use getBN and getNumberFromBN utility functions for conversions between BN and Number types.
Streamflow Community (free and open source version, with a limited feature set) is available here.
npx typedoc packages/stream/index.ts
WAGMI.