Init Stream
Asset stream initialization can be performed in following way.
const now = nowInSec();
const startTime = now + 180;
/*
* three min added deliberately because it takes times for your payload to hit
* zebec program in solana
**/
const endTime = startTime + 6000; // 100 min
const streamAmount = "1";
const receiver = <evm address>;
const sender = signer.address;
const canCancel = true;
const canUpdate = true;
const tokenMint = "<solana mint address>";
const sourceChain = CHAIN_ID_BSC;
const receipt = await ethClient.initStream(
startTime.toString(),
endTime.toString(),
streamAmount,
receiver,
sender,
canCancel,
canUpdate,
tokenMint,
);
Now you can find signed Vaa bytes of your payload sent from wormhole guardian rpc hosts.
const sequence = parseSequenceFromLogEth(receipt, getBridgeAddressForChain(sourceChain));
const zebecEmitterAddress = getEmitterAddressEth(BSC_ZEBEC_BRIDGE_ADDRESS);
const { vaaBytes } = await getSignedVAAWithRetry(
WORMHOLE_RPC_HOSTS,
sourceChain,
zebecEmitterAddress,
sequence,
);
Now post this signed vaa to wormhole solana core bridge program, parse the payloads from vaa and send the parsed data to solana zebec bridge program. This part is optional because it's handled by zebec's specialized relayer.
const payerAddress = wallet.publicKey.toString();
const bridgeAddress = getBridgeAddressForChain(targetChain);
const vaaBuf = Buffer.from(vaaBytes);
setDefaultWasm("node"); // use bundler for browser
// posting vaa in solana
await postVaaSolanaWithRetry(
connection,
wallet.signTransaction,
bridgeAddress,
payerAddress,
vaaBuf,
MAX_VAA_UPLOAD_RETRIES_SOLANA,
);
const parsedVaa = parse_vaa(streamVaa);
const parsedPayload = parseZebecPayload(Buffer.from(parsedVaa.payload));
const result = await solanaClient.initializeStream(streamVaa, <TokenStreamPayload>parsedPayload);
console.log(result);
Last modified 9mo ago