fix: detect qdreader user id in autman js
This commit is contained in:
@@ -4,7 +4,7 @@
|
|||||||
//[author: Hermes]
|
//[author: Hermes]
|
||||||
//[service: BOSS]
|
//[service: BOSS]
|
||||||
//[class: 工具类]
|
//[class: 工具类]
|
||||||
//[version: 2.3.6]
|
//[version: 2.3.7]
|
||||||
//[platform: web,qq,wx,tg,tb,fs,we]
|
//[platform: web,qq,wx,tg,tb,fs,we]
|
||||||
//[public: false]
|
//[public: false]
|
||||||
//[price: 0]
|
//[price: 0]
|
||||||
@@ -88,14 +88,29 @@ function getBindStore() { return cleanStringMap(safeJsonParse(cfgGet(BIND_KEY, "
|
|||||||
function setBindStore(obj) { return cfgSet(BIND_KEY, JSON.stringify(obj || {})) }
|
function setBindStore(obj) { return cfgSet(BIND_KEY, JSON.stringify(obj || {})) }
|
||||||
function getRemarkStore() { return cleanStringMap(safeJsonParse(cfgGet(REMARK_KEY, "{}"), {})) }
|
function getRemarkStore() { return cleanStringMap(safeJsonParse(cfgGet(REMARK_KEY, "{}"), {})) }
|
||||||
function setRemarkStore(obj) { return cfgSet(REMARK_KEY, JSON.stringify(obj || {})) }
|
function setRemarkStore(obj) { return cfgSet(REMARK_KEY, JSON.stringify(obj || {})) }
|
||||||
|
function callNoArg(obj, name) {
|
||||||
|
try { if (obj && typeof obj[name] === "function") return obj[name]() } catch (e) {}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
function currentUserId() {
|
function currentUserId() {
|
||||||
var v = ""
|
var v = ""
|
||||||
try { if (typeof sender !== "undefined" && sender && sender.getUserID) v = sender.getUserID() || "" } catch (e) {}
|
var names = ["getUserID", "getUserId", "getUserid", "getUser", "getSenderID", "getSenderId", "getSender", "getFromUserID", "getFromUserId", "getChatID", "getChatId"]
|
||||||
try { if (!v && typeof sender !== "undefined" && sender && sender.getUserId) v = sender.getUserId() || "" } catch (e) {}
|
try { if (typeof sender !== "undefined" && sender) for (var i = 0; i < names.length && !v; i++) v = callNoArg(sender, names[i]) || "" } catch (e) {}
|
||||||
try { if (!v && typeof userId !== "undefined") v = String(userId || "") } catch (e) {}
|
var globals = ["userId", "userID", "uid", "senderID", "senderId", "chatId", "chatID", "fromUserId", "fromUserID"]
|
||||||
try { if (!v && typeof getUserID === "function") v = getUserID() || "" } catch (e) {}
|
for (var j = 0; j < globals.length && !v; j++) { try { if (typeof this[globals[j]] !== "undefined") v = this[globals[j]] || "" } catch (e) {} }
|
||||||
|
for (var k = 0; k < names.length && !v; k++) { try { if (typeof this[names[k]] === "function") v = this[names[k]]() || "" } catch (e) {} }
|
||||||
return trim(v)
|
return trim(v)
|
||||||
}
|
}
|
||||||
|
function currentUserDebug() {
|
||||||
|
var parts = []
|
||||||
|
try { if (typeof sender !== "undefined" && sender) {
|
||||||
|
var names = ["getUserID", "getUserId", "getUserid", "getUser", "getSenderID", "getSenderId", "getSender", "getFromUserID", "getFromUserId", "getChatID", "getChatId", "getImtype"]
|
||||||
|
for (var i = 0; i < names.length; i++) if (typeof sender[names[i]] === "function") {
|
||||||
|
var v = callNoArg(sender, names[i]); parts.push(names[i] + "=" + (v ? maskUid(String(v)) : "空"))
|
||||||
|
}
|
||||||
|
} } catch (e) {}
|
||||||
|
return parts.length ? parts.join("; ") : "未发现可用用户方法"
|
||||||
|
}
|
||||||
function boundToCurrent(uid, bind) {
|
function boundToCurrent(uid, bind) {
|
||||||
var owner = bind && bind[String(uid)] ? String(bind[String(uid)]) : ""
|
var owner = bind && bind[String(uid)] ? String(bind[String(uid)]) : ""
|
||||||
var me = currentUserId()
|
var me = currentUserId()
|
||||||
@@ -180,7 +195,7 @@ function contentText() {
|
|||||||
}
|
}
|
||||||
function usage() {
|
function usage() {
|
||||||
return [
|
return [
|
||||||
"启点读书签到插件 v2.3.6",
|
"启点读书签到插件 v2.3.7",
|
||||||
"【一级菜单】",
|
"【一级菜单】",
|
||||||
"账号管理:启点账号",
|
"账号管理:启点账号",
|
||||||
"执行查询:启点查询",
|
"执行查询:启点查询",
|
||||||
@@ -595,7 +610,7 @@ function handleSaveCookie(arg, store, bind) {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if (!me) {
|
if (!me) {
|
||||||
lines.push("无法识别当前用户,拒绝保存 uid: " + uid)
|
lines.push("无法识别当前用户,拒绝保存 uid: " + uid + "。诊断: " + currentUserDebug())
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
var changed = store[uid] !== cookie
|
var changed = store[uid] !== cookie
|
||||||
|
|||||||
@@ -4,7 +4,7 @@
|
|||||||
//[author: Hermes]
|
//[author: Hermes]
|
||||||
//[service: BOSS]
|
//[service: BOSS]
|
||||||
//[class: 工具类]
|
//[class: 工具类]
|
||||||
//[version: 2.3.6]
|
//[version: 2.3.7]
|
||||||
//[platform: web,qq,wx,tg,tb,fs,we]
|
//[platform: web,qq,wx,tg,tb,fs,we]
|
||||||
//[public: false]
|
//[public: false]
|
||||||
//[price: 0]
|
//[price: 0]
|
||||||
@@ -88,14 +88,29 @@ function getBindStore() { return cleanStringMap(safeJsonParse(cfgGet(BIND_KEY, "
|
|||||||
function setBindStore(obj) { return cfgSet(BIND_KEY, JSON.stringify(obj || {})) }
|
function setBindStore(obj) { return cfgSet(BIND_KEY, JSON.stringify(obj || {})) }
|
||||||
function getRemarkStore() { return cleanStringMap(safeJsonParse(cfgGet(REMARK_KEY, "{}"), {})) }
|
function getRemarkStore() { return cleanStringMap(safeJsonParse(cfgGet(REMARK_KEY, "{}"), {})) }
|
||||||
function setRemarkStore(obj) { return cfgSet(REMARK_KEY, JSON.stringify(obj || {})) }
|
function setRemarkStore(obj) { return cfgSet(REMARK_KEY, JSON.stringify(obj || {})) }
|
||||||
|
function callNoArg(obj, name) {
|
||||||
|
try { if (obj && typeof obj[name] === "function") return obj[name]() } catch (e) {}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
function currentUserId() {
|
function currentUserId() {
|
||||||
var v = ""
|
var v = ""
|
||||||
try { if (typeof sender !== "undefined" && sender && sender.getUserID) v = sender.getUserID() || "" } catch (e) {}
|
var names = ["getUserID", "getUserId", "getUserid", "getUser", "getSenderID", "getSenderId", "getSender", "getFromUserID", "getFromUserId", "getChatID", "getChatId"]
|
||||||
try { if (!v && typeof sender !== "undefined" && sender && sender.getUserId) v = sender.getUserId() || "" } catch (e) {}
|
try { if (typeof sender !== "undefined" && sender) for (var i = 0; i < names.length && !v; i++) v = callNoArg(sender, names[i]) || "" } catch (e) {}
|
||||||
try { if (!v && typeof userId !== "undefined") v = String(userId || "") } catch (e) {}
|
var globals = ["userId", "userID", "uid", "senderID", "senderId", "chatId", "chatID", "fromUserId", "fromUserID"]
|
||||||
try { if (!v && typeof getUserID === "function") v = getUserID() || "" } catch (e) {}
|
for (var j = 0; j < globals.length && !v; j++) { try { if (typeof this[globals[j]] !== "undefined") v = this[globals[j]] || "" } catch (e) {} }
|
||||||
|
for (var k = 0; k < names.length && !v; k++) { try { if (typeof this[names[k]] === "function") v = this[names[k]]() || "" } catch (e) {} }
|
||||||
return trim(v)
|
return trim(v)
|
||||||
}
|
}
|
||||||
|
function currentUserDebug() {
|
||||||
|
var parts = []
|
||||||
|
try { if (typeof sender !== "undefined" && sender) {
|
||||||
|
var names = ["getUserID", "getUserId", "getUserid", "getUser", "getSenderID", "getSenderId", "getSender", "getFromUserID", "getFromUserId", "getChatID", "getChatId", "getImtype"]
|
||||||
|
for (var i = 0; i < names.length; i++) if (typeof sender[names[i]] === "function") {
|
||||||
|
var v = callNoArg(sender, names[i]); parts.push(names[i] + "=" + (v ? maskUid(String(v)) : "空"))
|
||||||
|
}
|
||||||
|
} } catch (e) {}
|
||||||
|
return parts.length ? parts.join("; ") : "未发现可用用户方法"
|
||||||
|
}
|
||||||
function boundToCurrent(uid, bind) {
|
function boundToCurrent(uid, bind) {
|
||||||
var owner = bind && bind[String(uid)] ? String(bind[String(uid)]) : ""
|
var owner = bind && bind[String(uid)] ? String(bind[String(uid)]) : ""
|
||||||
var me = currentUserId()
|
var me = currentUserId()
|
||||||
@@ -180,7 +195,7 @@ function contentText() {
|
|||||||
}
|
}
|
||||||
function usage() {
|
function usage() {
|
||||||
return [
|
return [
|
||||||
"启点读书签到插件 v2.3.6",
|
"启点读书签到插件 v2.3.7",
|
||||||
"【一级菜单】",
|
"【一级菜单】",
|
||||||
"账号管理:启点账号",
|
"账号管理:启点账号",
|
||||||
"执行查询:启点查询",
|
"执行查询:启点查询",
|
||||||
@@ -595,7 +610,7 @@ function handleSaveCookie(arg, store, bind) {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if (!me) {
|
if (!me) {
|
||||||
lines.push("无法识别当前用户,拒绝保存 uid: " + uid)
|
lines.push("无法识别当前用户,拒绝保存 uid: " + uid + "。诊断: " + currentUserDebug())
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
var changed = store[uid] !== cookie
|
var changed = store[uid] !== cookie
|
||||||
|
|||||||
@@ -5,22 +5,23 @@ import vm from 'node:vm';
|
|||||||
const pluginPath = new URL('../plugins/qdreader/qdreader_sign_autman.js', import.meta.url).pathname;
|
const pluginPath = new URL('../plugins/qdreader/qdreader_sign_autman.js', import.meta.url).pathname;
|
||||||
const code = fs.readFileSync(pluginPath, 'utf8');
|
const code = fs.readFileSync(pluginPath, 'utf8');
|
||||||
|
|
||||||
function runPlugin({ content = '', store = {}, bucketStore = {}, requests = [], userId = 'user-a', listens = [] } = {}) {
|
function runPlugin({ content = '', store = {}, bucketStore = {}, requests = [], userId = 'user-a', listens = [], senderOverrides = {}, globals = {} } = {}) {
|
||||||
const replies = [];
|
const replies = [];
|
||||||
const calls = [];
|
const calls = [];
|
||||||
let requestIndex = 0;
|
let requestIndex = 0;
|
||||||
let listenIndex = 0;
|
let listenIndex = 0;
|
||||||
const ctx = {
|
const baseSender = {
|
||||||
console,
|
|
||||||
Buffer,
|
|
||||||
sender: {
|
|
||||||
reply: (msg) => replies.push(String(msg)),
|
reply: (msg) => replies.push(String(msg)),
|
||||||
getMessage: () => content,
|
getMessage: () => content,
|
||||||
getContent: () => content,
|
getContent: () => content,
|
||||||
isAdmin: () => true,
|
isAdmin: () => true,
|
||||||
getUserID: () => userId,
|
getUserID: () => userId,
|
||||||
listen: () => (listenIndex < listens.length ? listens[listenIndex++] : 'q'),
|
listen: () => (listenIndex < listens.length ? listens[listenIndex++] : 'q'),
|
||||||
},
|
};
|
||||||
|
const ctx = {
|
||||||
|
console,
|
||||||
|
Buffer,
|
||||||
|
sender: { ...baseSender, ...senderOverrides },
|
||||||
GetContent: () => content,
|
GetContent: () => content,
|
||||||
getContent: () => content,
|
getContent: () => content,
|
||||||
get: (key) => store[key] || '',
|
get: (key) => store[key] || '',
|
||||||
@@ -36,6 +37,7 @@ function runPlugin({ content = '', store = {}, bucketStore = {}, requests = [],
|
|||||||
if (String(req.url).includes('/sign')) return { body: { code: 0, data: { headers: { 'QD-Sign': 'sig' } } } };
|
if (String(req.url).includes('/sign')) return { body: { code: 0, data: { headers: { 'QD-Sign': 'sig' } } } };
|
||||||
return { statusCode: 200, body: { code: 0, msg: '签到成功' } };
|
return { statusCode: 200, body: { code: 0, msg: '签到成功' } };
|
||||||
},
|
},
|
||||||
|
...globals,
|
||||||
};
|
};
|
||||||
vm.createContext(ctx);
|
vm.createContext(ctx);
|
||||||
vm.runInContext(code, ctx, { filename: pluginPath });
|
vm.runInContext(code, ctx, { filename: pluginPath });
|
||||||
@@ -98,6 +100,17 @@ test('quick submit prompts remark after saving cookie', () => {
|
|||||||
assert.equal(JSON.parse(r.store.qdreader_remark_json)['12345'], '主号');
|
assert.equal(JSON.parse(r.store.qdreader_remark_json)['12345'], '主号');
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test('quick submit can bind user from alternate Autman sender fields', () => {
|
||||||
|
const r = runPlugin({
|
||||||
|
content: '启点ck ' + cookie,
|
||||||
|
userId: '',
|
||||||
|
senderOverrides: { getUserID: undefined, getSenderID: () => 'sender-42' },
|
||||||
|
listens: ['n'],
|
||||||
|
});
|
||||||
|
assert.match(r.replies.join('\n'), /CK新增成功/);
|
||||||
|
assert.equal(JSON.parse(r.store.qdreader_user_bind_json)['12345'], 'sender-42');
|
||||||
|
});
|
||||||
|
|
||||||
test('manual sign and cron sign both call sign gateway then qidian checkin', () => {
|
test('manual sign and cron sign both call sign gateway then qidian checkin', () => {
|
||||||
const store = {
|
const store = {
|
||||||
qdreader_cookie_json: JSON.stringify({ '12345': cookie }),
|
qdreader_cookie_json: JSON.stringify({ '12345': cookie }),
|
||||||
|
|||||||
Reference in New Issue
Block a user