mirror of
https://github.com/tiennm99/noitu.git
synced 2026-10-11 12:28:54 +00:00
tiennm99
48b3b3c8ac
proto/noitu/v1/game.proto is the single source of truth for every WebSocket message. buf generates Go types into server/gen and JavaScript types into web/src/lib/proto; both trees are committed so building needs no codegen toolchain. The Go suite emits binary fixtures into proto/testdata and the JavaScript suite decodes the same bytes, so the two generated clients are checked against one artifact rather than against each other's assumptions. CI lints the schema, rejects breaking changes against main, and fails when the committed generated trees drift from the schema. game.NumRejectReasons and game.NumEndReasons let the mapping tests prove every engine reason has a wire value without guessing where the enum ends.
95 lines
3.7 KiB
JavaScript
95 lines
3.7 KiB
JavaScript
// Cross-language wire check.
|
|
//
|
|
// These fixtures are binary messages produced by the Go server's own test
|
|
// suite (server/internal/wsapi/wire_test.go, regenerated with `-update`).
|
|
// Decoding them here proves the two generated clients agree on the actual
|
|
// bytes — a JS-only round trip would only prove this runtime is
|
|
// self-consistent, which is exactly the failure mode that ships a broken
|
|
// client.
|
|
|
|
import { readFileSync, readdirSync } from 'node:fs';
|
|
import { join } from 'node:path';
|
|
import { fileURLToPath } from 'node:url';
|
|
import { describe, expect, it } from 'vitest';
|
|
import { fromBinary } from '@bufbuild/protobuf';
|
|
import {
|
|
ClientMessageSchema,
|
|
GameEndReason,
|
|
RejectReason,
|
|
ServerMessageSchema
|
|
} from '../src/lib/proto/noitu/v1/game_pb.js';
|
|
|
|
const fixtureDir = fileURLToPath(new URL('../../proto/testdata', import.meta.url));
|
|
|
|
const fixtures = readdirSync(fixtureDir).filter((f) => f.endsWith('.bin'));
|
|
|
|
/** Decode a fixture by name, choosing the schema from its client_/server_ prefix. */
|
|
function decode(name) {
|
|
const bytes = readFileSync(join(fixtureDir, `${name}.bin`));
|
|
const schema = name.startsWith('client_') ? ClientMessageSchema : ServerMessageSchema;
|
|
return fromBinary(schema, bytes);
|
|
}
|
|
|
|
describe('generated wire types', () => {
|
|
it('finds the fixtures the Go suite emits', () => {
|
|
expect(fixtures.length).toBeGreaterThan(0);
|
|
});
|
|
|
|
// Every arm must decode to a *named* case. An arm whose payload is empty on
|
|
// the wire (create_room, resign) still has to be distinguishable, so an
|
|
// undefined case here means the oneof tag was lost, not that the message
|
|
// was empty.
|
|
it.each(fixtures)('decodes %s to a known payload case', (file) => {
|
|
const msg = decode(file.replace(/\.bin$/, ''));
|
|
expect(msg.payload.case).toBeTypeOf('string');
|
|
});
|
|
|
|
it('preserves Vietnamese diacritics through UTF-8', () => {
|
|
const msg = decode('server_welcome');
|
|
expect(msg.payload.case).toBe('welcome');
|
|
expect(msg.payload.value.acceptedNickname).toBe('Người chơi ẩn danh');
|
|
expect(msg.payload.value.protocolVersion).toBe(1);
|
|
});
|
|
|
|
// int64 is a bigint in this runtime. Reading it as a Number would silently
|
|
// lose precision on timestamps far smaller than the ones a real deadline
|
|
// carries, so the type itself is the assertion.
|
|
it('reads int64 timestamps as bigint', () => {
|
|
const msg = decode('server_pong');
|
|
expect(msg.payload.case).toBe('pong');
|
|
expect(msg.payload.value.clientTimeMs).toBe(1756998000123n);
|
|
expect(msg.payload.value.serverTimeMs).toBe(1756998000456n);
|
|
});
|
|
|
|
it('agrees with Go on enum numbering', () => {
|
|
const rejected = decode('server_move_rejected');
|
|
expect(rejected.payload.case).toBe('moveRejected');
|
|
expect(rejected.payload.value.reason).toBe(RejectReason.WRONG_LINK);
|
|
expect(rejected.payload.value.word).toBe('cà phê');
|
|
|
|
const over = decode('server_game_over');
|
|
expect(over.payload.case).toBe('gameOver');
|
|
expect(over.payload.value.reason).toBe(GameEndReason.NO_LEGAL_MOVE);
|
|
expect(over.payload.value.iWon).toBe(false);
|
|
});
|
|
|
|
// The canonical/typed pair is what lets the UI show that the server
|
|
// corrected a spelling instead of appearing to rewrite the player's text.
|
|
it('carries both the canonical word and the raw input', () => {
|
|
const msg = decode('server_turn_update');
|
|
expect(msg.payload.case).toBe('turnUpdate');
|
|
const turn = msg.payload.value;
|
|
expect(turn.played.word).toBe('bình yên');
|
|
expect(turn.played.typed).toBe('binh yên');
|
|
expect(turn.played.byMe).toBe(false);
|
|
expect(turn.currentSyllable).toBe('yên');
|
|
expect(turn.deadlineUnixMs).toBe(1756998040000n);
|
|
expect(turn.turnSeq).toBe(2);
|
|
});
|
|
|
|
it('decodes an empty client arm without losing its tag', () => {
|
|
const msg = decode('client_create_room');
|
|
expect(msg.payload.case).toBe('createRoom');
|
|
});
|
|
});
|