feat(filestore): 优化文件存储缓存刷新机制并改进应用关闭流程

- 添加了 FlushNotifyCh 通道用于通知刷新操作
- 实现了防抖动和定期刷新机制，提高性能
- 添加了 ErrFlushInProgress 错误类型处理并发控制
- 修改了 WriteMeta、WriteFile、AppendData 等方法返回错误并触发刷新通知
- 重构了前端代码中的 Monaco 编辑器为懒加载模式
- 优化了应用关闭时的 WaveSrv 进程管理
- 添加了未处理 Promise 拒绝的错误处理
- 实现了优雅关闭时的文件存储刷新逻辑
- 修复了 Windows 平台进程关闭问题
- 添加了 WCloud 端点配置错误时的日志记录和自动禁用功能

Author: Cure217

.gitignore

@@ -44,3 +44,4 @@ docsite/
 docs/superpowers
 .claude
 .idea/
+/make/

assets/appicon-windows.ico

@@ -5,6 +5,7 @@ package main
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"log"
 	"os"
@@ -67,6 +68,22 @@ const DiagnosticTick = 10 * time.Minute
 
 var shutdownOnce sync.Once
 
+func flushFilestoreOnShutdown(ctx context.Context) {
+	stats, err := filestore.WFS.FlushCache(ctx)
+	for errors.Is(err, filestore.ErrFlushInProgress) && ctx.Err() == nil {
+		log.Printf("filestore flush already in progress during shutdown, waiting for it to finish\n")
+		time.Sleep(100 * time.Millisecond)
+		stats, err = filestore.WFS.FlushCache(ctx)
+	}
+	if err != nil {
+		log.Printf("error flushing filestore during shutdown: %v\n", err)
+		return
+	}
+	if stats.NumDirtyEntries > 0 {
+		log.Printf("filestore shutdown flush: %d/%d entries flushed\n", stats.NumCommitted, stats.NumDirtyEntries)
+	}
+}
+
 func init() {
 	envFilePath := os.Getenv("WAVETERM_ENVFILE")
 	if envFilePath != "" {
@@ -85,7 +102,7 @@ func doShutdown(reason string) {
 		sendTelemetryWrapper()
 		// TODO deal with flush in progress
 		clearTempFiles()
-		filestore.WFS.FlushCache(ctx)
+		flushFilestoreOnShutdown(ctx)
 		watcher := wconfig.GetWatcher()
 		if watcher != nil {
 			watcher.Close()

cmd/server/main-server.go

@@ -10,6 +10,7 @@ const windowsTargets = windowsShouldBuildInstallers ? ["nsis", "msi", "zip"] : [
 const localWindowsElectronDist = path.resolve(__dirname, "node_modules", "electron", "dist");
 const useLocalWindowsElectronDist =
     process.platform === "win32" && fs.existsSync(path.join(localWindowsElectronDist, "electron.exe"));
+const windowsIconPath = path.resolve(__dirname, "assets", "appicon-windows.ico");
 
 /**
  * @type {import('electron-builder').Configuration}
@@ -104,6 +105,7 @@ const config = {
     },
     win: {
         target: windowsTargets,
+        icon: windowsIconPath,
         signAndEditExecutable: windowsShouldEditExecutable,
         signtoolOptions: windowsShouldSign && {
             signingHashAlgorithms: ["sha256"],
@@ -112,6 +114,11 @@ const config = {
             certificateSha1: process.env.SM_CODE_SIGNING_CERT_SHA1_HASH,
         },
     },
+    nsis: {
+        installerIcon: windowsIconPath,
+        uninstallerIcon: windowsIconPath,
+        installerHeaderIcon: windowsIconPath,
+    },
     appImage: {
         license: "LICENSE",
     },

electron-builder.config.cjs

@@ -76,11 +76,11 @@ export function runWaveSrv(handleWSEvent: (evtMsg: WSEventType) => void): Promis
         cwd: getWaveSrvCwd(),
         env: envCopy,
     });
-    proc.on("exit", (e) => {
+    proc.on("exit", (code, signal) => {
         if (updater?.status == "installing") {
             return;
         }
-        console.log("wavesrv exited, shutting down");
+        console.log("wavesrv exited, shutting down", "code=", code, "signal=", signal);
         setForceQuit(true);
         isWaveSrvDead = true;
         electron.app.quit();
@@ -107,9 +107,7 @@ export function runWaveSrv(handleWSEvent: (evtMsg: WSEventType) => void): Promis
     });
     rlStderr.on("line", (line) => {
         if (line.includes("WAVESRV-ESTART")) {
-            const startParams = /ws:([a-z0-9.:]+) web:([a-z0-9.:]+) version:([a-z0-9.-]+) buildtime:(\d+)/gm.exec(
-                line
-            );
+            const startParams = /ws:([a-z0-9.:]+) web:([a-z0-9.:]+) version:([a-z0-9.-]+) buildtime:(\d+)/gm.exec(line);
             if (startParams == null) {
                 console.log("error parsing WAVESRV-ESTART line", line);
                 setUserConfirmedQuit(true);

emain/emain-wavesrv.ts

@@ -254,6 +254,23 @@ function hideWindowWithCatch(window: WaveBrowserWindow) {
     }
 }
 
+function requestWaveSrvShutdown() {
+    shutdownWshrpc();
+    const waveSrvProc = getWaveSrvProc();
+    if (waveSrvProc == null) {
+        return;
+    }
+    if (unamePlatform === "win32") {
+        try {
+            waveSrvProc.stdin.end();
+        } catch (e) {
+            console.log("error closing wavesrv stdin", e);
+        }
+        return;
+    }
+    waveSrvProc.kill("SIGINT");
+}
+
 electronApp.on("window-all-closed", () => {
     if (getGlobalIsRelaunching()) {
         return;
@@ -292,13 +309,7 @@ electronApp.on("before-quit", (e) => {
     }
     setGlobalIsQuitting(true);
     updater?.stop();
-    if (unamePlatform == "win32") {
-        // win32 doesn't have a SIGINT, so we just let electron die, which
-        // ends up killing wavesrv via closing it's stdin.
-        return;
-    }
-    getWaveSrvProc()?.kill("SIGINT");
-    shutdownWshrpc();
+    requestWaveSrvShutdown();
     if (getForceQuit()) {
         return;
     }
@@ -356,6 +367,12 @@ process.on("uncaughtException", (error) => {
     setUserConfirmedQuit(true);
     electronApp.quit();
 });
+process.on("unhandledRejection", (reason) => {
+    console.log("Unhandled Rejection:", reason);
+    if (reason instanceof Error) {
+        console.log("Stack Trace:", reason.stack);
+    }
+});
 
 let lastWaveWindowCount = 0;
 let lastIsBuilderWindowActive = false;

emain/emain.ts

@@ -1,13 +1,17 @@
 // Copyright 2025, Command Line Inc.
 // SPDX-License-Identifier: Apache-2.0
 
-import { MonacoCodeEditor } from "@/app/monaco/monaco-react";
 import { useOverrideConfigAtom } from "@/app/store/global";
 import { boundNumber } from "@/util/util";
 import type * as MonacoTypes from "monaco-editor";
-import * as MonacoModule from "monaco-editor";
 import React, { useMemo, useRef } from "react";
 
+const LazyMonacoCodeEditor = React.lazy(async () => {
+    const mod = await import("@/app/monaco/monaco-react");
+    return { default: mod.MonacoCodeEditor };
+});
+type MonacoModuleType = typeof import("monaco-editor");
+
 function defaultEditorOptions(): MonacoTypes.editor.IEditorOptions {
     const opts: MonacoTypes.editor.IEditorOptions = {
         scrollBeyondLastLine: false,
@@ -36,7 +40,7 @@ interface CodeEditorProps {
     language?: string;
     fileName?: string;
     onChange?: (text: string) => void;
-    onMount?: (monacoPtr: MonacoTypes.editor.IStandaloneCodeEditor, monaco: typeof MonacoModule) => () => void;
+    onMount?: (monacoPtr: MonacoTypes.editor.IStandaloneCodeEditor, monaco: MonacoModuleType) => () => void;
 }
 
 export function CodeEditor({ blockId, text, language, fileName, readonly, onChange, onMount }: CodeEditorProps) {
@@ -72,7 +76,7 @@ export function CodeEditor({ blockId, text, language, fileName, readonly, onChan
 
     function handleEditorOnMount(
         editor: MonacoTypes.editor.IStandaloneCodeEditor,
-        monaco: typeof MonacoModule
+        monaco: MonacoModuleType
     ): () => void {
         if (onMount) {
             const cleanup = onMount(editor, monaco);
@@ -95,15 +99,17 @@ export function CodeEditor({ blockId, text, language, fileName, readonly, onChan
     return (
         <div className="flex flex-col w-full h-full items-center justify-center">
             <div className="flex flex-col h-full w-full" ref={divRef}>
-                <MonacoCodeEditor
-                    readonly={readonly}
-                    text={text}
-                    options={editorOpts}
-                    onChange={handleEditorChange}
-                    onMount={handleEditorOnMount}
-                    path={editorPath}
-                    language={language}
-                />
+                <React.Suspense fallback={<div className="flex flex-col h-full w-full" />}>
+                    <LazyMonacoCodeEditor
+                        readonly={readonly}
+                        text={text}
+                        options={editorOpts}
+                        onChange={handleEditorChange}
+                        onMount={handleEditorOnMount}
+                        path={editorPath}
+                        language={language}
+                    />
+                </React.Suspense>
             </div>
         </div>
     );

frontend/app/view/codeeditor/codeeditor.tsx

@@ -1,11 +1,15 @@
 // Copyright 2025, Command Line Inc.
 // SPDX-License-Identifier: Apache-2.0
 
-import { MonacoDiffViewer } from "@/app/monaco/monaco-react";
 import { useOverrideConfigAtom } from "@/app/store/global";
 import { boundNumber } from "@/util/util";
 import type * as MonacoTypes from "monaco-editor";
-import { useMemo, useRef } from "react";
+import React, { useMemo, useRef } from "react";
+
+const LazyMonacoDiffViewer = React.lazy(async () => {
+    const mod = await import("@/app/monaco/monaco-react");
+    return { default: mod.MonacoDiffViewer };
+});
 
 interface DiffViewerProps {
     blockId: string;
@@ -62,13 +66,15 @@ export function DiffViewer({ blockId, original, modified, language, fileName }:
     return (
         <div className="flex flex-col w-full h-full overflow-hidden items-center justify-center">
             <div className="flex flex-col h-full w-full">
-                <MonacoDiffViewer
-                    path={editorPath}
-                    original={original}
-                    modified={modified}
-                    options={editorOpts}
-                    language={language}
-                />
+                <React.Suspense fallback={<div className="flex flex-col h-full w-full" />}>
+                    <LazyMonacoDiffViewer
+                        path={editorPath}
+                        original={original}
+                        modified={modified}
+                        options={editorOpts}
+                        language={language}
+                    />
+                </React.Suspense>
             </div>
         </div>
     );

frontend/app/view/codeeditor/diffviewer.tsx

@@ -2,7 +2,6 @@
 // SPDX-License-Identifier: Apache-2.0
 
 import { App } from "@/app/app";
-import { loadMonaco } from "@/app/monaco/monaco-env";
 import { loadBadges } from "@/app/store/badge";
 import { GlobalModel } from "@/app/store/global-model";
 import {
@@ -40,6 +39,7 @@ const platform = getApi().getPlatform();
 document.title = `Wave Terminal`;
 let savedInitOpts: WaveInitOpts = null;
 let tabTitleUnsub: (() => void) | null = null;
+let monacoLoadPromise: Promise<void> | null = null;
 
 (window as any).WOS = WOS;
 (window as any).globalStore = globalStore;
@@ -57,6 +57,27 @@ function updateZoomFactor(zoomFactor: number) {
     document.documentElement.style.setProperty("--zoomfactor-inv", String(1 / zoomFactor));
 }
 
+function ensureMonacoLoaded(): Promise<void> {
+    if (monacoLoadPromise == null) {
+        monacoLoadPromise = import("@/app/monaco/monaco-env").then(({ loadMonaco }) => {
+            loadMonaco();
+        });
+    }
+    return monacoLoadPromise;
+}
+
+function preloadMonaco() {
+    fireAndForget(async () => {
+        try {
+            await ensureMonacoLoaded();
+        } catch (e) {
+            const error = e instanceof Error ? e : new Error(String(e));
+            getApi().sendLog("Error preloading Monaco " + error.message + "\n" + error.stack);
+            console.error("Error preloading Monaco", e);
+        }
+    });
+}
+
 function formatWaveWindowTitle(tabName?: string | null) {
     const trimmedTabName = tabName?.trim();
     return trimmedTabName ? `Wave Terminal - ${trimmedTabName}` : "Wave Terminal";
@@ -182,11 +203,15 @@ async function initWave(initOpts: WaveInitOpts) {
     const globalWS = initWshrpc(makeTabRouteId(initOpts.tabId));
     (window as any).globalWS = globalWS;
     (window as any).TabRpcClient = TabRpcClient;
+    const startupConfigPromise = Promise.all([
+        RpcApi.GetFullConfigCommand(TabRpcClient),
+        RpcApi.GetWaveAIModeConfigCommand(TabRpcClient),
+    ]);
+    startupConfigPromise.catch(() => undefined);
 
     // ensures client/window/workspace are loaded into the cache before rendering
     try {
-        await loadConnStatus();
-        await loadBadges();
+        await Promise.all([loadConnStatus(), loadBadges()]);
         initGlobalWaveEventSubs(initOpts);
         subscribeToConnEvents();
         if (isMacOS()) {
@@ -212,11 +237,9 @@ async function initWave(initOpts: WaveInitOpts) {
     registerGlobalKeys();
     registerElectronReinjectKeyHandler();
     registerControlShiftStateUpdateHandler();
-    await loadMonaco();
-    const fullConfig = await RpcApi.GetFullConfigCommand(TabRpcClient);
+    const [fullConfig, waveaiModeConfig] = await startupConfigPromise;
     console.log("fullconfig", fullConfig);
     globalStore.set(atoms.fullConfigAtom, fullConfig);
-    const waveaiModeConfig = await RpcApi.GetWaveAIModeConfigCommand(TabRpcClient);
     globalStore.set(atoms.waveaiModeConfigAtom, waveaiModeConfig.configs);
     console.log("Wave First Render");
     let firstRenderResolveFn: () => void = null;
@@ -230,6 +253,7 @@ async function initWave(initOpts: WaveInitOpts) {
     await firstRenderPromise;
     console.log("Wave First Render Done");
     getApi().setWindowInitStatus("wave-ready");
+    preloadMonaco();
 }
 
 async function initBuilderWrap(initOpts: BuilderInitOpts) {
@@ -283,7 +307,7 @@ async function initBuilder(initOpts: BuilderInitOpts) {
 
     registerBuilderGlobalKeys();
     registerElectronReinjectKeyHandler();
-    await loadMonaco();
+    await ensureMonacoLoaded();
     const fullConfig = await RpcApi.GetFullConfigCommand(TabRpcClient);
     console.log("fullconfig", fullConfig);
     globalStore.set(atoms.fullConfigAtom, fullConfig);