test: 통일 이민족 소환 뒤 턴 재개 검증
This commit is contained in:
@@ -0,0 +1,276 @@
|
|||||||
|
import { describe, expect, it, vi } from 'vitest';
|
||||||
|
|
||||||
|
import { ManualClock } from '@sammo-ts/common';
|
||||||
|
import type { GamePrisma } from '@sammo-ts/infra';
|
||||||
|
import type { City, MapDefinition, MessagePayload, Nation, ScenarioConfig } from '@sammo-ts/logic';
|
||||||
|
|
||||||
|
import { InMemoryControlQueue } from '../src/lifecycle/inMemoryControlQueue.js';
|
||||||
|
import { TurnDaemonLifecycle } from '../src/lifecycle/turnDaemonLifecycle.js';
|
||||||
|
import { InMemoryTurnProcessor } from '../src/turn/inMemoryTurnProcessor.js';
|
||||||
|
import { InMemoryTurnStateStore } from '../src/turn/inMemoryStateStore.js';
|
||||||
|
import { InMemoryTurnWorld } from '../src/turn/inMemoryWorld.js';
|
||||||
|
import { InMemoryReservedTurnStore } from '../src/turn/reservedTurnStore.js';
|
||||||
|
import type { TurnGeneral, TurnWorldSnapshot, TurnWorldState } from '../src/turn/types.js';
|
||||||
|
import { createTurnDaemonCommandHandler } from '../src/turn/worldCommandHandler.js';
|
||||||
|
|
||||||
|
const addMinutes = (time: Date, minutes: number): Date => new Date(time.getTime() + minutes * 60_000);
|
||||||
|
|
||||||
|
const liveLastTurnTime = new Date('2026-08-19T21:14:00.000Z');
|
||||||
|
const liveWallAnchor = new Date('2026-08-20T06:21:58.611Z');
|
||||||
|
const acceptedAt = addMinutes(liveWallAnchor, 3);
|
||||||
|
|
||||||
|
const buildGeneral = (options: {
|
||||||
|
id: number;
|
||||||
|
name: string;
|
||||||
|
userId: string | null;
|
||||||
|
officerLevel: number;
|
||||||
|
npcState: number;
|
||||||
|
turnMinute: number;
|
||||||
|
}): TurnGeneral => ({
|
||||||
|
id: options.id,
|
||||||
|
userId: options.userId,
|
||||||
|
name: options.name,
|
||||||
|
nationId: 6,
|
||||||
|
cityId: 1,
|
||||||
|
troopId: 0,
|
||||||
|
stats: { leadership: 70, strength: 60, intelligence: 50 },
|
||||||
|
turnTime: addMinutes(liveLastTurnTime, options.turnMinute),
|
||||||
|
recentWarTime: null,
|
||||||
|
role: {
|
||||||
|
items: { horse: null, weapon: null, book: null, item: null },
|
||||||
|
personality: null,
|
||||||
|
specialDomestic: null,
|
||||||
|
specialWar: null,
|
||||||
|
},
|
||||||
|
triggerState: { flags: {}, counters: {}, modifiers: {}, meta: {} },
|
||||||
|
meta: { killturn: 240, dex1: 10, dex2: 20, dex3: 30, dex4: 40, dex5: 50 },
|
||||||
|
penalty: {},
|
||||||
|
officerLevel: options.officerLevel,
|
||||||
|
experience: 1_000,
|
||||||
|
dedication: 1_000,
|
||||||
|
injury: 0,
|
||||||
|
gold: 1_000,
|
||||||
|
rice: 1_000,
|
||||||
|
crew: 0,
|
||||||
|
crewTypeId: 0,
|
||||||
|
train: 0,
|
||||||
|
atmos: 0,
|
||||||
|
age: 30,
|
||||||
|
npcState: options.npcState,
|
||||||
|
});
|
||||||
|
|
||||||
|
const city = (id: number, level: number): City => ({
|
||||||
|
id,
|
||||||
|
name: id === 1 ? '업' : '남만',
|
||||||
|
nationId: 6,
|
||||||
|
level,
|
||||||
|
state: 0,
|
||||||
|
population: 10_000,
|
||||||
|
populationMax: 100_000,
|
||||||
|
agriculture: 1_000,
|
||||||
|
agricultureMax: 2_000,
|
||||||
|
commerce: 1_000,
|
||||||
|
commerceMax: 2_000,
|
||||||
|
security: 1_000,
|
||||||
|
securityMax: 2_000,
|
||||||
|
supplyState: 1,
|
||||||
|
frontState: 0,
|
||||||
|
defence: 1_000,
|
||||||
|
defenceMax: 2_000,
|
||||||
|
wall: 1_000,
|
||||||
|
wallMax: 2_000,
|
||||||
|
meta: {},
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('HWE-shaped unification invader resume', () => {
|
||||||
|
it('drains the recipient response while united is halted and resumes the next scheduled month', async () => {
|
||||||
|
const recipient = buildGeneral({
|
||||||
|
id: 882,
|
||||||
|
name: '운영자',
|
||||||
|
userId: 'hwe-recipient-882',
|
||||||
|
officerLevel: 11,
|
||||||
|
npcState: 0,
|
||||||
|
turnMinute: 1,
|
||||||
|
});
|
||||||
|
const generals = [
|
||||||
|
buildGeneral({
|
||||||
|
id: 41,
|
||||||
|
name: 'ⓝ곽가',
|
||||||
|
userId: null,
|
||||||
|
officerLevel: 12,
|
||||||
|
npcState: 2,
|
||||||
|
turnMinute: 2,
|
||||||
|
}),
|
||||||
|
recipient,
|
||||||
|
buildGeneral({
|
||||||
|
id: 966,
|
||||||
|
name: '유여',
|
||||||
|
userId: 'hwe-recipient-966',
|
||||||
|
officerLevel: 10,
|
||||||
|
npcState: 0,
|
||||||
|
turnMinute: 3,
|
||||||
|
}),
|
||||||
|
];
|
||||||
|
const nation: Nation = {
|
||||||
|
id: 6,
|
||||||
|
name: '㉿곽가',
|
||||||
|
color: '#777777',
|
||||||
|
capitalCityId: 1,
|
||||||
|
chiefGeneralId: 41,
|
||||||
|
gold: 1_000,
|
||||||
|
rice: 1_000,
|
||||||
|
power: 0,
|
||||||
|
level: 4,
|
||||||
|
typeCode: 'che_유가',
|
||||||
|
meta: { tech: 100, war: 1, scout: 1 },
|
||||||
|
};
|
||||||
|
const scenarioConfig: ScenarioConfig = {
|
||||||
|
stat: { total: 300, min: 10, max: 100, npcTotal: 150, npcMax: 75, npcMin: 10, chiefMin: 70 },
|
||||||
|
iconPath: '.',
|
||||||
|
map: {},
|
||||||
|
const: {},
|
||||||
|
environment: { mapName: 'test', unitSet: 'default' },
|
||||||
|
};
|
||||||
|
const map: MapDefinition = {
|
||||||
|
id: 'test',
|
||||||
|
name: 'test',
|
||||||
|
cities: [],
|
||||||
|
};
|
||||||
|
const state: TurnWorldState = {
|
||||||
|
id: 1,
|
||||||
|
currentYear: 226,
|
||||||
|
currentMonth: 3,
|
||||||
|
tickSeconds: 60,
|
||||||
|
lastTurnTime: liveLastTurnTime,
|
||||||
|
clockBaseTime: new Date('2026-08-19T12:00:00.000Z'),
|
||||||
|
clockTick: 19_980_000_000,
|
||||||
|
clockMode: 'realtime',
|
||||||
|
clockWallAnchor: liveWallAnchor,
|
||||||
|
lastTurnTick: 19_944_000_000,
|
||||||
|
meta: {
|
||||||
|
hiddenSeed: 'hwe-invader-resume-fixture',
|
||||||
|
serverId: 'hwe:default_snapshot',
|
||||||
|
isUnited: 2,
|
||||||
|
isunited: 2,
|
||||||
|
refreshLimit: 3_000,
|
||||||
|
maxGeneralsPerMinute: 1_000,
|
||||||
|
},
|
||||||
|
};
|
||||||
|
const snapshot: TurnWorldSnapshot = {
|
||||||
|
generals,
|
||||||
|
cities: [city(1, 3), city(2, 4)],
|
||||||
|
nations: [nation],
|
||||||
|
troops: [],
|
||||||
|
diplomacy: [],
|
||||||
|
events: [],
|
||||||
|
initialEvents: [],
|
||||||
|
scenarioConfig,
|
||||||
|
map,
|
||||||
|
};
|
||||||
|
const world = new InMemoryTurnWorld(state, snapshot, {
|
||||||
|
schedule: { entries: [{ startMinute: 0, tickMinutes: 1 }] },
|
||||||
|
});
|
||||||
|
const reservedTurns = new InMemoryReservedTurnStore(
|
||||||
|
{
|
||||||
|
generalTurn: { findMany: vi.fn(), deleteMany: vi.fn(), createMany: vi.fn() },
|
||||||
|
nationTurn: { findMany: vi.fn(), deleteMany: vi.fn(), createMany: vi.fn() },
|
||||||
|
} as never,
|
||||||
|
{ maxGeneralTurns: 30, maxNationTurns: 12 }
|
||||||
|
);
|
||||||
|
const message: MessagePayload = {
|
||||||
|
src: { generalId: 0, generalName: '', nationId: 0, nationName: 'System', color: '#000000', icon: '' },
|
||||||
|
dest: {
|
||||||
|
generalId: recipient.id,
|
||||||
|
generalName: recipient.name,
|
||||||
|
nationId: nation.id,
|
||||||
|
nationName: nation.name,
|
||||||
|
color: nation.color,
|
||||||
|
icon: '',
|
||||||
|
},
|
||||||
|
text: '이벤트 게임으로 이민족[쉬움]을 소환',
|
||||||
|
option: { action: 'raiseInvader', args: [-1, -1, -0.8, 0], used: false },
|
||||||
|
};
|
||||||
|
const requestId = 'hwe-invader-resume-message-1014';
|
||||||
|
const commandDb = {
|
||||||
|
inputEvent: {
|
||||||
|
findUnique: vi.fn(async () => ({
|
||||||
|
actorUserId: recipient.userId,
|
||||||
|
target: 'ENGINE',
|
||||||
|
eventType: 'messageRespond',
|
||||||
|
createdAt: acceptedAt,
|
||||||
|
})),
|
||||||
|
},
|
||||||
|
$queryRaw: vi.fn(async () => [
|
||||||
|
{
|
||||||
|
id: 1014,
|
||||||
|
mailbox: recipient.id,
|
||||||
|
type: 'private',
|
||||||
|
validUntil: new Date('9999-12-31T00:00:00.000Z'),
|
||||||
|
message,
|
||||||
|
},
|
||||||
|
]),
|
||||||
|
} as unknown as GamePrisma.TransactionClient;
|
||||||
|
const queue = new InMemoryControlQueue();
|
||||||
|
queue.enqueue({
|
||||||
|
type: 'messageRespond',
|
||||||
|
requestId,
|
||||||
|
userId: recipient.userId!,
|
||||||
|
generalId: recipient.id,
|
||||||
|
messageId: 1014,
|
||||||
|
response: true,
|
||||||
|
});
|
||||||
|
const commandHandler = createTurnDaemonCommandHandler({
|
||||||
|
world,
|
||||||
|
reservedTurns,
|
||||||
|
scenarioMeta: {
|
||||||
|
title: 'HWE snapshot',
|
||||||
|
startYear: 180,
|
||||||
|
life: null,
|
||||||
|
fiction: null,
|
||||||
|
history: [],
|
||||||
|
ignoreDefaultEvents: false,
|
||||||
|
},
|
||||||
|
map,
|
||||||
|
loadArchivedNationMaxId: async () => 57,
|
||||||
|
});
|
||||||
|
const processor = new InMemoryTurnProcessor(world);
|
||||||
|
const run = vi.fn(async (...args: Parameters<InMemoryTurnProcessor['run']>) => {
|
||||||
|
const result = await processor.run(...args);
|
||||||
|
queue.enqueue({ type: 'shutdown', reason: 'one resumed monthly boundary verified' });
|
||||||
|
return result;
|
||||||
|
});
|
||||||
|
const lifecycle = new TurnDaemonLifecycle(
|
||||||
|
{
|
||||||
|
clock: new ManualClock(acceptedAt.getTime()),
|
||||||
|
controlQueue: queue,
|
||||||
|
getNextTickTime: (value) => addMinutes(value, 1),
|
||||||
|
stateStore: new InMemoryTurnStateStore(world),
|
||||||
|
processor: { run },
|
||||||
|
commandHandler,
|
||||||
|
hooks: {
|
||||||
|
executeCommand: async (_commandRequestId, execute) => execute({ db: commandDb }),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
profile: 'hwe:default-snapshot',
|
||||||
|
defaultBudget: { budgetMs: 5_000, maxGenerals: 200, catchUpCap: 1 },
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
await lifecycle.start();
|
||||||
|
|
||||||
|
expect(commandDb.inputEvent.findUnique).toHaveBeenCalledWith(
|
||||||
|
expect.objectContaining({ where: { requestId } })
|
||||||
|
);
|
||||||
|
expect(commandDb.$queryRaw).toHaveBeenCalledOnce();
|
||||||
|
expect(world.getState()).toMatchObject({
|
||||||
|
currentYear: 226,
|
||||||
|
currentMonth: 4,
|
||||||
|
meta: { isUnited: 1, isunited: 1 },
|
||||||
|
});
|
||||||
|
expect(world.listNations().filter((entry) => entry.name.startsWith('ⓞ'))).toHaveLength(1);
|
||||||
|
expect(world.listGenerals().filter((entry) => entry.npcState === 9)).toHaveLength(10);
|
||||||
|
expect(run).toHaveBeenCalledOnce();
|
||||||
|
expect(lifecycle.getStatus().lastTurnTime).toBe('2026-08-19T21:15:00.000Z');
|
||||||
|
});
|
||||||
|
});
|
||||||
Reference in New Issue
Block a user