1 files changed, 35 insertions, 0 deletions

diff --git a/packages/transport-http/src/app.ts b/packages/transport-http/src/app.ts
index 656be9d..32a92f1 100644
--- a/packages/transport-http/src/app.ts
+++ b/packages/transport-http/src/app.ts
@@ -29,6 +29,7 @@ import type {
   ModelResponse,
   ModelsResponse,
   OpenConversationResponse,
+  QueueCancelResponse,
   QueueResponse,
   ReasoningEffortResponse,
   SetCompactPercentRequest,
@@ -456,6 +457,7 @@ export function createApp(opts: CreateServerOptions): Hono {
       reasoningEffort,
       workspaceId,
       images,
+      title,
     } = result;
     log.info("chat: request accepted", {
       conversationId,
@@ -516,6 +518,7 @@ export function createApp(opts: CreateServerOptions): Hono {
       ...(reasoningEffort !== undefined ? { reasoningEffort } : {}),
       ...(workspaceId !== undefined ? { workspaceId } : {}),
       ...(images !== undefined ? { images } : {}),
+      ...(title !== undefined ? { title } : {}),
     };
 
     opts.orchestrator
@@ -796,6 +799,28 @@ export function createApp(opts: CreateServerOptions): Hono {
     return c.json(response, 200);
   });
 
+  app.delete("/conversations/:id/queue/:messageId", (c) => {
+    const conversationId = c.req.param("id");
+    const messageId = c.req.param("messageId");
+
+    // `cancelQueuedMessage` is synchronous and owns the lookup + removal (no
+    // separate race — the pure `cancel` is idempotent). It does not throw for an
+    // unknown/idle conversation, which instead returns cancelled:false. Mirrors
+    // the direct sync call used by `POST /conversations/:id/queue`.
+    const { cancelled, queue } = opts.orchestrator.cancelQueuedMessage({
+      conversationId,
+      messageId,
+    });
+    log.info("conversations: cancelled queued message", {
+      conversationId,
+      messageId,
+      cancelled,
+      queueLength: queue.length,
+    });
+    const response: QueueCancelResponse = { conversationId, cancelled, queue };
+    return c.json(response, 200);
+  });
+
   app.get("/conversations/:id/cwd", async (c) => {
     const conversationId = c.req.param("id");
     try {
@@ -1673,6 +1698,16 @@ export function createApp(opts: CreateServerOptions): Hono {
       update.enabled = obj.enabled;
     }
 
+    // inactiveOnly: when true (the default), the heartbeat skips a fire while
+    // the configured workspace has active agents. A boolean; absent leaves it
+    // unchanged.
+    if (obj.inactiveOnly !== undefined) {
+      if (typeof obj.inactiveOnly !== "boolean") {
+        return c.json({ error: "Field 'inactiveOnly' must be a boolean" }, 400);
+      }
+      update.inactiveOnly = obj.inactiveOnly;
+    }
+
     if (obj.systemPrompt !== undefined) {
       if (typeof obj.systemPrompt !== "string") {
         return c.json({ error: "Field 'systemPrompt' must be a string" }, 400);