Salastil/streamwall
1
0
Fork 0
mirror of https://github.com/streamwall/streamwall.git synced 2026-04-03 12:22:09 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix rotating web pages setting to video kind

Browse Source
This commit is contained in:
Max Goodhart
2026-02-02 02:11:12 -08:00
parent 345a44f51b
commit a9ae4ffc2f
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/streamwall/src/main/data.ts
View File

@@ -91,11 +91,11 @@ export async function* combineDataSources(
}
interface LocalStreamDataEvents {
update: [StreamDataContent[]]
update: [Partial<StreamDataContent>[]]
}
export class LocalStreamData extends EventEmitter<LocalStreamDataEvents> {
dataByURL: Map<string, StreamDataContent>
dataByURL: Map<string, Partial<StreamDataContent>>
constructor(entries: StreamDataContent[] = []) {
super()
@@ -110,8 +110,11 @@ export class LocalStreamData extends EventEmitter<LocalStreamDataEvents> {
update(url: string, data: Partial<StreamDataContent>) {
const existing = this.dataByURL.get(url)
const kind = data.kind ?? existing?.kind ?? 'video'
const updated: StreamDataContent = { ...existing, ...data, kind, link: url }
const updated: Partial<StreamDataContent> = {
...existing,
...data,
link: url,
}
this.dataByURL.set(data.link ?? url, updated)
if (data.link != null && url !== data.link) {
this.dataByURL.delete(url)
@@ -128,7 +131,7 @@ export class LocalStreamData extends EventEmitter<LocalStreamDataEvents> {
this.emit('update', [...this.dataByURL.values()])
}
gen(): AsyncGenerator<StreamDataContent[]> {
gen(): AsyncGenerator<Partial<StreamDataContent>[]> {
return new Repeater(async (push, stop) => {
await push([...this.dataByURL.values()])
this.on('update', push)