pikasTech-HWLAB/internal/db/runtime-store.test.mjs

import assert from "node:assert/strict";
import test from "node:test";

import { handleJsonRpcRequest } from "../cloud/json-rpc.mjs";
import { ERROR_CODES, validateResponse } from "../protocol/index.mjs";
import {
  RUNTIME_DURABLE_ADAPTER_AUTH_BLOCKED,
  RUNTIME_DURABLE_ADAPTER_MIGRATION_BLOCKED,
  RUNTIME_DURABLE_ADAPTER_QUERY_BLOCKED,
  RUNTIME_DURABILITY_REQUIRED_EVIDENCE,
  RUNTIME_DURABLE_ADAPTER_SCHEMA_BLOCKED,
  RUNTIME_STORE_KIND_POSTGRES,
  createCloudRuntimeStore,
  createConfiguredCloudRuntimeStore
} from "./runtime-store.mjs";
import {
  CLOUD_CORE_MIGRATION_ID,
  CLOUD_RUNTIME_DURABLE_ADAPTER_SCHEMA_VERSION,
  CLOUD_RUNTIME_DURABLE_TABLE_COLUMNS
} from "./schema.mjs";

test("memory runtime store is never marked durable", () => {
  const store = createCloudRuntimeStore();
  const summary = store.summary();

  assert.equal(summary.adapter, "memory");
  assert.equal(summary.durable, false);
  assert.equal(summary.status, "degraded");
  assert.equal(summary.ready, undefined);
  assert.equal(summary.adapterContract.secretMaterialRequiredInSource, false);
  assert.equal(summary.durabilityContract.ready, false);
  assert.equal(summary.durabilityContract.status, "blocked");
  assert.equal(summary.durabilityContract.blockedLayer, "adapter");
  assert.equal(summary.durabilityContract.adapterQueryRequired, true);
  assert.equal(summary.durabilityContract.dbLiveEvidenceIsDurabilityEvidence, false);
  assert.equal(summary.durabilityContract.secretMaterialRead, false);
});

test("configured postgres runtime classifies auth blocker before schema and migration", async () => {
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_redacted@db.example.invalid:5432/hwlab",
    queryClient: {
      async query(sql) {
        assert.match(sql, /information_schema\.columns/u);
        const error = new Error("auth failed");
        error.code = "28P01";
        throw error;
      }
    }
  });

  const readiness = await store.readiness();
  assert.equal(readiness.adapter, RUNTIME_STORE_KIND_POSTGRES);
  assert.equal(readiness.durable, false);
  assert.equal(readiness.ready, false);
  assert.equal(readiness.status, "blocked");
  assert.equal(readiness.blocker, RUNTIME_DURABLE_ADAPTER_AUTH_BLOCKED);
  assert.equal(readiness.connection.queryAttempted, true);
  assert.equal(readiness.connection.queryResult, "auth_blocked");
  assert.equal(readiness.gates.auth.status, "blocked");
  assert.equal(readiness.gates.schema.status, "not_checked");
  assert.equal(readiness.gates.migration.status, "not_checked");
  assert.equal(readiness.durabilityContract.ready, false);
  assert.equal(readiness.durabilityContract.blockedLayer, "auth");
  assert.equal(readiness.durabilityContract.dbLiveEvidenceIsDurabilityEvidence, false);
});

test("configured postgres runtime reports schema blocker without green readiness", async () => {
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_redacted@db.example.invalid:5432/hwlab",
    queryClient: {
      async query(sql) {
        assert.match(sql, /information_schema\.columns/u);
        return { rows: [] };
      }
    }
  });

  const readiness = await store.readiness();
  assert.equal(readiness.adapter, RUNTIME_STORE_KIND_POSTGRES);
  assert.equal(readiness.durable, false);
  assert.equal(readiness.durableRequested, true);
  assert.equal(readiness.ready, false);
  assert.equal(readiness.status, "blocked");
  assert.equal(readiness.blocker, RUNTIME_DURABLE_ADAPTER_SCHEMA_BLOCKED);
  assert.equal(readiness.liveRuntimeEvidence, false);
  assert.equal(readiness.fixtureEvidence, false);
  assert.equal(readiness.schema.checked, true);
  assert.ok(readiness.schema.missingTables.includes("gateway_sessions"));
  assert.equal(readiness.migration.checked, false);
  assert.equal(readiness.gates.schema.status, "blocked");
  assert.equal(readiness.gates.migration.status, "not_checked");
  assert.equal(readiness.durabilityContract.ready, false);
  assert.equal(readiness.durabilityContract.blockedLayer, "schema");
  assert.equal(readiness.durabilityContract.dbLiveEvidenceIsDurabilityEvidence, false);
  assert.equal(JSON.stringify(readiness).includes("redacted@db.example"), false);
});

