production mode for pgSink

helium · Dec 17, 2024 · 90b359d · 90b359d
1 parent 0398c7b
commit 90b359d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/packages/account-postgres-sink-service/src/env.ts b/packages/account-postgres-sink-service/src/env.ts
@@ -6,6 +6,7 @@ process.env.ANCHOR_WALLET =
   process.env.ANCHOR_WALLET || os.homedir() + "/.config/solana/id.json";
 
 const getEnvBoolean = (key: string): boolean => process.env[key] === "true";
+export const PRODUCTION = process.env.NODE_ENV === "production" || false;
 export const SOLANA_URL = process.env.SOLANA_URL || "http://127.0.0.1:8899";
 
 export const REFRESH_PASSWORD = process.env.REFRESH_PASSWORD;

diff --git a/packages/account-postgres-sink-service/src/services/substream.ts b/packages/account-postgres-sink-service/src/services/substream.ts
@@ -13,7 +13,12 @@ import {
 } from "@substreams/core";
 import { FastifyInstance } from "fastify";
 import { Op } from "sequelize";
-import { SUBSTREAM, SUBSTREAM_API_KEY, SUBSTREAM_URL } from "../env";
+import {
+  PRODUCTION,
+  SUBSTREAM,
+  SUBSTREAM_API_KEY,
+  SUBSTREAM_URL,
+} from "../env";
 import { getPluginsByAccountTypeByProgram } from "../plugins";
 import { IConfig } from "../types";
 import { Cursor, database } from "../utils/database";
@@ -79,8 +84,7 @@ export const setupSubstream = async (
       const request = createRequest({
         substreamPackage: substream,
         outputModule: MODULE,
-        // Todo Bry: Setup as env
-        productionMode: false,
+        productionMode: PRODUCTION,
         startBlockNum: cursor ? undefined : currentBlock,
         startCursor: cursor,
       });