mirror of
https://github.com/NapNeko/NapCatQQ.git
synced 2026-02-11 15:30:25 +00:00
e37fa59b8c
* fix: get_group_info ownerUin is "0" * Add native module loading and improve logging Loaded a native module in NTQQGroupApi and added test calls to sendSsoCmdReqByContend with different parameter types. Changed fileLog default to true in config. Enhanced NativePacketClient with detailed send/receive logging. Updated NodeIKernelMsgService to accept unknown type for sendSsoCmdReqByContend param. Added process PID logging in napcat shell. * feat: new napcat-4.9.0-beta * feat: Add FFmpeg native addon and TypeScript definitions Introduced FFmpeg Node.js native addon binaries for multiple platforms (darwin-arm64, linux-arm64, linux-x64, win-x64) and added TypeScript type definitions for the addon interface, including video info extraction, duration detection, audio conversion, and PCM decoding. * Remove baseClient and simplify packet client selection Deleted baseClient.ts and moved its logic into nativeClient.ts, making NativePacketClient a standalone class. Refactored PacketClientContext to always use NativePacketClient, removing support for multiple packet backends and related selection logic. Updated binary for napi2native.win32.x64.node. * Remove debug log for process PID in napcat.ts Eliminated an unnecessary console.log statement that printed the process PID. This cleans up the output and removes leftover debugging code. * fix: getQQBuildStr * fix: 简化代码 * refactor: 大幅度调整send * feat: ffmpeg enhance for native node addon * Remove baseClient.ts from packet client module Deleted the src/core/packet/client/baseClient.ts file, which contained the PacketClient class and related interfaces. This may be part of a refactor or cleanup to remove unused or redundant code. * Remove 'bmp24' argument from getVideoInfo call Updated the extractThumbnail method to call addon.getVideoInfo without the 'bmp24' argument, aligning with the updated addon API. * refactor: 重构目录删除旧支持 * feat: raw包能力增强完成 * refactor: 规范化 * feat: packet能力增强 * feat: 9.9.22-40824 & 9.9.22-40768 * Refactor addon path resolution and rename Windows addon Simplifies the logic for resolving the ffmpeg addon path by dynamically constructing the filename from process.platform and process.arch. Also renames the Windows x64 addon file to ffmpegAddon.win32.x64.node for consistency. * Add mappings for 3.2.20 versions in napi2native.json Added send and recv address mappings for 3.2.20-x64 and 3.2.20-arm64 builds to support additional versions in napi2native.json. --------- Co-authored-by: Clansty <i@gao4.pw>
552 lines
22 KiB
TypeScript
552 lines
22 KiB
TypeScript
import {
|
||
ChatType,
|
||
ElementType,
|
||
IMAGE_HTTP_HOST,
|
||
IMAGE_HTTP_HOST_NT,
|
||
Peer,
|
||
PicElement,
|
||
PicSubType,
|
||
RawMessage,
|
||
SendFileElement,
|
||
SendPicElement,
|
||
SendPttElement,
|
||
SendVideoElement,
|
||
} from '@/core/types';
|
||
import path from 'path';
|
||
import fs from 'fs';
|
||
import fsPromises from 'fs/promises';
|
||
import { InstanceContext, NapCatCore, SearchResultItem } from '@/core';
|
||
import { fileTypeFromFile } from 'file-type';
|
||
import { RkeyManager } from '@/core/helper/rkey';
|
||
import { calculateFileMD5 } from '@/common/file';
|
||
import pathLib from 'node:path';
|
||
import { defaultVideoThumbB64 } from '@/common/video';
|
||
import { encodeSilk } from '@/common/audio';
|
||
import { SendMessageContext } from '@/onebot/api';
|
||
import { getFileTypeForSendType } from '../helper/msg';
|
||
import { FFmpegService } from '@/common/ffmpeg';
|
||
import { rkeyDataType } from '../types/file';
|
||
import { NapProtoMsg } from '@napneko/nap-proto-core';
|
||
import { FileId } from '../packet/transformer/proto/misc/fileid';
|
||
import { imageSizeFallBack } from '@/image-size';
|
||
|
||
export class NTQQFileApi {
|
||
context: InstanceContext;
|
||
core: NapCatCore;
|
||
rkeyManager: RkeyManager;
|
||
packetRkey: Array<{ rkey: string; time: number; type: number; ttl: bigint }> | undefined;
|
||
private fetchRkeyFailures: number = 0;
|
||
private readonly MAX_RKEY_FAILURES: number = 8;
|
||
|
||
constructor(context: InstanceContext, core: NapCatCore) {
|
||
this.context = context;
|
||
this.core = core;
|
||
this.rkeyManager = new RkeyManager([
|
||
'http://ss.xingzhige.com/music_card/rkey',
|
||
'https://secret-service.bietiaop.com/rkeys',
|
||
],
|
||
this.context.logger
|
||
);
|
||
}
|
||
|
||
private async fetchRkeyWithRetry() {
|
||
if (this.fetchRkeyFailures >= this.MAX_RKEY_FAILURES) {
|
||
throw new Error('Native.FetchRkey 已被禁用');
|
||
}
|
||
try {
|
||
let ret = await this.core.apis.PacketApi.pkt.operation.FetchRkey();
|
||
this.fetchRkeyFailures = 0; // Reset failures on success
|
||
return ret;
|
||
} catch (error) {
|
||
this.fetchRkeyFailures++;
|
||
this.context.logger.logError('FetchRkey 失败', (error as Error).message);
|
||
throw error;
|
||
}
|
||
}
|
||
|
||
async getFileUrl(chatType: ChatType, peer: string, fileUUID?: string, file10MMd5?: string | undefined,timeout: number = 5000) {
|
||
if (this.core.apis.PacketApi.packetStatus) {
|
||
try {
|
||
if (chatType === ChatType.KCHATTYPEGROUP && fileUUID) {
|
||
return this.core.apis.PacketApi.pkt.operation.GetGroupFileUrl(+peer, fileUUID, timeout);
|
||
} else if (file10MMd5 && fileUUID) {
|
||
return this.core.apis.PacketApi.pkt.operation.GetPrivateFileUrl(peer, fileUUID, file10MMd5, timeout);
|
||
}
|
||
} catch (error) {
|
||
this.context.logger.logError('获取文件URL失败', (error as Error).message);
|
||
}
|
||
}
|
||
throw new Error('fileUUID or file10MMd5 is undefined');
|
||
}
|
||
|
||
async getPttUrl(peer: string, fileUUID?: string,timeout: number = 5000) {
|
||
if (this.core.apis.PacketApi.packetStatus && fileUUID) {
|
||
let appid = new NapProtoMsg(FileId).decode(Buffer.from(fileUUID.replaceAll('-', '+').replaceAll('_', '/'), 'base64')).appid;
|
||
try {
|
||
if (appid && appid === 1403) {
|
||
return this.core.apis.PacketApi.pkt.operation.GetGroupPttUrl(+peer, {
|
||
fileUuid: fileUUID,
|
||
storeId: 1,
|
||
uploadTime: 0,
|
||
ttl: 0,
|
||
subType: 0,
|
||
}, timeout);
|
||
} else if (fileUUID) {
|
||
return this.core.apis.PacketApi.pkt.operation.GetPttUrl(peer, {
|
||
fileUuid: fileUUID,
|
||
storeId: 1,
|
||
uploadTime: 0,
|
||
ttl: 0,
|
||
subType: 0,
|
||
}, timeout);
|
||
}
|
||
} catch (error) {
|
||
this.context.logger.logError('获取文件URL失败', (error as Error).message);
|
||
}
|
||
}
|
||
throw new Error('packet cant get ptt url');
|
||
}
|
||
|
||
async getVideoUrlPacket(peer: string, fileUUID?: string,timeout: number = 5000) {
|
||
if (this.core.apis.PacketApi.packetStatus && fileUUID) {
|
||
let appid = new NapProtoMsg(FileId).decode(Buffer.from(fileUUID.replaceAll('-', '+').replaceAll('_', '/'), 'base64')).appid;
|
||
try {
|
||
if (appid && appid === 1415) {
|
||
return this.core.apis.PacketApi.pkt.operation.GetGroupVideoUrl(+peer, {
|
||
fileUuid: fileUUID,
|
||
storeId: 1,
|
||
uploadTime: 0,
|
||
ttl: 0,
|
||
subType: 0,
|
||
}, timeout);
|
||
} else if (fileUUID) {
|
||
return this.core.apis.PacketApi.pkt.operation.GetVideoUrl(peer, {
|
||
fileUuid: fileUUID,
|
||
storeId: 1,
|
||
uploadTime: 0,
|
||
ttl: 0,
|
||
subType: 0,
|
||
}, timeout);
|
||
}
|
||
} catch (error) {
|
||
this.context.logger.logError('获取文件URL失败', (error as Error).message);
|
||
}
|
||
}
|
||
throw new Error('packet cant get video url');
|
||
}
|
||
|
||
async copyFile(filePath: string, destPath: string) {
|
||
await this.core.util.copyFile(filePath, destPath);
|
||
}
|
||
|
||
async getFileSize(filePath: string): Promise<number> {
|
||
return await this.core.util.getFileSize(filePath);
|
||
}
|
||
|
||
async getVideoUrl(peer: Peer, msgId: string, elementId: string) {
|
||
return (await this.context.session.getRichMediaService().getVideoPlayUrlV2(peer, msgId, elementId, 0, {
|
||
downSourceType: 1,
|
||
triggerType: 1,
|
||
})).urlResult.domainUrl;
|
||
}
|
||
|
||
async uploadFile(filePath: string, elementType: ElementType = ElementType.PIC, elementSubType: number = 0) {
|
||
const fileMd5 = await calculateFileMD5(filePath);
|
||
const extOrEmpty = await fileTypeFromFile(filePath).then(e => e?.ext ?? '').catch(() => '');
|
||
const ext = extOrEmpty ? `.${extOrEmpty}` : '';
|
||
let fileName = `${path.basename(filePath)}`;
|
||
if (fileName.indexOf('.') === -1) {
|
||
fileName += ext;
|
||
}
|
||
|
||
const mediaPath = this.context.session.getMsgService().getRichMediaFilePathForGuild({
|
||
md5HexStr: fileMd5,
|
||
fileName: fileName,
|
||
elementType: elementType,
|
||
elementSubType,
|
||
thumbSize: 0,
|
||
needCreate: true,
|
||
downloadType: 1,
|
||
file_uuid: '',
|
||
});
|
||
|
||
await this.copyFile(filePath, mediaPath);
|
||
const fileSize = await this.getFileSize(filePath);
|
||
return {
|
||
md5: fileMd5,
|
||
fileName,
|
||
path: mediaPath,
|
||
fileSize,
|
||
ext,
|
||
};
|
||
}
|
||
|
||
async createValidSendFileElement(context: SendMessageContext, filePath: string, fileName: string = '', folderId: string = '',): Promise<SendFileElement> {
|
||
const {
|
||
fileName: _fileName,
|
||
path,
|
||
fileSize,
|
||
} = await this.core.apis.FileApi.uploadFile(filePath, ElementType.FILE);
|
||
if (fileSize === 0) {
|
||
throw new Error('文件异常，大小为0');
|
||
}
|
||
context.deleteAfterSentFiles.push(path);
|
||
return {
|
||
elementType: ElementType.FILE,
|
||
elementId: '',
|
||
fileElement: {
|
||
fileName: fileName || _fileName,
|
||
folderId: folderId,
|
||
filePath: path,
|
||
fileSize: fileSize.toString(),
|
||
},
|
||
};
|
||
}
|
||
|
||
async createValidSendPicElement(context: SendMessageContext, picPath: string, summary: string = '', subType: PicSubType = 0): Promise<SendPicElement> {
|
||
const { md5, fileName, path, fileSize } = await this.core.apis.FileApi.uploadFile(picPath, ElementType.PIC, subType);
|
||
if (fileSize === 0) {
|
||
throw new Error('文件异常，大小为0');
|
||
}
|
||
const imageSize = await imageSizeFallBack(picPath);
|
||
context.deleteAfterSentFiles.push(path);
|
||
return {
|
||
elementType: ElementType.PIC,
|
||
elementId: '',
|
||
picElement: {
|
||
md5HexStr: md5,
|
||
fileSize: fileSize.toString(),
|
||
picWidth: imageSize.width,
|
||
picHeight: imageSize.height,
|
||
fileName: fileName,
|
||
sourcePath: path,
|
||
original: true,
|
||
picType: await getFileTypeForSendType(picPath),
|
||
picSubType: subType,
|
||
fileUuid: '',
|
||
fileSubId: '',
|
||
thumbFileSize: 0,
|
||
summary,
|
||
} as PicElement,
|
||
};
|
||
}
|
||
|
||
async createValidSendVideoElement(context: SendMessageContext, filePath: string, fileName: string = '', _diyThumbPath: string = ''): Promise<SendVideoElement> {
|
||
let videoInfo = {
|
||
width: 1920,
|
||
height: 1080,
|
||
time: 15,
|
||
format: 'mp4',
|
||
size: 0,
|
||
filePath,
|
||
};
|
||
let fileExt = 'mp4';
|
||
try {
|
||
const tempExt = (await fileTypeFromFile(filePath))?.ext;
|
||
if (tempExt) fileExt = tempExt;
|
||
} catch (e) {
|
||
this.context.logger.logError('获取文件类型失败', e);
|
||
}
|
||
const newFilePath = `${filePath}.${fileExt}`;
|
||
fs.copyFileSync(filePath, newFilePath);
|
||
context.deleteAfterSentFiles.push(newFilePath);
|
||
filePath = newFilePath;
|
||
|
||
const { fileName: _fileName, path, fileSize, md5 } = await this.core.apis.FileApi.uploadFile(filePath, ElementType.VIDEO);
|
||
context.deleteAfterSentFiles.push(path);
|
||
if (fileSize === 0) {
|
||
throw new Error('文件异常，大小为0');
|
||
}
|
||
const thumbDir = path.replace(`${pathLib.sep}Ori${pathLib.sep}`, `${pathLib.sep}Thumb${pathLib.sep}`);
|
||
fs.mkdirSync(pathLib.dirname(thumbDir), { recursive: true });
|
||
const thumbPath = pathLib.join(pathLib.dirname(thumbDir), `${md5}_0.png`);
|
||
try {
|
||
videoInfo = await FFmpegService.getVideoInfo(filePath, thumbPath);
|
||
if (!fs.existsSync(thumbPath)) {
|
||
this.context.logger.logError('获取视频缩略图失败', new Error('缩略图不存在'));
|
||
throw new Error('获取视频缩略图失败');
|
||
}
|
||
} catch (e) {
|
||
this.context.logger.logError('获取视频信息失败', e);
|
||
fs.writeFileSync(thumbPath, Buffer.from(defaultVideoThumbB64, 'base64'));
|
||
}
|
||
if (_diyThumbPath) {
|
||
try {
|
||
await this.copyFile(_diyThumbPath, thumbPath);
|
||
} catch (e) {
|
||
this.context.logger.logError('复制自定义缩略图失败', e);
|
||
}
|
||
}
|
||
context.deleteAfterSentFiles.push(thumbPath);
|
||
const thumbSize = (await fsPromises.stat(thumbPath)).size;
|
||
const thumbMd5 = await calculateFileMD5(thumbPath);
|
||
context.deleteAfterSentFiles.push(thumbPath);
|
||
|
||
|
||
const uploadName = (fileName || _fileName).toLocaleLowerCase().endsWith(`.${fileExt.toLocaleLowerCase()}`) ? (fileName || _fileName) : `${fileName || _fileName}.${fileExt}`;
|
||
return {
|
||
elementType: ElementType.VIDEO,
|
||
elementId: '',
|
||
videoElement: {
|
||
fileName: uploadName,
|
||
filePath: path,
|
||
videoMd5: md5,
|
||
thumbMd5,
|
||
fileTime: videoInfo.time,
|
||
thumbPath: new Map([[0, thumbPath]]),
|
||
thumbSize,
|
||
thumbWidth: videoInfo.width,
|
||
thumbHeight: videoInfo.height,
|
||
fileSize: fileSize.toString(),
|
||
},
|
||
};
|
||
}
|
||
async createValidSendPttElement(_context: SendMessageContext, pttPath: string): Promise<SendPttElement> {
|
||
|
||
const { converted, path: silkPath, duration } = await encodeSilk(pttPath, this.core.NapCatTempPath, this.core.context.logger);
|
||
if (!silkPath) {
|
||
throw new Error('语音转换失败, 请检查语音文件是否正常');
|
||
}
|
||
const { md5, fileName, path, fileSize } = await this.core.apis.FileApi.uploadFile(silkPath, ElementType.PTT);
|
||
if (fileSize === 0) {
|
||
throw new Error('文件异常，大小为0');
|
||
}
|
||
if (converted) {
|
||
fsPromises.unlink(silkPath).then().catch((e) => this.context.logger.logError('删除临时文件失败', e));
|
||
}
|
||
return {
|
||
elementType: ElementType.PTT,
|
||
elementId: '',
|
||
pttElement: {
|
||
fileName: fileName,
|
||
filePath: path,
|
||
md5HexStr: md5,
|
||
fileSize: fileSize.toString(),
|
||
duration: duration ?? 1,
|
||
formatType: 1,
|
||
voiceType: 1,
|
||
voiceChangeType: 0,
|
||
canConvert2Text: true,
|
||
waveAmplitudes: [
|
||
0, 18, 9, 23, 16, 17, 16, 15, 44, 17, 24, 20, 14, 15, 17,
|
||
],
|
||
fileSubId: '',
|
||
playState: 1,
|
||
autoConvertText: 0,
|
||
},
|
||
};
|
||
}
|
||
|
||
async downloadFileForModelId(peer: Peer, modelId: string, unknown: string, timeout = 1000 * 60 * 2) {
|
||
const [, fileTransNotifyInfo] = await this.core.eventWrapper.callNormalEventV2(
|
||
'NodeIKernelRichMediaService/downloadFileForModelId',
|
||
'NodeIKernelMsgListener/onRichMediaDownloadComplete',
|
||
[peer, [modelId], unknown],
|
||
() => true,
|
||
(arg) => arg?.commonFileInfo?.fileModelId === modelId,
|
||
1,
|
||
timeout,
|
||
);
|
||
return fileTransNotifyInfo.filePath;
|
||
}
|
||
|
||
async downloadRawMsgMedia(msg: RawMessage[]) {
|
||
const res = await Promise.all(
|
||
msg.map(m =>
|
||
Promise.all(
|
||
m.elements
|
||
.filter(element =>
|
||
element.elementType === ElementType.PIC ||
|
||
element.elementType === ElementType.VIDEO ||
|
||
element.elementType === ElementType.PTT ||
|
||
element.elementType === ElementType.FILE
|
||
)
|
||
.map(element =>
|
||
this.downloadMedia(m.msgId, m.chatType, m.peerUid, element.elementId, '', '', 1000 * 60 * 2, true)
|
||
)
|
||
)
|
||
)
|
||
);
|
||
msg.forEach((m, msgIndex) => {
|
||
const elementResults = res[msgIndex];
|
||
let elementIndex = 0;
|
||
m.elements.forEach(element => {
|
||
if (
|
||
element.elementType === ElementType.PIC ||
|
||
element.elementType === ElementType.VIDEO ||
|
||
element.elementType === ElementType.PTT ||
|
||
element.elementType === ElementType.FILE
|
||
) {
|
||
switch (element.elementType) {
|
||
case ElementType.PIC:
|
||
element.picElement!.sourcePath = elementResults?.[elementIndex] ?? '';
|
||
break;
|
||
case ElementType.VIDEO:
|
||
element.videoElement!.filePath = elementResults?.[elementIndex] ?? '';
|
||
break;
|
||
case ElementType.PTT:
|
||
element.pttElement!.filePath = elementResults?.[elementIndex] ?? '';
|
||
break;
|
||
case ElementType.FILE:
|
||
element.fileElement!.filePath = elementResults?.[elementIndex] ?? '';
|
||
break;
|
||
}
|
||
elementIndex++;
|
||
}
|
||
});
|
||
});
|
||
return res.flat();
|
||
}
|
||
|
||
async downloadMedia(msgId: string, chatType: ChatType, peerUid: string, elementId: string, thumbPath: string, sourcePath: string, timeout = 1000 * 60 * 2, force: boolean = false) {
|
||
// 用于下载文件
|
||
if (sourcePath && fs.existsSync(sourcePath)) {
|
||
if (force) {
|
||
try {
|
||
await fsPromises.unlink(sourcePath);
|
||
} catch {
|
||
//
|
||
}
|
||
} else {
|
||
return sourcePath;
|
||
}
|
||
}
|
||
const [, completeRetData] = await this.core.eventWrapper.callNormalEventV2(
|
||
'NodeIKernelMsgService/downloadRichMedia',
|
||
'NodeIKernelMsgListener/onRichMediaDownloadComplete',
|
||
[{
|
||
fileModelId: '0',
|
||
downSourceType: 0,
|
||
downloadSourceType: 0,
|
||
triggerType: 1,
|
||
msgId: msgId,
|
||
chatType: chatType,
|
||
peerUid: peerUid,
|
||
elementId: elementId,
|
||
thumbSize: 0,
|
||
downloadType: 1,
|
||
filePath: thumbPath,
|
||
}],
|
||
() => true,
|
||
(arg) => arg.msgElementId === elementId && arg.msgId === msgId,
|
||
1,
|
||
timeout,
|
||
);
|
||
return completeRetData.filePath;
|
||
}
|
||
|
||
|
||
async searchForFile(keys: string[]): Promise<SearchResultItem | undefined> {
|
||
const randomResultId = 100000 + Math.floor(Math.random() * 10000);
|
||
let searchId = 0;
|
||
const [, searchResult] = await this.core.eventWrapper.callNormalEventV2(
|
||
'NodeIKernelFileAssistantService/searchFile',
|
||
'NodeIKernelFileAssistantListener/onFileSearch',
|
||
[
|
||
keys,
|
||
{ resultType: 2, pageLimit: 1 },
|
||
randomResultId,
|
||
],
|
||
(ret) => {
|
||
searchId = ret;
|
||
return true;
|
||
},
|
||
result => result.searchId === searchId && result.resultId === randomResultId,
|
||
);
|
||
return searchResult.resultItems[0];
|
||
}
|
||
|
||
async downloadFileById(
|
||
fileId: string,
|
||
fileSize: number = 1024576,
|
||
estimatedTime: number = (fileSize * 1000 / 1024576) + 5000,
|
||
) {
|
||
const [, fileData] = await this.core.eventWrapper.callNormalEventV2(
|
||
'NodeIKernelFileAssistantService/downloadFile',
|
||
'NodeIKernelFileAssistantListener/onFileStatusChanged',
|
||
[[fileId]],
|
||
ret => ret.result === 0,
|
||
status => status.fileStatus === 2 && status.fileProgress === '0',
|
||
1,
|
||
estimatedTime, // estimate 1MB/s
|
||
);
|
||
return fileData.filePath!;
|
||
}
|
||
|
||
async getImageUrl(element: PicElement): Promise<string> {
|
||
if (!element) {
|
||
return '';
|
||
}
|
||
|
||
const url: string = element.originImageUrl ?? '';
|
||
|
||
const md5HexStr = element.md5HexStr;
|
||
const fileMd5 = element.md5HexStr;
|
||
const parsedUrl = new URL(IMAGE_HTTP_HOST + url);
|
||
const imageAppid = parsedUrl.searchParams.get('appid');
|
||
const isNTV2 = imageAppid && ['1406', '1407'].includes(imageAppid);
|
||
const imageFileId = parsedUrl.searchParams.get('fileid');
|
||
if (url && isNTV2 && imageFileId) {
|
||
const rkeyData = await this.getRkeyData();
|
||
return this.getImageUrlFromParsedUrl(imageFileId, imageAppid, rkeyData);
|
||
}
|
||
return this.getImageUrlFromMd5(fileMd5, md5HexStr);
|
||
}
|
||
|
||
private async getRkeyData() {
|
||
const rkeyData: rkeyDataType = {
|
||
private_rkey: 'CAQSKAB6JWENi5LM_xp9vumLbuThJSaYf-yzMrbZsuq7Uz2qEc3Rbib9LP4',
|
||
group_rkey: 'CAQSKAB6JWENi5LM_xp9vumLbuThJSaYf-yzMrbZsuq7Uz2qffcqm614gds',
|
||
online_rkey: false
|
||
};
|
||
|
||
try {
|
||
if (this.core.apis.PacketApi.packetStatus) {
|
||
const rkey_expired_private = !this.packetRkey || (this.packetRkey[0] && this.packetRkey[0].time + Number(this.packetRkey[0].ttl) < Date.now() / 1000);
|
||
const rkey_expired_group = !this.packetRkey || (this.packetRkey[0] && this.packetRkey[0].time + Number(this.packetRkey[0].ttl) < Date.now() / 1000);
|
||
if (rkey_expired_private || rkey_expired_group) {
|
||
this.packetRkey = await this.fetchRkeyWithRetry();
|
||
}
|
||
if (this.packetRkey && this.packetRkey.length > 0) {
|
||
rkeyData.group_rkey = this.packetRkey[1]?.rkey.slice(6) ?? '';
|
||
rkeyData.private_rkey = this.packetRkey[0]?.rkey.slice(6) ?? '';
|
||
rkeyData.online_rkey = true;
|
||
}
|
||
}
|
||
} catch (error: unknown) {
|
||
this.context.logger.logDebug('获取native.rkey失败', (error as Error).message);
|
||
}
|
||
|
||
if (!rkeyData.online_rkey) {
|
||
try {
|
||
const tempRkeyData = await this.rkeyManager.getRkey();
|
||
rkeyData.group_rkey = tempRkeyData.group_rkey;
|
||
rkeyData.private_rkey = tempRkeyData.private_rkey;
|
||
rkeyData.online_rkey = tempRkeyData.expired_time > Date.now() / 1000;
|
||
} catch (error: unknown) {
|
||
this.context.logger.logDebug('获取remote.rkey失败', (error as Error).message);
|
||
}
|
||
}
|
||
// 进行 fallback.rkey 模式
|
||
return rkeyData;
|
||
}
|
||
|
||
private getImageUrlFromParsedUrl(imageFileId: string, appid: string, rkeyData: rkeyDataType): string {
|
||
const rkey = appid === '1406' ? rkeyData.private_rkey : rkeyData.group_rkey;
|
||
if (rkeyData.online_rkey) {
|
||
return IMAGE_HTTP_HOST_NT + `/download?appid=${appid}&fileid=${imageFileId}&rkey=${rkey}`;
|
||
}
|
||
return IMAGE_HTTP_HOST + `/download?appid=${appid}&fileid=${imageFileId}&rkey=${rkey}&spec=0`;
|
||
}
|
||
|
||
private getImageUrlFromMd5(fileMd5: string | undefined, md5HexStr: string | undefined): string {
|
||
if (fileMd5 || md5HexStr) {
|
||
return `${IMAGE_HTTP_HOST}/gchatpic_new/0/0-0-${(fileMd5 ?? md5HexStr ?? '').toUpperCase()}/0`;
|
||
}
|
||
|
||
this.context.logger.logDebug('图片url获取失败', { fileMd5, md5HexStr });
|
||
return '';
|
||
}
|
||
}
|
||
|