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

import { Injectable } from '@angular/core'
import { WsChatService } from 'src/app/services/chat/ws-chat.service';
import { MessageService } from 'src/app/services/chat/message.service'
import { ChatUserService } from 'src/app/services/chat/chat-user.service'
import { showDateDuration } from 'src/plugin/showDateDuration'
import { ToastsService } from '../toast.service';
import { chatHistory, ChatMessage } from 'src/app/models/chatMethod'
import { Storage } from '@ionic/storage';
import { Platform } from '@ionic/angular';
import { SqliteService } from 'src/app/services/sqlite.service';
@Injectable({
  providedIn: 'root'
})
export class RoomService {

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

  chatUser: ChatUserService[] = []
  customFields: any;
  id = ''
  t = ''
  name = ''
  _updatedAt = {}
  private hasLoadHistory = false
  duration = ''

  private ToastService = ToastsService
  mgsArray = [];

  scrollDown = () => { }

  constructor(
    public WsChatService: WsChatService,
    private MessageService: MessageService,
    private storage: Storage,
    private platform: Platform,
    private sqlservice: SqliteService,
  ) { }

  setData({ customFields, id, name, t, lastMessage = new MessageService(), _updatedAt }) {
    this.customFields = customFields
    this.id = id
    this.name = name
    this.t = t
    this.lastMessage = lastMessage
    this._updatedAt = _updatedAt

    this.calDateDuration()
  }

  receiveMessage() {

    this.WsChatService.receiveLiveMessageFromRoom(
      this.id,
      (ChatMessage) => {
        ChatMessage = ChatMessage.fields.args[0]
        ChatMessage = this.fix_updatedAt(ChatMessage)
        console.log('recivemessage', ChatMessage)

        /* this.ToastService._chatMessage({message:'Nova mensagem', sender:'Gilson'}) */
        const message = new MessageService()
        message.setData(ChatMessage)

        this.lastMessage.msg = message.msg
        if (message.t == 'r') { this.name = message.msg }
        this.calDateDuration(ChatMessage._updatedAt)
        this.massages.push(message)

        setTimeout(() => {
          this.scrollDown()
        }, 100)


        // save to ionic storage
        this.storage.get('chatmsg' + this.id).then((messages: any) => {
          const newListMessages = messages.push(ChatMessage)

          this.storage.set('chatmsg' + this.id, newListMessages).then((value) => {
            console.log('MSG SAVED ON STORAGE', value)
          });
        })

      }
    )
  }

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

  leave(rid?) {
    this.WsChatService.leaveRoom(this.id)
  }

  getMsgFromDBMobile() {
    console.log('ALL MSG DBBB', this.id)
    this.sqlservice.getAllChatMSG(this.id).then((msg: any = []) => {
      let ad = [];
      ad = msg
      console.log('ALL MSG DBBB', ad.length)
      msg.map(element => {
        console.log('CHANNEL ELEMENT', element)
        let msgChat = {
          _id: element.Id,
          attachments: this.isJson(element.Attachments),
          channels: this.isJson(element.Channels),
          file: {
            guid: this.isJson(element.File).guid,
            image_url: this.isJson(element.image_url),
            type: this.isJson(element.File).type

          },
          mentions: this.isJson(element.Mentions),
          msg: element.Msg,
          rid: element.Rid,
          ts: element.Ts,
          u: this.isJson(element.U),
          _updatedAt: this.isJson(element.UpdatedAt),
        }

        let mmessage = this.fix_updatedAt(msgChat)
        console.log('FROM DB WEB', mmessage)
        const wewMessage = new MessageService()
        wewMessage.setData(mmessage)
        this.massages.push(wewMessage)
        console.log('loadHistory 222', this.massages)
      });
    });
  }

  isJson(str) {
    try {
      JSON.parse(str);
    } catch (e) {
      return "";
    }
    return JSON.parse(str);
  }

