Matrix/element-web-Github
1
0
Fork 0
mirror of https://github.com/vector-im/element-web.git synced 2024-11-25 18:08:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

Experimental SSS

Browse Source 
Working branch to get SSS functional on element-web.

Requires https://github.com/matrix-org/matrix-js-sdk/pull/4400
This commit is contained in:
David Baker 2024-09-12 14:42:27 +01:00
parent f31776378d
commit df7bb61a5b
1 changed files with 7 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/SlidingSyncManager.ts
View File

@ -214,9 +214,9 @@ export class SlidingSyncManager {
try { try {
// if we only have range changes then call a different function so we don't nuke the list from before // if we only have range changes then call a different function so we don't nuke the list from before
if (updateArgs.ranges && Object.keys(updateArgs).length === 1) { if (updateArgs.ranges && Object.keys(updateArgs).length === 1) {
await this.slidingSync!.setListRanges(listKey, updateArgs.ranges); this.slidingSync!.setListRanges(listKey, updateArgs.ranges);
} else { } else {
await this.slidingSync!.setList(listKey, list); this.slidingSync!.setList(listKey, list);
} }
} catch (err) { } catch (err) {
logger.debug("ensureListRegistered: update failed txn_id=", err); logger.debug("ensureListRegistered: update failed txn_id=", err);
@ -266,21 +266,14 @@ export class SlidingSyncManager {
*/ */
public async startSpidering(batchSize: number, gapBetweenRequestsMs: number): Promise<void> { public async startSpidering(batchSize: number, gapBetweenRequestsMs: number): Promise<void> {
await sleep(gapBetweenRequestsMs); // wait a bit as this is called on first render so let's let things load await sleep(gapBetweenRequestsMs); // wait a bit as this is called on first render so let's let things load
let startIndex = batchSize; let windowSize = batchSize;
let hasMore = true; let hasMore = true;
let firstTime = true; let firstTime = true;
while (hasMore) { while (hasMore) {
const endIndex = startIndex + batchSize - 1;
try { try {
const ranges = [
[0, batchSize - 1],
[startIndex, endIndex],
];
if (firstTime) { if (firstTime) {
await this.slidingSync!.setList(SlidingSyncManager.ListSearch, { await this.slidingSync!.setList(SlidingSyncManager.ListSearch, {
// e.g [0,19] [20,39] then [0,19] [40,59]. We keep [0,20] constantly to ensure ranges: [[0, windowSize]],
// any changes to the list whilst spidering are caught.
ranges: ranges,
sort: [ sort: [
"by_recency", // this list isn't shown on the UI so just sorting by timestamp is enough "by_recency", // this list isn't shown on the UI so just sorting by timestamp is enough
], ],
@ -313,8 +306,8 @@ export class SlidingSyncManager {
await sleep(gapBetweenRequestsMs); await sleep(gapBetweenRequestsMs);
} }
const listData = this.slidingSync!.getListData(SlidingSyncManager.ListSearch)!; const listData = this.slidingSync!.getListData(SlidingSyncManager.ListSearch)!;
hasMore = endIndex + 1 < listData.joinedCount; hasMore = windowSize < listData.joinedCount;
startIndex += batchSize; windowSize += batchSize;
firstTime = false; firstTime = false;
} }
} }
@ -375,7 +368,7 @@ export class SlidingSyncManager {
public async nativeSlidingSyncSupport(client: MatrixClient): Promise<boolean> { public async nativeSlidingSyncSupport(client: MatrixClient): Promise<boolean> {
// Per https://github.com/matrix-org/matrix-spec-proposals/pull/3575/files#r1589542561 // Per https://github.com/matrix-org/matrix-spec-proposals/pull/3575/files#r1589542561
// `client` can be undefined/null in tests for some reason. // `client` can be undefined/null in tests for some reason.
const support = await client?.doesServerSupportUnstableFeature("org.matrix.msc3575"); const support = await client?.doesServerSupportUnstableFeature("org.matrix.simplified_msc3575");
if (support) { if (support) {
logger.log("nativeSlidingSyncSupport: sliding sync advertised as unstable"); logger.log("nativeSlidingSyncSupport: sliding sync advertised as unstable");
} }