chore: correct event structure

Author: adityachoudhari26

packages/events/src/kafka/event-dispatch/job.ts

@@ -105,7 +105,10 @@ const convertJobToGoEvent = async (
 ): Promise<GoMessage<keyof GoEventPayload>> => ({
   workspaceId,
   eventType,
-  data: await getOapiJob(job),
+  data: {
+    job: await getOapiJob(job),
+    id: job.id,
+  },
   timestamp: Date.now(),
 });
 

packages/events/src/kafka/events.ts

@@ -186,7 +186,7 @@ export type GoEventPayload = {
   [Event.PolicyCreated]: WorkspaceEngine["schemas"]["Policy"];
   [Event.PolicyUpdated]: WorkspaceEngine["schemas"]["Policy"];
   [Event.PolicyDeleted]: WorkspaceEngine["schemas"]["Policy"];
-  [Event.JobUpdated]: WorkspaceEngine["schemas"]["Job"];
+  [Event.JobUpdated]: WorkspaceEngine["schemas"]["JobUpdateEvent"];
   [Event.UserApprovalRecordCreated]: WorkspaceEngine["schemas"]["UserApprovalRecord"];
   [Event.UserApprovalRecordUpdated]: WorkspaceEngine["schemas"]["UserApprovalRecord"];
   [Event.UserApprovalRecordDeleted]: WorkspaceEngine["schemas"]["UserApprovalRecord"];

packages/workspace-engine-sdk/src/schema.ts

@@ -433,6 +433,24 @@ export interface components {
       | "invalidIntegration"
       | "externalRunNotFound"
       | "successful";
+    JobUpdateEvent: {
+      agentId?: string;
+      externalId?: string;
+      fieldsToUpdate?: (
+        | "completedAt"
+        | "createdAt"
+        | "externalId"
+        | "id"
+        | "jobAgentConfig"
+        | "jobAgentId"
+        | "releaseId"
+        | "startedAt"
+        | "status"
+        | "updatedAt"
+      )[];
+      id?: string;
+      job: components["schemas"]["Job"];
+    } & (unknown | unknown);
     JsonSelector: {
       json: Record<string, never>;
     };