Merge pull request #62 from Bostads-AB-Mimer/feat/1230-update-status-…

…on-expired-listings

feat: script to update expired listings

package.json

@@ -17,6 +17,7 @@
     "migrate:up": "knex migrate:latest --env dev",
     "migrate:down": "knex migrate:down --env dev",
     "seed": "knex seed:run --env dev",
+    "script:expire-listings": "ts-node src/scripts/expire-listings.ts",
     "ts:watch": "tsc --watch --noEmit"
   },
   "author": "",
@@ -59,7 +60,7 @@
     "koa-bodyparser": "^4.4.1",
     "koa-pino-logger": "^4.0.0",
     "mssql": "^9.3.2",
-    "onecore-types": "^1.18.0",
+    "onecore-types": "^1.19.0",
     "personnummer": "^3.2.1",
     "prettier": "^3.2.5",
     "randexp": "^0.5.3",

src/scripts/expire-listings.ts

@@ -0,0 +1,18 @@
+/* eslint-disable no-process-exit */
+import { getExpiredListings, updateListingStatuses } from '../services/lease-service/adapters/listing-adapter'
+import { ListingStatus } from 'onecore-types'
+
+async function updateExpiredListings() {
+    const expiredListings = await getExpiredListings();
+    console.log('Expired listings: ', expiredListings);
+    if (expiredListings.length > 0) {
+        const expiredListingsIds = expiredListings.map(l => l.Id);
+        console.log(`Found ${expiredListingsIds} expired listings`);
+        const updateCount = await updateListingStatuses(expiredListingsIds, ListingStatus.Expired);
+        console.log(`Updated ${updateCount} expired listings`);
+    }
+    console.log('Expired listings updated successfully')
+    process.exit(0);
+}
+
+updateExpiredListings();

src/services/lease-service/adapters/listing-adapter.ts

@@ -1,4 +1,4 @@
-import { Applicant, Listing, ApplicantStatus } from 'onecore-types'
+import { Applicant, Listing, ApplicantStatus, ListingStatus } from 'onecore-types'
 import { db } from './db'
 
 function transformFromDbListing(row: any): Listing {
@@ -275,6 +275,22 @@ const applicationExists = async (contactCode: string, listingId: number) => {
   return !!result // Convert result to boolean: true if exists, false if not
 }
 
+const getExpiredListings = async () => {
+  const currentDate = new Date()
+  const listings = await db('listing')
+    .where('PublishedTo', '<', currentDate)
+    .andWhere('Status', '==', ListingStatus.Active)
+  return listings
+}
+
+const updateListingStatuses = async (listingIds: number[], status: ListingStatus) => {
+  const updateCount = await db('listing')
+    .whereIn('Id', listingIds)
+    .update({ Status: status })
+
+  return updateCount
+}
+
 export {
   createListing,
   createApplication,
@@ -286,4 +302,6 @@ export {
   getApplicantsByContactCodeAndRentalObjectCode,
   applicationExists,
   updateApplicantStatus,
+  getExpiredListings,
+  updateListingStatuses
 }