Quá trình gửi tin nhắn

 import { randomUUID } from "node:crypto";
 
 import { and, asc, eq, sql } from "drizzle-orm";
 
 import type { Db } from "./client";
-import { channels, members, users } from "./schema";
+import { channels, members, messages, users } from "./schema";
 
 // The repository layer — the ONE place data access lives (ADR-04's single
 // writer, constitution I). Two surfaces with a bright line between them:
 //
 //   createEnvironment — the ADMIN surface. It creates tenants, so it is the
 //   only operation here that is not tenant-scoped. It also inserts a stub
 //   application row to satisfy environments' NOT NULL foreign key (recorded
 //   decision: the real application lifecycle belongs to Part 3).
 //
 //   Repository — everything else. The constructor REQUIRES an
 //   environment_id; every query is scoped by it HERE, in one home — never
 //   at call sites. Cross-tenant reads return null/empty: no data, and no
 //   reveal that the foreign id even exists (FR-TEN-05).
 //
 // Drizzle is the query engine inside this layer (ADR-16): queries keep
 // their SQL shape and gain end-to-end types. Where the builder falls short,
 // a raw SQL island is permitted — inside the layer, never outside it.
 //
 // All primary keys are generated app-side (crypto.randomUUID) — the SAD's
 // SQL declares no id defaults, and the migration adds none.
 
 export interface Environment {
   id: string;
   kind: "development" | "production";
 }
 
 export async function createEnvironment(
   db: Db,
   { name, kind = "development" }: { name: string; kind?: Environment["kind"] },
 ): Promise<Environment> {
   const applicationId = randomUUID();
   const environmentId = randomUUID();
   // The admin surface writes through the same Db handle but carries no
   // tenant scope — it is the operation that MINTS the scope.
   await db.execute(
     sql`INSERT INTO applications (id, name) VALUES (${applicationId}, ${name})`,
   );
   await db.execute(
     sql`INSERT INTO environments (id, application_id, kind, signing_secret)
         VALUES (${environmentId}, ${applicationId}, ${kind}, ${randomUUID()})`,
   );
   return { id: environmentId, kind };
 }
 
 export interface UserRow {
   id: string;
   external_id: string;
   display_name: string | null;
 }
 
 export interface ChannelRow {
   id: string;
   external_id: string;
   type: "public" | "private";
   name: string | null;
 }
 
