keamanan: resume_token ber-HMAC (sig sha256, verifikasi timing-safe sebelum pakai), allowlist kunci state_ref di kunciDariRef, containment path store runtime; temuan minor verifier wave-2

Author: Finerium

apps/web/lib/gudang.ts

@@ -11,7 +11,7 @@
 // empat pembaca di bawah ini dihapus dan diganti pemanggilan core lagi.
 
 import { access, appendFile, mkdir, readFile, readdir } from "node:fs/promises";
-import { dirname, join } from "node:path";
+import { dirname, join, resolve, sep } from "node:path";
 
 import { periksaBerkas, resolverGrounding } from "@varuna/core/grounding";
 import type { RuntimeStore } from "@varuna/core/store";
@@ -255,7 +255,16 @@ const dirRuntime = (): string =>
  *  append-only JSONL. packages/core/src/store.ts sengaja menyerahkan
  *  implementasinya ke jalur produk ini ("blobRuntimeStore: diisi di apps/web"). */
 export function gudangRuntime(): RuntimeStore {
-  const path = (kunci: string) => join(/* turbopackIgnore: true */ dirRuntime(), kunci);
+  // Containment: kunci apa pun (termasuk dari resume_token) tidak boleh
+  // menembus keluar direktori runtime.
+  const path = (kunci: string) => {
+    const dasar = resolve(dirRuntime());
+    const p = resolve(/* turbopackIgnore: true */ dasar, kunci);
+    if (p !== dasar && !p.startsWith(dasar + sep)) {
+      throw new Error(`kunci runtime di luar direktori: ${kunci}`);
+    }
+    return p;
+  };
   return {
     async append(kunci, rekaman) {
       const p = path(kunci);

packages/agents/src/executor.ts

@@ -12,6 +12,8 @@
 // Yang TIDAK dilakukan agen mana pun di berkas ini: menghitung status. PASHA
 // dipanggil executor (server) dari artefak yang dikutip replay, sesuai Bagian 4.
 
+import { createHmac, timingSafeEqual } from "node:crypto";
+
 import {
   ModelBehaviorError,
   RunState,
@@ -81,9 +83,33 @@ export const ResumeTokenSchema = z.object({
   ttl_s: z.literal(TTL_DETIK),
   run_id: z.string().regex(/^[a-z0-9]{6,32}$/),
   expires_at: z.iso.datetime({ offset: true }),
+  sig: z.string().regex(/^[0-9a-f]{64}$/),
 });
 export type ResumeToken = z.infer<typeof ResumeTokenSchema>;
 
+/** Token adalah bearer yang bolak-balik lewat klien; tanpa tanda tangan, field
+ *  mana pun (terutama state_ref) bisa diganti. HMAC atas JSON kanonis tujuh
+ *  field non-sig; rahasia dari env, fallback nilai dev yang sama konvensinya
+ *  dengan garam MMSI. */
+const rahasiaToken = (): string =>
+  process.env.RESUME_TOKEN_SECRET ?? process.env.MMSI_HASH_SALT ?? "varuna-dev-salt-2026";
+
+const tandaTanganToken = (t: Omit<ResumeToken, "sig">): string =>
+  createHmac("sha256", rahasiaToken())
+    .update(
+      JSON.stringify(
+        Object.fromEntries(Object.entries(t).sort(([a], [b]) => (a < b ? -1 : 1))),
+      ),
+    )
+    .digest("hex");
+
+const sigCocok = (t: ResumeToken): boolean => {
+  const { sig, ...tanpa } = t;
+  const a = Buffer.from(tandaTanganToken(tanpa), "hex");
+  const b = Buffer.from(sig, "hex");
+  return a.length === b.length && timingSafeEqual(a, b);
+};
+
 // ---------------------------------------------------------------------------
 // Peristiwa SSE (Bagian 3, event `agent_step`)
 // ---------------------------------------------------------------------------
@@ -456,17 +482,18 @@ async function jeda(
   });
 
   const nama = namaTertunda(tertunda[0] as RunToolApprovalItem);
+  const tanpaSig: Omit<ResumeToken, "sig"> = {
+    inv_id: ktx.inv.inv_id,
+    step_idx: berikut,
+    state_ref: refState(kunci),
+    seed: SEED,
+    ttl_s: TTL_DETIK,
+    run_id: ktx.run_id,
+    expires_at: new Date(Date.parse(m.sekarang()) + TTL_DETIK * 1000).toISOString(),
+  };
   return {
     selesai: false,
-    resume_token: {
-      inv_id: ktx.inv.inv_id,
-      step_idx: berikut,
-      state_ref: refState(kunci),
-      seed: SEED,
-      ttl_s: TTL_DETIK,
-      run_id: ktx.run_id,
-      expires_at: new Date(Date.parse(m.sekarang()) + TTL_DETIK * 1000).toISOString(),
-    },
+    resume_token: { ...tanpaSig, sig: tandaTanganToken(tanpaSig) },
     agen_berikut: nama === undefined ? null : idDariNamaAlat(nama),
     trace_ref: ktx.trace_ref,
     run_id: ktx.run_id,
@@ -515,6 +542,9 @@ export async function lanjutkanReplay(
   if (!token.success) {
     throw new GalatReplay("token", "resume_token tidak sah atau bukan milik protokol replay ini.");
   }
+  if (!sigCocok(token.data)) {
+    throw new GalatReplay("token", "tanda tangan resume_token tidak cocok; token diubah atau berasal dari server lain.");
+  }
   if (Date.parse(token.data.expires_at) <= Date.parse(m.sekarang())) {
     throw new GalatReplay(
       "kedaluwarsa",

packages/agents/src/mesin.ts

@@ -69,8 +69,15 @@ export const kunciJejak = (inv_id: string, run_id: string): string =>
  *  Vercel Blob atau filesystem dev. */
 export const refState = (kunci: string): string => `blob://${kunci}`;
 
-export const kunciDariRef = (ref: string): string | null =>
-  ref.startsWith("blob://") ? ref.slice("blob://".length) : null;
+/** Kunci datang dari resume_token (input tak tepercaya di route publik):
+ *  hanya segmen [a-z0-9._-] dipisah "/", tanpa "..", tanpa awalan "/". */
+const POLA_KUNCI = /^[a-z0-9][a-z0-9._-]*(\/[a-z0-9][a-z0-9._-]*)*$/i;
+export const kunciDariRef = (ref: string): string | null => {
+  if (!ref.startsWith("blob://")) return null;
+  const kunci = ref.slice("blob://".length);
+  if (!POLA_KUNCI.test(kunci) || kunci.split("/").includes("..")) return null;
+  return kunci;
+};
 
 // ---------------------------------------------------------------------------
 // Katalog bukti

packages/agents/test/executor.test.ts

@@ -8,7 +8,7 @@ import {
   type HasilLangkah,
   type PeristiwaAgen,
 } from "../src/executor";
-import { SEED, TTL_DETIK, kunciJejak, kunciKeluaran, kunciState } from "../src/mesin";
+import { SEED, TTL_DETIK, kunciDariRef, kunciJejak, kunciKeluaran, kunciState } from "../src/mesin";
 import {
   ART,
   INVESTIGASI_UJI,
@@ -215,9 +215,11 @@ describe("resume_token — penjaga batas kepercayaan", () => {
   };
 
   it("menolak token kedaluwarsa (ttl 900 detik)", async () => {
+    // Jam dimajukan, token utuh: tanda tangan tetap sah, yang gugur murni TTL.
     const { r, token } = await tokenSah();
-    const lewat = { ...token, expires_at: "2026-08-09T05:00:00.000Z" };
-    await expect(lanjutkanReplay(r.mesin, lewat, () => {})).rejects.toMatchObject({
+    (r.mesin as { sekarang: () => string }).sekarang = () =>
+      new Date(Date.parse(token.expires_at) + 1000).toISOString();
+    await expect(lanjutkanReplay(r.mesin, token, () => {})).rejects.toMatchObject({
       sebab: "kedaluwarsa",
     });
   });
@@ -266,6 +268,26 @@ describe("determinisme seed 20260809", () => {
     expect([...posisi].sort((a, b) => a - b)).toEqual(posisi);
   });
 
+  it("menolak resume_token yang tanda tangannya dirusak", async () => {
+    const r = siapkan(naskahStandar());
+    const awal = await mulaiReplay(r.mesin, INV_ID, () => {});
+    const rusak = {
+      ...(awal.resume_token as Record<string, unknown>),
+      state_ref: "blob://runtime/lain/state.jsonl",
+    };
+    await expect(lanjutkanReplay(r.mesin, rusak, () => {})).rejects.toMatchObject({
+      sebab: "token",
+    });
+  });
+
+  it("menolak state_ref traversal path meski tanda tangan dibuat ulang", async () => {
+    // kunciDariRef adalah gerbangnya: ".." tidak pernah jadi kunci store.
+    expect(kunciDariRef("blob://../../etc/passwd")).toBeNull();
+    expect(kunciDariRef("blob:///etc/passwd")).toBeNull();
+    expect(kunciDariRef("blob://runtime/inv/..%2F")).toBeNull();
+    expect(kunciDariRef("blob://runtime/inv-x/state.jsonl")).toBe("runtime/inv-x/state.jsonl");
+  });
+
   it("menulis jejak dan state di bawah run_id yang sama", async () => {
     const r = siapkan(naskahStandar());
     const awal = await mulaiReplay(r.mesin, INV_ID, () => {});