refa using parseRequestUrl

main.js

@@ -4,8 +4,8 @@ const request = require('request');
 const http = require('http');
 const crypto = require('crypto');
 const fs = require('fs');
-const url = require('url');
-const dns = require("dns");
+// const url = require('url');
+// const dns = require("dns");
 
 const config = JSON.parse(fs.readFileSync("./config.json"));
 let athleticUserPool = [];
@@ -23,6 +23,26 @@ let localLog = function (content) {
     console.log("[" + new Date().toLocaleString() + "] " + content)
 };
 
+function parseRequestUrl(req) {
+  const host = req.headers && req.headers.host ? req.headers.host : 'localhost'
+  const urlObj = new URL(req.url, 'http://' + host)
+
+  const query = Object.create(null)
+  const keys = new Set()
+
+  // 先收集 key（Node 12 的 iterator OK）
+  for (const k of urlObj.searchParams.keys()) keys.add(k)
+
+  // 再聚合成 object（对齐 url.parse(..., true) 的“多值数组”语义）
+  for (const k of keys) {
+    const all = urlObj.searchParams.getAll(k)
+    if (all.length <= 1) query[k] = all.length === 1 ? all[0] : ''
+    else query[k] = all
+  }
+
+  return { urlObj, query }
+}
+
 let getUserConfig = function (user, callback) {
     // HTTP GET 抓取数据。
     // 原 HTTP POST 抓取数据保留
@@ -396,7 +416,8 @@ let matchResponse = function(req, res) {
                     break; // 什么都不做，继续加入匹配池。
             }
         }
-        let arg = url.parse(req.url, true).query;
+      // let arg = url.parse(req.url, true).query;
+      let arg = parseRequestUrl(req).query;
         if (!arg.arena) arg.arena = 'entertain';
         localLog(username + ' apply for a ' + arg.arena + ' match.');
         // 选择匹配池
@@ -461,7 +482,7 @@ let endUserResponse = function(req, res) {
 };
 
 // 许可（GET /permit）
-let endUserPermit = function(query, req, res) {
+let endUserPermit = function(query, res) {
     let username = query.username;
     let password = query.password;
     let arena = query.arena;
@@ -547,23 +568,28 @@ function lookup(result) {
 
 // 创建服务器
 const server = http.createServer((req, res) => {
-    let parsedUrl = url.parse(req.url, true);
-    if (req.method === 'POST' && parsedUrl.pathname === '/')
-        matchResponse(req, res);
-    else if (req.method === 'GET' && parsedUrl.pathname.startsWith('/stats'))
-        getTimeResponse(parsedUrl, res);
-    else if (req.method === 'POST' && parsedUrl.pathname.startsWith('/finish'))
-        endUserResponse(req, res);
-    else if (req.method === 'POST' && parsedUrl.pathname.startsWith('/room-start'))
-        startUserResponse(parsedUrl.query, res);
-    else if (req.method == 'GET' && parsedUrl.pathname.startsWith('/permit'))
-        endUserPermit(parsedUrl.query, req, res);
-    else if (req.method === 'POST' && parsedUrl.pathname.startsWith('/clear'))
-        endClearResponse(parsedUrl.query, res)
-    else
-        notFoundResponse(res);
-
+  const parsed = parseRequestUrl(req)
+  const urlObj = parsed.urlObj
+  const query = parsed.query
+  const pathname = urlObj.pathname
+
+  if (req.method === 'POST' && pathname === '/') {
+    matchResponse(req, res)
+  } else if (req.method === 'GET' && pathname.startsWith('/stats')) {
+    getTimeResponse(urlObj, res)
+  } else if (req.method === 'POST' && pathname.startsWith('/finish')) {
+    endUserResponse(req, res)
+  } else if (req.method === 'POST' && pathname.startsWith('/room-start')) {
+    startUserResponse(query, res)
+  } else if (req.method === 'GET' && pathname.startsWith('/permit')) {
+    endUserPermit(query, res)
+  } else if (req.method === 'POST' && pathname.startsWith('/clear')) {
+    endClearResponse(query, res)
+  } else {
+    notFoundResponse(res)
+  }
 });
+
 server.timeout = 0;
 server.listen(1025);