fix(xo-server/rest-api): remove alarms information in the dashboard endpoint

CHANGELOG.unreleased.md

@@ -11,6 +11,8 @@
 
 > Users must be able to say: “Nice enhancement, I'm eager to test it”
 
+- [REST API] Add `/alarms` endpoint and remove `alarms` information in the `/dashboard` endpoint (PR [#7959](https://github.com/vatesfr/xen-orchestra/pull/7959))
+
 ### Bug fixes
 
 > Users must be able to say: “I had this issue, happy to know it's fixed”
@@ -31,4 +33,6 @@
 
 <!--packages-start-->
 
+- xo-server minor
+
 <!--packages-end-->

packages/xo-server/src/xo-mixins/rest-api.mjs

@@ -174,7 +174,6 @@ async function _getDashboardStats(app) {
   const poolIds = new Set()
   const hosts = []
   const writableSrs = []
-  const alarms = []
 
   for (const obj of app.objects.values()) {
     if (obj.type === 'host') {
@@ -190,10 +189,6 @@ async function _getDashboardStats(app) {
         writableSrs.push(obj)
       }
     }
-
-    if (obj.type === 'message' && obj.name === 'ALARM') {
-      alarms.push(obj)
-    }
   }
 
   dashboard.nPools = poolIds.size
@@ -360,40 +355,15 @@ async function _getDashboardStats(app) {
     console.error(error)
   }
 
-  dashboard.alarms = alarms.reduce((acc, { $object, body, time }) => {
-    try {
-      const [, value, name] = body.match(ALARM_BODY_REGEX)
-
-      let object
-      try {
-        object = app.getObject($object)
-      } catch (error) {
-        console.error(error)
-        object = {
-          type: 'unknown',
-          uuid: $object,
-        }
-      }
-
-      acc.push({
-        name,
-        object: {
-          type: object.type,
-          uuid: object.uuid,
-        },
-        timestamp: time,
-        value: +value,
-      })
-    } catch (error) {
-      console.error(error)
-    }
-
-    return acc
-  }, [])
   return dashboard
 }
 const getDashboardStats = throttle(_getDashboardStats, 6e4, { trailing: false, leading: true })
 
+const messagesFilter =
+  ({ onlyAlarms = false, excludeAlarms = false } = {}) =>
+  _ =>
+    _.type === 'message' && (onlyAlarms ? _.name === 'ALARM' : excludeAlarms ? _.name !== 'ALARM' : true)
+
 export default class RestApi {
   #api
 
@@ -477,7 +447,11 @@ export default class RestApi {
         await sendObjects(
           Object.values(
             app.getObjects({
-              filter: every(_ => _.type === 'message' && _.$object === id, handleOptionalUserFilter(query.filter)),
+              filter: every(
+                messagesFilter({ excludeAlarms: true }),
+                _ => _.$object === id,
+                handleOptionalUserFilter(query.filter)
+              ),
               limit: ifDef(query.limit, Number),
             })
           ),
@@ -486,10 +460,39 @@ export default class RestApi {
           '/messages'
         )
       }
+
+      async function alarms(req, res) {
+        const {
+          object: { id },
+          query,
+        } = req
+        await sendObjects(
+          Object.values(
+            app.getObjects({
+              filter: every(
+                messagesFilter({ onlyAlarms: true }),
+                _ => _.$object === id,
+                handleOptionalUserFilter(query.filter)
+              ),
+              limit: ifDef(query.limit, Number),
+            })
+          ),
+          req,
+          res,
+          '/alarms'
+        )
+      }
+
       for (const type of types) {
         const id = type.toLocaleLowerCase() + 's'
 
-        collections[id] = { getObject, getObjects, routes: { messages }, isCorrectType: _ => _.type === type, type }
+        collections[id] = {
+          getObject,
+          getObjects,
+          routes: { messages, alarms },
+          isCorrectType: _ => _.type === type,
+          type,
+        }
       }
 
       collections.hosts.routes = {
@@ -737,6 +740,71 @@ export default class RestApi {
       },
     }
     collections.dashboard = {}
+    collections.messages = {
+      async getObject(id) {
+        const message = app.getObject(id, 'message')
+        if (message === 'ALARM') {
+          throw noSuchObject(id, 'message')
+        }
+
+        return message
+      },
+      async getObjects(filter, limit) {
+        return handleArray(
+          await app.getObjects({
+            filter: every(messagesFilter({ excludeAlarms: true }), filter),
+            limit,
+          })
+        )
+      },
+    }
+    collections.alarms = {
+      async getObject(id, req) {
+        const alarm = app.getObject(id, 'message')
+        if (alarm.name !== 'ALARM') {
+          throw noSuchObject(id, 'alarm')
+        }
+
+        const { $object, body } = alarm
+        let object = {}
+        try {
+          object = app.getObject($object)
+        } catch (error) {
+          object = {
+            type: 'unknown',
+            uuid: $object,
+          }
+        }
+
+        const { baseUrl } = req
+        const objType = object.type.toLowerCase() + 's'
+        const href = collections[objType] === undefined ? undefined : `${baseUrl}/${objType}/${object.uuid}`
+        const [, value, name] = body.match(ALARM_BODY_REGEX)
+
+        return {
+          ...alarm,
+          body: {
+            value: +value,
+            name,
+          },
+          object: {
+            type: object.type,
+            uuid: object.uuid,
+            href,
+          },
+        }
+      },
+      async getObjects(filter, limit) {
+        return handleArray(
+          Object.values(
+            await app.getObjects({
+              filter: every(messagesFilter({ onlyAlarms: true }), filter),
+              limit,
+            })
+          )
+        )
+      },
+    }
 
     // normalize collections
     for (const id of Object.keys(collections)) {