Mastodon/Sengi-Windows-MacOS-Linux
1
0
Fork 0
mirror of https://github.com/NicolasConstant/sengi synced 2025-01-24 07:22:50 +01:00
Code Issues Releases Wiki Activity

added optimization for notification retrieval

Browse Source
This commit is contained in:
Nicolas Constant 2019-03-25 01:22:55 -04:00
parent 07318dbe15
commit f4ed9c4482
No known key found for this signature in database
GPG Key ID: 1E9F677FB01A5688
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/app/services/user-notification.service.ts
View File

@ -13,6 +13,8 @@ import { NotificationService } from './notification.service';
export class UserNotificationService { export class UserNotificationService {
userNotifications = new BehaviorSubject<UserNotification[]>([]); userNotifications = new BehaviorSubject<UserNotification[]>([]);
private sinceIds: { [id: string]: string } = {};
constructor( constructor(
private readonly notificationService: NotificationService, private readonly notificationService: NotificationService,
private readonly mastodonService: MastodonService, private readonly mastodonService: MastodonService,
@ -25,8 +27,13 @@ export class UserNotificationService {
let accounts = this.store.snapshot().registeredaccounts.accounts; let accounts = this.store.snapshot().registeredaccounts.accounts;
let promises: Promise<any>[] = []; let promises: Promise<any>[] = [];
accounts.forEach(account => { accounts.forEach((account: AccountInfo) => {
let getNotificationPromise = this.mastodonService.getNotifications(account, null, null, null, 30) let sinceId = null;
if(this.sinceIds[account.id]){
sinceId = this.sinceIds[account.id];
}
let getNotificationPromise = this.mastodonService.getNotifications(account, null, null, sinceId, 30)
.then((notifications: Notification[]) => { .then((notifications: Notification[]) => {
this.processNotifications(account, notifications); this.processNotifications(account, notifications);
}) })
@ -45,6 +52,10 @@ export class UserNotificationService {
} }
private processNotifications(account: AccountInfo, notifications: Notification[]) { private processNotifications(account: AccountInfo, notifications: Notification[]) {
if(notifications.length === 0){
return;
}
let currentNotifications = this.userNotifications.value; let currentNotifications = this.userNotifications.value;
const currentAccountNotifications = currentNotifications.find(x => x.account.id === account.id); const currentAccountNotifications = currentNotifications.find(x => x.account.id === account.id);
@ -52,6 +63,8 @@ export class UserNotificationService {
const userMentions = notifications.filter(x => x.type === 'mention').map(x => x.status); const userMentions = notifications.filter(x => x.type === 'mention').map(x => x.status);
const lastId = notifications[notifications.length - 1].id; const lastId = notifications[notifications.length - 1].id;
const sinceId = notifications[0].id;
this.sinceIds[account.id] = sinceId;
if (currentAccountNotifications) { if (currentAccountNotifications) {
const currentUserNotifications = currentAccountNotifications.notifications; const currentUserNotifications = currentAccountNotifications.notifications;