earthjasonlin/GenshinCloudGameHelper
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: earthjasonlin:f8e47879f17820813f9a60e4df1c0370665496d4
Branches Tags
earthjasonlin:main
..
compare: earthjasonlin:5c8a9eb55eba8a3732fd3d048b5b4bb4aec93dde
Branches Tags
earthjasonlin:main

No commits in common. "f8e47879f17820813f9a60e4df1c0370665496d4" and "5c8a9eb55eba8a3732fd3d048b5b4bb4aec93dde" have entirely different histories.
f8e47879f1 ... 5c8a9eb55e

5 changed files with 169 additions and 256 deletions
Show Stats Expand all files Collapse all files

3
configs/example.json
View File

@ -5,6 +5,5 @@
"device_model":"", "device_model":"",
"device_id":"", "device_id":"",
"sys_version":"", "sys_version":"",
"channel": "", "channel":""
"email": ""
} }

157
src/config.js
View File

@ -1,120 +1,104 @@
const { exit } = require("process"); const { exit } = require("process")
const fs = require("fs"); const fs = require("fs")
const { default: axios } = require("axios"); const { default: axios } = require("axios")
const { log } = require("./util"); const { log } = require("./util")
exports.ListNotificationURL = exports.ListNotificationURL = 'https://api-cloudgame.mihoyo.com/hk4e_cg_cn/gamer/api/listNotifications?is_sort=true&source=NotificationSourceUnknown&status=NotificationStatusUnread&type=NotificationTypePopup'
"https://api-cloudgame.mihoyo.com/hk4e_cg_cn/gamer/api/listNotifications?is_sort=true&source=NotificationSourceUnknown&status=NotificationStatusUnread&type=NotificationTypePopup"; exports.AckNotificationURL = 'https://api-cloudgame.mihoyo.com/hk4e_cg_cn/gamer/api/ackNotification'
exports.AckNotificationURL = exports.WalletURL = 'https://api-cloudgame.mihoyo.com/hk4e_cg_cn/wallet/wallet/get?cost_method=COST_METHOD_UNSPECIFIED'
"https://api-cloudgame.mihoyo.com/hk4e_cg_cn/gamer/api/ackNotification"; exports.AnnouncementURL = 'https://api-cloudgame.mihoyo.com/hk4e_cg_cn/gamer/api/getAnnouncementInfo'
exports.WalletURL =
"https://api-cloudgame.mihoyo.com/hk4e_cg_cn/wallet/wallet/get?cost_method=COST_METHOD_UNSPECIFIED";
exports.AnnouncementURL =
"https://api-cloudgame.mihoyo.com/hk4e_cg_cn/gamer/api/getAnnouncementInfo";
// Here must be an earlier version so that the response won't be null // Here must be an earlier version so that the response won't be null
exports.AppVersionURL = exports.AppVersionURL = 'https://api-takumi.mihoyo.com/ptolemaios/api/getLatestRelease?app_id=1953443910&app_version=3.8.0&channel=mihoyo'
"https://api-takumi.mihoyo.com/ptolemaios/api/getLatestRelease?app_id=1953443910&app_version=3.8.0&channel=mihoyo";
exports.ListNotification = async function(header) { exports.ListNotification = async function(header) {
let tmp = ( let tmp = (await axios(exports.ListNotificationURL,{
await axios(exports.ListNotificationURL, { headers:header
headers: header, })).data;
})
).data;
tmp.StringVersion = JSON.stringify(tmp); tmp.StringVersion = JSON.stringify(tmp);
return tmp; return tmp;
}; }
exports.AckNotification = async function(header, id) { exports.AckNotification = async function(header, id) {
let data = `{"id":"${id}"}`; let data = `{"id":"${id}"}`;
await axios.post(exports.AckNotificationURL, data,{ await axios.post(exports.AckNotificationURL, data,{
headers: header, headers:header
}); });
}; }
exports.Wallet = async function(header) { exports.Wallet = async function(header) {
let tmp = ( let tmp = (await axios(exports.WalletURL,{
await axios(exports.WalletURL, { headers:header
headers: header, })).data;
})
).data;
tmp.StringVersion = JSON.stringify(tmp); tmp.StringVersion = JSON.stringify(tmp);
return tmp; return tmp;
}; }
exports.Announcement = async function(header) { exports.Announcement = async function(header) {
let tmp = ( let tmp = (await axios(exports.AnnouncementURL,{
await axios(exports.AnnouncementURL, { headers:header
headers: header, })).data;
})
).data;
tmp.StringVersion = JSON.stringify(tmp); tmp.StringVersion = JSON.stringify(tmp);
return tmp; return tmp;
}; }
exports.AppVersion = async function() { exports.AppVersion = async function() {
let tmp = (await axios(exports.AppVersionURL)).data; let tmp = (await axios(exports.AppVersionURL)).data;
tmp.StringVersion = JSON.stringify(tmp); tmp.StringVersion = JSON.stringify(tmp);
return tmp; return tmp;
}; }
var configKeys = [ var configKeys = [
"token", "token",
"client_type", "client_type",
"device_name", "device_name",
"device_model", "device_model",
"sys_version", "sys_version",
"channel", "channel"
]; ]
exports.getGlobalConfig = function() { exports.getGlobalConfig = function() {
try { try {
var globalConfig = fs.readFileSync("global.json"); var globalConfig = fs.readFileSync("global.json")
} catch(e) { } catch(e) {
if(e.toString().includes("Error: ENOENT: no such file or directory")) { if(e.toString().includes("Error: ENOENT: no such file or directory")) {
log.error(`读取配置失败!找不到全局配置文件`); log.error(`读取配置失败!找不到全局配置文件`)
} else { } else {
log.error(`读取配置失败!错误信息：${e}`); log.error(`读取配置失败!错误信息：${e}`);
} }
exit(); exit()
} }
return JSON.parse(globalConfig); return JSON.parse(globalConfig);
}; }
exports.getConfigs = function(){ exports.getConfigs = function(){
try { try {
var configsList = fs.readdirSync("configs"); var configsList = fs.readdirSync("configs")
} catch(e) { } catch(e) {
if ( if(e == "Error: ENOENT: no such file or directory, scandir 'configs'") {
e == "Error: ENOENT: no such file or directory, scandir 'configs'" log.error(`读取配置失败!找不到configs文件夹`)
) {
log.error(`读取配置失败!找不到configs文件夹`);
} else { } else {
log.error(`读取配置失败!错误信息：${e}`); log.error(`读取配置失败!错误信息：${e}`);
} }
exit(); exit()
}
log.info(`检测到${configsList.length}个配置文件：`)
configsList.forEach(file => {
log.info(`${file}`)
})
var configs = {}
configsList.forEach(file => {
configs[file] = JSON.parse(fs.readFileSync(`configs/${file}`))
})
return configs
} }
log.info(`检测到${configsList.length}个配置文件：`);
configsList.forEach((file) => {
log.info(`${file}`);
});
var configs = {};
configsList.forEach((file) => {
configs[file] = JSON.parse(fs.readFileSync(`configs/${file}`));
});
return configs;
};
exports.checkConfigs = function(configs){ exports.checkConfigs = function(configs){
for(file in configs) { for(file in configs) {
var configThis = configs[file]; var configThis = configs[file];
for(key in configKeys) { for(key in configKeys) {
if ( if(configThis[configKeys[key]] == "" || configThis[configKeys[key]] == undefined || configThis[configKeys[key]] == null || configThis[configKeys[key]] == NaN) {
configThis[configKeys[key]] == "" ||
configThis[configKeys[key]] == undefined ||
configThis[configKeys[key]] == null ||
configThis[configKeys[key]] == NaN
) {
log.error(`配置文件 ${file} 异常：`); log.error(`配置文件 ${file} 异常：`);
log.error(` —— ${configKeys[key]}字段缺失`); log.error(` —— ${configKeys[key]}字段缺失`);
} }
} }
}
} }
};
exports.makeHeader = function(data,appversion){ exports.makeHeader = function(data,appversion){
return { return {
@ -137,47 +121,20 @@ exports.makeHeader = function (data, appversion) {
Connection: "Keep-Alive", Connection: "Keep-Alive",
"Accept-Encoding": "gzip, deflate", "Accept-Encoding": "gzip, deflate",
Accept: "*/*", Accept: "*/*",
}; }
}; }
exports.SendLog = function ( exports.SendLog = function(transporter,mailfrom,mailto,successNum,totalNum,content) {
transporter, transporter.sendMail({
mailfrom,
mailto,
successNum,
totalNum,
content
) {
transporter.sendMail(
{
from: `"Genshin Cloud Game Helper" <${mailfrom}>`, //邮件来源 from: `"Genshin Cloud Game Helper" <${mailfrom}>`, //邮件来源
to: mailto, //邮件发送到哪里，多个邮箱使用逗号隔开 to: mailto, //邮件发送到哪里，多个邮箱使用逗号隔开
subject: `今日已签到${successNum}/${totalNum}名用户`, // 邮件主题 subject: `今日已签到${successNum}/${totalNum}名用户`, // 邮件主题
text: "", // 存文本类型的邮件正文 text: '', // 存文本类型的邮件正文
html: `${content}`, // html类型的邮件正文 html: `${content}` // html类型的邮件正文
}, }, (error) => {
(error) => {
if (error) { if (error) {
return console.log(error); return console.log(error);
} }
log.info("日志已丢出！"); log.info("日志已丢出！")
});
} }
);
};
exports.SendResult = function (transporter, mailfrom, mailto, content) {
transporter.sendMail(
{
from: `"Genshin Cloud Game Helper" <${mailfrom}>`, //邮件来源
to: mailto, //邮件发送到哪里，多个邮箱使用逗号隔开
subject: `Genshin Cloud Game Helper`, // 邮件主题
text: `${content}`, // 存文本类型的邮件正文
},
(error) => {
if (error) {
return console.log(error);
}
log.info(`已发送通知至${mailto}`);
}
);
};

99
src/index.js
View File

@ -1,110 +1,67 @@
const { const { getConfigs, checkConfigs, makeHeader, ListNotification, AckNotification, Wallet, SendLog, AppVersion, getGlobalConfig } = require("./config")
getConfigs,
checkConfigs,
makeHeader,
ListNotification,
AckNotification,
Wallet,
SendLog,
AppVersion,
getGlobalConfig,
SendResult,
} = require("./config");
const { log, addLogContent, getLogs, sleep } = require("./util"); const { log, addLogContent, getLogs, sleep } = require("./util");
const nodemailer = require("nodemailer"); const nodemailer = require("nodemailer");
(async () => { (async () => {
log.info("开始获取全局配置"); log.info("开始获取全局配置")
var globalConfig = getGlobalConfig(); var globalConfig = getGlobalConfig();
log.info("获取成功"); log.info("获取成功")
if (globalConfig.sendMail == true) { if (globalConfig.sendMail == true) {
log.info("组装邮件发射器"); log.info("组装邮件发射器")
var transporter = nodemailer.createTransport({ var transporter = nodemailer.createTransport({
host: globalConfig.mailConfig.smtpServer, host: globalConfig.mailConfig.smtpServer,
port: globalConfig.mailConfig.smtpPort, port: globalConfig.mailConfig.smtpPort,
secure: globalConfig.mailConfig.smtpSecure, secure: globalConfig.mailConfig.smtpSecure,
auth: { auth: {
user: globalConfig.mailConfig.user, user: globalConfig.mailConfig.user,
pass: globalConfig.mailConfig.pass, pass: globalConfig.mailConfig.pass
}, }
}); });
} }
var minDelay = globalConfig.minDelay; var minDelay = globalConfig.minDelay
var maxDelay = globalConfig.maxDelay; var maxDelay = globalConfig.maxDelay
var configs = getConfigs(); var configs = getConfigs();
log.info(`正在检测配置有效性`); log.info(`正在检测配置有效性`)
checkConfigs(configs); checkConfigs(configs)
log.info("检测完毕！"); log.info("检测完毕！")
log.info("正在获取版本号"); log.info("正在获取版本号")
var appversion = await AppVersion(); var appversion = await AppVersion();
appversion = appversion.data.package_version; appversion = appversion.data.package_version
log.info(`获取成功！当前版本号：${appversion}`); log.info(`获取成功！当前版本号：${appversion}`)
var successNum = 0, var successNum = 0,totalNum = 0;
totalNum = 0;
for (key in configs) { for (key in configs) {
totalNum ++; totalNum ++;
log.info(`正在执行配置 ${key}`); log.info(`正在执行配置 ${key}`)
log.info("尝试签到……"); log.info("尝试签到……")
var header = makeHeader(configs[key], appversion); var header = makeHeader(configs[key], appversion);
var WalletRespond = await Wallet(header); var WalletRespond = await Wallet(header);
addLogContent( addLogContent(`<span style="color: orange; font-weight: bold">${key} Wallet返回体</span> <br> <span style="color: orange">${JSON.stringify(WalletRespond)}</span><br>`);
`<span style="color: orange; font-weight: bold">${key} Wallet返回体</span> <br> <span style="color: orange">${JSON.stringify(
WalletRespond
)}</span><br>`
);
if(WalletRespond.data != null) { if(WalletRespond.data != null) {
var NotificationRespond = await ListNotification(header); var NotificationRespond = await ListNotification(header);
addLogContent( addLogContent(`<span style="color: orange; font-weight: bold">${key} Notification返回体</span> <br> <span style="color: orange">${JSON.stringify(NotificationRespond)}</span><br>`);
`<span style="color: orange; font-weight: bold">${key} Notification返回体</span> <br> <span style="color: orange">${JSON.stringify(
NotificationRespond
)}</span><br>`
);
successNum ++; successNum ++;
log.info( log.info(`签到完毕! 获得时长：${WalletRespond.data.free_time.send_freetime}分钟，总时长:${WalletRespond.data.free_time.free_time}分钟`);
`签到完毕! 获得时长：${WalletRespond.data.free_time.send_freetime}分钟，总时长:${WalletRespond.data.free_time.free_time}分钟` let NotificationLength = NotificationRespond.data.list.length
);
if (configs[key].email != null) {
SendResult(
transporter,
globalConfig.mailConfig.user,
configs[key].email,
`签到完毕! 获得时长：${WalletRespond.data.free_time.send_freetime}分钟，总时长:${WalletRespond.data.free_time.free_time}分钟`
);
}
let NotificationLength = NotificationRespond.data.list.length;
let postHeader = header; let postHeader = header;
Object.assign(postHeader, { Object.assign(postHeader, {
"Content-Length": 28, "Content-Length": 28,
"Content-Type": "application/json", "Content-Type": "application/json",
}); });
for (var i = 0; i < NotificationLength; i++) { for (var i = 0; i < NotificationLength; i++) {
AckNotification( AckNotification(postHeader, NotificationRespond.data.list[i].id);
postHeader,
NotificationRespond.data.list[i].id
);
} }
} else { } else {
log.error("签到失败"); log.error("签到失败")
if (configs[key].email != null) {
SendResult(
transporter,
globalConfig.mailConfig.user,
configs[key].email,
"签到失败"
);
} }
} var delay = Math.round(Math.random() * (maxDelay - minDelay) + minDelay)
var delay = Math.round( log.info(`暂停：${delay}毫秒`)
Math.random() * (maxDelay - minDelay) + minDelay
);
log.info(`暂停：${delay}毫秒`);
await sleep(delay); await sleep(delay);
} }
if (globalConfig.sendMail == true) { if (globalConfig.sendMail == true) {
log.info(`运行完毕！丢出日志`); log.info(`运行完毕！丢出日志`)
SendLog( SendLog(
transporter, transporter,
globalConfig.mailConfig.user, globalConfig.mailConfig.user,
@ -112,6 +69,6 @@ const nodemailer = require("nodemailer");
successNum, successNum,
totalNum, totalNum,
getLogs() getLogs()
); )
} }
})(); })()

32
src/util.js
View File

@ -1,26 +1,26 @@
const reggol = require("reggol"); const reggol = require("reggol")
const baseLogger = new reggol("GenshinCloudGameHelper"); const baseLogger = new reggol("GenshinCloudGameHelper")
let logContent = ``; let logContent = ``
exports.addLogContent = function(content) { exports.addLogContent = function(content) {
logContent += content; logContent += content
}; }
exports.getLogs = function() { exports.getLogs = function() {
return logContent; return logContent
}; }
exports.log = { exports.log = {
info(content) { info(content) {
logContent += `<strong style="color: green">[info]</strong> ${content}<br>`; logContent += `<strong style="color: green">[info]</strong> ${content}<br>`
baseLogger.info(content); baseLogger.info(content)
}, },
error(content) { error(content) {
logContent += `<strong style="color: red">[error]</strong> ${content}<br>`; logContent += `<strong style="color: red">[error]</strong> ${content}<br>`
baseLogger.error(content); baseLogger.error(content)
}, }
}; }
exports.sleep = function (delay) { exports.sleep = function (delay) {
return new Promise((resolve) => { return new Promise((resolve) => {
setTimeout(resolve, delay); setTimeout(resolve, delay)
}); })
}; }