fix: add logs to investigate how long it takes to process upserted resource

Author: adityachoudhari26

apps/event-worker/src/utils/upsert-release-targets.ts

@@ -14,44 +14,35 @@ const getReleaseTargetInsertsForSystem = async (
     deployments: SCHEMA.Deployment[];
   },
 ): Promise<ReleaseTargetIdentifier[]> => {
-  logger.info(`processing system ${system.id} - ${system.name}`);
-
   const envs = system.environments.filter((e) => isPresent(e.resourceSelector));
   const { deployments } = system;
 
   const maybeTargetsPromises = envs.flatMap((env) =>
     deployments.map(async (dep) => {
-      logger.info(
-        `processing pair deployment ${dep.id} - ${dep.name} with env ${env.id} - ${env.name}`,
-      );
-      // const resource = await db.query.resource.findFirst({
-      //   where: and(
-      //     eq(SCHEMA.resource.id, resourceId),
-      //     SCHEMA.resourceMatchesMetadata(db, env.resourceSelector),
-      //     SCHEMA.resourceMatchesMetadata(db, dep.resourceSelector),
-      //   ),
-      // });
+      const resource = await db.query.resource.findFirst({
+        where: and(
+          eq(SCHEMA.resource.id, resourceId),
+          SCHEMA.resourceMatchesMetadata(db, env.resourceSelector),
+          SCHEMA.resourceMatchesMetadata(db, dep.resourceSelector),
+        ),
+      });
 
-      // if (resource == null) return null;
-      // return { environmentId: env.id, deploymentId: dep.id };
+      if (resource == null) return null;
+      return { environmentId: env.id, deploymentId: dep.id };
     }),
   );
 
-  return [];
-
-  // const targets = await Promise.all(maybeTargetsPromises).then((results) =>
-  //   results.filter(isPresent),
-  // );
+  const targets = await Promise.all(maybeTargetsPromises).then((results) =>
+    results.filter(isPresent),
+  );
 
-  // return targets.map((t) => ({ ...t, resourceId }));
+  return targets.map((t) => ({ ...t, resourceId }));
 };
 
 export const upsertReleaseTargets = async (
   db: Tx,
   resource: SCHEMA.Resource,
 ) => {
-  logger.info(`Upserting release targets for resource ${resource.id}`);
-
   const workspace = await db.query.workspace.findFirst({
     where: eq(SCHEMA.workspace.id, resource.workspaceId),
     with: { systems: { with: { environments: true, deployments: true } } },
@@ -62,9 +53,7 @@ export const upsertReleaseTargets = async (
     workspace.systems.map((system) =>
       getReleaseTargetInsertsForSystem(db, resource.id, system),
     ),
-  );
-
-  // .then((results) => results.flat());
+  ).then((results) => results.flat());
 
   // if (releaseTargetInserts.length === 0) return [];
   // return db

apps/event-worker/src/workers/updated-resources/index.ts

@@ -10,17 +10,15 @@ import { dispatchExitHooks } from "./dispatch-exit-hooks.js";
 export const updatedResourceWorker = createWorker(
   Channel.UpdatedResource,
   async ({ data: resource }) => {
-    console.log("updated resource", resource);
+    logger.info(`started processing updated resource ${resource.id}`);
 
-    await db.transaction(async (tx) => {
-      const currentReleaseTargets = await tx.query.releaseTarget.findMany({
-        where: eq(SCHEMA.releaseTarget.resourceId, resource.id),
-      });
+    const currentReleaseTargets = await db.query.releaseTarget.findMany({
+      where: eq(SCHEMA.releaseTarget.resourceId, resource.id),
+    });
 
-      await upsertReleaseTargets(tx, resource);
+    await upsertReleaseTargets(db, resource);
 
-      logger.info(`found ${currentReleaseTargets.length} release targets`);
-    });
+    logger.info(`finished processing updated resource ${resource.id}`);
 
     return;