+export interface MessageRow {
+  id: string;
+  channel_id: string;
+  seq: number;
+  text: string | null;
+  created_at: string;
+}
+
+/** Thrown when a channel id resolves to nothing IN THIS TENANT — which,
+ * from the caller's side, is indistinguishable from "does not exist"
+ * (FR-TEN-05: no data, and no reveal that the foreign id exists). The
+ * layer stays framework-free; the service turns this into the wire's
+ * 404 (constitution I's isolation, EIR-API-04's envelope). */
+export class ChannelNotFoundError extends Error {
+  constructor(public readonly channelId: string) {
+    super(`channel not found: ${channelId}`);
+    this.name = "ChannelNotFoundError";
+  }
+}
+
 export class Repository {
   // Constructor parameter properties — the shorthand chapter 1.4 released
   // for this service when ADR-15 spent erasableSyntaxOnly on decorator
   // metadata. The guarantee still holds in the gateway and every package.
   constructor(
     private readonly db: Db,
     private readonly environmentId: string,
   ) {}
 
   async createUser(externalId: string, displayName?: string): Promise<UserRow> {
     const id = randomUUID();
     await this.db.insert(users).values({
       id,
       environmentId: this.environmentId,
       externalId,
       displayName: displayName ?? null,
     });
     return { id, external_id: externalId, display_name: displayName ?? null };
   }
 
   async getUserByExternalId(externalId: string): Promise<UserRow | null> {
     const rows = await this.db
       .select({
         id: users.id,
         external_id: users.externalId,
         display_name: users.displayName,
       })
       .from(users)
       .where(
         and(
           eq(users.environmentId, this.environmentId),
           eq(users.externalId, externalId),
         ),
       );
     return rows[0] ?? null;
   }
 
   async createChannel(
     externalId: string,
     type: ChannelRow["type"],
     name?: string,
   ): Promise<ChannelRow> {
     const id = randomUUID();
     await this.db.insert(channels).values({
       id,
       environmentId: this.environmentId,
       externalId,
       type,
       name: name ?? null,
     });
     return { id, external_id: externalId, type, name: name ?? null };
   }
 
   async getChannelByExternalId(externalId: string): Promise<ChannelRow | null> {
     const rows = await this.db
       .select({
         id: channels.id,
         external_id: channels.externalId,
         type: sql<ChannelRow["type"]>`${channels.type}`,
         name: channels.name,
       })
       .from(channels)
       .where(
         and(
           eq(channels.environmentId, this.environmentId),
           eq(channels.externalId, externalId),
         ),
       );
     return rows[0] ?? null;
   }
 
   async listChannels(): Promise<ChannelRow[]> {
     return this.db
       .select({
         id: channels.id,
         external_id: channels.externalId,
         type: sql<ChannelRow["type"]>`${channels.type}`,
         name: channels.name,
       })
       .from(channels)
       .where(eq(channels.environmentId, this.environmentId))
       .orderBy(asc(channels.externalId));
   }
 
   /** Membership joins live in channel-land, so the tenant scope rides the
    * channel: the double-scoped SELECT below is what makes a foreign channel
    * id useless. INSERT ... SELECT is where the builder falls short — this
    * is the layer's one raw SQL island, permitted by ADR-16 and kept inside
    * the wall like everything else. */
   async addMember(channelId: string, userId: string): Promise<boolean> {
     const result = await this.db.execute(
       sql`INSERT INTO members (channel_id, user_id)
           SELECT c.id, u.id FROM channels c, users u
           WHERE c.id = ${channelId} AND c.environment_id = ${this.environmentId}
             AND u.id = ${userId} AND u.environment_id = ${this.environmentId}`,
     );
     return (result.rowCount ?? 0) > 0;
   }
 
   async listMembers(channelId: string): Promise<string[]> {
     const rows = await this.db
       .select({ user_id: members.userId })
       .from(members)
       .innerJoin(channels, eq(channels.id, members.channelId))
       .where(
         and(
           eq(members.channelId, channelId),
           eq(channels.environmentId, this.environmentId),
         ),
       )
       .orderBy(asc(members.joinedAt));
     return rows.map((r) => r.user_id);
   }
 
   async channelsForUser(userId: string): Promise<string[]> {
     const rows = await this.db
       .select({ channel_id: members.channelId })
       .from(members)
       .innerJoin(users, eq(users.id, members.userId))
       .where(
         and(
           eq(members.userId, userId),
           eq(users.environmentId, this.environmentId),
         ),
       );
     return rows.map((r) => r.channel_id);
   }
+
+  /** The write path (chapter 2.2): sequence assignment under the channel
+   * row lock (ADR-03). The transaction IS the ordering guarantee: the
+   * lock serialises assignment per channel, and the ack that matters
+   * happens only after commit (FR-MSG-05).
+   */
+  async sendMessage(
+    channelId: string,
+    {
+      userId,
+      text,
+      metadata,
+    }: { userId?: string; text: string; metadata?: unknown },
+  ): Promise<MessageRow> {
+    return this.db.transaction(async (tx) => {
+      const [channel] = await tx
+        .select({ id: channels.id, lastSequence: channels.lastSequence })
+        .from(channels)
+        .where(
+          and(
+            eq(channels.id, channelId),
+            eq(channels.environmentId, this.environmentId),
+          ),
+        )
+        .for("update");
+      if (!channel) throw new ChannelNotFoundError(channelId);
+      const seq = channel.lastSequence + 1;
+      const id = randomUUID();
+      await tx
+        .update(channels)
+        .set({ lastSequence: seq })
+        .where(eq(channels.id, channel.id));
+      await tx.insert(messages).values({
+        id,
+        channelId: channel.id,
+        sequence: seq,
+        userId: userId ?? null,
+        text,
+        metadata: metadata ?? {},
+      });
+      return {
+        id,
+        channel_id: channel.id,
+        seq,
+        text,
+        created_at: new Date().toISOString(),
+      };
+    });
+  }
 }

