Method LoadData

backend/Src/main.ts:255–302

()

    }

    public LoadData(): void {
        const pluginState = this.storage.FetchPlugins();

        pluginState.forEach(x => {
            const p = this.pluginManager.FindPlugin(x.name);

            if (p === null) {
                return;
            }

            p.id = x.id;
            p.enabled = x.enabled;

            const observables = new Set<string>();
            p.service.SetObservables(observables);
            this.linkedStreams.AddPlugin(p.id, observables);
        });
        this.pluginManager.ReorderPlugins(pluginState.map(x => x.id));

        this.storage
            .FetchObservables()
            .forEach(x => {
                const plugins: Plugin[] = [];
                for (const name of x.plugins) {
                    const plugin = this.pluginManager.FindPlugin(name);

                    if (plugin === null) {
                        Logger.Get.Log(`${x.url} has missing plugin '${name}'`);
                        return;
                    }
                    plugins.push(plugin);
                }

                this.observables.set(x.url, { url: x.url, lastSeen: x.lastSeen, plugins });
            });

        this.archive = this.storage.FetchArchiveRecords()
            .map(x => ({ ...x, locked: false, tags: new Set<string>() }));

        this.storage.FetchArchiveTags()
            .forEach(x => this.archive.find(y => y.filename === x.filename)?.tags.add(x.tag));

        this.storage.FetchArchiveFilters()
            .forEach(x => this.archiveFilters.set(x.id, x));

        this.storage.FetchObservablesFilters()
            .forEach(x => this.observablesFilters.set(x.id, x));
    }
    private async StartResourceMonitor() {
        this.systemResourcesMonitor =
            await new SystemResourcesMonitorFactory(ARCHIVE_FOLDER, 10000).Create();