fix chant streaming

This commit is contained in:
Peter Maquiran
2024-06-13 12:25:06 +01:00
parent 962ab6aa86
commit ec19d725c4
6 changed files with 3 additions and 14 deletions
@@ -5,9 +5,6 @@ export function roomListDetermineChanges(serverRooms: RoomListItemOutPutDTO[], l
const serverRoomMap = new Map(serverRooms.map(room => [room.id, room])); const serverRoomMap = new Map(serverRooms.map(room => [room.id, room]));
const localRoomMap = new Map(localRooms.map(room => [room.id, room])); const localRoomMap = new Map(localRooms.map(room => [room.id, room]));
console.log({serverRoomMap, localRoomMap})
const roomsToInsert = serverRooms.filter(room => !localRoomMap.has(room.id)); const roomsToInsert = serverRooms.filter(room => !localRoomMap.has(room.id));
const roomsToUpdate = serverRooms.filter(room => { const roomsToUpdate = serverRooms.filter(room => {
const localRoom = localRoomMap.get(room.id); const localRoom = localRoomMap.get(room.id);
@@ -14,8 +14,6 @@ export class MessageLiveDataSourceService {
const result = await this.socket.sendMessage(data).toPromise() const result = await this.socket.sendMessage(data).toPromise()
console.log({result})
return ok(result) return ok(result)
} catch (e) { } catch (e) {
return err(e) return err(e)
@@ -49,7 +49,6 @@ export class MessageLocalDataSourceService {
messageDataSource.message.hook('creating', (primKey, obj, trans) => { messageDataSource.message.hook('creating', (primKey, obj, trans) => {
// const newMessage = await trans.table('message').get(primKey); // const newMessage = await trans.table('message').get(primKey);
console.log(primKey, obj)
this.messageSubject.next(obj); this.messageSubject.next(obj);
// return newMessage // return newMessage
}) })
@@ -76,7 +75,6 @@ export class MessageLocalDataSourceService {
const result = await messageDataSource.message.add(data) const result = await messageDataSource.message.add(data)
return ok(result as string) return ok(result as string)
} catch (e) { } catch (e) {
console.log('add error')
return err(false) return err(false)
} }
@@ -114,7 +112,6 @@ export class MessageLocalDataSourceService {
async findMessageById(messageId: string) { async findMessageById(messageId: string) {
try { try {
console.log('messageId', messageId)
const a = await messageDataSource.message.where('messageId').equals(messageId).first() const a = await messageDataSource.message.where('messageId').equals(messageId).first()
if(a) { if(a) {
@@ -42,7 +42,6 @@ export class WebSocketService {
} }
console.log({payload, requestId})
}) })
} }
@@ -30,11 +30,11 @@ export class MessageRepositoryService {
try { try {
if(clone.sender.wxUserId != SessionStore.user.UserId) { if(clone.sender.wxUserId != SessionStore.user.UserId) {
console.log(this.messageLocalDataSourceService.createMessage(clone)) this.messageLocalDataSourceService.createMessage(clone)
} }
} catch (e) { } catch (e) {
console.log('error', {payload}) //console.log('error', {payload})
} }
} }
@@ -39,8 +39,6 @@ export class ChatPopoverPage implements OnInit {
this.members = this.navParams.get('members'); this.members = this.navParams.get('members');
this.isAdmin = this.navParams.get('isAdmin'); this.isAdmin = this.navParams.get('isAdmin');
console.log(this.navParams.data)
} }
ngOnInit() { ngOnInit() {