make ts happy

2024-11-22 01:56:33 +00:00 · 2024-08-06 01:47:51 +08:00
parent a9902d9109
commit 897f691d6c
64 changed files with 485 additions and 420 deletions
--- a/src/common/config.ts
+++ b/src/common/config.ts
@@ -1,7 +1,5 @@
-import fs from 'fs'
-import fsPromise from 'fs/promises'
+import fs from 'node:fs'
 import { Config, OB11Config } from './types'
-
 import { mergeNewProperties } from './utils/helper'
 import path from 'node:path'
 import { selfInfo } from './data'
--- a/src/common/data.ts
+++ b/src/common/data.ts
@@ -45,7 +45,7 @@ export async function getFriend(uinOrUid: string): Promise<Friend | undefined> {
      if (friend) {
        friends.push(friend)
      }
-    } catch (e) {
+    } catch (e: any) {
      log('刷新好友列表失败', e.stack.toString())
    }
  }
--- a/src/common/db.ts
+++ b/src/common/db.ts
@@ -14,9 +14,9 @@ class DBUtil {
  public readonly DB_KEY_PREFIX_FILE = 'file_'
  public readonly DB_KEY_PREFIX_GROUP_NOTIFY = 'group_notify_'
  private readonly DB_KEY_RECEIVED_TEMP_UIN_MAP = 'received_temp_uin_map'
-  public db: Level
+  public db: Level | undefined
  public cache: Record<string, RawMessage | string | FileCache | GroupNotify | ReceiveTempUinMap> = {} // <msg_id_ | msg_short_id_ | msg_seq_id_><id>: RawMessage
-  private currentShortId: number
+  private currentShortId: number | undefined

  /*
   * 数据库结构
@@ -44,7 +44,7 @@ class DBUtil {
          this.db = new Level(DB_PATH, { valueEncoding: 'json' })
          console.log('llonebot init db success')
          resolve(null)
-        } catch (e) {
+        } catch (e: any) {
          console.log('init db fail', e.stack.toString())
          setTimeout(initDB, 300)
        }
@@ -72,13 +72,13 @@ class DBUtil {

  public async getReceivedTempUinMap(): Promise<ReceiveTempUinMap> {
    try {
-      this.cache[this.DB_KEY_RECEIVED_TEMP_UIN_MAP] = JSON.parse(await this.db.get(this.DB_KEY_RECEIVED_TEMP_UIN_MAP))
-    } catch (e) {}
+      this.cache[this.DB_KEY_RECEIVED_TEMP_UIN_MAP] = JSON.parse(await this.db?.get(this.DB_KEY_RECEIVED_TEMP_UIN_MAP)!)
+    } catch (e) { }
    return (this.cache[this.DB_KEY_RECEIVED_TEMP_UIN_MAP] || {}) as ReceiveTempUinMap
  }
  public setReceivedTempUinMap(data: ReceiveTempUinMap) {
    this.cache[this.DB_KEY_RECEIVED_TEMP_UIN_MAP] = data
-    this.db.put(this.DB_KEY_RECEIVED_TEMP_UIN_MAP, JSON.stringify(data)).then()
+    this.db?.put(this.DB_KEY_RECEIVED_TEMP_UIN_MAP, JSON.stringify(data)).then()
  }
  private addCache(msg: RawMessage) {
    const longIdKey = this.DB_KEY_PREFIX_MSG_ID + msg.msgId
@@ -91,30 +91,30 @@ class DBUtil {
    this.cache = {}
  }

-  async getMsgByShortId(shortMsgId: number): Promise<RawMessage> {
+  async getMsgByShortId(shortMsgId: number): Promise<RawMessage | undefined> {
    const shortMsgIdKey = this.DB_KEY_PREFIX_MSG_SHORT_ID + shortMsgId
    if (this.cache[shortMsgIdKey]) {
      // log("getMsgByShortId cache", shortMsgIdKey, this.cache[shortMsgIdKey])
      return this.cache[shortMsgIdKey] as RawMessage
    }
    try {
-      const longId = await this.db.get(shortMsgIdKey)
-      const msg = await this.getMsgByLongId(longId)
-      this.addCache(msg)
+      const longId = await this.db?.get(shortMsgIdKey)
+      const msg = await this.getMsgByLongId(longId!)
+      this.addCache(msg!)
      return msg
-    } catch (e) {
+    } catch (e: any) {
      log('getMsgByShortId db error', e.stack.toString())
    }
  }

-  async getMsgByLongId(longId: string): Promise<RawMessage> {
+  async getMsgByLongId(longId: string): Promise<RawMessage | undefined> {
    const longIdKey = this.DB_KEY_PREFIX_MSG_ID + longId
    if (this.cache[longIdKey]) {
      return this.cache[longIdKey] as RawMessage
    }
    try {
-      const data = await this.db.get(longIdKey)
-      const msg = JSON.parse(data)
+      const data = await this.db?.get(longIdKey)
+      const msg = JSON.parse(data!)
      this.addCache(msg)
      return msg
    } catch (e) {
@@ -122,17 +122,17 @@ class DBUtil {
    }
  }

-  async getMsgBySeqId(seqId: string): Promise<RawMessage> {
+  async getMsgBySeqId(seqId: string): Promise<RawMessage | undefined> {
    const seqIdKey = this.DB_KEY_PREFIX_MSG_SEQ_ID + seqId
    if (this.cache[seqIdKey]) {
      return this.cache[seqIdKey] as RawMessage
    }
    try {
-      const longId = await this.db.get(seqIdKey)
-      const msg = await this.getMsgByLongId(longId)
-      this.addCache(msg)
+      const longId = await this.db?.get(seqIdKey)
+      const msg = await this.getMsgByLongId(longId!)
+      this.addCache(msg!)
      return msg
-    } catch (e) {
+    } catch (e: any) {
      log('getMsgBySeqId db error', e.stack.toString())
    }
  }
@@ -141,7 +141,7 @@ class DBUtil {
    // 有则更新，无则添加
    // log("addMsg", msg.msgId, msg.msgSeq, msg.msgShortId);
    const longIdKey = this.DB_KEY_PREFIX_MSG_ID + msg.msgId
-    let existMsg = this.cache[longIdKey] as RawMessage
+    let existMsg: RawMessage | undefined = this.cache[longIdKey] as RawMessage
    if (!existMsg) {
      try {
        existMsg = await this.getMsgByLongId(msg.msgId)
@@ -161,13 +161,13 @@ class DBUtil {
    msg.msgShortId = shortMsgId
    this.addCache(msg)
    // log("新增消息记录", msg.msgId)
-    this.db.put(shortIdKey, msg.msgId).then().catch()
-    this.db.put(longIdKey, JSON.stringify(msg)).then().catch()
+    this.db?.put(shortIdKey, msg.msgId).then().catch()
+    this.db?.put(longIdKey, JSON.stringify(msg)).then().catch()
    try {
-      await this.db.get(seqIdKey)
+      await this.db?.get(seqIdKey)
    } catch (e) {
      // log("新的seqId", seqIdKey)
-      this.db.put(seqIdKey, msg.msgId).then().catch()
+      this.db?.put(seqIdKey, msg.msgId).then().catch()
    }
    if (!this.cache[seqIdKey]) {
      this.cache[seqIdKey] = msg
@@ -178,7 +178,7 @@ class DBUtil {

  async updateMsg(msg: RawMessage) {
    const longIdKey = this.DB_KEY_PREFIX_MSG_ID + msg.msgId
-    let existMsg = this.cache[longIdKey] as RawMessage
+    let existMsg: RawMessage | undefined = this.cache[longIdKey] as RawMessage
    if (!existMsg) {
      try {
        existMsg = await this.getMsgByLongId(msg.msgId)
@@ -187,18 +187,18 @@ class DBUtil {
      }
    }

-    Object.assign(existMsg, msg)
-    this.db.put(longIdKey, JSON.stringify(existMsg)).then().catch()
-    const shortIdKey = this.DB_KEY_PREFIX_MSG_SHORT_ID + existMsg.msgShortId
+    Object.assign(existMsg!, msg)
+    this.db?.put(longIdKey, JSON.stringify(existMsg)).then().catch()
+    const shortIdKey = this.DB_KEY_PREFIX_MSG_SHORT_ID + existMsg?.msgShortId
    const seqIdKey = this.DB_KEY_PREFIX_MSG_SEQ_ID + msg.msgSeq
    if (!this.cache[seqIdKey]) {
-      this.cache[seqIdKey] = existMsg
+      this.cache[seqIdKey] = existMsg!
    }
-    this.db.put(shortIdKey, msg.msgId).then().catch()
+    this.db?.put(shortIdKey, msg.msgId).then().catch()
    try {
-      await this.db.get(seqIdKey)
+      await this.db?.get(seqIdKey)
    } catch (e) {
-      this.db.put(seqIdKey, msg.msgId).then().catch()
+      this.db?.put(seqIdKey, msg.msgId).then().catch()
      // log("更新seqId error", e.stack, seqIdKey);
    }
    // log("更新消息", existMsg.msgSeq, existMsg.msgShortId, existMsg.msgId);
@@ -208,15 +208,15 @@ class DBUtil {
    const key = 'msg_current_short_id'
    if (this.currentShortId === undefined) {
      try {
-        let id: string = await this.db.get(key)
-        this.currentShortId = parseInt(id)
+        const id = await this.db?.get(key)
+        this.currentShortId = parseInt(id!)
      } catch (e) {
        this.currentShortId = -2147483640
      }
    }

    this.currentShortId++
-    this.db.put(key, this.currentShortId.toString()).then().catch()
+    this.db?.put(key, this.currentShortId.toString()).then().catch()
    return this.currentShortId
  }

@@ -229,8 +229,8 @@ class DBUtil {
    delete cacheDBData['downloadFunc']
    this.cache[fileNameOrUuid] = data
    try {
-      await this.db.put(key, JSON.stringify(cacheDBData))
-    } catch (e) {
+      await this.db?.put(key, JSON.stringify(cacheDBData))
+    } catch (e: any) {
      log('addFileCache db error', e.stack.toString())
    }
  }
@@ -241,8 +241,8 @@ class DBUtil {
      return this.cache[key] as FileCache
    }
    try {
-      let data = await this.db.get(key)
-      return JSON.parse(data)
+      const data = await this.db?.get(key)
+      return JSON.parse(data!)
    } catch (e) {
      // log("getFileCache db error", e.stack.toString())
    }
@@ -255,7 +255,7 @@ class DBUtil {
      return
    }
    this.cache[key] = notify
-    this.db.put(key, JSON.stringify(notify)).then().catch()
+    this.db?.put(key, JSON.stringify(notify)).then().catch()
  }

  async getGroupNotify(seq: string): Promise<GroupNotify | undefined> {
@@ -264,8 +264,8 @@ class DBUtil {
      return this.cache[key] as GroupNotify
    }
    try {
-      let data = await this.db.get(key)
-      return JSON.parse(data)
+      const data = await this.db?.get(key)
+      return JSON.parse(data!)
    } catch (e) {
      // log("getGroupNotify db error", e.stack.toString())
    }
--- a/src/common/server/http.ts
+++ b/src/common/server/http.ts
@@ -1,5 +1,5 @@
 import express, { Express, Request, Response } from 'express'
-import http from 'http'
+import http from 'node:http'
 import cors from 'cors'
 import { log } from '../utils/log'
 import { getConfigUtil } from '../config'
@@ -10,7 +10,7 @@ type RegisterHandler = (res: Response, payload: any) => Promise<any>
 export abstract class HttpServerBase {
  name: string = 'LLOneBot'
  private readonly expressAPP: Express
-  private server: http.Server = null
+  private server: http.Server | null = null

  constructor() {
    this.expressAPP = express()
@@ -38,7 +38,7 @@ export abstract class HttpServerBase {
    let clientToken = ''
    const authHeader = req.get('authorization')
    if (authHeader) {
-      clientToken = authHeader.split('Bearer ').pop()
+      clientToken = authHeader.split('Bearer ').pop()!
      log('receive http header token', clientToken)
    } else if (req.query.access_token) {
      if (Array.isArray(req.query.access_token)) {
@@ -62,7 +62,7 @@ export abstract class HttpServerBase {
      })
      this.listen(port)
      llonebotError.httpServerError = ''
-    } catch (e) {
+    } catch (e: any) {
      log('HTTP服务启动失败', e.toString())
      llonebotError.httpServerError = 'HTTP服务启动失败, ' + e.toString()
    }
@@ -103,7 +103,7 @@ export abstract class HttpServerBase {
      log('收到http请求', url, payload)
      try {
        res.send(await handler(res, payload))
-      } catch (e) {
+      } catch (e: any) {
        this.handleFailed(res, payload, e.stack.toString())
      }
    })
--- a/src/common/server/websocket.ts
+++ b/src/common/server/websocket.ts
@@ -6,9 +6,9 @@ import { getConfigUtil } from '../config'
 import { llonebotError } from '../data'

 class WebsocketClientBase {
-  private wsClient: WebSocket
+  private wsClient: WebSocket | undefined

-  constructor() {}
+  constructor() { }

  send(msg: string) {
    if (this.wsClient && this.wsClient.readyState == WebSocket.OPEN) {
@@ -16,11 +16,11 @@ class WebsocketClientBase {
    }
  }

-  onMessage(msg: string) {}
+  onMessage(msg: string) { }
 }

 export class WebsocketServerBase {
-  private ws: WebSocketServer = null
+  private ws: WebSocketServer | null = null

  constructor() {
    console.log(`llonebot websocket service started`)
@@ -30,22 +30,22 @@ export class WebsocketServerBase {
    try {
      this.ws = new WebSocketServer({ port, maxPayload: 1024 * 1024 * 1024 })
      llonebotError.wsServerError = ''
-    } catch (e) {
+    } catch (e: any) {
      llonebotError.wsServerError = '正向ws服务启动失败, ' + e.toString()
    }
-    this.ws.on('connection', (wsClient, req) => {
-      const url = req.url.split('?').shift()
+    this.ws?.on('connection', (wsClient, req) => {
+      const url = req.url?.split('?').shift()
      this.authorize(wsClient, req)
-      this.onConnect(wsClient, url, req)
+      this.onConnect(wsClient, url!, req)
      wsClient.on('message', async (msg) => {
-        this.onMessage(wsClient, url, msg.toString())
+        this.onMessage(wsClient, url!, msg.toString())
      })
    })
  }

  stop() {
    llonebotError.wsServerError = ''
-    this.ws.close((err) => {
+    this.ws?.close((err) => {
      log('ws server close failed!', err)
    })
    this.ws = null
@@ -83,11 +83,11 @@ export class WebsocketServerBase {
    }
  }

-  authorizeFailed(wsClient: WebSocket) {}
+  authorizeFailed(wsClient: WebSocket) { }

-  onConnect(wsClient: WebSocket, url: string, req: IncomingMessage) {}
+  onConnect(wsClient: WebSocket, url: string, req: IncomingMessage) { }

-  onMessage(wsClient: WebSocket, url: string, msg: string) {}
+  onMessage(wsClient: WebSocket, url: string, msg: string) { }

-  sendHeart() {}
+  sendHeart() { }
 }
--- a/src/common/utils/audio.ts
+++ b/src/common/utils/audio.ts
@@ -114,7 +114,7 @@ export async function encodeSilk(filePath: string) {
      let duration = 0
      try {
        duration = getDuration(silk) / 1000
-      } catch (e) {
+      } catch (e: any) {
        log('获取语音文件时长失败, 使用文件大小推测时长', filePath, e.stack)
        duration = await guessDuration(filePath)
      }
@@ -125,7 +125,7 @@ export async function encodeSilk(filePath: string) {
        duration,
      }
    }
-  } catch (error) {
+  } catch (error: any) {
    log('convert silk failed', error.stack)
    return {}
  }
--- a/src/common/utils/file.ts
+++ b/src/common/utils/file.ts
@@ -52,7 +52,7 @@ export async function file2base64(path: string) {
    const data = await fsPromise.readFile(path)
    // 转换为Base64编码
    result.data = data.toString('base64')
-  } catch (err) {
+  } catch (err: any) {
    result.err = err.toString()
  }
  return result
@@ -119,7 +119,7 @@ type Uri2LocalRes = {
  isLocal: boolean
 }

-export async function uri2local(uri: string, fileName: string = null): Promise<Uri2LocalRes> {
+export async function uri2local(uri: string, fileName: string | null = null): Promise<Uri2LocalRes> {
  let res = {
    success: false,
    errMsg: '',
@@ -132,10 +132,10 @@ export async function uri2local(uri: string, fileName: string = null): Promise<U
    fileName = randomUUID()
  }
  let filePath = path.join(TEMP_DIR, fileName)
-  let url = null
+  let url: URL | null = null
  try {
    url = new URL(uri)
-  } catch (e) {
+  } catch (e: any) {
    res.errMsg = `uri ${uri} 解析失败,` + e.toString() + ` 可能${uri}不存在`
    return res
  }
@@ -153,10 +153,10 @@ export async function uri2local(uri: string, fileName: string = null): Promise<U
    }
  } else if (url.protocol == 'http:' || url.protocol == 'https:') {
    // 下载文件
-    let buffer: Buffer = null
+    let buffer: Buffer | null = null
    try {
      buffer = await httpDownload(uri)
-    } catch (e) {
+    } catch (e: any) {
      res.errMsg = `${url}下载失败,` + e.toString()
      return res
    }
@@ -208,7 +208,7 @@ export async function uri2local(uri: string, fileName: string = null): Promise<U
  // }
  if (!res.isLocal && !res.ext) {
    try {
-      let ext: string = (await fileType.fileTypeFromFile(filePath)).ext
+      const ext = (await fileType.fileTypeFromFile(filePath))?.ext
      if (ext) {
        log('获取文件类型', ext, filePath)
        await fsPromise.rename(filePath, filePath + `.${ext}`)
--- a/src/common/utils/helper.ts
+++ b/src/common/utils/helper.ts
@@ -41,7 +41,7 @@ export function mergeNewProperties(newObj: any, oldObj: any) {
  })
 }

-export function isNull(value: any) {
+export function isNull(value: any): value is null | undefined | void {
  return value === undefined || value === null
 }

@@ -73,14 +73,14 @@ export function wrapText(str: string, maxLength: number): string {
 * @param customKey 自定义缓存键前缀，可为空，防止方法名参数名一致时导致缓存键冲突
 * @returns 处理后缓存或调用原方法的结果
 */
-export function cacheFunc(ttl: number, customKey: string='') {
+export function cacheFunc(ttl: number, customKey: string = '') {
  const cache = new Map<string, { expiry: number; value: any }>();

  return function (target: any, propertyKey: string, descriptor: PropertyDescriptor): PropertyDescriptor {
    const originalMethod = descriptor.value;
    const className = target.constructor.name;  // 获取类名
    const methodName = propertyKey;             // 获取方法名
-    descriptor.value = async function (...args: any[]){
+    descriptor.value = async function (...args: any[]) {
      const cacheKey = `${customKey}${className}.${methodName}:${JSON.stringify(args)}`;
      const cached = cache.get(cacheKey);
      if (cached && cached.expiry > Date.now()) {
--- a/src/common/utils/upgrade.ts
+++ b/src/common/utils/upgrade.ts
@@ -91,7 +91,7 @@ export async function getRemoteVersionByMirror(mirrorGithub: string) {
    releasePage = (await httpDownload(mirrorGithub + '/LLOneBot/LLOneBot/releases')).toString()
    // log("releasePage", releasePage);
    if (releasePage === 'error') return ''
-    return releasePage.match(new RegExp('(?<=(tag/v)).*?(?=("))'))[0]
+    return releasePage.match(new RegExp('(?<=(tag/v)).*?(?=("))'))?.[0]
  } catch {}
  return ''
 }
--- a/src/common/utils/video.ts
+++ b/src/common/utils/video.ts
@@ -31,10 +31,10 @@ export async function getVideoInfo(filePath: string) {
          console.log('未找到视频流信息。')
        }
        resolve({
-          width: videoStream.width,
-          height: videoStream.height,
-          time: parseInt(videoStream.duration),
-          format: metadata.format.format_name,
+          width: videoStream?.width!,
+          height: videoStream?.height!,
+          time: parseInt(videoStream?.duration!),
+          format: metadata.format.format_name!,
          size,
          filePath,
        })
@@ -67,7 +67,7 @@ export async function encodeMp4(filePath: string) {
  return videoInfo
 }

-export function checkFfmpeg(newPath: string = null): Promise<boolean> {
+export function checkFfmpeg(newPath: string | null = null): Promise<boolean> {
  return new Promise((resolve, reject) => {
    log('开始检查ffmpeg', newPath)
    if (newPath) {
--- a/src/main/main.ts
+++ b/src/main/main.ts
@@ -123,7 +123,7 @@ function onLoad() {
      return
    }
    dialog
-      .showMessageBox(mainWindow, {
+      .showMessageBox(mainWindow!, {
        type: 'question',
        buttons: ['确认', '取消'],
        defaultId: 0, // 默认选中的按钮，0 代表第一个按钮，即 "确认"
@@ -210,7 +210,7 @@ function onLoad() {
    }>([ReceiveCmdS.NEW_MSG, ReceiveCmdS.NEW_ACTIVE_MSG], async (payload) => {
      try {
        await postReceiveMsg(payload.msgList)
-      } catch (e) {
+      } catch (e: any) {
        log('report message error: ', e.stack.toString())
      }
    })
@@ -254,7 +254,7 @@ function onLoad() {
      // log("reportSelfMessage", payload)
      try {
        await postReceiveMsg([payload.msgRecord])
-      } catch (e) {
+      } catch (e: any) {
        log('report self message error: ', e.stack.toString())
      }
    })
@@ -332,7 +332,7 @@ function onLoad() {
                if (notify.user2.uid) {
                  // 是被踢的
                  const member2 = await getGroupMember(notify.group.groupCode, notify.user2.uid)
-                  operatorId = member2.uin
+                  operatorId = member2?.uin!
                  subType = 'kick'
                }
                let groupDecreaseEvent = new OB11GroupDecreaseEvent(
@@ -342,14 +342,12 @@ function onLoad() {
                  subType,
                )
                postOb11Event(groupDecreaseEvent, true)
-              } catch (e) {
+              } catch (e: any) {
                log('获取群通知的成员信息失败', notify, e.stack.toString())
              }
            }
            else if ([GroupNotifyTypes.JOIN_REQUEST, GroupNotifyTypes.JOIN_REQUEST_BY_INVITED].includes(notify.type)) {
              log('有加群请求')
-              let groupRequestEvent = new OB11GroupRequestEvent()
-              groupRequestEvent.group_id = parseInt(notify.group.groupCode)
              let requestQQ = uidMaps[notify.user1.uid]
              if (!requestQQ) {
                try {
@@ -358,40 +356,47 @@ function onLoad() {
                  log('获取加群人QQ号失败', e)
                }
              }
-              groupRequestEvent.user_id = parseInt(requestQQ) || 0
-              groupRequestEvent.sub_type = 'add'
-              groupRequestEvent.comment = notify.postscript
-              groupRequestEvent.flag = notify.seq
+              let invitorId: number
              if (notify.type == GroupNotifyTypes.JOIN_REQUEST_BY_INVITED) {
                // groupRequestEvent.sub_type = 'invite'
                let invitorQQ = uidMaps[notify.user2.uid]
                if (!invitorQQ) {
                  try {
                    let invitor = (await NTQQUserApi.getUserDetailInfo(notify.user2.uid))
-                    groupRequestEvent.invitor_id = parseInt(invitor.uin)
+                    invitorId = parseInt(invitor.uin)
                  } catch (e) {
-                    groupRequestEvent.invitor_id = 0
+                    invitorId = 0
                    log('获取邀请人QQ号失败', e)
                  }
                }
              }
+              const groupRequestEvent = new OB11GroupRequestEvent(
+                parseInt(notify.group.groupCode),
+                parseInt(requestQQ) || 0,
+                notify.seq,
+                notify.postscript,
+                invitorId!,
+                'add'
+              )
              postOb11Event(groupRequestEvent)
            }
            else if (notify.type == GroupNotifyTypes.INVITE_ME) {
              log('收到邀请我加群通知')
-              let groupInviteEvent = new OB11GroupRequestEvent()
-              groupInviteEvent.group_id = parseInt(notify.group.groupCode)
-              let user_id = uidMaps[notify.user2.uid]
-              if (!user_id) {
-                user_id = (await NTQQUserApi.getUserDetailInfo(notify.user2.uid))?.uin
+              let userId = uidMaps[notify.user2.uid]
+              if (!userId) {
+                userId = (await NTQQUserApi.getUserDetailInfo(notify.user2.uid))?.uin
              }
-              groupInviteEvent.user_id = parseInt(user_id)
-              groupInviteEvent.sub_type = 'invite'
-              // groupInviteEvent.invitor_id = parseInt(user_id)
-              groupInviteEvent.flag = notify.seq
+              const groupInviteEvent = new OB11GroupRequestEvent(
+                parseInt(notify.group.groupCode),
+                parseInt(userId),
+                notify.seq,
+                undefined,
+                undefined,
+                'invite'
+              )
              postOb11Event(groupInviteEvent)
            }
-          } catch (e) {
+          } catch (e: any) {
            log('解析群通知失败', e.stack.toString())
          }
        }
@@ -403,19 +408,18 @@ function onLoad() {

    registerReceiveHook<FriendRequestNotify>(ReceiveCmdS.FRIEND_REQUEST, async (payload) => {
      for (const req of payload.data.buddyReqs) {
-        let flag = req.friendUid + req.reqTime
+        const flag = req.friendUid + req.reqTime
        if (req.isUnread && parseInt(req.reqTime) > startTime / 1000) {
          friendRequests[flag] = req
          log('有新的好友请求', req)
-          let friendRequestEvent = new OB11FriendRequestEvent()
+          let userId: number
          try {
-            let requester = await NTQQUserApi.getUserDetailInfo(req.friendUid)
-            friendRequestEvent.user_id = parseInt(requester.uin)
+            const requester = await NTQQUserApi.getUserDetailInfo(req.friendUid)
+            userId = parseInt(requester.uin)
          } catch (e) {
            log('获取加好友者QQ号失败', e)
          }
-          friendRequestEvent.flag = flag
-          friendRequestEvent.comment = req.extWords
+          const friendRequestEvent = new OB11FriendRequestEvent(userId!, req.extWords, flag)
          postOb11Event(friendRequestEvent)
        }
      }
@@ -438,7 +442,7 @@ function onLoad() {
        uidMaps[value] = key
      }
    })
-    NTEventDispatch.init({ ListenerMap: wrapperConstructor, WrapperSession: wrapperApi.NodeIQQNTWrapperSession })
+    NTEventDispatch.init({ ListenerMap: wrapperConstructor, WrapperSession: wrapperApi.NodeIQQNTWrapperSession! })
    try {
      log('start get groups')
      const _groups = await NTQQGroupApi.getGroups()
@@ -509,7 +513,7 @@ function onLoad() {
            selfInfo.nick = userInfo.nick
            return
          }
-        } catch (e) {
+        } catch (e: any) {
          log('get self nickname failed', e.stack)
        }
        if (getSelfNickCount < 10) {
@@ -537,7 +541,7 @@ function onBrowserWindowCreated(window: BrowserWindow) {
  try {
    hookNTQQApiCall(window)
    hookNTQQApiReceive(window)
-  } catch (e) {
+  } catch (e: any) {
    log('LLOneBot hook error: ', e.toString())
  }
 }
--- a/src/ntqqapi/api/file.ts
+++ b/src/ntqqapi/api/file.ts
@@ -22,7 +22,7 @@ import { Peer } from '@/ntqqapi/types/msg'
 export class NTQQFileApi {
  static async getVideoUrl(peer: Peer, msgId: string, elementId: string): Promise<string> {
    const session = wrapperApi.NodeIQQNTWrapperSession
-    return (await session.getRichMediaService().getVideoPlayUrlV2(peer,
+    return (await session?.getRichMediaService().getVideoPlayUrlV2(peer,
      msgId,
      elementId,
      0,
--- a/src/ntqqapi/api/friend.ts
+++ b/src/ntqqapi/api/friend.ts
@@ -70,9 +70,9 @@ export class NTQQFriendApi {
  static async getBuddyV2(refresh = false): Promise<FriendV2[]> {
    const uids: string[] = []
    const session = wrapperApi.NodeIQQNTWrapperSession
-    const buddyService = session.getBuddyService()
-    const buddyListV2 = refresh ? await buddyService.getBuddyListV2('0', BuddyListReqType.KNOMAL) : await buddyService.getBuddyListV2('0', BuddyListReqType.KNOMAL)
-    uids.push(...buddyListV2.data.flatMap(item => item.buddyUids))
+    const buddyService = session?.getBuddyService()
+    const buddyListV2 = refresh ? await buddyService?.getBuddyListV2('0', BuddyListReqType.KNOMAL) : await buddyService?.getBuddyListV2('0', BuddyListReqType.KNOMAL)
+    uids.push(...buddyListV2?.data.flatMap(item => item.buddyUids)!)
    const data = await NTEventDispatch.CallNoListenerEvent<NodeIKernelProfileService['getCoreAndBaseInfo']>(
      'NodeIKernelProfileService/getCoreAndBaseInfo', 5000, 'nodeStore', uids
    )
--- a/src/ntqqapi/api/group.ts
+++ b/src/ntqqapi/api/group.ts
@@ -135,7 +135,7 @@ export class NTQQGroupApi {
  }

  static async handleGroupRequest(seq: string, operateType: GroupRequestOperateTypes, reason?: string) {
-    const notify: GroupNotify = await dbUtil.getGroupNotify(seq)
+    const notify = await dbUtil.getGroupNotify(seq)
    if (!notify) {
      throw `${seq}对应的加群通知不存在`
    }
@@ -303,27 +303,27 @@ export class NTQQGroupApi {
    const session = wrapperApi.NodeIQQNTWrapperSession
    // 代码没测过
    // 需要 ob11msgid->msgId + (peer) -> msgSeq + msgRandom
-    let MsgData = await session.getMsgService().getMsgsIncludeSelf({ chatType: 2, guildId: '', peerUid: GroupCode }, msgId, 1, false)
+    let MsgData = await session?.getMsgService().getMsgsIncludeSelf({ chatType: 2, guildId: '', peerUid: GroupCode }, msgId, 1, false)
    let param = {
      groupCode: GroupCode,
      msgRandom: parseInt(MsgData.msgList[0].msgRandom),
      msgSeq: parseInt(MsgData.msgList[0].msgSeq)
    }
    // GetMsgByShoretID(ShoretID) -> MsgService.getMsgs(Peer,MsgId,1,false) -> 组出参数
-    return session.getGroupService().removeGroupEssence(param)
+    return session?.getGroupService().removeGroupEssence(param)
  }

  static async addGroupEssence(GroupCode: string, msgId: string) {
    const session = wrapperApi.NodeIQQNTWrapperSession
    // 代码没测过
    // 需要 ob11msgid->msgId + (peer) -> msgSeq + msgRandom
-    let MsgData = await session.getMsgService().getMsgsIncludeSelf({ chatType: 2, guildId: '', peerUid: GroupCode }, msgId, 1, false)
+    let MsgData = await session?.getMsgService().getMsgsIncludeSelf({ chatType: 2, guildId: '', peerUid: GroupCode }, msgId, 1, false)
    let param = {
      groupCode: GroupCode,
      msgRandom: parseInt(MsgData.msgList[0].msgRandom),
      msgSeq: parseInt(MsgData.msgList[0].msgSeq)
    }
    // GetMsgByShoretID(ShoretID) -> MsgService.getMsgs(Peer,MsgId,1,false) -> 组出参数
-    return session.getGroupService().addGroupEssence(param)
+    return session?.getGroupService().addGroupEssence(param)
  }
 }
--- a/src/ntqqapi/api/msg.ts
+++ b/src/ntqqapi/api/msg.ts
@@ -33,7 +33,7 @@ async function sendWaiter(peer: Peer, waitComplete = true, timeout: number = 100
  }
  await waitLastSend()

-  let sentMessage: RawMessage = null
+  let sentMessage: RawMessage | null = null
  sendMessagePool[peerUid] = async (rawMessage: RawMessage) => {
    delete sendMessagePool[peerUid]
    sentMessage = rawMessage
@@ -290,6 +290,6 @@ export class NTQQMsgApi {
  }
  static async getMsgsBySeqAndCount(peer: Peer, seq: string, count: number, desc: boolean, z: boolean) {
    const session = wrapperApi.NodeIQQNTWrapperSession
-    return await session.getMsgService().getMsgsBySeqAndCount(peer, seq, count, desc, z);
+    return await session?.getMsgService().getMsgsBySeqAndCount(peer, seq, count, desc, z);
  }
 }
--- a/src/ntqqapi/api/user.ts
+++ b/src/ntqqapi/api/user.ts
@@ -196,7 +196,7 @@ export class NTQQUserApi {

  static async getPSkey(domains: string[]): Promise<Map<string, string>> {
    const session = wrapperApi.NodeIQQNTWrapperSession
-    const res = await session.getTipOffService().getPskey(domains, true)
+    const res = await session?.getTipOffService().getPskey(domains, true)
    if (res.result !== 0) {
      throw new Error(`获取Pskey失败: ${res.errMsg}`)
    }
@@ -205,6 +205,6 @@ export class NTQQUserApi {

  static async getClientKey(): Promise<ClientKeyData> {
    const session = wrapperApi.NodeIQQNTWrapperSession
-    return await session.getTicketService().forceFetchClientKey('')
+    return await session?.getTicketService().forceFetchClientKey('')
  }
 }
--- a/src/ntqqapi/api/webapi.ts
+++ b/src/ntqqapi/api/webapi.ts
@@ -121,20 +121,20 @@ export interface GroupEssenceMsgRet {
 }

 export class WebApi {
-  static async getGroupEssenceMsg(GroupCode: string, page_start: string): Promise<GroupEssenceMsgRet> {
+  static async getGroupEssenceMsg(GroupCode: string, page_start: string): Promise<GroupEssenceMsgRet | undefined> {
    const { cookies: CookieValue, bkn: Bkn } = (await NTQQUserApi.getCookies('qun.qq.com'))
-    const url = 'https://qun.qq.com/cgi-bin/group_digest/digest_list?bkn=' + Bkn + '&group_code=' + GroupCode + '&page_start=' + page_start + '&page_limit=20';
-    let ret;
+    const url = 'https://qun.qq.com/cgi-bin/group_digest/digest_list?bkn=' + Bkn + '&group_code=' + GroupCode + '&page_start=' + page_start + '&page_limit=20'
+    let ret: GroupEssenceMsgRet
    try {
-      ret = await RequestUtil.HttpGetJson<GroupEssenceMsgRet>(url, 'GET', '', { 'Cookie': CookieValue });
+      ret = await RequestUtil.HttpGetJson<GroupEssenceMsgRet>(url, 'GET', '', { 'Cookie': CookieValue })
    } catch {
-      return undefined;
+      return undefined
    }
-    //console.log(url, CookieValue);
+    //console.log(url, CookieValue)
    if (ret.retcode !== 0) {
-      return undefined;
+      return undefined
    }
-    return ret;
+    return ret
  }

  static async getGroupMembers(GroupCode: string, cached: boolean = true): Promise<WebApiGroupMember[]> {
--- a/src/ntqqapi/api/window.ts
+++ b/src/ntqqapi/api/window.ts
@@ -27,7 +27,7 @@ export class NTQQWindowApi {
  static async openWindow<R = GeneralCallResult>(
    ntQQWindow: NTQQWindow,
    args: any[],
-    cbCmd: ReceiveCmd = null,
+    cbCmd: ReceiveCmd | null = null,
    autoCloseSeconds: number = 2,
  ) {
    const result = await callNTQQApi<R>({
--- a/src/ntqqapi/constructor.ts
+++ b/src/ntqqapi/constructor.ts
@@ -283,7 +283,7 @@ export class SendMsgElementConstructor {
    if (faceId >= 222){
      faceType = 2
    }
-    if (face.AniStickerType){
+    if (face?.AniStickerType){
      faceType = 3;
    }
    return {
@@ -292,10 +292,10 @@ export class SendMsgElementConstructor {
      faceElement: {
        faceIndex: faceId,
        faceType,
-        faceText: face.QDes,
-        stickerId: face.AniStickerId,
-        stickerType: face.AniStickerType,
-        packId: face.AniStickerPackId,
+        faceText: face?.QDes,
+        stickerId: face?.AniStickerId,
+        stickerType: face?.AniStickerType,
+        packId: face?.AniStickerPackId,
        sourceType: 1,
      },
    }
@@ -329,7 +329,7 @@ export class SendMsgElementConstructor {
        stickerId: '33',
        sourceType: 1,
        stickerType: 2,
-        resultId: resultId.toString(),
+        resultId: resultId?.toString(),
        surpriseId: '',
        // "randomType": 1,
      },
@@ -351,7 +351,7 @@ export class SendMsgElementConstructor {
        stickerId: '34',
        sourceType: 1,
        stickerType: 2,
-        resultId: resultId.toString(),
+        resultId: resultId?.toString(),
        surpriseId: '',
        // "randomType": 1,
      },
--- a/src/ntqqapi/hook.ts
+++ b/src/ntqqapi/hook.ts
@@ -83,7 +83,7 @@ export function hookNTQQApiReceive(window: BrowserWindow) {
    let isLogger = false
    try {
      isLogger = args[0]?.eventName?.startsWith('ns-LoggerApi')
-    } catch (e) {}
+    } catch (e) { }
    if (!isLogger) {
      try {
        HOOK_LOG && log(`received ntqq api message: ${channel}`, args)
@@ -102,7 +102,7 @@ export function hookNTQQApiReceive(window: BrowserWindow) {
                try {
                  let _ = hook.hookFunc(receiveData.payload)
                  if (hook.hookFunc.constructor.name === 'AsyncFunction') {
-                    ;(_ as Promise<void>).then()
+                    ; (_ as Promise<void>).then()
                  }
                } catch (e) {
                  log('hook error', e, receiveData.payload)
@@ -123,7 +123,7 @@ export function hookNTQQApiReceive(window: BrowserWindow) {
          delete hookApiCallbacks[callbackId]
        }
      }
-    } catch (e) {
+    } catch (e: any) {
      log('hookNTQQApiReceive error', e.stack.toString(), args)
    }
    originalSend.call(window.webContents, channel, ...args)
@@ -142,11 +142,11 @@ export function hookNTQQApiCall(window: BrowserWindow) {
      let isLogger = false
      try {
        isLogger = args[3][0].eventName.startsWith('ns-LoggerApi')
-      } catch (e) {}
+      } catch (e) { }
      if (!isLogger) {
        try {
          HOOK_LOG && log('call NTQQ api', thisArg, args)
-        } catch (e) {}
+        } catch (e) { }
        try {
          const _args: unknown[] = args[3][1]
          const cmdName: NTQQApiMethod = _args[0] as NTQQApiMethod
@@ -157,7 +157,7 @@ export function hookNTQQApiCall(window: BrowserWindow) {
                try {
                  let _ = hook.hookFunc(callParams)
                  if (hook.hookFunc.constructor.name === 'AsyncFunction') {
-                    ;(_ as Promise<void>).then()
+                    (_ as Promise<void>).then()
                  }
                } catch (e) {
                  log('hook call error', e, _args)
@@ -165,7 +165,7 @@ export function hookNTQQApiCall(window: BrowserWindow) {
              }).then()
            }
          })
-        } catch (e) {}
+        } catch (e) { }
      }
      return target.apply(thisArg, args)
    },
@@ -189,7 +189,7 @@ export function hookNTQQApiCall(window: BrowserWindow) {
      let ret = target.apply(thisArg, args)
      try {
        HOOK_LOG && log('call NTQQ invoke api return', ret)
-      } catch (e) {}
+      } catch (e) { }
      return ret
    },
  })
@@ -296,7 +296,7 @@ async function processGroupEvent(payload: { groupList: Group[] }) {

          // 判断bot是否是管理员，如果是管理员不需要从这里得知有人退群，这里的退群无法得知是主动退群还是被踢
          let bot = await getGroupMember(group.groupCode, selfInfo.uin)
-          if (bot.role == GroupMemberRole.admin || bot.role == GroupMemberRole.owner) {
+          if (bot?.role == GroupMemberRole.admin || bot?.role == GroupMemberRole.owner) {
            continue
          }
          for (const member of oldMembers) {
@@ -320,7 +320,7 @@ async function processGroupEvent(payload: { groupList: Group[] }) {
    }

    updateGroups(newGroupList, false).then()
-  } catch (e) {
+  } catch (e: any) {
    updateGroups(payload.groupList).then()
    log('更新群信息错误', e.stack.toString())
  }
@@ -328,7 +328,7 @@ async function processGroupEvent(payload: { groupList: Group[] }) {

 export async function startHook() {

-// 群列表变动
+  // 群列表变动
  registerReceiveHook<{ groupList: Group[]; updateType: number }>(ReceiveCmdS.GROUPS, (payload) => {
    // updateType 3是群列表变动，2是群成员变动
    // log("群列表变动", payload.updateType, payload.groupList)
@@ -372,10 +372,11 @@ export async function startHook() {
          )
        } else if (member.role != existMember.role) {
          log('有管理员变动通知')
-          let groupAdminNoticeEvent = new OB11GroupAdminNoticeEvent()
-          groupAdminNoticeEvent.group_id = parseInt(groupCode)
-          groupAdminNoticeEvent.user_id = parseInt(member.uin)
-          groupAdminNoticeEvent.sub_type = member.role == GroupMemberRole.admin ? 'set' : 'unset'
+          const groupAdminNoticeEvent = new OB11GroupAdminNoticeEvent(
+            member.role == GroupMemberRole.admin ? 'set' : 'unset',
+            parseInt(groupCode),
+            parseInt(member.uin)
+          )
          postOb11Event(groupAdminNoticeEvent, true)
        }
        Object.assign(existMember, member)
@@ -397,7 +398,7 @@ export async function startHook() {
    // }
  })

-// 好友列表变动
+  // 好友列表变动
  registerReceiveHook<{
    data: CategoryFriend[]
  }>(ReceiveCmdS.FRIENDS, (payload) => {
@@ -453,7 +454,7 @@ export async function startHook() {
          const pttPath = msgElement.pttElement?.filePath
          const filePath = msgElement.fileElement?.filePath
          const videoPath = msgElement.videoElement?.filePath
-          const videoThumbPath: string[] = [...msgElement.videoElement?.thumbPath.values()]
+          const videoThumbPath: string[] = [...msgElement.videoElement.thumbPath?.values()!]
          const pathList = [picPath, ...picThumbPath, pttPath, filePath, videoPath, ...videoThumbPath]
          if (msgElement.picElement) {
            pathList.push(...Object.values(msgElement.picElement.thumbPath))
@@ -471,7 +472,7 @@ export async function startHook() {
              })
            }
          }
-        }, getConfigUtil().getConfig().autoDeleteFileSecond * 1000)
+        }, getConfigUtil().getConfig().autoDeleteFileSecond! * 1000)
      }
    }
  })
@@ -486,7 +487,7 @@ export async function startHook() {
    if (sendCallback) {
      try {
        sendCallback(message)
-      } catch (e) {
+      } catch (e: any) {
        log('receive self msg error', e.stack)
      }
    }
@@ -518,8 +519,8 @@ export async function startHook() {
            NTQQMsgApi.getMsgHistory(peer, '', 20).then(({ msgList }) => {
              let lastTempMsg = msgList.pop()
              log('激活窗口之前的第一条临时会话消息:', lastTempMsg)
-              if (Date.now() / 1000 - parseInt(lastTempMsg.msgTime) < 5) {
-                OB11Constructor.message(lastTempMsg).then((r) => postOb11Event(r))
+              if (Date.now() / 1000 - parseInt(lastTempMsg?.msgTime!) < 5) {
+                OB11Constructor.message(lastTempMsg!).then((r) => postOb11Event(r))
              }
            })
          })
@@ -550,5 +551,4 @@ export async function startHook() {
      log('重新激活聊天窗口', peer, { result: r.result, errMsg: r.errMsg })
    })
  })
-
 }
--- a/src/ntqqapi/ntcall.ts
+++ b/src/ntqqapi/ntcall.ts
@@ -1,7 +1,6 @@
 import { ipcMain } from 'electron'
 import { hookApiCallbacks, ReceiveCmd, ReceiveCmdS, registerReceiveHook, removeReceiveHook } from './hook'
 import { log } from '../common/utils/log'
-import { NTQQWindow, NTQQWindowApi, NTQQWindows } from './api/window'
 import { HOOK_LOG } from '../common/config'
 import { randomUUID } from 'node:crypto'

--- a/src/onebot11/action/BaseAction.ts
+++ b/src/onebot11/action/BaseAction.ts
@@ -4,8 +4,8 @@ import { OB11Return } from '../types'

 import { log } from '../../common/utils/log'

-class BaseAction<PayloadType, ReturnDataType> {
-  actionName: ActionName
+abstract class BaseAction<PayloadType, ReturnDataType> {
+  abstract actionName: ActionName

  protected async check(payload: PayloadType): Promise<BaseCheckResult> {
    return {
@@ -21,7 +21,7 @@ class BaseAction<PayloadType, ReturnDataType> {
    try {
      const resData = await this._handle(payload)
      return OB11Response.ok(resData)
-    } catch (e) {
+    } catch (e: any) {
      log('发生错误', e)
      return OB11Response.error(e?.toString() || e?.stack?.toString() || '未知错误，可能操作超时', 200)
    }
@@ -35,7 +35,7 @@ class BaseAction<PayloadType, ReturnDataType> {
    try {
      const resData = await this._handle(payload)
      return OB11Response.ok(resData, echo)
-    } catch (e) {
+    } catch (e: any) {
      log('发生错误', e)
      return OB11Response.error(e.stack?.toString() || e.toString(), 1200, echo)
    }
--- a/src/onebot11/action/file/GetFile.ts
+++ b/src/onebot11/action/file/GetFile.ts
@@ -20,7 +20,7 @@ export interface GetFileResponse {
  base64?: string
 }

-export class GetFileBase extends BaseAction<GetFilePayload, GetFileResponse> {
+export abstract class GetFileBase extends BaseAction<GetFilePayload, GetFileResponse> {
  private getElement(msg: RawMessage, elementId: string): VideoElement | FileElement {
    let element = msg.elements.find((e) => e.elementId === elementId)
    if (!element) {
@@ -41,7 +41,7 @@ export class GetFileBase extends BaseAction<GetFilePayload, GetFileResponse> {
        // 等待文件下载完成
        msg = await dbUtil.getMsgByLongId(cache.msgId)
        log('下载完成后的msg', msg)
-        cache.filePath = this.getElement(msg, cache.elementId).filePath
+        cache.filePath = this.getElement(msg!, cache.elementId).filePath
        await checkFileReceived(cache.filePath, 10 * 1000)
        dbUtil.addFileCache(file, cache).then()
      }
--- a/src/onebot11/action/file/GetRecord.ts
+++ b/src/onebot11/action/file/GetRecord.ts
@@ -14,7 +14,7 @@ export default class GetRecord extends GetFileBase {

  protected async _handle(payload: Payload): Promise<GetFileResponse> {
    let res = await super._handle(payload)
-    res.file = await decodeSilk(res.file, payload.out_format)
+    res.file = await decodeSilk(res.file!, payload.out_format)
    res.file_name = path.basename(res.file)
    res.file_size = fs.statSync(res.file).size.toString()
    if (getConfigUtil().getConfig().enableLocalFile2Url){
--- a/src/onebot11/action/go-cqhttp/GetForwardMsg.ts
+++ b/src/onebot11/action/go-cqhttp/GetForwardMsg.ts
@@ -1,6 +1,6 @@
 import BaseAction from '../BaseAction'
 import { OB11ForwardMessage, OB11Message, OB11MessageData } from '../../types'
-import { NTQQMsgApi, Peer } from '../../../ntqqapi/api'
+import { NTQQMsgApi } from '@/ntqqapi/api'
 import { dbUtil } from '../../../common/db'
 import { OB11Constructor } from '../../constructor'
 import { ActionName } from '../types'
@@ -37,12 +37,13 @@ export class GoCQHTTGetForwardMsgAction extends BaseAction<Payload, any> {
    let messages = await Promise.all(
      msgList.map(async (msg) => {
        let resMsg = await OB11Constructor.message(msg)
-        resMsg.message_id = await dbUtil.addMsg(msg)
+        resMsg.message_id = (await dbUtil.addMsg(msg))!
        return resMsg
      }),
    )
-    messages.map((msg) => {
-      ;(<OB11ForwardMessage>msg).content = msg.message
+    messages.map(v => {
+      const msg = v as Partial<OB11ForwardMessage>
+      msg.content = msg.message
      delete msg.message
    })
    return { messages }
--- a/src/onebot11/action/go-cqhttp/GetGroupMsgHistory.ts
+++ b/src/onebot11/action/go-cqhttp/GetGroupMsgHistory.ts
@@ -6,7 +6,6 @@ import { ChatType } from '../../../ntqqapi/types'
 import { dbUtil } from '../../../common/db'
 import { NTQQMsgApi } from '../../../ntqqapi/api/msg'
 import { OB11Constructor } from '../../constructor'
-import { log } from '../../../common/utils'

 interface Payload {
  group_id: number
--- a/src/onebot11/action/go-cqhttp/UploadFile.ts
+++ b/src/onebot11/action/go-cqhttp/UploadFile.ts
@@ -1,11 +1,12 @@
 import BaseAction from '../BaseAction'
-import { getGroup, getUidByUin } from '../../../common/data'
+import { getGroup, getUidByUin } from '@/common/data'
 import { ActionName } from '../types'
-import { SendMsgElementConstructor } from '../../../ntqqapi/constructor'
-import { ChatType, SendFileElement } from '../../../ntqqapi/types'
+import { SendMsgElementConstructor } from '@/ntqqapi/constructor'
+import { ChatType, SendFileElement } from '@/ntqqapi/types'
 import fs from 'fs'
-import { NTQQMsgApi, Peer } from '../../../ntqqapi/api/msg'
-import { uri2local } from '../../../common/utils'
+import { NTQQMsgApi } from '@/ntqqapi/api/msg'
+import { uri2local } from '@/common/utils'
+import { Peer } from '@/ntqqapi/types'

 interface Payload {
  user_id: number
@@ -20,9 +21,9 @@ class GoCQHTTPUploadFileBase extends BaseAction<Payload, null> {

  getPeer(payload: Payload): Peer {
    if (payload.user_id) {
-      return { chatType: ChatType.friend, peerUid: getUidByUin(payload.user_id.toString()) }
+      return { chatType: ChatType.friend, peerUid: getUidByUin(payload.user_id.toString())! }
    }
-    return { chatType: ChatType.group, peerUid: payload.group_id.toString() }
+    return { chatType: ChatType.group, peerUid: payload.group_id?.toString()! }
  }

  protected async _handle(payload: Payload): Promise<null> {
--- a/src/onebot11/action/group/GetGroupEssence.ts
+++ b/src/onebot11/action/group/GetGroupEssence.ts
@@ -1,24 +1,24 @@
-import { GroupEssenceMsgRet, WebApi } from "@/ntqqapi/api";
-import BaseAction from "../BaseAction";
-import { ActionName } from "../types";
+import { GroupEssenceMsgRet, WebApi } from '@/ntqqapi/api'
+import BaseAction from '../BaseAction'
+import { ActionName } from '../types'

 interface PayloadType {
-  group_id: number;
-  pages?: number;
+  group_id: number
+  pages?: number
 }

-export class GetGroupEssence extends BaseAction<PayloadType, GroupEssenceMsgRet> {
-  actionName = ActionName.GoCQHTTP_GetEssenceMsg;
+export class GetGroupEssence extends BaseAction<PayloadType, GroupEssenceMsgRet | void> {
+  actionName = ActionName.GoCQHTTP_GetEssenceMsg

  protected async _handle(payload: PayloadType) {
    throw '此 api 暂不支持'
-    const ret = await WebApi.getGroupEssenceMsg(payload.group_id.toString(), payload.pages?.toString() || '0');
+    const ret = await WebApi.getGroupEssenceMsg(payload.group_id.toString(), payload.pages?.toString() || '0')
    if (!ret) {
-      throw new Error('获取失败');
+      throw new Error('获取失败')
    }
    // ret.map((item) => {
    //
    // })
-    return ret;
+    return ret
  }
 }
--- a/src/onebot11/action/group/GetGroupHonorInfo.ts
+++ b/src/onebot11/action/group/GetGroupHonorInfo.ts
@@ -1,22 +1,23 @@
-import { WebApi, WebHonorType } from "@/ntqqapi/api";
-import { ActionName } from "../types";
-import BaseAction from "../BaseAction";
+import { WebApi, WebHonorType } from '@/ntqqapi/api'
+import { ActionName } from '../types'
+import BaseAction from '../BaseAction'

 interface Payload {
-  group_id: number,
+  group_id: number
  type?: WebHonorType
 }
+
 export class GetGroupHonorInfo extends BaseAction<Payload, Array<any>> {
-  actionName = ActionName.GetGroupHonorInfo;
+  actionName = ActionName.GetGroupHonorInfo

  protected async _handle(payload: Payload) {
-    // console.log(await NTQQUserApi.getRobotUinRange());
+    // console.log(await NTQQUserApi.getRobotUinRange())
    if (!payload.group_id) {
-      throw '缺少参数group_id';
+      throw '缺少参数group_id'
    }
    if (!payload.type) {
-      payload.type = WebHonorType.ALL;
+      payload.type = WebHonorType.ALL
    }
-    return await WebApi.getGroupHonorInfo(payload.group_id.toString(), payload.type);
+    return await WebApi.getGroupHonorInfo(payload.group_id.toString(), payload.type)
  }
 }
--- a/src/onebot11/action/group/SendGroupMsg.ts
+++ b/src/onebot11/action/group/SendGroupMsg.ts
@@ -2,13 +2,11 @@ import SendMsg from '../msg/SendMsg'
 import { ActionName, BaseCheckResult } from '../types'
 import { OB11PostSendMsg } from '../../types'

-import { log } from '../../../common/utils/log'
-
 class SendGroupMsg extends SendMsg {
  actionName = ActionName.SendGroupMsg

  protected async check(payload: OB11PostSendMsg): Promise<BaseCheckResult> {
-    delete payload.user_id
+    delete (payload as Partial<OB11PostSendMsg>).user_id
    payload.message_type = 'group'
    return super.check(payload)
  }
--- a/src/onebot11/action/msg/ForwardSingleMsg.ts
+++ b/src/onebot11/action/msg/ForwardSingleMsg.ts
@@ -1,9 +1,10 @@
 import BaseAction from '../BaseAction'
-import { NTQQMsgApi, Peer } from '../../../ntqqapi/api'
-import { ChatType, RawMessage } from '../../../ntqqapi/types'
-import { dbUtil } from '../../../common/db'
-import { getUidByUin } from '../../../common/data'
+import { NTQQMsgApi } from '@/ntqqapi/api'
+import { ChatType, RawMessage } from '@/ntqqapi/types'
+import { dbUtil } from '@/common/db'
+import { getUidByUin } from '@/common/data'
 import { ActionName } from '../types'
+import { Peer } from '@/ntqqapi/types'

 interface Payload {
  message_id: number
@@ -15,16 +16,16 @@ interface Response {
  message_id: number
 }

-class ForwardSingleMsg extends BaseAction<Payload, Response> {
+abstract class ForwardSingleMsg extends BaseAction<Payload, Response> {
  protected async getTargetPeer(payload: Payload): Promise<Peer> {
    if (payload.user_id) {
-      return { chatType: ChatType.friend, peerUid: getUidByUin(payload.user_id.toString()) }
+      return { chatType: ChatType.friend, peerUid: getUidByUin(payload.user_id.toString())! }
    }
    return { chatType: ChatType.group, peerUid: payload.group_id.toString() }
  }

  protected async _handle(payload: Payload): Promise<Response> {
-    const msg = await dbUtil.getMsgByShortId(payload.message_id)
+    const msg = (await dbUtil.getMsgByShortId(payload.message_id))!
    const peer = await this.getTargetPeer(payload)
    const sentMsg = await NTQQMsgApi.forwardMsg(
      {
@@ -35,7 +36,7 @@ class ForwardSingleMsg extends BaseAction<Payload, Response> {
      [msg.msgId],
    )
    const ob11MsgId = await dbUtil.addMsg(sentMsg)
-    return {message_id: ob11MsgId}
+    return { message_id: ob11MsgId! }
  }
 }

--- a/src/onebot11/action/msg/SendMsg.ts
+++ b/src/onebot11/action/msg/SendMsg.ts
@@ -142,7 +142,7 @@ export async function createSendElements(
                  .RemainAtAllCountForUin
                log(`群${groupCode}剩余at全体次数`, remainAtAllCount)
                const self = await getGroupMember((target as Group)?.groupCode, selfInfo.uin)
-                isAdmin = self.role === GroupMemberRole.admin || self.role === GroupMemberRole.owner
+                isAdmin = self?.role === GroupMemberRole.admin || self?.role === GroupMemberRole.owner
              } catch (e) {
              }
            }
@@ -171,8 +171,8 @@ export async function createSendElements(
              SendMsgElementConstructor.reply(
                replyMsg.msgSeq,
                replyMsg.msgId,
-                replyMsg.senderUin,
-                replyMsg.senderUin,
+                replyMsg.senderUin!,
+                replyMsg.senderUin!,
              ),
            )
          }
@@ -251,7 +251,7 @@ export async function createSendElements(
                await SendMsgElementConstructor.pic(
                  path,
                  sendMsg.data.summary || '',
-                  <PicSubType>parseInt(sendMsg.data?.subType?.toString()) || 0,
+                  <PicSubType>parseInt(sendMsg.data?.subType?.toString()!) || 0,
                ),
              )
            }
@@ -266,16 +266,16 @@ export async function createSendElements(
      case OB11MessageDataType.poke: {
        let qq = sendMsg.data?.qq || sendMsg.data?.id
        if (qq) {
-          if ('groupCode' in target) {
+          if ('groupCode' in target!) {
            crychic.sendGroupPoke(target.groupCode, qq.toString())
          }
          else {
            if (!qq) {
-              qq = parseInt(target.uin)
+              qq = parseInt(target?.uin!)
            }
            crychic.sendFriendPoke(qq.toString())
          }
-          sendElements.push(SendMsgElementConstructor.poke('', ''))
+          sendElements.push(SendMsgElementConstructor.poke('', '')!)
        }
      }
        break
@@ -387,10 +387,10 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
    let group: Group | undefined = undefined
    let friend: Friend | undefined = undefined
    const genGroupPeer = async () => {
-      group = await getGroup(payload.group_id.toString())
+      group = await getGroup(payload.group_id?.toString()!)
      peer.chatType = ChatType.group
      // peer.name = group.name
-      peer.peerUid = group.groupCode
+      peer.peerUid = group?.groupCode!
    }

    const genFriendPeer = () => {
@@ -429,8 +429,8 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
    if (this.getSpecialMsgNum(messages, OB11MessageDataType.node)) {
      try {
        const returnMsg = await this.handleForwardNode(peer, messages as OB11MessageNode[], group)
-        return { message_id: returnMsg.msgShortId }
-      } catch (e) {
+        return { message_id: returnMsg?.msgShortId! }
+      } catch (e: any) {
        throw '发送转发消息失败 ' + e.toString()
      }
    }
@@ -447,8 +447,9 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
        }
        const postData: MusicSignPostData = { ...music.data }
        if (type === 'custom' && music.data.content) {
-          ;(postData as CustomMusicSignPostData).singer = music.data.content
-          delete (postData as OB11MessageCustomMusic['data']).content
+          const data = postData as CustomMusicSignPostData
+          data.singer = music.data.content
+          delete (data as OB11MessageCustomMusic['data']).content
        }
        if (type === 'custom') {
          const customMusicData = music.data as CustomMusicSignPostData
@@ -493,7 +494,7 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
    const returnMsg = await sendMsg(peer, sendElements, deleteAfterSentFiles)
    deleteAfterSentFiles.map((f) => fs.unlink(f, () => {
    }))
-    return { message_id: returnMsg.msgShortId }
+    return { message_id: returnMsg.msgShortId! }
  }

  private getSpecialMsgNum(message: OB11MessageData[], msgType: OB11MessageDataType): number {
@@ -503,7 +504,7 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
    return 0
  }

-  private async cloneMsg(msg: RawMessage): Promise<RawMessage> {
+  private async cloneMsg(msg: RawMessage): Promise<RawMessage | undefined> {
    log('克隆的目标消息', msg)
    let sendElements: SendMessageElement[] = []
    for (const ele of msg.elements) {
@@ -549,11 +550,11 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
      if (nodeId) {
        let nodeMsg = await dbUtil.getMsgByShortId(parseInt(nodeId))
        if (!needClone) {
-          nodeMsgIds.push(nodeMsg.msgId)
+          nodeMsgIds.push(nodeMsg?.msgId!)
        }
        else {
-          if (nodeMsg.peerUid !== selfInfo.uid) {
-            const cloneMsg = await this.cloneMsg(nodeMsg)
+          if (nodeMsg?.peerUid !== selfInfo.uid) {
+            const cloneMsg = await this.cloneMsg(nodeMsg!)
            if (cloneMsg) {
              nodeMsgIds.push(cloneMsg.msgId)
            }
@@ -605,7 +606,7 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {

    // 检查srcPeer是否一致，不一致则需要克隆成自己的消息, 让所有srcPeer都变成自己的，使其保持一致才能够转发
    let nodeMsgArray: Array<RawMessage> = []
-    let srcPeer: Peer = null
+    let srcPeer: Peer | null = null
    let needSendSelf = false
    for (const [index, msgId] of nodeMsgIds.entries()) {
      const nodeMsg = await dbUtil.getMsgByLongId(msgId)
@@ -648,7 +649,7 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
    }
    try {
      log('开发转发', nodeMsgIds)
-      return await NTQQMsgApi.multiForwardMsg(srcPeer, destPeer, nodeMsgIds)
+      return await NTQQMsgApi.multiForwardMsg(srcPeer!, destPeer, nodeMsgIds)
    } catch (e) {
      log('forward failed', e)
      return null
--- a/src/onebot11/action/quick-operation.ts
+++ b/src/onebot11/action/quick-operation.ts
@@ -71,17 +71,17 @@ async function handleMsg(msg: OB11Message, quickAction: QuickOperationPrivateMes
    peerUid: msg.user_id.toString(),
  }
  if (msg.message_type == 'private') {
-    peer.peerUid = getUidByUin(msg.user_id.toString())
+    peer.peerUid = getUidByUin(msg.user_id.toString())!
    if (msg.sub_type === 'group') {
      peer.chatType = ChatType.temp
    }
  }
  else {
    peer.chatType = ChatType.group
-    peer.peerUid = msg.group_id.toString()
+    peer.peerUid = msg.group_id?.toString()!
  }
  if (reply) {
-    let group: Group = null
+    let group: Group | null = null
    let replyMessage: OB11MessageData[] = []
    if (ob11Config.enableQOAutoQuote) {
      replyMessage.push({
@@ -93,7 +93,7 @@ async function handleMsg(msg: OB11Message, quickAction: QuickOperationPrivateMes
    }

    if (msg.message_type == 'group') {
-      group = await getGroup(msg.group_id.toString())
+      group = (await getGroup(msg.group_id?.toString()!))!
      if ((quickAction as QuickOperationGroupMessage).at_sender) {
        replyMessage.push({
          type: 'at',
@@ -104,7 +104,7 @@ async function handleMsg(msg: OB11Message, quickAction: QuickOperationPrivateMes
      }
    }
    replyMessage = replyMessage.concat(convertMessage2List(reply, quickAction.auto_escape))
-    const { sendElements, deleteAfterSentFiles } = await createSendElements(replyMessage, group)
+    const { sendElements, deleteAfterSentFiles } = await createSendElements(replyMessage, group!)
    log(`发送消息给`, peer, sendElements)
    sendMsg(peer, sendElements, deleteAfterSentFiles, false).then().catch(log)
  }
@@ -112,15 +112,15 @@ async function handleMsg(msg: OB11Message, quickAction: QuickOperationPrivateMes
    const groupMsgQuickAction = quickAction as QuickOperationGroupMessage
    // handle group msg
    if (groupMsgQuickAction.delete) {
-      NTQQMsgApi.recallMsg(peer, [rawMessage.msgId]).then().catch(log)
+      NTQQMsgApi.recallMsg(peer, [rawMessage?.msgId!]).then().catch(log)
    }
    if (groupMsgQuickAction.kick) {
-      NTQQGroupApi.kickMember(peer.peerUid, [rawMessage.senderUid]).then().catch(log)
+      NTQQGroupApi.kickMember(peer.peerUid, [rawMessage?.senderUid!]).then().catch(log)
    }
    if (groupMsgQuickAction.ban) {
      NTQQGroupApi.banMember(peer.peerUid, [
        {
-          uid: rawMessage.senderUid,
+          uid: rawMessage?.senderUid!,
          timeStamp: groupMsgQuickAction.ban_duration || 60 * 30,
        },
      ]).then().catch(log)
--- a/src/onebot11/action/system/CleanCache.ts
+++ b/src/onebot11/action/system/CleanCache.ts
@@ -1,9 +1,8 @@
 import BaseAction from '../BaseAction'
 import { ActionName } from '../types'
-import fs from 'fs'
-import Path from 'path'
+import fs from 'node:fs'
+import Path from 'node:path'
 import { ChatType, ChatCacheListItemBasic, CacheFileType } from '../../../ntqqapi/types'
-import { dbUtil } from '../../../common/db'
 import { NTQQFileApi, NTQQFileCacheApi } from '../../../ntqqapi/api/file'

 export default class CleanCache extends BaseAction<void, void> {
@@ -12,14 +11,16 @@ export default class CleanCache extends BaseAction<void, void> {
  protected _handle(): Promise<void> {
    return new Promise<void>(async (res, rej) => {
      try {
-        // dbUtil.clearCache();
+        // dbUtil.clearCache()
        const cacheFilePaths: string[] = []

        await NTQQFileCacheApi.setCacheSilentScan(false)

        cacheFilePaths.push(await NTQQFileCacheApi.getHotUpdateCachePath())
        cacheFilePaths.push(await NTQQFileCacheApi.getDesktopTmpPath())
-        ;(await NTQQFileCacheApi.getCacheSessionPathList()).forEach((e) => cacheFilePaths.push(e.value))
+
+        const list = await NTQQFileCacheApi.getCacheSessionPathList()
+        list.forEach((e) => cacheFilePaths.push(e.value))

        // await NTQQApi.addCacheScannedPaths(); // XXX: 调用就崩溃，原因目前还未知
        const cacheScanResult = await NTQQFileCacheApi.scanCache()
--- a/src/onebot11/action/system/GetStatus.ts
+++ b/src/onebot11/action/system/GetStatus.ts
@@ -8,7 +8,7 @@ export default class GetStatus extends BaseAction<any, OB11Status> {

  protected async _handle(payload: any): Promise<OB11Status> {
    return {
-      online: selfInfo.online,
+      online: selfInfo.online!,
      good: true,
    }
  }
--- a/src/onebot11/action/user/SendLike.ts
+++ b/src/onebot11/action/user/SendLike.ts
@@ -19,7 +19,7 @@ export default class SendLike extends BaseAction<Payload, null> {
      const friend = await getFriend(qq)
      let uid: string
      if (!friend) {
-        uid = getUidByUin(qq)
+        uid = getUidByUin(qq)!
      } else {
        uid = friend.uid
      }
--- a/src/onebot11/constructor.ts
+++ b/src/onebot11/constructor.ts
@@ -39,7 +39,7 @@ import { NTQQFileApi } from '../ntqqapi/api/file'
 import { NTQQMsgApi } from '../ntqqapi/api/msg'
 import { calcQQLevel } from '../common/utils/qqlevel'
 import { log } from '../common/utils/log'
-import { sleep } from '../common/utils/helper'
+import { isNull, sleep } from '../common/utils/helper'
 import { getConfigUtil } from '../common/config'
 import { OB11GroupTitleEvent } from './event/notice/OB11GroupTitleEvent'
 import { OB11GroupCardEvent } from './event/notice/OB11GroupCardEvent'
@@ -67,14 +67,14 @@ export class OB11Constructor {
    const message_type = msg.chatType == ChatType.group ? 'group' : 'private'
    const resMsg: OB11Message = {
      self_id: parseInt(selfInfo.uin),
-      user_id: parseInt(msg.senderUin),
+      user_id: parseInt(msg.senderUin!),
      time: parseInt(msg.msgTime) || Date.now(),
-      message_id: msg.msgShortId,
-      real_id: msg.msgShortId,
-      message_seq: msg.msgShortId,
+      message_id: msg.msgShortId!,
+      real_id: msg.msgShortId!,
+      message_seq: msg.msgShortId!,
      message_type: msg.chatType == ChatType.group ? 'group' : 'private',
      sender: {
-        user_id: parseInt(msg.senderUin),
+        user_id: parseInt(msg.senderUin!),
        nickname: msg.sendNickName,
        card: msg.sendMemberName || '',
      },
@@ -91,7 +91,7 @@ export class OB11Constructor {
    if (msg.chatType == ChatType.group) {
      resMsg.sub_type = 'normal'
      resMsg.group_id = parseInt(msg.peerUin)
-      const member = await getGroupMember(msg.peerUin, msg.senderUin)
+      const member = await getGroupMember(msg.peerUin, msg.senderUin!)
      if (member) {
        resMsg.sender.role = OB11Constructor.groupMemberRole(member.role)
        resMsg.sender.nickname = member.nick
@@ -99,7 +99,7 @@ export class OB11Constructor {
    }
    else if (msg.chatType == ChatType.friend) {
      resMsg.sub_type = 'friend'
-      const friend = await getFriend(msg.senderUin)
+      const friend = await getFriend(msg.senderUin!)
      if (friend) {
        resMsg.sender.nickname = friend.nick
      }
@@ -140,7 +140,7 @@ export class OB11Constructor {
        message_data = {
          type: OB11MessageDataType.at,
          data: {
-            qq,
+            qq: qq!,
            name
          }
        }
@@ -160,12 +160,12 @@ export class OB11Constructor {
          const replyMsg = await dbUtil.getMsgBySeqId(element.replyElement.replayMsgSeq)
          // log("找到回复消息", replyMsg.msgShortId, replyMsg.msgId)
          if (replyMsg) {
-            message_data['data']['id'] = replyMsg.msgShortId.toString()
+            message_data['data']['id'] = replyMsg.msgShortId?.toString()
          }
          else {
            continue
          }
-        } catch (e) {
+        } catch (e: any) {
          log('获取不到引用的消息', e.stack, element.replyElement.replayMsgSeq)
        }
      }
@@ -221,12 +221,12 @@ export class OB11Constructor {
          )
        }
        dbUtil
-          .addFileCache(videoOrFileElement.fileUuid, {
+          .addFileCache(videoOrFileElement.fileUuid!, {
            msgId: msg.msgId,
            elementId: element.elementId,
            fileName: videoOrFileElement.fileName,
            filePath: videoOrFileElement.filePath,
-            fileSize: videoOrFileElement.fileSize,
+            fileSize: videoOrFileElement.fileSize!,
            downloadFunc: async () => {
              await NTQQFileApi.downloadMedia(
                msg.msgId,
@@ -234,7 +234,7 @@ export class OB11Constructor {
                msg.peerUid,
                element.elementId,
                ob11MessageDataType == OB11MessageDataType.video
-                  ? (videoOrFileElement as VideoElement).thumbPath.get(0)
+                  ? (videoOrFileElement as VideoElement).thumbPath?.get(0)
                  : null,
                videoOrFileElement.filePath,
              )
@@ -297,7 +297,7 @@ export class OB11Constructor {
        message_data['data']['emoji_id'] = element.marketFaceElement.emojiId
        message_data['data']['emoji_package_id'] = String(element.marketFaceElement.emojiPackageId)
        message_data['data']['key'] = element.marketFaceElement.key
-        mFaceCache.set(md5, element.marketFaceElement.faceName)
+        mFaceCache.set(md5, element.marketFaceElement.faceName!)
      }
      else if (element.markdownElement) {
        message_data['type'] = OB11MessageDataType.markdown
@@ -321,7 +321,7 @@ export class OB11Constructor {
    return resMsg
  }

-  static async PrivateEvent(msg: RawMessage): Promise<OB11BaseNoticeEvent> {
+  static async PrivateEvent(msg: RawMessage): Promise<OB11BaseNoticeEvent | void> {
    if (msg.chatType !== ChatType.friend) {
      return
    }
@@ -350,7 +350,7 @@ export class OB11Constructor {
    }
  }

-  static async GroupEvent(msg: RawMessage): Promise<OB11GroupNoticeEvent> {
+  static async GroupEvent(msg: RawMessage): Promise<OB11GroupNoticeEvent | void> {
    if (msg.chatType !== ChatType.group) {
      return
    }
@@ -360,10 +360,10 @@ export class OB11Constructor {
        const event = new OB11GroupCardEvent(
          parseInt(msg.peerUid),
          parseInt(msg.senderUin),
-          msg.sendMemberName,
+          msg.sendMemberName!,
          member.cardName,
        )
-        member.cardName = msg.sendMemberName
+        member.cardName = msg.sendMemberName!
        return event
      }
    }
@@ -393,10 +393,10 @@ export class OB11Constructor {
        }
        else if (groupElement.type === TipGroupElementType.ban) {
          log('收到群群员禁言提示', groupElement)
-          const memberUid = groupElement.shutUp.member.uid
-          const adminUid = groupElement.shutUp.admin.uid
+          const memberUid = groupElement.shutUp?.member.uid
+          const adminUid = groupElement.shutUp?.admin.uid
          let memberUin: string = ''
-          let duration = parseInt(groupElement.shutUp.duration)
+          let duration = parseInt(groupElement.shutUp?.duration!)
          let sub_type: 'ban' | 'lift_ban' = duration > 0 ? 'ban' : 'lift_ban'
          if (memberUid) {
            memberUin =
@@ -410,7 +410,7 @@ export class OB11Constructor {
            }
          }
          const adminUin =
-            (await getGroupMember(msg.peerUid, adminUid))?.uin || (await NTQQUserApi.getUserDetailInfo(adminUid))?.uin
+            (await getGroupMember(msg.peerUid, adminUid!))?.uin || (await NTQQUserApi.getUserDetailInfo(adminUid!))?.uin
          if (memberUin && adminUin) {
            return new OB11GroupBanEvent(
              parseInt(msg.peerUid),
@@ -443,8 +443,8 @@ export class OB11Constructor {
        }
      }
      else if (element.fileElement) {
-        return new OB11GroupUploadNoticeEvent(parseInt(msg.peerUid), parseInt(msg.senderUin), {
-          id: element.fileElement.fileUuid,
+        return new OB11GroupUploadNoticeEvent(parseInt(msg.peerUid), parseInt(msg.senderUin!), {
+          id: element.fileElement.fileUuid!,
          name: element.fileElement.fileName,
          size: parseInt(element.fileElement.fileSize),
          busid: element.fileElement.fileBizId || 0,
@@ -476,13 +476,13 @@ export class OB11Constructor {
            if (!msg) {
              return
            }
-            return new OB11GroupMsgEmojiLikeEvent(parseInt(msg.peerUid), parseInt(senderUin), msg.msgShortId, [
+            return new OB11GroupMsgEmojiLikeEvent(parseInt(msg.peerUid), parseInt(senderUin), msg.msgShortId!, [
              {
                emoji_id: emojiId,
                count: 1,
              },
            ])
-          } catch (e) {
+          } catch (e: any) {
            log('解析表情回应消息失败', e.stack)
          }
        }
@@ -495,8 +495,8 @@ export class OB11Constructor {
          if (xmlElement?.content) {
            const regex = /jp="(\d+)"/g

-            let matches = []
-            let match = null
+            const matches: string[] = []
+            let match: RegExpExecArray | null = null

            while ((match = regex.exec(xmlElement.content)) !== null) {
              matches.push(match[1])
@@ -557,20 +557,22 @@ export class OB11Constructor {
            }
            let msgList = (await NTQQMsgApi.getMsgsBySeqAndCount(Peer, msgSeq.toString(), 1, true, true)).msgList
            const origMsg = await dbUtil.getMsgByLongId(msgList[0].msgId)
-            const postMsg = await dbUtil.getMsgBySeqId(origMsg.msgSeq) ?? origMsg
+            const postMsg = await dbUtil.getMsgBySeqId(origMsg?.msgSeq!) ?? origMsg
            // 如果 senderUin 为 0，可能是 历史消息 或 自身消息
            if (msgList[0].senderUin === '0') {
              msgList[0].senderUin = postMsg?.senderUin ?? selfInfo.uin
            }
-            return new OB11GroupEssenceEvent(parseInt(msg.peerUid), postMsg.msgShortId, parseInt(msgList[0].senderUin))
+            return new OB11GroupEssenceEvent(parseInt(msg.peerUid), postMsg?.msgShortId!, parseInt(msgList[0].senderUin))
            // 获取MsgSeq+Peer可获取具体消息
          }
          if (grayTipElement.jsonGrayTipElement.busiId == 2407) {
            const memberUin = json.items[1].param[0]
            const title = json.items[3].txt
            log('收到群成员新头衔消息', json)
-            getGroupMember(msg.peerUid, memberUin).then((member) => {
-              member.memberSpecialTitle = title
+            getGroupMember(msg.peerUid, memberUin).then(member => {
+              if (!isNull(member)) {
+                member.memberSpecialTitle = title
+              }
            })
            return new OB11GroupTitleEvent(parseInt(msg.peerUid), parseInt(memberUin), title)
          }
@@ -592,16 +594,16 @@ export class OB11Constructor {
    const revokeElement = msgElement.grayTipElement.revokeElement
    if (isGroup) {
      const operator = await getGroupMember(msg.peerUid, revokeElement.operatorUid)
-      const sender = await getGroupMember(msg.peerUid, revokeElement.origMsgSenderUid)
+      const sender = await getGroupMember(msg.peerUid, revokeElement.origMsgSenderUid!)
      return new OB11GroupRecallNoticeEvent(
        parseInt(msg.peerUid),
-        parseInt(sender.uin),
-        parseInt(operator.uin),
-        msg.msgShortId,
+        parseInt(sender?.uin!),
+        parseInt(operator?.uin!),
+        msg.msgShortId!,
      )
    }
    else {
-      return new OB11FriendRecallNoticeEvent(parseInt(msg.senderUin), msg.msgShortId)
+      return new OB11FriendRecallNoticeEvent(parseInt(msg.senderUin!), msg.msgShortId!)
    }
  }

@@ -610,7 +612,7 @@ export class OB11Constructor {
      user_id: parseInt(friend.uin),
      nickname: friend.nick,
      remark: friend.remark,
-      sex: OB11Constructor.sex(friend.sex),
+      sex: OB11Constructor.sex(friend.sex!),
      level: (friend.qqLevel && calcQQLevel(friend.qqLevel)) || 0,
    }
  }
@@ -668,7 +670,7 @@ export class OB11Constructor {
      user_id: parseInt(member.uin),
      nickname: member.nick,
      card: member.cardName,
-      sex: OB11Constructor.sex(member.sex),
+      sex: OB11Constructor.sex(member.sex!),
      age: 0,
      area: '',
      level: 0,
@@ -690,7 +692,7 @@ export class OB11Constructor {
      ...user,
      user_id: parseInt(user.uin),
      nickname: user.nick,
-      sex: OB11Constructor.sex(user.sex),
+      sex: OB11Constructor.sex(user.sex!),
      age: 0,
      qid: user.qid,
      login_days: 0,
--- a/src/onebot11/event/OB11BaseEvent.ts
+++ b/src/onebot11/event/OB11BaseEvent.ts
@@ -11,5 +11,5 @@ export enum EventType {
 export abstract class OB11BaseEvent {
  time = Math.floor(Date.now() / 1000)
  self_id = parseInt(selfInfo.uin)
-  post_type: EventType
+  abstract post_type: EventType
 }
--- a/src/onebot11/event/meta/OB11BaseMetaEvent.ts
+++ b/src/onebot11/event/meta/OB11BaseMetaEvent.ts
@@ -2,5 +2,5 @@ import { EventType, OB11BaseEvent } from '../OB11BaseEvent'

 export abstract class OB11BaseMetaEvent extends OB11BaseEvent {
  post_type = EventType.META
-  meta_event_type: string
+  abstract meta_event_type: string
 }
--- a/src/onebot11/event/notice/OB11GroupAdminNoticeEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupAdminNoticeEvent.ts
@@ -2,5 +2,14 @@ import { OB11GroupNoticeEvent } from './OB11GroupNoticeEvent'

 export class OB11GroupAdminNoticeEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_admin'
-  sub_type: 'set' | 'unset' // "set" | "unset"
+  sub_type: 'set' | 'unset'
+  group_id: number
+  user_id: number
+
+  constructor(subType: 'set' | 'unset', groupId: number, userId: number) {
+    super()
+    this.sub_type = subType
+    this.group_id = groupId
+    this.user_id = userId
+  }
 }
--- a/src/onebot11/event/notice/OB11GroupBanEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupBanEvent.ts
@@ -5,6 +5,8 @@ export class OB11GroupBanEvent extends OB11GroupNoticeEvent {
  operator_id: number
  duration: number
  sub_type: 'ban' | 'lift_ban'
+  group_id: number
+  user_id: number

  constructor(groupId: number, userId: number, operatorId: number, duration: number, sub_type: 'ban' | 'lift_ban') {
    super()
--- a/src/onebot11/event/notice/OB11GroupCardEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupCardEvent.ts
@@ -4,6 +4,8 @@ export class OB11GroupCardEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_card'
  card_new: string
  card_old: string
+  group_id: number
+  user_id: number

  constructor(groupId: number, userId: number, cardNew: string, cardOld: string) {
    super()
--- a/src/onebot11/event/notice/OB11GroupDecreaseEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupDecreaseEvent.ts
@@ -6,6 +6,8 @@ export class OB11GroupDecreaseEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_decrease'
  sub_type: GroupDecreaseSubType = 'leave' // TODO: 实现其他几种子类型的识别 ("leave" | "kick" | "kick_me")
  operator_id: number
+  group_id: number
+  user_id: number

  constructor(groupId: number, userId: number, operatorId: number, subType: GroupDecreaseSubType = 'leave') {
    super()
--- a/src/onebot11/event/notice/OB11GroupEssenceEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupEssenceEvent.ts
@@ -1,14 +1,16 @@
 import { OB11GroupNoticeEvent } from './OB11GroupNoticeEvent';
 export class OB11GroupEssenceEvent extends OB11GroupNoticeEvent {
-  notice_type = 'essence';
-  message_id: number;
-  sender_id: number;
-  sub_type: 'add' | 'delete' = 'add';
+  notice_type = 'essence'
+  message_id: number
+  sender_id: number
+  sub_type: 'add' | 'delete' = 'add'
+  group_id: number
+  user_id: number = 0

  constructor(groupId: number, message_id: number, sender_id: number) {
-    super();
-    this.group_id = groupId;
-    this.message_id = message_id;
-    this.sender_id = sender_id;
+    super()
+    this.group_id = groupId
+    this.message_id = message_id
+    this.sender_id = sender_id
  }
 }
--- a/src/onebot11/event/notice/OB11GroupIncreaseEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupIncreaseEvent.ts
@@ -1,10 +1,14 @@
 import { OB11GroupNoticeEvent } from './OB11GroupNoticeEvent'

 type GroupIncreaseSubType = 'approve' | 'invite'
+
 export class OB11GroupIncreaseEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_increase'
  operator_id: number
  sub_type: GroupIncreaseSubType
+  group_id: number
+  user_id: number
+
  constructor(groupId: number, userId: number, operatorId: number, subType: GroupIncreaseSubType = 'approve') {
    super()
    this.group_id = groupId
--- a/src/onebot11/event/notice/OB11GroupNoticeEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupNoticeEvent.ts
@@ -1,6 +1,7 @@
 import { OB11BaseNoticeEvent } from './OB11BaseNoticeEvent'

 export abstract class OB11GroupNoticeEvent extends OB11BaseNoticeEvent {
-  group_id: number
-  user_id: number
+  abstract group_id: number
+  abstract user_id: number
+  abstract notice_type: string
 }
--- a/src/onebot11/event/notice/OB11GroupRecallNoticeEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupRecallNoticeEvent.ts
@@ -4,6 +4,8 @@ export class OB11GroupRecallNoticeEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_recall'
  operator_id: number
  message_id: number
+  group_id: number
+  user_id: number

  constructor(groupId: number, userId: number, operatorId: number, messageId: number) {
    super()
--- a/src/onebot11/event/notice/OB11GroupTitleEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupTitleEvent.ts
@@ -4,6 +4,8 @@ export class OB11GroupTitleEvent extends OB11GroupNoticeEvent {
  notice_type = 'notify'
  sub_type = 'title'
  title: string
+  group_id: number
+  user_id: number

  constructor(groupId: number, userId: number, title: string) {
    super()
--- a/src/onebot11/event/notice/OB11GroupUploadNoticeEvent.ts
+++ b/src/onebot11/event/notice/OB11GroupUploadNoticeEvent.ts
@@ -10,6 +10,8 @@ export interface GroupUploadFile {
 export class OB11GroupUploadNoticeEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_upload'
  file: GroupUploadFile
+  group_id: number
+  user_id: number

  constructor(groupId: number, userId: number, file: GroupUploadFile) {
    super()
--- a/src/onebot11/event/notice/OB11MsgEmojiLikeEvent.ts
+++ b/src/onebot11/event/notice/OB11MsgEmojiLikeEvent.ts
@@ -8,14 +8,17 @@ export interface MsgEmojiLike {
 export class OB11GroupMsgEmojiLikeEvent extends OB11GroupNoticeEvent {
  notice_type = 'group_msg_emoji_like'
  message_id: number
-  sub_type: 'ban' | 'lift_ban'
+  sub_type?: 'ban' | 'lift_ban'
  likes: MsgEmojiLike[]
+  group_id: number
+  user_id: number

-  constructor(groupId: number, userId: number, messageId: number, likes: MsgEmojiLike[]) {
+  constructor(groupId: number, userId: number, messageId: number, likes: MsgEmojiLike[], sub_type?: 'ban' | 'lift_ban') {
    super()
    this.group_id = groupId
    this.user_id = userId // 可为空，表示是对别人的消息操作，如果是对bot自己的消息则不为空
    this.message_id = messageId
    this.likes = likes
+    this.sub_type = sub_type
  }
 }
--- a/src/onebot11/event/notice/OB11PokeEvent.ts
+++ b/src/onebot11/event/notice/OB11PokeEvent.ts
@@ -1,16 +1,15 @@
 import { OB11BaseNoticeEvent } from './OB11BaseNoticeEvent'
-import { selfInfo } from '../../../common/data'
-import { OB11BaseEvent } from '../OB11BaseEvent'

-class OB11PokeEvent extends OB11BaseNoticeEvent {
+abstract class OB11PokeEvent extends OB11BaseNoticeEvent {
  notice_type = 'notify'
  sub_type = 'poke'
  target_id = 0
-  user_id: number
+  abstract user_id: number
  raw_message: any
 }

 export class OB11FriendPokeEvent extends OB11PokeEvent {
+  user_id: number

  constructor(user_id: number, target_id: number, raw_message: any) {
    super();
@@ -21,6 +20,7 @@ export class OB11FriendPokeEvent extends OB11PokeEvent {
 }

 export class OB11GroupPokeEvent extends OB11PokeEvent {
+  user_id: number
  group_id: number
  constructor(group_id: number, user_id: number = 0, target_id: number = 0, raw_message: any) {
    super()
--- a/src/onebot11/event/request/OB11FriendRequest.ts
+++ b/src/onebot11/event/request/OB11FriendRequest.ts
@@ -4,7 +4,15 @@ import { EventType } from '../OB11BaseEvent'
 export class OB11FriendRequestEvent extends OB11BaseNoticeEvent {
  post_type = EventType.REQUEST
  user_id: number
-  request_type: 'friend' = 'friend'
+  request_type: 'friend'
  comment: string
  flag: string
+
+  constructor(userId: number, comment: string, flag: string, requestType: 'friend' = 'friend') {
+    super()
+    this.user_id = userId
+    this.comment = comment
+    this.flag = flag
+    this.request_type = requestType
+  }
 }
--- a/src/onebot11/event/request/OB11GroupRequest.ts
+++ b/src/onebot11/event/request/OB11GroupRequest.ts
@@ -1,11 +1,24 @@
-import { OB11GroupNoticeEvent } from '../notice/OB11GroupNoticeEvent'
+import { OB11BaseNoticeEvent } from '../notice/OB11BaseNoticeEvent'
 import { EventType } from '../OB11BaseEvent'

-export class OB11GroupRequestEvent extends OB11GroupNoticeEvent {
+export class OB11GroupRequestEvent extends OB11BaseNoticeEvent {
  post_type = EventType.REQUEST
-  request_type: 'group' = 'group'
-  sub_type: 'add' | 'invite' = 'add'
-  invitor_id: number | undefined = undefined
-  comment: string
+  request_type: 'group'
+  sub_type: 'add' | 'invite'
+  invitor_id: number | undefined
+  comment?: string
  flag: string
+  group_id: number
+  user_id: number
+
+  constructor(groupId: number, userId: number, flag: string, comment?: string, invitorId?: number, subType: 'add' | 'invite' = 'add', requestType: 'group' = 'group') {
+    super()
+    this.group_id = groupId
+    this.user_id = userId
+    this.comment = comment
+    this.flag = flag
+    this.request_type = requestType
+    this.sub_type = subType
+    this.invitor_id = invitorId
+  }
 }
--- a/src/onebot11/server/event-for-http.ts
+++ b/src/onebot11/server/event-for-http.ts
@@ -1,5 +1,4 @@
-import { PostEventType } from "./post-ob11-event"
-
+import { PostEventType } from './post-ob11-event'

 interface HttpEventType {
    seq: number
@@ -11,58 +10,56 @@ interface HttpUserType {
    userSeq: number
 }

-let curentSeq:number = 0;
-let eventList:HttpEventType[] = [];
-let httpUser:Record<string,HttpUserType> = {};
-
+let curentSeq: number = 0
+const eventList: HttpEventType[] = []
+const httpUser: Record<string, HttpUserType> = {}

 export function postHttpEvent(event: PostEventType) {
-    curentSeq += 1;
+    curentSeq += 1
    eventList.push({
        seq: curentSeq,
        event: event
    });
-    while(eventList.length > 100) {
-        eventList.shift();
+    while (eventList.length > 100) {
+        eventList.shift()
    }
 }

-
-export async function getHttpEvent(userKey:string,timeout = 0) {
-    let toRetEvent = [];
+export async function getHttpEvent(userKey: string, timeout = 0) {
+    const toRetEvent: PostEventType[] = []

    // 清除过时的user，5分钟没访问过的user将被删除
-    let now = Date.now();
-    for(let key in httpUser) {
-        let user = httpUser[key];
-        if(now - user.lastAccessTime > 1000 * 60 * 5) {
-            delete httpUser[key];
+    const now = Date.now();
+    for (let key in httpUser) {
+        let user = httpUser[key]
+        if (now - user.lastAccessTime > 1000 * 60 * 5) {
+            delete httpUser[key]
        }
    }

    // 增加新的user
-    if(!httpUser[userKey] ) {
+    if (!httpUser[userKey]) {
        httpUser[userKey] = {
            lastAccessTime: now,
            userSeq: curentSeq
        }
    }

-    let user = httpUser[userKey];
+    const user = httpUser[userKey]
    // 等待数据到来，暂时先这么写吧......
-    while(curentSeq == user.userSeq && Date.now() - now < timeout) {
-        await new Promise( resolve => setTimeout(resolve, 10) );
+    while (curentSeq == user.userSeq && Date.now() - now < timeout) {
+        await new Promise(resolve => setTimeout(resolve, 10))
    }
    // 取数据
-    for(let i = 0; i < eventList.length; i++) {
-        let evt = eventList[i];
-        if(evt.seq > user.userSeq) {
-            toRetEvent.push(evt.event);
+    for (let i = 0; i < eventList.length; i++) {
+        let evt = eventList[i]
+        if (evt.seq > user.userSeq) {
+            toRetEvent.push(evt.event)
        }
    }

    // 更新user数据
-    user.lastAccessTime = Date.now();
-    user.userSeq = curentSeq;
-    return toRetEvent;
+    user.lastAccessTime = Date.now()
+    user.userSeq = curentSeq
+    return toRetEvent
 }
--- a/src/onebot11/server/http.ts
+++ b/src/onebot11/server/http.ts
@@ -40,7 +40,7 @@ class HTTPHeart {
    }
    this.intervalId = setInterval(() => {
      // ws的心跳是ws自己维护的
-      postOb11Event(new OB11HeartbeatEvent(selfInfo.online, true, heartInterval), false, false)
+      postOb11Event(new OB11HeartbeatEvent(selfInfo.online!, true, heartInterval!), false, false)
    }, heartInterval)
  }

--- a/src/onebot11/server/post-ob11-event.ts
+++ b/src/onebot11/server/post-ob11-event.ts
@@ -43,7 +43,7 @@ export function postOb11Event(msg: PostEventType, reportSelf = false, postWs = t
  }
  if (config.ob11.enableHttpPost) {
    const msgStr = JSON.stringify(msg)
-    const hmac = crypto.createHmac('sha1', config.ob11.httpSecret)
+    const hmac = crypto.createHmac('sha1', config.ob11.httpSecret!)
    hmac.update(msgStr)
    const sig = hmac.digest('hex')
    let headers = {
@@ -79,9 +79,8 @@ export function postOb11Event(msg: PostEventType, reportSelf = false, postWs = t
  if (postWs) {
    postWsEvent(msg)
  }
-  if(!(msg.post_type == 'meta_event' && (msg as OB11BaseMetaEvent).meta_event_type == 'heartbeat')) {
+  if (!(msg.post_type == 'meta_event' && (msg as OB11BaseMetaEvent).meta_event_type == 'heartbeat')) {
    // 不上报心跳
    postHttpEvent(msg)
  }
-  
 }
--- a/src/onebot11/server/ws/ReverseWebsocket.ts
+++ b/src/onebot11/server/ws/ReverseWebsocket.ts
@@ -15,7 +15,7 @@ import { version } from '../../../version'
 export let rwsList: ReverseWebsocket[] = []

 export class ReverseWebsocket {
-  public websocket: WebSocketClass
+  public websocket?: WebSocketClass
  public url: string
  private running: boolean = false

@@ -27,38 +27,38 @@ export class ReverseWebsocket {

  public stop() {
    this.running = false
-    this.websocket.close()
+    this.websocket?.close()
  }

  public onopen() {
-    wsReply(this.websocket, new OB11LifeCycleEvent(LifeCycleSubType.CONNECT))
+    wsReply(this.websocket!, new OB11LifeCycleEvent(LifeCycleSubType.CONNECT))
  }

  public async onmessage(msg: string) {
-    let receiveData: { action: ActionName; params: any; echo?: any } = { action: null, params: {} }
+    let receiveData: { action: ActionName | null; params: any; echo?: any } = { action: null, params: {} }
    let echo = null
    try {
      receiveData = JSON.parse(msg.toString())
      echo = receiveData.echo
      log('收到反向Websocket消息', receiveData)
    } catch (e) {
-      return wsReply(this.websocket, OB11Response.error('json解析失败，请检查数据格式', 1400, echo))
+      return wsReply(this.websocket!, OB11Response.error('json解析失败，请检查数据格式', 1400, echo))
    }
-    const action: BaseAction<any, any> = actionMap.get(receiveData.action)
+    const action: BaseAction<any, any> = actionMap.get(receiveData.action!)!
    if (!action) {
-      return wsReply(this.websocket, OB11Response.error('不支持的api ' + receiveData.action, 1404, echo))
+      return wsReply(this.websocket!, OB11Response.error('不支持的api ' + receiveData.action, 1404, echo))
    }
    try {
      let handleResult = await action.websocketHandle(receiveData.params, echo)
-      wsReply(this.websocket, handleResult)
+      wsReply(this.websocket!, handleResult)
    } catch (e) {
-      wsReply(this.websocket, OB11Response.error(`api处理出错:${e}`, 1200, echo))
+      wsReply(this.websocket!, OB11Response.error(`api处理出错:${e}`, 1200, echo))
    }
  }

-  public onclose = function () {
+  public onclose = () => {
    log('反向ws断开', this.url)
-    unregisterWsEventSender(this.websocket)
+    unregisterWsEventSender(this.websocket!)
    if (this.running) {
      this.reconnect()
    }
@@ -104,7 +104,7 @@ export class ReverseWebsocket {
    this.websocket.on('error', log)

    const wsClientInterval = setInterval(() => {
-      postWsEvent(new OB11HeartbeatEvent(selfInfo.online, true, heartInterval))
+      postWsEvent(new OB11HeartbeatEvent(selfInfo.online!, true, heartInterval!))
    }, heartInterval) // 心跳包
    this.websocket.on('close', () => {
      clearInterval(wsClientInterval)
@@ -121,7 +121,7 @@ class OB11ReverseWebsockets {
      new Promise(() => {
        try {
          rwsList.push(new ReverseWebsocket(url))
-        } catch (e) {
+        } catch (e: any) {
          log(e.stack)
        }
      }).then()
@@ -132,7 +132,7 @@ class OB11ReverseWebsockets {
    for (let rws of rwsList) {
      try {
        rws.stop()
-      } catch (e) {
+      } catch (e: any) {
        log('反向ws关闭:', e.stack)
      }
    }
--- a/src/onebot11/server/ws/WebsocketServer.ts
+++ b/src/onebot11/server/ws/WebsocketServer.ts
@@ -13,15 +13,13 @@ import { selfInfo } from '../../../common/data'
 import { log } from '../../../common/utils/log'
 import { getConfigUtil } from '../../../common/config'

-let heartbeatRunning = false
-
 class OB11WebsocketServer extends WebsocketServerBase {
  authorizeFailed(wsClient: WebSocket) {
    wsClient.send(JSON.stringify(OB11Response.res(null, 'failed', 1403, 'token验证失败')))
  }

  async handleAction(wsClient: WebSocket, actionName: string, params: any, echo?: any) {
-    const action: BaseAction<any, any> = actionMap.get(actionName)
+    const action: BaseAction<any, any> = actionMap.get(actionName)!
    if (!action) {
      return wsReply(wsClient, OB11Response.error('不支持的api ' + actionName, 1404, echo))
    }
@@ -29,7 +27,7 @@ class OB11WebsocketServer extends WebsocketServerBase {
      let handleResult = await action.websocketHandle(params, echo)
      handleResult.echo = echo
      wsReply(wsClient, handleResult)
-    } catch (e) {
+    } catch (e: any) {
      wsReply(wsClient, OB11Response.error(`api处理出错:${e.stack}`, 1200, echo))
    }
  }
@@ -37,7 +35,7 @@ class OB11WebsocketServer extends WebsocketServerBase {
  onConnect(wsClient: WebSocket, url: string, req: IncomingMessage) {
    if (url == '/api' || url == '/api/' || url == '/') {
      wsClient.on('message', async (msg) => {
-        let receiveData: { action: ActionName; params: any; echo?: any } = { action: null, params: {} }
+        let receiveData: { action: ActionName | null; params: any; echo?: any } = { action: null, params: {} }
        let echo = null
        try {
          receiveData = JSON.parse(msg.toString())
@@ -46,7 +44,7 @@ class OB11WebsocketServer extends WebsocketServerBase {
        } catch (e) {
          return wsReply(wsClient, OB11Response.error('json解析失败，请检查数据格式', 1400, echo))
        }
-        this.handleAction(wsClient, receiveData.action, receiveData.params, receiveData.echo).then()
+        this.handleAction(wsClient, receiveData.action!, receiveData.params, receiveData.echo).then()
      })
    }
    if (url == '/event' || url == '/event/' || url == '/') {
@@ -61,7 +59,7 @@ class OB11WebsocketServer extends WebsocketServerBase {
      }
      const { heartInterval } = getConfigUtil().getConfig()
      const wsClientInterval = setInterval(() => {
-        postWsEvent(new OB11HeartbeatEvent(selfInfo.online, true, heartInterval))
+        postWsEvent(new OB11HeartbeatEvent(selfInfo.online!, true, heartInterval!))
      }, heartInterval) // 心跳包
      wsClient.on('close', () => {
        log('event上报ws客户端已断开')
--- a/src/onebot11/server/ws/reply.ts
+++ b/src/onebot11/server/ws/reply.ts
@@ -12,7 +12,7 @@ export function wsReply(wsClient: WebSocketClass, data: OB11Response | PostEvent
    }
    wsClient.send(JSON.stringify(packet))
    log('ws 消息上报', wsClient.url || '', data)
-  } catch (e) {
+  } catch (e: any) {
    log('websocket 回复失败', e.stack, data)
  }
 }
--- a/src/renderer/components/item.ts
+++ b/src/renderer/components/item.ts
@@ -1,6 +1,6 @@
 export const SettingItem = (
  title: string,
-  subtitle?: string,
+  subtitle?: string | null,
  action?: string,
  id?: string,
  visible: boolean = true,
--- a/src/renderer/components/select.ts
+++ b/src/renderer/components/select.ts
@@ -30,11 +30,11 @@ window.customElements.define(
      super()

      this.attachShadow({ mode: 'open' })
-      this.shadowRoot.append(SelectTemplate.content.cloneNode(true))
+      this.shadowRoot?.append(SelectTemplate.content.cloneNode(true))

-      this._button = this.shadowRoot.querySelector('div[part="button"]')
-      this._text = this.shadowRoot.querySelector('input[part="current-text"]')
-      this._context = this.shadowRoot.querySelector('ul[part="option-list"]')
+      this._button = this.shadowRoot?.querySelector('div[part="button"]')!
+      this._text = this.shadowRoot?.querySelector('input[part="current-text"]')!
+      this._context = this.shadowRoot?.querySelector('ul[part="option-list"]')!

      const buttonClick = () => {
        const isHidden = this._context.classList.toggle('hidden')
@@ -46,7 +46,8 @@ window.customElements.define(
      }

      this._button.addEventListener('click', buttonClick)
-      this._context.addEventListener('click', ({ target }: MouseEventExtend) => {
+      this._context.addEventListener('click', e => {
+        const { target } = e as MouseEventExtend
        if (target.tagName !== 'SETTING-OPTION') return
        buttonClick()

@@ -55,7 +56,7 @@ window.customElements.define(
        this.querySelectorAll('setting-option[is-selected]').forEach((dom) => dom.toggleAttribute('is-selected'))
        target.toggleAttribute('is-selected')

-        this._text.value = target.textContent
+        this._text.value = target.textContent!
        this.dispatchEvent(
          new CustomEvent('selected', {
            bubbles: true,
@@ -68,7 +69,7 @@ window.customElements.define(
        )
      })

-      this._text.value = this.querySelector('setting-option[is-selected]').textContent
+      this._text.value = this.querySelector('setting-option[is-selected]')?.textContent!
    }
  },
 )
--- a/src/renderer/index.ts
+++ b/src/renderer/index.ts
@@ -12,16 +12,16 @@ function aprilFoolsEgg(node: Element) {
  let today = new Date()
  if (today.getDate() === 1) {
    console.log('超时空猫猫!!!')
-    node.querySelector('.name').innerHTML = 'ChronoCat'
+    node.querySelector('.name')!.innerHTML = 'ChronoCat'
  }
 }

 function initSideBar() {
  document.querySelectorAll('.nav-item.liteloader').forEach((node) => {
-    if (node.textContent.startsWith('LLOneBot')) {
+    if (node.textContent?.startsWith('LLOneBot')) {
      aprilFoolsEgg(node)
      let iconEle = node.querySelector('.q-icon')
-      iconEle.innerHTML = iconSvg
+      iconEle!.innerHTML = iconSvg
    }
  })
 }
@@ -64,11 +64,11 @@ async function onSettingWindowCreated(view: Element) {
        ),
      ]),
      SettingList([
-          SettingItem(
-            '是否启用 LLOneBot, 重启QQ后生效',
-            null,
-            SettingSwitch('enableLLOB', config.enableLLOB, { 'control-display-id': 'config-enableLLOB' }),
-          )]
+        SettingItem(
+          '是否启用 LLOneBot, 重启QQ后生效',
+          null,
+          SettingSwitch('enableLLOB', config.enableLLOB, { 'control-display-id': 'config-enableLLOB' }),
+        )]
      ),
      SettingList([
        SettingItem(
@@ -234,29 +234,29 @@ async function onSettingWindowCreated(view: Element) {
    await new Promise((res) => setTimeout(() => res(true), 1000))

    const errDom = document.querySelector('#llonebot-error') || doc.querySelector('#llonebot-error')
-    const errCodeDom = errDom.querySelector('code')
+    const errCodeDom = errDom?.querySelector('code')
    const errMsg = await window.llonebot.getError()

    if (!errMsg) {
-      errDom.classList.remove('show')
+      errDom?.classList.remove('show')
    } else {
-      errDom.classList.add('show')
+      errDom?.classList.add('show')
    }
-    errCodeDom.innerHTML = errMsg
+    errCodeDom!.innerHTML = errMsg
  }
  showError().then()

  // 外链按钮
-  doc.querySelector('#open-github').addEventListener('click', () => {
+  doc.querySelector('#open-github')?.addEventListener('click', () => {
    window.LiteLoader.api.openExternal('https://github.com/LLOneBot/LLOneBot')
  })
-  doc.querySelector('#open-telegram').addEventListener('click', () => {
+  doc.querySelector('#open-telegram')?.addEventListener('click', () => {
    window.LiteLoader.api.openExternal('https://t.me/+nLZEnpne-pQ1OWFl')
  })
-  doc.querySelector('#open-qq-group').addEventListener('click', () => {
+  doc.querySelector('#open-qq-group')?.addEventListener('click', () => {
    window.LiteLoader.api.openExternal('https://qm.qq.com/q/bDnHRG38aI')
  })
-  doc.querySelector('#open-docs').addEventListener('click', () => {
+  doc.querySelector('#open-docs')?.addEventListener('click', () => {
    window.LiteLoader.api.openExternal('https://llonebot.github.io/')
  })
  // 生成反向地址列表
@@ -303,14 +303,14 @@ async function onSettingWindowCreated(view: Element) {
  }
  const addReverseHost = (type: string, doc: Document = document, inputAttr: any = {}) => {
    const hostContainerDom = doc.body.querySelector(`#config-ob11-${type}-list`)
-    hostContainerDom.appendChild(buildHostListItem(type, '', ob11Config[type].length, inputAttr))
+    hostContainerDom?.appendChild(buildHostListItem(type, '', ob11Config[type].length, inputAttr))
    ob11Config[type].push('')
  }
  const initReverseHost = (type: string, doc: Document = document) => {
    const hostContainerDom = doc.body.querySelector(`#config-ob11-${type}-list`)
-    ;[...hostContainerDom.childNodes].forEach((dom) => dom.remove())
+      ;[...hostContainerDom?.childNodes!].forEach((dom) => dom.remove())
    buildHostList(ob11Config[type], type).forEach((dom) => {
-      hostContainerDom.appendChild(dom)
+      hostContainerDom?.appendChild(dom)
    })
  }
  initReverseHost('httpHosts', doc)
@@ -318,42 +318,43 @@ async function onSettingWindowCreated(view: Element) {

  doc
    .querySelector('#config-ob11-httpHosts-add')
-    .addEventListener('click', () =>
+    ?.addEventListener('click', () =>
      addReverseHost('httpHosts', document, { placeholder: '如：http://127.0.0.1:5140/onebot' }),
    )
  doc
    .querySelector('#config-ob11-wsHosts-add')
-    .addEventListener('click', () =>
+    ?.addEventListener('click', () =>
      addReverseHost('wsHosts', document, { placeholder: '如：ws://127.0.0.1:5140/onebot' }),
    )

-  doc.querySelector('#config-ffmpeg-select').addEventListener('click', () => {
+  doc.querySelector('#config-ffmpeg-select')?.addEventListener('click', () => {
    window.llonebot.selectFile().then((path) => {
      if (!isEmpty(path)) {
        setConfig('ffmpeg', path)
-        document.querySelector('#config-ffmpeg-path-text').innerHTML = path
+        document.querySelector('#config-ffmpeg-path-text')!.innerHTML = path
      }
    })
  })

-  doc.querySelector('#config-open-log-path').addEventListener('click', () => {
+  doc.querySelector('#config-open-log-path')?.addEventListener('click', () => {
    window.LiteLoader.api.openPath(window.LiteLoader.plugins['LLOneBot'].path.data)
  })

  // 开关
-  doc.querySelectorAll('setting-switch[data-config-key]').forEach((dom: HTMLElement) => {
+  doc.querySelectorAll('setting-switch[data-config-key]').forEach(element => {
+    const dom = element as HTMLElement
    dom.addEventListener('click', () => {
      const active = dom.getAttribute('is-active') === null

-      setConfig(dom.dataset.configKey, active)
+      setConfig(dom.dataset.configKey!, active)

      if (active) dom.setAttribute('is-active', '')
      else dom.removeAttribute('is-active')

      if (!isEmpty(dom.dataset.controlDisplayId)) {
        const displayDom = document.querySelector(`#${dom.dataset.controlDisplayId}`)
-        if (active) displayDom.removeAttribute('is-hidden')
-        else displayDom.setAttribute('is-hidden', '')
+        if (active) displayDom?.removeAttribute('is-hidden')
+        else displayDom?.setAttribute('is-hidden', '')
      }
    })
  })
@@ -361,28 +362,31 @@ async function onSettingWindowCreated(view: Element) {
  // 输入框
  doc
    .querySelectorAll('setting-item .q-input input.q-input__inner[data-config-key]')
-    .forEach((dom: HTMLInputElement) => {
+    .forEach(element => {
+      const dom = element as HTMLInputElement
      dom.addEventListener('input', () => {
        const Type = dom.getAttribute('type')
        const configKey = dom.dataset.configKey
        const configValue = Type === 'number' ? (parseInt(dom.value) >= 1 ? parseInt(dom.value) : 1) : dom.value

-        setConfig(configKey, configValue)
+        setConfig(configKey!, configValue)
      })
    })

  // 下拉框
-  doc.querySelectorAll('ob-setting-select[data-config-key]').forEach((dom: HTMLElement) => {
-    dom.addEventListener('selected', (e: CustomEvent) => {
+  doc?.querySelectorAll('ob-setting-select[data-config-key]').forEach(element => {
+    const dom = element as HTMLElement
+    dom?.addEventListener('selected', e => {
+      const { detail } = e as CustomEvent
      const configKey = dom.dataset.configKey
-      const configValue = e.detail.value
+      const configValue = detail.value

-      setConfig(configKey, configValue)
+      setConfig(configKey!, configValue)
    })
  })

  // 保存按钮
-  doc.querySelector('#config-ob11-save').addEventListener('click', () => {
+  doc.querySelector('#config-ob11-save')?.addEventListener('click', () => {
    config.ob11 = ob11Config

    window.llonebot.setConfig(false, config)
@@ -446,7 +450,7 @@ function init() {
 }

 if (location.hash === '#/blank') {
-  ;(window as any).navigation.addEventListener('navigatesuccess', init, { once: true })
+  globalThis.navigation.addEventListener('navigatesuccess', init, { once: true })
 } else {
  init()
 }