openclaw/ui/src/app/native-gateways.runtime.ts

export type NativeGateway = {
  id: string;
  name: string;
  kind: "local" | "remote";
  isPrimary: boolean;
  canPromote: boolean;
  health: "ok" | "error" | "unknown";
};

export type NativeGatewaysSnapshot = { gateways: NativeGateway[]; currentId: string };
type NativeGatewaysMessage =
  | { type: "select" | "open-window" | "set-primary"; id: string }
  | { type: "open-settings" };
type NativeGatewaysWindow = Window & {
  __OPENCLAW_NATIVE_GATEWAYS__?: unknown;
  webkit?: {
    messageHandlers?: { openclawGateways?: { postMessage(message: NativeGatewaysMessage): void } };
  };
};

const NATIVE_GATEWAYS_CHANGED_EVENT = "openclaw:native-gateways-changed";

export type NativeGatewaysCapability = {
  readonly snapshot: NativeGatewaysSnapshot | null;
  subscribe(listener: (snapshot: NativeGatewaysSnapshot) => void): () => void;
  select(id: string): void;
  openWindow(id: string): void;
  setPrimary(id: string): void;
  openSettings(): void;
};

function snapshotFrom(value: unknown): NativeGatewaysSnapshot | null {
  if (!value || typeof value !== "object") {
    return null;
  }
  const snapshot = value as Partial<NativeGatewaysSnapshot>;
  // The embedder owns this payload; deep validation only defends the Mac app from itself.
  return Array.isArray(snapshot.gateways) && typeof snapshot.currentId === "string"
    ? (snapshot as NativeGatewaysSnapshot)
    : null;
}

function createNativeGatewaysCapability(): NativeGatewaysCapability | null {
  if (typeof window === "undefined") {
    return null;
  }
  const nativeWindow = window as NativeGatewaysWindow;
  const handler = nativeWindow.webkit?.messageHandlers?.openclawGateways;
  if (!handler?.postMessage) {
    return null;
  }
  const post = handler.postMessage.bind(handler);
  const postWithId = (type: "select" | "open-window" | "set-primary", id: string) =>
    post({ type, id });
  let snapshot = snapshotFrom(nativeWindow["__OPENCLAW_NATIVE_GATEWAYS__"]);
  const listeners = new Set<(snapshot: NativeGatewaysSnapshot) => void>();
  const onChange = (event: Event) => {
    const next = snapshotFrom((event as CustomEvent<unknown>).detail);
    if (!next) {
      return;
    }
    snapshot = next;
    listeners.forEach((listener) => listener(next));
  };
  window.addEventListener(NATIVE_GATEWAYS_CHANGED_EVENT, onChange);
  return {
    get snapshot() {
      return snapshot;
    },
    subscribe(listener) {
      listeners.add(listener);
      return () => listeners.delete(listener);
    },
    select: (id) => postWithId("select", id),
    openWindow: (id) => postWithId("open-window", id),
    setPrimary: (id) => postWithId("set-primary", id),
    openSettings: () => post({ type: "open-settings" }),
  };
}

let singleton: NativeGatewaysCapability | null | undefined;

// Chat-chunk-owned so this capability never enters the QA-smoke startup bundle.
export function nativeGatewaysCapability(): NativeGatewaysCapability | null {
  if (singleton === undefined) {
    singleton = createNativeGatewaysCapability();
  }
  return singleton;
}