星月
85e58ae239
- Move all Hermes skills from skills/ to hermes/ - Add cursor/ for Cursor rules (.mdc) - Add code-review.mdc (Gitea PR review with tea CLI) - Update sync.sh to use new hermes/ path - Update README with new structure
108 lines
3.7 KiB
JavaScript
108 lines
3.7 KiB
JavaScript
#!/usr/bin/env node
|
|
// Usage: node scripts/feishu-send-image.mjs <target> <image_path>
|
|
// target: "user:open_id_xxx" or "oc_xxx" (chat_id)
|
|
|
|
import { readFileSync, writeFileSync, existsSync } from 'fs';
|
|
import { resolve } from 'path';
|
|
import { homedir } from 'os';
|
|
|
|
const API = 'https://open.feishu.cn/open-apis';
|
|
const TOKEN_CACHE = '/tmp/feishu-token.json';
|
|
|
|
const [target, imagePath] = process.argv.slice(2);
|
|
if (!target || !imagePath) {
|
|
console.error('Usage: node scripts/feishu-send-image.mjs <target> <image_path>');
|
|
process.exit(1);
|
|
}
|
|
|
|
// --- credentials (env vars preferred, fallback to openclaw.json) ---
|
|
let appId = process.env.FEISHU_APP_ID;
|
|
let appSecret = process.env.FEISHU_APP_SECRET;
|
|
|
|
if (!appId || !appSecret) {
|
|
try {
|
|
const configPath = resolve(homedir(), '.openclaw/openclaw.json');
|
|
const config = JSON.parse(readFileSync(configPath, 'utf8'));
|
|
const accounts = config.channels?.feishu?.accounts ?? {};
|
|
const acctName = process.env.FEISHU_ACCOUNT || Object.keys(accounts)[0];
|
|
const acct = accounts[acctName];
|
|
appId = acct?.appId;
|
|
appSecret = acct?.appSecret;
|
|
} catch {}
|
|
}
|
|
if (!appId || !appSecret) {
|
|
console.error('Missing credentials. Set FEISHU_APP_ID + FEISHU_APP_SECRET env vars, or configure ~/.openclaw/openclaw.json');
|
|
process.exit(1);
|
|
}
|
|
|
|
// --- tenant_access_token (cached) ---
|
|
async function getToken() {
|
|
if (existsSync(TOKEN_CACHE)) {
|
|
try {
|
|
const cached = JSON.parse(readFileSync(TOKEN_CACHE, 'utf8'));
|
|
if (cached.token && cached.expiresAt > Date.now() + 60_000) return cached.token;
|
|
} catch {}
|
|
}
|
|
const res = await fetch(`${API}/auth/v3/tenant_access_token/internal`, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify({ app_id: appId, app_secret: appSecret }),
|
|
});
|
|
const data = await res.json();
|
|
if (data.code !== 0) throw new Error(`token error: ${data.msg}`);
|
|
const token = data.tenant_access_token;
|
|
writeFileSync(TOKEN_CACHE, JSON.stringify({ token, expiresAt: Date.now() + data.expire * 1000 }));
|
|
return token;
|
|
}
|
|
|
|
// --- upload image ---
|
|
async function uploadImage(token, filePath) {
|
|
const absPath = resolve(filePath);
|
|
const bytes = readFileSync(absPath);
|
|
const blob = new Blob([bytes]);
|
|
const form = new FormData();
|
|
form.append('image_type', 'message');
|
|
form.append('image', blob, absPath.split('/').pop());
|
|
const res = await fetch(`${API}/im/v1/images`, {
|
|
method: 'POST',
|
|
headers: { Authorization: `Bearer ${token}` },
|
|
body: form,
|
|
});
|
|
const data = await res.json();
|
|
if (data.code !== 0) throw new Error(`upload error: ${data.code} ${data.msg}`);
|
|
return data.data.image_key;
|
|
}
|
|
|
|
// --- send message ---
|
|
async function sendImage(token, target, imageKey) {
|
|
let receiveIdType, receiveId;
|
|
if (target.startsWith('user:')) {
|
|
receiveIdType = 'open_id';
|
|
receiveId = target.slice(5);
|
|
} else {
|
|
receiveIdType = 'chat_id';
|
|
receiveId = target;
|
|
}
|
|
const res = await fetch(`${API}/im/v1/messages?receive_id_type=${receiveIdType}`, {
|
|
method: 'POST',
|
|
headers: { Authorization: `Bearer ${token}`, 'Content-Type': 'application/json' },
|
|
body: JSON.stringify({ receive_id: receiveId, msg_type: 'image', content: JSON.stringify({ image_key: imageKey }) }),
|
|
});
|
|
const data = await res.json();
|
|
if (data.code !== 0) throw new Error(`send error: ${data.code} ${data.msg}`);
|
|
return data.data.message_id;
|
|
}
|
|
|
|
// --- main ---
|
|
try {
|
|
const token = await getToken();
|
|
console.log('token ok');
|
|
const imageKey = await uploadImage(token, imagePath);
|
|
console.log('uploaded:', imageKey);
|
|
const msgId = await sendImage(token, target, imageKey);
|
|
console.log('sent:', msgId);
|
|
} catch (e) {
|
|
console.error(e.message);
|
|
process.exit(1);
|
|
}
|