// THE NAIVE WRITE — this file exists for one section of chapter 2.2 and is
// deleted before the tag. Read the sequence, add one, insert. It passes
// every single-user test you will ever write.
//
// The `pause` parameter is the test's handle on the gap: production code
// would never take it, but a race you cannot reproduce is a race you
// cannot demonstrate (the same injection idiom 2.7 uses on the resume
// window).
async sendMessageNaive(channelId: string, text: string, pause?: Promise<void>) {
  const [channel] = await this.db
    .select({ id: channels.id, lastSequence: channels.lastSequence })
    .from(channels)
    .where(and(eq(channels.id, channelId), eq(channels.environmentId, this.environmentId)));
  if (!channel) throw new ChannelNotFoundError(channelId);
  const seq = channel.lastSequence + 1;          // ← read…
  if (pause) await pause;                        //   …the gap, held open…
  const id = randomUUID();
  await this.db.insert(messages).values({ id, channelId, sequence: seq, text });
  await this.db                                  // …then write.
    .update(channels)
    .set({ lastSequence: seq })
    .where(eq(channels.id, channel.id));
  return { id, channel_id: channelId, seq, text };
}

 import { afterAll, beforeAll, describe, expect, it } from "vitest";
 
 import { createDb, createPool, DEFAULT_DATABASE_URL, type Db } from "./client";
 import { migrate } from "./migrate";
 import { createEnvironment, Repository, type Environment } from "./repository";
 
 // The isolation suite: attack the repository with FOREIGN tenant ids and
 // prove the leak inexpressible (FR-TEN-05, NFR-SEC-09, constitution I).
 // Requires the compose Postgres — this file is *.itest.ts precisely so the
 // Docker-free unit lane never collects it.
 
 // Guardrail: integration tests run against the LOCAL compose stack only.
 const url = new URL(process.env.DATABASE_URL ?? DEFAULT_DATABASE_URL);
 if (!["localhost", "127.0.0.1"].includes(url.hostname)) {
   throw new Error(
     `integration tests refuse non-local databases (got host "${url.hostname}") — never point this suite at a shared database`,
   );
 }
 
 const pool = createPool();
 const db: Db = createDb(pool);
 let envA: Environment;
 let envB: Environment;
 let repoA: Repository;
 let repoB: Repository;
 
 beforeAll(async () => {
   await migrate(pool);
-  // Deterministic ground: this suite owns these tables in the dev database.
-  await pool.query(
-    "TRUNCATE members, messages, channels, users, environments, applications CASCADE",
-  );
+  // Deterministic ground WITHOUT a truncate: this suite mints its own
+  // environments, and 2.1 proved no other environment's rows are visible
+  // through them. Isolation buys parallel-safe test files for free — see
+  // the note below.
   envA = await createEnvironment(db, { name: "tenant-a" });
   envB = await createEnvironment(db, { name: "tenant-b" });
   repoA = new Repository(db, envA.id);
   repoB = new Repository(db, envB.id);
 });
 
 afterAll(async () => {
   await pool.end();
 });
 
 describe("tenant isolation is structural (FR-TEN-05)", () => {
   it("a foreign external_id resolves to nothing — not even an existence hint", async () => {
     await repoA.createUser("tuan", "Tuan");
     expect(await repoA.getUserByExternalId("tuan")).not.toBeNull();
     expect(await repoB.getUserByExternalId("tuan")).toBeNull();
   });
 
   it("channel reads and lists are scoped by construction", async () => {
     await repoA.createChannel("support", "public", "Support");
     expect(await repoB.getChannelByExternalId("support")).toBeNull();
     expect(await repoB.listChannels()).toEqual([]);
     expect((await repoA.listChannels()).map((c) => c.external_id)).toContain(
       "support",
     );
   });
 
   it("membership writes with foreign ids affect zero rows", async () => {
     const user = await repoA.getUserByExternalId("tuan");
     const channel = await repoA.getChannelByExternalId("support");
     expect(await repoA.addMember(channel!.id, user!.id)).toBe(true);
     // B holds A's REAL ids — and still cannot write or read through them.
     expect(await repoB.addMember(channel!.id, user!.id)).toBe(false);
     expect(await repoB.listMembers(channel!.id)).toEqual([]);
     expect(await repoB.channelsForUser(user!.id)).toEqual([]);
     expect(await repoA.listMembers(channel!.id)).toEqual([user!.id]);
   });
 
   it("uniqueness is per-tenant (DR-02): both tenants may own the same external_id", async () => {
     await expect(
       repoB.createUser("tuan", "A different Tuan"),
     ).resolves.toBeTruthy();
     await expect(repoA.createUser("tuan", "Duplicate in A")).rejects.toThrow();
   });
 });
