STREAM-1587: support base

lerna.json

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

packages/common/package.json

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

packages/common/types.ts

@@ -21,6 +21,7 @@ export enum IChain {
   BNB = "BNB",
   Polygon = "Polygon",
   Sui = "Sui",
+  Base = "Base",
 }
 
 /**

packages/distributor/package.json

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

packages/eslint-config/package.json

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

packages/stream/common/GenericStreamClient.ts

@@ -48,7 +48,7 @@ export interface AptosStreamClientOptions {
 }
 
 export interface EvmStreamClientOptions {
-  chain: IChain.Ethereum | IChain.BNB | IChain.Polygon;
+  chain: IChain.Ethereum | IChain.BNB | IChain.Polygon | IChain.Base;
   clusterUrl: string;
   signer: Signer;
   cluster?: ICluster;
@@ -141,6 +141,7 @@ export default class GenericStreamClient<T extends IChain> extends BaseStreamCli
           options.programId,
         ) as StreamClientType<T>;
         break;
+      case IChain.Base:
       case IChain.BNB:
       case IChain.Ethereum:
       case IChain.Polygon:

packages/stream/evm/StreamClient.ts

@@ -7,13 +7,14 @@ import {
   ICancelData,
   IChain,
   ICluster,
+  ICreateMultiError,
   ICreateMultipleStreamData,
   ICreateResult,
   ICreateStreamData,
-  IGetFeesData,
+  IFees,
   IGetAllData,
+  IGetFeesData,
   IGetOneData,
-  IFees,
   IMultiTransactionResult,
   IRecipient,
   ITopUpData,
@@ -24,7 +25,7 @@ import {
   Stream,
   StreamDirection,
 } from "../common/types";
-import { BNB_PROGRAM_IDS, ETHEREUM_PROGRAM_IDS, POLYGON_PROGRAM_IDS } from "./constants";
+import { BASE_PROGRAM_IDS, BNB_PROGRAM_IDS, ETHEREUM_PROGRAM_IDS, POLYGON_PROGRAM_IDS } from "./constants";
 import abi from "./abi";
 import ercAbi from "./ercAbi";
 import { BASE_FEE, WITHDRAW_AVAILABLE_AMOUNT } from "../common/constants";
@@ -51,10 +52,6 @@ export default class EvmStreamClient extends BaseStreamClient {
   ) {
     super();
 
-    if (chain !== IChain.Ethereum && chain !== IChain.BNB && chain !== IChain.Polygon) {
-      throw new Error("Wrong chain. Supported chains are Ethereum , BNB and Polygon!");
-    }
-
     if (programId) {
       this.programId = programId;
     } else {
@@ -68,6 +65,11 @@ export default class EvmStreamClient extends BaseStreamClient {
         case IChain.Polygon:
           this.programId = POLYGON_PROGRAM_IDS[cluster];
           break;
+        case IChain.Base:
+          this.programId = BASE_PROGRAM_IDS[cluster];
+          break;
+        default:
+          throw new Error("Wrong chain. Supported chains are Ethereum , BNB, Base and Polygon!");
       }
     }
 
@@ -123,42 +125,31 @@ export default class EvmStreamClient extends BaseStreamClient {
 
     const creationPromises = args.map((item) => this.writeContract.create(...item, { value: fees.value }));
 
-    const signatures: string[] = [];
     const results = await Promise.all(creationPromises);
+    const errors: ICreateMultiError[] = [];
+    const signatures: string[] = [];
+    const metadatas: string[] = [];
+    const metadataToRecipient: { [key: string]: IRecipient } = {};
 
     const confirmations = await Promise.allSettled(results.map((result) => result.wait()));
-    const successes = confirmations
-      .filter((el): el is PromiseFulfilledResult<any> => el.status === "fulfilled")
-      .map((el) => el.value);
-    signatures.push(...successes.map((el) => el.hash));
-
-    const metadatas = confirmations.map((result: PromiseSettledResult<any>) =>
-      result.status === "fulfilled"
-        ? this.formatMetadataId(
-            result.value.events!.find((item: ethers.Event) => item.event === "ContractCreated")!.args![0],
-          )
-        : null,
-    );
-    const metadataToRecipient = metadatas.reduce(
-      (acc, value, index) => {
-        if (value) {
-          acc[value] = multipleStreamData.recipients[index];
-        }
-
-        return acc;
-      },
-      {} as Record<string, IRecipient>,
-    );
-
-    const failures = confirmations
-      .filter((el): el is PromiseRejectedResult => el.status === "rejected")
-      .map((el) => el.reason);
+    confirmations.forEach((res: PromiseSettledResult<any>, index: number) => {
+      if (res.status === "rejected") {
+        errors.push(res.reason);
+        return;
+      }
+      signatures.push(res.value.transactionHash);
+      const metadataId = this.formatMetadataId(
+        res.value.events!.find((item: ethers.Event) => item.event === "ContractCreated")!.args![0],
+      );
+      metadatas.push(metadataId);
+      metadataToRecipient[metadataId] = multipleStreamData.recipients[index];
+    });
 
     return {
       txs: signatures,
-      metadatas: metadatas.filter(Boolean) as string[],
+      metadatas,
       metadataToRecipient,
-      errors: failures,
+      errors,
     };
   }
 

packages/stream/evm/constants.ts

@@ -21,6 +21,13 @@ export const POLYGON_PROGRAM_IDS: Record<ICluster, string> = {
   [ICluster.Local]: "0x5Db7a43D20De64E3a3BC765334a477026FD13E7d",
 };
 
+export const BASE_PROGRAM_IDS: Record<ICluster, string> = {
+  [ICluster.Mainnet]: "0x94d4646Bd307Bf91CB1893BC64d976BF9E60D9B2",
+  [ICluster.Devnet]: "0x5Db7a43D20De64E3a3BC765334a477026FD13E7d",
+  [ICluster.Testnet]: "0x5Db7a43D20De64E3a3BC765334a477026FD13E7d",
+  [ICluster.Local]: "0x5Db7a43D20De64E3a3BC765334a477026FD13E7d",
+};
+
 export const EVM_ERROR_MATCH_REGEX = /execution reverted: ([A-Z_]+)/;
 
 export const EVM_ERROR_MAP = {

packages/stream/package.json

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