mirror of
https://github.com/garrytan/gstack.git
synced 2026-05-16 09:12:13 +08:00
* feat: buildFetchHandler factory unblocks gbrowser submodule consumption
Add buildFetchHandler(cfg: ServerConfig): ServerHandle in browse/src/server.ts.
Refactor start() to delegate handler construction to the factory and read env
once via resolveConfigFromEnv(). Wire the beforeRoute hook (runs after the
tunnel surface filter, before per-route dispatch).
Auth is now cfg-driven end-to-end. Module-level AUTH_TOKEN const +
initRegistry(AUTH_TOKEN) boot call, validateAuth, and shutdown are deleted;
factory closure owns them. start() threads cfg.authToken into launchHeaded,
the state-file write, and the factory.
initRegistry is idempotent for same-token re-init; throws clearly for
different-token re-init. __resetRegistry() test helper added (mirrors
__resetConnectRateLimit). Existing tests that did rotateRoot() ->
initRegistry('fixed-token') swap to __resetRegistry() to avoid the new guard.
14 factory contract tests added covering ServerHandle shape, auth wiring,
validation throws, hook semantics across both surfaces, and registry
idempotency.
Source-pattern tests in dual-listener.test.ts and server-auth.test.ts
updated for the new identifiers (handle.fetchLocal/fetchTunnel, authToken,
shutdownFn).
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
* chore: bump version and changelog (v1.39.0.0)
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
---------
Co-authored-by: Claude Opus 4.7 <noreply@anthropic.com>
168 lines
6.2 KiB
TypeScript
168 lines
6.2 KiB
TypeScript
/**
|
|
* skill-token tests — verify scoped tokens minted per spawn behave correctly:
|
|
* - mint creates a session token bound to the right clientId
|
|
* - default scopes are read+write (no admin/control)
|
|
* - TTL = spawnTimeout + 30s slack
|
|
* - revoke kills the token
|
|
* - revoking an already-revoked token is idempotent (returns false)
|
|
* - the clientId encoding survives round-trip
|
|
* - generated spawn ids are unique
|
|
*/
|
|
|
|
import { describe, it, expect, beforeEach } from 'bun:test';
|
|
import {
|
|
initRegistry, __resetRegistry, validateToken, checkScope,
|
|
} from '../src/token-registry';
|
|
import {
|
|
generateSpawnId,
|
|
skillClientId,
|
|
mintSkillToken,
|
|
revokeSkillToken,
|
|
} from '../src/skill-token';
|
|
|
|
describe('skill-token', () => {
|
|
beforeEach(() => {
|
|
// __resetRegistry zeroes rootToken so the new initRegistry mismatch guard
|
|
// doesn't fire on the immediate initRegistry call.
|
|
__resetRegistry();
|
|
initRegistry('root-token-for-tests');
|
|
});
|
|
|
|
describe('generateSpawnId', () => {
|
|
it('returns a hex string', () => {
|
|
const id = generateSpawnId();
|
|
expect(id).toMatch(/^[0-9a-f]+$/);
|
|
expect(id.length).toBe(16); // 8 bytes -> 16 hex chars
|
|
});
|
|
|
|
it('returns unique ids on each call', () => {
|
|
const ids = new Set<string>();
|
|
for (let i = 0; i < 50; i++) ids.add(generateSpawnId());
|
|
expect(ids.size).toBe(50);
|
|
});
|
|
});
|
|
|
|
describe('skillClientId', () => {
|
|
it('encodes skillName + spawnId deterministically', () => {
|
|
expect(skillClientId('hackernews-frontpage', 'abc123')).toBe('skill:hackernews-frontpage:abc123');
|
|
});
|
|
});
|
|
|
|
describe('mintSkillToken', () => {
|
|
it('mints a session token for the spawn', () => {
|
|
const info = mintSkillToken({
|
|
skillName: 'hn-frontpage',
|
|
spawnId: 'spawn1',
|
|
spawnTimeoutSeconds: 60,
|
|
});
|
|
expect(info.token).toStartWith('gsk_sess_');
|
|
expect(info.clientId).toBe('skill:hn-frontpage:spawn1');
|
|
expect(info.type).toBe('session');
|
|
});
|
|
|
|
it('defaults to read+write scopes (no admin)', () => {
|
|
const info = mintSkillToken({
|
|
skillName: 'hn-frontpage',
|
|
spawnId: 'spawn1',
|
|
spawnTimeoutSeconds: 60,
|
|
});
|
|
expect(info.scopes).toEqual(['read', 'write']);
|
|
expect(info.scopes).not.toContain('admin');
|
|
expect(info.scopes).not.toContain('control');
|
|
});
|
|
|
|
it('TTL is spawnTimeout + 30s slack', () => {
|
|
const before = Date.now();
|
|
const info = mintSkillToken({
|
|
skillName: 'x', spawnId: 'y', spawnTimeoutSeconds: 60,
|
|
});
|
|
const after = Date.now();
|
|
const expiresMs = new Date(info.expiresAt!).getTime();
|
|
// Token expires ~90s after mint (60s + 30s slack), allow some test fuzz.
|
|
expect(expiresMs).toBeGreaterThanOrEqual(before + 90_000 - 1_000);
|
|
expect(expiresMs).toBeLessThanOrEqual(after + 90_000 + 1_000);
|
|
});
|
|
|
|
it('minted token validates and grants browser-driving scope', () => {
|
|
const info = mintSkillToken({
|
|
skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60,
|
|
});
|
|
const validated = validateToken(info.token);
|
|
expect(validated).not.toBeNull();
|
|
expect(checkScope(validated!, 'goto')).toBe(true);
|
|
expect(checkScope(validated!, 'click')).toBe(true);
|
|
expect(checkScope(validated!, 'snapshot')).toBe(true);
|
|
expect(checkScope(validated!, 'text')).toBe(true);
|
|
});
|
|
|
|
it('minted token denies admin commands (eval, js, cookies, storage)', () => {
|
|
const info = mintSkillToken({
|
|
skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60,
|
|
});
|
|
const validated = validateToken(info.token);
|
|
expect(validated).not.toBeNull();
|
|
expect(checkScope(validated!, 'eval')).toBe(false);
|
|
expect(checkScope(validated!, 'js')).toBe(false);
|
|
expect(checkScope(validated!, 'cookies')).toBe(false);
|
|
expect(checkScope(validated!, 'storage')).toBe(false);
|
|
});
|
|
|
|
it('minted token denies control commands (state, stop, restart)', () => {
|
|
const info = mintSkillToken({
|
|
skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60,
|
|
});
|
|
const validated = validateToken(info.token);
|
|
expect(checkScope(validated!, 'stop')).toBe(false);
|
|
expect(checkScope(validated!, 'restart')).toBe(false);
|
|
expect(checkScope(validated!, 'state')).toBe(false);
|
|
});
|
|
|
|
it('rateLimit is unlimited (skill scripts run as fast as daemon allows)', () => {
|
|
const info = mintSkillToken({
|
|
skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60,
|
|
});
|
|
expect(info.rateLimit).toBe(0);
|
|
});
|
|
|
|
it('two spawns of the same skill mint distinct tokens', () => {
|
|
const a = mintSkillToken({ skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60 });
|
|
const b = mintSkillToken({ skillName: 'hn', spawnId: 's2', spawnTimeoutSeconds: 60 });
|
|
expect(a.token).not.toBe(b.token);
|
|
expect(a.clientId).not.toBe(b.clientId);
|
|
// Both remain valid until revoked.
|
|
expect(validateToken(a.token)).not.toBeNull();
|
|
expect(validateToken(b.token)).not.toBeNull();
|
|
});
|
|
});
|
|
|
|
describe('revokeSkillToken', () => {
|
|
it('revokes the token for a given spawn', () => {
|
|
const info = mintSkillToken({ skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60 });
|
|
expect(validateToken(info.token)).not.toBeNull();
|
|
|
|
const ok = revokeSkillToken('hn', 's1');
|
|
expect(ok).toBe(true);
|
|
expect(validateToken(info.token)).toBeNull();
|
|
});
|
|
|
|
it('idempotent — revoking again returns false (already gone)', () => {
|
|
mintSkillToken({ skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60 });
|
|
expect(revokeSkillToken('hn', 's1')).toBe(true);
|
|
expect(revokeSkillToken('hn', 's1')).toBe(false);
|
|
});
|
|
|
|
it('revoking unknown spawn is a no-op (returns false)', () => {
|
|
expect(revokeSkillToken('nonexistent', 'whatever')).toBe(false);
|
|
});
|
|
|
|
it('revoking one spawn does not affect a sibling spawn', () => {
|
|
const a = mintSkillToken({ skillName: 'hn', spawnId: 's1', spawnTimeoutSeconds: 60 });
|
|
const b = mintSkillToken({ skillName: 'hn', spawnId: 's2', spawnTimeoutSeconds: 60 });
|
|
|
|
expect(revokeSkillToken('hn', 's1')).toBe(true);
|
|
expect(validateToken(a.token)).toBeNull();
|
|
expect(validateToken(b.token)).not.toBeNull();
|
|
});
|
|
});
|
|
});
|