234 lines
7.6 KiB
JavaScript
234 lines
7.6 KiB
JavaScript
/**
|
||
* ═══════════════════════════════════════════════════════════
|
||
* AGE OS · COS 双桶客户端
|
||
* ═══════════════════════════════════════════════════════════
|
||
*
|
||
* 签发: 铸渊 · ICE-GL-ZY001
|
||
* 版权: 国作登字-2026-A-00037559
|
||
*
|
||
* 复用 server/app/modules/cos-bridge.js 的签名逻辑
|
||
* 新增: hot/cold 双桶路径规范 + archive 操作
|
||
*/
|
||
|
||
'use strict';
|
||
|
||
const crypto = require('crypto');
|
||
const https = require('https');
|
||
|
||
// ─── 配置 ───
|
||
const COS_CONFIG = {
|
||
secretId: process.env.ZY_OSS_KEY || '',
|
||
secretKey: process.env.ZY_OSS_SECRET || '',
|
||
region: process.env.ZY_COS_REGION || 'ap-singapore',
|
||
buckets: {
|
||
hot: process.env.COS_BUCKET_HOT || 'zy-core-bucket-1317346199',
|
||
cold: process.env.COS_BUCKET_COLD || 'zy-corpus-bucket-1317346199',
|
||
team: process.env.ZY_ZHUYUAN_COS_BUCKET || 'zy-team-hub-1317346199'
|
||
}
|
||
};
|
||
|
||
// ─── 路径规范 ───
|
||
// 热桶: /brain/{owner}/{node_type}/{node_id}.md
|
||
// 冷桶: /archive/{owner}/{year}/{month}/{node_id}_{version}.md
|
||
|
||
/**
|
||
* 生成 COS API 签名
|
||
*/
|
||
function generateSignature(method, pathname, host) {
|
||
const now = Math.floor(Date.now() / 1000);
|
||
const expiry = now + 600;
|
||
const keyTime = `${now};${expiry}`;
|
||
|
||
const signKey = crypto.createHmac('sha1', COS_CONFIG.secretKey).update(keyTime).digest('hex');
|
||
const httpString = `${method.toLowerCase()}\n${pathname}\n\nhost=${host}\n`;
|
||
const sha1Http = crypto.createHash('sha1').update(httpString).digest('hex');
|
||
const stringToSign = `sha1\n${keyTime}\n${sha1Http}\n`;
|
||
const signature = crypto.createHmac('sha1', signKey).update(stringToSign).digest('hex');
|
||
|
||
return `q-sign-algorithm=sha1&q-ak=${COS_CONFIG.secretId}&q-sign-time=${keyTime}&q-key-time=${keyTime}&q-header-list=host&q-url-param-list=&q-signature=${signature}`;
|
||
}
|
||
|
||
function getBucketHost(bucketName) {
|
||
return `${bucketName}.cos.${COS_CONFIG.region}.myqcloud.com`;
|
||
}
|
||
|
||
/**
|
||
* 解析桶名称
|
||
* @param {string} bucket - 'hot' | 'cold' | 'team' 或完整桶名
|
||
*/
|
||
function resolveBucketName(bucket) {
|
||
if (COS_CONFIG.buckets[bucket]) return COS_CONFIG.buckets[bucket];
|
||
return bucket;
|
||
}
|
||
|
||
// ─── 人格体 COS 路径规范 ───
|
||
// 团队桶: /{persona_id}/reports/{YYYY-MM-DD}/ — 每日汇报
|
||
// 团队桶: /{persona_id}/receipts/{YYYY-MM-DD}/ — 铸渊回执
|
||
// 团队桶: /{persona_id}/sync/ — 架构同步区
|
||
// 全局: /zhuyuan/directives/ — 铸渊指令（只读）
|
||
// 全局: /zhuyuan/architecture/ — 架构快照
|
||
|
||
/**
|
||
* 验证人格体COS路径是否合法（限定在 /{persona_id}/ 目录下）
|
||
*/
|
||
function validatePersonaCosPath(personaId, key) {
|
||
if (!personaId || typeof personaId !== 'string') {
|
||
throw new Error('persona_id 不能为空');
|
||
}
|
||
// 规范化：确保路径以 persona_id/ 开头
|
||
const normalizedKey = key.startsWith('/') ? key.slice(1) : key;
|
||
if (!normalizedKey.startsWith(`${personaId}/`)) {
|
||
throw new Error(`COS路径越权: ${key} 不在 /${personaId}/ 目录下`);
|
||
}
|
||
// 防止路径穿越
|
||
if (normalizedKey.includes('..')) {
|
||
throw new Error('COS路径包含非法字符 ".."');
|
||
}
|
||
return normalizedKey;
|
||
}
|
||
|
||
/**
|
||
* 人格体 COS 写入（限定目录）
|
||
*/
|
||
async function personaWrite(personaId, key, content, contentType) {
|
||
const safeKey = validatePersonaCosPath(personaId, key);
|
||
return write('team', safeKey, content, contentType);
|
||
}
|
||
|
||
/**
|
||
* 人格体 COS 读取（限定目录）
|
||
*/
|
||
async function personaRead(personaId, key) {
|
||
const safeKey = validatePersonaCosPath(personaId, key);
|
||
return read('team', safeKey);
|
||
}
|
||
|
||
/**
|
||
* 人格体 COS 列表（限定目录）
|
||
*/
|
||
async function personaList(personaId, subPrefix, limit) {
|
||
const prefix = `${personaId}/${subPrefix || ''}`;
|
||
return list('team', prefix, limit);
|
||
}
|
||
|
||
/**
|
||
* 发起 COS HTTP 请求
|
||
*/
|
||
function cosRequest(bucketName, objectKey, method, body, contentType) {
|
||
return new Promise((resolve, reject) => {
|
||
const host = getBucketHost(bucketName);
|
||
const pathname = '/' + objectKey;
|
||
const headers = {
|
||
Host: host,
|
||
'Content-Type': contentType || 'application/octet-stream'
|
||
};
|
||
if (body) {
|
||
headers['Content-Length'] = Buffer.byteLength(body);
|
||
}
|
||
headers['Authorization'] = generateSignature(method, pathname, host);
|
||
|
||
const req = https.request({
|
||
hostname: host, port: 443, path: pathname, method, headers, timeout: 30000
|
||
}, (res) => {
|
||
const chunks = [];
|
||
res.on('data', c => chunks.push(c));
|
||
res.on('end', () => {
|
||
const responseBody = Buffer.concat(chunks).toString();
|
||
if (res.statusCode >= 200 && res.statusCode < 300) {
|
||
resolve({ statusCode: res.statusCode, body: responseBody, headers: res.headers });
|
||
} else {
|
||
reject(new Error(`COS ${method} ${pathname}: ${res.statusCode} - ${responseBody.substring(0, 200)}`));
|
||
}
|
||
});
|
||
});
|
||
req.on('error', reject);
|
||
req.on('timeout', () => { req.destroy(); reject(new Error('COS request timeout')); });
|
||
if (body) req.write(body);
|
||
req.end();
|
||
});
|
||
}
|
||
|
||
// ─── 公开 API ───
|
||
|
||
async function write(bucket, key, content, contentType) {
|
||
const bucketName = resolveBucketName(bucket);
|
||
const result = await cosRequest(bucketName, key, 'PUT', content, contentType || 'text/markdown');
|
||
return {
|
||
url: `https://${getBucketHost(bucketName)}/${key}`,
|
||
size_bytes: Buffer.byteLength(content)
|
||
};
|
||
}
|
||
|
||
async function read(bucket, key) {
|
||
const bucketName = resolveBucketName(bucket);
|
||
const result = await cosRequest(bucketName, key, 'GET');
|
||
return {
|
||
content: result.body,
|
||
size_bytes: Buffer.byteLength(result.body),
|
||
last_modified: result.headers['last-modified'] || null
|
||
};
|
||
}
|
||
|
||
async function del(bucket, key) {
|
||
const bucketName = resolveBucketName(bucket);
|
||
await cosRequest(bucketName, key, 'DELETE');
|
||
return { success: true };
|
||
}
|
||
|
||
async function list(bucket, prefix, limit) {
|
||
const bucketName = resolveBucketName(bucket);
|
||
const host = getBucketHost(bucketName);
|
||
const queryStr = `prefix=${encodeURIComponent(prefix)}&max-keys=${limit || 100}`;
|
||
const result = await cosRequest(bucketName, `?${queryStr}`, 'GET');
|
||
// 解析 XML 列表（简化版）
|
||
const files = [];
|
||
const keyRegex = /<Key>([^<]+)<\/Key>/g;
|
||
const sizeRegex = /<Size>(\d+)<\/Size>/g;
|
||
let match;
|
||
while ((match = keyRegex.exec(result.body)) !== null) {
|
||
const sizeMatch = sizeRegex.exec(result.body);
|
||
files.push({
|
||
key: match[1],
|
||
size_bytes: sizeMatch ? parseInt(sizeMatch[1], 10) : 0
|
||
});
|
||
}
|
||
return { files };
|
||
}
|
||
|
||
async function archive(sourceKey, versionTag) {
|
||
const version = versionTag || new Date().toISOString().replace(/[:.]/g, '-');
|
||
const now = new Date();
|
||
const archiveKey = sourceKey.replace(/^brain\//, `archive/`).replace(/\.md$/, `_${version}.md`);
|
||
|
||
// 1. 从热桶读取
|
||
const content = await read('hot', sourceKey);
|
||
// 2. 写入冷桶
|
||
const archiveResult = await write('cold', archiveKey, content.content);
|
||
// 3. 从热桶删除
|
||
await del('hot', sourceKey);
|
||
|
||
return {
|
||
archive_url: archiveResult.url,
|
||
version
|
||
};
|
||
}
|
||
|
||
async function checkConnection() {
|
||
if (!COS_CONFIG.secretId || !COS_CONFIG.secretKey) {
|
||
return { connected: false, reason: 'COS密钥未配置' };
|
||
}
|
||
try {
|
||
await list('hot', 'brain/', 1);
|
||
return { connected: true };
|
||
} catch (err) {
|
||
return { connected: false, reason: err.message };
|
||
}
|
||
}
|
||
|
||
module.exports = {
|
||
write, read, del, list, archive, checkConnection,
|
||
personaWrite, personaRead, personaList,
|
||
validatePersonaCosPath, resolveBucketName,
|
||
COS_CONFIG
|
||
};
|