NapCatQQ/src/onebot/action/msg/MarkMsgAsRead.ts

import { ChatType, Peer } from '@/core/entities';
import BaseAction from '../BaseAction';
import { ActionName } from '../types';
import { FromSchema, JSONSchema } from 'json-schema-to-ts';

const SchemaData = {
    type: 'object',
    properties: {
        user_id: { type: ['number', 'string'] },
        group_id: { type: ['number', 'string'] },
    },
} as const satisfies JSONSchema;

type PlayloadType = FromSchema<typeof SchemaData>;

class MarkMsgAsRead extends BaseAction<PlayloadType, null> {
    async getPeer(payload: PlayloadType): Promise<Peer> {
        const NTQQUserApi = this.CoreContext.apis.UserApi;
        const NTQQFriendApi = this.CoreContext.apis.FriendApi;
        if (payload.user_id) {
            const peerUid = await NTQQUserApi.getUidByUinV2(payload.user_id.toString());
            if (!peerUid) {
                throw `私聊${payload.user_id}不存在`;
            }
            const isBuddy = await NTQQFriendApi.isBuddy(peerUid);
            return { chatType: isBuddy ? ChatType.KCHATTYPEC2C : ChatType.KCHATTYPETEMPC2CFROMGROUP, peerUid };
        }
        if (!payload.group_id) {
            throw '缺少参数 group_id 或 user_id';
        }
        return { chatType: ChatType.KCHATTYPEGROUP, peerUid: payload.group_id.toString() };
    }

    async _handle(payload: PlayloadType): Promise<null> {
        const NTQQMsgApi = this.CoreContext.apis.MsgApi;
        // 调用API
        const ret = await NTQQMsgApi.setMsgRead(await this.getPeer(payload));
        if (ret.result != 0) {
            throw new Error('设置已读失败,' + ret.errMsg);
        }
        return null;
    }
}

// 以下为非标准实现
export class MarkPrivateMsgAsRead extends MarkMsgAsRead {
    PayloadSchema = SchemaData;
    actionName = ActionName.MarkPrivateMsgAsRead;
}

export class MarkGroupMsgAsRead extends MarkMsgAsRead {
    PayloadSchema = SchemaData;
    actionName = ActionName.MarkGroupMsgAsRead;
}


interface Payload {
    message_id: number;
}

export class GoCQHTTPMarkMsgAsRead extends BaseAction<Payload, null> {
    actionName = ActionName.GoCQHTTP_MarkMsgAsRead;

    async _handle(payload: Payload): Promise<null> {
        return null;
    }
}

export class MarkAllMsgAsRead extends BaseAction<Payload, null> {
    actionName = ActionName._MarkAllMsgAsRead;

    async _handle(payload: Payload): Promise<null> {
        const NTQQMsgApi = this.CoreContext.apis.MsgApi;
        await NTQQMsgApi.markallMsgAsRead();
        return null;
    }
}