feat: update mongo version

Author: answer-huang

server/controllers/message.js

@@ -20,11 +20,11 @@ module.exports = class MessageRouter {
   })
   @tag
   static async getMessages(ctx, next) {
-    var page = ctx.query.page || 0;
-    var size = ctx.query.size || 10;
-    var user = ctx.state.user.data;
+    let page = ctx.query.page || 0;
+    let size = ctx.query.size || 10;
+    let user = ctx.state.user.data;
 
-    var result = await Message.find({ receiver: user._id })
+    let result = await Message.find({ receiver: user._id })
       .limit(size)
       .skip(page * size);
     ctx.body = responseWrapper(result);
@@ -34,18 +34,18 @@ module.exports = class MessageRouter {
   @summary("获取消息总条数和未读条数")
   @tag
   static async getMessageCount(ctx, next) {
-    var user = ctx.state.user.data;
-    var count = await Message.count({ receiver: user._id });
-    var unread = await Message.count({ receiver: user._id, status: "unread" });
+    let user = ctx.state.user.data;
+    let count = await Message.countDocuments({ receiver: user._id });
+    let unread = await Message.countDocuments({ receiver: user._id, status: "unread" });
     ctx.body = responseWrapper({ total: count, unread: unread });
   }
 
   @request("get", "/api/messages/markread")
   @summary("把消息全部标记为已读")
   @tag
   static async markMessageRead(ctx, next) {
-    var user = ctx.state.user.data;
-    var result = await Message.update({ receiver: user._id ,status:'unread'},{
+    let user = ctx.state.user.data;
+    let result = await Message.update({ receiver: user._id ,status:'unread'},{
         status: "hasread"
     });
     ctx.body = responseWrapper(true,'所有消息已标记已读');
@@ -59,9 +59,9 @@ module.exports = class MessageRouter {
   })
   @tag
   static async clearMessages(ctx, next) {
-    var page = ctx.query.page || 0;
-    var size = ctx.query.size || 10;
-    var user = ctx.state.user.data;
+    let page = ctx.query.page || 0;
+    let size = ctx.query.size || 10;
+    let user = ctx.state.user.data;
     await Message.deleteMany({ receiver: user._id });
     ctx.body = responseWrapper(true, "消息已清空");
   }

server/helper/db.js

@@ -3,24 +3,22 @@ const Fawn = require("fawn");
 import config from '../config';
 
 let dbUrl = `mongodb://${ config.dbHost }:${ config.dbPort }/${ config.dbName }`;
-if (config.dbUser) {
-    dbUrl = `mongodb://${config.dbUser}:${config.dbPass}@${config.dbHost}:${config.dbPort}/${config.dbName}`;
+if ( config.dbUser ) {
+  dbUrl = `mongodb://${ config.dbUser }:${ config.dbPass }@${ config.dbHost }:${ config.dbPort }/${ config.dbName }`;
 }
 
 console.log(dbUrl)
-mongoose.connect(dbUrl, { useNewUrlParser: true, useUnifiedTopology: true }, (err) => {
-    if (err) {
-        console.log('Mongoose connection error: ' + err.message)
-    } else {
-        console.log('数据库连接成功')
-    }
+mongoose.connect(dbUrl).then((result) => {
+  console.log('数据库连接成功')
+}).catch((e) => {
+  console.log('Mongoose connection error: ' + e)
 })
 
 mongoose
-    .connection
-    .on('disconnected', function () {
-        console.log('Mongoose connection disconnected')
-    })
+  .connection
+  .on('disconnected', function () {
+    console.log('Mongoose connection disconnected')
+  })
 Fawn.init(dbUrl);
 
 module.exports = mongoose

server/model/app_model.js

@@ -41,7 +41,7 @@ var appSchema = new Schema({
         default: false
     },
     installWithPwd: {
-        Boolean,
+        type: Boolean,
         default: false
     },
     installPwd: {

server/model/message.js

@@ -1,31 +1,31 @@
 const mongoose = require('../helper/db')
 const Schema = mongoose.Schema
 
-var messageSchema = new Schema({
+const messageSchema = new Schema({
     category: {
-        type:String,
-        required:true //消息类型  //INVITE 邀请
+        type: String,
+        required: true //消息类型  //INVITE 邀请
     },
-    content:{
-        type:String,
-        required:true  //消息内容
+    content: {
+        type: String,
+        required: true  //消息内容
     },
-    sender:String, //发送者的id
-    receiver:{ 
-        type:String,  //接受者的id 必填
-        required:true
+    sender: String, //发送者的id
+    receiver: {
+        type: String,  //接受者的id 必填
+        required: true
     },
-    sendAt:{
-        type:Date,
-        default:Date.now()
+    sendAt: {
+        type: Date,
+        default: Date.now()
     },
-    status:{
-        type:String,
-        default:'unread',
-        enum:['unread','hasread']
+    status: {
+        type: String,
+        default: 'unread',
+        enum: [ 'unread', 'hasread' ]
     },
-    data:String     //消息中带有的data字段
+    data: String     //消息中带有的data字段
 
-})
+});
 
 module.exports = mongoose.model('Message', messageSchema);

server/package.json

@@ -38,7 +38,7 @@
     "ldapjs": "^3.0.7",
     "lodash": "^4.17.21",
     "mkdirp": "^3.0.1",
-    "mongoose": "^6.0.4",
+    "mongoose": "^8.9.0",
     "mustache": "^4.2.0",
     "nodemailer": "^6.9.16",
     "text2png": "^2.3.0",