feat(progress): adds queuing service to progress

Author: dvcol

demo/components/DemoProgress.svelte

@@ -64,8 +64,6 @@
 
   const label = $derived(NeoProgressStatus.Active === controlledState ? 'pause' : 'play');
 
-  $inspect(controlledState);
-
   const bar = $state<NeoProgressBarProps>({
     elevation: -1,
     borderless: false,

src/lib/progress/index.ts

@@ -1,6 +1,7 @@
 export { default as NeoProgress } from './NeoProgress.svelte';
 export { default as NeoProgressBar } from './NeoProgressBar.svelte';
 
+export * from './neo-progress-service.svelte';
 export { NeoProgressDirection, NeoProgressStatus } from './neo-progress.model.js';
 
 export type * from './neo-progress-bar.model.js';

src/lib/progress/neo-progress-service.svelte.ts

@@ -0,0 +1,84 @@
+import type { NeoProgressHTMLElement, NeoProgressStart } from '~/progress/neo-progress.model.js';
+
+import { getUUID } from '@dvcol/common-utils/common/string';
+import { SvelteSet } from 'svelte/reactivity';
+
+import { NeoProgressStatus } from '~/progress/neo-progress.model.js';
+
+/**
+ * Queuing service to keep track of concurrent call to progress bar
+ */
+export class NeoProgressService {
+  #ref: NeoProgressHTMLElement;
+  #active = $state(new SvelteSet<string>());
+
+  get value() {
+    return this.#ref.value;
+  }
+
+  get buffer() {
+    return this.#ref.buffer;
+  }
+
+  get status() {
+    return this.#ref.status;
+  }
+
+  get active(): Set<string> {
+    return $state.snapshot(this.#active);
+  }
+
+  constructor(ref: NeoProgressHTMLElement) {
+    this.#ref = ref;
+  }
+
+  sync() {
+    if (this.status === NeoProgressStatus.Active) return;
+    if (this.status === NeoProgressStatus.Indeterminate) return;
+    this.#active.clear();
+    return this.active;
+  }
+
+  start(opts?: NeoProgressStart, id = getUUID()) {
+    this.sync();
+    this.#active.add(id);
+    if (this.status === NeoProgressStatus.Active) this.#ref.reset(true, opts);
+    else this.#ref.start(opts);
+    return id;
+  }
+
+  cancel(id?: string, force = !id) {
+    this.sync();
+    if (id) this.#active.delete(id);
+    if (force || this.#active.size === 0) void this.#ref.cancel();
+    return id;
+  }
+
+  complete(id?: string, force = !id) {
+    this.sync();
+    if (id) this.#active.delete(id);
+    if (force || this.#active.size === 0) void this.#ref.complete();
+    return id;
+  }
+
+  error(id?: string, force = !id) {
+    this.sync();
+    if (id) this.#active.delete(id);
+    if (force || this.#active.size === 0) void this.#ref.complete({ state: NeoProgressStatus.Error });
+    return id;
+  }
+
+  success(id?: string, force = !id) {
+    this.sync();
+    if (id) this.#active.delete(id);
+    if (force || this.#active.size === 0) void this.#ref.complete({ state: NeoProgressStatus.Success });
+    return id;
+  }
+
+  warning(id?: string, force = !id) {
+    this.sync();
+    if (id) this.#active.delete(id);
+    if (force || this.#active.size === 0) void this.#ref.complete({ state: NeoProgressStatus.Warning });
+    return id;
+  }
+}