| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100 |
- import {
- Address,
- Commitment,
- CompilableTransactionMessage,
- TransactionMessageWithBlockhashLifetime,
- ProgramDerivedAddress,
- Rpc,
- RpcSubscriptions,
- SolanaRpcApi,
- SolanaRpcSubscriptionsApi,
- TransactionSigner,
- airdropFactory,
- appendTransactionMessageInstruction,
- createSolanaRpc,
- createSolanaRpcSubscriptions,
- createTransactionMessage,
- generateKeyPairSigner,
- getSignatureFromTransaction,
- lamports,
- pipe,
- sendAndConfirmTransactionFactory,
- setTransactionMessageFeePayerSigner,
- setTransactionMessageLifetimeUsingBlockhash,
- signTransactionMessageWithSigners,
- } from '@solana/kit';
- import { findCounterPda, getCreateInstructionAsync } from '../src';
- type Client = {
- rpc: Rpc<SolanaRpcApi>;
- rpcSubscriptions: RpcSubscriptions<SolanaRpcSubscriptionsApi>;
- };
- export const createDefaultSolanaClient = (): Client => {
- const rpc = createSolanaRpc('http://127.0.0.1:8899');
- const rpcSubscriptions = createSolanaRpcSubscriptions('ws://127.0.0.1:8900');
- return { rpc, rpcSubscriptions };
- };
- export const generateKeyPairSignerWithSol = async (
- client: Client,
- putativeLamports: bigint = 1_000_000_000n
- ) => {
- const signer = await generateKeyPairSigner();
- await airdropFactory(client)({
- recipientAddress: signer.address,
- lamports: lamports(putativeLamports),
- commitment: 'confirmed',
- });
- return signer;
- };
- export const createDefaultTransaction = async (
- client: Client,
- feePayer: TransactionSigner
- ) => {
- const { value: latestBlockhash } = await client.rpc
- .getLatestBlockhash()
- .send();
- return pipe(
- createTransactionMessage({ version: 0 }),
- (tx) => setTransactionMessageFeePayerSigner(feePayer, tx),
- (tx) => setTransactionMessageLifetimeUsingBlockhash(latestBlockhash, tx)
- );
- };
- export const signAndSendTransaction = async (
- client: Client,
- transactionMessage: CompilableTransactionMessage &
- TransactionMessageWithBlockhashLifetime,
- commitment: Commitment = 'confirmed'
- ) => {
- const signedTransaction =
- await signTransactionMessageWithSigners(transactionMessage);
- const signature = getSignatureFromTransaction(signedTransaction);
- await sendAndConfirmTransactionFactory(client)(signedTransaction, {
- commitment,
- });
- return signature;
- };
- export const getBalance = async (client: Client, address: Address) =>
- (await client.rpc.getBalance(address, { commitment: 'confirmed' }).send())
- .value;
- export const createCounterForAuthority = async (
- client: Client,
- authority: TransactionSigner
- ): Promise<ProgramDerivedAddress> => {
- const [transaction, counterPda, createIx] = await Promise.all([
- createDefaultTransaction(client, authority),
- findCounterPda({ authority: authority.address }),
- getCreateInstructionAsync({ authority }),
- ]);
- await pipe(
- transaction,
- (tx) => appendTransactionMessageInstruction(createIx, tx),
- (tx) => signAndSendTransaction(client, tx)
- );
- return counterPda;
- };
|