✨ feat(protocol): 将协议数据传输至前端

Author: MoYingJi

electron/main/index.ts

@@ -11,7 +11,7 @@ import initAppServer from "../server";
 import loadWindow from "./windows/load-window";
 import mainWindow from "./windows/main-window";
 import initIpc from "./ipc";
-import { openCustomProtocol, registerCustomProtocol } from "./utils/protocol";
+import { trySendCustomProtocol, registerCustomProtocol } from "./utils/protocol";
 
 // 屏蔽报错
 process.env.ELECTRON_DISABLE_SECURITY_WARNINGS = "true";
@@ -80,8 +80,8 @@ class MainProcess {
 
     // 自定义协议
     app.on("open-url", (_, url) => {
-      processLog.log("Received custom protocol URL:", url);
-      openCustomProtocol(url)
+      processLog.log("🔗 Received custom protocol URL:", url);
+      trySendCustomProtocol(url)
     });
 
     // 将要退出

electron/main/utils/protocol.ts

@@ -1,46 +1,30 @@
 import { app } from "electron";
 import { processLog } from "../logger";
+import mainWindow from "../windows/main-window";
 
 export const registerCustomProtocol = () => {
   app.setAsDefaultProtocolClient("orpheus");
   processLog.info("🔗 Registered custom protocol");
 };
 
-export const openCustomProtocol = (str: string): boolean => {
-  switch (true) {
-    case str.startsWith("orpheus://"):
-      handleOpenOrpheus(str);
+export const trySendCustomProtocol = (str: string): boolean => {
+  try {
+    if (str.startsWith("orpheus://")) {
+      mainWindow.getWin()!.webContents.send("protocol-url", str);
       return true;
-    default:
-      return false;
+    }
+    return false;
+  } catch (e) {
+    processLog.error("❌ Failed to send protocol url", e);
+    return false;
   }
 }
 
 export const processProtocolFromCommand = (command: string[]): boolean => {
   // 这里第一个参数是程序名称 忽略此 仅遍历参数
   for (let i = 1; i < command.length; i++) {
     const arg = command[i];
-    if (openCustomProtocol(arg)) return true;
+    if (trySendCustomProtocol(arg)) return true;
   }
   return false;
 }
-
-export const handleOpenOrpheus = (url: string) => {
-  // 这里的协议是从网页端打开官方客户端的协议
-  // 形如 `orpheus://eyJ0eXBlIjoic29uZyIsImlkIjoiMTgyNjM2MTcxMiIsImNtZCI6InBsYXkifQ==`
-  // URI 的 Path 部分是 Base64 编码过的，解码后得到 Json
-  // 形如 `{"type":"song","id":"1826361712","cmd":"play"}`
-
-  if (!url.startsWith("orpheus://")) return;
-  const path = url.replace("orpheus://", "");
-  const data = atob(path);
-  let json: any;
-  try {
-    json = JSON.parse(data);
-  } catch (e) {
-    processLog.error("❌ Invalid JSON:", e);
-    return;
-  }
-  processLog.info("🚀 Open Orpheus:", json);
-  // TODO 处理
-};

electron/main/utils/single-lock.ts

@@ -21,7 +21,7 @@ export const initSingleLock = (): boolean => {
       if (!processProtocolFromCommand(commandLine)) {
         systemLog.warn("❌ 第二个实例将要启动");
       } else {
-        systemLog.info("🚀 第二个实例将要启动，因打开了 Custom Protocol");
+        systemLog.info("🚀 第二个实例将要启动，通过 Custom Protocol");
       }
       mainWindow.getWin()?.show();
     });

src/utils/initIpc.ts

@@ -6,6 +6,7 @@ import { usePlayer } from "./player";
 import { cloneDeep } from "lodash-es";
 import { getPlayerInfo } from "./player-utils/song";
 import { SettingType } from "@/types/main";
+import { handleProtocolUrl } from "@/utils/protocal";
 
 // 关闭更新状态
 const closeUpdateStatus = () => {
@@ -82,6 +83,11 @@ const initIpc = () => {
       closeUpdateStatus();
       window.$message.error("更新过程出现错误");
     });
+    // 协议数据
+    window.electron.ipcRenderer.on("protocol-url", (_, url) => {
+      console.log("📡 Received protocol url:", url);
+      handleProtocolUrl(url)
+    });
   } catch (error) {
     console.log(error);
   }

src/utils/protocal.ts

@@ -0,0 +1,51 @@
+class OrpheusData {
+  constructor(type: string, id: string, cmd: string) {
+    this.type = type;
+    this.id = id;
+    this.cmd = cmd;
+  }
+
+  type: string = "";
+  id: string = "";
+  cmd: string = "";
+}
+
+export const handleProtocolUrl = (url: string) => {
+  switch (true) {
+    case url.startsWith("orpheus://"):
+      handleOpenOrpheus(url);
+      break;
+    default:
+      break;
+  }
+}
+
+
+
+export const handleOpenOrpheus = (url: string) => {
+  const data = parseOrpheus(url);
+  if (!data) return;
+  console.log("🚀 Open Orpheus:", data);
+
+  // TODO 处理
+};
+
+const parseOrpheus = (url: string): OrpheusData | undefined => {
+  // 这里的协议是从网页端打开官方客户端的协议
+  // 形如 `orpheus://eyJ0eXBlIjoic29uZyIsImlkIjoiMTgyNjM2MTcxMiIsImNtZCI6InBsYXkifQ==`
+  // URI 的 Path 部分是 Base64 编码过的，解码后得到 Json
+  // 形如 `{"type":"song","id":"1826361712","cmd":"play"}`
+
+  if (!url.startsWith("orpheus://")) return;
+  const path = url.replace("orpheus://", "");
+  const jsonString = atob(path);
+  let data: OrpheusData;
+  try {
+    const json = JSON.parse(jsonString);
+    data = new OrpheusData(json.type, json.id, json.cmd);
+  } catch (e) {
+    console.error("❌ Invalid Data:", e);
+    return;
+  }
+  return data;
+}