From 0c4e08be25e4b93a52905e5a778057af8f272bd1 Mon Sep 17 00:00:00 2001
From: chrismclarke <chris.m.clarke@live.co.uk>
Date: Mon, 10 Mar 2025 11:23:12 -0700
Subject: [PATCH] feat: user debug page dynamic updates

---
 .../pages/user-debug/user-debug.page.html     |  18 ++-
 .../pages/user-debug/user-debug.page.scss     |   7 +
 .../user/pages/user-debug/user-debug.page.ts  | 127 +++++++++++-------
 3 files changed, 97 insertions(+), 55 deletions(-)

diff --git a/src/app/feature/user/pages/user-debug/user-debug.page.html b/src/app/feature/user/pages/user-debug/user-debug.page.html
index 07cd9276f0..6d54f362cc 100644
--- a/src/app/feature/user/pages/user-debug/user-debug.page.html
+++ b/src/app/feature/user/pages/user-debug/user-debug.page.html
@@ -94,16 +94,15 @@ <h2>Dynamic Data</h2>
   <ion-select
     #dynamicDataSelect
     placeholder="Select Data"
-    [(ngModel)]="dynamicDataSelected"
-    (ionChange)="setDynamicEntryView(dynamicDataSelect.value)"
+    [value]="dynamicDataSelected()"
+    (ionChange)="dynamicDataSelected.set(dynamicDataSelect.value)"
     style="margin-bottom: 1rem"
-    [compareWith]="dynamicEntryCompareFn"
   >
