2 Commits

Author SHA1 Message Date
Alejandro Gutiérrez
c8682dd700 fix(cli): deduplicate --dangerously-load-development-channels flag
Some checks failed
CI / Lint (push) Has been cancelled
CI / Typecheck (push) Has been cancelled
CI / Broker tests (Postgres) (push) Has been cancelled
CI / Docker build (linux/amd64) (push) Has been cancelled
Release / Publish multi-arch images (push) Has been cancelled
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
2026-04-06 10:56:30 +01:00
Alejandro Gutiérrez
004602a83c fix(cli): v0.1.8 — remove Zod dependency (bun bundler crash)
Some checks failed
CI / Lint (push) Has been cancelled
CI / Typecheck (push) Has been cancelled
CI / Broker tests (Postgres) (push) Has been cancelled
CI / Docker build (linux/amd64) (push) Has been cancelled
Release / Publish multi-arch images (push) Has been cancelled
Replace Zod schemas with plain TypeScript validation in env.ts,
config.ts, and invite/parse.ts. Zod 4 classes break under bun
build --target=node (Class2 is not a constructor).

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
2026-04-06 10:51:42 +01:00
5 changed files with 83 additions and 74 deletions

View File

@@ -1,6 +1,6 @@
{ {
"name": "claudemesh-cli", "name": "claudemesh-cli",
"version": "0.1.7", "version": "0.1.9",
"description": "Claude Code MCP client for claudemesh — peer mesh messaging between Claude sessions.", "description": "Claude Code MCP client for claudemesh — peer mesh messaging between Claude sessions.",
"keywords": [ "keywords": [
"claude-code", "claude-code",

View File

@@ -195,10 +195,20 @@ export async function runLaunch(extraArgs: string[]): Promise<void> {
if (!args.quiet) printBanner(displayName, mesh.slug); if (!args.quiet) printBanner(displayName, mesh.slug);
// 6. Spawn claude with ephemeral config + dev channel + display name. // 6. Spawn claude with ephemeral config + dev channel + display name.
// Strip any user-supplied --dangerously-load-development-channels
// to avoid duplicates — we always inject our own.
const filtered: string[] = [];
for (let i = 0; i < args.claudeArgs.length; i++) {
if (args.claudeArgs[i] === "--dangerously-load-development-channels") {
i++; // skip the next arg (the channel value) too
continue;
}
filtered.push(args.claudeArgs[i]!);
}
const claudeArgs = [ const claudeArgs = [
"--dangerously-load-development-channels", "--dangerously-load-development-channels",
"server:claudemesh", "server:claudemesh",
...args.claudeArgs, ...filtered,
]; ];
const isWindows = process.platform === "win32"; const isWindows = process.platform === "win32";

View File

@@ -1,27 +1,23 @@
import { z } from "zod";
/** /**
* CLI environment config. * CLI environment config.
* *
* Read once at startup. Overridable via env vars so users can point * Read once at startup. Overridable via env vars so users can point
* at a self-hosted broker or a staging instance without rebuilding. * at a self-hosted broker or a staging instance without rebuilding.
*/ */
const envSchema = z.object({
CLAUDEMESH_BROKER_URL: z.string().default("wss://ic.claudemesh.com/ws"),
CLAUDEMESH_CONFIG_DIR: z.string().optional(),
CLAUDEMESH_DEBUG: z.coerce.boolean().default(false),
});
export type CliEnv = z.infer<typeof envSchema>; export interface CliEnv {
CLAUDEMESH_BROKER_URL: string;
CLAUDEMESH_CONFIG_DIR: string | undefined;
CLAUDEMESH_DEBUG: boolean;
}
export function loadEnv(): CliEnv { export function loadEnv(): CliEnv {
const parsed = envSchema.safeParse(process.env); return {
if (!parsed.success) { CLAUDEMESH_BROKER_URL:
console.error("[claudemesh] invalid environment:"); process.env.CLAUDEMESH_BROKER_URL ?? "wss://ic.claudemesh.com/ws",
console.error(z.treeifyError(parsed.error)); CLAUDEMESH_CONFIG_DIR: process.env.CLAUDEMESH_CONFIG_DIR || undefined,
process.exit(1); CLAUDEMESH_DEBUG: process.env.CLAUDEMESH_DEBUG === "1" || process.env.CLAUDEMESH_DEBUG === "true",
} };
return parsed.data;
} }
export const env = loadEnv(); export const env = loadEnv();

View File

@@ -5,22 +5,19 @@
* verification and one-time-use invite-token tracking land in Step 18. * verification and one-time-use invite-token tracking land in Step 18.
*/ */
import { z } from "zod";
import { ensureSodium } from "../crypto/keypair"; import { ensureSodium } from "../crypto/keypair";
const invitePayloadSchema = z.object({ export interface InvitePayload {
v: z.literal(1), v: 1;
mesh_id: z.string().min(1), mesh_id: string;
mesh_slug: z.string().min(1), mesh_slug: string;
broker_url: z.string().min(1), broker_url: string;
expires_at: z.number().int().positive(), expires_at: number;
mesh_root_key: z.string().min(1), mesh_root_key: string;
role: z.enum(["admin", "member"]), role: "admin" | "member";
owner_pubkey: z.string().regex(/^[0-9a-f]{64}$/i), owner_pubkey: string;
signature: z.string().regex(/^[0-9a-f]{128}$/i), signature: string;
}); }
export type InvitePayload = z.infer<typeof invitePayloadSchema>;
export interface ParsedInvite { export interface ParsedInvite {
payload: InvitePayload; payload: InvitePayload;
@@ -28,6 +25,21 @@ export interface ParsedInvite {
token: string; // base64url(JSON) — DB lookup key (everything after ic://join/) token: string; // base64url(JSON) — DB lookup key (everything after ic://join/)
} }
function validatePayload(obj: unknown): InvitePayload {
if (!obj || typeof obj !== "object") throw new Error("invite payload is not an object");
const o = obj as Record<string, unknown>;
if (o.v !== 1) throw new Error("invite payload: v must be 1");
if (typeof o.mesh_id !== "string" || !o.mesh_id) throw new Error("invite payload: mesh_id required");
if (typeof o.mesh_slug !== "string" || !o.mesh_slug) throw new Error("invite payload: mesh_slug required");
if (typeof o.broker_url !== "string" || !o.broker_url) throw new Error("invite payload: broker_url required");
if (typeof o.expires_at !== "number" || o.expires_at <= 0) throw new Error("invite payload: expires_at must be a positive number");
if (typeof o.mesh_root_key !== "string" || !o.mesh_root_key) throw new Error("invite payload: mesh_root_key required");
if (o.role !== "admin" && o.role !== "member") throw new Error("invite payload: role must be admin or member");
if (typeof o.owner_pubkey !== "string" || !/^[0-9a-f]{64}$/i.test(o.owner_pubkey)) throw new Error("invite payload: owner_pubkey must be 64 hex chars");
if (typeof o.signature !== "string" || !/^[0-9a-f]{128}$/i.test(o.signature)) throw new Error("invite payload: signature must be 128 hex chars");
return o as unknown as InvitePayload;
}
/** Canonical invite bytes — must match broker's canonicalInvite(). */ /** Canonical invite bytes — must match broker's canonicalInvite(). */
export function canonicalInvite(p: { export function canonicalInvite(p: {
v: number; v: number;
@@ -96,41 +108,34 @@ export async function parseInviteLink(link: string): Promise<ParsedInvite> {
); );
} }
const parsed = invitePayloadSchema.safeParse(obj); const payload = validatePayload(obj);
if (!parsed.success) {
throw new Error(
`invite link shape invalid: ${parsed.error.issues.map((i) => i.path.join(".") + ": " + i.message).join("; ")}`,
);
}
// Expiry check (unix seconds). // Expiry check (unix seconds).
const nowSeconds = Math.floor(Date.now() / 1000); const nowSeconds = Math.floor(Date.now() / 1000);
if (parsed.data.expires_at < nowSeconds) { if (payload.expires_at < nowSeconds) {
throw new Error( throw new Error(
`invite expired: expires_at=${parsed.data.expires_at}, now=${nowSeconds}`, `invite expired: expires_at=${payload.expires_at}, now=${nowSeconds}`,
); );
} }
// Verify the ed25519 signature against the embedded owner_pubkey. // Verify the ed25519 signature against the embedded owner_pubkey.
// Client-side verification gives immediate feedback on tampered
// links; broker re-verifies authoritatively on /join.
const s = await ensureSodium(); const s = await ensureSodium();
const canonical = canonicalInvite({ const canonical = canonicalInvite({
v: parsed.data.v, v: payload.v,
mesh_id: parsed.data.mesh_id, mesh_id: payload.mesh_id,
mesh_slug: parsed.data.mesh_slug, mesh_slug: payload.mesh_slug,
broker_url: parsed.data.broker_url, broker_url: payload.broker_url,
expires_at: parsed.data.expires_at, expires_at: payload.expires_at,
mesh_root_key: parsed.data.mesh_root_key, mesh_root_key: payload.mesh_root_key,
role: parsed.data.role, role: payload.role,
owner_pubkey: parsed.data.owner_pubkey, owner_pubkey: payload.owner_pubkey,
}); });
const sigOk = (() => { const sigOk = (() => {
try { try {
return s.crypto_sign_verify_detached( return s.crypto_sign_verify_detached(
s.from_hex(parsed.data.signature), s.from_hex(payload.signature),
s.from_string(canonical), s.from_string(canonical),
s.from_hex(parsed.data.owner_pubkey), s.from_hex(payload.owner_pubkey),
); );
} catch { } catch {
return false; return false;
@@ -140,7 +145,7 @@ export async function parseInviteLink(link: string): Promise<ParsedInvite> {
throw new Error("invite signature invalid (link tampered?)"); throw new Error("invite signature invalid (link tampered?)");
} }
return { payload: parsed.data, raw: link, token: encoded }; return { payload, raw: link, token: encoded };
} }
/** /**
@@ -155,8 +160,6 @@ export function encodeInviteLink(payload: InvitePayload): string {
/** /**
* Sign and assemble an invite payload → ic://join/... link. * Sign and assemble an invite payload → ic://join/... link.
* The canonical bytes (everything except signature) are signed with
* the mesh owner's ed25519 secret key.
*/ */
export async function buildSignedInvite(args: { export async function buildSignedInvite(args: {
v: 1; v: 1;

View File

@@ -15,38 +15,38 @@ import {
} from "node:fs"; } from "node:fs";
import { homedir } from "node:os"; import { homedir } from "node:os";
import { join, dirname } from "node:path"; import { join, dirname } from "node:path";
import { z } from "zod";
import { env } from "../env"; import { env } from "../env";
const joinedMeshSchema = z.object({ export interface JoinedMesh {
meshId: z.string(), meshId: string;
memberId: z.string(), memberId: string;
slug: z.string(), slug: string;
name: z.string(), name: string;
pubkey: z.string(), // ed25519 hex (32 bytes = 64 chars) pubkey: string; // ed25519 hex (32 bytes = 64 chars)
secretKey: z.string(), // ed25519 hex (64 bytes = 128 chars) secretKey: string; // ed25519 hex (64 bytes = 128 chars)
brokerUrl: z.string(), brokerUrl: string;
joinedAt: z.string(), joinedAt: string;
}); }
const configSchema = z.object({ export interface Config {
version: z.literal(1).default(1), version: 1;
meshes: z.array(joinedMeshSchema).default([]), meshes: JoinedMesh[];
}); }
export type JoinedMesh = z.infer<typeof joinedMeshSchema>;
export type Config = z.infer<typeof configSchema>;
const CONFIG_DIR = env.CLAUDEMESH_CONFIG_DIR ?? join(homedir(), ".claudemesh"); const CONFIG_DIR = env.CLAUDEMESH_CONFIG_DIR ?? join(homedir(), ".claudemesh");
const CONFIG_PATH = join(CONFIG_DIR, "config.json"); const CONFIG_PATH = join(CONFIG_DIR, "config.json");
export function loadConfig(): Config { export function loadConfig(): Config {
if (!existsSync(CONFIG_PATH)) { if (!existsSync(CONFIG_PATH)) {
return configSchema.parse({ version: 1, meshes: [] }); return { version: 1, meshes: [] };
} }
try { try {
const raw = readFileSync(CONFIG_PATH, "utf-8"); const raw = readFileSync(CONFIG_PATH, "utf-8");
return configSchema.parse(JSON.parse(raw)); const parsed = JSON.parse(raw);
if (!parsed || !Array.isArray(parsed.meshes)) {
return { version: 1, meshes: [] };
}
return { version: 1, meshes: parsed.meshes };
} catch (e) { } catch (e) {
throw new Error( throw new Error(
`Failed to load ${CONFIG_PATH}: ${e instanceof Error ? e.message : String(e)}`, `Failed to load ${CONFIG_PATH}: ${e instanceof Error ? e.message : String(e)}`,