NangoHQ · khaliqgant · Mar 27, 2024 · Mar 26, 2024 · Mar 27, 2024 · Mar 27, 2024
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -10,7 +10,8 @@
         "packages/runner",
         "packages/persist",
         "packages/jobs",
-        "packages/webapp"
+        "packages/webapp",
+        "packages/utils"
     ],
     "scripts": {
         "create:migration": "cd packages/shared/lib/db && knex migrate:make $1 --esm --knexfile ./knexfile.cjs",

diff --git a/packages/jobs/Dockerfile b/packages/jobs/Dockerfile
@@ -10,6 +10,7 @@ WORKDIR /nango
 
 COPY packages/node-client/ packages/node-client/
 COPY packages/shared/ packages/shared/
+COPY packages/utils/ packages/utils/
 COPY packages/jobs/ packages/jobs/
 COPY packages/runner/ packages/runner/
 COPY package*.json ./

diff --git a/packages/jobs/lib/activities.ts b/packages/jobs/lib/activities.ts
@@ -20,12 +20,14 @@ import {
     LogTypes,
     isInitialSyncStillRunning,
     getSyncByIdAndName,
-    logger,
     getLastSyncDate
 } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
 import integrationService from './integration.service.js';
 import type { ContinuousSyncArgs, InitialSyncArgs, ActionArgs, WebhookArgs } from './models/worker';
 
+const { logger } = new Logger('Jobs');
+
 export async function routeSync(args: InitialSyncArgs): Promise<boolean | object | null> {
     const { syncId, syncJobId, syncName, nangoConnection, debug } = args;
     let environmentId = nangoConnection?.environment_id;

diff --git a/packages/jobs/lib/app.ts b/packages/jobs/lib/app.ts
@@ -4,12 +4,14 @@ import { server } from './server.js';
 import { cronAutoIdleDemo } from './crons/autoIdleDemo.js';
 import { deleteOldActivityLogs } from './crons/deleteOldActivities.js';
 import { deleteSyncsData } from './crons/deleteSyncsData.js';
-import { logger } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
+
+const { logger } = new Logger('Jobs');
 
 try {
     const port = parseInt(process.env['NANGO_JOBS_PORT'] || '') || 3005;
     server.listen(port);
-    logger.info(`🚀 Jobs service ready at http://localhost:${port}`);
+    logger.info(`🚀 service ready at http://localhost:${port}`);
     const temporalNs = process.env['TEMPORAL_NAMESPACE'] || 'default';
     const temporal = new Temporal(temporalNs);
 
@@ -29,6 +31,6 @@ try {
         });
     });
 } catch (err) {
-    logger.error(`[JOBS]: ${JSON.stringify(err)}`);
+    logger.error(`${JSON.stringify(err)}`);
     process.exit(1);
 }
diff --git a/packages/jobs/lib/crons/autoIdleDemo.ts b/packages/jobs/lib/crons/autoIdleDemo.ts
@@ -11,11 +11,13 @@ import {
     updateScheduleStatus,
     isErr,
     findPausableDemoSyncs,
-    logger,
     SpanTypes
 } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
 import tracer from 'dd-trace';
 
