add search distributors method (#192)

lerna.json

@@ -2,6 +2,6 @@
   "packages": [
     "packages/*"
   ],
-  "version": "6.3.9",
+  "version": "6.3.10",
   "$schema": "node_modules/lerna/schemas/lerna-schema.json"
 }

package.json

@@ -44,8 +44,5 @@
     "typedoc": "0.25.11",
     "typescript": "^5.3.3"
   },
-  "version": "4.0.1",
-  "workspaces": [
-    "packages/*"
-  ]
-}
+  "version": "4.0.1"
+}

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/common",
-  "version": "6.3.9",
+  "version": "6.3.10",
   "description": "Common utilities and types used by streamflow packages.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "dist/index.js",

packages/distributor/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/distributor",
-  "version": "6.3.9",
+  "version": "6.3.10",
   "description": "JavaScript SDK to interact with Streamflow Airdrop protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "dist/index.js",

packages/distributor/solana/client.ts

@@ -1,3 +1,4 @@
+import bs58 from "bs58";
 import BN from "bn.js";
 import PQueue from "p-queue";
 import {
@@ -14,6 +15,7 @@ import {
   TransactionInstruction,
   Commitment,
   ConnectionConfig,
+  MemcmpFilter,
 } from "@solana/web3.js";
 import { ICluster, ITransactionResult } from "@streamflow/common";
 import {
@@ -26,7 +28,7 @@ import {
   buildSendThrottler,
 } from "@streamflow/common/solana";
 
-import { DISTRIBUTOR_PROGRAM_ID } from "./constants";
+import { DISTRIBUTOR_ADMIN_OFFSET, DISTRIBUTOR_MINT_OFFSET, DISTRIBUTOR_PROGRAM_ID } from "./constants";
 import {
   IClaimData,
   IClawbackData,
@@ -36,6 +38,7 @@ import {
   IGetDistributors,
   ICreateSolanaExt,
   IInteractSolanaExt,
+  ISearchDistributors,
 } from "./types";
 import {
   ClaimLockedAccounts,
@@ -361,4 +364,29 @@ export default class SolanaDistributorClient {
     const distributorPublicKeys = data.ids.map((distributorId) => new PublicKey(distributorId));
     return MerkleDistributor.fetchMultiple(this.connection, distributorPublicKeys, this.programId);
   }
+
+  public async searchDistributors(data: ISearchDistributors): Promise<MerkleDistributor[]> {
+    const filters: MemcmpFilter[] = [{ memcmp: { offset: 0, bytes: bs58.encode(MerkleDistributor.discriminator) } }];
+    if (data.mint) {
+      filters.push({
+        memcmp: {
+          offset: DISTRIBUTOR_MINT_OFFSET,
+          bytes: data.mint,
+        },
+      });
+    }
+    if (data.admin) {
+      filters.push({
+        memcmp: {
+          offset: DISTRIBUTOR_ADMIN_OFFSET,
+          bytes: data.admin,
+        },
+      });
+    }
+    const accounts = await this.connection.getProgramAccounts(this.programId, { filters });
+
+    return accounts.map(({ account }) => {
+      return MerkleDistributor.decode(account.data);
+    });
+  }
 }

packages/distributor/solana/constants.ts

@@ -1,5 +1,9 @@
 import { ICluster } from "@streamflow/common";
 
+export const ANCHOR_DISCRIMINATOR_OFFSET = 8;
+export const DISTRIBUTOR_MINT_OFFSET = ANCHOR_DISCRIMINATOR_OFFSET + 41;
+export const DISTRIBUTOR_ADMIN_OFFSET = ANCHOR_DISCRIMINATOR_OFFSET + 201;
+
 export const ONE_IN_BASIS_POINTS = BigInt(10_000);
 
 export const DISTRIBUTOR_PROGRAM_ID = {

packages/distributor/solana/types.ts

@@ -48,6 +48,11 @@ export interface IGetDistributors {
   ids: string[];
 }
 
+export interface ISearchDistributors {
+  mint?: string;
+  admin?: string;
+}
+
 export interface ISetDataAdmin {
   id: string;
   newAdmin: string;

packages/eslint-config/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/eslint-config",
-  "version": "6.3.9",
+  "version": "6.3.10",
   "license": "ISC",
   "main": "index.js",
   "files": [

packages/stream/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/stream",
-  "version": "6.3.9",
+  "version": "6.3.10",
   "description": "JavaScript SDK to interact with Streamflow protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "dist/index.js",