self-hosted/joplin
1
0
Fork 0
mirror of https://github.com/laurent22/joplin.git synced 2025-11-26 22:41:17 +02:00
Code Issues Releases Activity

Server: Added more logging for sharing

Browse Source
This commit is contained in:
Laurent Cozic
2024-10-21 17:56:06 +01:00
parent 1d6c1e4664
commit 2779a9cffc
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
packages/server/src/models/ShareModel.ts
View File

@@ -315,18 +315,30 @@ export default class ShareModel extends BaseModel<Share> {
perfTimer.push('Main'); perfTimer.push('Main');
while (true) { while (true) {
perfTimer.push('Get latestProcessedChange');
const latestProcessedChange = await this.models().keyValue().value<string>('ShareService::latestProcessedChange'); const latestProcessedChange = await this.models().keyValue().value<string>('ShareService::latestProcessedChange');
perfTimer.pop();
perfTimer.push('Get paginated changes');
const paginatedChanges = await this.models().change().allFromId(latestProcessedChange || ''); const paginatedChanges = await this.models().change().allFromId(latestProcessedChange || '');
perfTimer.pop();
const changes = paginatedChanges.items; const changes = paginatedChanges.items;
if (!changes.length) { if (!changes.length) {
perfTimer.push('Set latestProcessedChange');
await this.models().keyValue().setValue('ShareService::latestProcessedChange', paginatedChanges.cursor); await this.models().keyValue().setValue('ShareService::latestProcessedChange', paginatedChanges.cursor);
perfTimer.pop();
} else { } else {
perfTimer.push(`Load items for ${changes.length} changes`);
const items = await this.models().item().loadByIds(changes.map(c => c.item_id)); const items = await this.models().item().loadByIds(changes.map(c => c.item_id));
perfTimer.pop();
const shareIds = unique(items.filter(i => !!i.jop_share_id).map(i => i.jop_share_id)); const shareIds = unique(items.filter(i => !!i.jop_share_id).map(i => i.jop_share_id));
const shares = await this.models().share().loadByIds(shareIds);
perfTimer.push(`Load ${shareIds.length} shares`);
const shares = await this.models().share().loadByIds(shareIds);
perfTimer.pop();
perfTimer.push('Change processing transaction');
await this.withTransaction(async () => { await this.withTransaction(async () => {
perfTimer.push(`Processing ${changes.length} changes`); perfTimer.push(`Processing ${changes.length} changes`);
@@ -358,6 +370,7 @@ export default class ShareModel extends BaseModel<Share> {
perfTimer.pop(); perfTimer.pop();
}, 'ShareService::updateSharedItems3'); }, 'ShareService::updateSharedItems3');
perfTimer.pop();
} }
if (!paginatedChanges.has_more) break; if (!paginatedChanges.has_more) break;