mirror of
https://github.com/hicccc77/WeFlow.git
synced 2026-10-26 01:54:43 +08:00
720 lines
26 KiB
TypeScript
720 lines
26 KiB
TypeScript
import { BrowserWindow, desktopCapturer, ipcMain, screen } from "electron";
|
||
import { join } from "path";
|
||
import { ConfigService } from "../services/config";
|
||
|
||
// 通知交付分流：Windows 走特制液态玻璃通知窗口；
|
||
// Linux / macOS 走系统通知中心（systemNotificationService）
|
||
const isLinux = process.platform === "linux";
|
||
const isMac = process.platform === "darwin";
|
||
const usesSystemNotifications = isLinux || isMac;
|
||
|
||
// 原生液态玻璃（Windows 专用）：DXGI 零拷贝采集 + D3D11 玻璃管线 + DComp 直接上屏，
|
||
// 感知滞后中位 ~6ms（Chromium 流方案 ~77ms），渲染完全不经过 Electron 进程。
|
||
// 不可用（系统过旧 / 二进制缺失）时自动回退 Chromium 桌面流管线
|
||
type NativeCapturePolicy = "all" | "dda-only" | "none";
|
||
type NativeGlassModule = typeof import("@hicccc77/electron-liquid-glass") & {
|
||
setWindowCapturePolicy: (
|
||
windowOrHwnd: BrowserWindow | Buffer,
|
||
policy: NativeCapturePolicy,
|
||
) => boolean;
|
||
};
|
||
type NativePanelOptions = Parameters<NativeGlassModule["createPanel"]>[0] & {
|
||
capturePolicy: NativeCapturePolicy;
|
||
};
|
||
let nativeGlass: NativeGlassModule | null = null;
|
||
if (!usesSystemNotifications) {
|
||
try {
|
||
const mod: NativeGlassModule = require("@hicccc77/electron-liquid-glass");
|
||
// DDA-only 排除是可截图原生玻璃的必要能力。旧版模块没有该 API 时
|
||
// 直接走受 WDA 保护的 Chromium 回退，不能冒险让采集流拍到通知自身。
|
||
nativeGlass =
|
||
mod.isSupported() && typeof mod.setWindowCapturePolicy === "function"
|
||
? mod
|
||
: null;
|
||
} catch {
|
||
nativeGlass = null;
|
||
}
|
||
}
|
||
|
||
let systemNotificationService:
|
||
| typeof import("../services/systemNotificationService")
|
||
| null = null;
|
||
|
||
// 用于处理通知点击的回调函数（系统通知平台用于导航到会话）
|
||
let onNotificationNavigate: ((payload: unknown) => void) | null = null;
|
||
|
||
export function setNotificationNavigateHandler(
|
||
callback: (payload: unknown) => void,
|
||
) {
|
||
onNotificationNavigate = callback;
|
||
}
|
||
|
||
let notificationWindow: BrowserWindow | null = null;
|
||
let closeTimer: NodeJS.Timeout | null = null;
|
||
|
||
// 空闲销毁：隐藏的通知窗口（含渲染进程）常驻占用 ~120MB 工作集，
|
||
// 通知稀少时不值得养着。隐藏后闲置超时即销毁，下一条通知重新冷启动
|
||
const IDLE_DESTROY_DELAY_MS = 3 * 60 * 1000;
|
||
let idleDestroyTimer: NodeJS.Timeout | null = null;
|
||
|
||
function cancelIdleDestroy() {
|
||
if (idleDestroyTimer) {
|
||
clearTimeout(idleDestroyTimer);
|
||
idleDestroyTimer = null;
|
||
}
|
||
}
|
||
|
||
function scheduleIdleDestroy() {
|
||
cancelIdleDestroy();
|
||
idleDestroyTimer = setTimeout(() => {
|
||
idleDestroyTimer = null;
|
||
// 可见期间不销毁（cancel/schedule 时序兜底）
|
||
if (notificationWindow && !notificationWindow.isDestroyed() && notificationWindow.isVisible()) {
|
||
scheduleIdleDestroy();
|
||
return;
|
||
}
|
||
destroyNotificationWindow();
|
||
}, IDLE_DESTROY_DELAY_MS);
|
||
idleDestroyTimer.unref?.();
|
||
}
|
||
|
||
// 原生玻璃面板：与通知窗口一样常驻复用（创建后隐藏待命），
|
||
// 展示期跟随渲染层上报的卡片实测矩形（notification:glassRect）
|
||
let glassPanel: import("@hicccc77/electron-liquid-glass").GlassPanel | null = null;
|
||
// 面板创建时的 dpr：原生端几何常量按 dpr 换算且仅在创建时设定，
|
||
// 显示器缩放变化后必须重建面板，否则复用旧 dpr 会算错折射几何
|
||
let glassPanelDpr = 0;
|
||
|
||
function destroyGlassPanel() {
|
||
if (glassPanel) {
|
||
try {
|
||
glassPanel.destroy();
|
||
} catch {
|
||
/* 面板已随会话销毁 */
|
||
}
|
||
glassPanel = null;
|
||
}
|
||
}
|
||
|
||
// 视觉参数换算（缺省值与渲染层 GLASS_PARAMS 一致，CSS 值 → 物理像素/比例）
|
||
function toGlassParams(payload: Record<string, number | undefined>, scale: number) {
|
||
return {
|
||
cornerRadius: (payload.cornerRadius ?? 16) * scale,
|
||
blurSigma: (payload.blurSigma ?? 2) * scale,
|
||
displacementScale: payload.displacementScale ?? 70,
|
||
aberrationIntensity: payload.aberrationIntensity ?? 1,
|
||
saturation: (payload.saturation ?? 140) / 100,
|
||
};
|
||
}
|
||
|
||
// 创建或复用玻璃面板并同步全部状态（不负责 show/hide）。
|
||
// 空闲预热与 glassRect 上报共用此路径：预热时占位几何 + 空亮度带，
|
||
// 首次上报会以实测值幂等覆盖
|
||
function ensureGlassPanel(
|
||
bounds: { x: number; y: number; width: number; height: number },
|
||
params: ReturnType<typeof toGlassParams>,
|
||
scale: number,
|
||
bands: Array<{ id: number; x: number; y: number; width: number; height: number }>,
|
||
) {
|
||
if (!nativeGlass || !notificationWindow || notificationWindow.isDestroyed()) {
|
||
return null;
|
||
}
|
||
if (glassPanel && glassPanelDpr !== scale) destroyGlassPanel();
|
||
if (!glassPanel) {
|
||
const panelOptions: NativePanelOptions = {
|
||
...bounds,
|
||
...params,
|
||
dpr: scale,
|
||
// 仅从本模块使用的 Desktop Duplication 输入中排除；WGC 等外部
|
||
// 捕获仍能看到原生 DComp 玻璃面板。
|
||
capturePolicy: "dda-only" as const,
|
||
anchorWindow: notificationWindow,
|
||
lumaBands: bands,
|
||
onLuma: (bandStats) => {
|
||
if (notificationWindow && !notificationWindow.isDestroyed()) {
|
||
notificationWindow.webContents.send("notification:luma", bandStats);
|
||
}
|
||
},
|
||
};
|
||
glassPanel = nativeGlass.createPanel(panelOptions);
|
||
glassPanelDpr = scale;
|
||
} else {
|
||
glassPanel.setBounds(bounds);
|
||
glassPanel.setParams(params);
|
||
glassPanel.setLumaBands(bands);
|
||
glassPanel.anchor(notificationWindow);
|
||
}
|
||
return glassPanel;
|
||
}
|
||
|
||
// —— Chromium 桌面流回退管线（仅原生玻璃不可用时启用：系统过旧 / 二进制缺失）——
|
||
// 透明窗口内 backdrop-filter 采样不到桌面像素（Chromium 只能采样页面内容），
|
||
// 回退路径下折射源由渲染层用 getUserMedia 开启的实时桌面视频流提供。
|
||
// 主进程只负责预热并缓存屏幕采集源 ID：desktopCapturer.getSources 会同步
|
||
// 初始化 DirectX 采集管线（实测阻塞主线程 300ms+，不要缩略图也一样），
|
||
// 绝不能出现在通知弹出路径上，否则每条通知都会让整个应用卡一下。
|
||
// 回退模式下通知窗口使用 content protection，不会被拍进视频流造成折射回环
|
||
let cachedSourceId: string | null = null;
|
||
let sourceIdRefreshing: Promise<void> | null = null;
|
||
|
||
function refreshDesktopSourceId(): Promise<void> {
|
||
if (sourceIdRefreshing) return sourceIdRefreshing;
|
||
sourceIdRefreshing = (async () => {
|
||
try {
|
||
const display = screen.getPrimaryDisplay();
|
||
const sources = await desktopCapturer.getSources({
|
||
types: ["screen"],
|
||
thumbnailSize: { width: 0, height: 0 },
|
||
});
|
||
const source =
|
||
sources.find((s) => s.display_id === String(display.id)) ?? sources[0];
|
||
cachedSourceId = source?.id ?? null;
|
||
} catch (error) {
|
||
console.warn(
|
||
"[NotificationWindow] Failed to refresh desktop source id:",
|
||
error,
|
||
);
|
||
} finally {
|
||
sourceIdRefreshing = null;
|
||
}
|
||
})();
|
||
return sourceIdRefreshing;
|
||
}
|
||
|
||
export function destroyNotificationWindow() {
|
||
cancelIdleDestroy();
|
||
if (closeTimer) {
|
||
clearTimeout(closeTimer);
|
||
closeTimer = null;
|
||
}
|
||
activeNotificationData = null;
|
||
pendingNotificationData = null;
|
||
lastReadyRendererSessionId = null;
|
||
destroyGlassPanel();
|
||
|
||
// Linux/macOS：关闭系统通知服务并清理缓存（fire-and-forget，不阻塞退出）
|
||
if (usesSystemNotifications && systemNotificationService) {
|
||
systemNotificationService.shutdownSystemNotificationService().catch((error) => {
|
||
console.warn("[NotificationWindow] Failed to shutdown system notification service:", error);
|
||
});
|
||
systemNotificationService = null;
|
||
}
|
||
|
||
if (!notificationWindow || notificationWindow.isDestroyed()) {
|
||
notificationWindow = null;
|
||
return;
|
||
}
|
||
|
||
const win = notificationWindow;
|
||
notificationWindow = null;
|
||
|
||
try {
|
||
win.destroy();
|
||
} catch (error) {
|
||
console.warn("[NotificationWindow] Failed to destroy window:", error);
|
||
}
|
||
}
|
||
|
||
// 窗口通过 min/max 锁定尺寸，程序化调整尺寸前需要同步放宽限制。
|
||
// 尺寸未变化时直接跳过：可见状态下重复 setSize 会让 DWM
|
||
// 短暂拉伸旧帧缓冲，在通知周围闪出一圈"幽灵轮廓"
|
||
function applyWindowSize(win: BrowserWindow, width: number, height: number) {
|
||
const [currentWidth, currentHeight] = win.getSize();
|
||
if (currentWidth === width && currentHeight === height) return;
|
||
win.setMinimumSize(width, height);
|
||
win.setMaximumSize(width, height);
|
||
win.setSize(width, height);
|
||
}
|
||
|
||
export function createNotificationWindow() {
|
||
if (notificationWindow && !notificationWindow.isDestroyed()) {
|
||
return notificationWindow;
|
||
}
|
||
|
||
const isDev = !!process.env.VITE_DEV_SERVER_URL;
|
||
const iconPath = isDev
|
||
? join(__dirname, "../../public/icon.ico")
|
||
: join(process.resourcesPath, "icon.ico");
|
||
|
||
console.log("[NotificationWindow] Creating window...");
|
||
const width = 344;
|
||
const height = 114;
|
||
|
||
// Update default creation size
|
||
notificationWindow = new BrowserWindow({
|
||
width: width,
|
||
height: height,
|
||
type: "toolbar", // 辅助置顶（仅 Windows 走此窗口）
|
||
frame: false,
|
||
// 无边框透明窗口：不会出现 DWM 材质窗口的系统描边，
|
||
// 玻璃底下的"桌面"由原生面板或渲染层的实时桌面视频流提供
|
||
transparent: true,
|
||
hasShadow: false, // 卡片投影由 CSS 提供
|
||
resizable: false,
|
||
show: false,
|
||
alwaysOnTop: true,
|
||
skipTaskbar: true,
|
||
focusable: false, // 不抢占焦点
|
||
icon: iconPath,
|
||
webPreferences: {
|
||
preload: join(__dirname, "preload.js"), // FIX: Use correct relative path (same dir in dist)
|
||
contextIsolation: true,
|
||
nodeIntegration: false,
|
||
// devTools: true // Enable DevTools
|
||
},
|
||
});
|
||
|
||
if (nativeGlass) {
|
||
// 原生玻璃内部只使用 DXGI Desktop Duplication。仅从 DDA 排除宿主
|
||
// HWND 可阻断自采集回环，同时保留 WGC 等外部截图/录屏可见性。
|
||
let capturePolicyApplied = false;
|
||
try {
|
||
capturePolicyApplied = nativeGlass.setWindowCapturePolicy(
|
||
notificationWindow,
|
||
"dda-only",
|
||
);
|
||
} catch (error) {
|
||
console.warn(
|
||
"[NotificationWindow] Failed to apply DDA-only capture policy:",
|
||
error,
|
||
);
|
||
}
|
||
|
||
if (!capturePolicyApplied) {
|
||
// 策略不可用时必须整体降级：Chromium 回退的具体采集后端不固定，
|
||
// 继续使用 DDA-only 会在 WGC/GDI 路径重新拍到自身形成反馈。
|
||
nativeGlass = null;
|
||
notificationWindow.setContentProtection(true);
|
||
}
|
||
} else {
|
||
// Chromium 桌面流回退仍需全捕获保护，避免视频流递归采到通知窗口。
|
||
notificationWindow.setContentProtection(true);
|
||
}
|
||
|
||
applyWindowSize(notificationWindow, width, height);
|
||
|
||
// notificationWindow.webContents.openDevTools({ mode: 'detach' }) // DEBUG: Force Open DevTools
|
||
notificationWindow.setIgnoreMouseEvents(true, { forward: true }); // 初始点击穿透
|
||
|
||
// 处理鼠标事件 (如果需要从渲染进程转发，但目前特定区域处理?)
|
||
// 实际上，我们希望窗口可点击。
|
||
// 我们将在显示时将忽略鼠标事件设为 false。
|
||
|
||
const loadUrl = isDev
|
||
? `${process.env.VITE_DEV_SERVER_URL}#/notification-window`
|
||
: `file://${join(__dirname, "../dist/index.html")}#/notification-window`;
|
||
|
||
console.log("[NotificationWindow] Loading URL:", loadUrl);
|
||
notificationWindow.loadURL(loadUrl);
|
||
|
||
// Chromium 会按 file:// 域持久化页面缩放（主窗口与通知窗口同域）：
|
||
// 任何来源的缩放残留都会让通知按错误的逻辑尺寸排版，这里强制钉回 1
|
||
notificationWindow.webContents.on("did-finish-load", () => {
|
||
notificationWindow?.webContents.setZoomFactor(1);
|
||
});
|
||
|
||
notificationWindow.on("closed", () => {
|
||
notificationWindow = null;
|
||
});
|
||
|
||
return notificationWindow;
|
||
}
|
||
|
||
export async function showNotification(data: any) {
|
||
// 先检查配置
|
||
const config = ConfigService.getInstance();
|
||
const sessionId = typeof data.sessionId === "string" ? data.sessionId : "";
|
||
const channel = typeof data.channel === "string" ? data.channel : "";
|
||
const isAiInsightNotification = channel === "ai-insight";
|
||
|
||
if (isAiInsightNotification) {
|
||
const enabled = await config.get("aiInsightNotificationEnabled");
|
||
if (enabled === false) return; // 默认为 true
|
||
} else {
|
||
const enabled = await config.get("notificationEnabled");
|
||
if (enabled === false) return; // 默认为 true
|
||
|
||
// 检查会话过滤
|
||
const filterMode = config.get("notificationFilterMode") || "all";
|
||
const filterList = config.get("notificationFilterList") || [];
|
||
// 系统通知（如 "WeFlow 准备就绪"）不是聊天消息，不应受会话白/黑名单影响
|
||
const isSystemNotification = sessionId.startsWith("weflow-");
|
||
|
||
if (!isSystemNotification && filterMode !== "all") {
|
||
const isInList = sessionId !== "" && filterList.includes(sessionId);
|
||
if (filterMode === "whitelist" && !isInList) {
|
||
// 白名单模式：不在列表中则不显示（空列表视为全部拦截）
|
||
return;
|
||
}
|
||
if (filterMode === "blacklist" && isInList) {
|
||
// 黑名单模式：在列表中则不显示
|
||
return;
|
||
}
|
||
}
|
||
}
|
||
|
||
// Linux / macOS 走系统通知中心，仅 Windows 使用特制液态玻璃窗口
|
||
if (usesSystemNotifications) {
|
||
await showViaSystemNotification(data);
|
||
return;
|
||
}
|
||
|
||
cancelIdleDestroy();
|
||
let win = notificationWindow;
|
||
if (!win || win.isDestroyed()) {
|
||
win = createNotificationWindow();
|
||
}
|
||
|
||
if (!win) return;
|
||
|
||
// 确保加载完成
|
||
if (win.webContents.isLoading()) {
|
||
win.once("ready-to-show", () => {
|
||
showAndSend(win!, data);
|
||
});
|
||
} else {
|
||
showAndSend(win, data);
|
||
}
|
||
}
|
||
|
||
// 经系统通知中心显示（Linux / macOS）
|
||
async function showViaSystemNotification(data: any) {
|
||
if (!systemNotificationService) {
|
||
try {
|
||
systemNotificationService =
|
||
await import("../services/systemNotificationService");
|
||
} catch (error) {
|
||
console.error(
|
||
"[NotificationWindow] Failed to load system notification service:",
|
||
error,
|
||
);
|
||
return;
|
||
}
|
||
}
|
||
|
||
systemNotificationService.showSystemNotification({
|
||
title: data.title,
|
||
content: data.content,
|
||
avatarUrl: data.avatarUrl,
|
||
sessionId: data.sessionId,
|
||
channel: data.channel,
|
||
insightRecordId: data.insightRecordId,
|
||
targetRoute: data.targetRoute,
|
||
expireTimeout: 5000,
|
||
});
|
||
}
|
||
|
||
type NotificationDeliveryPayload = Record<string, any> & {
|
||
deliveryId: string;
|
||
};
|
||
|
||
// active 表示当前仍处于展示生命周期内的通知；close 时立即清空。
|
||
// pending 只覆盖 IPC 投递到 renderer 的短暂窗口，renderer ACK 后立即清空。
|
||
// 二者分离后既能在可见窗口热重载时恢复当前通知，也不会复活已经关闭的旧通知。
|
||
let activeNotificationData: NotificationDeliveryPayload | null = null;
|
||
let pendingNotificationData: NotificationDeliveryPayload | null = null;
|
||
let notificationDeliverySequence = 0;
|
||
let lastReadyRendererSessionId: string | null = null;
|
||
|
||
function nextNotificationDeliveryId() {
|
||
notificationDeliverySequence += 1;
|
||
return `${Date.now()}-${notificationDeliverySequence}`;
|
||
}
|
||
|
||
async function showAndSend(win: BrowserWindow, data: any) {
|
||
const config = ConfigService.getInstance();
|
||
const position = (await config.get("notificationPosition")) || "top-right";
|
||
|
||
// 更新位置：基于工作区完整矩形（含原点偏移）定位。
|
||
// macOS 菜单栏、Windows 任务栏靠上/靠左时工作区原点不为 (0,0)，
|
||
// 只用 workAreaSize 会把通知压进系统栏下面
|
||
const display = screen.getPrimaryDisplay();
|
||
const workArea = display.workArea;
|
||
const winWidth = position === "top-center" ? 280 : 344;
|
||
const winHeight = 114;
|
||
const padding = 20;
|
||
|
||
let x = 0;
|
||
let y = 0;
|
||
|
||
switch (position) {
|
||
case "top-center":
|
||
x = workArea.x + (workArea.width - winWidth) / 2;
|
||
y = workArea.y + padding;
|
||
break;
|
||
case "top-right":
|
||
x = workArea.x + workArea.width - winWidth - padding;
|
||
y = workArea.y + padding;
|
||
break;
|
||
case "bottom-right":
|
||
x = workArea.x + workArea.width - winWidth - padding;
|
||
y = workArea.y + workArea.height - winHeight - padding;
|
||
break;
|
||
case "top-left":
|
||
x = workArea.x + padding;
|
||
y = workArea.y + padding;
|
||
break;
|
||
case "bottom-left":
|
||
x = workArea.x + padding;
|
||
y = workArea.y + workArea.height - winHeight - padding;
|
||
break;
|
||
}
|
||
|
||
const winX = Math.floor(x);
|
||
const winY = Math.floor(y);
|
||
|
||
// 采集源 ID 使用启动时预热的缓存；仅当首条通知早于预热完成时补一次。
|
||
// 除此之外通知路径不触碰 desktopCapturer，弹出过程主线程零阻塞。
|
||
// 原生玻璃可用时折射由原生面板提供，渲染层不再开启 Chromium 桌面流
|
||
if (!nativeGlass && !cachedSourceId) await refreshDesktopSourceId();
|
||
const payload = {
|
||
...data,
|
||
deliveryId: nextNotificationDeliveryId(),
|
||
position,
|
||
backdrop: {
|
||
native: Boolean(nativeGlass),
|
||
sourceId: nativeGlass ? null : cachedSourceId,
|
||
winX,
|
||
winY,
|
||
width: display.size.width,
|
||
height: display.size.height,
|
||
},
|
||
};
|
||
activeNotificationData = payload;
|
||
pendingNotificationData = payload;
|
||
|
||
win.setPosition(winX, winY);
|
||
// 窗口高度始终沿用渲染层的实测校准值（notification:resize），
|
||
// 这里只同步宽度；反复重置高度会造成 114→实测高度的弹跳闪烁
|
||
const [, currentHeight] = win.getSize();
|
||
applyWindowSize(win, winWidth, currentHeight);
|
||
|
||
win.webContents.send("notification:show", payload);
|
||
|
||
// 设为可交互
|
||
win.setIgnoreMouseEvents(false);
|
||
win.showInactive(); // 显示但不聚焦
|
||
win.setAlwaysOnTop(true, "screen-saver"); // 最高层级
|
||
|
||
// 自动关闭计时器通常由渲染进程管理
|
||
// 渲染进程发送 'notification:close' 来隐藏窗口
|
||
}
|
||
|
||
// 注册通知处理
|
||
export async function registerNotificationHandlers() {
|
||
// Linux / macOS：初始化系统通知服务
|
||
if (usesSystemNotifications) {
|
||
try {
|
||
const systemNotificationModule =
|
||
await import("../services/systemNotificationService");
|
||
systemNotificationService = systemNotificationModule;
|
||
|
||
// 初始化服务
|
||
await systemNotificationModule.initSystemNotificationService();
|
||
|
||
// 注册通知点击回调（导航到会话/洞察）
|
||
systemNotificationModule.onNotificationAction((payload: unknown) => {
|
||
console.log(
|
||
"[NotificationWindow] System notification clicked, payload:",
|
||
payload,
|
||
);
|
||
// 如果设置了导航处理程序，则使用该处理程序；否则，回退到ipcMain方法。
|
||
if (onNotificationNavigate) {
|
||
onNotificationNavigate(payload);
|
||
} else {
|
||
// 如果尚未设置处理程序，则通过ipcMain发出事件
|
||
// 正常流程中不应该发生这种情况，因为我们在初始化之前设置了处理程序。
|
||
console.warn(
|
||
"[NotificationWindow] onNotificationNavigate not set yet",
|
||
);
|
||
}
|
||
});
|
||
|
||
console.log(
|
||
"[NotificationWindow] System notification service initialized",
|
||
);
|
||
} catch (error) {
|
||
console.error(
|
||
"[NotificationWindow] Failed to initialize system notification service:",
|
||
error,
|
||
);
|
||
}
|
||
}
|
||
|
||
ipcMain.handle("notification:show", (_, data) => {
|
||
showNotification(data);
|
||
});
|
||
|
||
ipcMain.handle("notification:close", () => {
|
||
if (usesSystemNotifications) {
|
||
// 系统通知由通知中心管理生命周期，无窗口可关
|
||
return;
|
||
}
|
||
activeNotificationData = null;
|
||
pendingNotificationData = null;
|
||
// 窗口即将隐藏，玻璃面板立即消失（渲染层通常已提前发过淡出信号）
|
||
glassPanel?.hide(0);
|
||
if (notificationWindow && !notificationWindow.isDestroyed()) {
|
||
notificationWindow.hide();
|
||
notificationWindow.setIgnoreMouseEvents(true, { forward: true });
|
||
}
|
||
scheduleIdleDestroy();
|
||
});
|
||
|
||
// —— 原生玻璃面板生命周期（仅 nativeGlass 可用时渲染层才会发这些消息）——
|
||
|
||
// 渲染层在卡片入场动画落定后上报实测几何（窗口本地 CSS 像素）
|
||
ipcMain.on("notification:glassRect", (_event, payload) => {
|
||
if (!nativeGlass || !notificationWindow || notificationWindow.isDestroyed()) return;
|
||
const display = screen.getDisplayMatching(notificationWindow.getBounds());
|
||
// 优先用渲染层实测的 devicePixelRatio（已含可能的页面缩放），显示器缩放兜底
|
||
const scale = payload.dpr || display.scaleFactor;
|
||
const [winX, winY] = notificationWindow.getPosition();
|
||
const toPhysical = (rect: { x: number; y: number; width: number; height: number }) => ({
|
||
x: Math.round(rect.x * scale),
|
||
y: Math.round(rect.y * scale),
|
||
width: Math.round(rect.width * scale),
|
||
height: Math.round(rect.height * scale),
|
||
});
|
||
const bounds = {
|
||
x: Math.round((winX + payload.card.x) * scale),
|
||
y: Math.round((winY + payload.card.y) * scale),
|
||
width: Math.round(payload.card.width * scale),
|
||
height: Math.round(payload.card.height * scale),
|
||
};
|
||
// 亮度带矩形是卡片本地坐标（带 id：0=整卡 1=标题行 2=正文）
|
||
const bands = (payload.bands ?? []).map(
|
||
(band: { id: number; x: number; y: number; width: number; height: number }) => ({
|
||
id: band.id,
|
||
...toPhysical(band),
|
||
}),
|
||
);
|
||
|
||
const panel = ensureGlassPanel(bounds, toGlassParams(payload, scale), scale, bands);
|
||
panel?.show(120);
|
||
});
|
||
|
||
// 渲染层退场动画开始：面板与卡片的 0.3s 渐隐同步淡出
|
||
ipcMain.on("notification:glassHide", () => {
|
||
glassPanel?.hide(240);
|
||
});
|
||
|
||
// renderer 每次文档加载生成一个 session id。React StrictMode 会重复执行 effect，
|
||
// 相同 session 的第二次 ready 不应再次触发通知及玻璃几何上报。
|
||
ipcMain.on("notification:ready", (event, rendererSessionId: unknown) => {
|
||
if (usesSystemNotifications) {
|
||
// 系统通知平台不需要通知窗口，拦截通知窗口渲染
|
||
return;
|
||
}
|
||
if (
|
||
!notificationWindow ||
|
||
notificationWindow.isDestroyed() ||
|
||
event.sender !== notificationWindow.webContents
|
||
) {
|
||
return;
|
||
}
|
||
|
||
const normalizedSessionId =
|
||
typeof rendererSessionId === "string" ? rendererSessionId : "";
|
||
if (
|
||
normalizedSessionId &&
|
||
normalizedSessionId === lastReadyRendererSessionId
|
||
) {
|
||
return;
|
||
}
|
||
lastReadyRendererSessionId = normalizedSessionId || null;
|
||
|
||
console.log("[NotificationWindow] Renderer ready, checking active data");
|
||
if (
|
||
activeNotificationData &&
|
||
notificationWindow.isVisible()
|
||
) {
|
||
pendingNotificationData = activeNotificationData;
|
||
console.log("[NotificationWindow] Re-sending active data");
|
||
notificationWindow.webContents.send(
|
||
"notification:show",
|
||
activeNotificationData,
|
||
);
|
||
}
|
||
});
|
||
|
||
// ACK 只清除与当前投递 id 匹配的 pending，避免旧 renderer 的迟到 ACK
|
||
// 清掉刚刚替换的新通知。active 保留到 close，以支持展示期间的 renderer 重载。
|
||
ipcMain.on("notification:received", (event, deliveryId: unknown) => {
|
||
if (
|
||
!notificationWindow ||
|
||
notificationWindow.isDestroyed() ||
|
||
event.sender !== notificationWindow.webContents ||
|
||
typeof deliveryId !== "string" ||
|
||
pendingNotificationData?.deliveryId !== deliveryId
|
||
) {
|
||
return;
|
||
}
|
||
pendingNotificationData = null;
|
||
});
|
||
|
||
// 启动空闲期预热（系统通知平台不需要）：
|
||
// - 采集源 ID：getSources 初始化采集管线会同步阻塞主线程 300ms+，放到空闲期一次性完成
|
||
// （原生玻璃可用时不需要 Chromium 采集源，跳过）
|
||
// - 预创建通知窗口：首条通知免去窗口创建和渲染器冷启动
|
||
// - 预创建原生玻璃面板（隐藏待命）：worker 线程、D3D 设备、着色器编译、
|
||
// DComp 窗口链全部离开首条通知的可见路径（原生端实测 ~150ms）；
|
||
// 隐藏面板零渲染零采集，常驻开销可忽略
|
||
if (!usesSystemNotifications) {
|
||
setTimeout(() => {
|
||
const win = createNotificationWindow();
|
||
// createNotificationWindow 可能因 DDA-only 策略设置失败而切到回退，
|
||
// 因此应在窗口创建后再判断并预热 Chromium 采集源。
|
||
if (!nativeGlass) refreshDesktopSourceId();
|
||
if (nativeGlass && win) {
|
||
const scale = screen.getPrimaryDisplay().scaleFactor;
|
||
const [winX, winY] = win.getPosition();
|
||
ensureGlassPanel(
|
||
{
|
||
x: Math.round(winX * scale),
|
||
y: Math.round(winY * scale),
|
||
width: Math.round(344 * scale),
|
||
height: Math.round(96 * scale),
|
||
},
|
||
toGlassParams({}, scale),
|
||
scale,
|
||
[],
|
||
);
|
||
}
|
||
// 预热窗口若迟迟没有通知到来，按空闲策略回收
|
||
scheduleIdleDestroy();
|
||
}, 3000);
|
||
if (!nativeGlass) {
|
||
// 显示器增删后源 ID 可能失效，重新预热
|
||
screen.on("display-added", () => refreshDesktopSourceId());
|
||
screen.on("display-removed", () => refreshDesktopSourceId());
|
||
}
|
||
}
|
||
|
||
// Handle resize request from renderer
|
||
ipcMain.on("notification:resize", (event, { width, height }) => {
|
||
if (usesSystemNotifications) {
|
||
// 系统通知由通知中心排版，无需窗口尺寸同步
|
||
return;
|
||
}
|
||
if (notificationWindow && !notificationWindow.isDestroyed()) {
|
||
// Enforce max-height if needed, or trust renderer
|
||
// Ensure it doesn't go off screen bottom?
|
||
// Logic in showAndSend handles position, but we need to keep anchor point (top-right usually).
|
||
// If we resize, we should re-calculate position to keep it anchored?
|
||
// Actually, setSize changes size. If it's top-right, x/y stays same -> window grows down. That's fine for top-right.
|
||
// If bottom-right, growing down pushes it off screen.
|
||
|
||
// Simple version: just setSize. For V1 we assume Top-Right.
|
||
// But wait, the config supports bottom-right.
|
||
// We can re-call setPosition or just let it be.
|
||
// If bottom-right, y needs to prevent overflow.
|
||
|
||
// For now, let's just set the size as requested.
|
||
applyWindowSize(notificationWindow, Math.round(width), Math.round(height));
|
||
}
|
||
});
|
||
|
||
// 'notification-clicked' 在 main.ts 中处理 (导航)
|
||
}
|