test("configured postgres runtime keeps durable false when migration ledger is missing", async () => {
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_redacted@db.example.invalid:5432/hwlab",
    queryClient: createFakePostgresClient({ migrationReady: false })
  });

  const readiness = await store.readiness();
  assert.equal(readiness.adapter, RUNTIME_STORE_KIND_POSTGRES);
  assert.equal(readiness.durable, false);
  assert.equal(readiness.durableRequested, true);
  assert.equal(readiness.ready, false);
  assert.equal(readiness.status, "blocked");
  assert.equal(readiness.blocker, RUNTIME_DURABLE_ADAPTER_MIGRATION_BLOCKED);
  assert.equal(readiness.schema.ready, true);
  assert.equal(readiness.migration.checked, true);
  assert.equal(readiness.migration.ready, false);
  assert.equal(readiness.migration.missing, true);
  assert.equal(readiness.gates.schema.status, "ready");
  assert.equal(readiness.gates.migration.status, "blocked");
  assert.equal(readiness.liveRuntimeEvidence, false);
  assert.equal(readiness.durabilityContract.ready, false);
  assert.equal(readiness.durabilityContract.blockedLayer, "migration");
  assert.equal(readiness.durabilityContract.dbLiveEvidenceIsDurabilityEvidence, false);
});

test("configured postgres runtime classifies durable read query blocker after schema and migration", async () => {
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_redacted@db.example.invalid:5432/hwlab",
    queryClient: createFakePostgresClient({ migrationReady: true, countErrorCode: "57014" })
  });

  const readiness = await store.readiness();
  assert.equal(readiness.adapter, RUNTIME_STORE_KIND_POSTGRES);
  assert.equal(readiness.durable, false);
  assert.equal(readiness.ready, false);
  assert.equal(readiness.status, "blocked");
  assert.equal(readiness.blocker, RUNTIME_DURABLE_ADAPTER_QUERY_BLOCKED);
  assert.equal(readiness.schema.ready, true);
  assert.equal(readiness.migration.ready, true);
  assert.equal(readiness.connection.queryAttempted, true);
  assert.equal(readiness.connection.queryResult, "query_blocked");
  assert.equal(readiness.gates.auth.status, "ready");
  assert.equal(readiness.gates.schema.status, "ready");
  assert.equal(readiness.gates.migration.status, "ready");
  assert.equal(readiness.gates.durability.status, "blocked");
  assert.equal(readiness.durabilityContract.ready, false);
  assert.equal(readiness.durabilityContract.blockedLayer, "durability_query");
  assert.equal(readiness.durabilityContract.dbLiveEvidenceIsDurabilityEvidence, false);
});

test("JSON-RPC audit/evidence durable queries return blocked errors instead of empty success", async () => {
  const secretDbUrl = "postgres://hwlab_user:super-secret-password@db.example.invalid:5432/hwlab";
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: secretDbUrl,
    queryClient: createFakePostgresClient({ migrationReady: true, countErrorCode: "57014" })
  });
  const context = { runtimeStore: store, dbProbe: { probe: false } };
  const meta = {
    traceId: "trc_01J00000000000000000002000",
    actorId: "usr_01J00000000000000000002000",
    serviceId: "hwlab-cloud-web",
    environment: "dev"
  };

  for (const [id, method] of [
    ["req_01J00000000000000000002001", "audit.event.query"],
    ["req_01J00000000000000000002002", "evidence.record.query"]
  ]) {
    const response = await handleJsonRpcRequest(
      {
        jsonrpc: "2.0",
        id,
        method,
        params: {
          projectId: "prj_01J00000000000000000002000"
        },
        meta
      },
      context
    );

    validateResponse(response);
    assert.equal(Object.hasOwn(response, "result"), false);
    assert.equal(response.error.code, ERROR_CODES.internalError);
    assert.equal(response.error.data.method, method);
    assert.equal(response.error.data.adapter, "postgres");
    assert.equal(response.error.data.status, "blocked");
    assert.equal(response.error.data.blocker, RUNTIME_DURABLE_ADAPTER_QUERY_BLOCKED);
    assert.equal(response.error.data.durable, false);
    assert.equal(response.error.data.durableRequested, true);
    assert.equal(response.error.data.liveRuntimeEvidence, false);
    assert.equal(response.error.data.queryResult, "query_blocked");
    assert.equal(response.error.data.blockedLayer, "durability_query");
    assert.equal(response.error.data.requiredEvidence, RUNTIME_DURABILITY_REQUIRED_EVIDENCE);
    assert.equal(response.error.data.dbLiveEvidenceIsDurabilityEvidence, false);
    assert.equal(response.error.data.secretMaterialRead, false);
    assert.equal(response.error.data.valueRedacted, true);
    assert.equal(response.error.data.endpointRedacted, true);
    assert.equal(Object.hasOwn(response.error.data, "events"), false);
    assert.equal(Object.hasOwn(response.error.data, "records"), false);
    assert.equal(Object.hasOwn(response.error.data, "count"), false);

    const serialized = JSON.stringify(response);
    assert.equal(serialized.includes("super-secret-password"), false);
    assert.equal(serialized.includes(secretDbUrl), false);
  }
});

