feat: music card sign

This commit is contained in:
student_2333 2024-04-30 12:50:38 +08:00
parent f38e544815
commit 6ff49722d8
No known key found for this signature in database
GPG Key ID: B36E8DF853C33EE1
6 changed files with 81 additions and 20 deletions

View File

@ -52,6 +52,7 @@ export class ConfigUtil {
autoDeleteFile: false, autoDeleteFile: false,
autoDeleteFileSecond: 60, autoDeleteFileSecond: 60,
enablePoke: false, enablePoke: false,
musicSignUrl: '',
} }
if (!fs.existsSync(this.configPath)) { if (!fs.existsSync(this.configPath)) {

View File

@ -28,6 +28,7 @@ export interface Config {
autoDeleteFileSecond?: number autoDeleteFileSecond?: number
ffmpeg?: string // ffmpeg路径 ffmpeg?: string // ffmpeg路径
enablePoke?: boolean enablePoke?: boolean
musicSignUrl?: string
} }
export interface LLOneBotError { export interface LLOneBotError {

35
src/common/utils/sign.ts Normal file
View File

@ -0,0 +1,35 @@
import { log } from './log'
export interface IdMusicSignPostData {
type: 'qq' | '163'
id: string | number
}
export interface CustomMusicSignPostData {
type: 'custom'
url: string
audio: string
title: string
image?: string
singer?: string
}
export class MusicSign {
private readonly url: string
constructor(url: string) {
this.url = url
}
async sign(postData: CustomMusicSignPostData | IdMusicSignPostData): Promise<any> {
const resp = await fetch(this.url, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify(postData),
})
if (!resp.ok) throw new Error(resp.statusText)
const data = await resp.json()
log('音乐消息生成成功', data)
return data
}
}

View File

@ -16,6 +16,7 @@ import {
OB11MessageData, OB11MessageData,
OB11MessageDataType, OB11MessageDataType,
OB11MessageMixType, OB11MessageMixType,
OB11MessageMusic,
OB11MessageNode, OB11MessageNode,
OB11PostSendMsg, OB11PostSendMsg,
} from '../../types' } from '../../types'
@ -26,12 +27,13 @@ import { ActionName, BaseCheckResult } from '../types'
import * as fs from 'node:fs' import * as fs from 'node:fs'
import { decodeCQCode } from '../../cqcode' import { decodeCQCode } from '../../cqcode'
import { dbUtil } from '../../../common/db' import { dbUtil } from '../../../common/db'
import { ALLOW_SEND_TEMP_MSG } from '../../../common/config' import { ALLOW_SEND_TEMP_MSG, getConfigUtil } from '../../../common/config'
import { log } from '../../../common/utils/log' import { log } from '../../../common/utils/log'
import { sleep } from '../../../common/utils/helper' import { sleep } from '../../../common/utils/helper'
import { uri2local } from '../../../common/utils' import { uri2local } from '../../../common/utils'
import { crychic } from '../../../ntqqapi/external/crychic' import { crychic } from '../../../ntqqapi/external/crychic'
import { NTQQGroupApi } from '../../../ntqqapi/api' import { NTQQGroupApi } from '../../../ntqqapi/api'
import { MusicSign } from '../../../common/utils/sign'
function checkSendMessage(sendMsgList: OB11MessageData[]) { function checkSendMessage(sendMsgList: OB11MessageData[]) {
function checkUri(uri: string): boolean { function checkUri(uri: string): boolean {
@ -376,16 +378,26 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
} }
} else { } else {
if (this.getSpecialMsgNum(payload, OB11MessageDataType.music)) { if (this.getSpecialMsgNum(payload, OB11MessageDataType.music)) {
const music: OB11MessageCustomMusic = messages[0] as OB11MessageCustomMusic const music = messages[0] as OB11MessageMusic
if (music) { if (music) {
const { url, audio, title, content, image } = music.data const { musicSignUrl } = getConfigUtil().getConfig()
const selfPeer: Peer = { peerUid: selfInfo.uid, chatType: ChatType.friend } if (!musicSignUrl) {
// 搞不定! throw '音乐签名地址未配置'
// const musicMsg = await this.send(selfPeer, [this.genMusicElement(url, audio, title, content, image)], [], false) }
// 转发 const { type } = music.data
// const res = await NTQQApi.forwardMsg(selfPeer, peer, [musicMsg.msgId]) if (!['qq', '163', 'custom'].includes(type)) {
// log("转发音乐消息成功", res); throw `不支持的音乐类型 ${type}`
// return {message_id: musicMsg.msgShortId} }
let jsonContent: string
try {
jsonContent = await new MusicSign(musicSignUrl).sign(music.data)
} catch (e) {
throw `签名音乐消息失败:${e}`
}
messages[0] = {
type: OB11MessageDataType.json,
data: { data: jsonContent },
}
} }
} }
} }

View File

@ -1,5 +1,6 @@
import { PicSubType, RawMessage } from '../ntqqapi/types' import { PicSubType, RawMessage } from '../ntqqapi/types'
import { EventType } from './event/OB11BaseEvent' import { EventType } from './event/OB11BaseEvent'
import { IdMusicSignPostData, CustomMusicSignPostData } from '../common/utils/sign'
export interface OB11User { export interface OB11User {
user_id: number user_id: number
@ -219,18 +220,18 @@ export interface OB11MessageNode {
} }
} }
export interface OB11MessageIdMusic {
type: OB11MessageDataType.music
data: IdMusicSignPostData
}
export interface OB11MessageCustomMusic { export interface OB11MessageCustomMusic {
type: OB11MessageDataType.music type: OB11MessageDataType.music
data: { data: Omit<CustomMusicSignPostData, 'singer'> & { content?: string }
type: 'custom'
url: string
audio: string
title: string
content?: string
image?: string
}
} }
export type OB11MessageMusic = OB11MessageIdMusic | OB11MessageCustomMusic
export interface OB11MessageJson { export interface OB11MessageJson {
type: OB11MessageDataType.json type: OB11MessageDataType.json
data: { config: { token: string } } & any data: { config: { token: string } } & any
@ -247,6 +248,7 @@ export type OB11MessageData =
| OB11MessageFile | OB11MessageFile
| OB11MessageVideo | OB11MessageVideo
| OB11MessageNode | OB11MessageNode
| OB11MessageIdMusic
| OB11MessageCustomMusic | OB11MessageCustomMusic
| OB11MessageJson | OB11MessageJson
| OB11MessagePoke | OB11MessagePoke

View File

@ -95,7 +95,9 @@ async function onSettingWindowCreated(view: Element) {
<setting-text>HTTP </setting-text> <setting-text>HTTP </setting-text>
</div> </div>
<div class="q-input"> <div class="q-input">
<input id="config-ob11-httpSecret" class="q-input__inner" data-config-key="ob11.httpSecret" type="text" value="${config.ob11.httpSecret}" placeholder="未设置" /> <input id="config-ob11-httpSecret" class="q-input__inner" data-config-key="ob11.httpSecret" type="text" value="${
config.ob11.httpSecret
}" placeholder="" />
</div> </div>
</setting-item> </setting-item>
<setting-item data-direction="row"> <setting-item data-direction="row">
@ -158,9 +160,17 @@ async function onSettingWindowCreated(view: Element) {
), ),
SettingItem( SettingItem(
'ffmpeg 路径发送语音、视频需要同时保证ffprobe和ffmpeg在一起', 'ffmpeg 路径发送语音、视频需要同时保证ffprobe和ffmpeg在一起',
` <a href="javascript:LiteLoader.api.openExternal(\'https://llonebot.github.io/zh-CN/guide/ffmpeg\');">下载地址</a> <span id="config-ffmpeg-path-text">, 路径:${!isEmpty(config.ffmpeg) ? config.ffmpeg : '未指定'}</span>`, ` <a href="javascript:LiteLoader.api.openExternal(\'https://llonebot.github.io/zh-CN/guide/ffmpeg\');">下载地址</a> <span id="config-ffmpeg-path-text">, 路径:${
!isEmpty(config.ffmpeg) ? config.ffmpeg : '未指定'
}</span>`,
SettingButton('选择ffmpeg', 'config-ffmpeg-select'), SettingButton('选择ffmpeg', 'config-ffmpeg-select'),
), ),
SettingItem(
'音乐卡片签名地址',
null,
`<div class="q-input" style="width:210px;"><input class="q-input__inner" data-config-key="musicSignUrl" type="text" value="${config.musicSignUrl}" placeholder="未设置" /></div>`,
'config-musicSignUrl',
),
SettingItem('', null, SettingButton('保存', 'config-ob11-save', 'primary')), SettingItem('', null, SettingButton('保存', 'config-ob11-save', 'primary')),
]), ]),
SettingList([ SettingList([