doneit-web/src/app/module/chat/domain/chat-service.service.ts

import { Injectable } from '@angular/core';
import { MessageDeleteLiveUseCaseService, MessageDeleteInputDTO } from 'src/app/module/chat/domain/use-case/message-delete-live-use-case.service'
import { SessionStore } from 'src/app/store/session.service';
import { MessageReactionInput, MessageReactionUseCaseService } from 'src/app/module/chat/domain/use-case/message-reaction-use-case.service';
import { MessageUpdateInput, MessageUpdateUseCaseService } from 'src/app/module/chat/domain/use-case/message-update-use-case.service';
import { SignalRService } from '../infra/socket/signal-r.service';
import { SocketMessageDeleteUseCaseService } from 'src/app/module/chat/domain/use-case/socket/socket-message-delete-use-case.service';
import { SocketMessageUpdateUseCaseService } from 'src/app/module/chat/domain/use-case/socket/socket-message-update-use-case.service';
import { SocketMessageCreateUseCaseService } from 'src/app/module/chat/domain/use-case/socket/socket-message-create-use-case.service';
import { filter } from 'rxjs/operators';
import { InstanceId } from '../data/repository/message-respository.service';

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

  constructor(
    private MessageDeleteLiveUseCaseService: MessageDeleteLiveUseCaseService,
    private MessageReactionUseCaseService: MessageReactionUseCaseService,
    private MessageUpdateUseCaseService: MessageUpdateUseCaseService,
    private SocketMessageDeleteUseCaseService: SocketMessageDeleteUseCaseService,
    private messageLiveSignalRDataSourceService: SignalRService,
    private SocketMessageUpdateUseCaseService: SocketMessageUpdateUseCaseService,
    private SocketMessageCreateUseCaseService: SocketMessageCreateUseCaseService
  ) {
    this.messageLiveSignalRDataSourceService.getMessageDelete()
    .pipe()
    .subscribe(async (message) => {
      if(message?.id) {
        this.SocketMessageDeleteUseCaseService.execute(message)
      }

    })

    this.messageLiveSignalRDataSourceService.getMessageUpdate().pipe(
      filter((message) => {
        return !message?.requestId?.startsWith(InstanceId)
      })
    ).subscribe(async (message) => {

      if(message?.id) {
        this.SocketMessageUpdateUseCaseService.execute(message)
      }
    })

    this.messageLiveSignalRDataSourceService.getMessage().pipe(
      filter((message) => {
        if(!message?.requestId?.startsWith(InstanceId) == false) {
          // console.log('exclude my message---')
        }
        return !message?.requestId?.startsWith(InstanceId)
      })
    ).subscribe(async (message) => {

      if(message?.id) {
        console.log('create message')
        this.SocketMessageCreateUseCaseService.execute(message)
      }


    })

  }

  messageDelete(data: {roomId, messageId}) {

    const params = {
      ...data,
      senderId: SessionStore.user.UserId,
    }

    return this.MessageDeleteLiveUseCaseService.execute(params)
  }

  reactToMessage(input: MessageReactionInput) {
    return this.MessageReactionUseCaseService.execute(input);
  }

  updateMessage(input: MessageUpdateInput) {
    return this.MessageUpdateUseCaseService.execute(input);
  }
}