fix: only added topic (#3365)

Author: rebelchris

__tests__/workers/cdc/primary.ts

@@ -6917,10 +6917,10 @@ describe('organization', () => {
 
     expect(triggerTypedEvent).toHaveBeenCalledTimes(2);
     expect(jest.mocked(triggerTypedEvent).mock.calls[0][1]).toEqual(
-      'api.v1.opportunity-updated',
+      'api.v1.opportunity-added',
     );
     expect(jest.mocked(triggerTypedEvent).mock.calls[1][1]).toEqual(
-      'api.v1.opportunity-updated',
+      'api.v1.opportunity-added',
     );
   });
 

src/common/opportunity/pubsub.ts

@@ -334,12 +334,10 @@ export const notifyJobOpportunity = async ({
   con,
   logger,
   opportunityId,
-  isUpdate = false,
 }: {
   con: DataSource;
   logger: FastifyBaseLogger;
   opportunityId: string;
-  isUpdate?: boolean;
 }) => {
   const [opportunity, organization, keywords, users, locations] =
     await queryReadReplica(con, async ({ queryRunner }) => {
@@ -458,11 +456,8 @@ export const notifyJobOpportunity = async ({
     excludedUserIds,
   });
 
-  const topicName = isUpdate
-    ? 'api.v1.opportunity-updated'
-    : 'api.v1.opportunity-added';
   try {
-    await triggerTypedEvent(logger, topicName, message);
+    await triggerTypedEvent(logger, 'api.v1.opportunity-added', message);
   } catch (_err) {
     const err = _err as Error;
     logger.error({ err, message }, 'failed to send opportunity event');

src/workers/cdc/primary.ts

@@ -1388,7 +1388,6 @@ const onOpportunityChange = async (
       con,
       logger,
       opportunityId: data.payload.after!.id,
-      isUpdate: true,
     });
     if (data.payload.after?.state !== OpportunityState.LIVE) {
       await con
@@ -1447,7 +1446,6 @@ const onOrganizationChange = async (
           con,
           logger,
           opportunityId: opportunity.id,
-          isUpdate: true,
         });
       }),
     );