Add HDSModelAppStreams: resolve app-contextual sub-streams from data model

Author: perki

ts/HDSModel/HDSModel-AppStreams.ts

@@ -0,0 +1,95 @@
+import { HDSModel } from './HDSModel.ts';
+
+export interface AppStreamDef {
+  key: string;
+  suffix: string;
+  eventType: string;
+  label: { [lang: string]: string };
+  description: { [lang: string]: string };
+  display: string;
+}
+
+/**
+ * AppStreams - Extension of HDSModel
+ *
+ * Manages app-contextual stream definitions.
+ * Each app/bridge access declares `clientData.appStreamId` (e.g. "bridge-mira-app").
+ * AppStreams definitions declare sub-streams by suffix (e.g. suffix "notes" → "bridge-mira-app-notes").
+ */
+export class HDSModelAppStreams {
+  #model: HDSModel;
+  #defs: AppStreamDef[] | null;
+
+  constructor (model: HDSModel) {
+    this.#model = model;
+    this.#defs = null;
+  }
+
+  /** Get all app stream definitions */
+  getAll (): AppStreamDef[] {
+    if (!this.#defs) {
+      this.#defs = [];
+      const raw = this.#model.modelData.appStreams || {};
+      for (const [key, def] of Object.entries(raw)) {
+        const d = def as any;
+        this.#defs.push({
+          key,
+          suffix: d.suffix,
+          eventType: d.eventType,
+          label: d.label || {},
+          description: d.description || {},
+          display: d.display || 'diary',
+        });
+      }
+    }
+    return this.#defs;
+  }
+
+  /** Get an app stream definition by key (e.g. "notes", "chat") */
+  forKey (key: string): AppStreamDef | null {
+    return this.getAll().find(d => d.key === key) || null;
+  }
+
+  /**
+   * Resolve the full stream ID for an app stream definition given an appStreamId.
+   * E.g. resolveStreamId("bridge-mira-app", "notes") → "bridge-mira-app-notes"
+   */
+  resolveStreamId (appStreamId: string, key: string): string | null {
+    const def = this.forKey(key);
+    if (!def) return null;
+    return `${appStreamId}-${def.suffix}`;
+  }
+
+  /**
+   * Resolve all app sub-stream IDs for a given appStreamId.
+   * Returns a map of key → full stream ID.
+   * E.g. resolveAll("bridge-mira-app") → { notes: "bridge-mira-app-notes", chat: "bridge-mira-app-chat" }
+   */
+  resolveAll (appStreamId: string): Record<string, string> {
+    const result: Record<string, string> = {};
+    for (const def of this.getAll()) {
+      result[def.key] = `${appStreamId}-${def.suffix}`;
+    }
+    return result;
+  }
+
+  /**
+   * Check if a streamId belongs to an app stream.
+   * Returns the app stream definition key if matched, null otherwise.
+   * E.g. matchStream("bridge-mira-app-notes", "bridge-mira-app") → "notes"
+   */
+  matchStream (streamId: string, appStreamId: string): string | null {
+    for (const def of this.getAll()) {
+      if (streamId === `${appStreamId}-${def.suffix}`) return def.key;
+    }
+    return null;
+  }
+
+  /**
+   * Extract appStreamId from an access's clientData.
+   * Returns null if not set.
+   */
+  static getAppStreamId (access: { clientData?: Record<string, any> }): string | null {
+    return access?.clientData?.appStreamId || null;
+  }
+}

ts/HDSModel/HDSModel.ts

@@ -8,6 +8,7 @@ import { HDSModelDatasources } from './HDSModel-Datasources.ts';
 import { HDSModelConversions } from './HDSModel-Conversions.ts';
 import { HDSModelConverters } from './HDSModel-Converters.ts';
 import { HDSModelPreferred } from './HDSModel-Preferred.ts';
+import { HDSModelAppStreams } from './HDSModel-AppStreams.ts';
 
 export class HDSModel {
   /**
@@ -143,6 +144,14 @@ export class HDSModel {
     }
     return this.laziliyLoadedMap.preferred;
   }
+
+  get appStreams (): HDSModelAppStreams {
+    if (!this.isLoaded) throwNotLoadedError();
+    if (!this.laziliyLoadedMap.appStreams) {
+      this.laziliyLoadedMap.appStreams = new HDSModelAppStreams(this);
+    }
+    return this.laziliyLoadedMap.appStreams;
+  }
 }
 
 function throwNotLoadedError (): never {

ts/index.ts

@@ -16,6 +16,7 @@ import { HDSProfile, PROFILE_FIELDS } from './settings/HDSProfile.ts';
 import { HDSModelConversions } from './HDSModel/HDSModel-Conversions.ts';
 import { HDSModelConverters } from './HDSModel/HDSModel-Converters.ts';
 import { HDSModelPreferred, getPreferredInput, getPreferredDisplay } from './HDSModel/HDSModel-Preferred.ts';
+import { HDSModelAppStreams } from './HDSModel/HDSModel-AppStreams.ts';
 import { EuclidianDistanceEngine } from './converters/EuclidianDistanceEngine.ts';
 import { HDSLibError } from './errors.ts';
 export type { MonitorScopeConfig, MonitorScopeCallbacks } from './MonitorScope.ts';
@@ -25,10 +26,11 @@ export type { SettingKey, SettingsValues, DateFormat, UnitSystem, Theme } from '
 export type { ProfileKey, ProfileValues } from './settings/HDSProfile.ts';
 export type { ConverterPack, ConversionResult as ConverterConversionResult, ObservationVector, SourceBlock } from './converters/types.ts';
 export type { PreferredConfig } from './HDSModel/HDSModel-Preferred.ts';
+export type { AppStreamDef } from './HDSModel/HDSModel-AppStreams.ts';
 
 export const getHDSModel = HDSModelInitAndSingleton.getModel;
 export const initHDSModel = HDSModelInitAndSingleton.initHDSModel;
-export { pryv, settings, HDSService, HDSModel, appTemplates, localizeText, localizeText as l, toolkit, logger, durationToSeconds, durationToLabel, computeReminders, eventToShortText, formatEventDate, MonitorScope, HDSSettings, SETTING_TYPES, HDSProfile, PROFILE_FIELDS, HDSModelConversions, HDSModelConverters, HDSModelPreferred, getPreferredInput, getPreferredDisplay, EuclidianDistanceEngine, HDSLibError };
+export { pryv, settings, HDSService, HDSModel, appTemplates, localizeText, localizeText as l, toolkit, logger, durationToSeconds, durationToLabel, computeReminders, eventToShortText, formatEventDate, MonitorScope, HDSSettings, SETTING_TYPES, HDSProfile, PROFILE_FIELDS, HDSModelConversions, HDSModelConverters, HDSModelPreferred, getPreferredInput, getPreferredDisplay, HDSModelAppStreams, EuclidianDistanceEngine, HDSLibError };
 
 // also exporting default for typescript to capture HDSLib.. there is surely a nicer way to do
 const HDSLib = {