-
-
- );
- }
-
return (
-
+ = {};
@@ -153,18 +113,6 @@ export function Sidebar({ liveStates, collapsed, onToggle }: SidebarProps) {
const isOverview = matchRoute({ to: "/" });
const isSettings = matchRoute({ to: "/settings" });
- const agentActivity = useMemo(() => {
- const byAgent: Record = {};
- for (const channel of channels) {
- const live = liveStates[channel.id];
- if (!live) continue;
- if (!byAgent[channel.agent_id]) byAgent[channel.agent_id] = { workers: 0, branches: 0 };
- byAgent[channel.agent_id].workers += Object.keys(live.workers).length;
- byAgent[channel.agent_id].branches += Object.keys(live.branches).length;
- }
- return byAgent;
- }, [channels, liveStates]);
-
const sensors = useSensors(
useSensor(PointerSensor, {
activationConstraint: {
@@ -187,40 +135,9 @@ export function Sidebar({ liveStates, collapsed, onToggle }: SidebarProps) {
};
return (
-
- {/* Logo + collapse toggle */}
-
+
);
}
diff --git a/interface/src/components/TopBar.tsx b/interface/src/components/TopBar.tsx
new file mode 100644
index 000000000..cf5d6c4b0
--- /dev/null
+++ b/interface/src/components/TopBar.tsx
@@ -0,0 +1,118 @@
+import { createContext, useContext, useRef, useCallback, useSyncExternalStore, type ReactNode, type MouseEvent } from "react";
+import { Link } from "@tanstack/react-router";
+import { BASE_PATH, IS_TAURI } from "@/api/client";
+
+// ── Context ──────────────────────────────────────────────────────────────
+
+interface TopBarStore {
+ content: ReactNode;
+ subscribe: (cb: () => void) => () => void;
+ setContent: (node: ReactNode) => void;
+ getSnapshot: () => ReactNode;
+}
+
+function createTopBarStore(): TopBarStore {
+ let content: ReactNode = null;
+ const listeners = new Set<() => void>();
+
+ return {
+ get content() {
+ return content;
+ },
+ subscribe(cb: () => void) {
+ listeners.add(cb);
+ return () => listeners.delete(cb);
+ },
+ setContent(node: ReactNode) {
+ content = node;
+ for (const cb of listeners) cb();
+ },
+ getSnapshot() {
+ return content;
+ },
+ };
+}
+
+const TopBarContext = createContext(null);
+
+export function TopBarProvider({ children }: { children: ReactNode }) {
+ const storeRef = useRef(null);
+ if (!storeRef.current) {
+ storeRef.current = createTopBarStore();
+ }
+ return (
+
+ {children}
+
+ );
+}
+
+/**
+ * Hook for routes to set topbar content. Content is displayed in the TopBar
+ * component rendered at the root layout level.
+ *
+ * The component that calls this hook "owns" the topbar content for its lifetime.
+ * Uses a ref + effect to avoid re-render loops.
+ */
+export function useSetTopBar(node: ReactNode) {
+ const store = useContext(TopBarContext);
+ if (!store) throw new Error("useSetTopBar must be used within TopBarProvider");
+
+ // Update content synchronously during render (like useSyncExternalStore pattern).
+ // This avoids the useEffect loop entirely.
+ store.setContent(node);
+}
+
+// ── Component ────────────────────────────────────────────────────────────
+
+export function TopBar() {
+ const store = useContext(TopBarContext);
+ if (!store) throw new Error("TopBar must be used within TopBarProvider");
+
+ const content = useSyncExternalStore(
+ store.subscribe,
+ store.getSnapshot,
+ store.getSnapshot,
+ );
+
+ const handleMouseDown = useCallback((e: MouseEvent) => {
+ if (!IS_TAURI) return;
+ // Only drag on primary button, and not when clicking interactive elements
+ if (e.buttons !== 1) return;
+ const target = e.target as HTMLElement;
+ if (target.closest("a, button, input, select, textarea, [role=button]")) return;
+ e.preventDefault();
+ (window as any).__TAURI_INTERNALS__.invoke("plugin:window|start_dragging");
+ }, []);
+
+ return (
+
-
);
}
-export function Sidebar({ liveStates, collapsed, onToggle }: SidebarProps) {
+export function Sidebar({ liveStates: _liveStates }: SidebarProps) {
const [createOpen, setCreateOpen] = useState(false);
const { data: agentsData } = useQuery({
@@ -119,12 +86,6 @@ export function Sidebar({ liveStates, collapsed, onToggle }: SidebarProps) {
refetchInterval: 30_000,
});
- const { data: channelsData } = useQuery({
- queryKey: ["channels"],
- queryFn: api.channels,
- refetchInterval: 10_000,
- });
-
const { data: providersData } = useQuery({
queryKey: ["providers"],
queryFn: api.providers,
@@ -134,8 +95,7 @@ export function Sidebar({ liveStates, collapsed, onToggle }: SidebarProps) {
const hasProvider = providersData?.has_any ?? false;
const agents = agentsData?.agents ?? [];
- const channels = channelsData?.channels ?? [];
-
+
const agentIds = useMemo(() => agents.map((a) => a.id), [agents]);
const agentDisplayNames = useMemo(() => {
const map: Record
- {activity.workers > 0 && (
-
- {activity.workers}w
-
- )}
- {activity.branches > 0 && (
-
- {activity.branches}b
-
- )}
-
- )}
+
- {collapsed ? (
-
- ) : (
-
-
- {/* Collapsed: icon-only nav */}
- {collapsed ? (
-
-
- 
-
- Spacebot
-
-
-
-
- )}
-
-
- Spacebot
-
-
-
-
+
{agents[0] && (
+ {/* Left corner block */}
+ {IS_TAURI ? (
+ /* Tauri: padding for macOS traffic lights */
+
+ ) : (
+ /* Web: ball icon block matching sidebar width + border */
+
+
+
+ )}
+
+ {/* Route-controlled content area */}
+
+ );
+}
diff --git a/interface/src/main.tsx b/interface/src/main.tsx
index 156771b6f..fb97b5e16 100644
--- a/interface/src/main.tsx
+++ b/interface/src/main.tsx
@@ -7,6 +7,11 @@ import "@fontsource/ibm-plex-sans/500.css";
import "@fontsource/ibm-plex-sans/600.css";
import "@fontsource/ibm-plex-sans/700.css";
+// WKWebView renders at a slightly smaller effective scale than browsers
+if ((window as any).__TAURI_INTERNALS__) {
+ document.body.style.zoom = "1.1";
+}
+
ReactDOM.createRoot(document.getElementById("root")!).render(
+
+ )}
+
+ {/* Route-controlled content area */}
+
+ {content}
+
+
- setSidebarCollapsed(!sidebarCollapsed)}
- />
-
+
+
);
}
-function AgentHeader({agentId}: {agentId: string}) {
+// ── Topbar content for agent routes ──────────────────────────────────────
+
+function AgentTopBar({agentId}: {agentId: string}) {
const agentsQuery = useQuery({
queryKey: ["agents"],
queryFn: () => api.agents(),
@@ -58,9 +59,9 @@ function AgentHeader({agentId}: {agentId: string}) {
const agent = agentsQuery.data?.agents.find((a) => a.id === agentId);
const displayName = agent?.display_name;
- return (
- <>
-
+ useSetTopBar(
+
+
+
-
-
+
+
+
,
);
+
+ return {displayName ? ( <> @@ -71,12 +72,15 @@ function AgentHeader({agentId}: {agentId: string}) { agentId )}
- -
+
,
+ );
return (
- Logs
+
-
-
-
Logs
-
-
+ Logs coming soon
-
+
);
},
@@ -128,7 +132,7 @@ const agentRoute = createRoute({
const {liveStates} = useLiveContext();
return (
Logs coming soon
-
-
-
-
-
-
-
-
-
-
-
-
-
@@ -314,23 +301,26 @@ function WorkerCard({
onClick={onClick}
className={cx(
"flex w-full flex-col gap-1 border-b border-app-line/30 px-4 py-3 text-left transition-colors",
- selected ? "bg-app-selected/50" : "",
+ selected ? "bg-app-hover/30" : "",
)}
>
-
-
- {worker.task} +
+
- {/* Compact status bar */}
-
+ {worker.task.replace(/^\[opencode]\s*/, "")}
-
- {isInteractive && (
+
- {/* Tab bar (only for OpenCode workers with embed data) */}
- {hasOpenCodeEmbed && (
-
+ {worker.worker_type === "opencode" ? (
+
+ OpenCode
+
+ ) : isInteractive ? (
interactive
- )}
+ ) : null}
{isLive && !isIdle && (
@@ -451,33 +441,61 @@ function WorkerDetail({
/>
)}
-
- {detail.channel_name && {detail.channel_name}}
- {hasOpenCodeEmbed && detail.opencode_port && (
-
+
{/* Live status bar for running workers */}
@@ -494,34 +512,6 @@ function WorkerDetail({
)}
+ {detail.channel_name && {detail.channel_name}}
+ {hasOpenCodeEmbed && detail.opencode_port && (
+
+ {hasOpenCodeEmbed && (
+
+
+
+
)}
-
-
-
- )}
-
{/* Content */}
{activeTab === "opencode" && hasOpenCodeEmbed ? (
-
-
,
+ );
+ return (
+
-
+ useSetTopBar(
+ Spacebot
- {statusData ? ( - - ) : ( - - )} -
+
-
+
+ )}
+
+
- Spacebot
+ {statusData ? ( + + ) : ( + + )} +
-
- {agents.length} agent{agents.length !== 1 ? "s" : ""}
-
-
- {channels.length} channel{channels.length !== 1 ? "s" : ""}
-
- {formatUptime(uptime)}
-
+
+
+ {agents.length} agent{agents.length !== 1 ? "s" : ""}
+
+
+ {channels.length} channel{channels.length !== 1 ? "s" : ""}
+
+ {formatUptime(uptime)}
+
- {(activity.workers > 0 || activity.branches > 0) && (
-
- {activity.workers > 0 && (
-
-
-
- {activity.workers}w
-
+ {(activity.workers > 0 || activity.branches > 0) && (
+
+
+ )}
+
+ {activity.workers > 0 && (
+
+
+
+ {activity.workers}w
- )}
- {activity.branches > 0 && (
-
-
-
- {activity.branches}b
-
+
+ )}
+ {activity.branches > 0 && (
+
+
+
+ {activity.branches}b
- )}
-
- )}
-
-
+
+
+
{/* Full-screen topology */}
{overviewLoading ? (
diff --git a/interface/src/routes/Settings.tsx b/interface/src/routes/Settings.tsx
index 90aa6e96d..8086d9194 100644
--- a/interface/src/routes/Settings.tsx
+++ b/interface/src/routes/Settings.tsx
@@ -12,6 +12,7 @@ import { faSearch } from "@fortawesome/free-solid-svg-icons";
import { parse as parseToml } from "smol-toml";
import { useTheme, THEMES, type ThemeId } from "@/hooks/useTheme";
import { Markdown } from "@/components/Markdown";
+import { useSetTopBar } from "@/components/TopBar";
type SectionId = "appearance" | "providers" | "channels" | "api-keys" | "secrets" | "server" | "opencode" | "worker-logs" | "updates" | "config-file" | "changelog";
@@ -572,6 +573,16 @@ export function Settings() {
return data.providers[statusKey] ?? false;
};
+ const sectionLabel = SECTIONS.find((s) => s.id === activeSection)?.label;
+
+ useSetTopBar(
+
+
,
+ );
+
return (
+ {sectionLabel ?? "Settings"} +
+
{/* Sidebar */}
@@ -596,11 +607,6 @@ export function Settings() {
{/* Content */}
-
-
- {SECTIONS.find((s) => s.id === activeSection)?.label} -
-
{activeSection === "appearance" ? (
>>>;
+
/// A background process result waiting to be relayed to the user via retrigger.
///
/// Instead of injecting raw result text into history as a fake "User" message
@@ -111,6 +115,15 @@ pub struct ChannelState {
pub logs_dir: std::path::PathBuf,
/// Prompt snapshot store for debugging prompt construction.
pub prompt_snapshot_store: Option>,
+ /// Shared live transcript cache for running workers. When a worker is
+ /// cancelled via `handle.abort()`, we drain its accumulated transcript
+ /// steps from this cache and persist them to the DB so that cancelled
+ /// workers still have their transcript available for review.
+ ///
+ /// This Arc is shared with `ApiState` — the event loop populates it from
+ /// `ToolStarted`/`ToolCompleted` events as they flow through the system.
+ /// Defaults to a standalone empty map when the API layer is not active.
+ pub live_worker_transcripts: LiveWorkerTranscripts,
}
impl ChannelState {
@@ -152,10 +165,73 @@ impl ChannelState {
return Err(format!("Worker {worker_id} not found"));
}
+ // Abort first so the worker stops producing new ToolStarted/ToolCompleted
+ // events, then drain whatever was accumulated. This avoids a race where
+ // events written between drain and abort would be lost.
if let Some(handle) = handle {
handle.abort();
}
+ // Now that the worker future is cancelled, drain the live transcript
+ // cache. persist_transcript() inside the worker's run() method will
+ // never execute after abort, so we compensate here.
+ let live_steps = self
+ .live_worker_transcripts
+ .write()
+ .await
+ .remove(&worker_id.to_string());
+
+ // Persist whatever transcript was accumulated from ToolStarted/ToolCompleted
+ // events. This is a best-effort snapshot — it won't include the worker's
+ // internal reasoning text (which only exists in the Rig history) but it
+ // captures every tool call and result, which is the most useful part.
+ if let Some(steps) = &live_steps
+ && !steps.is_empty()
+ {
+ let transcript_blob = crate::conversation::worker_transcript::serialize_steps(steps);
+ let worker_id_str = worker_id.to_string();
+ let pool = self.deps.sqlite_pool.clone();
+ // Count tool calls from the transcript steps.
+ let tool_calls: i64 = steps
+ .iter()
+ .map(|step| match step {
+ crate::conversation::worker_transcript::TranscriptStep::Action { content } => {
+ content
+ .iter()
+ .filter(|c| {
+ matches!(
+ c,
+ crate::conversation::worker_transcript::ActionContent::ToolCall {
+ ..
+ }
+ )
+ })
+ .count() as i64
+ }
+ _ => 0,
+ })
+ .sum();
+ // Fire-and-forget DB write (consistent with the existing pattern
+ // documented in AGENTS.md under "Fire-and-forget DB writes").
+ tokio::spawn(async move {
+ if let Err(error) = sqlx::query(
+ "UPDATE worker_runs SET transcript = ?, tool_calls = ? WHERE id = ? AND transcript IS NULL",
+ )
+ .bind(&transcript_blob)
+ .bind(tool_calls)
+ .bind(&worker_id_str)
+ .execute(&pool)
+ .await
+ {
+ tracing::warn!(
+ %error,
+ worker_id = %worker_id_str,
+ "failed to persist cancelled worker transcript"
+ );
+ }
+ });
+ }
+
let reason = crate::summarize_first_non_empty_line(reason, crate::EVENT_SUMMARY_MAX_CHARS);
let result = if reason.is_empty() {
"Worker cancelled.".to_string()
@@ -405,6 +481,7 @@ impl Channel {
/// All tunable config (prompts, routing, thresholds, browser, skills) is read
/// from `deps.runtime_config` on each use, so changes propagate to running
/// channels without restart.
+ #[allow(clippy::too_many_arguments)]
pub fn new(
id: ChannelId,
deps: AgentDeps,
@@ -413,6 +490,7 @@ impl Channel {
screenshot_dir: std::path::PathBuf,
logs_dir: std::path::PathBuf,
prompt_snapshot_store: Option>,
+ live_worker_transcripts: Option,
) -> (Self, mpsc::Sender) {
let process_id = ProcessId::Channel(id.clone());
let hook = SpacebotHook::new(
@@ -452,6 +530,8 @@ impl Channel {
screenshot_dir,
logs_dir,
prompt_snapshot_store,
+ live_worker_transcripts: live_worker_transcripts
+ .unwrap_or_else(|| Arc::new(RwLock::new(HashMap::new()))),
};
// Each channel gets its own isolated tool server to avoid races between
diff --git a/src/cron/scheduler.rs b/src/cron/scheduler.rs
index 1d0fe5d60..adf59101b 100644
--- a/src/cron/scheduler.rs
+++ b/src/cron/scheduler.rs
@@ -862,6 +862,7 @@ async fn run_cron_job(job: &CronJob, context: &CronContext) -> Result<()> {
context.screenshot_dir.clone(),
context.logs_dir.clone(),
None, // cron channels don't capture prompt snapshots
+ None, // cron channels don't share live transcript cache
);
// Spawn the channel's event loop
diff --git a/src/main.rs b/src/main.rs
index 4caf60e32..0679c27f3 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1829,6 +1829,7 @@ async fn run(
agent.config.screenshot_dir(),
agent.config.logs_dir(),
snapshot_store,
+ Some(api_state.live_worker_transcripts.clone()),
);
let channel_registration_id = agent
.deps
@@ -2036,6 +2037,7 @@ async fn run(
agent.config.screenshot_dir(),
agent.config.logs_dir(),
snapshot_store,
+ Some(api_state.live_worker_transcripts.clone()),
);
let channel_registration_id = agent
.deps
diff --git a/src/tools/send_message_to_another_channel.rs b/src/tools/send_message_to_another_channel.rs
index bb0681fab..b2232f637 100644
--- a/src/tools/send_message_to_another_channel.rs
+++ b/src/tools/send_message_to_another_channel.rs
@@ -188,28 +188,39 @@ impl Tool for SendMessageTool {
.current_adapter
.as_ref()
.filter(|adapter| adapter.starts_with("signal"))
- && let Some(target) = parse_implicit_signal_shorthand(&args.target, current_adapter)
{
- self.messaging_manager
- .broadcast(
- &target.adapter,
- &target.target,
- crate::OutboundResponse::Text(args.message),
- )
- .await
- .map_err(|error| SendMessageError(format!("failed to send message: {error}")))?;
-
- tracing::info!(
- adapter = %target.adapter,
- broadcast_target = %"[REDACTED]",
- "message sent via implicit Signal shorthand"
- );
-
- return Ok(SendMessageOutput {
- success: true,
- target: target.target,
- platform: target.adapter,
- });
+ match parse_implicit_signal_shorthand(&args.target, current_adapter) {
+ Ok(Some(target)) => {
+ self.messaging_manager
+ .broadcast(
+ &target.adapter,
+ &target.target,
+ crate::OutboundResponse::Text(args.message),
+ )
+ .await
+ .map_err(|error| {
+ SendMessageError(format!("failed to send message: {error}"))
+ })?;
+
+ tracing::info!(
+ adapter = %target.adapter,
+ broadcast_target = %"[REDACTED]",
+ "message sent via implicit Signal shorthand"
+ );
+
+ return Ok(SendMessageOutput {
+ success: true,
+ target: target.target,
+ platform: target.adapter,
+ });
+ }
+ Err(validation_error) => {
+ return Err(SendMessageError(validation_error));
+ }
+ Ok(None) => {
+ // Not a Signal shorthand — fall through to channel-name lookup.
+ }
+ }
}
// Check for explicit email target
@@ -328,25 +339,34 @@ fn parse_explicit_signal_prefix(raw: &str) -> Option Option {
+) -> Result, String> {
let trimmed = raw.trim();
if trimmed.is_empty() {
- return None;
+ return Ok(None);
}
use crate::messaging::target::BroadcastTarget;
// Check for bare UUID format (strict validation)
if is_valid_uuid(trimmed) {
- return Some(BroadcastTarget {
+ return Ok(Some(BroadcastTarget {
adapter: current_adapter.to_string(),
target: format!("uuid:{trimmed}"),
- });
+ }));
+ }
+
+ // Looks like a UUID but doesn't parse — give a targeted error.
+ if trimmed.len() == 36 && trimmed.chars().filter(|c| *c == '-').count() == 4 {
+ return Err(format!(
+ "'{trimmed}' looks like a UUID but is malformed. Use the format: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx"
+ ));
}
// Phone number format: starts with + followed by 7+ digits
@@ -354,21 +374,38 @@ fn parse_implicit_signal_shorthand(
&& trimmed[1..].len() >= 7
&& trimmed[1..].chars().all(|c| c.is_ascii_digit())
{
- return Some(BroadcastTarget {
+ return Ok(Some(BroadcastTarget {
adapter: current_adapter.to_string(),
target: trimmed.to_string(),
- });
+ }));
+ }
+
+ // Starts with + but doesn't meet phone number requirements.
+ if let Some(digits) = trimmed.strip_prefix('+') {
+ if digits.chars().all(|c| c.is_ascii_digit()) {
+ return Err(format!(
+ "'{trimmed}' looks like a phone number but is too short. Phone numbers need at least 7 digits after the + prefix."
+ ));
+ }
+ if !digits.is_empty() {
+ return Err(format!(
+ "'{trimmed}' looks like a phone number but contains non-digit characters. Use format: +1234567890"
+ ));
+ }
}
// Group ID format: group:xxx
- if trimmed.starts_with("group:") {
- return Some(BroadcastTarget {
+ if let Some(group_id) = trimmed.strip_prefix("group:") {
+ if group_id.is_empty() {
+ return Err("group: prefix requires an ID. Use format: group:".to_string());
+ }
+ return Ok(Some(BroadcastTarget {
adapter: current_adapter.to_string(),
target: trimmed.to_string(),
- });
+ }));
}
- None
+ Ok(None)
}
fn parse_explicit_email_target(raw: &str) -> Option {
@@ -477,6 +514,7 @@ mod tests {
"123e4567-e89b-12d3-a456-426655440000",
"signal:gvoice1",
)
+ .expect("no error")
.expect("signal target");
assert_eq!(target.adapter, "signal:gvoice1");
assert_eq!(target.target, "uuid:123e4567-e89b-12d3-a456-426655440000");
@@ -485,6 +523,7 @@ mod tests {
#[test]
fn parses_implicit_signal_group_shorthand() {
let target = parse_implicit_signal_shorthand("group:grp123", "signal:default")
+ .expect("no error")
.expect("signal target");
assert_eq!(target.adapter, "signal:default");
assert_eq!(target.target, "group:grp123");
@@ -493,6 +532,7 @@ mod tests {
#[test]
fn parses_implicit_signal_bare_phone_plus() {
let target = parse_implicit_signal_shorthand("+1234567890", "signal:primary")
+ .expect("no error")
.expect("signal target");
assert_eq!(target.adapter, "signal:primary");
assert_eq!(target.target, "+1234567890");
@@ -502,27 +542,82 @@ mod tests {
fn ignores_bare_phone_digits_for_implicit() {
// Bare phone numbers without + prefix are rejected
// to avoid confusing numeric channel IDs with Signal numbers
- assert!(parse_implicit_signal_shorthand("1234567890", "signal:default").is_none());
+ assert!(
+ parse_implicit_signal_shorthand("1234567890", "signal:default")
+ .expect("no error")
+ .is_none()
+ );
}
#[test]
fn ignores_explicit_signal_prefix_for_implicit() {
// parse_implicit_signal_shorthand does NOT handle signal: prefix
// that's handled by parse_explicit_signal_prefix
- assert!(parse_implicit_signal_shorthand("signal:+1234567890", "signal:default").is_none());
+ assert!(
+ parse_implicit_signal_shorthand("signal:+1234567890", "signal:default")
+ .expect("no error")
+ .is_none()
+ );
assert!(
parse_implicit_signal_shorthand(
"signal:uuid:123e4567-e89b-12d3-a456-426655440000",
"signal:default"
)
+ .expect("no error")
.is_none()
);
}
#[test]
fn ignores_non_signal_targets_for_implicit() {
- assert!(parse_implicit_signal_shorthand("discord:123", "signal:default").is_none());
- assert!(parse_implicit_signal_shorthand("general", "signal:default").is_none());
- assert!(parse_implicit_signal_shorthand("", "signal:default").is_none());
+ assert!(
+ parse_implicit_signal_shorthand("discord:123", "signal:default")
+ .expect("no error")
+ .is_none()
+ );
+ assert!(
+ parse_implicit_signal_shorthand("general", "signal:default")
+ .expect("no error")
+ .is_none()
+ );
+ assert!(
+ parse_implicit_signal_shorthand("", "signal:default")
+ .expect("no error")
+ .is_none()
+ );
+ }
+
+ #[test]
+ fn rejects_malformed_uuid_shorthand() {
+ let error = parse_implicit_signal_shorthand(
+ "123e4567-e89b-12d3-a456-42665544ZZZZ",
+ "signal:default",
+ )
+ .expect_err("should be validation error");
+ assert!(
+ error.contains("looks like a UUID but is malformed"),
+ "{error}"
+ );
+ }
+
+ #[test]
+ fn rejects_short_phone_number() {
+ let error = parse_implicit_signal_shorthand("+123", "signal:default")
+ .expect_err("should be validation error");
+ assert!(error.contains("too short"), "{error}");
+ }
+
+ #[test]
+ fn rejects_phone_with_non_digits() {
+ let error = parse_implicit_signal_shorthand("+123456abc0", "signal:default")
+ .expect_err("should be validation error");
+ assert!(error.contains("non-digit"), "{error}");
+ }
+
+ #[test]
+ fn rejects_empty_group_id() {
+ let error = parse_implicit_signal_shorthand("group:", "signal:default")
+ .expect_err("should be validation error");
+ assert!(error.contains("requires an ID"), "{error}");
}
}
diff --git a/tests/context_dump.rs b/tests/context_dump.rs
index abf09b07d..4fad60d8f 100644
--- a/tests/context_dump.rs
+++ b/tests/context_dump.rs
@@ -246,6 +246,9 @@ async fn dump_channel_context() {
logs_dir: std::path::PathBuf::from("/tmp/logs"),
reply_target_message_id: Arc::new(tokio::sync::RwLock::new(None)),
prompt_snapshot_store: None,
+ live_worker_transcripts: Arc::new(tokio::sync::RwLock::new(
+ std::collections::HashMap::new(),
+ )),
};
let tool_server = rig::tool::server::ToolServer::new().run();
@@ -483,6 +486,9 @@ async fn dump_all_contexts() {
logs_dir: std::path::PathBuf::from("/tmp/logs"),
reply_target_message_id: Arc::new(tokio::sync::RwLock::new(None)),
prompt_snapshot_store: None,
+ live_worker_transcripts: Arc::new(tokio::sync::RwLock::new(
+ std::collections::HashMap::new(),
+ )),
};
let channel_tool_server = rig::tool::server::ToolServer::new().run();
let skip_flag = spacebot::tools::new_skip_flag();