Nango integration & Removal of tenantId from many places (#2870)

Co-authored-by: Joana Maia <[email protected]>

Author: themarolt

backend/.env.dist.local

@@ -165,3 +165,5 @@ CROWD_QUESTDB_SQL_PASSWORD=quest
 CROWD_QUESTDB_SQL_DATABASE=qdb
 CROWD_QUESTDB_ILP_HOST=localhost
 CROWD_QUESTDB_ILP_PORT=9000
+
+CROWD_GITHUB_IS_SNOWFLAKE_ENABLED=false

backend/config/custom-environment-variables.json

@@ -127,7 +127,9 @@
   },
   "nango": {
     "url": "CROWD_NANGO_URL",
-    "secretKey": "CROWD_NANGO_SECRET_KEY"
+    "secretKey": "CROWD_NANGO_SECRET_KEY",
+    "cloudSecretKey": "NANGO_CLOUD_SECRET_KEY",
+    "cloudIntegrations": "NANGO_CLOUD_INTEGRATIONS"
   },
   "enrichment": {
     "url": "CROWD_ENRICHMENT_PROGAI_URL",

backend/config/default.json

@@ -52,5 +52,6 @@
   "openStatusApi": {},
   "gitlab": {},
   "jiraIssueReporter": {},
-  "snowflake": {}
+  "snowflake": {},
+  "nango": {}
 }

backend/package.json

@@ -54,14 +54,15 @@
     "@crowd/data-access-layer": "workspace:*",
     "@crowd/integrations": "workspace:*",
     "@crowd/logging": "workspace:*",
+    "@crowd/nango": "workspace:*",
     "@crowd/opensearch": "workspace:*",
     "@crowd/questdb": "workspace:*",
     "@crowd/queue": "workspace:*",
     "@crowd/redis": "workspace:*",
+    "@crowd/snowflake": "workspace:*",
     "@crowd/telemetry": "workspace:*",
     "@crowd/temporal": "workspace:*",
     "@crowd/types": "workspace:*",
-    "@crowd/snowflake": "workspace:*",
     "@google-cloud/storage": "5.3.0",
     "@octokit/auth-app": "^3.6.1",
     "@octokit/core": "^6.1.2",

backend/src/api/activity/activityAddWithMember.ts

@@ -8,7 +8,7 @@ import PermissionChecker from '../../services/user/permissionChecker'
  * @tag Activities
  * @security Bearer
  * @description Create or update an activity with a member
- * Activity existence is checked by sourceId and tenantId
+ * Activity existence is checked by sourceId
  * Member existence is checked by platform and username
  * @bodyContent {ActivityUpsertWithMemberInput} application/json
  * @response 200 - Ok

backend/src/api/apiResponseHandler.ts

@@ -46,9 +46,12 @@ export default class ApiResponseHandler extends LoggerBase {
     } else if (error && error.message === 'stream is not readable') {
       res.status(400).send('Request interrupted')
     } else {
-      if (!error.code) {
+      if (error.code && (!Number.isInteger(error.code) || error.code < 100 || error.code > 599)) {
+        error.code = 500
+      } else if (!error.code) {
         error.code = 500
       }
+
       req.log.error(
         error,
         { code: error.code, url: req.url, method: req.method, query: req.query, body: req.body },

backend/src/api/auth/authSignIn.ts

@@ -1,4 +1,4 @@
-import { getDefaultTenantId } from '@crowd/common'
+import { DEFAULT_TENANT_ID } from '@crowd/common'
 
 import AuthService from '../../services/auth/authService'
 
@@ -7,7 +7,7 @@ export default async (req, res) => {
     req.body.email,
     req.body.password,
     req.body.invitationToken,
-    getDefaultTenantId(),
+    DEFAULT_TENANT_ID,
     req,
   )
 

backend/src/api/auth/authSignUp.ts

@@ -1,4 +1,4 @@
-import { getDefaultTenantId } from '@crowd/common'
+import { DEFAULT_TENANT_ID } from '@crowd/common'
 
 import AuthService from '../../services/auth/authService'
 
@@ -10,7 +10,7 @@ export default async (req, res) => {
     req.body.email,
     req.body.password,
     req.body.invitationToken,
-    getDefaultTenantId(),
+    DEFAULT_TENANT_ID,
     req.body.firstName,
     req.body.lastName,
     req.body.acceptedTermsAndPrivacy,

backend/src/api/auth/authSocial.ts

@@ -1,6 +1,6 @@
 import passport from 'passport'
 
-import { getDefaultTenantId } from '@crowd/common'
+import { DEFAULT_TENANT_ID } from '@crowd/common'
 import { getServiceChildLogger } from '@crowd/logging'
 
 import { API_CONFIG, GITHUB_CONFIG, GOOGLE_CONFIG } from '../../conf'
@@ -22,7 +22,7 @@ export default (app, routes) => {
   routes.post('/auth/social/onboard', async (req, res) => {
     const payload = await AuthService.handleOnboard(
       req.currentUser,
-      { invitationToken: req.body.invitationToken, tenantId: getDefaultTenantId() },
+      { invitationToken: req.body.invitationToken, tenantId: DEFAULT_TENANT_ID },
       req,
     )
 

backend/src/api/auth/ssoCallback.ts

@@ -1,7 +1,7 @@
 import jwt from 'jsonwebtoken'
 import jwksClient from 'jwks-rsa'
 
-import { Error401, getDefaultTenantId } from '@crowd/common'
+import { DEFAULT_TENANT_ID, Error401 } from '@crowd/common'
 
 import { AUTH0_CONFIG } from '../../conf'
 import AuthService from '../../services/auth/authService'
@@ -22,7 +22,7 @@ async function getKey(header, callback) {
 
 export default async (req, res) => {
   const { idToken, invitationToken } = req.body
-  const tenantId = getDefaultTenantId()
+  const tenantId = DEFAULT_TENANT_ID
 
   try {
     const verifyToken = new Promise((resolve, reject) => {