add ssl

neos.config.json

@@ -4,7 +4,8 @@
       {
          "name":"koishi",
          "ip":"koishi.momobako.com",
-         "port":"7211"
+         "port":"7211",
+         "ssl": true
       }
    ],
    "assetsPath":"/neos-assets",

neos.config.prod.json

@@ -4,7 +4,8 @@
       {
          "name":"koishi",
          "ip":"koishi.momobako.com",
-         "port":"7211"
+         "port":"7211",
+         "ssl": true
       }
    ],
    "assetsPath":"/neos-assets",

src/infra/stream.ts

@@ -12,8 +12,12 @@ export class WebSocketStream {
   public ws: WebSocket;
   stream: ReadableStream;
 
-  constructor(ip: string, onWsOpen?: (ws: WebSocket, ev: Event) => any) {
-    this.ws = new WebSocket("wss://" + ip);
+  constructor(
+    ip: string,
+    ssl: boolean,
+    onWsOpen?: (ws: WebSocket, ev: Event) => any,
+  ) {
+    this.ws = new WebSocket(ssl ? "wss://" : "ws://" + ip);
     if (onWsOpen) {
       this.ws.onopen = (e) => onWsOpen(this.ws, e);
     }

src/middleware/socket.ts

@@ -25,6 +25,7 @@ export interface socketAction {
     ip: string;
     player: string;
     passWd: string;
+    ssl: boolean;
   };
   isReplay?: boolean; // 是否是回放模式
   replayInfo?: {
@@ -43,13 +44,14 @@ export default async function (action: socketAction) {
     case socketCmd.CONNECT: {
       const { initInfo: info, isReplay, replayInfo } = action;
       if (info) {
-        ws = new WebSocketStream(info.ip, (conn, _event) =>
+        ws = new WebSocketStream(info.ip, info.ssl, (conn, _event) =>
           handleSocketOpen(conn, info.ip, info.player, info.passWd),
         );
 
         await ws.execute(handleSocketMessage);
       } else if (isReplay && replayInfo) {
-        ws = new WebSocketStream(replayInfo.Url, (conn, _event) => {
+        // 回放模式必定支持ssl
+        ws = new WebSocketStream(replayInfo.Url, true, (conn, _event) => {
           console.info("replay websocket open.");
           conn.binaryType = "arraybuffer";
           conn.send(replayInfo.data);

src/ui/Match/MatchModal.tsx

@@ -51,7 +51,7 @@ export const MatchModal: React.FC = ({}) => {
 
   const handleSubmit = async () => {
     setConfirmLoading(true);
-    await connectSrvpro({ player, ip: server, passWd: passwd });
+    await connectSrvpro({ player, ip: server, passWd: passwd, ssl: true });
   };
 
   useEffect(() => {

src/ui/Match/ReplayModal.tsx

@@ -49,6 +49,7 @@ export const ReplayModal: React.FC = () => {
         ip: "",
         player: "",
         passWd: "",
+        ssl: true,
         replay: true,
         replayData: replay,
       });

src/ui/Match/index.tsx

@@ -55,6 +55,7 @@ export const Component: React.FC = () => {
           ip: matchInfo.address + ":" + (matchInfo.port + 1),
           player: user.username,
           passWd: matchInfo.password,
+          ssl: true,
         });
       } else {
         message.error("匹配失败T_T");
@@ -71,6 +72,7 @@ export const Component: React.FC = () => {
       ip: server,
       player: user?.name ?? "Guest",
       passWd: "AI",
+      ssl: true,
     });
   };
 

src/ui/Match/util.ts

@@ -12,6 +12,7 @@ export const connectSrvpro = async (params: {
   ip: string;
   player: string;
   passWd: string;
+  ssl: boolean;
   replay?: boolean;
   replayData?: ArrayBuffer;
 }) => {