toki/mattermost-mobile
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix loading threads (#6441)

Browse source
This commit is contained in:
Elias Nahum 2022-06-30 04:10:28 -04:00 committed by GitHub
parent 4a79ae0574
commit 094e98a5ea
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
app/queries/servers/thread.ts
View file

@ -93,6 +93,8 @@ export const prepareThreadsFromReceivedPosts = async (operator: ServerDataOperat
const models: Model[] = [];
const threads: ThreadWithLastFetchedAt[] = [];
const toUpdate: {[rootId: string]: number | undefined} = {};
let processedThreads: Set<string> | undefined;
posts.forEach((post: Post) => {
if (!post.root_id && post.type === '') {
threads.push({
@ -107,15 +109,18 @@ export const prepareThreadsFromReceivedPosts = async (operator: ServerDataOperat
toUpdate[post.root_id] = Math.max(toUpdate[post.root_id] || 0, post.create_at, post.update_at, post.delete_at);
}
});
if (threads.length) {
const threadModels = await operator.handleThreads({threads, prepareRecordsOnly: true});
const threadModels = await operator.handleThreads({threads, prepareRecordsOnly: true}) as ThreadModel[];
processedThreads = new Set<string>(threadModels.map((t) => t.id));
models.push(...threadModels);
}
const toUpdateKeys = Object.keys(toUpdate);
if (toUpdateKeys.length) {
const toUpdateThreads = await Promise.all(toUpdateKeys.map((key) => getThreadById(operator.database, key)));
for (const thread of toUpdateThreads) {
if (thread) {
if (thread && !processedThreads?.has(thread.id)) {
const model = thread.prepareUpdate((record) => {
record.lastFetchedAt = Math.max(record.lastFetchedAt, toUpdate[thread.id] || 0);
});