feat(xo-server/xo-web/host): display 2CRSi informations in general tab

@xen-orchestra/xapi/host.mjs

@@ -5,6 +5,13 @@ import { defer } from 'golike-defer'
 import { incorrectState, operationFailed } from 'xo-common/api-errors.js'
 
 import { getCurrentVmUuid } from './_XenStore.mjs'
+import {
+  addIpmiSensorDataType,
+  containsDigit,
+  IPMI_SENSOR_DATA_TYPE,
+  IPMI_SENSOR_REGEX_BY_DATA_TYPE_BY_SUPPORTED_PRODUCT_NAME,
+  isRelevantIpmiSensor,
+} from './host/_ipmi.mjs'
 
 const waitAgentRestart = (xapi, hostRef, prevAgentStartTime) =>
   new Promise(resolve => {
@@ -120,6 +127,41 @@ class Host {
     await this.callAsync('host.reboot', ref)
     await waitAgentRestart(this, ref, agentStartTime)
   }
+
+  async getIpmiSensors(ref, { cache } = {}) {
+    const productName = (await this.call(cache, 'host.get_bios_strings', ref))['system-product-name']?.toLowerCase()
+
+    if (IPMI_SENSOR_REGEX_BY_DATA_TYPE_BY_SUPPORTED_PRODUCT_NAME[productName] === undefined) {
+      return {}
+    }
+
+    const callSensorPlugin = fn => this.call(cache, 'host.call_plugin', ref, '2crsi-sensors.py', fn, {})
+    // https://github.com/AtaxyaNetwork/xcp-ng-xapi-plugins/tree/ipmi-sensors?tab=readme-ov-file#ipmi-sensors-parser
+    const [stringifiedIpmiSensors, ip] = await Promise.all([callSensorPlugin('get_info'), callSensorPlugin('get_ip')])
+    const ipmiSensors = JSON.parse(stringifiedIpmiSensors)
+
+    const ipmiSensorsByDataType = {}
+    for (const ipmiSensor of ipmiSensors) {
+      if (!isRelevantIpmiSensor(ipmiSensor, productName)) {
+        continue
+      }
+
+      addIpmiSensorDataType(ipmiSensor, productName)
+      const dataType = ipmiSensor.dataType
+
+      if (ipmiSensorsByDataType[dataType] === undefined) {
+        ipmiSensorsByDataType[dataType] = containsDigit(ipmiSensor.Name) ? [] : ipmiSensor
+      }
+
+      if (Array.isArray(ipmiSensorsByDataType[ipmiSensor.dataType])) {
+        ipmiSensorsByDataType[dataType].push(ipmiSensor)
+      }
+    }
+
+    ipmiSensorsByDataType[IPMI_SENSOR_DATA_TYPE.generalInfo] = { ip }
+
+    return ipmiSensorsByDataType
+  }
 }
 export default Host
 

@xen-orchestra/xapi/host/_ipmi.mjs

@@ -0,0 +1,63 @@
+import TTLCache from '@isaacs/ttlcache'
+
+const IPMI_CACHE_TTL = 6e4
+
+export const IPMI_SENSOR_DATA_TYPE = {
+  totalPower: 'totalPower',
+  outletTemp: 'outletTemp',
+  bmcStatus: 'bmcStatus',
+  inletTemp: 'inletTemp',
+  cpuTemp: 'cpuTemp',
+  fanStatus: 'fanStatus',
+  fanSpeed: 'fanSpeed',
+  psuStatus: 'psuStatus',
+  generalInfo: 'generalInfo',
+  unknown: 'unknown',
+}
+
+export const IPMI_SENSOR_REGEX_BY_DATA_TYPE_BY_SUPPORTED_PRODUCT_NAME = {
+  'mona_1.44gg': {
+    [IPMI_SENSOR_DATA_TYPE.totalPower]: /^total_power$/i,
+    [IPMI_SENSOR_DATA_TYPE.outletTemp]: /^outlet_temp$/i,
+    [IPMI_SENSOR_DATA_TYPE.bmcStatus]: /^bmc_status$/i,
+    [IPMI_SENSOR_DATA_TYPE.inletTemp]: /^psu_inlet_temp$/i,
+    [IPMI_SENSOR_DATA_TYPE.cpuTemp]: /^cpu[0-9]+_temp$/i,
+    [IPMI_SENSOR_DATA_TYPE.fanStatus]: /^fan[0-9]+_status$/i,
+    [IPMI_SENSOR_DATA_TYPE.fanSpeed]: /^fan[0-9]+_r_speed$/i,
+    [IPMI_SENSOR_DATA_TYPE.psuStatus]: /^psu[0-9]+_status$/i,
+  },
+}
+const IPMI_SENSOR_REGEX_BY_PRODUCT_NAME = Object.keys(IPMI_SENSOR_REGEX_BY_DATA_TYPE_BY_SUPPORTED_PRODUCT_NAME).reduce(
+  (acc, productName) => {
+    const regexes = Object.values(IPMI_SENSOR_REGEX_BY_DATA_TYPE_BY_SUPPORTED_PRODUCT_NAME[productName])
+    const combinedRegex = new RegExp(regexes.map(regex => regex.source).join('|'), 'i')
+    acc[productName] = combinedRegex
+    return acc
+  },
+  {}
+)
+
+export const IPMI_CACHE = new TTLCache({
+  ttl: IPMI_CACHE_TTL,
+  max: 1000,
+})
+
+export const isRelevantIpmiSensor = (data, productName) =>
+  IPMI_SENSOR_REGEX_BY_PRODUCT_NAME[productName].test(data.Name)
+
+export const containsDigit = str => /\d/.test(str)
+
+export const addIpmiSensorDataType = (data, productName) => {
+  const name = data.Name
+  const ipmiRegexByDataType = IPMI_SENSOR_REGEX_BY_DATA_TYPE_BY_SUPPORTED_PRODUCT_NAME[productName]
+
+  for (const dataType in ipmiRegexByDataType) {
+    const regex = ipmiRegexByDataType[dataType]
+    if (regex.test(name)) {
+      data.dataType = dataType
+      return
+    }
+  }
+
+  data.dataType = IPMI_SENSOR_DATA_TYPE.unknown
+}

@xen-orchestra/xapi/package.json

@@ -23,6 +23,7 @@
     "test": "node--test"
   },
   "dependencies": {
+    "@isaacs/ttlcache": "^1.4.1",
     "@vates/async-each": "^1.0.0",
     "@vates/decorate-with": "^2.1.0",
     "@vates/nbd-client": "^3.0.2",

CHANGELOG.unreleased.md

@@ -12,6 +12,7 @@
 > Users must be able to say: “Nice enhancement, I'm eager to test it”
 
 - [Backups] Add 'report recipients' when creating a metadata backup [#7569](https://github.com/vatesfr/xen-orchestra/issues/7569) (PR [#7776](https://github.com/vatesfr/xen-orchestra/pull/7776))
+- [Host/General] Display additional hardware data for 2CRSi server [#7816](https://github.com/vatesfr/xen-orchestra/issues/7816) (PR [#7838](https://github.com/vatesfr/xen-orchestra/pull/7838))
 
 ### Bug fixes
 
@@ -25,7 +26,7 @@
 - [New SR] Add confirmation modal before creating an SR if SRs are already present in the same path (for NFS/ISCSI) [#4273](https://github.com/vatesfr/xen-orchestra/issues/4273) (PR [#7845](https://github.com/vatesfr/xen-orchestra/pull/7845))
 - [XO Tasks] Reduce the number of API calls that incorrectly stay in pending status (often `sr.getAllUnhealthyVdiChainsLength`) [Forum#79281](https://xcp-ng.org/forum/post/79281) [Forum#80010](https://xcp-ng.org/forum/post/80010)
 - [Plugin/backup-reports] Fix _Metadata Backup_ report not sent in some cases (PR [#7776](https://github.com/vatesfr/xen-orchestra/pull/7776))
-- [Host/Advanced] Fix *Advanced Live Telemetry* link on recent XOAs
+- [Host/Advanced] Fix _Advanced Live Telemetry_ link on recent XOAs
 
 ### Packages to release
 
@@ -46,7 +47,7 @@
 - @vates/nbd-client minor
 - @xen-orchestra/backups patch
 - @xen-orchestra/mixins minor
-- @xen-orchestra/xapi patch
+- @xen-orchestra/xapi minor
 - xen-api minor
 - xo-server minor
 - xo-server-backup-reports minor

packages/xo-server/src/api/host.mjs

@@ -3,6 +3,7 @@ import { createLogger } from '@xen-orchestra/log'
 import assert from 'assert'
 import { format } from 'json-rpc-peer'
 import { incorrectState } from 'xo-common/api-errors.js'
+import { IPMI_CACHE } from '@xen-orchestra/xapi/host/_ipmi.mjs'
 
 import backupGuard from './_backupGuard.mjs'
 
@@ -592,3 +593,13 @@ getBlockdevices.params = {
 getBlockdevices.resolve = {
   host: ['id', 'host', 'administrate'],
 }
+
+export function getIpmiSensors({ host }) {
+  return this.getXapi(host).host_getIpmiSensors(host._xapiRef, { cache: IPMI_CACHE })
+}
+getIpmiSensors.params = {
+  id: { type: 'string' },
+}
+getIpmiSensors.resolve = {
+  host: ['id', 'host', 'administrate'],
+}

packages/xo-web/src/common/intl/messages.js

@@ -2844,6 +2844,16 @@ const messages = {
   secondsFormat: '{seconds, plural, one {# second} other {# seconds}}',
   durationFormat:
     '{days, plural, =0 {} one {# day } other {# days }}{hours, plural, =0 {} one {# hour } other {# hours }}{minutes, plural, =0 {} one {# minute } other {# minutes }}{seconds, plural, =0 {} one {# second} other {# seconds}}',
+
+  // ----- IPMI -----
+  highestCpuTemperature: '{n, number}x CPU{n, plural, one {} other {s}} (highest: {degres})',
+  highestFanSpeed: '{n, number}x fan{n, plural, one {} other {s}} (highest: {speed})',
+  inletTemperature: 'Inlet temperature',
+  ipmi: 'IPMI',
+  nFanStatus: '{n, number}x fan{n, plural, one {} other {s}} status: {status}',
+  nPsuStatus: '{n, number}x PSU{n, plural, one {} other {s}} status: {status}',
+  outletTemperature: 'Outlet temperature',
+  totalPower: 'Total power',
 }
 forEach(messages, function (message, id) {
   if (typeof message === 'string') {

packages/xo-web/src/common/xo/index.js

@@ -732,6 +732,27 @@ subscribeXostorInterfaces.forceRefresh = sr => {
   subscription?.forceRefresh()
 }
 
+const subscribeHostsIpmiSensors = {}
+export const subscribeIpmiSensors = host => {
+  const _isAdmin = isAdmin(store.getState())
+  const hostId = resolveId(host)
+
+  if (subscribeHostsIpmiSensors[hostId] === undefined) {
+    subscribeHostsIpmiSensors[hostId] = createSubscription(
+      async () =>
+        _isAdmin
+          ? await _call('host.getIpmiSensors', {
+              id: hostId,
+            })
+          : undefined,
+      {
+        polling: 6e4,
+      }
+    )
+  }
+
+  return subscribeHostsIpmiSensors[hostId]
+}
 // System ============================================================
 
 export const apiMethods = _call('system.getMethodsInfo')
@@ -2373,9 +2394,7 @@ export const migrateVdi = (vdi, sr, resourceSet) =>
     sr_id: resolveId(sr),
   })
 
-  export const setCbt = (vdi, cbt) =>
-    _call('vdi.set', { id: resolveId(vdi), cbt })
-
+export const setCbt = (vdi, cbt) => _call('vdi.set', { id: resolveId(vdi), cbt })
 
 // VBD ---------------------------------------------------------------
 

packages/xo-web/src/icons.scss

@@ -420,6 +420,40 @@
     @extend .fa-share;
   }
 
+  // IPMI
+  &-cpu-temperature {
+    @extend .fa;
+    @extend .fa-thermometer-full;
+  }
+  &-fan-speed {
+    @extend .fa;
+    @extend .fa-circle-o-notch;
+  }
+  &-fan-status {
+    @extend .fa;
+    @extend .fa-medkit;
+  }
+  &-inlet {
+    @extend .fa;
+    @extend .fa-sign-in;
+  }
+  &-ipmi {
+    @extend .fa;
+    @extend .fa-wrench;
+  }
+  &-outlet {
+    @extend .fa;
+    @extend .fa-sign-out;
+  }
+  &-psu {
+    @extend .fa;
+    @extend .fa-plug;
+  }
+  &-total-power {
+    @extend .fa;
+    @extend .fa-tachometer;
+  }
+
   // VM
   &-vm {
     // States