CloudConnectionPanel.tsx

// Copyright (c) 2025 ObjectStack. Licensed under the Apache-2.0 license.

/**
 * CloudConnectionPanel — the RFC 8628 device-code binding state machine,
 * registered as the SDUI widget `cloud-connection:panel`.
 *
 * This is deliberately the ONLY React in the Cloud Connection surface:
 * the page shell, nav placement and labels ship as metadata WITH the
 * `@objectstack/cloud-connection` plugin (cloud ADR-0008 / console
 * SDUI-first direction). The widget talks to the runtime's same-origin
 * `/api/v1/cloud-connection/*` routes.
 *
 * Zero-input flow (ADR runtime-identity-binding §2.3): [Connect] →
 * bind/start (no environment id — the registration is created cloud-side
 * at approval) → the approval page auto-opens in a popup with the code
 * pre-filled and the device named → bind/poll … → bound. The visible
 * user code is the popup-blocked fallback, not the primary path.
 *
 * The runtime credential never reaches the browser — bind/poll persists
 * it server-side and strips it from the response.
 */

import { useCallback, useEffect, useRef, useState } from 'react';
import {
  Cloud,
  CloudOff,
  Copy,
  ExternalLink,
  Loader2,
  AlertCircle,
  CheckCircle2,
  Unplug,
} from 'lucide-react';
import { useObjectTranslation } from '@object-ui/i18n';
import { ComponentRegistry } from '@object-ui/core';

const BASE = '/api/v1/cloud-connection';

interface ConnectionView {
  organization_id?: string | null;
  account_email?: string | null;
  bound_at?: string | null;
  name?: string | null;
  runtime_id?: string | null;
}
interface StatusData {
  environmentId: string | null;
  runtimeId?: string | null;
  bound: boolean;
  connection: ConnectionView | null;
}
interface DeviceCode {
  device_code: string;
  user_code: string;
  verification_uri?: string;
  verification_uri_complete?: string;
  interval: number;
  expires_in: number;
}

type Phase =
  | { kind: 'loading' }
  | { kind: 'unbound' }
  | { kind: 'waiting'; code: DeviceCode; popupOpened: boolean }
  | { kind: 'bound'; status: StatusData }
  | { kind: 'error'; message: string };

async function getJson(url: string, init?: RequestInit): Promise<any> {
  const resp = await fetch(url, {
    credentials: 'same-origin',
    headers: { 'Content-Type': 'application/json' },
    ...init,
  });
  const body = await resp.json().catch(() => ({}));
  if (!resp.ok && body?.success !== true) {
    const msg = body?.error?.message ?? body?.error?.code ?? body?.error ?? `HTTP ${resp.status}`;
    throw new Error(typeof msg === 'string' ? msg : JSON.stringify(msg));
  }
  return body;
}

