tailchat/server/plugins/com.msgbyte.topic/services/topic.service.ts

import _ from 'lodash';
import {
  TcService,
  TcDbService,
  TcContext,
  GroupPanelType,
  db,
  call,
} from 'tailchat-server-sdk';
import type { GroupTopicDocument, GroupTopicModel } from '../models/topic';
const { Types } = db;

/**
 * 群组话题
 */
interface GroupTopicService
  extends TcService,
    TcDbService<GroupTopicDocument, GroupTopicModel> {}
class GroupTopicService extends TcService {
  get serviceName(): string {
    return 'plugin:com.msgbyte.topic';
  }

  onInit(): void {
    this.registerLocalDb(require('../models/topic').default);

    this.registerAction('create', this.create, {
      params: {
        groupId: 'string',
        panelId: 'string',
        content: 'string',
      },
    });
  }

  /**
   * 创建一条Topic
   */
  async create(
    ctx: TcContext<{
      groupId: string;
      panelId: string;
      content: string;
    }>
  ) {
    const { groupId, panelId, content } = ctx.params;
    const userId = ctx.meta.userId;
    const t = ctx.meta.t;

    // 鉴权
    const group = await call(ctx).getGroupInfo(groupId);
    const isMember = group.members.some((member) => member.userId === userId);
    if (!isMember) {
      throw new Error(t('不是该群组成员'));
    }

    const targetPanel = group.panels.find((p) => p.id === panelId);

    if (!targetPanel) {
      throw new Error(t('面板不存在'));
    }
    const isPanelValid =
      targetPanel.type === GroupPanelType.TEXT &&
      _.get(targetPanel, ['meta', 'variant']) === 'topic';
    if (!isPanelValid) {
      throw new Error(t('面板类型不合法'));
    }

    const topic = await this.adapter.model.create({
      groupId: new Types.ObjectId(groupId),
      panelId,
      content,
      author: new Types.ObjectId(userId),
      comment: [],
    });

    const json = await this.transformDocuments(ctx, {}, topic);

    this.roomcastNotify(ctx, groupId, 'create', json);

    return true;
  }
}

export default GroupTopicService;