feat: add Nango integrations setup for data syncing #144

coderabbitai · 2025-12-05T14:23:44Z

⚠️ Potential issue | 🟠 Major

🧩 Analysis chain

🌐 Web query:

Nango integration framework build artifacts deployment requirements

💡 Result:

Summary of key build-artifact / deployment requirements for Nango integrations:

Nango CLI + project layout: install the nango CLI (npm) and keep integrations in a version-controlled nango-integrations/ folder (nango init creates structure). [1][2]

Runtime tooling: Node.js/npm for building functions, and Docker (or Docker Compose) when using local/self‑hosted Nango or sample apps. [2][3][4]

Environment variables / secrets: provide NANGO_SECRET_KEY_DEV and NANGO_SECRET_KEY_PROD for CLI auth, set NANGO_HOSTPORT to your instance URL for self‑hosted, and any .env in ./nango-integrations with these values. CI deploys must supply those secrets. [1][2]

Encryption key (self-hosted): a persistent NANGO_ENCRYPTION_KEY is required for self‑hosted deployments (cannot be re‑generated later). [5]

Deployment commands / CI: use nango deploy (can target envs like dev/prod); CI should install nango CLI, load env secrets, and may pass flags like --auto-confirm or --allow-destructive when needed. [1][2][5]

Ports / infra (self-hosted): default OSS ports (server 3003, Postgres 5432) when using docker-compose; adapt as needed in .env/docker-compose. [4]

Best practices: keep integrations in source control, include .env templates, and automate deploys in CI with appropriate secret management. [2][3]

Sources: Nango CLI & env docs; Functions/setup and deploy guides; Sample app deployment; Self-hosting (docker compose); note on NANGO_ENCRYPTION_KEY. [1][2][3][4][5]

🏁 Script executed:

# Check if there are other similar compiled artifacts in the build directory fd -e cjs nango-integrations/build/ | head -20

Repository: drifter089/orgOS

Length of output: 465

🏁 Script executed:

# Look for build configuration and CI/CD setup fd -e json -e yaml -e yml -e toml . | grep -E "(package\.json|tsconfig|esbuild|webpack|build|ci)" | head -30

Repository: drifter089/orgOS

Length of output: 151

🏁 Script executed:

# Search for documentation about nango-integrations structure find . -name "README*" -o -name "*.md" | xargs grep -l "nango-integrations\|build artifact" 2>/dev/null | head -10

Repository: drifter089/orgOS

Length of output: 42

🏁 Script executed:

# Explore nango-integrations directory structure ls -la nango-integrations/ 2>/dev/null | head -20

Repository: drifter089/orgOS

Length of output: 620

🏁 Script executed:

# Check the actual build directory ls -la nango-integrations/build/ 2>/dev/null | head -30

Repository: drifter089/orgOS

Length of output: 423

🏁 Script executed:

# Check package.json build scripts cat nango-integrations/package.json | head -50

Repository: drifter089/orgOS

Length of output: 342

🏁 Script executed:

# Check .gitignore for build patterns cat .gitignore 2>/dev/null

Repository: drifter089/orgOS

Length of output: 874

🏁 Script executed:

# Look for nango CLI config (nango.yaml or similar) find nango-integrations -name "nango.yaml" -o -name "nango.yml" -o -name ".nangorc*" 2>/dev/null

Repository: drifter089/orgOS

Length of output: 42

🏁 Script executed:

# Verify the nango-integrations/.gitignore specifically cat nango-integrations/.gitignore

Repository: drifter089/orgOS

Length of output: 147

🏁 Script executed:

# Check if build files are tracked by git cd nango-integrations && git ls-files build/ 2>/dev/null || echo "Not in git or error"

Repository: drifter089/orgOS

Length of output: 182

🏁 Script executed:

# Look at the source TypeScript files find nango-integrations/github -name "*.ts" -type f | head -10

Repository: drifter089/orgOS

Length of output: 218

