add plan to unleash context

services/apps/merge_suggestions_worker/src/activities/getAllTenants.ts

@@ -1,10 +1,10 @@
-import { ITenantId } from 'types'
+import { ITenant } from 'types'
 import { svc } from '../main'
 import TenantRepository from 'repo/tenant.repo'
 import { isFeatureEnabled } from '@crowd/feature-flags'
 import { FeatureFlag } from '@crowd/types'
 
-export async function getAllTenants(): Promise<ITenantId[]> {
+export async function getAllTenants(): Promise<ITenant[]> {
   const tenantRepository = new TenantRepository(svc.postgres.writer.connection(), svc.log)
   const tenants = await tenantRepository.getAllTenants()
 
@@ -15,6 +15,7 @@ export async function getAllTenants(): Promise<ITenantId[]> {
       async () => {
         return {
           tenantId: tenant.tenantId,
+          plan: tenant.plan,
         }
       },
       svc.unleash,

services/apps/merge_suggestions_worker/src/repo/tenant.repo.ts

@@ -1,18 +1,18 @@
 import { DbConnection, DbTransaction } from '@crowd/database'
 import { Logger } from '@crowd/logging'
-import { ITenantId } from 'types'
+import { ITenant } from 'types'
 
 class TenantRepository {
   constructor(
     private readonly connection: DbConnection | DbTransaction,
     private readonly log: Logger,
   ) {}
 
-  async getAllTenants(): Promise<ITenantId[]> {
-    let rows: ITenantId[] = []
+  async getAllTenants(): Promise<ITenant[]> {
+    let rows: ITenant[] = []
     try {
       rows = await this.connection.query(`
-        SELECT id as "tenantId"
+        SELECT id as "tenantId", plan
         FROM tenants WHERE "deletedAt" IS NULL;
       `)
     } catch (err) {

services/apps/merge_suggestions_worker/src/types.ts

@@ -1,5 +1,6 @@
-export interface ITenantId {
+export interface ITenant {
   tenantId: string
+  plan: string
 }
 
 interface ITermFilter {