tbenandClaude Opus 5.5
7b762fd384
A worker asks for another bot's help with ask_crew. The coordinator reads the request, asks the right bot (in a workspace, only its members), and sends the answer back into the asking bot's conversation, waking it. Each exchange is kept as a read-only chatroom: listed in the main rail after the workspaces, or in the workspace's rail for requests made there, with live status rows for each bot while it's open and a Stop button. Room sessions are hidden from every conversation list, other bots' words reach the model fenced as data, and turns, nesting and open rooms are capped. Closed rooms are pruned after a retention period and past a cap per place (Settings > General). Co-Authored-By: Claude Opus 5.5 <[email protected]>
75 lines
2.7 KiB
TypeScript
75 lines
2.7 KiB
TypeScript
import grabBotById from "@/src/functions/backend/db/bots/grab-bot-by-id";
|
|
import grabJobUserId from "@/src/functions/backend/db/bots-queue/grab-job-user-id";
|
|
import HarnessError from "@/src/harness/harness-error";
|
|
import { runWithHarnessUsageScope } from "@/src/harness/usage/harness-usage-scope";
|
|
import BotJobFatalError from "./bot-job-fatal-error";
|
|
import runBotReply from "./run-bot-reply";
|
|
import runBotTask from "./run-bot-task";
|
|
import runChatroomTurn from "./run-chatroom-turn";
|
|
import type { BotJobRunner } from "./types";
|
|
|
|
/**
|
|
* Does a job's actual work on the harness: a `reply` answers the user in
|
|
* chat (`runBotReply`), a `task` works through its brief (`runBotTask`),
|
|
* and the coordinator's turn in a chatroom works the room's request
|
|
* (`runChatroomTurn`).
|
|
*
|
|
* It works for the user whose conversation the job is in: their memory,
|
|
* and only what they can reach.
|
|
*
|
|
* Harness failures that waiting can fix (rate limits, outages) are thrown
|
|
* as they are, so the queue retries with backoff; the rest are fatal.
|
|
*/
|
|
const runBotJob: BotJobRunner = async (context) => {
|
|
const { job } = context;
|
|
const bot = job.bot_id ? await grabBotById({ bot_id: job.bot_id }) : null;
|
|
|
|
if (!bot?.id) {
|
|
throw new BotJobFatalError(`The bot for this job no longer exists.`);
|
|
}
|
|
|
|
const user_id = await grabJobUserId({ job });
|
|
|
|
if (!user_id) {
|
|
throw new BotJobFatalError(`The conversation for this job no longer exists.`);
|
|
}
|
|
|
|
const owned = { ...bot, id: bot.id };
|
|
|
|
try {
|
|
/**
|
|
* Everything the job's models do is recorded for this user, this
|
|
* bot, this conversation and this job. A reply's text loop adds
|
|
* the message it is producing to the one-turn scope it opens.
|
|
*/
|
|
return await runWithHarnessUsageScope({
|
|
scope: {
|
|
user_id,
|
|
bot_id: bot.id,
|
|
workspace_id: job.workspace_id || null,
|
|
session_id: job.session_id || null,
|
|
job_id: job.id || null,
|
|
message_id: null,
|
|
},
|
|
task: () =>
|
|
bot.kind == "coordinator" && context.params.chatroom_id
|
|
? runChatroomTurn({ ...context, bot: owned, user_id })
|
|
: job.kind == "reply"
|
|
? runBotReply({ ...context, bot: owned, user_id })
|
|
: runBotTask({ ...context, bot: owned, user_id }),
|
|
});
|
|
} catch (error: unknown) {
|
|
if (
|
|
error instanceof HarnessError &&
|
|
error.code != "aborted" &&
|
|
!error.retryable
|
|
) {
|
|
throw new BotJobFatalError(error.message);
|
|
}
|
|
|
|
throw error;
|
|
}
|
|
};
|
|
|
|
export default runBotJob;
|