🏁 Script executed:

# Check git history to see if build files were recently added git log --oneline nango-integrations/build/ 2>/dev/null | head -5

Repository: drifter089/orgOS

Length of output: 127

🏁 Script executed:

# Verify the compilation flow - does nango compile generate these files? cat nango-integrations/tsconfig.json

Repository: drifter089/orgOS

Length of output: 986

Remove committed build artifacts from the nango-integrations/build directory.

The compiled .cjs files in nango-integrations/build/ are build artifacts generated by nango compile from TypeScript sources. Nango's own tsconfig.json explicitly excludes the build directory, indicating these files should not be in version control. They are regenerated during deployment via nango deploy. Remove all .cjs files from nango-integrations/build/ and add build/ to nango-integrations/.gitignore. Keep only the source .ts files in nango-integrations/github/.

🤖 Prompt for AI Agents

In nango-integrations/build/github_on-events_pre-connection-deletion.cjs (lines 1-41): this is a compiled build artifact that should not be committed; remove this .cjs file (and any other files under nango-integrations/build/), add build/ to nango-integrations/.gitignore, ensure only the original TypeScript source files remain under nango-integrations/github/, and update the commit so the build output is no longer tracked.

coderabbitai · 2025-12-05T14:23:44Z

⚠️ Potential issue | 🔴 Critical

🧩 Analysis chain

🏁 Script executed:

# Find the source TypeScript file find . -name "fetchIssues.ts" -type f

Repository: drifter089/orgOS

Length of output: 108

🌐 Web query:

GitHub REST API issue object body field null

💡 Result:

Common causes

The issue really has no body (empty) — then the JSON "body" is null.

You're requesting the default/other media type that doesn't return the raw "body" field; GitHub exposes different representations (body, body_text, body_html) only when the appropriate Accept media type is used.
What to do

Verify the issue actually has text in the web UI.

Request the body explicitly by sending an Accept header such as:

application/vnd.github.raw+json (returns body)

application/vnd.github.text+json (returns body_text)

application/vnd.github.html+json (returns body_html)

application/vnd.github.full+json (returns body, body_text, body_html)
References

GitHub REST issues docs (media types & body fields). [1] [2]

Sources
[1] REST API endpoints for issues — GitHub Docs. [turn0search0]
[2] REST API endpoints for issues (Enterprise) — GitHub Docs. [turn0search3]

🏁 Script executed:

cat -n ./nango-integrations/github/syncs/fetchIssues.ts

Repository: drifter089/orgOS

Length of output: 3295

Fix nullable body field in schema.

The body field is defined as z.string(), but GitHub's API returns null for issues without a description. This causes validation failures when syncing such issues. Update the schema in the source TypeScript file:

- body: z.string(), + body: z.string().nullable(),

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

var issueSchema = z.object({

id: z.string(),

owner: z.string(),

repo: z.string(),

issue_number: z.number(),

title: z.string(),

state: z.string(),

author: z.string(),

author_id: z.number(),

body: z.string(),

date_created: z.string(),

date_last_modified: z.string()

});

var issueSchema = z.object({

id: z.string(),

owner: z.string(),

repo: z.string(),

issue_number: z.number(),

title: z.string(),

state: z.string(),

author: z.string(),

author_id: z.number(),

body: z.string().nullable(),

date_created: z.string(),

date_last_modified: z.string()

});

🤖 Prompt for AI Agents

In nango-integrations/build/github_syncs_fetchIssues.cjs around lines 38 to 50, the issueSchema defines body as z.string() which fails when GitHub returns null; replace the body schema with a nullable string (e.g., change body: z.string() to body: z.string().nullable()) so validation accepts both string and null; update the source TypeScript schema (not just the built CJS) and rebuild to propagate the change.

coderabbitai · 2025-12-05T14:23:44Z

⚠️ Potential issue | 🟠 Major

Add error handling for individual repository failures.