+
+describe("sequence assignment is serialised per channel (ADR-03)", () => {
+  it("two concurrent sends never interleave", async () => {
+    const channel = await repoA.createChannel("ordering", "public");
+    const [a, b] = await Promise.all([
+      repoA.sendMessage(channel.id, { text: "first writer" }),
+      repoA.sendMessage(channel.id, { text: "second writer" }),
+    ]);
+    // Two sends, two DISTINCT consecutive sequence numbers — always.
+    expect(new Set([a.seq, b.seq]).size).toBe(2);
+    expect(Math.abs(a.seq - b.seq)).toBe(1);
+  });
+});

[ { ok: 1 },
  { err: 'Error: Failed query: insert into "messages" …' } ]

  /** The write path (chapter 2.2): sequence assignment under the channel
   * row lock (ADR-03). The transaction IS the ordering guarantee: the
   * lock serialises assignment per channel, and the ack that matters
   * happens only after commit (FR-MSG-05).
   */
  async sendMessage(
    channelId: string,
    {
      userId,
      text,
      metadata,
    }: { userId?: string; text: string; metadata?: unknown },
  ): Promise<MessageRow> {
    return this.db.transaction(async (tx) => {
      const [channel] = await tx
        .select({ id: channels.id, lastSequence: channels.lastSequence })
        .from(channels)
        .where(
          and(
            eq(channels.id, channelId),
            eq(channels.environmentId, this.environmentId),
          ),
        )
        .for("update");
      if (!channel) throw new ChannelNotFoundError(channelId);
      const seq = channel.lastSequence + 1;
      const id = randomUUID();
      await tx
        .update(channels)
        .set({ lastSequence: seq })
        .where(eq(channels.id, channel.id));
      await tx.insert(messages).values({
        id,
        channelId: channel.id,
        sequence: seq,
        userId: userId ?? null,
        text,
        metadata: metadata ?? {},
      });
      return {
        id,
        channel_id: channel.id,
        seq,
        text,
        created_at: new Date().toISOString(),
      };
    });
  }

import { Body, Controller, Param, Post, UseGuards } from "@nestjs/common";
 
import { EnvironmentContextGuard } from "./environment-context.guard";
import { MessagesService } from "./messages.service";
import { sendMessageBodySchema } from "./messages.schema";
// `import type` is required, not stylistic: with isolatedModules and
// emitDecoratorMetadata on (ADR-15's trade-off, chapter 1.4), a type used
// in a decorated signature must be imported as a type or TS1272 refuses
// to compile it.
import type { SendMessageBody } from "./messages.schema";
import { ZodValidationPipe } from "./zod-validation.pipe";
 
