Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-30 04:01:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

init UI increase logs buffer and don't throw on websocket unsubscribe (#2669)

Browse Source 
* init UI increase logs buffer and don't throw on websocket unsubscribe

* fix: remove smooth scroll for logs

---------

Co-authored-by: waterplea <alexander@inkin.ru>
This commit is contained in:
Matt Hill
2024-07-18 21:49:31 -06:00
committed by GitHub
parent 8f0bdcd172
commit 196561fed2
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
web/projects/ui/src/app/pages/init/init.service.ts
View File

@@ -58,8 +58,8 @@ export class InitService extends Observable<MappedProgress> {
}
}),
catchError(e => {
// @TODO this toast is presenting when we navigate away from init page. It seems other websockets exhibit the same behavior, but we never noticed because the error were not being caught and presented in this manner
this.errorService.handleError(e)
// @TODO Alex this toast is presenting when we navigate away from init page. It seems other websockets exhibit the same behavior, but we never noticed because the error were not being caught and presented in this manner. It seems odd that unsubscribing from a websocket subject would be treated as an error.
// this.errorService.handleError(e)
return EMPTY
}),

6
web/projects/ui/src/app/pages/init/logs/logs.component.ts
View File

@@ -24,10 +24,10 @@ export class LogsComponent {
scroll = true
scrollTo(bottom: HTMLElement) {
if (this.scroll) bottom.scrollIntoView({ behavior: 'smooth' })
if (this.scroll) bottom.scrollIntoView()
}
onBottom([{ isIntersecting }]: readonly IntersectionObserverEntry[]) {
this.scroll = isIntersecting
onBottom(entries: readonly IntersectionObserverEntry[]) {
this.scroll = entries[entries.length - 1].isIntersecting
}
}

2
web/projects/ui/src/app/pages/init/logs/logs.service.ts
View File

@@ -39,7 +39,7 @@ export class LogsService extends Observable<readonly string[]> {
this.api.initFollowLogs({ boot: 0 }),
).pipe(
switchMap(({ guid }) => this.api.openWebsocket$<Log>(guid, {})),
bufferTime(250),
bufferTime(500),
filter(logs => !!logs.length),
map(convertAnsi),
scan((logs: readonly string[], log) => [...logs, log], []),