doneit-web/src/app/module/chat/data/repository/message/message-local-data-source.service.ts

import { Injectable } from '@angular/core';
import { liveQuery } from 'Dexie';
import { err, ok, Result } from 'neverthrow';
import { Observable, Subject } from 'rxjs';
import { filter } from 'rxjs/operators';
import { MessageEntity } from '../../../../../core/chat/entity/message';
import { DexieRepository } from 'src/app/infra/repository/dexie/dexie-repository.service';
import { MessageTable, MessageTableSchema } from 'src/app/module/chat/infra/database/dexie/schema/message';
import { chatDatabase } from '../../../infra/database/dexie/service';
import { Observable as  DexieObservable, PromiseExtended } from 'Dexie';

@Injectable({
  providedIn: 'root'
})
export class MessageLocalDataSourceService extends DexieRepository<MessageTable, MessageEntity>  {


  constructor() {
    super(chatDatabase.message, MessageTableSchema)

    this.setAllSenderToFalse();
  }

  async setAllSenderToFalse() {
    try {
      await chatDatabase.transaction('rw', chatDatabase.message, async () => {
        // Perform the update operation within the transaction
        await chatDatabase.message.toCollection().modify({ sending: false });
      });
    } catch (error) {
      console.error('Error updating messages:', error);
    }
  }

  getItems(roomId: string): PromiseExtended<MessageEntity[]> {
    return chatDatabase.message.where('roomId').equals(roomId).sortBy('$id') as any
  }

  getItemsLive(roomId: string): DexieObservable<MessageEntity[]> {
    return liveQuery(() => chatDatabase.message.where('roomId').equals(roomId).sortBy('$id') as any)
  }

  async getOfflineMessages () {
    try {
      const allMessages = await chatDatabase.message
        .filter(msg => typeof msg.id !== 'string' && msg.sending == false)
        .toArray();

      return allMessages as MessageEntity[];
    } catch (error) {
      console.error('Error fetching messages:', error);
    }
  }
}