chore: update source and other logic

Author: skwowet

services/libs/data-access-layer/src/enrichment/organizationEnrichmentCache/index.ts

@@ -1,4 +1,4 @@
-import { OrganizationEnrichmentSource } from '@crowd/types'
+import { IOrganizationEnrichmentCache, OrganizationEnrichmentSource } from '@crowd/types'
 
 import { QueryExecutor } from '../../queryExecutor'
 
@@ -7,20 +7,20 @@ export async function insertOrganizationEnrichmentCache<T>(
   organizationId: string,
   data: T,
   source: OrganizationEnrichmentSource,
-) {
-  return qx.result(
+): Promise<void> {
+  await qx.result(
     `insert into "organizationEnrichmentCache" ("organizationId", "data", "source", "createdAt", "updatedAt")
         values ($(organizationId), $(data), $(source), now(), now())
         on conflict ("organizationId", "source") do update set "data" = $(data), "updatedAt" = now()`,
     { organizationId, data, source },
   )
 }
 
-export async function findOrganizationEnrichmentCache(
+export async function findOrganizationEnrichmentCache<T>(
   qx: QueryExecutor,
   organizationId: string,
   source: OrganizationEnrichmentSource,
-) {
+): Promise<IOrganizationEnrichmentCache<T> | null> {
   return qx.selectOneOrNone(
     `select * from "organizationEnrichmentCache" where "organizationId" = $(organizationId) and "source" = $(source)`,
     { organizationId, source },
@@ -32,8 +32,8 @@ export async function updateOrganizationEnrichmentCache<T>(
   organizationId: string,
   data: T,
   source: OrganizationEnrichmentSource,
-) {
-  return qx.result(
+): Promise<void> {
+  await qx.result(
     `update "organizationEnrichmentCache" set "data" = $(data), "updatedAt" = now() where "organizationId" = $(organizationId) and "source" = $(source)`,
     { organizationId, data, source },
   )

services/libs/types/src/enrichment.ts

@@ -1,4 +1,4 @@
-import { MemberEnrichmentSource } from './enums'
+import { MemberEnrichmentSource, OrganizationEnrichmentSource } from './enums'
 import { IMemberIdentity, IMemberReach } from './members'
 import { IOrganizationIdentity } from './organizations'
 
@@ -55,3 +55,11 @@ export interface IMemberOriginalData {
   // memberOrganizations table data
   organizations: IMemberOrganizationData[]
 }
+
+export interface IOrganizationEnrichmentCache<T> {
+  createdAt: string
+  updatedAt: string
+  organizationId: string
+  data: T
+  source: OrganizationEnrichmentSource
+}

services/libs/types/src/enums/enrichment.ts

@@ -19,5 +19,5 @@ export enum MemberEnrichmentMaterializedView {
 }
 
 export enum OrganizationEnrichmentSource {
-  CLEARBIT = 'clearbit',
-}
+  INTERNAL_API = 'internal-api',
+}