drop/server/internal/news/index.ts

import { triggerAsyncId } from "async_hooks";
import prisma from "../db/database";

class NewsManager {
  async create(data: {
    title: string;
    content: string;
    description: string;
    tags: string[];
    authorId: string;
    image?: string;
  }) {
    return await prisma.article.create({
      data: {
        title: data.title,
        description: data.description,
        content: data.content,

        tags: {
          connectOrCreate: data.tags.map((e) => ({
            where: { name: e },
            create: { name: e },
          })),
        },

        image: data.image,
        author: {
          connect: {
            id: data.authorId,
          },
        },
      },
    });
  }

  async fetch(
    options: {
      take?: number;
      skip?: number;
      orderBy?: "asc" | "desc";
      tags?: string[];
      search?: string;
    } = {}
  ) {
    return await prisma.article.findMany({
      where: {
        AND: [
          {
            tags: {
              some: { OR: options.tags?.map((e) => ({ name: e })) ?? [] },
            },
          },
          {
            title: {
              search: options.search
            },
            description: {
              search: options.search
            },
            content: {
              search: options.search
            }
          }
        ],
      },
      take: options?.take || 10,
      skip: options?.skip || 0,
      orderBy: {
        publishedAt: options?.orderBy || "desc",
      },
      include: {
        author: {
          select: {
            id: true,
            displayName: true,
          },
        },
      },
    });
  }

  async fetchById(id: string) {
    return await prisma.article.findUnique({
      where: { id },
      include: {
        author: {
          select: {
            id: true,
            displayName: true,
          },
        },
      },
    });
  }

  async update(
    id: string,
    data: {
      title?: string;
      content?: string;
      excerpt?: string;
      image?: string;
    }
  ) {
    return await prisma.article.update({
      where: { id },
      data,
    });
  }

  async delete(id: string) {
    return await prisma.article.delete({
      where: { id },
    });
  }
}

export default new NewsManager();