// The api's first product endpoint (chapter 2.2). Validation is zod at the
// boundary — the same schema family as @relay/protocol, so the REST body
// and the WebSocket frame payload cannot drift (1.3's payoff, again).
@Controller("v1/channels/:channelId/messages")
@UseGuards(EnvironmentContextGuard)
export class MessagesController {
  constructor(private readonly messages: MessagesService) {}
 
  @Post()
  async send(
    @Param("channelId") channelId: string,
    @Body(new ZodValidationPipe(sendMessageBodySchema)) body: SendMessageBody,
  ) {
    return this.messages.send(channelId, body);
  }
}

import { z } from "zod";
 
// The send body (chapter 2.2). FR-MSG-01 fixes the limits: text up to
// 8,000 characters, metadata up to 4 KB of JSON — the length check lands
// with FR-EMJ-02's code-point counting in the emoji chapter; today the
// character bound is the honest approximation, recorded as such.
export const sendMessageBodySchema = z.strictObject({
  text: z.string().min(1).max(8000),
  metadata: z.record(z.string(), z.unknown()).optional(),
});
 
export type SendMessageBody = z.infer<typeof sendMessageBodySchema>;

 {
   "name": "@relay/api",
   "private": true,
   "version": "0.0.0",
   "type": "commonjs",
   "scripts": {
     "build": "nest build",
     "dev": "nest start --watch",
     "start": "node dist/main.js",
     "typecheck": "tsc --noEmit",
     "test": "vitest run",
     "migrate": "nest build && node dist/db/migrate.js",
     "test:integration": "vitest run --config vitest.integration.config.mts"
   },
   "dependencies": {
     "@nestjs/common": "^11.1.28",
     "@nestjs/core": "^11.1.28",
     "@nestjs/platform-express": "^11.1.28",
     "@relay/protocol": "workspace:*",
     "@relay/service-kit": "workspace:*",
     "drizzle-orm": "^0.45.2",
     "pg": "^8.22.0",
     "reflect-metadata": "^0.2.2",
-    "rxjs": "^7.8.2"
+    "rxjs": "^7.8.2",
+    "zod": "^4.4.3"
   },
   "devDependencies": {
     "@nestjs/cli": "^11.0.24",
     "@nestjs/testing": "^11.1.28",
     "@swc/core": "^1.15.47",
     "@types/pg": "^8.20.3",
     "drizzle-kit": "^0.31.10",
     "unplugin-swc": "^1.5.9"
   }
 }

import { BadRequestException, type PipeTransform } from "@nestjs/common";
import type { ZodType } from "zod";
 
// Boundary validation (chapter 2.2). safeParse, never parse: a throw
// from deep inside a library is not an error shape anyone can rely on.
// The BadRequestException carries the message; 1.4's ProtocolErrorFilter
// turns it into the EIR-API-04 envelope on the way out — one error shape,
// one home, unchanged since the skeleton.
export class ZodValidationPipe<T> implements PipeTransform<unknown, T> {
  constructor(private readonly schema: ZodType<T>) {}
 
  transform(value: unknown): T {
    const result = this.schema.safeParse(value);
    if (!result.success) {
      throw new BadRequestException(
        result.error.issues[0]?.message ?? "invalid body",
      );
    }
    return result.data;
  }
}

import {
  type CanActivate,
  type ExecutionContext,
  Injectable,
  UnauthorizedException,
} from "@nestjs/common";
 
