doneit-web/src/app/services/chat/room.service.ts

import { Injectable } from '@angular/core'
import { RocketChatClientService } from 'src/app/services/socket/rocket-chat-client.service';
import { MessageService } from 'src/app/services/chat/message.service'
import { ChatUserService } from 'src/app/services/chat/chat-user.service'
@Injectable({
  providedIn: 'root'
})
export class RoomService {

  massages: MessageService[] = []
  lastMessage: MessageService;

  chatUser: ChatUserService[] = []
  id = ''
  name = ''
  private hasLoadHistory = false

  constructor(
    public RocketChatClientService: RocketChatClientService,
    private MessageService: MessageService
  ) {
    
  }

  setData({id, name, lastMessage}) {

    this.id = id
    this.name = name
    this.lastMessage = lastMessage
  }

  receiveMessage() {
    this.RocketChatClientService.receiveLiveMessageFromRoom(
      this.id,
      this.constructor.name+this.id,
      (Chatmessage)=>{
        this.massages.push(Chatmessage.result)
      }
    )
  }

  send(msg) {
    this.RocketChatClientService.send(this.id, msg)
  }

  // runs onces only
  loadHistory(limit= 100) {

    if(this.hasLoadHistory){ return false }

    this.RocketChatClientService.loadHistory(this.id, limit).then((message:any) => {
      console.log('loadHistory', message)
      
      message.result.messages.reverse().forEach(element => {
        const message = new MessageService()
        message.setData(element)
        this.massages.push(message)
      });

    })

    this.hasLoadHistory = true
  }

  create() {}
  deleteMessage(msgId) {}
  ReactToMessage() {}

}