PSA/ee/appliance/host-service/tests/update-engine.test.mjs

import fs from 'node:fs';
import os from 'node:os';
import path from 'node:path';
import test from 'node:test';
import assert from 'node:assert/strict';
import { runAppChannelUpdate } from '../update-engine.mjs';

test('runAppChannelUpdate applies channel update and persists history without OS/k3s mutation scope', async () => {
  const tmp = fs.mkdtempSync(path.join(os.tmpdir(), 'alga-update-engine-'));
  const stateFile = path.join(tmp, 'install-state.json');
  const releaseSelectionFile = path.join(tmp, 'release-selection.json');
  const updateHistoryFile = path.join(tmp, 'update-history.json');
  const metadataFile = path.join(tmp, 'maintenance-metadata.json');
  const fluxManifestPath = path.join(tmp, 'flux-source.yaml');
  const fakeBin = path.join(tmp, 'bin');
  fs.mkdirSync(fakeBin, { recursive: true });
  fs.writeFileSync(path.join(fakeBin, 'kubectl'), '#!/usr/bin/env bash\ncat >/dev/null || true\nexit 0\n');
  fs.chmodSync(path.join(fakeBin, 'kubectl'), 0o755);

  fs.writeFileSync(releaseSelectionFile, JSON.stringify({
    registryHost: 'ghcr.io',
    repository: 'nine-minds/alga-appliance-release',
    manifestDigest: 'sha256:previous',
    runtime: { appHostname: 'psa.example.com', dnsMode: 'system', dnsServers: '' }
  }));

  const valueYaml = `image:\n  tag: latest\n`;
  const coreYaml = `appUrl: https://alga.local\nhost: alga.local\ndomainSuffix: alga.local\nbootstrap:\n  mode: recover\nsetup:\n  image:\n    tag: latest\nserver:\n  image:\n    tag: latest\n`;
  const originalPath = process.env.PATH;
  process.env.PATH = `${fakeBin}:${originalPath}`;

  const result = await runAppChannelUpdate({ channel: 'nightly' }, {
    stateFile,
    releaseSelectionFile,
    updateHistoryFile,
    releaseManifestOverride: {
      schema: 'alga.appliance.release/v1',
      version: '2.0.0-nightly.1',
      valuesProfile: 'test-profile',
      images: {
        algaCore: 'core1234',
        workflowWorker: 'worker1234',
        emailService: 'email1234',
        temporalWorker: 'temporal1234'
      },
      controlPlane: 'cp1234',
      config: { repository: 'ghcr.io/nine-minds/alga-appliance-config', tag: '2.0.0-nightly.1', digest: 'sha256:feedfacefeedfacefeedfacefeedfacefeedfacefeedfacefeedfacefeedface' },
      charts: { sebastian: '0.0.1' },
      profileValues: {
        'alga-core.test-profile.yaml': coreYaml,
        'pgbouncer.test-profile.yaml': valueYaml,
        'temporal.test-profile.yaml': valueYaml,
        'workflow-worker.test-profile.yaml': valueYaml,
        'email-service.test-profile.yaml': valueYaml,
        'temporal-worker.test-profile.yaml': valueYaml
      }
    },
    tokenFile: path.join(tmp, 'setup-token'),
    fluxSourceApplyCommand: `cat > ${fluxManifestPath}`,
    reconcileSourceCommand: 'true',
    reconcileHelmCommand: 'true',
    metadataFile,
    osReleaseFile: path.join(tmp, 'os-release'),
    k3sVersionCommand: "printf 'k3s version v1.31.4+k3s1'"
  });
  process.env.PATH = originalPath;

  assert.equal(result.ok, true);
  assert.equal(result.selectedChannel, 'nightly');
  assert.equal(result.updateScope, 'application-only');

  const state = JSON.parse(fs.readFileSync(stateFile, 'utf8'));
  assert.equal(state.status, 'update-complete');
  assert.equal(state.update.scope, 'application-only');

  const releaseSelection = JSON.parse(fs.readFileSync(releaseSelectionFile, 'utf8'));
  assert.equal(releaseSelection.selectedChannel, 'nightly');
  assert.equal(releaseSelection.selectedReleaseVersion, '2.0.0-nightly.1');

  const history = JSON.parse(fs.readFileSync(updateHistoryFile, 'utf8'));
  assert.equal(Array.isArray(history.history), true);
  assert.equal(history.history[0].ok, true);

  const fluxManifest = fs.readFileSync(fluxManifestPath, 'utf8');
  assert.match(fluxManifest, /kind: OCIRepository/);
});