+
+
+ Read-only observer mode · execution, configuration, secrets, and terminal input are disabled
+
+
+ )
+}
diff --git a/packages/app/src/pages/session/activity.ts b/packages/app/src/pages/session/activity.ts
new file mode 100644
index 0000000000..28e819eea4
--- /dev/null
+++ b/packages/app/src/pages/session/activity.ts
@@ -0,0 +1,82 @@
+export type ActivitySource = "agent" | "tool" | "mcp" | "bolt" | "browser" | "pty" | "finding" | "system"
+export type WorkbenchChannel =
+ | "activity"
+ | "mission"
+ | "topology"
+ | "memory"
+ | "mcp"
+ | "bolt"
+ | "terminal"
+ | "vulns"
+ | "web"
+
+export type Activity = {
+ id: string
+ projectID: string
+ sessionID?: string
+ type: string
+ source: ActivitySource
+ correlationID?: string
+ parentID?: string
+ data: Record
+ time: number
+}
+
+export const isActivity = (event: unknown): event is Activity => {
+ if (!event || typeof event !== "object") return false
+ const value = event as Partial
+ return (
+ typeof value.id === "string" &&
+ typeof value.type === "string" &&
+ typeof value.source === "string" &&
+ typeof value.time === "number" &&
+ !!value.data &&
+ typeof value.data === "object"
+ )
+}
+
+export const mergeActivity = (history: Activity[], live: Activity[], limit = 2_000) => {
+ const byID = new Map([...history, ...live].map((event) => [event.id, event]))
+ return [...byID.values()].sort((a, b) => a.time - b.time).slice(-limit)
+}
+
+const value = (data: Record, key: string) =>
+ typeof data[key] === "string" || typeof data[key] === "number" ? String(data[key]) : ""
+
+export const activitySummary = (event: Activity) => {
+ const title = value(event.data, "title")
+ const tool = value(event.data, "tool")
+ const status = value(event.data, "status")
+ const name = value(event.data, "name")
+ const count = value(event.data, "count")
+ return [tool || name || event.type, status, title, count ? `${count} items` : ""].filter(Boolean).join(" · ")
+}
+
+export const activityChannels = (event: Activity): WorkbenchChannel[] => {
+ const channels: WorkbenchChannel[] = ["activity"]
+ if (event.source === "mcp") channels.push("mcp")
+ if (event.source === "bolt") channels.push("bolt")
+ if (event.source === "pty") channels.push("terminal")
+ if (event.type.startsWith("memory.")) channels.push("memory")
+ if (
+ event.type.startsWith("methodology.") ||
+ event.type.startsWith("intel.") ||
+ event.type.startsWith("coverage.")
+ )
+ channels.push("mission")
+ if (event.type.startsWith("intel.")) channels.push("topology")
+ if (event.type.startsWith("vulnerability.")) channels.push("vulns", "mission", "topology")
+ if (event.type.startsWith("nmap.") || event.type.startsWith("dossier.note.")) channels.push("topology")
+ if (
+ event.type.startsWith("request.") ||
+ event.type.startsWith("web.") ||
+ event.type.startsWith("web_") ||
+ event.type.startsWith("hackbrowser.") ||
+ event.type.startsWith("observation.")
+ )
+ channels.push("web", "topology")
+ return [...new Set(channels)]
+}
+
+export const activityRefreshChannels = (event: Activity): WorkbenchChannel[] =>
+ event.type === "session.idle" ? ["mission", "topology", "memory", "mcp", "bolt", "vulns", "web"] : []
diff --git a/packages/app/src/pages/session/memory-panel.tsx b/packages/app/src/pages/session/memory-panel.tsx
new file mode 100644
index 0000000000..a2165320bd
--- /dev/null
+++ b/packages/app/src/pages/session/memory-panel.tsx
@@ -0,0 +1,265 @@
+import { For, Show, createEffect, createSignal, on, onCleanup } from "solid-js"
+import { createStore, reconcile } from "solid-js/store"
+import { useParams } from "@solidjs/router"
+import type { MemoryListResponse } from "@cyberstrike-io/sdk/v2/client"
+import { Icon } from "@cyberstrike-io/ui/icon"
+import { useSDK } from "@/context/sdk"
+import { useWorkbench } from "@/context/workbench"
+
+type Kind = MemoryListResponse[number]["kind"]
+
+const kinds: Array<{ id: Kind; label: string }> = [
+ { id: "working", label: "Working" },
+ { id: "episodic", label: "Episodic" },
+ { id: "semantic", label: "Semantic" },
+ { id: "procedural", label: "Procedural" },
+]
+
+const trust = (value: MemoryListResponse[number]["trust"]) => {
+ if (value === "human") return "bg-surface-success-base text-text-success-base"
+ if (value === "tool") return "bg-surface-info-base text-text-info-base"
+ if (value === "untrusted") return "bg-surface-critical-base text-text-critical-base"
+ return "bg-surface-base text-text-weak"
+}
+
+export function MemoryPanel() {
+ const params = useParams()
+ const sdk = useSDK()
+ const workbench = useWorkbench()
+ const [items, setItems] = createStore([])
+ const [query, setQuery] = createSignal("")
+ const [kind, setKind] = createSignal("all")
+ const [error, setError] = createSignal("")
+ const [form, setForm] = createStore({
+ open: false,
+ project: false,
+ kind: "episodic" as Kind,
+ title: "",
+ content: "",
+ saving: false,
+ })
+
+ const load = async () => {
+ const sessionID = params.id
+ const filter = kind()
+ try {
+ const response = query().trim()
+ ? await sdk.client.memory.search({
+ query: query().trim(),
+ sessionID,
+ kind: filter === "all" ? undefined : filter,
+ limit: 100,
+ })
+ : await sdk.client.memory.list({
+ sessionID,
+ kind: filter === "all" ? undefined : filter,
+ limit: 200,
+ })
+ setItems(reconcile(response.data ?? []))
+ setError("")
+ } catch (cause) {
+ setError(cause instanceof Error ? cause.message : String(cause))
+ }
+ }
+
+ createEffect(() => {
+ params.id
+ kind()
+ const search = query()
+ const timer = setTimeout(load, search ? 250 : 0)
+ onCleanup(() => clearTimeout(timer))
+ })
+
+ createEffect(on(() => workbench.revision("memory"), () => void load(), { defer: true }))
+
+ const add = async () => {
+ const title = form.title.trim()
+ const content = form.content.trim()
+ if (!title || !content || form.saving) return
+ setForm("saving", true)
+ try {
+ const response = await sdk.client.memory.create({
+ sessionID: form.project ? undefined : params.id,
+ kind: form.kind,
+ title,
+ content,
+ confidence: 1,
+ tags: ["human-confirmed"],
+ })
+ if (response.data) setItems((current) => [response.data!, ...current])
+ setForm({
+ open: false,
+ project: false,
+ kind: "episodic",
+ title: "",
+ content: "",
+ saving: false,
+ })
+ setError("")
+ } catch (cause) {
+ setForm("saving", false)
+ setError(cause instanceof Error ? cause.message : String(cause))
+ }
+ }
+
+ const invalidate = async (id: string) => {
+ try {
+ await sdk.client.memory.invalidate({ entryID: id })
+ setItems(reconcile(items.filter((item) => item.id !== id)))
+ } catch (cause) {
+ setError(cause instanceof Error ? cause.message : String(cause))
+ }
+ }
+
+ return (
+
+
+
Persistent memory
+
+ 0}>
+
+ Live · {new Date(workbench.last("memory")).toLocaleTimeString()}
+
+
+
+
+
+
+
+
+ {(item) => (
+
+ )}
+
+
+
+ setQuery(event.currentTarget.value)}
+ />
+
+
+