Function handleSendMessage

scripts/coms-net-server.ts:823–964

(req: Request)

}

async function handleSendMessage(req: Request): Promise<Response> {
	let body: SendRequest;
	try {
		body = (await req.json()) as SendRequest;
	} catch {
		return errorJson("invalid_json", 400);
	}
	if (
		!body ||
		typeof body !== "object" ||
		typeof body.sender_session !== "string" ||
		typeof body.prompt !== "string"
	) {
		return errorJson("invalid_request", 400);
	}
	const projectName = body.project ?? "default";
	const p = state.projects.get(projectName);
	if (!p) return errorJson("agent_not_found", 404);

	const sender = p.agents.get(body.sender_session);
	if (!sender) return errorJson("sender_not_registered", 404);

	const hops = typeof body.hops === "number" ? body.hops : 0;
	if (hops >= MAX_HOPS) {
		logRejected("hop_limit", `${sender.name} hops=${hops} max=${MAX_HOPS}`);
		return errorJson("hop_limit_exceeded", 409, { hops, max_hops: MAX_HOPS });
	}

	// Resolve target.
	let target: RegistryEntry | undefined;
	if (body.target_session && typeof body.target_session === "string") {
		target = p.agents.get(body.target_session);
		if (!target) {
			logRejected("target_not_found", `${sender.name} → ${body.target_session.slice(-6)}`);
			return errorJson("target_not_found", 404);
		}
	} else {
		const desired = (body.target ?? "").trim();
		if (!desired) return errorJson("missing_target", 400);
		// Direct session_id match first.
		const directSid = p.agents.get(desired);
		if (directSid) {
			target = directSid;
		} else {
			const bag = p.nameIndex.get(desired);
			if (!bag || bag.size === 0) {
				logRejected("target_not_found", `${sender.name} → "${desired}"`);
				return errorJson("target_not_found", 404, { target: desired });
			}
			if (bag.size > 1) {
				logRejected("ambiguous", `${sender.name} → "${desired}" matches ${bag.size}`);
				return errorJson("ambiguous_target", 409, {
					target: desired,
					candidates: [...bag],
				});
			}
			const onlySid = [...bag][0];
			target = p.agents.get(onlySid);