test("JSON-RPC audit/evidence table read failures return blocked errors", async () => {
  const queryClient = createFakePostgresClient({ migrationReady: true, readErrorCode: "57014" });
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_user:another-secret@db.example.invalid:5432/hwlab",
    queryClient
  });
  const context = { runtimeStore: store, dbProbe: { probe: false } };
  const meta = {
    traceId: "trc_01J00000000000000000002200",
    actorId: "usr_01J00000000000000000002200",
    serviceId: "hwlab-cloud-web",
    environment: "dev"
  };

  for (const [id, method] of [
    ["req_01J00000000000000000002201", "audit.event.query"],
    ["req_01J00000000000000000002202", "evidence.record.query"]
  ]) {
    const response = await handleJsonRpcRequest(
      {
        jsonrpc: "2.0",
        id,
        method,
        params: {
          projectId: "prj_01J00000000000000000002200"
        },
        meta
      },
      context
    );

    validateResponse(response);
    assert.equal(Object.hasOwn(response, "result"), false);
    assert.equal(response.error.code, ERROR_CODES.internalError);
    assert.equal(response.error.data.method, method);
    assert.equal(response.error.data.blocker, RUNTIME_DURABLE_ADAPTER_QUERY_BLOCKED);
    assert.equal(response.error.data.queryResult, "query_blocked");
    assert.equal(response.error.data.blockedLayer, "durability_query");

    const serialized = JSON.stringify(response);
    assert.equal(serialized.includes("another-secret"), false);
    assert.equal(serialized.includes("events"), false);
    assert.equal(serialized.includes("records"), false);
    assert.equal(serialized.includes("\"count\":0"), false);
  }
});

test("JSON-RPC durable queries return successful empty result sets for true empty tables", async () => {
  const queryClient = createFakePostgresClient({ migrationReady: true });
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_redacted@db.example.invalid:5432/hwlab",
    queryClient
  });
  const context = { runtimeStore: store, dbProbe: { probe: false } };
  const meta = {
    traceId: "trc_01J00000000000000000002100",
    actorId: "usr_01J00000000000000000002100",
    serviceId: "hwlab-cloud-web",
    environment: "dev"
  };

  async function rpc(id, method, params = {}) {
    const response = await handleJsonRpcRequest(
      {
        jsonrpc: "2.0",
        id,
        method,
        params,
        meta
      },
      context
    );
    validateResponse(response);
    assert.equal(Object.hasOwn(response, "error"), false, response.error?.message);
    return response.result;
  }

  const audit = await rpc("req_01J00000000000000000002101", "audit.event.query", {
    projectId: "prj_01J00000000000000000002100"
  });
  assert.deepEqual(audit.events, []);
  assert.equal(audit.count, 0);
  assert.equal(audit.persistence.adapter, "postgres");
  assert.equal(audit.persistence.durable, true);
  assert.equal(audit.persistence.ready, true);

  const evidence = await rpc("req_01J00000000000000000002102", "evidence.record.query", {
    projectId: "prj_01J00000000000000000002100"
  });
  assert.deepEqual(evidence.records, []);
  assert.equal(evidence.count, 0);
  assert.equal(evidence.persistence.adapter, "postgres");
  assert.equal(evidence.persistence.durable, true);
  assert.equal(evidence.persistence.ready, true);
});

