mirror of
https://code.equilibrium.co.ao/ITO/doneit-web.git
synced 2026-04-19 04:57:52 +00:00
feature/gabinete-search
This commit is contained in:
@@ -334,13 +334,9 @@ export class ChatSystemService {
|
||||
this.defaultSubtribe(id)
|
||||
}
|
||||
|
||||
this.RochetChatConnectorService.streamNotifyLogged().then((subscription => {
|
||||
console.log(subscription)
|
||||
}))
|
||||
this.RochetChatConnectorService.streamNotifyLogged().then((subscription => {}))
|
||||
|
||||
this.RochetChatConnectorService.subStreamMessageUser().then((subscription => {
|
||||
console.log(subscription)
|
||||
}))
|
||||
this.RochetChatConnectorService.subStreamMessageUser().then((subscription => {}))
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -133,7 +133,6 @@ export class MessageService {
|
||||
} else if( this.u.username == SessionStore.user.UserName) {
|
||||
this.u.name = SessionStore.user.FullName
|
||||
} else {
|
||||
// console.log(user.username, SessionStore.user.UserName)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -290,7 +289,6 @@ export class MessageService {
|
||||
clearTimeout(this.functionTimer);
|
||||
|
||||
this.redefinedMessage(ChatMessage)
|
||||
// console.log()
|
||||
}
|
||||
).catch((error) => {
|
||||
clearTimeout(this.functionTimer);
|
||||
@@ -369,7 +367,6 @@ export class MessageService {
|
||||
|
||||
if(!roomObject.isGroup) {
|
||||
var memeberTosend = this.ChatSystemService.getRoomById(this.rid).membersExcludeMe
|
||||
console.log(ChatMessage)
|
||||
this.notificationService.ChatSendMessageNotification(memeberTosend[0].username,ChatMessage.u.name,ChatMessage.msg,this.rid)
|
||||
} else {
|
||||
var memeberTosend = this.ChatSystemService.getRoomById(this.rid).membersExcludeMe
|
||||
@@ -571,7 +568,6 @@ export class MessageService {
|
||||
|
||||
} else {
|
||||
this.earlySave = true
|
||||
console.log('save change to early')
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -38,7 +38,6 @@ export class RochetChatConnectorService {
|
||||
key:'ping-pong',
|
||||
funx:(message: any) => {
|
||||
if(message.msg == "ping") {
|
||||
// console.log(message)
|
||||
this.ws.send({message:{msg:"pong"}, loginRequired: false})
|
||||
}
|
||||
}
|
||||
@@ -799,8 +798,6 @@ export class RochetChatConnectorService {
|
||||
this.wsMsgQueue[requestId] = {message, requestId, loginRequired}
|
||||
} else {
|
||||
let messageStr = JSON.stringify(message)
|
||||
//
|
||||
// console.log(messageStr)
|
||||
this.socket.send(messageStr)
|
||||
}
|
||||
return requestId
|
||||
@@ -808,8 +805,6 @@ export class RochetChatConnectorService {
|
||||
|
||||
onmessage: async (event: any)=> {
|
||||
const data = JSON.parse(event.data)
|
||||
|
||||
// console.log('data', data)
|
||||
|
||||
for (const [key, value] of Object.entries(this.wsCallbacks)) {
|
||||
if(value.type== 'Onmessage') {
|
||||
|
||||
@@ -722,7 +722,7 @@ export class RoomService {
|
||||
this.registerSendMessage(offlineMessage)
|
||||
offlineMessage?.decryptMessage()
|
||||
offlineMessage.send()
|
||||
// console.log('send offline', ChatMessage)
|
||||
|
||||
|
||||
}
|
||||
|
||||
@@ -876,20 +876,19 @@ export class RoomService {
|
||||
|
||||
private async findMessageInDBByData({localReference, _id}) {
|
||||
|
||||
// console.log('look')
|
||||
const a = await MessageModel.filter({localReference: localReference})
|
||||
if(a.length >= 1) {
|
||||
// console.log('localReference', localReference)
|
||||
|
||||
return true
|
||||
}
|
||||
|
||||
const c = await MessageModel.filter({_id: _id})
|
||||
if(c.length >= 1) {
|
||||
// console.log('_id', _id)
|
||||
|
||||
return true
|
||||
}
|
||||
|
||||
// console.log('look not found')
|
||||
|
||||
return false
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user