data readiness

Author: shakyShane

special-pages/pages/history/app/global-state/DataProvider.js

@@ -23,7 +23,7 @@ const DataState = createContext({
  *
  * @param {Object} props
  * @param {import('../history.service.js').HistoryService} props.service - An instance of the history service to manage state updates.
- * @param {import('../history.service.js').ServiceData} props.initial - The initial state data for the history service.
+ * @param {import('../history.service.js').InitialServiceData} props.initial - The initial state data for the history service.
  * @param {import('preact').ComponentChildren} props.children
  */
 export function DataProvider({ service, initial, children }) {

special-pages/pages/history/app/global-state/HistoryServiceProvider.js

@@ -135,7 +135,7 @@ export function useRangeChange(service) {
     const dispatch = useHistoryServiceDispatch();
     useSignalEffect(() => {
         function handler(/** @type {CustomEvent<{start: number, end: number}>} */ event) {
-            if (!service.query.data) throw new Error('unreachable');
+            if (!service.query) throw new Error('unreachable');
             const { end } = event.detail;
             dispatch({ kind: 'request-more', end });
         }

special-pages/pages/history/app/global-state/SelectionProvider.js

@@ -235,6 +235,7 @@ export function useRowInteractions() {
                 break;
             }
             case 'delete': {
+                if (selected.value.size === 0) break;
                 historyDispatch({ kind: 'delete-entries-by-index', value: [...selected.value] });
                 break;
             }

special-pages/pages/history/app/history.range.service.js

@@ -0,0 +1,87 @@
+/**
+ * @typedef {import('../types/history.js').Range} Range
+ * @typedef {{ranges: Range[]}} RangeData
+ * @typedef {{kind: 'none'} | { kind: 'domain-search'; value: string }} MenuContinuation
+ */
+
+export class HistoryRangeService {
+    data = new EventTarget();
+
+    /**
+     * @type {RangeData|null}
+     */
+    ranges = null;
+
+    /**
+     * @param {import("../src/index.js").HistoryPage} history
+     */
+    constructor(history) {
+        this.history = history;
+    }
+
+    /**
+     * @param {RangeData} d
+     */
+    accept(d) {
+        this.ranges = d;
+        this.data.dispatchEvent(new Event('data'));
+    }
+
+    /**
+     * @returns {Promise<RangeData>}
+     */
+    async getInitial() {
+        const rangesPromise = await this.history.messaging.request('getRanges');
+        this.accept(rangesPromise);
+        return rangesPromise;
+    }
+
+    /**
+     * @param {(data: RangeData) => void} cb
+     */
+    onResults(cb) {
+        const controller = new AbortController();
+        this.data.addEventListener(
+            'data',
+            () => {
+                if (this.ranges === null) throw new Error('unreachable');
+                cb(this.ranges);
+            },
+            { signal: controller.signal },
+        );
+        return () => controller.abort();
+    }
+
+    /**
+     * @param {(d: RangeData) => RangeData} updater
+     */
+    update(updater) {
+        if (this.ranges === null) throw new Error('unreachable');
+        this.accept(updater(this.ranges));
+    }
+
+    /**
+     * @param {Range} range
+     */
+    async deleteRange(range) {
+        console.log('📤 [deleteRange]: ', JSON.stringify({ range }));
+        const resp = await this.history.messaging.request('deleteRange', { range });
+        if (resp.action === 'delete') {
+            if (range === 'all') {
+                this.update((_old) => {
+                    return {
+                        ranges: ['all'],
+                    };
+                });
+            } else {
+                this.update((old) => {
+                    return {
+                        ...old,
+                        ranges: old.ranges.filter((x) => x !== range),
+                    };
+                });
+            }
+        }
+        return resp;
+    }
+}