feat(postings): ability to expire postings (#184)

app/components/admin/PostingCard.vue

@@ -45,9 +45,15 @@ if (props.posting && props.posting.tagsCSV) {
       <footer class="mt-5">
         <div class="text-sm font-medium text-gray-500 mb-2">Created {{ timeAgo(new Date(posting.createdAt)) }}</div>
         <div class="flex justify-between items-center">
+          <div
+            class="text-xs font-medium rounded-lg text-center px-2.5 py-1 bg-red-100 text-red-700"
+            v-if="posting.isExpired"
+          >
+            Expired
+          </div>
           <div
             class="text-xs font-medium rounded-lg text-center px-2.5 py-1 bg-green-100 text-green-700"
-            v-if="posting.isPublished"
+            v-else-if="posting.isPublished"
           >
             Published
           </div>

nuxt.config.ts

@@ -8,6 +8,11 @@ const composeVersion = () => {
   }
 };
 
+const cronSchedule: Record<string, string[]> = {
+  // Every day, at 00:00.
+  '0 0 * * *': ['cron:expire-postings'],
+};
+
 // https://nuxt.com/docs/api/configuration/nuxt-config
 export default defineNuxtConfig({
   future: {
@@ -17,6 +22,7 @@ export default defineNuxtConfig({
     experimental: {
       tasks: true,
     },
+    scheduledTasks: cronSchedule,
   },
   routeRules: {
     '/admin/**': { ssr: false },

server/api/posting/index.put.ts

@@ -13,6 +13,20 @@ export default defineEventHandler(async (event) => {
     console.log('updating posting id', q.id);
   }
 
+  const isPostingAlreadyExpired = (
+    await database
+      .select({ isExpired: jobPostingsTable.isExpired })
+      .from(jobPostingsTable)
+      .where(eq(jobPostingsTable.id, q.id))
+  )[0]?.isExpired;
+
+  if (isPostingAlreadyExpired) {
+    throw createError({
+      statusCode: 400,
+      statusMessage: 'Expired postings cannot be updated.',
+    });
+  }
+
   const updateQuery = {
     ...q,
     updatedAt: new Date(),
@@ -23,12 +37,15 @@ export default defineEventHandler(async (event) => {
   )[0] as JobPosting;
 
   const postings = (await general_memoryStorage.getItem<JobPosting[]>('postings')) || [];
+  const updatedPostings = postings.map((p) => {
+    if (p.id == updatedJobPosting.id) return updatedJobPosting;
+    return p;
+  });
+
+  await general_memoryStorage.setItem('postings', updatedPostings);
 
   await general_memoryStorage.setItem(
-    'postings',
-    postings.map((p) => {
-      if (p.id == updatedJobPosting.id) return updatedJobPosting;
-      return p;
-    })
+    'totalActivePostings',
+    updatedPostings.filter((p) => !p.isExpired && p.isPublished).length
   );
 });

server/api/public/posting.get.ts

@@ -15,7 +15,7 @@ export default defineEventHandler(async (event) => {
   }
 
   const postings = ((await general_memoryStorage.getItem<JobPosting[]>('postings')) || [])
-    .filter((p) => p.id === query.id && p.isPublished)
+    .filter((p) => p.id === query.id && p.isPublished && !p.isExpired)
     .map((p) => {
       return {
         ...p,

server/api/public/postings.get.ts

@@ -2,7 +2,7 @@ import { type JobPosting } from '~~/server/db/schema';
 
 export default defineEventHandler(async (_) => {
   const postings = ((await general_memoryStorage.getItem<JobPosting[]>('postings')) || [])
-    .filter((p) => p.isPublished)
+    .filter((p) => p.isPublished && !p.isExpired)
     .map((p) => ({
       ...p,
       contents: null,

server/db/migrations/0011_clever_spiral.sql

@@ -0,0 +1,2 @@
+ALTER TABLE "job_postings" ADD COLUMN "is_expired" boolean DEFAULT false NOT NULL;--> statement-breakpoint
+ALTER TABLE "job_postings" ADD COLUMN "valid_till" date;