Infinity_Vis_Rust/web/v1/app.js

(function () {
  const apiState = {
    stateResponse: null,
    previewResponse: null,
    catalog: null,
    events: [],
    ws: null,
    commandTimers: new Map(),
  };

  const dom = {
    projectName: document.getElementById("project-name"),
    topologyLabel: document.getElementById("topology-label"),
    connectionPill: document.getElementById("connection-pill"),
    previewUpdated: document.getElementById("preview-updated"),
    refreshButton: document.getElementById("refresh-button"),
    patternSelect: document.getElementById("pattern-select"),
    transitionSlider: document.getElementById("transition-slider"),
    transitionValue: document.getElementById("transition-value"),
    transitionStyleSelect: document.getElementById("transition-style-select"),
    brightnessSlider: document.getElementById("brightness-slider"),
    brightnessValue: document.getElementById("brightness-value"),
    blackoutButton: document.getElementById("blackout-button"),
    presetList: document.getElementById("preset-list"),
    presetIdInput: document.getElementById("preset-id-input"),
    presetOverwriteInput: document.getElementById("preset-overwrite-input"),
    savePresetButton: document.getElementById("save-preset-button"),
    groupFilterInput: document.getElementById("group-filter-input"),
    groupList: document.getElementById("group-list"),
    snapshotIdInput: document.getElementById("snapshot-id-input"),
    snapshotLabelInput: document.getElementById("snapshot-label-input"),
    snapshotOverwriteInput: document.getElementById("snapshot-overwrite-input"),
    saveSnapshotButton: document.getElementById("save-snapshot-button"),
    snapshotList: document.getElementById("snapshot-list"),
    sceneParams: document.getElementById("scene-params"),
    previewGrid: document.getElementById("preview-grid"),
    summaryCards: document.getElementById("summary-cards"),
    snapshotJson: document.getElementById("snapshot-json"),
    eventKindFilter: document.getElementById("event-kind-filter"),
    eventSearchFilter: document.getElementById("event-search-filter"),
    eventList: document.getElementById("event-list"),
  };

  function init() {
    bindControls();
    refreshAll();
    connectStream();
  }

  function bindControls() {
    dom.refreshButton.addEventListener("click", () => refreshAll());

    dom.patternSelect.addEventListener("change", (event) => {
      sendCommand({
        type: "select_pattern",
        payload: { pattern_id: event.target.value },
      });
    });

    dom.transitionSlider.addEventListener("input", (event) => {
      const value = Number(event.target.value);
      dom.transitionValue.textContent = `${value} ms`;
      debounceCommand("transition-duration", {
        type: "set_transition_duration_ms",
        payload: { duration_ms: value },
      });
    });

    dom.transitionStyleSelect.addEventListener("change", (event) => {
      sendCommand({
        type: "set_transition_style",
        payload: { style: event.target.value },
      });
    });

    dom.brightnessSlider.addEventListener("input", (event) => {
      const value = Number(event.target.value);
      dom.brightnessValue.textContent = `${Math.round(value * 100)}%`;
      debounceCommand("brightness", {
        type: "set_master_brightness",
        payload: { value },
      });
    });

    dom.blackoutButton.addEventListener("click", () => {
      const enabled = !(apiState.stateResponse?.state?.global?.blackout ?? false);
      sendCommand({
        type: "set_blackout",
        payload: { enabled },
      });
    });

    dom.savePresetButton.addEventListener("click", async () => {
      const presetId = dom.presetIdInput.value.trim();
      if (!presetId) {
        pushEvent({
          at: new Date().toLocaleTimeString(),
          kind: "warning",
          code: "preset_id_required",
          message: "Preset ID is required before saving.",
        });
        return;
      }

      await sendCommand({
        type: "save_preset",
        payload: {
          preset_id: presetId,
          overwrite: dom.presetOverwriteInput.checked,
        },
      });
    });

    dom.saveSnapshotButton.addEventListener("click", async () => {
      const snapshotId = dom.snapshotIdInput.value.trim();
      if (!snapshotId) {
        pushEvent({
          at: new Date().toLocaleTimeString(),
          kind: "warning",
          code: "snapshot_id_required",
          message: "Snapshot ID is required before saving a creative variant.",
        });
        return;
      }

      await sendCommand({
        type: "save_creative_snapshot",
        payload: {
          snapshot_id: snapshotId,
          label: dom.snapshotLabelInput.value.trim() || null,
          overwrite: dom.snapshotOverwriteInput.checked,
        },
      });
    });

    dom.groupFilterInput.addEventListener("input", () => renderGroups());
    dom.eventKindFilter.addEventListener("change", () => renderEvents());
    dom.eventSearchFilter.addEventListener("input", () => renderEvents());
  }

  async function refreshAll() {
    setConnectionState("connecting", "loading");
    try {
      const [stateResponse, previewResponse, catalog] = await Promise.all([
        fetchJson("/api/v1/state"),
        fetchJson("/api/v1/preview"),
        fetchJson("/api/v1/catalog"),
      ]);

      apiState.stateResponse = stateResponse;
      apiState.previewResponse = previewResponse;
      apiState.catalog = catalog;

      renderAll();
      setConnectionState("online", "HTTP sync");
    } catch (error) {
      console.error(error);
      setConnectionState("offline", "snapshot fetch failed");
      pushEvent({
        at: new Date().toLocaleTimeString(),
        kind: "error",
        code: "http_refresh_failed",
        message: `HTTP refresh failed: ${error.message}`,
      });
    }
  }

  function connectStream() {
    const protocol = window.location.protocol === "https:" ? "wss:" : "ws:";
    const url = `${protocol}//${window.location.host}/api/v1/stream`;
    const socket = new WebSocket(url);
    apiState.ws = socket;

    socket.addEventListener("open", () => {
      setConnectionState("online", "stream connected");
      pushEvent({
        at: new Date().toLocaleTimeString(),
        kind: "info",
        code: "stream_connected",
        message: "WebSocket stream connected",
      });
    });

    socket.addEventListener("message", (event) => {
      const envelope = JSON.parse(event.data);
      handleStreamEnvelope(envelope);
    });

    socket.addEventListener("close", () => {
      setConnectionState("offline", "stream disconnected");
      pushEvent({
        at: new Date().toLocaleTimeString(),
        kind: "warning",
        code: "stream_reconnect",
        message: "WebSocket stream closed, retrying",
      });
      window.setTimeout(connectStream, 1500);
    });

    socket.addEventListener("error", () => {
      setConnectionState("warning", "stream error");
    });
  }

  function handleStreamEnvelope(envelope) {
    const message = envelope.message;
    if (!message) {
      return;
    }

    if (message.type === "snapshot") {
      apiState.stateResponse = {
        api_version: envelope.api_version,
        generated_at_millis: envelope.generated_at_millis,
        state: message.payload,
      };
      renderState();
      return;
    }

    if (message.type === "preview") {
      apiState.previewResponse = {
        api_version: envelope.api_version,
        generated_at_millis: envelope.generated_at_millis,
        preview: message.payload,
      };
      renderPreview();
      renderSnapshotJson();
      return;
    }

    if (message.type === "event") {
      pushEvent({
        at: `${envelope.generated_at_millis} ms`,
        kind: message.payload.kind || "info",
        code: message.payload.code || null,
        message: message.payload.message,
      });
    }
  }

  async function sendCommand(command) {
    try {
      const response = await fetchJson("/api/v1/command", {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({
          request_id: `web-${Date.now()}`,
          command,
        }),
      });
      pushEvent({
        at: new Date().toLocaleTimeString(),
        kind: "info",
        code: response.command_type,
        message: response.summary,
      });
      await refreshAll();
      return response;
    } catch (error) {
      console.error(error);
      pushEvent({
        at: new Date().toLocaleTimeString(),
        kind: "error",
        code: "command_failed",
        message: `Command failed: ${error.message}`,
      });
      return null;
    }
  }

  function debounceCommand(key, command) {
    const existing = apiState.commandTimers.get(key);
    if (existing) {
      window.clearTimeout(existing);
    }
    const timeoutId = window.setTimeout(() => {
      sendCommand(command);
      apiState.commandTimers.delete(key);
    }, 120);
    apiState.commandTimers.set(key, timeoutId);
  }

  async function fetchJson(url, options) {
    const response = await window.fetch(url, options);
    const body = await response.text();
    let payload = null;
    try {
      payload = body ? JSON.parse(body) : null;
    } catch (error) {
      throw new Error(`Invalid JSON from ${url}`);
    }

    if (!response.ok) {
      const message = payload?.error?.message || payload?.error || response.statusText;
      throw new Error(message);
    }
    return payload;
  }

  function renderAll() {
    renderState();
    renderPreview();
    renderEvents();
  }

  function renderState() {
    const state = apiState.stateResponse?.state;
    if (!state) {
      return;
    }

    const global = state.global;
    const scene = state.active_scene;

    dom.projectName.textContent = state.system.project_name;
    dom.topologyLabel.textContent = `${state.system.topology_label} / API ${apiState.stateResponse.api_version}`;

    dom.patternSelect.innerHTML = "";
    (apiState.catalog?.patterns || []).forEach((pattern) => {
      const option = document.createElement("option");
      option.value = pattern.pattern_id;
      option.textContent = `${pattern.display_name} (${pattern.pattern_id})`;
      option.selected = pattern.pattern_id === global.selected_pattern;
      dom.patternSelect.appendChild(option);
    });

    dom.transitionSlider.value = String(global.transition_duration_ms);
    dom.transitionValue.textContent = `${global.transition_duration_ms} ms`;
    dom.transitionStyleSelect.value = global.transition_style;
    dom.brightnessSlider.value = String(global.master_brightness);
    dom.brightnessValue.textContent = `${Math.round(global.master_brightness * 100)}%`;
    dom.blackoutButton.textContent = global.blackout ? "Release blackout" : "Enable blackout";
    dom.blackoutButton.classList.toggle("is-active", global.blackout);

    renderPresets(scene);
    renderGroups(global);
    renderCreativeSnapshots();
    renderSceneParameters(scene);
    renderSummaryCards(state);
    renderSnapshotJson();
  }

  function renderPresets(scene) {
    dom.presetList.innerHTML = "";
    const presets = apiState.catalog?.presets || [];
    if (!presets.length) {
      dom.presetList.innerHTML = '<div class="empty-state">No presets available.</div>';
      return;
    }

    presets.forEach((preset) => {
      const button = document.createElement("button");
      button.type = "button";
      button.className = "preset-button";
      button.classList.toggle("active", scene.preset_id === preset.preset_id);
      button.innerHTML = `
        <strong>${preset.preset_id}</strong>
        <div class="pill-subtext">${preset.pattern_id} / ${preset.transition_style} / ${preset.source}</div>
      `;
      button.addEventListener("click", () =>
        sendCommand({
          type: "recall_preset",
          payload: { preset_id: preset.preset_id },
        })
      );
      dom.presetList.appendChild(button);
    });
  }

  function renderGroups(global) {
    dom.groupList.innerHTML = "";
    const filterValue = dom.groupFilterInput.value.trim().toLowerCase();
    const groups = (apiState.catalog?.groups || []).filter((group) => {
      if (!filterValue) {
        return true;
      }
      return (
        group.group_id.toLowerCase().includes(filterValue) ||
        (group.tags || []).some((tag) => tag.toLowerCase().includes(filterValue))
      );
    });

    const allButton = document.createElement("button");
    allButton.type = "button";
    allButton.className = "group-button";
    allButton.classList.toggle("active", !global.selected_group);
    allButton.innerHTML = "<strong>all_panels</strong><div class=\"pill-subtext\">global target</div>";
    allButton.addEventListener("click", () =>
      sendCommand({
        type: "select_group",
        payload: { group_id: null },
      })
    );
    dom.groupList.appendChild(allButton);

    if (!groups.length) {
      const empty = document.createElement("div");
      empty.className = "empty-state";
      empty.textContent = "No groups match the current filter.";
      dom.groupList.appendChild(empty);
      return;
    }

    groups.forEach((group) => {
      const button = document.createElement("button");
      button.type = "button";
      button.className = "group-button";
      button.classList.toggle("active", group.group_id === global.selected_group);
      button.innerHTML = `
        <strong>${group.group_id}</strong>
        <div class="pill-subtext">${group.member_count} members / ${group.source}</div>
      `;
      button.addEventListener("click", () =>
        sendCommand({
          type: "select_group",
          payload: { group_id: group.group_id },
        })
      );
      dom.groupList.appendChild(button);
    });
  }

  function renderCreativeSnapshots() {
    dom.snapshotList.innerHTML = "";
    const snapshots = apiState.catalog?.creative_snapshots || [];
    if (!snapshots.length) {
      dom.snapshotList.innerHTML =
        '<div class="empty-state">No creative snapshots saved yet.</div>';
      return;
    }

    snapshots.forEach((snapshot) => {
      const card = document.createElement("article");
      card.className = "snapshot-card";
      card.innerHTML = `
        <div class="snapshot-card-header">
          <div>
            <strong>${snapshot.label || snapshot.snapshot_id}</strong>
            <div class="preview-meta">${snapshot.snapshot_id}</div>
          </div>
          <button type="button" class="ghost-button">Recall</button>
        </div>
        <div class="snapshot-meta-row">
          <span class="meta-chip">${snapshot.pattern_id}</span>
          <span class="meta-chip">${snapshot.transition_style}</span>
          <span class="meta-chip">${snapshot.transition_duration_ms} ms</span>
          <span class="meta-chip">${snapshot.target_group || "all_panels"}</span>
        </div>
      `;
      card.querySelector("button").addEventListener("click", () =>
        sendCommand({
          type: "recall_creative_snapshot",
          payload: { snapshot_id: snapshot.snapshot_id },
        })
      );
      dom.snapshotList.appendChild(card);
    });
  }

  function renderSceneParameters(scene) {
    dom.sceneParams.innerHTML = "";
    const parameters = scene.parameters || [];
    if (!parameters.length) {
      dom.sceneParams.innerHTML =
        '<div class="empty-state">This pattern has no exposed scene parameters.</div>';
      return;
    }

    parameters.forEach((parameter) => {
      const card = document.createElement("div");
      card.className = "parameter-card";

      if (parameter.kind === "scalar") {
        const currentValue = Number(parameter.value.value || 0);
        card.innerHTML = `
          <label>
            <strong>${parameter.label}</strong>
            <span>${parameter.key}</span>
            <input
              type="range"
              min="${parameter.min_scalar ?? 0}"
              max="${parameter.max_scalar ?? 1}"
              step="${parameter.step ?? 0.01}"
              value="${currentValue}"
            />
            <span>${currentValue.toFixed(2)}</span>
          </label>
        `;
        const slider = card.querySelector("input");
        const readout = card.querySelector("span:last-of-type");
        slider.addEventListener("input", (event) => {
          const value = Number(event.target.value);
          readout.textContent = value.toFixed(2);
          debounceCommand(`param:${parameter.key}`, {
            type: "set_scene_parameter",
            payload: {
              key: parameter.key,
              value: { kind: "scalar", value },
            },
          });
        });
      } else if (parameter.kind === "toggle") {
        const checked = Boolean(parameter.value.value);
        card.innerHTML = `
          <label>
            <strong>${parameter.label}</strong>
            <span>${parameter.key}</span>
            <input type="checkbox" ${checked ? "checked" : ""} />
          </label>
        `;
        const checkbox = card.querySelector("input");
        checkbox.addEventListener("change", (event) =>
          sendCommand({
            type: "set_scene_parameter",
            payload: {
              key: parameter.key,
              value: { kind: "toggle", value: event.target.checked },
            },
          })
        );
      } else {
        const currentValue = parameter.value.value || "";
        card.innerHTML = `
          <label>
            <strong>${parameter.label}</strong>
            <span>${parameter.key}</span>
            <input type="text" value="${escapeHtml(currentValue)}" />
          </label>
        `;
        const input = card.querySelector("input");
        input.addEventListener("change", (event) =>
          sendCommand({
            type: "set_scene_parameter",
            payload: {
              key: parameter.key,
              value: { kind: "text", value: event.target.value },
            },
          })
        );
      }

      dom.sceneParams.appendChild(card);
    });
  }

  function renderPreview() {
    const preview = apiState.previewResponse?.preview;
    dom.previewGrid.innerHTML = "";
    if (!preview?.panels?.length) {
      dom.previewGrid.innerHTML =
        '<div class="empty-state">Preview stream is waiting for panel snapshots.</div>';
      return;
    }

    dom.previewUpdated.textContent = `${apiState.previewResponse.generated_at_millis} ms`;
    const panels = [...preview.panels].sort(comparePreviewPanels);
    panels.forEach((panel) => {
      const card = document.createElement("article");
      card.className = "preview-card";
      card.style.setProperty("--preview-color", panel.representative_color_hex);
      card.innerHTML = `
        <div class="preview-card-header">
          <div>
            <h3>${panel.node_id}</h3>
            <div class="preview-meta">${panel.panel_position} / ${panel.source}</div>
          </div>
          <strong>${panel.energy_percent}%</strong>
        </div>
        <div class="preview-swatch"></div>
        <div class="energy-bar"><span style="--energy-width: ${panel.energy_percent}%"></span></div>
        <div class="sample-row">
          ${panel.sample_led_hex
            .map(
              (hex) =>
                `<span class="sample-dot" style="--sample-color: ${hex}" title="${hex}"></span>`
            )
            .join("")}
        </div>
      `;
      dom.previewGrid.appendChild(card);
    });
  }

  function renderSummaryCards(state) {
    const scene = state.active_scene;
    const global = state.global;
    const engine = state.engine;
    const nodeStats = summarizeNodes(state.nodes || []);
    const creativeSnapshotCount = (apiState.catalog?.creative_snapshots || []).length;

    const cards = [
      {
        label: "Active Pattern",
        value: scene.pattern_id,
        detail: scene.preset_id ? `Preset ${scene.preset_id}` : "live scene",
      },
      {
        label: "Group Target",
        value: scene.target_group || "all_panels",
        detail: `${(apiState.catalog?.groups || []).length} groups available`,
      },
      {
        label: "Transition",
        value: `${global.transition_style} / ${global.transition_duration_ms} ms`,
        detail: engine.active_transition
          ? `${engine.active_transition.style} ${Math.round(engine.active_transition.progress * 100)}%`
          : "idle",
      },
      {
        label: "Brightness",
        value: `${Math.round(global.master_brightness * 100)}%`,
        detail: global.blackout ? "blackout active" : "output live",
      },
      {
        label: "Engine",
        value: `${engine.frame_hz} fps target`,
        detail: `${engine.logic_hz} hz logic / frame ${engine.frame_index}`,
      },
      {
        label: "Nodes",
        value: `${nodeStats.online}/${state.nodes.length} online`,
        detail: `${nodeStats.degraded} degraded / ${nodeStats.offline} offline`,
      },
      {
        label: "Creative Snapshots",
        value: `${creativeSnapshotCount}`,
        detail: `${(apiState.catalog?.presets || []).length} presets in library`,
      },
    ];

    dom.summaryCards.innerHTML = cards
      .map(
        (card) => `
          <div class="summary-card">
            <strong>${card.value}</strong>
            <span>${card.label}</span>
            <div class="preview-meta">${card.detail}</div>
          </div>
        `
      )
      .join("");
  }

  function renderSnapshotJson() {
    dom.snapshotJson.textContent = JSON.stringify(buildComposedSnapshot(), null, 2);
  }

  function buildComposedSnapshot() {
    return {
      api_version: apiState.stateResponse?.api_version || apiState.previewResponse?.api_version || "v1",
      generated_at_millis:
        apiState.previewResponse?.generated_at_millis ||
        apiState.stateResponse?.generated_at_millis ||
        0,
      state: apiState.stateResponse?.state || null,
      preview: apiState.previewResponse?.preview || null,
      catalog: apiState.catalog || null,
    };
  }

  function pushEvent(entry) {
    apiState.events.unshift({
      kind: entry.kind || "info",
      code: entry.code || null,
      ...entry,
    });
    apiState.events = apiState.events.slice(0, 50);
    renderEvents();
  }

  function renderEvents() {
    const kindFilter = dom.eventKindFilter.value;
    const searchFilter = dom.eventSearchFilter.value.trim().toLowerCase();
    const filtered = apiState.events.filter((entry) => {
      const kindMatches = kindFilter === "all" || entry.kind === kindFilter;
      const searchMatches =
        !searchFilter ||
        (entry.message || "").toLowerCase().includes(searchFilter) ||
        (entry.code || "").toLowerCase().includes(searchFilter);
      return kindMatches && searchMatches;
    });

    if (!filtered.length) {
      dom.eventList.innerHTML = '<div class="empty-state">No events match the current filter.</div>';
      return;
    }

    dom.eventList.innerHTML = filtered
      .map(
        (entry) => `
          <article class="event-item event-${entry.kind}">
            <div class="event-meta">${entry.at}</div>
            ${entry.code ? `<span class="event-code">${entry.code}</span>` : ""}
            <strong>${entry.message}</strong>
          </article>
        `
      )
      .join("");
  }

  function setConnectionState(kind, message) {
    dom.connectionPill.textContent = message;
    dom.connectionPill.className =
      kind === "online"
        ? "pill pill-online"
        : kind === "warning"
          ? "pill pill-warning"
          : "pill pill-offline";
  }

  function summarizeNodes(nodes) {
    return nodes.reduce(
      (summary, node) => {
        summary[node.connection] += 1;
        return summary;
      },
      { online: 0, degraded: 0, offline: 0 }
    );
  }

  function comparePreviewPanels(left, right) {
    const leftNode = left.node_id.localeCompare(right.node_id);
    if (leftNode !== 0) {
      return leftNode;
    }
    return panelPositionRank(left.panel_position) - panelPositionRank(right.panel_position);
  }

  function panelPositionRank(position) {
    if (position === "top") {
      return 0;
    }
    if (position === "middle") {
      return 1;
    }
    return 2;
  }

  function escapeHtml(value) {
    return String(value)
      .replaceAll("&", "&amp;")
      .replaceAll("<", "&lt;")
      .replaceAll(">", "&gt;")
      .replaceAll('"', "&quot;");
  }

  init();
})();