// DECISION (chapter 2.2): real credentials arrive with Part 3 (API keys
// in 3.2, tenancy in 3.1). Until then, public routes name their tenant
// via the X-Relay-Environment header — a dev-mode seam, load-bearing for
// exactly as long as it takes Part 3 to replace it. The guard resolves
// the header; the request-scoped Repository below it is what makes the
// scoping real (constitution I).
@Injectable()
export class EnvironmentContextGuard implements CanActivate {
  canActivate(context: ExecutionContext): boolean {
    const req = context.switchToHttp().getRequest<{
      headers: Record<string, string | undefined>;
      environmentId?: string;
    }>();
    const environmentId = req.headers["x-relay-environment"];
    if (!environmentId) {
      throw new UnauthorizedException("missing X-Relay-Environment");
    }
    req.environmentId = environmentId;
    return true;
  }
}

import { Injectable, NotFoundException } from "@nestjs/common";
 
import {
  ChannelNotFoundError,
  Repository,
  type MessageRow,
} from "../db/repository";
import type { SendMessageBody } from "./messages.schema";
 
// The thin layer between HTTP and the repository (chapter 2.2). It owns
// exactly one thing today: turning the layer's domain error into the
// wire's 404 — same non-answer a foreign tenant's id has received since
// 2.1, now wearing an HTTP status. The filter from 1.4 shapes the body.
@Injectable()
export class MessagesService {
  constructor(private readonly repo: Repository) {}
 
  async send(channelId: string, body: SendMessageBody): Promise<MessageRow> {
    try {
      return await this.repo.sendMessage(channelId, body);
    } catch (error) {
      if (error instanceof ChannelNotFoundError) {
        // A CONSTANT message: echoing the id back would make the foreign-id
        // answer differ from the missing-id answer, and "different" is
        // itself a disclosure (FR-TEN-05).
        throw new NotFoundException("channel not found");
      }
      throw error;
    }
  }
}

import { Module, Scope } from "@nestjs/common";
import { REQUEST } from "@nestjs/core";
 
import { createDb, createPool, type Db } from "../db/client";
import type { RequestWithTenant } from "./request-with-tenant";
import { Repository } from "../db/repository";
import { EnvironmentContextGuard } from "./environment-context.guard";
import { MessagesController } from "./messages.controller";
import { MessagesService } from "./messages.service";
 
// The repository stays the plain 2.1 class — the framework's job is only
// to construct it per request with the authenticated tenant (ADR-15's
// scope note: guards authenticate, the data layer isolates).
@Module({
  controllers: [MessagesController],
  providers: [
    {
      provide: "DB",
      useFactory: (): Db => createDb(createPool()),
      scope: Scope.DEFAULT,
    },
    {
      provide: Repository,
      scope: Scope.REQUEST,
      inject: ["DB", REQUEST],
      useFactory: (db: Db, req: RequestWithTenant) =>
        // The FACTORY reads the header, not the guard's leftovers: Nest
        // resolves request-scoped providers BEFORE the enhancer chain
        // runs, so anything a guard stashes on the request is invisible
        // here. The guard still rejects tenant-less requests (401); the
        // factory is what scopes the layer.
        new Repository(db, req.headers["x-relay-environment"] ?? ""),
    },
    MessagesService,
    EnvironmentContextGuard,
  ],
})
export class MessagesModule {}

import "reflect-metadata";
 
import { Test } from "@nestjs/testing";
import type { INestApplication } from "@nestjs/common";
import { afterAll, beforeAll, describe, expect, it } from "vitest";
 
import { AppModule } from "../app.module";
import { createDb, createPool } from "../db/client";
import { createEnvironment, Repository } from "../db/repository";
 