+const { logger } = new Logger('Jobs');
+
 export function cronAutoIdleDemo(): void {
     schedule('1 * * * *', () => {
         const span = tracer.startSpan(SpanTypes.JOBS_IDLE_DEMO);

diff --git a/packages/jobs/lib/crons/deleteOldActivities.ts b/packages/jobs/lib/crons/deleteOldActivities.ts
@@ -1,8 +1,11 @@
 import * as cron from 'node-cron';
-import { deleteLog, deleteLogsMessages, errorManager, ErrorSourceEnum, findOldActivities, logger, MetricTypes, telemetry } from '@nangohq/shared';
+import { deleteLog, deleteLogsMessages, errorManager, ErrorSourceEnum, findOldActivities, MetricTypes, telemetry } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
 import tracer from 'dd-trace';
 import { setTimeout } from 'node:timers/promises';
 
+const { logger } = new Logger('Jobs');
+
 // Retention in days
 const retention = parseInt(process.env['NANGO_CLEAR_ACTIVITIES_RETENTION'] || '', 10) || 15;
 const limitLog = parseInt(process.env['NANGO_CLEAR_ACTIVITIES_LIMIT'] || '', 10) || 2000;

diff --git a/packages/jobs/lib/crons/deleteSyncsData.ts b/packages/jobs/lib/crons/deleteSyncsData.ts
@@ -2,7 +2,6 @@ import * as cron from 'node-cron';
 import {
     errorManager,
     ErrorSourceEnum,
-    logger,
     MetricTypes,
     softDeleteSchedules,
     telemetry,
@@ -11,8 +10,11 @@ import {
     db,
     findRecentlyDeletedSync
 } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
 import tracer from 'dd-trace';
 
+const { logger } = new Logger('Jobs');
+
 const limitJobs = 1000;
 const limitSchedules = 1000;
 const limitRecords = 1000;

diff --git a/packages/jobs/lib/integration.service.ts b/packages/jobs/lib/integration.service.ts
@@ -1,16 +1,7 @@
 import type { Context } from '@temporalio/activity';
 import type { IntegrationServiceInterface, NangoIntegrationData, NangoProps, ServiceResponse } from '@nangohq/shared';
-import {
-    createActivityLogMessage,
-    localFileService,
-    remoteFileService,
-    isCloud,
-    isProd,
-    integrationFilesAreRemote,
-    NangoError,
-    formatScriptError,
-    isOk
-} from '@nangohq/shared';
+import { integrationFilesAreRemote, isCloud, isProd } from '@nangohq/utils/dist/environment/detection.js';
+import { createActivityLogMessage, localFileService, remoteFileService, NangoError, formatScriptError, isOk } from '@nangohq/shared';
 import type { Runner } from './runner/runner.js';
 import { getOrStartRunner, getRunnerId } from './runner/runner.js';
 import tracer from 'dd-trace';
@@ -82,7 +73,7 @@ class IntegrationService implements IntegrationServiceInterface {
             .setTag('syncName', syncName);
         try {
             const script: string | null =
-                (isCloud() || integrationFilesAreRemote()) && !optionalLoadLocation
+                (isCloud || integrationFilesAreRemote) && !optionalLoadLocation
                     ? await remoteFileService.getFile(integrationData.fileLocation as string, environmentId)
                     : localFileService.getIntegrationFile(syncName, optionalLoadLocation);
 

diff --git a/packages/jobs/lib/runner/local.runner.ts b/packages/jobs/lib/runner/local.runner.ts
@@ -3,7 +3,9 @@ import { RunnerType } from './runner.js';
 import type { ChildProcess } from 'child_process';
 import { execSync, spawn } from 'child_process';
 import { getRunnerClient } from '@nangohq/nango-runner';
-import { logger } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
+
+const { logger } = new Logger('Jobs');
 
 export class LocalRunner implements Runner {
     public client: any;

diff --git a/packages/jobs/lib/runner/remote.runner.ts b/packages/jobs/lib/runner/remote.runner.ts
@@ -1,8 +1,10 @@
-import { logger } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
 import type { Runner } from './runner.js';
 import { RunnerType } from './runner.js';
 import { getRunnerClient } from '@nangohq/nango-runner';
 
+const { logger } = new Logger('Jobs');
+
 export class RemoteRunner implements Runner {
     public client: any;
     public runnerType: RunnerType = RunnerType.Remote;

diff --git a/packages/jobs/lib/runner/runner.ts b/packages/jobs/lib/runner/runner.ts
@@ -2,8 +2,12 @@ import type { KVStore } from '@nangohq/shared/lib/utils/kvstore/KVStore.js';
 import { LocalRunner } from './local.runner.js';
 import { RenderRunner } from './render.runner.js';
 import { RemoteRunner } from './remote.runner.js';
-import { getEnv, getRedisUrl, InMemoryKVStore, RedisKVStore, isEnterprise, logger } from '@nangohq/shared';
+import { isEnterprise, env } from '@nangohq/utils/dist/environment/detection.js';
+import { getRedisUrl, InMemoryKVStore, RedisKVStore } from '@nangohq/shared';
 import type { ProxyAppRouter } from '@nangohq/nango-runner';
+import Logger from '@nangohq/utils/dist/logger.js';
+
+const { logger } = new Logger('Runner');
 
 export enum RunnerType {
     Local = 'local',
@@ -21,7 +25,7 @@ export interface Runner {
 }
 
 export function getRunnerId(suffix: string): string {
-    return `${getEnv()}-runner-account-${suffix}`;
+    return `${env}-runner-account-${suffix}`;
 }
 
 export async function getOrStartRunner(runnerId: string): Promise<Runner> {
@@ -53,7 +57,7 @@ export async function getOrStartRunner(runnerId: string): Promise<Runner> {
     }
     const isRender = process.env['IS_RENDER'] === 'true';
     let runner: Runner;
-    if (isEnterprise()) {
+    if (isEnterprise) {
         runner = await RemoteRunner.getOrStart(runnerId);
     } else if (isRender) {
         runner = await RenderRunner.getOrStart(runnerId);

diff --git a/packages/jobs/lib/server.ts b/packages/jobs/lib/server.ts
@@ -3,7 +3,9 @@ import { createHTTPServer } from '@trpc/server/adapters/standalone';
 import superjson from 'superjson';
 import { z } from 'zod';
 import { suspendRunner } from './runner/runner.js';
-import { logger } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
+
+const { logger } = new Logger('Jobs');
 
 export const t = initTRPC.create({
     transformer: superjson

diff --git a/packages/jobs/lib/temporal.ts b/packages/jobs/lib/temporal.ts
@@ -3,7 +3,11 @@ import fs from 'fs-extra';
 import * as dotenv from 'dotenv';
 import { createRequire } from 'module';
 import * as activities from './activities.js';
-import { SYNC_TASK_QUEUE, WEBHOOK_TASK_QUEUE, isProd, isEnterprise, logger } from '@nangohq/shared';
+import { SYNC_TASK_QUEUE, WEBHOOK_TASK_QUEUE } from '@nangohq/shared';
+import { isProd, isEnterprise } from '@nangohq/utils/dist/environment/detection.js';
+import Logger from '@nangohq/utils/dist/logger.js';
+
+const { logger } = new Logger('Jobs.Temporal');
 
 const TEMPORAL_WORKER_MAX_CONCURRENCY = parseInt(process.env['TEMPORAL_WORKER_MAX_CONCURRENCY'] || '0') || 500;
 
@@ -26,7 +30,7 @@ export class Temporal {
         let crt: Buffer | null = null;
         let key: Buffer | null = null;
 
-        if (isProd() || isEnterprise()) {
+        if (isProd() || isEnterprise) {
             crt = await fs.readFile(`/etc/secrets/${this.namespace}.crt`);
             key = await fs.readFile(`/etc/secrets/${this.namespace}.key`);
         }
@@ -35,7 +39,7 @@ export class Temporal {
             const connection = await NativeConnection.connect({
                 address: process.env['TEMPORAL_ADDRESS'] || 'localhost:7233',
                 tls:
-                    !isProd() && !isEnterprise()
+                    !isProd() && !isEnterprise
                         ? false
                         : {
                               clientCertPair: {

diff --git a/packages/jobs/nodemon.json b/packages/jobs/nodemon.json
@@ -1,7 +1,7 @@
 {
-  "watch": ["lib", "../shared/lib", "../../.env"],
-  "ext": "ts,json",
-  "ignore": ["lib/**/*.spec.ts"],
-  "exec": "tsx -r dotenv/config lib/app.ts dotenv_config_path=./../../.env",
-  "signal": "SIGTERM"
-}
+    "watch": ["lib", "../shared/lib", "../utils/lib", "../../.env"],
+    "ext": "ts,json",
+    "ignore": ["lib/**/*.spec.ts"],
+    "exec": "tsx -r dotenv/config lib/app.ts dotenv_config_path=./../../.env",
+    "signal": "SIGTERM"
+}
diff --git a/packages/jobs/package.json b/packages/jobs/package.json
@@ -17,6 +17,7 @@
     "dependencies": {
         "@nangohq/nango-runner": "^1.0.0",
         "@nangohq/shared": "^0.39.8",
+        "@nangohq/utils": "file:../utils",
         "@temporalio/activity": "^1.9.1",
         "@temporalio/client": "^1.9.1",
         "@temporalio/worker": "^1.9.1",

diff --git a/packages/jobs/tsconfig.json b/packages/jobs/tsconfig.json
@@ -10,9 +10,10 @@
         },
         {
             "path": "../runner"
+        },
+        {
+            "path": "../utils"
         }
     ],
-    "include": [
-        "lib/**/*"
-    ]
+    "include": ["lib/**/*"]
 }
diff --git a/packages/persist/Dockerfile b/packages/persist/Dockerfile
@@ -11,6 +11,7 @@ WORKDIR /nango
 COPY packages/node-client/ packages/node-client/
 COPY packages/shared/ packages/shared/
 COPY packages/persist/ packages/persist/
+COPY packages/utils/ packages/utils/
 COPY package*.json ./
 
 RUN npm pkg delete scripts.prepare

diff --git a/packages/persist/lib/app.ts b/packages/persist/lib/app.ts
@@ -1,10 +1,13 @@
 import './tracer.js';
+import Logger from '@nangohq/utils/dist/logger.js';
 import { server } from './server.js';
 
+const { logger } = new Logger('Persist');
+
 try {
     const port = parseInt(process.env['NANGO_PERSIST_PORT'] || '') || 3007;
     server.listen(port, () => {
-        console.log(`🚀 Persist API ready at http://localhost:${port}`);
+        logger.info(`🚀 API ready at http://localhost:${port}`);
     });
 } catch (err) {
     console.error(`Persist API error: ${err}`);

diff --git a/packages/persist/lib/server.ts b/packages/persist/lib/server.ts
@@ -2,8 +2,11 @@ import express from 'express';
 import type { Request, Response, NextFunction } from 'express';
 import { validateRequest } from 'zod-express';
 import { z } from 'zod';
+import Logger from '@nangohq/utils/dist/logger.js';
 import persistController from './controllers/persist.controller.js';
-import { logLevelValues, logger } from '@nangohq/shared';
+import { logLevelValues } from '@nangohq/shared';
+
+const { logger } = new Logger('Persist');
 
 export const server = express();
 server.use(express.json({ limit: '100mb' }));
@@ -12,14 +15,14 @@ server.use((req: Request, res: Response, next: NextFunction) => {
     const originalSend = res.send;
     res.send = function (body: any) {
         if (res.statusCode >= 400) {
-            logger.info(`[Persist] [Error] ${req.method} ${req.path} ${res.statusCode} '${JSON.stringify(body)}'`);
+            logger.info(`[Error] ${req.method} ${req.path} ${res.statusCode} '${JSON.stringify(body)}'`);
         }
         originalSend.call(this, body) as any;
         return this;
     };
     next();
     if (res.statusCode < 400) {
-        logger.info(`[Persist] ${req.method} ${req.path} ${res.statusCode}`);
+        logger.info(`${req.method} ${req.path} ${res.statusCode}`);
     }
 });
 

diff --git a/packages/persist/nodemon.json b/packages/persist/nodemon.json
@@ -1,6 +1,6 @@
 {
-  "watch": ["lib", "../shared/lib", "../../.env"],
-  "ext": "ts,json",
-  "ignore": ["lib/**/*.test.ts"],
-  "exec": "tsc && tsx -r dotenv/config lib/app.ts dotenv_config_path=./../../.env"
-}
+    "watch": ["lib", "../shared/lib", "../utils/lib", "../../.env"],
+    "ext": "ts,json",
+    "ignore": ["lib/**/*.test.ts"],
+    "exec": "tsc && tsx -r dotenv/config lib/app.ts dotenv_config_path=./../../.env"
+}
diff --git a/packages/persist/package.json b/packages/persist/package.json
@@ -18,6 +18,7 @@
     },
     "license": "SEE LICENSE IN LICENSE FILE IN GIT REPOSITORY",
     "dependencies": {
+        "@nangohq/utils": "file:../utils",
         "@nangohq/shared": "^0.39.8",
         "dd-trace": "5.2.0",
         "express": "^4.18.2",

diff --git a/packages/persist/tsconfig.json b/packages/persist/tsconfig.json
@@ -4,6 +4,6 @@
         "rootDir": "lib",
         "outDir": "dist"
     },
-    "references": [{ "path": "../shared" }],
+    "references": [{ "path": "../shared" }, { "path": "../utils" }],
     "include": ["lib/**/*"]
-}
+}
diff --git a/packages/runner/Dockerfile b/packages/runner/Dockerfile
@@ -10,6 +10,7 @@ WORKDIR /nango
 
 COPY packages/node-client/ packages/node-client/
 COPY packages/shared/ packages/shared/
+COPY packages/utils/ packages/utils/
 COPY packages/runner/ packages/runner/
 COPY package*.json ./
 

diff --git a/packages/runner/lib/app.ts b/packages/runner/lib/app.ts
@@ -1,12 +1,14 @@
 import './tracer.js';
 import { server } from './server.js';
-import { logger } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
+
+const { logger } = new Logger('Runner');
 
 try {
     const port = parseInt(process.argv[2] || '') || 3006;
     const id = process.argv[3] || process.env['RUNNER_ID'] || 'unknown-id';
     server.listen(port, () => {
-        logger.info(`🚀 Runner '${id}' ready at http://localhost:${port}`);
+        logger.info(`🚀 '${id}' ready at http://localhost:${port}`);
     });
 } catch (err) {
     logger.error(`Unable to start runner: ${JSON.stringify(err)}`);

diff --git a/packages/runner/lib/server.ts b/packages/runner/lib/server.ts
@@ -3,12 +3,15 @@ import * as trpcExpress from '@trpc/server/adapters/express';
 import express from 'express';
 import type { Request, Response, NextFunction } from 'express';
 import timeout from 'connect-timeout';
-import { logger, type NangoProps, type RunnerOutput } from '@nangohq/shared';
+import type { NangoProps, RunnerOutput } from '@nangohq/shared';
+import Logger from '@nangohq/utils/dist/logger.js';
 import { exec } from './exec.js';
 import { cancel } from './cancel.js';
 import superjson from 'superjson';
 import { fetch } from 'undici';
 
+const { logger } = new Logger('Runner');
+
 export const t = initTRPC.create({
     transformer: superjson
 });