Function getIntegration

apps/web/services/matrix/index.ts:4–24

(id: string, model: 'threads' | 'messages')

import axios from 'axios';

async function getIntegration(id: string, model: 'threads' | 'messages') {
  const query = {
    where: { id },
    select: {
      channel: {
        select: {
          account: {
            select: {
              integrationMatrix: true,
            },
          },
        },
      },
    },
  };
  const matrix =
    model === 'threads'
      ? await prisma.threads.findUnique(query)
      : await prisma.messages.findUnique(query);
  return matrix?.channel.account?.integrationMatrix.find((i) => i.enabled);
}

export async function matrixNewThread({
  threadId,