miao-plugin/models/ProfileReq.js

117 lines
2.9 KiB
JavaScript
Raw Normal View History

import lodash from 'lodash'
2022-08-18 10:13:42 +00:00
import Base from './Base.js'
import ProfileServ from './ProfileServ.js'
import fetch from 'node-fetch'
function sleep (ms) {
return new Promise((resolve) => setTimeout(resolve, ms))
}
export default class ProfileReq extends Base {
constructor ({ e, uid }) {
super()
this.e = e
this.uid = uid
}
async setCd (seconds = 60) {
let ext = new Date() * 1 + seconds * 1000
2022-08-18 21:04:31 +00:00
await redis.set(`miao:profile-cd:${this.uid}`, ext + '', { EX: seconds })
2022-08-18 10:13:42 +00:00
}
async inCd () {
2022-08-18 21:04:31 +00:00
let ext = await redis.get(`miao:profile-cd:${this.uid}`)
2022-08-18 10:13:42 +00:00
if (!ext || isNaN(ext)) {
return false
}
let cd = (new Date() * 1) - ext
if (cd < 0 && Math.abs(cd) < 100 * 60 * 1000) {
2022-08-18 10:13:42 +00:00
return Math.ceil(0 - cd / 1000)
}
return false
}
err (msg = '', cd = 0) {
const msgs = {
error: '请求失败,可能是面板服务升级维护或遇到故障,请稍后重试...',
2022-08-18 10:13:42 +00:00
empty: '请将角色放置在【游戏内】角色展柜并打开【显示详情】等待5分钟重新获取面板'
}
msg = msgs[msg] || msg
if (msg) {
this.e.reply(msg)
}
// 设置CD
if (cd) {
this.setCd(cd)
}
return false
}
msg (msg) {
this.e.reply(msg)
}
async request () {
let Serv = ProfileReq.getServ(this.uid)
let reqParam = await Serv.getReqParam(this.uid)
let cdTime = await this.inCd()
if (cdTime) {
return this.err(`请求过快,请${cdTime}秒后重试..`)
}
await this.setCd(20)
2022-11-24 15:27:03 +00:00
this.msg(`开始获取uid:${this.uid}的数据,可能会需要一定时间~`)
2022-08-18 10:13:42 +00:00
await sleep(100)
// 发起请求
2022-08-22 20:53:31 +00:00
let data = {}
try {
let params = reqParam.params || {}
params.timeout = params.timeout || 1000 * 20
let req = await fetch(reqParam.url, params)
data = await req.text()
if (data[0] === '<') {
let titleRet = /<title>(.+)<\/title>/.exec(data)
if (titleRet && titleRet[1]) {
data = { error: titleRet[1] }
} else {
return this.err('error', 60)
}
} else {
data = JSON.parse(data)
}
2022-08-22 20:53:31 +00:00
} catch (e) {
console.log('面板请求错误', e)
data = {}
}
2022-08-18 10:13:42 +00:00
data = await Serv.response(data, this)
// 设置CD
cdTime = Serv.getCdTime(data)
if (cdTime) {
await this.setCd(cdTime)
}
if (data === false) {
return false
}
let userData = Serv.getUserData(data)
let profiles = Serv.getProfileData(data)
cdTime = Serv.getCdTime(data)
if (cdTime) {
await this.setCd(cdTime)
}
return lodash.extend({
uid: this.uid,
chars: profiles
}, userData)
2022-08-18 10:13:42 +00:00
}
}
ProfileReq.serv = {}
ProfileReq.regServ = function (serv) {
for (let key in serv) {
ProfileReq.serv[key] = serv[key]
}
}
ProfileReq.getServ = function (uid) {
return ProfileServ.getServ({ uid, serv: ProfileReq.serv })
}