fix: unblock web build and enforce web-ui CI checks

Author: LIU9293

.github/workflows/ci.yml

@@ -31,3 +31,6 @@ jobs:
 
       - name: Agent fast tests
         run: bun test packages/agents/test/cli-command.test.ts packages/agents/test/agent-registry.test.ts
+
+      - name: Build web UI
+        run: bun run build:web

.github/workflows/release.yml

@@ -35,6 +35,9 @@ jobs:
       - name: Install dependencies
         run: bun install
 
+      - name: Install web-ui deps
+        run: bun install --cwd packages/web-ui
+
       - name: Run core tests
         run: bun test packages/core/test
 

packages/config/local/ode.ts

@@ -1,9 +1,16 @@
-import { existsSync, mkdirSync, readFileSync, writeFileSync } from "fs";
-import { homedir } from "os";
-import { join } from "path";
+import * as fs from "fs";
+import * as os from "os";
+import * as path from "path";
 import { z } from "zod";
 import { normalizeCwd } from "../paths";
 
+const existsSync = fs.existsSync;
+const mkdirSync = fs.mkdirSync;
+const readFileSync = fs.readFileSync;
+const writeFileSync = fs.writeFileSync;
+const join = typeof path.join === "function" ? path.join : (...parts: string[]) => parts.join("/");
+const homedir = typeof os.homedir === "function" ? os.homedir : () => "";
+
 const XDG_CONFIG_HOME = join(homedir(), ".config");
 const ODE_CONFIG_DIR = join(XDG_CONFIG_HOME, "ode");
 export const ODE_CONFIG_FILE = join(ODE_CONFIG_DIR, "ode.json");

packages/config/local/sessions.ts

@@ -1,8 +1,17 @@
-import { readFileSync, writeFileSync, existsSync, mkdirSync, readdirSync, unlinkSync } from "fs";
-import { join } from "path";
-import { homedir } from "os";
+import * as fs from "fs";
+import * as path from "path";
+import * as os from "os";
 import { log } from "@/utils";
 
+const readFileSync = fs.readFileSync;
+const writeFileSync = fs.writeFileSync;
+const existsSync = fs.existsSync;
+const mkdirSync = fs.mkdirSync;
+const readdirSync = fs.readdirSync;
+const unlinkSync = fs.unlinkSync;
+const join = typeof path.join === "function" ? path.join : (...parts: string[]) => parts.join("/");
+const homedir = typeof os.homedir === "function" ? os.homedir : () => "";
+
 const ODE_CONFIG_DIR = join(homedir(), ".config", "ode");
 const SESSIONS_DIR = join(ODE_CONFIG_DIR, "sessions");
 

packages/config/local/settings.ts

@@ -1,11 +1,18 @@
-import { readFileSync, writeFileSync, existsSync, mkdirSync } from "fs";
-import { join } from "path";
-import { homedir } from "os";
+import * as fs from "fs";
+import * as path from "path";
+import * as os from "os";
 import {
   setChannelCwd as setChannelCwdInConfig,
 } from "./ode";
 import { loadSession } from "./sessions";
 
+const readFileSync = fs.readFileSync;
+const writeFileSync = fs.writeFileSync;
+const existsSync = fs.existsSync;
+const mkdirSync = fs.mkdirSync;
+const join = typeof path.join === "function" ? path.join : (...parts: string[]) => parts.join("/");
+const homedir = typeof os.homedir === "function" ? os.homedir : () => "";
+
 const ODE_CONFIG_DIR = join(homedir(), ".config", "ode");
 const SETTINGS_FILE = join(ODE_CONFIG_DIR, "settings.json");
 const AGENTS_DIR = join(ODE_CONFIG_DIR, "agents");

packages/config/paths.ts

@@ -1,5 +1,3 @@
-import { join, resolve } from "path";
-
 const isNodeRuntime =
   typeof process !== "undefined" &&
   typeof process.versions === "object" &&
@@ -11,11 +9,53 @@ const homeDir = isNodeRuntime
 
 const cwd = isNodeRuntime && typeof process.cwd === "function" ? process.cwd() : "/";
 
+const WINDOWS_DRIVE_PATH = /^[A-Za-z]:[\\/]/;
+
+function isAbsolutePath(input: string): boolean {
+  return input.startsWith("/") || input.startsWith("\\") || WINDOWS_DRIVE_PATH.test(input);
+}
+
+function normalizePath(input: string): string {
+  if (!input) return "/";
+
+  const normalized = input.replace(/\\/g, "/");
+  const hasDrivePrefix = WINDOWS_DRIVE_PATH.test(normalized);
+  const drivePrefix = hasDrivePrefix ? normalized.slice(0, 2) : "";
+  const withoutDrive = hasDrivePrefix ? normalized.slice(2) : normalized;
+  const isAbsolute = withoutDrive.startsWith("/");
+  const segments = withoutDrive.split("/");
+  const stack: string[] = [];
+
+  for (const segment of segments) {
+    if (!segment || segment === ".") continue;
+    if (segment === "..") {
+      if (stack.length > 0) {
+        stack.pop();
+      }
+      continue;
+    }
+    stack.push(segment);
+  }
+
+  const body = stack.join("/");
+  const prefix = `${drivePrefix}${isAbsolute ? "/" : ""}`;
+  const output = `${prefix}${body}`;
+
+  if (output) return output;
+  if (drivePrefix) return `${drivePrefix}/`;
+  return isAbsolute ? "/" : ".";
+}
+
+function resolvePath(basePath: string, input: string): string {
+  if (isAbsolutePath(input)) return normalizePath(input);
+  return normalizePath(`${basePath.replace(/\\/g, "/")}/${input}`);
+}
+
 export function normalizeCwd(input: string): string {
   if (!input) return cwd;
   if (input === "~") return homeDir || cwd;
   if (input.startsWith("~/")) {
-    return resolve(join(homeDir || cwd, input.slice(2)));
+    return resolvePath(homeDir || cwd, input.slice(2));
   }
-  return resolve(input);
+  return resolvePath(cwd, input);
 }

