Favorites #19, Social Media Start #53

bizmatch-server/src/listings/commercial-property.service.ts

@@ -1,5 +1,5 @@
 import { BadRequestException, Inject, Injectable } from '@nestjs/common';
-import { and, count, eq, gte, ilike, inArray, lte, ne, or, SQL, sql } from 'drizzle-orm';
+import { and, arrayContains, count, eq, gte, ilike, inArray, lte, ne, or, SQL, sql } from 'drizzle-orm';
 import { NodePgDatabase } from 'drizzle-orm/node-postgres';
 import { WINSTON_MODULE_PROVIDER } from 'nest-winston';
 import { Logger } from 'winston';
@@ -10,7 +10,7 @@ import { FileService } from '../file/file.service.js';
 import { GeoService } from '../geo/geo.service.js';
 import { CommercialPropertyListing, CommercialPropertyListingSchema } from '../models/db.model.js';
 import { CommercialPropertyListingCriteria, emailToDirName, JwtUser } from '../models/main.model.js';
-import { convertCommercialToDrizzleCommercial, convertDrizzleCommercialToCommercial, getDistanceQuery } from '../utils.js';
+import { convertCommercialToDrizzleCommercial, convertDrizzleBusinessToBusiness, convertDrizzleCommercialToCommercial, getDistanceQuery } from '../utils.js';
 
 @Injectable()
 export class CommercialPropertyService {
@@ -123,6 +123,14 @@ export class CommercialPropertyService {
       .where(and(...conditions))) as CommercialPropertyListing[];
     return listings.map(l => convertDrizzleCommercialToCommercial(l)) as CommercialPropertyListing[];
   }
+  // #### Find Favorites ########################################
+  async findFavoriteListings(user: JwtUser): Promise<CommercialPropertyListing[]> {
+    const userFavorites = await this.conn
+      .select()
+      .from(commercials)
+      .where(arrayContains(commercials.favoritesForUser, [user.username]));
+    return userFavorites.map(l => convertDrizzleBusinessToBusiness(l));
+  }
   // #### Find by imagePath ########################################
   async findByImagePath(imagePath: string, serial: string): Promise<CommercialPropertyListing> {
     const result = await this.conn
@@ -202,6 +210,15 @@ export class CommercialPropertyService {
   async deleteListing(id: string): Promise<void> {
     await this.conn.delete(commercials).where(eq(commercials.id, id));
   }
+  // #### DELETE Favorite ###################################
+  async deleteFavorite(id: string, user: JwtUser): Promise<void> {
+    await this.conn
+      .update(commercials)
+      .set({
+        favoritesForUser: sql`array_remove(${commercials.favoritesForUser}, ${user.username})`,
+      })
+      .where(sql`${commercials.id} = ${id}`);
+  }
   // ##############################################################
   // States
   // ##############################################################