Files
hermes-agent/tests-js/source-update-observer.test.mjs
ethernet 53e6f001c7 refactor(pm): consolidate runtime ownership and updater completion
Run historical updater completion in a fresh interpreter so cached imports
cannot revive retired dependency installers. Share Git and ZIP completion,
carry receipt and recovery state, and preserve child exit status.

Route plugin admission, binary acquisition, desktop launch and build paths
through PM. Replace redundant helpers and tests with real worker, package,
publication and launch checks. Keep the shipped compatibility surface fixed.

Targeted Python and desktop checks pass. Native update journeys and fresh
production image qualification remain pending. This is a checkpoint before
those acceptance runs.
2026-09-12 16:30:35 -04:00

42 lines
2.0 KiB
JavaScript

import { mkdtempSync, mkdirSync, writeFileSync, rmSync } from 'node:fs'
import { tmpdir } from 'node:os'
import { join } from 'node:path'
import { afterEach, expect, test } from 'vitest'
import { observeSourceUpdate } from '../tests/install/e2e-assets/source-update-observer.mjs'
const roots = []
afterEach(() => roots.splice(0).forEach(root => rmSync(root, { recursive: true, force: true })))
function fixture() {
const home = mkdtempSync(join(tmpdir(), 'source-update-observer-'))
roots.push(home)
const receipts = join(home, 'logs/update_receipts')
mkdirSync(receipts, { recursive: true })
const resultPath = join(home, '.hermes-update-result.json')
const write = (name, data) => writeFileSync(join(receipts, name), JSON.stringify(data))
return { home, resultPath, write }
}
test('checkout movement and old receipts are not update completion', () => {
const f = fixture()
f.write('update_old.json', { outcome: 'success', finished_at: 'old', post_update: { sha: 'target' } })
const observe = observeSourceUpdate({ ...f, expectSha: 'target' })
expect(observe('target')).toBe(false)
f.write('pm_sync.json', { outcome: 'success', finished_at: 'now', post_update: { sha: 'target' } })
expect(observe('target')).toBe(false)
f.write('update_new.json', { outcome: 'success', finished_at: 'now', post_update: { sha: 'target' } })
expect(observe('old')).toBe(false)
expect(observe('target')).toBe(true)
})
test('failed handoff fails even at target SHA; success waits for marker removal', () => {
const f = fixture()
const observe = observeSourceUpdate({ ...f, expectSha: 'target' })
writeFileSync(f.resultPath, JSON.stringify({ ok: false, exit_code: 1 }))
expect(() => observe('target')).toThrow(/failed/)
writeFileSync(f.resultPath, JSON.stringify({ ok: true, exit_code: 0 }))
const marker = join(f.home, '.hermes-update-in-progress')
writeFileSync(marker, 'updater still finishing')
expect(observe('target')).toBe(false)
rmSync(marker)
expect(observe('target')).toBe(true)
})