test("configured postgres runtime persists and queries records through query client", async () => {
  const queryClient = createFakePostgresClient({ migrationReady: true });
  const store = createConfiguredCloudRuntimeStore({
    env: {
      HWLAB_CLOUD_RUNTIME_ADAPTER: "postgres",
      HWLAB_CLOUD_RUNTIME_DURABLE: "true"
    },
    dbUrl: "postgres://hwlab_redacted@db.example.invalid:5432/hwlab",
    queryClient,
    now: () => "2026-05-22T00:00:00.000Z"
  });
  const context = { runtimeStore: store, dbProbe: { probe: false } };
  const meta = {
    traceId: "trc_01J00000000000000000001000",
    actorId: "usr_01J00000000000000000001000",
    serviceId: "hwlab-cloud-web",
    environment: "dev"
  };

  async function rpc(id, method, params = {}) {
    const response = await handleJsonRpcRequest(
      {
        jsonrpc: "2.0",
        id,
        method,
        params,
        meta
      },
      context
    );
    validateResponse(response);
    assert.equal(Object.hasOwn(response, "error"), false, response.error?.message);
    return response.result;
  }

  const health = await rpc("req_01J00000000000000000001000", "system.health");
  assert.equal(health.runtime.adapter, "postgres");
  assert.equal(health.runtime.durable, true);
  assert.equal(health.runtime.durableRequested, true);
  assert.equal(health.runtime.durableCapable, true);
  assert.equal(health.runtime.ready, true);
  assert.equal(health.runtime.liveRuntimeEvidence, true);
  assert.equal(health.runtime.fixtureEvidence, false);
  assert.equal(health.runtime.schema.ready, true);
  assert.equal(health.runtime.migration.ready, true);
  assert.equal(health.runtime.gates.migration.status, "ready");
  assert.equal(health.runtime.gates.durability.status, "ready");
  assert.equal(health.runtime.durabilityContract.ready, true);
  assert.equal(health.runtime.durabilityContract.blockedLayer, null);
  assert.equal(health.runtime.durabilityContract.dbLiveEvidenceIsDurabilityEvidence, false);
  assert.equal(health.readiness.components.runtime, "ready");
  assert.equal(health.readiness.durability.status, "ready");
  assert.equal(health.readiness.durability.dbLiveEvidenceIsDurabilityEvidence, false);

  await rpc("req_01J00000000000000000001001", "gateway.session.register", {
    projectId: "prj_01J00000000000000000001000",
    gatewaySessionId: "gws_01J00000000000000000001000",
    gatewayId: "gtw_01J00000000000000000001000",
    serviceId: "hwlab-gateway-simu",
    endpoint: "http://127.0.0.1:7101"
  });
  await rpc("req_01J00000000000000000001002", "box.resource.register", {
    projectId: "prj_01J00000000000000000001000",
    gatewaySessionId: "gws_01J00000000000000000001000",
    resourceId: "res_01J00000000000000000001000",
    boxId: "box_01J00000000000000000001000",
    resourceType: "board",
    state: "available"
  });
  await rpc("req_01J00000000000000000001003", "box.capability.report", {
    capabilityId: "cap_01J00000000000000000001000",
    resourceId: "res_01J00000000000000000001000",
    projectId: "prj_01J00000000000000000001000",
    name: "shell.exec",
    direction: "bidirectional",
    valueType: "object",
    mutatesState: true
  });
  const invoke = await rpc("req_01J00000000000000000001004", "hardware.invoke.shell", {
    projectId: "prj_01J00000000000000000001000",
    gatewaySessionId: "gws_01J00000000000000000001000",
    resourceId: "res_01J00000000000000000001000",
    capabilityId: "cap_01J00000000000000000001000",
    input: {
      command: "echo durable"
    }
  });

  const audit = await rpc("req_01J00000000000000000001005", "audit.event.query", {
    projectId: "prj_01J00000000000000000001000"
  });
  const evidence = await rpc("req_01J00000000000000000001006", "evidence.record.query", {
    projectId: "prj_01J00000000000000000001000"
  });

  assert.ok(queryClient.calls.some((call) => call.sql.startsWith("INSERT INTO gateway_sessions")));
  assert.ok(queryClient.calls.some((call) => call.sql.startsWith("INSERT INTO evidence_records")));
  assert.ok(audit.events.some((event) => event.action === "hardware.invoke.shell"));
  assert.equal(evidence.count, 1);
  assert.equal(evidence.records[0].operationId, invoke.operationId);
});