packages/core/runtime/event-stream.ts

@@ -6,6 +6,7 @@ import {
   type TrackedTodo,
   type TrackedTool,
 } from "@/config/local/sessions";
+import { resolveMessageFrequency } from "@/config/message-frequency";
 import { storeSessionEvent } from "@/config/local/redis";
 import { CoreStateMachine } from "@/core/state-machine";
 import type { AgentAdapter, IMAdapter } from "@/core/types";
@@ -163,7 +164,12 @@ export async function startEventStreamWatcher(
         await deps.im.updateMessage(
           request.channelId,
           request.statusMessageTs,
-          buildLiveStatusMessage(request, workingPath, liveParsedState.get(messageKey)),
+          buildLiveStatusMessage(
+            request,
+            workingPath,
+            liveParsedState.get(messageKey),
+            resolveMessageFrequency()
+          ),
           false
         );
         setPendingQuestion(request.channelId, request.threadId, {

packages/core/runtime/open-request.ts

@@ -1,4 +1,5 @@
 import { storeSessionMeta } from "@/config/local/redis";
+import { resolveMessageFrequency } from "@/config/message-frequency";
 import {
   completeActiveRequest,
   createActiveRequest,
@@ -114,7 +115,8 @@ export async function runOpenRequest(params: {
       const statusText = buildLiveStatusMessage(
         request,
         cwd,
-        liveParsedState.get(getStatusMessageKey(request))
+        liveParsedState.get(getStatusMessageKey(request)),
+        resolveMessageFrequency()
       );
       if (!request.statusFrozen) {
         await deps.im.updateMessage(context.channelId, statusTs, statusText, false);

packages/core/runtime/selection-reply.ts

@@ -7,6 +7,7 @@ import {
   markMessageProcessed,
   saveSession,
 } from "@/config/local/sessions";
+import { resolveMessageFrequency } from "@/config/message-frequency";
 import { runTrackedRequest } from "@/core/runtime/request-runner";
 import { CoreStateMachine } from "@/core/state-machine";
 import type { AgentAdapter, IMAdapter } from "@/core/types";
@@ -115,7 +116,8 @@ export async function handleSelectionReply(params: HandleSelectionReplyParams):
       const statusText = buildLiveStatusMessage(
         request,
         cwd,
-        state.liveParsedState.get(getStatusMessageKey(request))
+        state.liveParsedState.get(getStatusMessageKey(request)),
+        resolveMessageFrequency()
       );
       await deps.im.updateMessage(channelId, statusTs, statusText, false);
     },

packages/utils/status.ts

@@ -1,11 +1,23 @@
 import {
-  resolveMessageFrequency,
   TOOL_DISPLAY_CONFIG,
   type MessageFrequency,
-} from "@/config";
-import type { ActiveRequest, TrackedTodo } from "@/config/local/sessions";
+} from "@/config/web";
 import type { SessionMessageState } from "./session-inspector";
 
+export type StatusRequest = {
+  channelId: string;
+  threadId: string;
+  statusMessageTs: string;
+  startedAt: number;
+  currentText: string;
+  statusFrozen?: boolean;
+};
+
+type StatusTodo = {
+  content: string;
+  status: string;
+};
+
 const PLAN_TODO_LIMIT = 15;
 
 export function formatElapsedTime(startedAt: number): string {
@@ -40,7 +52,7 @@ export function getTodoIcon(status: string): string {
   }
 }
 
-export function getStatusMessageKey(request: ActiveRequest): string {
+export function getStatusMessageKey(request: StatusRequest): string {
   return `${request.channelId}:${request.threadId}:${request.statusMessageTs}`;
 }
 
@@ -74,7 +86,7 @@ export function trimToolPath(label: string, workingPath: string): string {
   return trimmed;
 }
 
-function formatTodoLines(todos: TrackedTodo[], limit = PLAN_TODO_LIMIT): string[] {
+function formatTodoLines(todos: StatusTodo[], limit = PLAN_TODO_LIMIT): string[] {
   const lines: string[] = [];
   for (const todo of todos.slice(0, limit)) {
     const statusLabel = todo.status === "in_progress"
@@ -165,9 +177,10 @@ export function buildToolLines(
 }
 
 export function buildLiveStatusMessage(
-  request: ActiveRequest,
+  request: StatusRequest,
   workingPath: string,
-  state?: SessionMessageState
+  state?: SessionMessageState,
+  frequency: MessageFrequency = "medium"
 ): string {
   if (!state) {
     if (request.statusFrozen && request.currentText) {
@@ -194,12 +207,12 @@ export function buildLiveStatusMessage(
   if (state.todos.length > 0) {
     const todos = state.todos.map((todo) => ({
       content: todo.content,
-      status: todo.status as TrackedTodo["status"],
+      status: todo.status,
     }));
     lines.push("", "*Tasks*", ...formatTodoLines(todos));
   }
 
-  const toolLines = buildToolLines(state, workingPath, resolveMessageFrequency());
+  const toolLines = buildToolLines(state, workingPath, frequency);
   if (toolLines.length > 0) {
     lines.push("");
     lines.push(...toolLines);