joshandClaude Opus 4.7
13a29e5ace
Full server lifecycle management from Electric Cherry: pick game/mode/map/pluto key in the Fleet page, EC provisions the deployment via Komodo, allocates a port in 28960-28980, creates the 0o777 host dir, and starts the container. Destroy button tears everything down (Komodo Destroy+Delete, rm -rf host dir, transactional DB cleanup) and surfaces any partial-failure warnings inline. Same phase cuts over to the new naming scheme (t5_zombie_cosmodrome_1 etc.). Komodo entity names now match EC server names 1:1 (no more _/- transform), and the map catalog carries friendly/slug/canonical for each of the 11 t5 zombie maps. Server rows gain game_mode, map_slug, host_dir, config_file, game_id, image, created_by, and destroyed_at columns for provisioning + audit. Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
97 lines
3.9 KiB
TypeScript
97 lines
3.9 KiB
TypeScript
import { describe, expect, it, beforeEach, afterEach } from 'vitest';
|
|
import { mkdirSync, rmSync, writeFileSync } from 'node:fs';
|
|
import { resolve } from 'node:path';
|
|
import { tmpdir } from 'node:os';
|
|
|
|
// The logs module reads config.serversRoot lazily, so set SERVERS_ROOT
|
|
// before importing it. Vitest imports the module once per file so we
|
|
// stash the root globally and reset between describe blocks.
|
|
const TMP_ROOT = resolve(tmpdir(), `ec-logs-test-${Date.now()}`);
|
|
process.env.SERVERS_ROOT = TMP_ROOT;
|
|
process.env.REL_DEST = 'runtime/plutonium/storage/t5/raw/scripts/sp';
|
|
process.env.BETA_ARCHIVE_DIR = resolve(TMP_ROOT, 'beta-archive');
|
|
process.env.DB_PATH = resolve(TMP_ROOT, 'test.db');
|
|
|
|
const { resolveLogPath, tailLog, isLogKey } = await import(
|
|
'../../src/lib/server/fleet/logs.js'
|
|
);
|
|
|
|
const SERVER = 't5_zombie_theater_1';
|
|
const LOG_DIR = resolve(TMP_ROOT, SERVER, 'logs');
|
|
|
|
beforeEach(() => {
|
|
mkdirSync(LOG_DIR, { recursive: true });
|
|
});
|
|
|
|
afterEach(() => {
|
|
rmSync(TMP_ROOT, { recursive: true, force: true });
|
|
});
|
|
|
|
describe('isLogKey', () => {
|
|
it('accepts whitelisted keys and rejects anything else', () => {
|
|
expect(isLogKey('console')).toBe(true);
|
|
expect(isLogKey('games_sp')).toBe(true);
|
|
expect(isLogKey('bogus')).toBe(false);
|
|
expect(isLogKey('../etc/passwd')).toBe(false);
|
|
});
|
|
});
|
|
|
|
describe('resolveLogPath', () => {
|
|
it('resolves whitelisted log keys under the server directory', () => {
|
|
const p = resolveLogPath(SERVER, 'console');
|
|
expect(p).toBe(resolve(TMP_ROOT, SERVER, 'logs/console.log'));
|
|
});
|
|
|
|
it('rejects a server name that would path-traverse', () => {
|
|
// Server name with .. tries to escape the servers root
|
|
const p = resolveLogPath('..', 'console');
|
|
// resolve(TMP_ROOT, '..', 'logs/console.log') escapes TMP_ROOT,
|
|
// so the guard against non-serverDir-prefixed paths kicks in.
|
|
// The check is against the resolved server dir; escaping should
|
|
// return null.
|
|
expect(p).toBeNull();
|
|
});
|
|
});
|
|
|
|
describe('tailLog', () => {
|
|
it('returns null for a missing file (not an error)', async () => {
|
|
const path = resolve(LOG_DIR, 'console.log');
|
|
expect(await tailLog(path, 10)).toBeNull();
|
|
});
|
|
|
|
it('returns the last N lines of a small file with truncated=false', async () => {
|
|
const path = resolve(LOG_DIR, 'console.log');
|
|
const body = Array.from({ length: 20 }, (_, i) => `line ${i}`).join('\n') + '\n';
|
|
writeFileSync(path, body);
|
|
|
|
const tail = await tailLog(path, 5);
|
|
expect(tail).not.toBeNull();
|
|
expect(tail?.lines).toEqual(['line 15', 'line 16', 'line 17', 'line 18', 'line 19']);
|
|
expect(tail?.truncated).toBe(false);
|
|
expect(tail?.size).toBe(body.length);
|
|
});
|
|
|
|
it('caps at MAX_TAIL_LINES and marks truncated when reading past the window', async () => {
|
|
const path = resolve(LOG_DIR, 'big.log');
|
|
// 500 KB of 60-char lines — comfortably larger than the 256 KB read window.
|
|
const line = 'x'.repeat(59);
|
|
const body = Array.from({ length: 8500 }, (_, i) => `${i.toString().padStart(4, '0')}${line.slice(4)}`).join('\n');
|
|
writeFileSync(path, body);
|
|
|
|
const tail = await tailLog(path, 100);
|
|
expect(tail).not.toBeNull();
|
|
expect(tail!.truncated).toBe(true);
|
|
expect(tail!.lines.length).toBeLessThanOrEqual(100);
|
|
// Last line should be the highest-numbered one; first line of the tail
|
|
// is somewhere in the middle since we can only read the last 256 KB.
|
|
expect(tail!.lines[tail!.lines.length - 1].startsWith('8499')).toBe(true);
|
|
});
|
|
|
|
it('drops the trailing empty line when file ends with a newline', async () => {
|
|
const path = resolve(LOG_DIR, 'trailing.log');
|
|
writeFileSync(path, 'a\nb\nc\n');
|
|
const tail = await tailLog(path, 10);
|
|
expect(tail?.lines).toEqual(['a', 'b', 'c']);
|
|
});
|
|
});
|