Implement evt of clusterEventsMonitor usecase

web/src/core/usecases/clusterEventsMonitor/evt.ts

@@ -0,0 +1,31 @@
+import type { CreateEvt } from "core/bootstrap";
+import { Evt } from "evt";
+
+export const createEvt = (({ evtAction }) => {
+    const evtOut = Evt.create<{
+        actionName: "display notification";
+        severity: "warning" | "error";
+        message: string;
+    }>();
+
+    evtAction.$attach(
+        action =>
+            action.usecaseName === "clusterEventsMonitor" &&
+            action.actionName === "clusterEventReceived"
+                ? [action.payload]
+                : null,
+        ({ clusterEvent }) => {
+            if (clusterEvent.severity === "info") {
+                return;
+            }
+
+            evtOut.post({
+                "actionName": "display notification",
+                "message": clusterEvent.message,
+                "severity": clusterEvent.severity
+            });
+        }
+    );
+
+    return evtOut;
+}) satisfies CreateEvt;

web/src/core/usecases/clusterEventsMonitor/selectors.ts

@@ -0,0 +1,45 @@
+import type { State as RootState } from "core/bootstrap";
+import * as projectManagement from "core/usecases/projectManagement";
+import { createSelector } from "clean-architecture";
+import { name } from "./state";
+
+const state = (rootState: RootState) => rootState[name];
+
+const scopedState = createSelector(
+    state,
+    projectManagement.selectors.currentProject,
+    (state, currentProject) => {
+        const scopedState = state.clusterEventsByProjectId[currentProject.id];
+
+        if (scopedState === undefined) {
+            return {
+                "clusterEvents": [],
+                "notificationCheckoutTime": 0
+            };
+        }
+
+        return scopedState;
+    }
+);
+
+const clusterEvents = createSelector(scopedState, scopedState => {
+    const { clusterEvents, notificationCheckoutTime } = scopedState;
+
+    return clusterEvents.map(clusterEvent => ({
+        ...clusterEvent,
+        "isHighlighted":
+            clusterEvent.severity !== "info" &&
+            clusterEvent.timestamp > notificationCheckoutTime
+    }));
+});
+
+const notificationsCount = createSelector(
+    clusterEvents,
+    clusterEvents =>
+        clusterEvents.filter(clusterEvent => clusterEvent.isHighlighted).length
+);
+
+export const selectors = {
+    clusterEvents,
+    notificationsCount
+};

web/src/core/usecases/clusterEvents/state.ts → web/src/core/usecases/clusterEventsMonitor/state.ts

@@ -17,7 +17,7 @@ export type State = {
     >;
 };
 
-export const name = "custerEvents";
+export const name = "clusterEventsMonitor";
 
 export const { reducer, actions } = createUsecaseActions({
     name,

web/src/core/usecases/index.ts

@@ -1,5 +1,6 @@
 import * as autoLogoutCountdown from "./autoLogoutCountdown";
 import * as catalog from "./catalog";
+import * as clusterEventsMonitor from "./clusterEventsMonitor";
 import * as deploymentRegionManagement from "./deploymentRegionManagement";
 import * as fileExplorer from "./fileExplorer";
 import * as secretExplorer from "./secretExplorer";
@@ -23,6 +24,7 @@ import * as viewQuotas from "./viewQuotas";
 export const usecases = {
     autoLogoutCountdown,
     catalog,
+    clusterEventsMonitor,
     deploymentRegionManagement,
     fileExplorer,
     secretExplorer,