index.js

// index.js
/* eslint-disable no-undef */
import {bot} from './util/init.js';
import {sendMessage} from './util/util.js'
import { config } from 'dotenv';
import express from 'express';
import {log} from './db/logs.js'
import { singleChat,groupChat,handleFile, handleImage,handleAudio,handleVideo,
  handleMiniProgram,
  handleGIF,handleTransfer,handlePush } from './util/handle.js';
import router from './router/router.js';
import staticRouter from './router/static.js';
import {saveWechatConfig} from './db/wechat.js';
import {saveWechatFriends,saveWechatRooms} from './util/wechat.js';
// import {Jimp} from 'jimp';
import bodyParser from 'body-parser';
import {transporter,mailOptions} from './util/mailer.js';
const port = 4000;
config();
const app = express();
app.use(bodyParser.json({'limit':'800kb'}));
app.use(express.urlencoded({'extended':false,'limit':'800kb'}));
app.use(router);
app.use(staticRouter);


export async function prepareBot() {
  bot.on("message", async (message) => {  
    const contact = message.talker();
    if (contact.self()) {
      return;
    } 
    let {payload} = message;
    let {talkerId,listenerId,text} = payload;
    if (message.room()) {
      groupChat(message)
      return;
    }
    switch (message.type()) {
      case 0:
        await sendMessage(talkerId, "感谢老板抬爱，祝老板在缅A发财")
        break;
      case 1:
          await handleFile(message,talkerId)
          break;
      case 2:
          await handleAudio(message,talkerId)
          break;
      case 5:
          await handleGIF(message,talkerId)
          break;
      case 7:
        await singleChat(talkerId,listenerId,text)
        break;
      case 6:
        await handleImage(message,talkerId)
        break;
      case 11:
        { const xmlstr = payload.text;
          handleTransfer(xmlstr,talkerId)
          break; 
        }
    case 14:
      { 
        handleArticle(payload.text,talkerId)
        break; 
      }
    case 9:
      await handleMiniProgram(message,talkerId)
      break;
    case 15:
      await handleVideo(message,talkerId)
      break;
    default:
      break;
    }
  });

  bot.on("friendship", async (friendship) => {
    try {
      const contact = friendship.contact();
      switch (friendship.type()) {  
      case bot.Friendship.Type.Receive:
        await friendship.accept()  
        await contact.say(process.env.WELCOME_TEXT)
        break  
      }
    } catch (e) {
      console.error(e)
    }
  });

  bot.on('scan', (qrcode) => {
    saveWechatConfig({loginurl:qrcode,wechatid:'',username:'',avatar:'',friends:''})
  })

  bot.on("login", async (user) => {
    const selfContact = bot.currentUser;
    let dataUrl = ""
    try {
      const selfAvatarFileBox = await selfContact.avatar();
      if (selfAvatarFileBox.buffer) {
        const buffer = await selfAvatarFileBox.toBuffer();
        const base64 = buffer.toString('base64');
        dataUrl = `data:image/jpeg;base64,${base64}`;
      }
    } catch (e) {
      log('error', "获取头像失败"+e);
    }
    saveWechatConfig({username:user.payload.name,wechatid:user.payload.id,avatar:dataUrl,loginurl:'',friends:''})
    log('info', "机器人登录成功，账号名："+user.payload.name);
  })

  bot.on('logout', async (user)=>{
    log('info', user.payload.name+"退出登录");
    transporter.sendMail(mailOptions, (error, info) => {
      if (error) {
        return console.log(error);
      }
      console.log('Message sent: %s', info.messageId);
    });
  })

  bot.on("error", () => {
    // let text = e
    // if(`${e}`.includes("AssertionError: 400 != 400")){
    //   text = "获取微信二维码超时5分钟"
    // }
    // if(`${e}`.includes("1101 == 0")){
    //   text = "微信退出登录"
    // }
    
    // log('error', text);
  })

  bot.on("ready",async ()=>{
    let roomList = await bot.Room.findAll()
    const contactList = await bot.Contact.findAll();
    if(roomList && contactList){
      await saveWechatRooms(roomList)
      await saveWechatFriends(contactList)
      await handlePush(roomList)
    }
  })

  await bot.start();
  await bot.ready();
  return bot;
}

async function startBot() {
   app.listen(port, async () => {
       console.log(`Web server listening at http://localhost:${port}`);
      //  await open(`http://localhost:${port}`);
    });
  await prepareBot();

}

startBot().catch((e)=>{
  console.log("Bot Catch",e);
});

process.on('exit', async(code) => {
  log('warning', "程序退出"+code);
});

process.on('SIGINT', async () => {
  log('warning', "程序退出");
  await bot.logout();
  process.exit();
});

process.on('uncaughtException', async (err) => {
  console.error('抛出异常退出:', err);
});