The sync iterates through all repositories without try-catch blocks. If fetching issues from one repository fails (e.g., due to permissions or API errors), the entire sync will fail and subsequent repositories won't be processed.

Consider wrapping the per-repository logic in try-catch in the source TypeScript file:

for (const repo of repos) { try { const proxyConfig = { /* ... */ }; for await (const issueBatch of nango.paginate(proxyConfig)) { // ... existing logic } } catch (error) { await nango.log(`Failed to fetch issues from ${repo.owner.login}/${repo.name}: ${error}`); // Continue with next repository } }

🤖 Prompt for AI Agents

In nango-integrations/build/github_syncs_fetchIssues.cjs around lines 68 to 97, the loop over repos lacks per-repository error handling so a failure fetching one repo's issues can abort the whole sync; wrap the logic that builds proxyConfig and the for-await-of nango.paginate(...) processing (including filtering, mapping, batchSave and log) in a try-catch that on catch awaits nango.log with a message containing the repo owner/name and the caught error, then continues to the next repo so other repositories still get processed.

-Original file line number
+Diff line change
@@ Expand Up / @@ -8,7 +8,7 @@ const compat = new FlatCompat({ @@
     export default tseslint.config(
       {
-        ignores: [".next", "tests/**", "next-env.d.ts"],
+        ignores: [".next", "tests/**", "next-env.d.ts", "nango-integrations/**"],
       },
       ...compat.extends("next/core-web-vitals"),
       {
@@ Expand Down @@

-Original file line number
+Diff line change
@@ -0,0 +1,8 @@
+    # Environment files
+    .env
+    # Nango compiled output
+    .nango/
+    # Node modules
+    node_modules/

-Original file line number
+Diff line change
@@ -0,0 +1,74 @@
+    "use strict";
+    var __create = Object.create;
+    var __defProp = Object.defineProperty;
+    var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
+    var __getOwnPropNames = Object.getOwnPropertyNames;
+    var __getProtoOf = Object.getPrototypeOf;
+    var __hasOwnProp = Object.prototype.hasOwnProperty;
+    var __export = (target, all) => {
+      for (var name in all)
+        __defProp(target, name, { get: all[name], enumerable: true });
+    };
+    var __copyProps = (to, from, except, desc) => {
+      if (from && typeof from === "object" || typeof from === "function") {
+        for (let key of __getOwnPropNames(from))
+          if (!__hasOwnProp.call(to, key) && key !== except)
+            __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
+      }
+      return to;
+    };
+    var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps(
+      // If the importer is in node compatibility mode or this is not an ESM
+      // file that has been converted to a CommonJS file using a Babel-
+      // compatible transform (i.e. "__esModule" has not been set), then set
+      // "default" to the CommonJS "module.exports" for node compatibility.
+      isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target,
+      mod
+    ));
+    var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
+    // nango-integrations/github/actions/createIssue.ts
+    var createIssue_exports = {};
+    __export(createIssue_exports, {
+      default: () => createIssue_default
+    });
+    module.exports = __toCommonJS(createIssue_exports);
+    var z = __toESM(require("zod"), 1);
+    var issueSchema = z.object({
+      id: z.string(),
+      owner: z.string(),
+      repo: z.string(),
+      issue_number: z.number(),
+      title: z.string(),
+      state: z.string(),
+      author: z.string(),
+      author_id: z.number(),
+      body: z.string(),
+      date_created: z.string(),
+      date_last_modified: z.string()
+    });
+    var action = {
+      type: "action",
+      description: `Create an issue in GitHub`,
+      version: "1.0.0",
+      endpoint: {
+        method: "POST",
+        path: "/example/github/issues",
+        group: "Issues"
+      },
+      input: issueSchema,
+      output: z.void(),
+      // Action execution
+      exec: async (nango, input) => {
+        await nango.proxy({
+          endpoint: "/repos/NangoHQ/interactive-demo/issues",
+          data: {
+            title: `[demo] ${input.title}`,
+            body: `This issue was created automatically using Nango Action.`,
+            labels: ["automatic"]
+          }
+        });
+      }
+    };
+    var createIssue_default = action;
+    //# sourceMappingURL=data:application/json;base64,ewogICJ2ZXJzaW9uIjogMywKICAic291cmNlcyI6IFsibmFuZ28taW50ZWdyYXRpb25zL2dpdGh1Yi9hY3Rpb25zL2NyZWF0ZUlzc3VlLnRzIl0sCiAgInNvdXJjZXNDb250ZW50IjogWyJpbXBvcnQgeyBjcmVhdGVBY3Rpb24gfSBmcm9tICduYW5nbyc7XG5pbXBvcnQgKiBhcyB6IGZyb20gJ3pvZCc7XG5jb25zdCBpc3N1ZVNjaGVtYSA9IHoub2JqZWN0KHtcbiAgaWQ6IHouc3RyaW5nKCksXG4gIG93bmVyOiB6LnN0cmluZygpLFxuICByZXBvOiB6LnN0cmluZygpLFxuICBpc3N1ZV9udW1iZXI6IHoubnVtYmVyKCksXG4gIHRpdGxlOiB6LnN0cmluZygpLFxuICBzdGF0ZTogei5zdHJpbmcoKSxcbiAgYXV0aG9yOiB6LnN0cmluZygpLFxuICBhdXRob3JfaWQ6IHoubnVtYmVyKCksXG4gIGJvZHk6IHouc3RyaW5nKCksXG4gIGRhdGVfY3JlYXRlZDogei5zdHJpbmcoKSxcbiAgZGF0ZV9sYXN0X21vZGlmaWVkOiB6LnN0cmluZygpXG59KTtcbmNvbnN0IGFjdGlvbiA9IHtcbiAgdHlwZTogXCJhY3Rpb25cIixcbiAgZGVzY3JpcHRpb246IGBDcmVhdGUgYW4gaXNzdWUgaW4gR2l0SHViYCxcbiAgdmVyc2lvbjogJzEuMC4wJyxcbiAgZW5kcG9pbnQ6IHtcbiAgICBtZXRob2Q6ICdQT1NUJyxcbiAgICBwYXRoOiAnL2V4YW1wbGUvZ2l0aHViL2lzc3VlcycsXG4gICAgZ3JvdXA6ICdJc3N1ZXMnXG4gIH0sXG4gIGlucHV0OiBpc3N1ZVNjaGVtYSxcbiAgb3V0cHV0OiB6LnZvaWQoKSxcbiAgLy8gQWN0aW9uIGV4ZWN1dGlvblxuICBleGVjOiBhc3luYyAobmFuZ28sIGlucHV0KSA9PiB7XG4gICAgYXdhaXQgbmFuZ28ucHJveHkoe1xuICAgICAgZW5kcG9pbnQ6ICcvcmVwb3MvTmFuZ29IUS9pbnRlcmFjdGl2ZS1kZW1vL2lzc3VlcycsXG4gICAgICBkYXRhOiB7XG4gICAgICAgIHRpdGxlOiBgW2RlbW9dICR7aW5wdXQudGl0bGV9YCxcbiAgICAgICAgYm9keTogYFRoaXMgaXNzdWUgd2FzIGNyZWF0ZWQgYXV0b21hdGljYWxseSB1c2luZyBOYW5nbyBBY3Rpb24uYCxcbiAgICAgICAgbGFiZWxzOiBbJ2F1dG9tYXRpYyddXG4gICAgICB9XG4gICAgfSk7XG4gIH1cbn07XG5leHBvcnQgdHlwZSBOYW5nb0FjdGlvbkxvY2FsID0gUGFyYW1ldGVyczwodHlwZW9mIGFjdGlvbilbJ2V4ZWMnXT5bMF07XG5leHBvcnQgZGVmYXVsdCBhY3Rpb247Il0sCiAgIm1hcHBpbmdzIjogIjs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUNBLFFBQW1CO0FBQ25CLElBQU0sY0FBZ0IsU0FBTztBQUFBLEVBQzNCLElBQU0sU0FBTztBQUFBLEVBQ2IsT0FBUyxTQUFPO0FBQUEsRUFDaEIsTUFBUSxTQUFPO0FBQUEsRUFDZixjQUFnQixTQUFPO0FBQUEsRUFDdkIsT0FBUyxTQUFPO0FBQUEsRUFDaEIsT0FBUyxTQUFPO0FBQUEsRUFDaEIsUUFBVSxTQUFPO0FBQUEsRUFDakIsV0FBYSxTQUFPO0FBQUEsRUFDcEIsTUFBUSxTQUFPO0FBQUEsRUFDZixjQUFnQixTQUFPO0FBQUEsRUFDdkIsb0JBQXNCLFNBQU87QUFDL0IsQ0FBQztBQUNELElBQU0sU0FBUztBQUFBLEVBQ2IsTUFBTTtBQUFBLEVBQ04sYUFBYTtBQUFBLEVBQ2IsU0FBUztBQUFBLEVBQ1QsVUFBVTtBQUFBLElBQ1IsUUFBUTtBQUFBLElBQ1IsTUFBTTtBQUFBLElBQ04sT0FBTztBQUFBLEVBQ1Q7QUFBQSxFQUNBLE9BQU87QUFBQSxFQUNQLFFBQVUsT0FBSztBQUFBO0FBQUEsRUFFZixNQUFNLE9BQU8sT0FBTyxVQUFVO0FBQzVCLFVBQU0sTUFBTSxNQUFNO0FBQUEsTUFDaEIsVUFBVTtBQUFBLE1BQ1YsTUFBTTtBQUFBLFFBQ0osT0FBTyxVQUFVLE1BQU0sS0FBSztBQUFBLFFBQzVCLE1BQU07QUFBQSxRQUNOLFFBQVEsQ0FBQyxXQUFXO0FBQUEsTUFDdEI7QUFBQSxJQUNGLENBQUM7QUFBQSxFQUNIO0FBQ0Y7QUFFQSxJQUFPLHNCQUFROyIsCiAgIm5hbWVzIjogW10KfQo=

-Original file line number
+Diff line change
@@ -0,0 +1,41 @@
+    "use strict";
+    var __defProp = Object.defineProperty;
+    var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
+    var __getOwnPropNames = Object.getOwnPropertyNames;
+    var __hasOwnProp = Object.prototype.hasOwnProperty;
+    var __export = (target, all) => {
+      for (var name in all)
+        __defProp(target, name, { get: all[name], enumerable: true });
+    };
+    var __copyProps = (to, from, except, desc) => {
+      if (from && typeof from === "object" || typeof from === "function") {
+        for (let key of __getOwnPropNames(from))
+          if (!__hasOwnProp.call(to, key) && key !== except)
+            __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
+      }
+      return to;
+    };
+    var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
+    // nango-integrations/github/on-events/pre-connection-deletion.ts
+    var pre_connection_deletion_exports = {};
+    __export(pre_connection_deletion_exports, {
+      default: () => pre_connection_deletion_default,
+      onEvent: () => onEvent
+    });
+    module.exports = __toCommonJS(pre_connection_deletion_exports);
+    var onEvent = {
+      type: "onEvent",
+      event: "pre-connection-deletion",
+      // 'post-connection-creation' | 'validate-connection'
+      description: "This script is executed before a connection is deleted",
+      exec: async (nango) => {
+        await nango.log("Executed");
+      }
+    };
+    var pre_connection_deletion_default = onEvent;
+    // Annotate the CommonJS export names for ESM import in node:
+&& (module.exports = {
+      onEvent
+    });
+    //# sourceMappingURL=data:application/json;base64,ewogICJ2ZXJzaW9uIjogMywKICAic291cmNlcyI6IFsibmFuZ28taW50ZWdyYXRpb25zL2dpdGh1Yi9vbi1ldmVudHMvcHJlLWNvbm5lY3Rpb24tZGVsZXRpb24udHMiXSwKICAic291cmNlc0NvbnRlbnQiOiBbImltcG9ydCB7IGNyZWF0ZU9uRXZlbnQgfSBmcm9tICduYW5nbyc7XG5leHBvcnQgY29uc3Qgb25FdmVudCA9IHtcbiAgdHlwZTogXCJvbkV2ZW50XCIsXG4gIGV2ZW50OiAncHJlLWNvbm5lY3Rpb24tZGVsZXRpb24nLFxuICAvLyAncG9zdC1jb25uZWN0aW9uLWNyZWF0aW9uJyB8ICd2YWxpZGF0ZS1jb25uZWN0aW9uJ1xuICBkZXNjcmlwdGlvbjogJ1RoaXMgc2NyaXB0IGlzIGV4ZWN1dGVkIGJlZm9yZSBhIGNvbm5lY3Rpb24gaXMgZGVsZXRlZCcsXG4gIGV4ZWM6IGFzeW5jIG5hbmdvID0+IHtcbiAgICBhd2FpdCBuYW5nby5sb2coJ0V4ZWN1dGVkJyk7XG4gIH1cbn07XG5leHBvcnQgZGVmYXVsdCBvbkV2ZW50OyJdLAogICJtYXBwaW5ncyI6ICI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQ08sSUFBTSxVQUFVO0FBQUEsRUFDckIsTUFBTTtBQUFBLEVBQ04sT0FBTztBQUFBO0FBQUEsRUFFUCxhQUFhO0FBQUEsRUFDYixNQUFNLE9BQU0sVUFBUztBQUNuQixVQUFNLE1BQU0sSUFBSSxVQUFVO0FBQUEsRUFDNUI7QUFDRjtBQUNBLElBQU8sa0NBQVE7IiwKICAibmFtZXMiOiBbXQp9Cg==

-Original file line number
+Diff line change
@@ -0,0 +1,39 @@
+    import { createAction } from "nango";
+    import * as z from "zod";
+    const issueSchema = z.object({
+      id: z.string(),
+      owner: z.string(),
+      repo: z.string(),
+      issue_number: z.number(),
+      title: z.string(),
+      state: z.string(),
+      author: z.string(),
+      author_id: z.number(),
+      body: z.string(),
+      date_created: z.string(),
+      date_last_modified: z.string(),
+    });
+    const action = createAction({
+      description: `Create an issue in GitHub`,
+      version: "1.0.0",
+      endpoint: { method: "POST", path: "/example/github/issues", group: "Issues" },
+      input: issueSchema,
+      output: z.void(),
+      // Action execution
+      exec: async (nango, input) => {
+        await nango.proxy({
+          endpoint: "/repos/NangoHQ/interactive-demo/issues",
+          data: {
+            title: `[demo] ${input.title}`,
+            body: `This issue was created automatically using Nango Action.`,
+            labels: ["automatic"],
+          },
+        });
+      },
+    });
+    export type NangoActionLocal = Parameters<(typeof action)["exec"]>[0];
+    export default action;

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: add Nango integrations setup for data syncing #144

Uh oh!

Diff view

Diff view

There are no files selected for viewing

coderabbitai bot Dec 5, 2025

Uh oh!

coderabbitai bot Dec 5, 2025

Uh oh!

coderabbitai bot Dec 5, 2025

Uh oh!

Uh oh!

Uh oh!

feat: add Nango integrations setup for data syncing #144

Are you sure you want to change the base?

Uh oh!

feat: add Nango integrations setup for data syncing #144

Uh oh!

Uh oh!

Diff view

Diff view

There are no files selected for viewing

coderabbitai bot Dec 5, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 5, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 5, 2025

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!