-    @for(entry of dynamicDataEntries; track entry.id){
-    <ion-select-option [value]="entry">{{entry.flow_name}}</ion-select-option>
+    @for(flowName of dynamicDataSelectOptions(); track flowName){
+    <ion-select-option [value]="flowName">{{flowName}}</ion-select-option>
     }
   </ion-select>
-  @if(dynamicDataTable; as table){
+  @if(dynamicDataTableData(); as table){
   <div class="table-container">
     <table>
       <thead>
@@ -117,7 +116,12 @@ <h2>Dynamic Data</h2>
         @for(row of table.rows; track row.id){
         <tr>
           @for(header of table.headers; track header){
-          <td>{{row[header]}}</td>
+          <td
+            class="dynamic-data-value"
+            [class.isOverrideValue]="row._override_keys.includes(header)"
+          >
+            {{row[header]}}
+          </td>
           }
         </tr>
         }
diff --git a/src/app/feature/user/pages/user-debug/user-debug.page.scss b/src/app/feature/user/pages/user-debug/user-debug.page.scss
index 4e382b8b7b..83a1fd037c 100644
--- a/src/app/feature/user/pages/user-debug/user-debug.page.scss
+++ b/src/app/feature/user/pages/user-debug/user-debug.page.scss
@@ -16,6 +16,13 @@ th {
   top: 0;
   background-color: #f9f8f8;
 }
+
+td.dynamic-data-value {
+  opacity: 0.4;
+}
+td.isOverrideValue {
+  opacity: 1;
+}
 .table-container {
   max-height: 300px;
   overflow: auto;
diff --git a/src/app/feature/user/pages/user-debug/user-debug.page.ts b/src/app/feature/user/pages/user-debug/user-debug.page.ts
index 0f540a5f30..5493b18deb 100644
--- a/src/app/feature/user/pages/user-debug/user-debug.page.ts
+++ b/src/app/feature/user/pages/user-debug/user-debug.page.ts
@@ -1,17 +1,13 @@
-import { Component, Injector, OnInit, signal } from "@angular/core";
-import { uniqueObjectArrayKeys } from "packages/shared/src/utils/object-utils";
+import { Component, computed, effect, Injector, OnInit, signal } from "@angular/core";
+import { isEqual, uniqueObjectArrayKeys } from "packages/shared/src/utils/object-utils";
+import { map } from "rxjs";
+import { toSignal } from "@angular/core/rxjs-interop";
 import { TemplateActionService } from "src/app/shared/components/template/services/instance/template-action.service";
 import { TemplateFieldService } from "src/app/shared/components/template/services/template-field.service";
 import { AuthService } from "src/app/shared/services/auth/auth.service";
 import { DynamicDataService } from "src/app/shared/services/dynamic-data/dynamic-data.service";
 import { LocalStorageService } from "src/app/shared/services/local-storage/local-storage.service";
-
-interface IDynamicDataEntry {
-  id: string;
-  flow_type: string;
-  flow_name: string;
-  data: Record<string, any>;
-}
+import { AppDataService } from "src/app/shared/services/data/app-data.service";
 
 @Component({
   selector: "user-debug-page",
@@ -19,13 +15,6 @@ interface IDynamicDataEntry {
   styleUrl: "user-debug.page.scss",
 })
 export class UserDebugPage implements OnInit {
-  constructor(
-    private fieldService: TemplateFieldService,
-    private dynamicDataService: DynamicDataService,
-    private localStorageService: LocalStorageService,
-    public authService: AuthService,
-    private injector: Injector
-  ) {}
   /** Id of current user */
   public userId = "";
   /** ID of user to import */
@@ -34,15 +23,68 @@ export class UserDebugPage implements OnInit {
   public contactFields = signal<{ key: string; value: string }[]>([]);
   /** List of protected user contact fields */
   public protectedFields = signal<{ key: string; value: string }[]>([]);
-  /** List of user dynamic_data entries */
-  public dynamicDataEntries: IDynamicDataEntry[] = [];
-  /** Active row selected from list of user dynamic_data entries */
-  public dynamicDataSelected: IDynamicDataEntry;
+
+  /** Live state of all dynamic data stored */
+  private dynamicDataState = toSignal(this.subscribeToDynamicDataState());
+
+  /** Name of flow selected to display dynamic data */
+  public dynamicDataSelected = signal("");
+
+  /** Live state of selected flow dynamic data sub-state */
+  private dynamicDataSelectedState = computed(
+    () => {
+      const state = this.dynamicDataState() || ({} as any);
+      const selected = this.dynamicDataSelected();
+      return { ...state.data_list?.[selected] };
+    },
+    { equal: isEqual }
+  );
+
   /** Table configuration to display data from active dynamic_data row */
-  public dynamicDataTable: { headers: string[]; rows: any[] };
+  public dynamicDataTableData = signal({ headers: [], rows: [] });
+
+  /** List of all flow names where dynamic data has been set */
+  public dynamicDataSelectOptions = computed(() => [
+    ...Object.keys(this.dynamicDataState()?.data_list || {}),
+  ]);
 
   private actionService = new TemplateActionService(this.injector);
 
+  constructor(
+    private fieldService: TemplateFieldService,
+    private appDataService: AppDataService,
+    private dynamicDataService: DynamicDataService,
+    private localStorageService: LocalStorageService,
+    public authService: AuthService,
+    private injector: Injector
+  ) {
+    // load first dynamic data option by default
+    effect(
+      () => {
+        const selected = this.dynamicDataSelected();
+        if (!selected) {
+          const options = this.dynamicDataSelectOptions();
+          if (options[0]) {
+            this.dynamicDataSelected.set(options[0]);
+          }
+        }
+      },
+      { allowSignalWrites: true }
+    );
+    // load table data when selected flow or corresponding data sub-state changes
+    effect(
+      async () => {
+        const selected = this.dynamicDataSelected();
+        const dynamicData = this.dynamicDataSelectedState();
+        if (selected) {
+          const { headers, rows } = await this.loadDynamicDataTable(selected, dynamicData);
+          this.dynamicDataTableData.set({ headers, rows });
+        }
+      },
+      { allowSignalWrites: true }
+    );
+  }
+
   async ngOnInit() {
     await this.fieldService.ready();
     await this.dynamicDataService.ready();
@@ -55,10 +97,6 @@ export class UserDebugPage implements OnInit {
     this.loadUserContactFields();
     this.userId = this.fieldService.getField("_app_user_id");
     this.importUserId = this.userId;
-    this.dynamicDataEntries = await this.getDynamicDataEntries();
-    // populate dynamic data table with first entry if available
-    this.dynamicDataSelected = this.dynamicDataEntries[0];
-    this.setDynamicEntryView(this.dynamicDataEntries[0]);
   }
 
   public async importUserData(id: string) {
@@ -81,19 +119,17 @@ export class UserDebugPage implements OnInit {
   }
 
   /** Prepare table data to display for provided dynamic data entry */
-  public setDynamicEntryView(entry?: IDynamicDataEntry) {
-    if (entry) {
-      // ensure all entries include an id column and put at start of table
-      const rows = Object.entries(entry.data).map(([id, data]) => ({ ...data, id }));
-      const uniqueKeys = uniqueObjectArrayKeys(rows);
-      const headers = ["id", ...uniqueKeys.filter((k) => k !== "id")];
-      this.dynamicDataTable = { headers, rows };
-    } else {
-      this.dynamicDataTable = { headers: [], rows: [] };
-    }
-  }
-  public dynamicEntryCompareFn(a: IDynamicDataEntry, b: IDynamicDataEntry) {
-    return a.id === b.id;
+  private async loadDynamicDataTable(flowName: string, flowDynamicData: any = {}) {
+    const sheetData = await this.appDataService.getSheet("data_list", flowName);
+    const allTableData = sheetData?.rows || [];
+    // generate list of all unique headers found across original data and overrides
+    const headers = uniqueObjectArrayKeys([...allTableData, ...Object.values(flowDynamicData)]);
+    // generate a list of merged initial + user override data, tracking what keys contain overridden values
+    const rows = allTableData.map((r) => {
+      const overrides = flowDynamicData[r.id];
+      return { ...r, ...overrides, _override_keys: Object.keys(overrides || {}) };
+    });
+    return { headers, rows };
   }
 
   /** Retrieve localStorage entries prefixed by field service prefix */
@@ -107,15 +143,10 @@ export class UserDebugPage implements OnInit {
     this.protectedFields.set(contactFields.filter((v) => v.key.startsWith("_")));
   }
 
-  /** Retrieve user dynamic data entries stored in IndexedDB */
-  private async getDynamicDataEntries() {
-    const dynamicData: IDynamicDataEntry[] = [];
-    const state = await this.dynamicDataService.getState();
-    for (const [flow_type, dataByFlow] of Object.entries(state)) {
-      for (const [flow_name, data] of Object.entries(dataByFlow)) {
-        dynamicData.push({ flow_type, flow_name, data, id: `${flow_type}__${flow_name}` });
-      }
-    }
-    return dynamicData;
+  /** Create a subscription that updates with any writeCache db changes and returns full state of cache */
+  private subscribeToDynamicDataState() {
+    const writeCache = this.dynamicDataService["writeCache"];
+    // return new object for writeCache state to ensure signal fires
+    return writeCache["collection"].find().$.pipe(map(() => ({ ...writeCache.state })));
   }
 }