Schedule unfeaturing listing in 7 days with Trigger

ResilienceWeb · Oct 27, 2024 · 92c3534 · 92c3534
1 parent aa7a9eb
commit 92c3534
Show file tree

Hide file tree

Showing 5 changed files with 28 additions and 28 deletions.
diff --git a/app/api/hello-world/route.ts b/app/api/hello-world/route.ts
diff --git a/app/api/listing/[id]/feature/route.ts b/app/api/listing/[id]/feature/route.ts
@@ -1,4 +1,6 @@
 import prisma from '@prisma-rw'
+import { unfeatureListingTask } from '@trigger/unfeature-listing'
+import { tasks } from '@trigger.dev/sdk/v3'
 
 export async function PATCH(_request, { params }) {
   try {
@@ -13,6 +15,9 @@ export async function PATCH(_request, { params }) {
       },
     })
 
+    const handle = await unfeatureListingTask.trigger({ listingId })
+    console.log('[RW]Task is running with handle', handle.id)
+
     return Response.json({
       listing,
     })

diff --git a/hooks/listings/useFeatureListing.tsx b/hooks/listings/useFeatureListing.tsx
@@ -11,7 +11,7 @@ const featureListingRequest = async (id) => {
   return listing
 }
 
-const unfeatureListingRequest = async (id) => {
+export const unfeatureListingRequest = async (id) => {
   const response = await fetch(`api/listing/${id}/unfeature`, {
     method: 'PATCH',
   })

diff --git a/trigger/example.ts b/trigger/example.ts
diff --git a/trigger/unfeature-listing.ts b/trigger/unfeature-listing.ts
@@ -0,0 +1,22 @@
+import { logger, task, wait } from '@trigger.dev/sdk/v3'
+import { REMOTE_URL } from '@helpers/config'
+
+export const unfeatureListingTask = task({
+  id: 'unfeature-listing',
+  run: async (payload: any, { ctx }) => {
+    logger.log('Scheduling job to unfeature listing in 7 days', {
+      payload,
+      ctx,
+    })
+    const { listingId } = payload
+
+    await wait.for({ minutes: 1 })
+    await fetch(`${REMOTE_URL}/api/listing/${listingId}/unfeature`, {
+      method: 'PATCH',
+    })
+
+    return {
+      message: 'Hello, world!',
+    }
+  },
+})