claw-daemon/clawd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

read sms loop

Browse Source
This commit is contained in:
stswangzhiping
2026-05-01 09:29:04 +08:00
parent 44f69a99b7
commit 46153b5a5e
2 changed files with 202 additions and 166 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
bin/clawd.js
View File

@@ -8,6 +8,7 @@ const path = require('path');
const { exec } = require('child_process');
const { ClawClient } = require('../lib/client');
const log = require('../lib/logger');
const { pollSms } = require('../drivers/sim/sms-reader');
// 每次启动绑定 Quectel 串口驱动（失败不影响主流程）
const bindScript = path.join(__dirname, '..', 'tools', 'bind-quectel-serial.sh');
@@ -16,15 +17,40 @@ exec(`bash "${bindScript}"`, (err, stdout, stderr) => {
else log.info('clawd', `bind-quectel-serial: ok`);
});
let smsTimer = null;
let smsPolling = false;
async function pollSmsSafe() {
if (smsPolling) return;
smsPolling = true;
try {
const text = await pollSms();
process.stdout.write(text);
} catch (err) {
log.warn('clawd', `sms-reader poll failed: ${err.message}`);
} finally {
smsPolling = false;
}
}
const client = new ClawClient();
client.start();
pollSmsSafe();
smsTimer = setInterval(pollSmsSafe, 15_000);
let stopping = false;
function shutdown(signal) {
if (stopping) return;
stopping = true;
log.info('clawd', `收到 ${signal}，正在停止...`);
if (smsTimer) {
clearInterval(smsTimer);
smsTimer = null;
}
client.stop();
setTimeout(() => process.exit(0), 500);
}

342
drivers/sim/sms-reader.js
View File

