Method create

apps/web/services/messages/index.ts:21–164

({
    body,
    files,
    accountId,
    channelId,
    threadId,
    imitationId,
    userId,
    externalMessageId,
    mentions,
    messageFormat = MessageFormat.LINEN,
  }: {
    body: string;
    files?: UploadedFile[];
    accountId: string;
    channelId: string;
    threadId: string;
    imitationId?: string;
    userId: string;
    externalMessageId?: string;
    mentions?: { id: string }[];
    messageFormat?: MessageFormat;
  })

export default class MessagesService {
  static async create({
    body,
    files,
    accountId,
    channelId,
    threadId,
    imitationId,
    userId,
    externalMessageId,
    mentions,
    messageFormat = MessageFormat.LINEN,
  }: {
    body: string;
    files?: UploadedFile[];
    accountId: string;
    channelId: string;
    threadId: string;
    imitationId?: string;
    userId: string;
    externalMessageId?: string;
    mentions?: { id: string }[];
    messageFormat?: MessageFormat;
  }) {
    const account = await prisma.accounts.findFirst({
      where: { id: accountId },
    });
    if (!account) {
      throw new Error("can't find the account");
    }
    if (account.chat === ChatType.NONE) {
      throw new Error('chat is disabled');
    }
    const channel = await prisma.channels.findFirst({
      where: { id: channelId, accountId },
    });

    if (!channel || !channel.accountId || channel.accountId !== accountId) {
      throw new Error("can't find the channel");
    }

    const sentAt = new Date();

    const tree = parse.linen(body);
    const mentionNodes = mentions || find.mentions(tree);
    const userIds = unique<string>(
      mentionNodes.map(({ id }: { id: string }) => id)
    );
    const messages = {
      create: {
        body,
        channel: { connect: { id: channelId } },
        sentAt,
        author: { connect: { id: userId } },
        mentions: {
          create: userIds.map((id: string) => ({ usersId: id })),
        },
        externalMessageId,
        ...(files?.length && {