doneit-web/src/app/module/chat/data/async/socket/message-async.service.ts

import { Injectable } from '@angular/core';
import { MessageLiveDataSourceService } from '../../data-source/message/message-live-data-source.service';
import { MessageLocalDataSourceService } from '../../data-source/message/message-local-data-source.service';
import { MessageRemoteDataSourceService } from '../../data-source/message/message-remote-data-source.service';
import { SignalRService } from '../../../infra/socket/signal-r.service';
import { filter } from 'rxjs/operators';
import { InstanceId } from '../../repository/message-respository.service';

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

  constructor(
    private messageRemoteDataSourceService: MessageRemoteDataSourceService,
    private messageLiveDataSourceService: MessageLiveDataSourceService,
    private messageLiveSignalRDataSourceService: SignalRService,
    private messageLocalDataSourceService: MessageLocalDataSourceService
  ) {


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

      console.log('message async ', message)
      const id = message.id
      delete message.id;

      const result = await this.messageLocalDataSourceService.createMessage({
        messageId: id,
        sending: false,
        ...message
      })

      if(result.isOk()) {

        console.log(result.value)
        console.log("nice send receive")

      } else {
        console.log(result.error)
      }

    })

  }
}