improvement(aec): add more detail to env update events (#7830)

Co-authored-by: Jon Edvald <edvald@gmail.com>

Author: edvald-garden

core/package.json

@@ -26,7 +26,7 @@
   "types": "build/src/index.d.ts",
   "dependencies": {
     "@bufbuild/protobuf": "2.8.0",
-    "@buf/garden_grow-platform.bufbuild_es": "2.8.0-20251110103340-a7d565dfe8c7.1",
+    "@buf/garden_grow-platform.bufbuild_es": "2.8.0-20251119201656-897f960f13d3.1",
     "@codenamize/codenamize": "^1.1.1",
     "@connectrpc/connect": "2.1.0",
     "@connectrpc/connect-node": "2.0.4",

core/src/cloud/api/grpc-event-converter.ts

@@ -221,6 +221,7 @@ export class GrpcEventConverter {
           aecAgentInfo: payload.aecAgentInfo,
           projectId: payload.projectId,
           timestamp: timestampFromDate(new Date(payload.timestamp)),
+          lastDeployed: payload.lastDeployed,
           actionTriggered: payload.actionTriggered
             ? aecEnvironmentUpdateActionTriggeredMap[payload.actionTriggered]
             : undefined,
@@ -230,6 +231,7 @@ export class GrpcEventConverter {
           inProgress: payload.inProgress,
           error: payload.error,
           success: payload.success,
+          resource: payload.resource,
         }),
       }),
     ]

core/src/events/events.ts

@@ -316,6 +316,7 @@ export interface AecAgentEnvironmentUpdate {
   error: boolean
   actionTriggered?: AecAction
   success?: boolean
+  resource: string[]
 }
 
 export type EventName = keyof Events

core/src/plugins/kubernetes/commands/aec-agent.ts

@@ -251,14 +251,22 @@ async function handler({ ctx, log, args, garden }: PluginCommandParams<Kubernete
   return { result }
 }
 
-function emitEnvironmentStatus(events: EventBus, event: EventPayload<"aecAgentEnvironmentUpdate">) {
+function emitEnvironmentStatus(
+  events: EventBus,
+  namespaceName: string,
+  event: Omit<EventPayload<"aecAgentEnvironmentUpdate">, "resource" | "timestamp">
+) {
   const key = `${event.projectId}-${event.environmentType}-${event.environmentName}`
   const lastStatus = lastEnvironmentStatus[key]
   if (lastStatus === event.statusDescription) {
     return
   }
   lastEnvironmentStatus[key] = event.statusDescription
-  events.emit("aecAgentEnvironmentUpdate", event)
+  events.emit("aecAgentEnvironmentUpdate", {
+    ...event,
+    timestamp: new Date().toISOString(),
+    resource: [`namespace/${namespaceName}`],
+  })
 }
 
 async function cleanupLoop({
@@ -332,8 +340,7 @@ async function cleanupLoop({
 
         // Skip sending events if the namespace is not configured for AEC
         if (result.aecConfigured) {
-          emitEnvironmentStatus(events, {
-            timestamp: new Date().toISOString(),
+          emitEnvironmentStatus(events, namespaceName, {
             aecAgentInfo,
             projectId,
             environmentType,
@@ -350,8 +357,7 @@ async function cleanupLoop({
       } catch (e) {
         const msg = `Unexpected error: ${e}`
         nsLog.error({ msg })
-        emitEnvironmentStatus(events, {
-          timestamp: new Date().toISOString(),
+        emitEnvironmentStatus(events, namespaceName, {
           aecAgentInfo,
           projectId,
           environmentType,
@@ -658,8 +664,7 @@ export async function checkAndCleanupNamespace({
     log.info({ msg: `Pausing workloads...` })
 
     if (!dryRun) {
-      emitEnvironmentStatus(events, {
-        timestamp: new Date().toISOString(),
+      emitEnvironmentStatus(events, namespaceName, {
         aecAgentInfo,
         projectId,
         environmentType,
@@ -709,8 +714,7 @@ export async function checkAndCleanupNamespace({
     log.info({ msg: `Cleaning up namespace` })
 
     if (!dryRun) {
-      emitEnvironmentStatus(events, {
-        timestamp: new Date().toISOString(),
+      emitEnvironmentStatus(events, namespaceName, {
         aecAgentInfo,
         projectId,
         environmentType,

core/test/unit/src/cloud/grpc-event-stream.ts

@@ -178,6 +178,7 @@ describe("GrpcEventStream", () => {
       inProgress: false,
       error: false,
       success: false,
+      resource: ["namespace/fake-namespace-name"],
     })
     await bufferedEventStream.close()
     expect(receivedEvents.length).to.equal(1)