// The endpoint path (chapter 2.2): guard → pipe → service → repository →
// filter, over real HTTP against the compose Postgres. Its own environment,
// minted here — no truncate, because tenant isolation means this suite and
// the repository suite cannot see each other's rows (2.1's property, paying
// for itself in the test lane).
describe("POST /v1/channels/:channelId/messages", () => {
  let app: INestApplication;
  let url: string;
  let env: { id: string };
  let channelId: string;
  let foreignChannelId: string;
 
  beforeAll(async () => {
    const db = createDb(createPool());
    env = await createEnvironment(db, { name: "messages-itest" });
    channelId = (
      await new Repository(db, env.id).createChannel("general", "public")
    ).id;
    const other = await createEnvironment(db, { name: "messages-itest-other" });
    foreignChannelId = (
      await new Repository(db, other.id).createChannel("theirs", "public")
    ).id;
    app = (
      await Test.createTestingModule({ imports: [AppModule] }).compile()
    ).createNestApplication({ logger: false });
    await app.listen(0);
    url = await app.getUrl();
  });
 
  afterAll(async () => {
    await app.close();
  });
 
  const send = (body: unknown, channel = channelId, environment = env.id) =>
    fetch(`${url}/v1/channels/${channel}/messages`, {
      method: "POST",
      headers: {
        "content-type": "application/json",
        "x-relay-environment": environment,
      },
      body: JSON.stringify(body),
    });
 
  it("returns 201 with an ascending sequence", async () => {
    const first = await send({ text: "hello" });
    expect(first.status).toBe(201);
    const a = (await first.json()) as { seq: number };
    const b = (await (await send({ text: "again" })).json()) as { seq: number };
    expect(b.seq).toBe(a.seq + 1);
  });
 
  it("rejects a malformed body through the protocol envelope", async () => {
    const res = await send({ text: "" });
    expect(res.status).toBe(400);
    const body = (await res.json()) as Record<string, unknown>;
    expect(body).toMatchObject({ code: "invalid_request" });
    expect(typeof body.docs_url).toBe("string");
  });
 
  it("answers a FOREIGN channel id with the same 404 as a missing one", async () => {
    const foreign = await send({ text: "not for you" }, foreignChannelId);
    const missing = await send({ text: "nobody home" }, crypto.randomUUID());
    expect(foreign.status).toBe(404);
    expect(missing.status).toBe(404);
    // Indistinguishable — no data, and no reveal that the id exists.
    expect(await foreign.json()).toEqual(await missing.json());
  });
});

 import type { ServerResponse } from "node:http";
 
 import {
   Catch,
   HttpException,
   type ArgumentsHost,
   type ExceptionFilter,
 } from "@nestjs/common";
 
 // EIR-API-04: one error shape, one home. Whatever throws — the router's own
 // 404, a future guard, an unhandled bug — the wire sees the same envelope
 // the @relay/protocol error payload defines, so the REST surface and the
 // WebSocket surface cannot drift apart. The docs_url host is a placeholder
 // until the docs site exists (constitution V's reachable-page promise).
 @Catch()
 export class ProtocolErrorFilter implements ExceptionFilter {
   catch(exception: unknown, host: ArgumentsHost): void {
     const res = host.switchToHttp().getResponse<ServerResponse>();
     const status =
       exception instanceof HttpException ? exception.getStatus() : 500;
-    const code = status === 404 ? "not_found" : "internal_error";
+    // REST error codes by status (chapter 2.2 widened this: a 400 that
+    // calls itself "internal_error" is a lie the client cannot act on).
+    // The registry stays here until an API chapter owns a REST one.
+    const code =
+      status === 400
+        ? "invalid_request"
+        : status === 401
+          ? "unauthorized"
+          : status === 404
+            ? "not_found"
+            : "internal_error";
     const message =
       exception instanceof HttpException
         ? exception.message
         : "unexpected internal error";
     res.statusCode = status;
     res.setHeader("content-type", "application/json");
     res.end(
       JSON.stringify({
         code,
         message,
         docs_url: `https://relay.example/docs/errors/${code}`,
       }),
     );
   }
 }

docker compose up -d --wait postgres
pnpm --filter @relay/api migrate
pnpm dev
curl -s -X POST localhost:4000/v1/channels/$CHANNEL/messages \
  -H "X-Relay-Environment: $ENV" -H "content-type: application/json" \
  -d '{"text":"first message ever"}'