  getMsgFromDB() {

    this.storage.get('chatmsg' + this.id).then((message) => {

      message.forEach(message => {

        if (message.file) {
          if (message.file.guid) {
            this.storage.get(message.file.guid).then((image) => {
              console.log('IMAGE FROM STORAGE', image)
              message.file.image_url = image
            });
          }
        }

        let mmessage = this.fix_updatedAt(message)
        console.log('FROM DB WEB', mmessage)
        const wewMessage = new MessageService()
        wewMessage.setData(mmessage)
        this.massages.push(wewMessage)
        console.log('loadHistory 222', this.massages)
      });
    })
  }



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

    if (this.hasLoadHistory) { return false }

    /* this.WsChatService.loadHistory(this.id, limit).then((chatHistory:chatHistory) => {
      console.log('loadHistory', chatHistory)

      chatHistory.result.messages.reverse().forEach(message => {

        message = this.fix_updatedAt(message)
        const wewMessage = new MessageService()
        wewMessage.setData(message)
        this.massages.push(wewMessage)
      });


    }) */

    this.WsChatService.loadHistory(this.id, limit).then(async (chatHistory: chatHistory) => {

      const mgsArray = chatHistory.result.messages.reverse();
      if (this.platform.is('desktop') || this.platform.is('mobileweb')) {
        await this.storage.remove('chatmsg' + this.id).then(() => {
          console.log('MSG REMOVE ON STORAGE')
        })
        await this.storage.set('chatmsg' + this.id, mgsArray).then((value) => {
          console.log('MSG SAVED ON STORAGE', value)
          this.getMsgFromDB()
        });
      } else {
        mgsArray.forEach((element) => {
          console.log('SQLITE WEBSOCKET', element)
          this.sqlservice.addChatMSG(element)
        })
        this.getMsgFromDBMobile()
      }


    })

    setTimeout(() => {
      this.scrollDown()
    }, 50)

    this.hasLoadHistory = true
  }


  updateMeessage(messageID, imgbase64) {

  }

  async returnData(res) {

    return res;
  }

  async transformData(res) {

    this.mgsArray = [];
    res.forEach(async element => {

      if (element.file) {
        if (element.file.guid) {
          await this.storage.get(element.file.guid).then((image) => {
            let chatmsg = {
              _id: element._id,
              attachments: element.attachments,
              channels: element.channels,
              file: {
                guid: element.file.guid,
                image_url: image,
                type: element.file.type
              },
              mentions: element.mentions,
              msg: element.msg,
              rid: element.rid,
              ts: element.ts,
              u: element.u,
              _updatedAt: element._updatedAt,
            }

            this.mgsArray.push(chatmsg);

          })
        } else {
          let chatmsg = {
            _id: element._id,
            attachments: element.attachments,
            channels: element.channels,
            file: element.file,
            mentions: element.mentions,
            msg: element.msg,
            rid: element.rid,
            ts: element.ts,
            u: element.u,
            _updatedAt: element._updatedAt,
          }

          this.mgsArray.push(chatmsg)
        }
      } else {
        let chatmsg = {
          _id: element._id,
          attachments: element.attachments,
          channels: element.channels,
          mentions: element.mentions,
          msg: element.msg,
          rid: element.rid,
          ts: element.ts,
          u: element.u,
          _updatedAt: element._updatedAt,
        }

        this.mgsArray.push(chatmsg)
      }

    });
    await this.storage.remove('chatmsg').then(() => {
      console.log('MSG REMOVE FROM STORAGE')
    });
    await this.storage.set('chatmsg', this.mgsArray).then((value) => {
      console.log('MSG SAVED ON STORAGE', value)
    });

  }

  ReactToMessage() { }

  private calDateDuration(date = null) {
    this.duration = showDateDuration(date || this._updatedAt);
  }


  private fix_updatedAt(message) {
    if (message.result) {
      console.log('FIX UPDATE ', message.result)
      message.result._updatedAt = message.result._updatedAt['$date']
    } else {
      console.log('FIX UPDATE 11', message)
      message._updatedAt = message._updatedAt['$date']
    }
    return message
  }


  // to add
  countDownDate() { }

}