function createFakePostgresClient({ migrationReady = true, countErrorCode = null, readErrorCode = null } = {}) {
  const state = {
    gateway_sessions: new Map(),
    box_resources: new Map(),
    box_capabilities: new Map(),
    hardware_operations: new Map(),
    audit_events: new Map(),
    evidence_records: new Map(),
    hwlab_schema_migrations: new Map()
  };
  if (migrationReady) {
    state.hwlab_schema_migrations.set(CLOUD_CORE_MIGRATION_ID, {
      id: CLOUD_CORE_MIGRATION_ID,
      schema_version: CLOUD_RUNTIME_DURABLE_ADAPTER_SCHEMA_VERSION
    });
  }
  const calls = [];

  return {
    calls,
    async query(sql, params = []) {
      calls.push({ sql, params });
      if (sql.includes("information_schema.columns")) {
        return { rows: schemaRows() };
      }
      if (sql.startsWith("SELECT COUNT(*)::int AS count FROM ")) {
        if (countErrorCode) {
          const error = new Error("count query failed");
          error.code = countErrorCode;
          throw error;
        }
        const table = sql.match(/FROM ([a-z_]+)/u)?.[1];
        return { rows: [{ count: state[table]?.size ?? 0 }] };
      }
      if (sql.startsWith("SELECT id, schema_version FROM hwlab_schema_migrations")) {
        const row = state.hwlab_schema_migrations.get(params[0]);
        return { rows: row ? [row] : [] };
      }
      if (sql.startsWith("SELECT gateway_session_json FROM gateway_sessions")) {
        return jsonSelect(state.gateway_sessions, params[0], "gateway_session_json");
      }
      if (sql.startsWith("SELECT resource_json FROM box_resources")) {
        return jsonSelect(state.box_resources, params[0], "resource_json");
      }
      if (sql.startsWith("SELECT capability_json FROM box_capabilities")) {
        return jsonSelect(state.box_capabilities, params[0], "capability_json");
      }
      if (sql.startsWith("SELECT event_json FROM audit_events")) {
        if (readErrorCode) {
          const error = new Error("audit read query failed");
          error.code = readErrorCode;
          throw error;
        }
        return { rows: [...state.audit_events.values()].map((record) => ({ event_json: record.event_json })) };
      }
      if (sql.startsWith("SELECT metadata_json FROM evidence_records")) {
        if (readErrorCode) {
          const error = new Error("evidence read query failed");
          error.code = readErrorCode;
          throw error;
        }
        return { rows: [...state.evidence_records.values()].map((record) => ({ metadata_json: record.metadata_json })) };
      }
      if (sql.startsWith("INSERT INTO gateway_sessions")) {
        state.gateway_sessions.set(params[0], { gateway_session_json: params[6] });
        return { rows: [] };
      }
      if (sql.startsWith("INSERT INTO box_resources")) {
        state.box_resources.set(params[0], { resource_json: params[5] });
        return { rows: [] };
      }
      if (sql.startsWith("INSERT INTO box_capabilities")) {
        state.box_capabilities.set(params[0], { capability_json: params[3] });
        return { rows: [] };
      }
      if (sql.startsWith("INSERT INTO hardware_operations")) {
        state.hardware_operations.set(params[0], { operation_json: params[4] });
        return { rows: [] };
      }
      if (sql.startsWith("INSERT INTO audit_events")) {
        state.audit_events.set(params[0], { event_json: params[8] });
        return { rows: [] };
      }
      if (sql.startsWith("INSERT INTO evidence_records")) {
        state.evidence_records.set(params[0], { metadata_json: params[5] });
        return { rows: [] };
      }
      throw new Error(`unexpected sql: ${sql}`);
    }
  };
}

function schemaRows() {
  return Object.entries(CLOUD_RUNTIME_DURABLE_TABLE_COLUMNS).flatMap(([table, columns]) =>
    columns.map((column) => ({
      table_name: table,
      column_name: column
    }))
  );
}

function jsonSelect(map, id, column) {
  const row = map.get(id);
  return {
    rows: row ? [{ [column]: row[column] }] : []
  };
}