mirror of
https://code.equilibrium.co.ao/ITO/doneit-web.git
synced 2026-04-19 04:57:52 +00:00
improve
This commit is contained in:
@@ -232,7 +232,7 @@ export class RoomService {
|
||||
this.countDownTime = "Expired";
|
||||
let body = { "roomId": this.id }
|
||||
|
||||
this.chatService.getRoomInfo(this.id).subscribe(room=>{
|
||||
this.chatService.getRoomInfo(this.id).subscribe( room =>{
|
||||
|
||||
|
||||
if(this.t === 'p') {
|
||||
|
||||
@@ -218,8 +218,6 @@ export class WsChatMethodsService {
|
||||
|
||||
|
||||
await this.storage.set('Rooms', rooms);
|
||||
console.log("Done")
|
||||
|
||||
|
||||
setTimeout(() => {
|
||||
this.sortRoomList()
|
||||
@@ -247,7 +245,6 @@ export class WsChatMethodsService {
|
||||
*/
|
||||
subscribeToRoom() {
|
||||
|
||||
console.log('subcribe/////////////////////////////////')
|
||||
for (const id in this.dm) {
|
||||
this.defaultSubtribe(id)
|
||||
}
|
||||
@@ -297,15 +294,11 @@ export class WsChatMethodsService {
|
||||
this.WsChatService.subStreamNotifyRoom(id, 'readMessage', false).then((subscription) => {
|
||||
const room = this.getRoomById(id);
|
||||
room.status.receive.readMessage = true;
|
||||
// console.log(subscription, "subStreamNotifyRoom");
|
||||
//
|
||||
})
|
||||
|
||||
this.WsChatService.streamNotifyRoomDeleteMessage(id).then((subscription) => {
|
||||
const room = this.getRoomById(id);
|
||||
room.status.receive.deleteMessage = true;
|
||||
// console.log(subscription);
|
||||
//
|
||||
})
|
||||
}
|
||||
|
||||
@@ -362,7 +355,6 @@ export class WsChatMethodsService {
|
||||
|
||||
this.dm[roomId] = room
|
||||
this._dm.push(room)
|
||||
// console.log(this._dm)
|
||||
this.dmCount++
|
||||
|
||||
} else {
|
||||
|
||||
Reference in New Issue
Block a user