update 1.0.1

[+] index.html 可以自定义ws地址
[+] 增加了 start.bat
[U] 更新了部分注释

Author: lixiny93

config/users.db

@@ -0,0 +1,83 @@
+//[WARN]请注意，此JS仅用于测试，未完成正式开发！
+//此文件不做注释！
+
+const sqlite3 = require('sqlite3')
+const express = require('express')
+const fs = require('fs')
+const path = require('path')
+const { randomInt } = require('crypto')
+const tools = require('./tools.js')
+
+var router = express.Router()
+var tool = new tools()
+
+var db = new sqlite3.Database(path.join(__dirname,'config/users.db'),(err) => {
+    if(err) {
+        console.log("[数据库]数据库错误,检查数据库users.db是否存在")
+        tool.pass()
+    }else {
+        console.log("[数据库]数据库连接成功")
+        tool.pass()
+    }
+})
+
+//需要请求参数 user pwd
+router.get('/user/reg',(req,res) => {
+    console.log("[GET]/user/reg 请求参数:")
+    tool.pass()
+
+    var req_json = tool.objto(req.query)
+    req_json = tool.jsonto(req_json)
+    console.log(req_json)
+    tool.pass()
+    if(req_json.user == "" | req_json.pwd == "" ) {
+        res.send("用户名或密码为空")
+    }else if(req_json.user == undefined | req_json.pwd == undefined) {
+        res.send("所需参数为空！")
+    }else if(req_json.user != undefined | req_json.pwd != undefined){
+        var id = randomInt(100000,1000000000)
+        console.log("为用户随机出来的id是:" + id)
+        tool.pass()
+        db.run(`INSERT INTO USERS VALUES(?,?,?,"USER")`,id,req_json.user,req_json.pwd)
+        db.all(`SELECT * FROM USERS WHERE ID = ?;`,id,(err,rows) => {
+            console.log("[数据库]数据库返回的结果:" + tool.objto(rows))
+            tool.pass()
+            res.send("完成:" + tool.objto(rows) + "<br><h1>请谨记id与密码!</h1>")
+        })
+    }
+    
+})
+
+
+//需要请求参数 id pwd
+router.get('/user/login',(req,res) => {
+    console.log("[GET]/user/login 请求参数:")
+    tool.pass()
+
+    var req_json = tool.objto(req.query)
+    req_json = tool.jsonto(req_json)
+
+    console.log(req_json)
+    tool.pass()
+
+    if(req_json.id == "" | req_json.pwd == "" ) {
+        res.send("ID或密码为空")
+    }else if(req_json.id == undefined | req_json.pwd == undefined) {
+        res.send("所需参数为空")
+    }else if(req_json.id != "" | req_json.pwd != "") {
+        db.all(`SELECT ID, PWD FROM USERS WHERE ID = ?`,req_json.id,(err,rows) => {
+            var ret = tool.objto(rows)
+            ret = tool.jsonto(ret)
+            console.log("[数据库]数据库返回参数:"+ret[0].PWD)
+            tool.pass()
+            if(ret[0].PWD == req_json.pwd) {
+                res.send("登录成功!ID:" + req_json.id)
+            }
+        })
+
+    }
+    
+})
+
+
+module.exports = router

db.js

@@ -1,52 +1,84 @@
-const express = require("express")
-const websocket = require("nodejs-websocket")
-const fs = require('fs')
-
-var addr = "127.0.0.1"
-var port_express = 8919
-var port_ws = 9897
-
-
-
-try {
-    var f = fs.readFile("config/config.json",(err,data) => {
-        var json_cfg = JSON.parse(data)
-        addr = json_cfg.server[0].addr
-        port_express = json_cfg.server[0].web_port
-        port_ws = json_cfg.server[0].ws_port
-        console.log("根据配置," + "端口号:" + port_express + " WS端口号:" + port_ws + " 设置的地址:" + addr)
-        console.log("=======")
-        app_start()
-    })
-}catch {
-    console.log("Error 不过没关系，以按照默认配置启动")
-}
-
-console.log("SB Chat 启动中...")
-
-const app = express()
-
-
-app.use('/',express.static('pages'))
-
-app.get("/",(req,res) => {
-    res.sendFile(__dirname + "/pages/index.html")
-})
-
-function app_start() {
-    const wss = websocket.createServer((coon) => {
-        console.log("[WS]有一个新连接")
-        coon.on("text",(data) => {
-            console.log("[message]"+data)
-            coon.sendText(data)
-        })
-        coon.on("close", function (code, reason) {
-            console.log("[WS]有一个连接取消了")
-        })
-        coon.on("error",() => {
-        })	
-    }).listen(port_ws)
-    var server = app.listen(port_express,addr,() => {
-        console.log("网页服务器已启动 位于端口号"+ port_express + "WS端口号" + port_ws + "设置的地址:" + addr)
-    })
-}
+const express = require("express")
+const websocket = require("nodejs-websocket")
+const fs = require('fs')
+//const db = require('./db.js') /* 未完成的部分 */
+const tools = require('./tools.js')
+
+//初始化变量
+var addr = "127.0.0.1"
+//默认地址为127.0.0.1
+var port_express = 8919
+//网页服务器端口
+var port_ws = 9897
+//websocket端口
+
+var tool = new tools()
+//初始化工具
+
+//启动文本
+console.log("SB Chat 启动中...")
+tool.pass()
+
+try {
+    //尝试读取配置文件
+    var f = fs.readFile("config/config.json"/* 读取配置文件 */,(err,data) => {
+        //解析配置文件
+        var json_cfg = tool.jsonto(data)
+        //设置地址、端口
+        addr = json_cfg.server[0].addr
+        port_express = json_cfg.server[0].web_port
+        port_ws = json_cfg.server[0].ws_port
+        //输出配置
+        console.log("根据配置," + "端口号:" + port_express + " WS端口号:" + port_ws + " 设置的地址:" + addr)
+        tool.pass()
+        //执行app_start
+        app_start()
+    })
+}catch {
+    //错误提示，不过并无大碍，一般是读取文件失败
+    console.log("Error了 不过没关系，以按照默认配置启动")
+    tool.pass()
+    //启动
+    app_start();
+}
+
+
+//初始化网页文件
+const app = express()
+
+//未来可能会更新的数据库，用于用户注册登录，注册部分以完成，登录仍需打磨，目前我做不出来，但你可以试试，我很支持，目前是匿名聊天
+//app.use('/',db) /* 未完成部分 */
+
+//引用静态文件
+app.use('/',express.static('pages'))
+
+//请求主页
+app.get("/",(req,res) => {
+    console.log("[GET]请求主页 / ")
+    tool.pass()
+    res.sendFile(__dirname + "/pages/index.html")
+})
+
+//程序后端部分，我太懒了，就不注释了
+function app_start() {
+    const wss = websocket.createServer((coon) => {
+        console.log("[WS]有一个新连接")
+        tool.pass()
+        coon.on("text",(data) => {
+            console.log("[message]"+data)
+            coon.sendText(data)
+        })
+        coon.on("close", function (code, reason) {
+            console.log("[WS]有一个连接取消了")
+            tool.pass()
+        })
+        coon.on("error",() => {})	
+    }).listen(port_ws)
+    var server = app.listen(port_express,addr,() => {
+        console.log("网页服务器已启动 位于端口号"+ port_express + "WS端口号" + port_ws + "设置的地址:" + addr)
+        tool.pass()
+        console.log("你的聊天服务器地址: ws://"+addr+":"+port_ws+" 这会在网页内用到")
+        tool.pass()
+    })
+}
+