Mastodon/Sengi-Windows-MacOS-Linux
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

added buffer logic when scrolling the stream

Browse Source
This commit is contained in:
Nicolas Constant 2018-09-17 22:13:37 -04:00
parent a3e63366a7
commit 0795a39502
No known key found for this signature in database
GPG Key ID: 1E9F677FB01A5688
1 changed files with 26 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/app/components/stream/stream.component.ts
View File

@ -18,6 +18,7 @@ export class StreamComponent implements OnInit {
private websocketStreaming: StreamingWrapper; private websocketStreaming: StreamingWrapper;
statuses: Status[] = []; statuses: Status[] = [];
private bufferStream: Status[] = [];
@Input() @Input()
set streamElement(streamElement: StreamElement) { set streamElement(streamElement: StreamElement) {
@ -69,12 +70,22 @@ export class StreamComponent implements OnInit {
if (atBottom) { if (atBottom) {
console.log('Bottom reached!!'); console.log('Bottom reached!!');
this.streamPositionnedAtBottom = true; this.streamPositionnedAtBottom = true;
} else if (atTop) { } else if (atTop) {
console.log('Top reached!!'); this.scrolledToTop()
this.streamPositionnedAtTop = true;
} }
} }
private scrolledToTop() {
console.log('Top reached!!');
this.streamPositionnedAtTop = true;
for (const status of this.bufferStream) {
this.statuses.unshift(status); //TODO check order of status
}
this.bufferStream.length = 0;
}
private getRegisteredAccounts(): AccountInfo[] { private getRegisteredAccounts(): AccountInfo[] {
var regAccounts = <AccountInfo[]>this.store.snapshot().registeredaccounts.accounts; var regAccounts = <AccountInfo[]>this.store.snapshot().registeredaccounts.accounts;
return regAccounts; return regAccounts;
@ -89,13 +100,19 @@ export class StreamComponent implements OnInit {
}); });
} }
private launchWebsocket(): void { private launchWebsocket(): void {
this.websocketStreaming = this.streamingService.getStreaming(this.account, this._streamElement.type); this.websocketStreaming = this.streamingService.getStreaming(this.account, this._streamElement.type);
this.websocketStreaming.statusUpdateSubjet.subscribe((update: StatusUpdate) => { this.websocketStreaming.statusUpdateSubjet.subscribe((update: StatusUpdate) => {
if (update) { if (update) {
if (update.type === EventEnum.update) { if (update.type === EventEnum.update) {
if (!this.statuses.find(x => x.id == update.status.id)) { if (!this.statuses.find(x => x.id == update.status.id)) {
this.statuses.unshift(update.status); if (this.streamPositionnedAtTop) {
this.statuses.unshift(update.status);
} else {
this.bufferStream.unshift(update.status);
}
} }
} }
} }
@ -104,11 +121,13 @@ export class StreamComponent implements OnInit {
}); });
} }
private checkAndCleanUpStream(): void { private checkAndCleanUpStream(): void {
if (this.streamPositionnedAtTop && this.statuses.length > 60) { if (this.streamPositionnedAtTop && this.statuses.length > 60) {
console.log(`clean up start! ${this.statuses.length}`);
this.statuses.length = 40; this.statuses.length = 40;
console.log(`clean up ends! ${this.statuses.length}`); }
if (this.bufferStream.length > 60) {
this.bufferStream.length = 40;
} }
} }
} }