Refactor app flows and update UI components across core modules

Author: hereww

assets/inject/renderer-inject.js

@@ -1580,11 +1580,31 @@
   }
 
   async function setBackendSetting(key, value) {
+    const previousSettings = codexPlusBackendSettings;
     codexPlusBackendSettings = { ...codexPlusBackendSettings, [key]: value };
     refreshCodexPlusBackendToggles();
     try {
-      const settings = await postJson("/settings/set", { [key]: value });
+      const settings = await postJson("/settings/set", { [key]: value }, { timeoutMs: 15000 });
+      if (!settings || settings.status !== "ok") {
+        codexPlusBackendSettings = previousSettings;
+        sendCodexPlusDiagnostic("backend_setting_save_failed", {
+          key,
+          status: settings?.status || "failed",
+          message: settings?.message || "设置保存失败",
+          timeout: !!settings?.timeout,
+        });
+        return false;
+      }
       codexPlusBackendSettings = { ...codexPlusBackendSettings, ...settings };
+      return true;
+    } catch (error) {
+      codexPlusBackendSettings = previousSettings;
+      sendCodexPlusDiagnostic("backend_setting_save_failed", {
+        key,
+        status: "failed",
+        message: error?.message || String(error),
+      });
+      return false;
     } finally {
       refreshCodexPlusBackendToggles();
     }

bridge.go

@@ -257,7 +257,7 @@ func (r *launcherRuntime) setBridgeSettings(payload map[string]any) map[string]a
 	if err := saveSettings(settings); err != nil {
 		return map[string]any{"status": "failed", "message": err.Error()}
 	}
-	r.settings = settings
+	r.setRuntimeSettings(settings)
 	result := r.bridgeSettingsValue(settings)
 	result["status"] = "ok"
 	return result
@@ -519,7 +519,7 @@ func (r *launcherRuntime) installBridge(ctx context.Context, websocketURL string
 		_ = conn.Close()
 		return err
 	}
-	scripts := []string{injectionScript(helperPort, r.settings)}
+	scripts := []string{injectionScript(helperPort, r.runtimeSettingsSnapshot())}
 	if bundle := enabledUserScriptBundle(); strings.TrimSpace(bundle) != "" {
 		scripts = append(scripts, bundle)
 	}

conversation_history_repair.go

@@ -720,29 +720,9 @@ func createConversationHistoryRepairBackupDir(home string) (string, error) {
 }
 
 func acquireConversationHistoryRepairLock(home string) (func(), error) {
-	lockDir := filepath.Join(home, "tmp", "provider-sync.lock")
-	if err := os.MkdirAll(filepath.Dir(lockDir), 0o755); err != nil {
-		return nil, fmt.Errorf("创建历史维护锁目录失败：%w", err)
-	}
-	acquired := false
-	if err := os.Mkdir(lockDir, 0o755); err == nil {
-		acquired = true
-	} else if stale, reason := providerSyncLockStale(lockDir, time.Now()); stale {
-		appendDiagnosticLog("conversation_history_repair.stale_lock_removed", map[string]any{"lock": lockDir, "reason": reason})
-		if removeErr := os.RemoveAll(lockDir); removeErr == nil {
-			if retryErr := os.Mkdir(lockDir, 0o755); retryErr == nil {
-				acquired = true
-			}
-		}
-	}
-	if !acquired {
-		return nil, errors.New("另一个历史会话维护任务正在运行，请稍后重试")
-	}
-	release := func() { _ = os.RemoveAll(lockDir) }
-	owner := []byte(fmt.Sprintf(`{"pid":%d,"startedAt":%d,"operation":"conversation-history-repair"}`, os.Getpid(), time.Now().Unix()))
-	if err := os.WriteFile(filepath.Join(lockDir, "owner.json"), owner, 0o644); err != nil {
-		release()
-		return nil, fmt.Errorf("写入历史维护锁失败：%w", err)
+	release, err := acquireProviderSyncLock(home, "conversation-history-repair")
+	if err != nil {
+		return nil, fmt.Errorf("另一个历史会话维护任务正在运行，请稍后重试：%w", err)
 	}
 	return release, nil
 }