import type { StateStorage } from "zustand/middleware";
import type { StorageAdapter } from "../types/storage";

// Paired module vars — always set/cleared together by the workspace layout.
// _currentSlug is the primary identifier (matches the URL segment).
// _currentWsId is derived (from the React Query workspace list) and used for
// query keys and path-embedded API calls where UUID is required.
let _currentSlug: string | null = null;
let _currentWsId: string | null = null;

const _rehydrateFns: Array<() => void> = [];
const _slugSubscribers = new Set<(slug: string | null) => void>();
let _pendingNotify = false;
let _pendingRehydrate = false;

/**
 * Update the current workspace identity. This is the single source of truth
 * for "which workspace is active"; everything downstream (WS connection,
 * persist namespace, cache-key derivation) follows from here.
 *
 * If the slug actually changed, two side effects fire:
 *   1. Subscribers are notified (e.g. WSProvider reconnects).
 *   2. All registered persist stores rehydrate from the new slug's namespace.
 *
 * Both side effects are idempotent on slug-equality: repeat calls with the
 * same slug are a pure no-op. This matters on desktop, where N tabs each
 * mount their own WorkspaceRouteLayout and each one naively tries to sync;
 * only the first call for a given slug does real work.
 *
 * Both side effects are deferred to a microtask because zustand persist
 * rehydrate + subscriber notifications both end up calling setState(), and
 * React 19 forbids "cross-component updates during render".
 */
export function setCurrentWorkspace(slug: string | null, wsId: string | null) {
  if (_currentSlug === slug) {
    // Slug unchanged: nothing to rehydrate, nothing to notify. Accept a
    // (possibly) updated wsId for consumers that read the UUID mirror.
    _currentWsId = wsId;
    return;
  }
  _currentSlug = slug;
  _currentWsId = wsId;

  if (!_pendingNotify) {
    _pendingNotify = true;
    queueMicrotask(() => {
      _pendingNotify = false;
      const current = _currentSlug;
      for (const fn of _slugSubscribers) {
        fn(current);
      }
    });
  }

  if (!_pendingRehydrate) {
    _pendingRehydrate = true;
    queueMicrotask(() => {
      _pendingRehydrate = false;
      for (const fn of _rehydrateFns) {
        fn();
      }
    });
  }
}

/** Current workspace slug (from URL). */
export function getCurrentSlug(): string | null {
  return _currentSlug;
}

/** Current workspace UUID (derived from slug + workspace list cache). */
export function getCurrentWsId(): string | null {
  return _currentWsId;
}

/**
 * Subscribe to changes of the current workspace slug. Returns an unsubscribe
 * function. Designed for React's `useSyncExternalStore` (WSProvider reconnect).
 */
export function subscribeToCurrentSlug(
  fn: (slug: string | null) => void,
): () => void {
  _slugSubscribers.add(fn);
  return () => {
    _slugSubscribers.delete(fn);
  };
}

/** Register a persist store's rehydrate function to be called on workspace switch. */
export function registerForWorkspaceRehydration(fn: () => void) {
  _rehydrateFns.push(fn);
}

/**
 * Storage that automatically namespaces keys with the current workspace slug.
 * Reads _currentSlug at call time, so it follows workspace switches dynamically.
 */
export function createWorkspaceAwareStorage(adapter: StorageAdapter): StateStorage {
  const resolve = (key: string) =>
    _currentSlug ? `${key}:${_currentSlug}` : key;

  return {
    getItem: (key) => adapter.getItem(resolve(key)),
    setItem: (key, value) => adapter.setItem(resolve(key), value),
    removeItem: (key) => adapter.removeItem(resolve(key)),
  };
}