api.ts

import type { NextApiRequest, NextApiResponse } from 'next';
import Parser from 'rss-parser';
import { HashnodePost } from '../../utils/types';
import { RSS_FEED_URL } from '../../utils/utils';
import { prisma } from '../../lib/prisma';
import { Post } from '@prisma/client';

export default async function handler(
  _req: NextApiRequest,
  res: NextApiResponse
) {
  const parser = new Parser();
  const feed = await parser.parseURL(RSS_FEED_URL);
  const posts = feed.items as HashnodePost[];

  const addedPosts: Post[] = [];

  for (const post of posts) {
    // find if the post already exists in the db
    const existingPost = await prisma.post.findFirst({
      where: {
        link: post.link,
      },
    });

    if (existingPost) {
      // if it does, skip it
      continue;
    } else {
      // if it doesn't, create it
      const addedPost = await prisma.post.create({
        data: {
          title: post.title,
          link: post.link,
          author: post.creator,
          pubDate: '05-20-2022',
        },
      });
      addedPosts.push(addedPost);
    }
  }

  res.status(200).json({ count: addedPosts.length, posts: addedPosts });
}