Merge pull request #102 from topicusonderwijs/refactor/registry

refactor(registry): Added registry to flows

Author: Aukevanoost

build.js

@@ -96,6 +96,15 @@ async function generateBundles() {
       sourcemap: true
     },
 
+    'vanilla-native-federation/registry': {
+      ...baseConfig,
+      entryPoints: ['src/lib/registry.index.ts'],
+      outfile: path.join(OUTPUT_PATHS.fesm2022, 'registry.mjs'),
+      bundle: true,
+      sourcemap: true
+    },
+
+
     'vanilla-native-federation/audit': {
       ...baseConfig,
       entryPoints: ['src/lib/audit.index.ts'],
@@ -115,8 +124,8 @@ async function generateBundles() {
 
     'vanilla-native-federation/registry': {
       ...baseConfig,
-      entryPoints: [path.join(PATHS.quickstart, "registry.ts")],
-      outfile: path.join(OUTPUT_PATHS.quickstart, `registry.mjs`),
+      entryPoints: [path.join(PATHS.quickstart, "init-registry.ts")],
+      outfile: path.join(OUTPUT_PATHS.quickstart, `init-registry.mjs`),
       bundle: true,
       sourcemap: false,
       minify: true
@@ -134,8 +143,8 @@ function generatePackageExports() {
         "default": "./quickstart.mjs"
       },
 
-      "./registry.mjs": {
-        "default": "./registry.mjs"
+      "./init-registry.mjs": {
+        "default": "./init-registry.mjs"
       },
 
       ".": {
@@ -147,6 +156,11 @@ function generatePackageExports() {
         "types": "./types/lib/sdk.index.d.ts", 
         "default": "./fesm2022/sdk.mjs"
       },
+
+      "./registry": {
+        "types": "./types/lib/registry.index.d.ts", 
+        "default": "./fesm2022/registry.mjs"
+      },
 
       "./options": {
         "types": "./types/lib/options.index.d.ts",

src/init-registry.ts

@@ -0,0 +1,32 @@
+import { createRegistry } from 'lib/registry.index';
+import type { NFEventRegistry } from './lib/1.domain/registry/event-registry.contract';
+import type { NFEventRegistryConfig } from './lib/2.app/config/registry.contract';
+
+declare global {
+  interface Window {
+    __NF_REGISTRY__: NFEventRegistry;
+  }
+}
+
+(function (): void {
+  const script = document.currentScript as HTMLScriptElement | null;
+
+  const config: NFEventRegistryConfig = {
+    // Maximum number of different event types to keep in the registry.
+    maxStreams: script?.dataset?.maxStreams ? Number(script.dataset.maxStreams) : 50,
+
+    // Maximum number of events to keep in the history for each event type.
+    maxEvents: script?.dataset?.maxEvents ? Number(script.dataset.maxEvents) : 50,
+
+    // When trimming events, remove this percentage of the oldest events.
+    // E.g. with 0.25 and maxEvents=50, when the 51st event is added, the oldest 12 events are removed,
+    // leaving 38 events in the history.
+    removePercentage: script?.dataset?.removePercentage
+      ? Number(script.dataset.removePercentage) / 100
+      : 0.5,
+  };
+
+  const registry = createRegistry(config);
+
+  window.__NF_REGISTRY__ = Object.freeze(registry());
+})();

src/lib/1.domain/registry/event-registry.contract.ts

@@ -10,4 +10,5 @@ export type NFEventRegistry = {
   onReady<T>(name: string, callback: NFEventConsumer<T>): NFEventUnsubscribe;
   emit<T>(type: string, data: T): void;
   on<T>(type: string, callback: NFEventConsumer<NFEventData<T>>): NFEventUnsubscribe;
+  clear(type?: string): void;
 };

src/lib/2.app/config/registry.contract.ts

@@ -0,0 +1,7 @@
+export type NFEventRegistryConfig = {
+  maxStreams: number;
+  maxEvents: number;
+  removePercentage: number;
+};
+
+export type NFEventRegistryOptions = Partial<NFEventRegistryConfig>;

src/lib/2.app/driver-ports/registry/for-managing-events.port.ts

@@ -0,0 +1,3 @@
+import type { NFEventRegistry } from '../../../1.domain/registry/event-registry.contract';
+
+export type ForManagingEvents = () => NFEventRegistry;