P2P-Hiverelay / test / unit / api-health.test.js

import test from 'brittle'
import {
  buildHealthResponse,
  diskHealthSummary,
  MAX_HEALTH_DISK_ERROR_BYTES,
  resolveHealthRoute
} from '../../packages/core/core/relay-node/api-health.js'

function nodeFixture (overrides = {}) {
  return {
    running: true,
    config: {},
    metrics: {
      getSummary () {
        return { uptime: 1234 }
      }
    },
    ...overrides
  }
}

test('api health: route resolver maps only the exact public health route', (t) => {
  t.alike(resolveHealthRoute('GET', '/health'), { kind: 'health' })
  t.is(resolveHealthRoute('POST', '/health'), null, 'wrong method falls through')
  t.is(resolveHealthRoute('GET', '/health/extra'), null, 'subpath falls through')
  t.is(resolveHealthRoute('GET', '/status'), null, 'adjacent status route falls through')
  t.is(resolveHealthRoute('GET', '/api/health-detail'), null, 'operator health detail route falls through')
})

test('api health: summarizes missing, error, and ordinary disk state', (t) => {
  t.is(diskHealthSummary(null), null)
  t.alike(diskHealthSummary({ error: 'df failed', status: 'critical', usedPct: 99 }), {
    error: 'df failed'
  })
  t.alike(diskHealthSummary({
    usedPct: 72.5,
    status: 'warn',
    mountPath: '/data',
    extra: 'not public'
  }), {
    usedPct: 72.5,
    status: 'warn'
  })
})

test('api health: disk summary omits filesystem topology and caps unsafe errors', (t) => {
  t.alike(diskHealthSummary({
    usedPct: -1,
    status: 'weird',
    mountPath: '/private/data'
  }), {
    usedPct: 0,
    status: null
  })

  t.alike(diskHealthSummary({
    error: 'df failed\n/private/data',
    mountPath: '/private/data'
  }), {
    usedPct: 0,
    status: null
  })

  const out = diskHealthSummary({ error: 'x'.repeat(MAX_HEALTH_DISK_ERROR_BYTES + 10) })
  t.is(out.error.length, MAX_HEALTH_DISK_ERROR_BYTES)
})

test('api health: healthy response includes version uptime running and disk facts', (t) => {
  const out = buildHealthResponse({
    version: '9.9.9',
    node: nodeFixture({
      diskMonitor: {
        getInfo () {
          return { usedPct: 42, status: 'ok', mountPath: '/relay' }
        }
      }
    })
  })

  t.is(out.status, 200)
  t.alike(out.payload, {
    ok: true,
    version: '9.9.9',
    uptime: 1234,
    running: true,
    disk: { usedPct: 42, status: 'ok' }
  })
})

test('api health: critical disk stays 200 unless diskHealthGate is enabled', (t) => {
  const out = buildHealthResponse({
    version: '1.2.3',
    node: nodeFixture({
      config: { diskHealthGate: false },
      diskMonitor: {
        getInfo () {
          return { usedPct: 99, status: 'critical', mountPath: '/data' }
        }
      }
    })
  })

  t.is(out.status, 200)
  t.is(out.payload.ok, true)
  t.is(out.payload.disk.status, 'critical')
})

test('api health: diskHealthGate drains critical relays with stable fleet payload', (t) => {
  const out = buildHealthResponse({
    version: '2.0.0',
    node: nodeFixture({
      running: false,
      config: { diskHealthGate: true },
      diskMonitor: {
        getInfo () {
          return { usedPct: 98.2, status: 'critical', mountPath: '/data' }
        }
      }
    })
  })

  t.is(out.status, 503)
  t.alike(out.payload, {
    ok: false,
    reason: 'disk-critical',
    version: '2.0.0',
    uptime: 1234,
    running: false,
    disk: { usedPct: 98.2, status: 'critical' }
  })
})

test('api health: missing metrics and disk monitor remain stable', (t) => {
  const out = buildHealthResponse({
    version: null,
    node: nodeFixture({ metrics: null, diskMonitor: null })
  })

  t.is(out.status, 200)
  t.alike(out.payload, {
    ok: true,
    version: null,
    uptime: null,
    running: true,
    disk: null
  })
})