@@ -3,31 +3,25 @@
/**
* SIM 卡短信读取器
* - 扫描 /dev/serial/by-path 中以 :1.3-port0 结尾的 Quectel AT 串口
* - 每 15 秒读取一次，过滤 5 分钟内的短信
* - 去重后追加写入 ~/sms-messages.txt
* - 单次执行：读取并覆盖写入 /home/sts/sms-messages.txt
* - 不去重
* - 显示短信真实时间（取自 +CMGL 头）
* - 只保留最近 15 分钟内的短信
* - 多卡安全长短信拼接：按 IMSI + From + timestampRaw 合并相邻分片
*/
const fs = require('fs');
const path = require('path');
const os = require('os');
const crypto = require('crypto');
const fs = require('fs');
const path = require('path');
const { execSync } = require('child_process');
const BY_PATH_DIR = '/dev/serial/by-path';
const TARGET_SUFFIX = ':1.3-port0';
const OUT_FILE = path.join(os.homedir(), 'sms-messages.txt');
const STATE_FILE = path.join(os.homedir(), '.sms-seen.json');
const BAUD = 9600;
const POLL_MS = 15_000;
const WINDOW_MINUTES = 5;
const SEEN_LIMIT = 2000;
// ── 工具 ─────────────────────────────────────────────────────────────────────
const BY_PATH_DIR = '/dev/serial/by-path';
const TARGET_SUFFIX = ':1.3-port0';
const OUT_FILE = '/home/sts/sms-messages.txt';
const BAUD = 9600;
const WINDOW_MINUTES = 15;
const sleep = ms => new Promise(r => setTimeout(r, ms));
// ── 串口操作 ──────────────────────────────────────────────────────────────────
function setupPort(dev) {
execSync(
`stty -F "${dev}" ${BAUD} cs8 -cstopb -parenb cread clocal -crtscts raw ` +
@@ -36,11 +30,10 @@ function setupPort(dev) {
);
}
/** 读取串口原始数据，直到 OK/ERROR 或超时 */
async function readRaw(fd, timeoutMs = 2000, stopOnOk = true) {
const buf = Buffer.alloc(4096);
const buf = Buffer.alloc(4096);
const deadline = Date.now() + timeoutMs;
let text = '';
let text = '';
while (Date.now() < deadline) {
let n = 0;
@@ -53,7 +46,6 @@ async function readRaw(fd, timeoutMs = 2000, stopOnOk = true) {
if (n > 0) {
text += buf.slice(0, n).toString('utf8');
if (stopOnOk && (/\nOK|\rOK|ERROR/.test(text))) {
// 排尽剩余缓冲
await sleep(120);
try {
while (true) {
@@ -71,10 +63,10 @@ async function readRaw(fd, timeoutMs = 2000, stopOnOk = true) {
return text;
}
/** 发送 AT 命令，返回清理后的响应行数组 */
async function atCmd(fd, command, waitMs = 2000) {
// 清空输入缓冲
try { while (fs.readSync(fd, Buffer.alloc(256), 0, 256, null) > 0) {} } catch (_) {}
try {
while (fs.readSync(fd, Buffer.alloc(256), 0, 256, null) > 0) {}
} catch (_) {}
fs.writeSync(fd, Buffer.from(command + '\r'));
const raw = await readRaw(fd, waitMs, true);
return cleanLines(raw);
@@ -94,8 +86,6 @@ function cleanLines(raw) {
});
}
// ── 端口发现 ──────────────────────────────────────────────────────────────────
function discoverPorts() {
if (!fs.existsSync(BY_PATH_DIR)) return [];
return fs.readdirSync(BY_PATH_DIR)
@@ -106,217 +96,237 @@ function discoverPorts() {
try {
const real = fs.realpathSync(link);
return fs.existsSync(real) ? { link, real } : null;
} catch (_) { return null; }
} catch (_) {
return null;
}
})
.filter(Boolean);
}
// ── SMS 解析 ──────────────────────────────────────────────────────────────────
/** 尝试将纯 UCS2 hex 解码为中文 */
function maybeDecodeUcs2(text) {
const s = (text || '').replace(/\s+/g, '');
if (!s || s.length % 4 !== 0) return '';
if (/^\d+$/.test(s)) return ''; // 纯数字不解码（验证码原文）
if (!s) return '';
if (/^\d+$/.test(s)) return '';
if (s.length % 4 !== 0) return '';
if (!/^[0-9A-Fa-f]+$/.test(s)) return '';
try {
const decoded = Buffer.from(s, 'hex').toString('utf16le');
// utf16le 是 little-endian，Quectel 发的是 big-endian，需交换字节
const beDecoded = Buffer.from(s, 'hex').swap16().toString('utf16le');
const printable = c => c >= ' ';
const score = s => [...s].filter(printable).length / Math.max(1, s.length);
const best = score(beDecoded) >= score(decoded) ? beDecoded : decoded;
return score(best) >= 0.85 ? best.trim() : '';
} catch (_) { return ''; }
return Buffer.from(s, 'hex').swap16().toString('utf16le').trim();
} catch (_) {
return '';
}
}
/** 从文本提取 4-8 位验证码 */
function extractOtp(text) {
const m = (text || '').match(/(?<!\d)(\d{4,8})(?!\d)/);
return m ? m[1] : '';
}
/** 解析 +CMGL 响应行为消息对象数组 */
function parseSmsTimestamp(raw) {
if (!raw) return null;
const m = raw.match(/^(\d{2})\/(\d{2})\/(\d{2}),(\d{2}):(\d{2}):(\d{2})([+-]\d{2})$/);
if (!m) return null;
const [, yy, mo, dd, hh, mi, ss, tzq] = m;
const year = 2000 + Number(yy);
const offsetMinutes = Number(tzq) * 15;
const sign = offsetMinutes >= 0 ? '+' : '-';
const abs = Math.abs(offsetMinutes);
const offH = String(Math.floor(abs / 60)).padStart(2, '0');
const offM = String(abs % 60).padStart(2, '0');
const iso = `${year}-${mo}-${dd}T${hh}:${mi}:${ss}${sign}${offH}:${offM}`;
const d = new Date(iso);
return Number.isNaN(d.getTime()) ? null : d;
}
function formatDate(d) {
if (!d || Number.isNaN(d.getTime())) return 'UNKNOWN';
const pad = n => String(n).padStart(2, '0');
const y = d.getFullYear();
const mo = pad(d.getMonth() + 1);
const da = pad(d.getDate());
const hh = pad(d.getHours());
const mi = pad(d.getMinutes());
const ss = pad(d.getSeconds());
const offset = -d.getTimezoneOffset();
const sign = offset >= 0 ? '+' : '-';
const abs = Math.abs(offset);
const offH = pad(Math.floor(abs / 60));
const offM = pad(abs % 60);
return `${y}-${mo}-${da} ${hh}:${mi}:${ss} ${sign}${offH}${offM}`;
}
function recentOnly(messages, minutes = WINDOW_MINUTES) {
const cutoff = Date.now() - minutes * 60 * 1000;
return messages.filter(msg => {
if (!msg.timestamp || Number.isNaN(msg.timestamp.getTime())) return false;
return msg.timestamp.getTime() >= cutoff;
});
}
function parseSms(lines) {
const messages = [];
let current = null;
for (const line of lines) {
if (line.startsWith('+CMGL:') || line.startsWith('+CMGR:')) {
const parts = line.split(',').map(p => p.trim().replace(/^"|"$/g, ''));
const sender = line.startsWith('+CMGL:')
? (parts[2] || 'UNKNOWN')
: (parts[1] || 'UNKNOWN');
// 时间戳在 +CMGL: idx,stat,sender,,"yy/MM/dd,HH:mm:ss+tz"
const tsRaw = parts[4] || '';
current = { sender, tsRaw, timestamp: parseTimestamp(tsRaw), content: '', decoded: '' };
if (line.startsWith('+CMGL:')) {
const m = line.match(/^\+CMGL:\s*\d+,"[^"]*","([^"]*)",,"(\d{2}\/\d{2}\/\d{2},\d{2}:\d{2}:\d{2}[+-]\d{2})"$/);
const sender = m ? (m[1] || 'UNKNOWN') : 'UNKNOWN';
const timestampRaw = m ? m[2] : '';
current = {
sender,
timestampRaw,
timestamp: parseSmsTimestamp(timestampRaw),
content: '',
decoded: '',
code: '',
};
messages.push(current);
} else if (current && !line.startsWith('+')) {
continue;
}
if (line.startsWith('+CMGR:')) {
const parts = line.split(',').map(p => p.trim().replace(/^\"|\"$/g, ''));
const sender = parts[1] || 'UNKNOWN';
current = {
sender,
timestampRaw: '',
timestamp: null,
content: '',
decoded: '',
code: '',
};
messages.push(current);
continue;
}
if (current && !line.startsWith('+')) {
const raw = (current.content + ' ' + line).trim();
current.content = raw;
current.decoded = maybeDecodeUcs2(raw);
current.code = extractOtp(current.decoded || current.content);
current = null;
}
}
return messages;
}
/** 解析 Quectel 时间戳 "26/04/30,12:34:56+32"（+tz 单位 1/4 小时） */
function parseTimestamp(raw) {
if (!raw) return new Date();
const m = raw.match(/(\d{2})\/(\d{2})\/(\d{2}),(\d{2}):(\d{2}):(\d{2})([+-]\d+)?/);
if (!m) return new Date();
const [, yy, mo, dd, hh, mm, ss, tz] = m;
const tzMin = tz ? parseInt(tz) * 15 : 0;
const iso = `20${yy}-${mo}-${dd}T${hh}:${mm}:${ss}${tzOffsetStr(tzMin)}`;
const d = new Date(iso);
return isNaN(d) ? new Date() : d;
}
function mergeLongSms(imsi, messages) {
const merged = [];
function tzOffsetStr(totalMin) {
const sign = totalMin >= 0 ? '+' : '-';
const abs = Math.abs(totalMin);
const h = String(Math.floor(abs / 60)).padStart(2, '0');
const m = String(abs % 60).padStart(2, '0');
return `${sign}${h}:${m}`;
}
for (const msg of messages) {
const prev = merged[merged.length - 1];
const sameGroup =
prev &&
(prev._mergeImsi === imsi) &&
(prev.sender === msg.sender) &&
(prev.timestampRaw === msg.timestampRaw);
/** 过滤 N 分钟内的短信 */
function recentOnly(messages, minutes = WINDOW_MINUTES) {
const cutoff = Date.now() - minutes * 60 * 1000;
return messages.filter(m => m.timestamp >= cutoff);
}
// ── 去重 ──────────────────────────────────────────────────────────────────────
function fingerprint(imsi, msg) {
const key = [
imsi || 'UNKNOWN',
msg.sender || 'UNKNOWN',
msg.decoded || msg.content || '',
msg.timestamp.toISOString(),
].join('|');
return crypto.createHash('sha1').update(key).digest('hex');
}
function loadSeen() {
try {
const data = JSON.parse(fs.readFileSync(STATE_FILE, 'utf8'));
return Array.isArray(data) ? data : [];
} catch (_) { return []; }
}
function saveSeen(seen) {
fs.writeFileSync(STATE_FILE, JSON.stringify(seen.slice(-SEEN_LIMIT), null, 2), 'utf8');
}
function filterNew(results, seen) {
const seenSet = new Set(seen);
const newSeen = [...seen];
const filtered = [];
for (const item of results) {
const msgs = [];
for (const msg of item.messages) {
const fp = fingerprint(item.imsi, msg);
if (seenSet.has(fp)) continue;
seenSet.add(fp);
newSeen.push(fp);
msgs.push(msg);
if (!sameGroup) {
merged.push({
...msg,
_mergeImsi: imsi,
});
continue;
}
filtered.push({ ...item, messages: msgs });
}
return { filtered, newSeen: newSeen.slice(-SEEN_LIMIT) };
}
// ── 读取一个端口 ──────────────────────────────────────────────────────────────
prev.content = [prev.content, msg.content].filter(Boolean).join('');
const prevText = prev.decoded || prev.content || '';
const nextText = msg.decoded || msg.content || '';
const joinedText = [prevText, nextText].filter(Boolean).join('');
// 合并后优先重新按整体判断是否可解码；否则用拼接后的文本
const redecoded = maybeDecodeUcs2((prev.content || ''));
prev.decoded = redecoded || joinedText;
prev.code = extractOtp(prev.decoded || prev.content);
}
return merged.map(({ _mergeImsi, ...rest }) => rest);
}
async function readPort({ link, real }) {
let fd;
try {
setupPort(real);
fd = fs.openSync(real, fs.constants.O_RDWR | fs.constants.O_NOCTTY | fs.constants.O_NONBLOCK);
// 排空缓冲
await readRaw(fd, 400, false);
// 获取 IMSI
const cimiLines = await atCmd(fd, 'AT+CIMI');
const imsiMatch = cimiLines.join('\n').match(/\b(\d{15})\b/);
const imsi = imsiMatch ? imsiMatch[1] : 'UNKNOWN';
// 切换文本模式
await atCmd(fd, 'AT+CMGF=1');
// 读取所有短信
const smsLines = await atCmd(fd, 'AT+CMGL="ALL"', 4000);
const messages = recentOnly(parseSms(smsLines));
const parsed = parseSms(smsLines);
const merged = mergeLongSms(imsi, parsed);
const messages = recentOnly(merged, WINDOW_MINUTES);
return { link, device: real, imsi, messages };
} catch (e) {
return { link, device: real, imsi: 'UNKNOWN', messages: [], error: e.message };
} finally {
if (fd !== undefined) try { fs.closeSync(fd); } catch (_) {}
if (fd !== undefined) {
try { fs.closeSync(fd); } catch (_) {}
}
}
}
// ── 输出渲染 ──────────────────────────────────────────────────────────────────
function render(results) {
const now = new Date().toLocaleString('zh-CN', { hour12: false,
const now = new Date().toLocaleString('zh-CN', {
hour12: false,
year: 'numeric', month: '2-digit', day: '2-digit',
hour: '2-digit', minute: '2-digit', second: '2-digit',
timeZoneName: 'short' });
timeZoneName: 'short',
});
const lines = [`=== ${now} ===`];
if (!results.length) {
lines.push('No matching ports found.');
return lines.join('\n') + '\n';
}
let anySms = false;
for (const item of results) {
const errStr = item.error ? ` ERROR: ${item.error}` : '';
lines.push(`Port: ${item.device} IMSI: ${item.imsi} Messages: ${item.messages.length}${errStr}`);
const errStr = item.error ? ` ERROR: ${item.error}` : '';
lines.push(`Port: ${item.device} IMSI: ${item.imsi} Messages: ${item.messages.length}${errStr}`);
for (const msg of item.messages) {
anySms = true;
lines.push(`Time: ${msg.timestamp.toLocaleString('zh-CN', { hour12: false })}`);
lines.push(`IMSI: ${item.imsi}`);
lines.push(`From: ${msg.sender}`);
lines.push(`SmsTime: ${formatDate(msg.timestamp)}`);
lines.push(`IMSI: ${item.imsi}`);
lines.push(`From: ${msg.sender}`);
lines.push(`Content: ${msg.decoded || msg.content}`);
const otp = extractOtp(msg.decoded || msg.content);
if (otp) lines.push(`Code: ${otp}`);
if (msg.code) lines.push(`Code: ${msg.code}`);
lines.push('');
}
}
if (!anySms) lines.push(`No new SMS in last ${WINDOW_MINUTES} minutes.`);
if (!anySms) lines.push(`No SMS found in last ${WINDOW_MINUTES} minutes.`);
return lines.join('\n').trimEnd() + '\n';
}
// ── 主循环 ────────────────────────────────────────────────────────────────────
async function poll() {
const ports = discoverPorts();
async function pollSms() {
const ports = discoverPorts();
const results = await Promise.all(ports.map(readPort));
for (const item of results) {
for (const msg of item.messages) {
msg.otp = extractOtp(msg.decoded || msg.content);
}
}
const seen = loadSeen();
const { filtered, newSeen } = filterNew(results, seen);
const text = render(filtered);
fs.appendFileSync(OUT_FILE, text, 'utf8');
saveSeen(newSeen);
process.stdout.write(text);
const text = render(results);
fs.writeFileSync(OUT_FILE, text, 'utf8');
return text;
}
async function main() {
console.log(`SIM SMS reader started. Poll every ${POLL_MS / 1000}s → ${OUT_FILE}`);
while (true) {
try {
await poll();
} catch (e) {
console.error('poll error:', e.message);
}
await sleep(POLL_MS);
}
}
module.exports = { pollSms };
main();
if (require.main === module) {
pollSms()
.then(text => process.stdout.write(text))
.catch(err => {
console.error(`sms-reader error: ${err.message}`);
process.exitCode = 1;
});
}