doneit-web/src/app/services/Repositorys/chat/data-source/room/rooom-local-data-source.service.ts

import { Injectable } from '@angular/core';
import { AddMemberToRoomInputDTO } from '../../dto/room/addMemberToRoomInputDto';
import { RoomListItemOutPutDTO, RoomListOutPutDTO } from '../../dto/room/roomListOutputDTO';
import { Dexie, EntityTable, liveQuery } from 'Dexie';
import { err, ok } from 'neverthrow';
import { Observable } from 'rxjs';
import { RoomOutPutDTO } from '../../dto/room/roomOutputDTO';
import { z } from 'zod';



const tableSchema = z.object({
  id: z.string(),
  roomName: z.string(),
  createdBy: z.any(),
  createdAt: z.any(),
  expirationDate: z.any(),
  roomType: z.any()
})
export type TableRoom = z.infer<typeof tableSchema>

// Database declaration (move this to its own module also)
export const roomDataSource = new Dexie('FriendDatabase') as Dexie & {
  room: EntityTable<TableRoom, 'id'>;
};



roomDataSource.version(1).stores({
  room: 'id, createdBy, roomName, roomType, expirationDate'
});


@Injectable({
  providedIn: 'root'
})
export class RoomLocalDataSourceService {

  private baseUrl = 'https://gdapi-dev.dyndns.info/stage/api/v2/Chat'; // Your base URL

  constructor() {}


  async createRoom(data: TableRoom) {
    try {
      const result = await roomDataSource.room.add(data)
      return ok(result)
    } catch (e) {
      return err(false)
    }
  }

  async updateRoom(data: TableRoom) {
    try {
      const result = await roomDataSource.room.update(data.id, data);

      return ok(result)
    } catch (e) {
      return err(false)
    }
  }

  async createOrUpdateRoom(data: TableRoom) {
    const createResult = await this.createRoom(data)

    if(createResult.isOk()) {
      return this.updateRoom(data)
    } else  {
      return createResult
    }
  }

  async getRoomById(id: any) {
    try {
      const result = await roomDataSource.room.get(id)
      return ok(result)
    } catch (e) {
      return err(false)
    }

  }

  getItemsLive(): Observable<RoomListOutPutDTO[]> {
    return liveQuery(() => roomDataSource.room.toArray()) as any;
  }

  getRoomByIdLive(id: any): Observable<RoomListItemOutPutDTO | undefined> {
    return liveQuery(() => roomDataSource.room.get(id)) as any;
  }

}