Updated reddit lib to use new db.

Author: digitalnomad91

src/app/api/reddit/messages/fetch/route.ts

@@ -1,5 +1,5 @@
 import { NextResponse } from 'next/server'
-import { checkRedditMessages } from '@/lib/reddit'
+import { checkRedditMessages } from '@/lib/jobs/reddit'
 
 export async function GET() {
   try {

src/app/api/reddit/posts/fetch/route.ts

@@ -1,37 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import { fetchRedditPosts, storePosts } from '@/lib/reddit'
-import webpush from 'web-push'
-import prisma from '@/lib/db'
-
-// List of subreddits to monitor for new posts
-const SUBREDDITS = [
-  'forhire',
-  'jobs4bitcoins',
-  'freelance',
-  'remotejs',
-  'jobs4dogecoins',
-  'jobs4crypto',
-]
-
-// Set up web-push VAPID keys for push notifications
-webpush.setVapidDetails(
-  'mailto:your-email@example.com',
-  process.env.NEXT_PUBLIC_VAPID_PUBLIC_KEY!,
-  process.env.VAPID_PRIVATE_KEY!
-)
-
-export async function GET(req: NextRequest) {
-  try {
-    const posts = await fetchRedditPosts(SUBREDDITS)
-    const hiringPosts = posts.filter((post) => post.title.includes('[Hiring]'))
-
-    await storePosts(hiringPosts)
-
-    return NextResponse.json({ message: 'Posts fetched and stored successfully.' })
-  } catch (error) {
-    console.error(error)
-    return NextResponse.json({ error: 'An error occurred while fetching posts.' }, { status: 500 })
-  } finally {
-    await prisma.$disconnect()
-  }
-}

src/app/api/reddit/posts/route.ts

@@ -1,36 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import prisma from '@/lib/db'
-import { withLogging } from '@/lib/logger'
-
-export const GET = withLogging(async (request: NextRequest) => {
-  try {
-    // Parse query parameters for pagination
-    const { searchParams } = new URL(request.url)
-    const page = parseInt(searchParams.get('page') || '1', 10)
-    const pageSize = parseInt(searchParams.get('pageSize') || '10', 10)
-
-    // Calculate skip value
-    const skip = (page - 1) * pageSize
-
-    // Fetch paginated posts from Prisma
-    const posts = await prisma.redditPost.findMany({
-      orderBy: { createdAt: 'desc' },
-      skip,
-      take: pageSize,
-      // select: { id: true, title: true, ... } // You can choose which fields to return
-    })
-
-    // Optionally, get the total number of posts to return along with pagination info
-    const totalCount = await prisma.redditPost.count()
-
-    return NextResponse.json({
-      data: posts,
-      page,
-      pageSize,
-      totalCount,
-    })
-  } catch (error) {
-    // Handle any errors
-    return NextResponse.json({ error: (error as Error).message }, { status: 500 })
-  }
-})