export function CloudConnectionPanel() {
  const { t, language } = useObjectTranslation();
  const [phase, setPhase] = useState<Phase>({ kind: 'loading' });
  const [busy, setBusy] = useState(false);
  const [copied, setCopied] = useState(false);
  const pollTimer = useRef<ReturnType<typeof setTimeout> | null>(null);

  const stopPolling = useCallback(() => {
    if (pollTimer.current) { clearTimeout(pollTimer.current); pollTimer.current = null; }
  }, []);

  const refreshStatus = useCallback(async () => {
    try {
      const body = await getJson(`${BASE}/status`);
      const data: StatusData = body?.data ?? { environmentId: null, bound: false, connection: null };
      setPhase(data.bound ? { kind: 'bound', status: data } : { kind: 'unbound' });
    } catch (err: any) {
      setPhase({ kind: 'error', message: err?.message ?? String(err) });
    }
  }, []);

  useEffect(() => {
    void refreshStatus();
    return stopPolling;
  }, [refreshStatus, stopPolling]);

  const poll = useCallback((code: DeviceCode, startedAt: number) => {
    const intervalMs = Math.max(code.interval, 2) * 1000;
    const tick = async () => {
      if (Date.now() - startedAt > code.expires_in * 1000) {
        setPhase({ kind: 'error', message: t('cloudConnection.errors.expired') });
        return;
      }
      try {
        const body = await getJson(`${BASE}/bind/poll`, {
          method: 'POST',
          body: JSON.stringify({ device_code: code.device_code }),
        });
        if (body?.data?.pending) {
          pollTimer.current = setTimeout(tick, intervalMs);
          return;
        }
        if (body?.data?.bound || body?.success) {
          await refreshStatus();
          return;
        }
        setPhase({ kind: 'error', message: body?.error?.code ?? t('cloudConnection.errors.bindFailed') });
      } catch (err: any) {
        setPhase({ kind: 'error', message: err?.message ?? String(err) });
      }
    };
    pollTimer.current = setTimeout(tick, intervalMs);
  }, [refreshStatus, t]);

  const connect = useCallback(async () => {
    setBusy(true);
    try {
      const body = await getJson(`${BASE}/bind/start`, { method: 'POST', body: '{}' });
      const code: DeviceCode = body?.data;
      if (!code?.device_code || !code?.user_code) throw new Error(t('cloudConnection.errors.deviceCodeFailed'));
      // Auto-open the approval page — the GitHub-login moment. Still within
      // the click's transient activation, so popup blockers generally allow
      // it; the code display below is the blocked-popup fallback.
      const link = code.verification_uri_complete ?? code.verification_uri;
      let popupOpened = false;
      if (link) {
        try {
          popupOpened = Boolean(window.open(link, '_blank', 'noopener,width=520,height=720'));
        } catch { /* blocked — fallback UI below */ }
      }
      setPhase({ kind: 'waiting', code, popupOpened });
      poll(code, Date.now());
    } catch (err: any) {
      setPhase({ kind: 'error', message: err?.message ?? String(err) });
    } finally {
      setBusy(false);
    }
  }, [poll, t]);

  const disconnect = useCallback(async () => {
    setBusy(true);
    try {
      await getJson(`${BASE}/unbind`, { method: 'POST', body: '{}' });
      await refreshStatus();
    } catch (err: any) {
      setPhase({ kind: 'error', message: err?.message ?? String(err) });
    } finally {
      setBusy(false);
    }
  }, [refreshStatus]);

  const copyCode = useCallback(async (code: string) => {
    try {
      await navigator.clipboard.writeText(code);
      setCopied(true);
      setTimeout(() => setCopied(false), 1500);
    } catch { /* clipboard unavailable — user can select the text */ }
  }, []);

  if (phase.kind === 'loading') {
    return (
      <div className="flex items-center gap-2 rounded-lg border p-6 text-sm text-muted-foreground">
        <Loader2 className="h-4 w-4 animate-spin" aria-hidden="true" /> {t('cloudConnection.checking')}
      </div>
    );
  }

  if (phase.kind === 'error') {
    return (
      <div className="flex flex-col gap-3 rounded-lg border border-destructive/40 bg-destructive/5 p-6">
        <div className="flex items-center gap-2 text-sm text-destructive">
          <AlertCircle className="h-4 w-4" aria-hidden="true" /> {phase.message}
        </div>
        <button
          type="button"
          className="self-start rounded-md border px-3 py-1.5 text-sm hover:bg-accent"
          onClick={() => { stopPolling(); void refreshStatus(); }}
        >
          {t('cloudConnection.retry')}
        </button>
      </div>
    );
  }

  if (phase.kind === 'waiting') {
    const link = phase.code.verification_uri_complete ?? phase.code.verification_uri;
    return (
      <div className="flex flex-col gap-4 rounded-lg border p-6">
        <div className="flex items-center gap-2 text-sm text-muted-foreground">
          <Loader2 className="h-4 w-4 animate-spin" aria-hidden="true" />
          {phase.popupOpened
            ? t('cloudConnection.waiting.popupOpened')
            : t('cloudConnection.waiting.polling')}
        </div>
        {!phase.popupOpened && link ? (
          <a
            className="inline-flex items-center gap-1.5 self-start rounded-md bg-primary px-4 py-2 text-sm font-medium text-primary-foreground hover:bg-primary/90"
            href={link}
            target="_blank"
            rel="noreferrer"
          >
            {t('cloudConnection.waiting.openApproval')} <ExternalLink className="h-3.5 w-3.5" aria-hidden="true" />
          </a>
        ) : null}
        <div className="flex items-center gap-3">
          <code className="rounded-md bg-muted px-4 py-2 text-2xl font-semibold tracking-[0.25em]">
            {phase.code.user_code}
          </code>
          <button
            type="button"
            className="inline-flex items-center gap-1.5 rounded-md border px-3 py-1.5 text-sm hover:bg-accent"
            onClick={() => void copyCode(phase.code.user_code)}
          >
            <Copy className="h-3.5 w-3.5" aria-hidden="true" />
            {copied ? t('cloudConnection.waiting.copied') : t('cloudConnection.waiting.copy')}
          </button>
        </div>
        {/* Two self-contained strings rather than one sentence stitched across
            JSX — a translator never receives a dangling clause or a bare '.'. */}
        <p className="text-sm text-muted-foreground">
          {t('cloudConnection.waiting.codePrefilled')}
          {phase.popupOpened && link ? (
            <>
              {' '}
              <a className="inline-flex items-center gap-1 text-primary underline-offset-2 hover:underline" href={link} target="_blank" rel="noreferrer">
                {t('cloudConnection.waiting.openItHere')} <ExternalLink className="h-3 w-3" aria-hidden="true" />
              </a>
            </>
          ) : null}
        </p>
        <button
          type="button"
          className="self-start rounded-md border px-3 py-1.5 text-sm hover:bg-accent"
          onClick={() => { stopPolling(); void refreshStatus(); }}
        >
          {t('cloudConnection.waiting.cancel')}
        </button>
      </div>
    );
  }

  if (phase.kind === 'bound') {
    const conn = phase.status.connection ?? {};
    const runtimeId = conn.runtime_id ?? phase.status.runtimeId;
    return (
      <div className="flex flex-col gap-4 rounded-lg border p-6">
        <div className="flex items-center gap-2">
          <CheckCircle2 className="h-5 w-5 text-emerald-600" aria-hidden="true" />
          <span className="font-medium">{t('cloudConnection.bound.title')}</span>
        </div>
        <dl className="grid grid-cols-[auto_1fr] gap-x-6 gap-y-1.5 text-sm">
          {conn.name ? (<><dt className="text-muted-foreground">{t('cloudConnection.bound.runtime')}</dt><dd>{conn.name}</dd></>) : null}
          {conn.organization_id ? (<><dt className="text-muted-foreground">{t('cloudConnection.bound.organization')}</dt><dd className="font-mono">{conn.organization_id}</dd></>) : null}
          {conn.account_email ? (<><dt className="text-muted-foreground">{t('cloudConnection.bound.approvedBy')}</dt><dd>{conn.account_email}</dd></>) : null}
          {runtimeId ? (<><dt className="text-muted-foreground">{t('cloudConnection.bound.runtimeId')}</dt><dd className="font-mono text-xs">{runtimeId}</dd></>) : null}
          {phase.status.environmentId ? (<><dt className="text-muted-foreground">{t('cloudConnection.bound.environment')}</dt><dd className="font-mono">{phase.status.environmentId}</dd></>) : null}
          {conn.bound_at ? (<><dt className="text-muted-foreground">{t('cloudConnection.bound.since')}</dt><dd>{new Date(conn.bound_at).toLocaleString(language)}</dd></>) : null}
        </dl>
        <p className="text-sm text-muted-foreground">
          {t('cloudConnection.bound.privatePackages')}
        </p>
        <button
          type="button"
          disabled={busy}
          className="inline-flex items-center gap-1.5 self-start rounded-md border border-destructive/40 px-3 py-1.5 text-sm text-destructive hover:bg-destructive/5 disabled:opacity-50"
          onClick={() => void disconnect()}
        >
          <Unplug className="h-3.5 w-3.5" aria-hidden="true" /> {t('cloudConnection.bound.disconnect')}
        </button>
      </div>
    );
  }

  // unbound — zero input: no environment id, nothing to paste anywhere.
  return (
    <div className="flex flex-col gap-4 rounded-lg border p-6">
      <div className="flex items-center gap-2">
        <CloudOff className="h-5 w-5 text-muted-foreground" aria-hidden="true" />
        <span className="font-medium">{t('cloudConnection.unbound.title')}</span>
      </div>
      <p className="text-sm text-muted-foreground">
        {t('cloudConnection.unbound.body')}
      </p>
      <button
        type="button"
        disabled={busy}
        className="inline-flex items-center gap-1.5 self-start rounded-md bg-primary px-4 py-2 text-sm font-medium text-primary-foreground hover:bg-primary/90 disabled:opacity-50"
        onClick={() => void connect()}
      >
        {busy ? <Loader2 className="h-4 w-4 animate-spin" aria-hidden="true" /> : <Cloud className="h-4 w-4" aria-hidden="true" />}
        {t('cloudConnection.unbound.connect')}
      </button>
    </div>
  );
}

// SDUI registration: page metadata (shipped by @objectstack/cloud-connection)
// references this widget by type. The renderer passes the component node as
// `schema`; the panel needs no properties today.
ComponentRegistry.register('cloud-connection:panel', () => <CloudConnectionPanel />, {
  namespace: 'app-shell',
  label: 'Cloud Connection Panel',
  category: 'plugin',
  inputs: [],
});