feat(lpms-server): add search space service and

Availability db
FacilityRepository
SpaceAvailabilityRepository

Author: Galeaf11

src/repositories/FacilityRepository.ts

@@ -0,0 +1,47 @@
+import DBService from '../services/DBService';
+import { Level } from 'level';
+import { Facility } from '../proto/facility';
+
+export class FacilityRepository {
+  private dbService: DBService;
+  private db: Level<string, string | string[]>;
+
+  constructor() {
+    this.dbService = DBService.getInstance();
+    this.db = DBService.getInstance().getDB();
+  }
+
+  public async getFacilityIds(): Promise<string[]> {
+    try {
+      return await this.db.get<string, string[]>(
+        'facilities',
+        { valueEncoding: 'json' }
+      );
+    } catch (e) {
+      if (e.status !== 404) {
+        throw e;
+      }
+    }
+    return [];
+  }
+
+  public async createFacility(facilityId: string, facility: Facility): Promise<void> {
+    const facilitySublevel = this.dbService.getFacilitySublevelDB(facilityId);
+
+    await facilitySublevel.put('metadata', facility);
+
+    await this.createFacilityIndex(facilityId);
+  }
+
+  private async createFacilityIndex(facilityId: string) {
+    const facilitiesIds = await this.getFacilityIds();
+
+    if (facilitiesIds.length > 0) {
+      const idsSet = new Set<string>(facilitiesIds);
+      idsSet.add(facilityId);
+      await this.db.put('facilities', Array.from(idsSet));
+    } else {
+      await this.db.put('facilities', [facilityId]);
+    }
+  }
+}

src/repositories/SpaceAvailabilityRepository.ts

@@ -0,0 +1,36 @@
+import DBService, { DateType, FacilityItemValues, LevelDefaultTyping } from '../services/DBService';
+import { AbstractLevel, AbstractSublevel } from 'abstract-level';
+import { Availability } from '../proto/lpms';
+
+export class SpaceAvailabilityRepository {
+  private dbService: DBService;
+  private availableDB: AbstractSublevel<AbstractLevel<LevelDefaultTyping, string, FacilityItemValues>, LevelDefaultTyping, "default" | DateType, Availability>;
+
+  constructor(facilityId, spaceId) {
+    this.dbService = DBService.getInstance();
+    this.availableDB = this.dbService.getSpaceAvailabilityDB(facilityId, spaceId);
+  }
+
+  public async getSpaceAvailabilityNumSpaces(key): Promise<number> {
+    try {
+      const availability: Availability = await this.availableDB.get(key);
+      return availability.numSpaces;
+    } catch (e) {
+      if (e.status !== 404) {
+        throw e;
+      }
+    }
+
+    return 0;
+  }
+
+  public async createAvailabilityByDate(key: DateType): Promise<void> {
+    const count = await this.getSpaceAvailabilityNumSpaces(key);
+
+    const availability: Availability = {
+      numSpaces: count + 1
+    };
+
+    await this.availableDB.put(key, availability);
+  }
+}

src/services/DBService.ts

@@ -8,11 +8,8 @@ import {
   DayOfWeekRateModifer,
   LOSRateModifier,
   NoticeRequiredRule,
-  OccupancyRateModifier,
-  Rates
+  OccupancyRateModifier
 } from '../proto/lpms';
-import { Bytes } from 'ethers';
-import { Person } from '@windingtree/stays-models/dist/cjs/proto/person';
 
 export type LevelDefaultTyping = string | Buffer | Uint8Array;
 export type DBLevel = Level<string, string | string[]>;
@@ -31,6 +28,7 @@ export type FacilityLevelValues = Facility | string[];
 export type FacilitySpaceLevelValues = Item | Space;
 export type FacilityItemType = 'spaces' | 'otherItems';
 export type FacilityItemValues = Item | FacilitySpaceLevelValues;
+export type DateType = `${number}-${number}-${number}`
 
 export default class DBService {
   protected db: DBLevel;
@@ -114,4 +112,11 @@ export default class DBService {
       FacilityItemValues
     >(key, { valueEncoding: 'json' });
   }
+
+  public getSpaceAvailabilityDB(facilityId: string, itemId: string) {
+    return this.getFacilityItemDB(facilityId, 'spaces', itemId).sublevel<'default' | DateType, Availability>(
+      'availability',
+      { valueEncoding: 'json' }
+    );
+  }
 }