splite

2026-09-16 17:40:46 -04:00 · 2026-04-29 13:12:04 -04:00
parent 2eafcce95b
commit e2bd29e2c2
3 changed files with 146 additions and 188 deletions
@@ -2,6 +2,7 @@
 // Purpose: Handles event-bus announcements to Discord channels.
 // Scope: Processes supported event types and posts formatted messages/embeds.
 const { EmbedBuilder, AttachmentBuilder } = require('discord.js');
+const { buildBatteryStatusEmbed, buildBatteryCaption } = require('../batteryEmbeds');

 function createBusEventHandler(deps) {
  const { logger, discordConfig, MODES, roverManager, rovers, schedulePresenceRotation, formatDuration, sendToChannel } = deps;
@@ -17,117 +18,6 @@ function createBusEventHandler(deps) {
    return embed;
  }

-  function formatVoltage(voltageMv) {
-    if (voltageMv == null) return 'n/a';
-    return `${(voltageMv / 1000).toFixed(2)}V`;
-  }
-
-  function formatCurrent(currentMa) {
-    if (currentMa == null) return 'n/a';
-    return `${currentMa}mA`;
-  }
-
-  function formatChargeState(batteryState) {
-    if (!batteryState) return 'n/a';
-    const charge = batteryState.charge;
-    const capacity = batteryState.capacity;
-    const percent = batteryState.percentDisplay;
-    const chargeText = charge != null && capacity != null ? `${charge}/${capacity}mAh` : 'n/a';
-    const percentText = percent != null ? `${percent}%` : 'n/a';
-    return `${chargeText} (${percentText})`;
-  }
-
-  function formatDockEmoji(docked) { return docked ? '🏠' : '🧭'; }
-  function formatChargeEmoji(charging) { return charging ? '⚡' : '🔌'; }
-  function formatLockEmoji(locked) { return locked ? '🔒' : '🔓'; }
-  function formatBatteryEmoji(batteryState) {
-    if (batteryState?.urgentActive) return '🛑';
-    if (batteryState?.warnActive) return '⚠️';
-    return '🔋';
-  }
-
-  function isCharging(sensors) {
-    const label = sensors?.chargingState?.label?.toLowerCase();
-    const chargingByLabel = label === 'waiting' || label === 'full charging' || label === 'trickle charging';
-    const code = sensors?.chargingState?.code;
-    const chargingByCode = code === 2 || code === 3 || code === 4;
-    return chargingByLabel || chargingByCode;
-  }
-
-  function buildRoverStatusSnapshot(record) {
-    if (!record) return null;
-    const sensors = record.lastSensor?.decoded || record.lastSensor?.sensors || null;
-    return {
-      id: record.id,
-      name: record.meta?.name || record.id,
-      locked: record.locked,
-      lockReason: record.lockReason,
-      docked: Boolean(sensors?.chargingSources?.homeBase),
-      charging: isCharging(sensors),
-      chargingLabel: sensors?.chargingState?.label || 'unknown',
-      voltageMv: sensors?.voltageMv ?? null,
-      currentMa: sensors?.currentMa ?? null,
-      batteryState: record.batteryState,
-    };
-  }
-
-  function buildBatteryStatusEmbed(color, records = null) {
-    const embed = buildEmbed({ title: 'Rover Battery Status', color: color || 0x2196f3 });
-    const sourceRecords = records || Array.from(rovers.values());
-    const snapshots = sourceRecords.map((entry) => buildRoverStatusSnapshot(entry)).filter(Boolean);
-    if (!snapshots.length) {
-      embed.setDescription('No rovers online.');
-      return embed;
-    }
-    snapshots.forEach((snapshot) => {
-      const lockLabel = snapshot.locked ? `locked${snapshot.lockReason ? ` (${snapshot.lockReason})` : ''}` : 'unlocked';
-      const dockLabel = snapshot.docked ? 'docked' : 'undocked';
-      const chargingLabel = snapshot.charging ? `charging (${snapshot.chargingLabel})` : 'not charging';
-      const header = [
-        formatBatteryEmoji(snapshot.batteryState),
-        formatDockEmoji(snapshot.docked),
-        formatChargeEmoji(snapshot.charging),
-        formatLockEmoji(snapshot.locked),
-      ].join(' ');
-      embed.addFields({
-        name: `${header} ${snapshot.name}`,
-        value: [
-          `Dock: ${dockLabel}`,
-          `Charging: ${chargingLabel}`,
-          `Battery: ${formatChargeState(snapshot.batteryState)}`,
-          `Voltage: ${formatVoltage(snapshot.voltageMv)}`,
-          `Current: ${formatCurrent(snapshot.currentMa)}`,
-          `Lock: ${lockLabel}`,
-        ].join('\n'),
-        inline: true,
-      });
-    });
-    return embed;
-  }
-
-  function buildBatteryCaption(type, payload) {
-    const roverId = payload?.roverId || 'unknown';
-    const record = rovers.get(roverId) || null;
-    const snapshot = buildRoverStatusSnapshot(record);
-    const base = snapshot?.name || roverId;
-    const percent = snapshot?.batteryState?.percentDisplay;
-    const percentLabel = percent != null ? `${percent}%` : 'n/a';
-    const dockLabel = snapshot?.docked ? 'docked' : 'undocked';
-    const chargingLabel = snapshot?.charging ? 'charging' : 'not charging';
-    const detail = `${dockLabel}, ${chargingLabel}, ${formatVoltage(snapshot?.voltageMv ?? null)}, ${formatCurrent(snapshot?.currentMa ?? null)}, ${formatChargeState(snapshot?.batteryState ?? null)}`;
-
-    switch (type) {
-      case 'battery.warn': return `Battery warn: ${base} at ${percentLabel}. ${detail}`;
-      case 'battery.urgent': return `Battery urgent: ${base} at ${percentLabel}. ${detail}`;
-      case 'battery.docked': return `Docked: ${base}. ${detail}`;
-      case 'battery.undocked': return `Undocked: ${base}. ${detail}`;
-      case 'battery.charging.start': return `Charging started: ${base}. ${detail}`;
-      case 'battery.charging.stop': return `Charging stopped: ${base}. ${detail}`;
-      case 'battery.locked': return `Locked for charging: ${base}. ${detail}`;
-      case 'battery.unlocked': return `Unlocked after charging: ${base}. ${detail}`;
-      default: return `Battery update: ${base}. ${detail}`;
-    }
-  }

  async function announce({ channelId, content, pingRoleId, color, title, description, embeds, files }) {
    if (!channelId) return;
@@ -165,22 +55,22 @@ function createBusEventHandler(deps) {
        announce({ channelId: channels.adminAlerts, color: 0xf0b651, title: 'Dock Guard Triggered', description: `${payload?.roverId} (${payload?.reasonText || 'undocked'}) for ${formatDuration(payload?.idleMs)}.` });
        break;
      case 'battery.warn':
-        announce({ channelId: channels.adminAlerts, pingRoleId: roles.adminPing || null, color: 0xf0b651, content: buildBatteryCaption(type, payload), embeds: [buildBatteryStatusEmbed(0xf0b651, Array.from(rovers.values()))] });
+        announce({ channelId: channels.adminAlerts, pingRoleId: roles.adminPing || null, color: 0xf0b651, content: buildBatteryCaption(type, rovers.get(payload?.roverId || 'unknown')), embeds: [buildBatteryStatusEmbed({ color: 0xf0b651, records: Array.from(rovers.values()), includeOi: false })] });
        break;
      case 'battery.urgent':
-        announce({ channelId: channels.adminAlerts, pingRoleId: roles.adminPing || null, color: 0xe53935, content: buildBatteryCaption(type, payload), embeds: [buildBatteryStatusEmbed(0xe53935, Array.from(rovers.values()))] });
+        announce({ channelId: channels.adminAlerts, pingRoleId: roles.adminPing || null, color: 0xe53935, content: buildBatteryCaption(type, rovers.get(payload?.roverId || 'unknown')), embeds: [buildBatteryStatusEmbed({ color: 0xe53935, records: Array.from(rovers.values()), includeOi: false })] });
        break;
      case 'battery.docked':
      case 'battery.undocked':
      case 'battery.charging.start':
-        announce({ channelId: channels.adminAlerts, color: 0x2196f3, content: buildBatteryCaption(type, payload), embeds: [buildBatteryStatusEmbed(0x2196f3, Array.from(rovers.values()))] });
+        announce({ channelId: channels.adminAlerts, color: 0x2196f3, content: buildBatteryCaption(type, rovers.get(payload?.roverId || 'unknown')), embeds: [buildBatteryStatusEmbed({ color: 0x2196f3, records: Array.from(rovers.values()), includeOi: false })] });
        break;
      case 'battery.charging.stop':
      case 'battery.locked':
-        announce({ channelId: channels.adminAlerts, color: 0xf0b651, content: buildBatteryCaption(type, payload), embeds: [buildBatteryStatusEmbed(0xf0b651, Array.from(rovers.values()))] });
+        announce({ channelId: channels.adminAlerts, color: 0xf0b651, content: buildBatteryCaption(type, rovers.get(payload?.roverId || 'unknown')), embeds: [buildBatteryStatusEmbed({ color: 0xf0b651, records: Array.from(rovers.values()), includeOi: false })] });
        break;
      case 'battery.unlocked':
-        announce({ channelId: channels.adminAlerts, color: 0x4caf50, content: buildBatteryCaption(type, payload), embeds: [buildBatteryStatusEmbed(0x4caf50, Array.from(rovers.values()))] });
+        announce({ channelId: channels.adminAlerts, color: 0x4caf50, content: buildBatteryCaption(type, rovers.get(payload?.roverId || 'unknown')), embeds: [buildBatteryStatusEmbed({ color: 0x4caf50, records: Array.from(rovers.values()), includeOi: false })] });
        break;
      case 'humanAlert.buttonPressed': {
        const imageBase64 = payload?.imageBase64 ? String(payload.imageBase64) : '';