Process room subs
This commit is contained in:
parent
9d171682da
commit
50294d2bfd
1 changed files with 9 additions and 3 deletions
|
@ -41,12 +41,13 @@ const ROOM_LIST_TIMELINE_LIMIT = 1;
|
||||||
// the state events which will be returned for every currently visible room on the central panel
|
// the state events which will be returned for every currently visible room on the central panel
|
||||||
const ROOM_SUB_STATE_EVENTS = [
|
const ROOM_SUB_STATE_EVENTS = [
|
||||||
["m.room.avatar", ""],
|
["m.room.avatar", ""],
|
||||||
["m.room.topic", ""],
|
["m.room.topic", ""], // TODO: we don't show this anywhere?
|
||||||
["m.room.join_rules", ""],
|
["m.room.join_rules", ""],
|
||||||
["m.room.history_visibility", ""],
|
["m.room.history_visibility", ""],
|
||||||
["m.room.power_levels", ""],
|
["m.room.power_levels", ""],
|
||||||
["m.room.create", ""], // TODO: Does H need this?
|
["m.room.create", ""], // TODO: Does H need this?
|
||||||
["m.room.encrypted", ""],
|
["m.room.encryption", ""], // Used for Encryption: on|off in room details
|
||||||
|
["m.room.canonical_alias", ""], // Room details shows it
|
||||||
];
|
];
|
||||||
// the number of timeline events to get for every currently visible room timeline
|
// the number of timeline events to get for every currently visible room timeline
|
||||||
const ROOM_SUB_TIMELINE_LIMIT = 50;
|
const ROOM_SUB_TIMELINE_LIMIT = 50;
|
||||||
|
@ -340,7 +341,7 @@ export class Sync3 {
|
||||||
}, this.nextRoomSubscriptions, this.currentRoomSubscriptions);
|
}, this.nextRoomSubscriptions, this.currentRoomSubscriptions);
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
await sleep(100);
|
await sleep(10);
|
||||||
let resp: Sync3Response;
|
let resp: Sync3Response;
|
||||||
this.currentRequest = await this.hsApi.sync3(requestBody, pos);
|
this.currentRequest = await this.hsApi.sync3(requestBody, pos);
|
||||||
resp = await this.currentRequest.response();
|
resp = await this.currentRequest.response();
|
||||||
|
@ -388,6 +389,11 @@ export class Sync3 {
|
||||||
private async processResponse(isFirstSync: boolean, resp: Sync3Response) {
|
private async processResponse(isFirstSync: boolean, resp: Sync3Response) {
|
||||||
console.log(resp);
|
console.log(resp);
|
||||||
let { indexToRoom, updates } = this.processOps(resp.ops);
|
let { indexToRoom, updates } = this.processOps(resp.ops);
|
||||||
|
// add in room subs
|
||||||
|
for (let [roomId, roomResp] of Object.entries(resp.room_subscriptions)) {
|
||||||
|
roomResp.room_id = roomId;
|
||||||
|
updates.push(roomResp);
|
||||||
|
}
|
||||||
this.totalRooms = resp.counts[0];
|
this.totalRooms = resp.counts[0];
|
||||||
|
|
||||||
let rooms: any[] = [];
|
let rooms: any[] = [];
|
||||||
|
|
Reference in a new issue