diff --git a/packages/common/solana/types.ts b/packages/common/solana/types.ts index 48d24e7..06cf008 100644 --- a/packages/common/solana/types.ts +++ b/packages/common/solana/types.ts @@ -36,7 +36,7 @@ export interface ThrottleParams { sendThrottler?: PQueue; } -export interface ProgramAccount { +export interface IProgramAccount { publicKey: PublicKey; account: T; } diff --git a/packages/distributor/solana/client.ts b/packages/distributor/solana/client.ts index e4aa166..b7b3a55 100644 --- a/packages/distributor/solana/client.ts +++ b/packages/distributor/solana/client.ts @@ -26,7 +26,7 @@ import { prepareTransaction, getMintAndProgram, buildSendThrottler, - ProgramAccount, + IProgramAccount, } from "@streamflow/common/solana"; import { DISTRIBUTOR_ADMIN_OFFSET, DISTRIBUTOR_MINT_OFFSET, DISTRIBUTOR_PROGRAM_ID } from "./constants"; @@ -366,7 +366,7 @@ export default class SolanaDistributorClient { return MerkleDistributor.fetchMultiple(this.connection, distributorPublicKeys, this.programId); } - public async searchDistributors(data: ISearchDistributors): Promise[]> { + public async searchDistributors(data: ISearchDistributors): Promise[]> { const filters: MemcmpFilter[] = [{ memcmp: { offset: 0, bytes: bs58.encode(MerkleDistributor.discriminator) } }]; if (data.mint) { filters.push({ diff --git a/packages/stream/solana/StreamClient.ts b/packages/stream/solana/StreamClient.ts index 849d6c2..4f0414c 100644 --- a/packages/stream/solana/StreamClient.ts +++ b/packages/stream/solana/StreamClient.ts @@ -30,7 +30,7 @@ import { executeTransaction, executeMultipleTransactions, buildSendThrottler, - ProgramAccount, + IProgramAccount, } from "@streamflow/common/solana"; import * as borsh from "borsh"; @@ -894,7 +894,7 @@ export default class SolanaStreamClient extends BaseStreamClient { return sortedStreams.filter((stream) => stream[1].type === type); } - public async searchStreams(data: ISearchStreams): Promise[]> { + public async searchStreams(data: ISearchStreams): Promise[]> { const filters: MemcmpFilter[] = []; for (const [k, v] of Object.entries(data)) { if (v) {