Hide_D
ce0c9e257d
미래 예약 RESET을 보존하면서 DB 유지 DEPLOY 한 건을 별도 queue lane에 등록한다. 예약 시각까지 시작되지 않은 중간 배포는 RESET claim 전에 자동 취소하고 관리자 화면에 이 경계를 안내한다.
74 lines
3.2 KiB
TypeScript
74 lines
3.2 KiB
TypeScript
import fs from 'node:fs/promises';
|
|
import os from 'node:os';
|
|
import path from 'node:path';
|
|
|
|
import { afterEach, describe, expect, it } from 'vitest';
|
|
|
|
import { readReleaseManifest, RELEASE_CONTROLLER_PROTOCOL } from '../src/orchestrator/releaseManifest.js';
|
|
|
|
const temporaryDirectories: string[] = [];
|
|
|
|
const createWorkspace = async (gatewayHead: string, gameHead: string, controllerProtocol = 1): Promise<string> => {
|
|
const workspace = await fs.mkdtemp(path.join(os.tmpdir(), 'sammo-release-manifest-'));
|
|
temporaryDirectories.push(workspace);
|
|
await fs.mkdir(path.join(workspace, 'packages/infra/prisma/gateway-migrations', gatewayHead), {
|
|
recursive: true,
|
|
});
|
|
await fs.mkdir(path.join(workspace, 'packages/infra/prisma/migrations', gameHead), { recursive: true });
|
|
await fs.writeFile(
|
|
path.join(workspace, 'release-manifest.json'),
|
|
JSON.stringify({
|
|
formatVersion: 1,
|
|
controllerProtocol,
|
|
gatewaySchemaHead: gatewayHead,
|
|
gameSchemaHead: gameHead,
|
|
components: ['gateway-api', 'gateway-frontend', 'game-api', 'game-engine', 'game-frontend'],
|
|
})
|
|
);
|
|
return workspace;
|
|
};
|
|
|
|
afterEach(async () => {
|
|
await Promise.all(temporaryDirectories.splice(0).map((directory) => fs.rm(directory, { recursive: true })));
|
|
});
|
|
|
|
describe('readReleaseManifest', () => {
|
|
it('keeps the checked-in manifest aligned with the checked-in migration heads', async () => {
|
|
const workspaceRoot = path.resolve(import.meta.dirname, '../../..');
|
|
|
|
await expect(readReleaseManifest(workspaceRoot)).resolves.toMatchObject({
|
|
controllerProtocol: RELEASE_CONTROLLER_PROTOCOL,
|
|
gatewaySchemaHead: '20260824090000_allow_interim_profile_deploy',
|
|
gameSchemaHead: '20260824080000_vote_utc_wall_timestamps',
|
|
});
|
|
});
|
|
|
|
it('accepts a manifest whose schema heads match the selected workspace', async () => {
|
|
const workspace = await createWorkspace('20260801000000_gateway', '20260801000000_game');
|
|
|
|
await expect(readReleaseManifest(workspace)).resolves.toMatchObject({
|
|
gatewaySchemaHead: '20260801000000_gateway',
|
|
gameSchemaHead: '20260801000000_game',
|
|
});
|
|
});
|
|
|
|
it('rejects a stale schema head before any deployment command runs', async () => {
|
|
const workspace = await createWorkspace('20260801000000_gateway', '20260801000000_game');
|
|
await fs.mkdir(path.join(workspace, 'packages/infra/prisma/migrations/20260802000000_newer'));
|
|
|
|
await expect(readReleaseManifest(workspace)).rejects.toThrow('does not match workspace head');
|
|
});
|
|
|
|
it('allows only the explicit controller self-upgrade boundary to cross protocol versions', async () => {
|
|
const futureProtocol = RELEASE_CONTROLLER_PROTOCOL + 1;
|
|
const workspace = await createWorkspace('20260801000000_gateway', '20260801000000_game', futureProtocol);
|
|
|
|
await expect(readReleaseManifest(workspace)).rejects.toThrow(
|
|
`Release requires controller protocol ${futureProtocol}`
|
|
);
|
|
await expect(readReleaseManifest(workspace, { allowControllerUpgrade: true })).resolves.toMatchObject({
|
|
controllerProtocol: futureProtocol,
|
|
});
|
|
});
|
|
});
|