Enhancement/org enrichment with temporal c 2905

.github/workflows/lf-production-deploy-new.yaml

@@ -491,4 +491,4 @@ jobs:
         with:
           service: script-executor
           image: ${{ needs.build-and-push-script-executor.outputs.image }}
-          cluster: ${{ env.CROWD_CLUSTER }}
+          cluster: ${{ env.CROWD_CLUSTER }}

.github/workflows/lf-staging-deploy-organizations-enrichment-worker.yaml

@@ -0,0 +1,60 @@
+name: LF Staging Deploy Organizations Enrichment Worker
+
+on:
+  push:
+    branches:
+      - 'lf-staging/**'
+      - 'lf-staging-**'
+    paths:
+      - 'services/libs/**'
+      - 'services/apps/premium/organizations_enrichment_worker/**'
+
+env:
+  DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
+  DOCKERHUB_PASSWORD: ${{ secrets.DOCKERHUB_PASSWORD }}
+  CROWD_CLUSTER: ${{ secrets.LF_STAGING_CLUSTER_NAME }}
+  CROWD_ROLE_ARN: ${{ secrets.LF_STAGING_CLUSTER_ROLE_ARN }}
+  AWS_ACCESS_KEY_ID: ${{ secrets.LF_AWS_ACCESS_KEY_ID }}
+  AWS_SECRET_ACCESS_KEY: ${{ secrets.LF_AWS_SECRET_ACCESS_KEY }}
+  AWS_REGION: ${{ secrets.LF_AWS_REGION }}
+  SLACK_CHANNEL: deploys-lf-staging
+  SLACK_WEBHOOK: ${{ secrets.LF_STAGING_SLACK_CHANNEL_HOOK }}
+
+jobs:
+  build-and-push:
+    runs-on: ubuntu-latest
+    outputs:
+      image: ${{ steps.image.outputs.IMAGE }}
+    defaults:
+      run:
+        shell: bash
+
+    steps:
+      - name: Check out repository code
+        uses: actions/checkout@v2
+
+      - uses: ./.github/actions/build-docker-image
+        id: image-builder
+        with:
+          image: organizations-enrichment-worker
+
+      - name: Set docker image output
+        id: image
+        run: echo "IMAGE=${{ steps.image-builder.outputs.image }}" >> $GITHUB_OUTPUT
+
+  deploy-organizations-enrichment-worker:
+    needs: build-and-push
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        shell: bash
+
+    steps:
+      - name: Check out repository code
+        uses: actions/checkout@v2
+
+      - uses: ./.github/actions/deploy-service
+        with:
+          service: organizations-enrichment-worker
+          image: ${{ needs.build-and-push.outputs.image }}
+          cluster: ${{ env.CROWD_CLUSTER }}

.github/workflows/staging-deploy-organizations-enrichment-worker.yaml

@@ -0,0 +1,60 @@
+name: Staging Deploy Organizations Enrichment Worker
+
+on:
+  push:
+    branches:
+      - 'staging/**'
+      - 'staging-**'
+    paths:
+      - 'services/libs/**'
+      - 'services/apps/premium/organizations_enrichment_worker/**'
+
+env:
+  DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
+  DOCKERHUB_PASSWORD: ${{ secrets.DOCKERHUB_PASSWORD }}
+  CROWD_CLUSTER: ${{ secrets.STAGING_CLUSTER_NAME }}
+  CROWD_ROLE_ARN: ${{ secrets.STAGING_CLUSTER_ROLE_ARN }}
+  AWS_ACCESS_KEY_ID: ${{ secrets.AWS_ACCESS_KEY_ID }}
+  AWS_SECRET_ACCESS_KEY: ${{ secrets.AWS_SECRET_ACCESS_KEY }}
+  AWS_REGION: ${{ secrets.AWS_REGION }}
+  SLACK_CHANNEL: deploys-staging
+  SLACK_WEBHOOK: ${{ secrets.STAGING_SLACK_CHANNEL_HOOK }}
+
+jobs:
+  build-and-push:
+    runs-on: ubuntu-latest
+    outputs:
+      image: ${{ steps.image.outputs.IMAGE }}
+    defaults:
+      run:
+        shell: bash
+
+    steps:
+      - name: Check out repository code
+        uses: actions/checkout@v2
+
+      - uses: ./.github/actions/build-docker-image
+        id: image-builder
+        with:
+          image: organizations-enrichment-worker
+
+      - name: Set docker image output
+        id: image
+        run: echo "IMAGE=${{ steps.image-builder.outputs.image }}" >> $GITHUB_OUTPUT
+
+  deploy-organizations-enrichment-worker:
+    needs: build-and-push
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        shell: bash
+
+    steps:
+      - name: Check out repository code
+        uses: actions/checkout@v2
+
+      - uses: ./.github/actions/deploy-service
+        with:
+          service: organizations-enrichment-worker
+          image: ${{ needs.build-and-push.outputs.image }}
+          cluster: ${{ env.CROWD_CLUSTER }}

backend/src/api/plan/stripe/checkout.ts

@@ -1,4 +1,5 @@
 import { Error400, Error403 } from '@crowd/common'
+import { TenantPlans } from '@crowd/types'
 import { PLANS_CONFIG } from '../../../conf'
 import Plans from '../../../security/plans'
 import TenantService from '../../../services/tenantService'
@@ -19,7 +20,7 @@ export default async (req, res) => {
   }
 
   if (
-    currentTenant.plan !== Plans.values.essential &&
+    currentTenant.plan !== TenantPlans.Essential &&
     currentTenant.planStatus !== 'cancel_at_period_end' &&
     currentTenant.planUserId !== currentUser.id
   ) {

backend/src/api/plan/stripe/portal.ts

@@ -1,6 +1,6 @@
 import { Error400, Error403 } from '@crowd/common'
+import { TenantPlans } from '@crowd/types'
 import { PLANS_CONFIG } from '../../../conf'
-import Plans from '../../../security/plans'
 import TenantService from '../../../services/tenantService'
 import { tenantSubdomain } from '../../../services/tenantSubdomain'
 
@@ -19,7 +19,7 @@ export default async (req, res) => {
   }
 
   if (
-    currentTenant.plan !== Plans.values.essential &&
+    currentTenant.plan !== TenantPlans.Essential &&
     currentTenant.planStatus !== 'cancel_at_period_end' &&
     currentTenant.planUserId !== currentUser.id
   ) {

backend/src/api/premium/enrichment/memberEnrichBulk.ts

@@ -1,13 +1,12 @@
 import { RedisCache } from '@crowd/redis'
 import { getServiceLogger } from '@crowd/logging'
 import { Error403 } from '@crowd/common'
-import { FeatureFlag, FeatureFlagRedisKey } from '@crowd/types'
+import { FeatureFlag, FeatureFlagRedisKey, PLAN_LIMITS } from '@crowd/types'
 import { getSecondsTillEndOfMonth } from '../../../utils/timing'
 import Permissions from '../../../security/permissions'
 import identifyTenant from '../../../segment/identifyTenant'
 import PermissionChecker from '../../../services/user/permissionChecker'
 import track from '../../../segment/track'
-import { PLAN_LIMITS } from '../../../feature-flags/isFeatureEnabled'
 import SequelizeRepository from '../../../database/repositories/sequelizeRepository'
 import { getNodejsWorkerEmitter } from '@/serverless/utils/serviceSQS'