import { useEffect, useMemo, useRef, useState } from "react"; import { useAtomSet, useAtomValue } from "@effect/atom-react"; import * as AsyncResult from "effect/unstable/reactivity/AsyncResult"; import { connectionsAtom, sourceAtom, startOAuth } from "@executor-js/react/api/atoms"; import { useScope, useScopeStack, useUserScope } from "@executor-js/react/api/scope-context"; import { connectionWriteKeys, sourceWriteKeys } from "@executor-js/react/api/reactivity-keys"; import { Button } from "@executor-js/react/components/button"; import { CopyButton } from "@executor-js/react/components/copy-button"; import { CardStack, CardStackContent, CardStackEntry, CardStackEntryContent, CardStackEntryDescription, CardStackEntryField, CardStackEntryTitle, } from "@executor-js/react/components/card-stack"; import { FilterTabs } from "@executor-js/react/components/filter-tabs"; import { Input } from "@executor-js/react/components/input"; import { sourceWriteKeys as openApiWriteKeys } from "@executor-js/react/api/reactivity-keys"; import { ConnectionId, ScopeId, SecretId } from "@executor-js/sdk/core"; import { CreatableSecretPicker } from "@executor-js/react/plugins/secret-header-auth"; import { useSecretPickerSecrets } from "@executor-js/react/plugins/use-secret-picker-secrets"; import { oauthCallbackUrl, useOAuthPopupFlow, type OAuthCompletionPayload, } from "@executor-js/react/plugins/oauth-sign-in"; import { openApiSourceAtom, openApiSourceBindingsAtom, removeOpenApiSourceBinding, setOpenApiSourceBinding, updateOpenApiSource, } from "./atoms"; import { OPENAPI_OAUTH_CALLBACK_PATH, OPENAPI_OAUTH_POPUP_NAME, inferOAuthIssuerUrl, resolveOAuthUrl, } from "./AddOpenApiSource"; import { oauth2ClientSecretSlot } from "../sdk/store"; import type { OpenApiSourceBindingValue } from "../sdk/types"; type SlotDef = | { readonly kind: "secret"; readonly slot: string; readonly label: string; readonly hint?: string; } | { readonly kind: "oauth2"; readonly slot: string; readonly label: string; }; const slugify = (value: string): string => value .trim() .toLowerCase() .replace(/[^a-z0-9]+/g, "-") .replace(/^-+|-+$/g, "") || "default"; const shortHash = (value: string): string => { let hash = 0x811c9dc5; for (let i = 0; i < value.length; i++) { hash ^= value.charCodeAt(i); hash = Math.imul(hash, 0x01000193); } return (hash >>> 0).toString(36).slice(0, 6); }; const openApiOAuthConnectionId = ( sourceId: string, securitySchemeName: string, targetScope: ScopeId, ): ConnectionId => ConnectionId.make( `openapi-oauth-${slugify(sourceId)}-${slugify(securitySchemeName)}-${shortHash(targetScope as string)}`, ); const bindingSecretId = (sourceId: string, slot: string, scopeId: string): string => `source-binding-${slugify(sourceId)}-${slugify(slot)}-${slugify(scopeId)}`; const effectiveClientSecretSlot = (oauth2: { readonly securitySchemeName: string; readonly clientSecretSlot: string | null; }): string => oauth2.clientSecretSlot ?? oauth2ClientSecretSlot(oauth2.securitySchemeName); const exactBindingForScope = ( rows: readonly { readonly slot: string; readonly scopeId: ScopeId; readonly value: unknown; }[], slot: string, scopeId: ScopeId, ) => rows.find((row) => row.slot === slot && row.scopeId === scopeId) ?? null; const scopeRank = (ranks: ReadonlyMap, scopeId: ScopeId): number => ranks.get(scopeId as string) ?? Number.MAX_SAFE_INTEGER; const effectiveBindingForScope = ( rows: readonly { readonly slot: string; readonly scopeId: ScopeId; readonly value: unknown; }[], slot: string, targetScope: ScopeId, ranks: ReadonlyMap, ) => rows.find( (row) => row.slot === slot && scopeRank(ranks, row.scopeId) >= scopeRank(ranks, targetScope), ) ?? null; const isSecretBindingValue = ( value: unknown, ): value is Extract => typeof value === "object" && value !== null && "kind" in value && (value as { kind?: unknown }).kind === "secret" && "secretId" in value; const isConnectionBindingValue = ( value: unknown, ): value is Extract => typeof value === "object" && value !== null && "kind" in value && (value as { kind?: unknown }).kind === "connection" && "connectionId" in value; export default function EditOpenApiSource(props: { readonly sourceId: string; readonly onSave: () => void; }) { const displayScope = useScope(); const scopeStack = useScopeStack(); const userScope = useUserScope(); const sourceSummaryResult = useAtomValue(sourceAtom(props.sourceId, displayScope)); const sourceSummary = AsyncResult.isSuccess(sourceSummaryResult) && sourceSummaryResult.value ? sourceSummaryResult.value : null; const sourceScopeId = sourceSummary?.scopeId ?? displayScope; const sourceScope = ScopeId.make(sourceScopeId); const scopeRanks = useMemo( () => new Map(scopeStack.map((scope, index) => [scope.id as string, index] as const)), [scopeStack], ); const sourceResult = useAtomValue(openApiSourceAtom(sourceScope, props.sourceId)); const bindingsResult = useAtomValue( openApiSourceBindingsAtom(displayScope, props.sourceId, sourceScope), ); const connectionsResult = useAtomValue(connectionsAtom(displayScope)); const secretList = useSecretPickerSecrets(); const doUpdate = useAtomSet(updateOpenApiSource, { mode: "promise" }); const doSetBinding = useAtomSet(setOpenApiSourceBinding, { mode: "promise" }); const doRemoveBinding = useAtomSet(removeOpenApiSourceBinding, { mode: "promise" }); const doStartOAuth = useAtomSet(startOAuth, { mode: "promise" }); const oauth = useOAuthPopupFlow({ popupName: OPENAPI_OAUTH_POPUP_NAME, popupBlockedMessage: "OAuth popup was blocked by the browser", startErrorMessage: "Failed to connect OAuth", }); const source = AsyncResult.isSuccess(sourceResult) && sourceResult.value ? sourceResult.value : null; const bindingRows = AsyncResult.isSuccess(bindingsResult) ? bindingsResult.value : []; const connections = AsyncResult.isSuccess(connectionsResult) ? connectionsResult.value : []; const oauth2RedirectUrl = oauthCallbackUrl(OPENAPI_OAUTH_CALLBACK_PATH); const [name, setName] = useState(source?.name ?? ""); const [baseUrl, setBaseUrl] = useState(source?.config.baseUrl ?? ""); const [sourceSaveState, setSourceSaveState] = useState<"idle" | "saving" | "saved">("idle"); const [error, setError] = useState(null); const [busyKey, setBusyKey] = useState(null); const [pendingOAuthConnection, setPendingOAuthConnection] = useState<{ readonly scopeId: ScopeId; readonly slot: string; readonly connectionId: string; } | null>(null); const [loadedSourceKey, setLoadedSourceKey] = useState(null); const [selectedCredentialScope, setSelectedCredentialScope] = useState( userScope !== sourceScopeId ? userScope : sourceScopeId, ); const sourceSaveSeq = useRef(0); useEffect(() => { if (!source) return; const sourceKey = `${sourceScopeId}:${source.namespace}`; if (loadedSourceKey === sourceKey) return; setName(source.name); setBaseUrl(source.config.baseUrl ?? ""); setSourceSaveState("idle"); setLoadedSourceKey(sourceKey); }, [loadedSourceKey, source, sourceScopeId]); useEffect(() => { setSelectedCredentialScope(userScope !== sourceScopeId ? userScope : sourceScopeId); }, [sourceScopeId, userScope]); useEffect(() => { if (!source) return; const sourceKey = `${sourceScopeId}:${source.namespace}`; if (loadedSourceKey !== sourceKey) return; const nextName = name.trim(); const nextBaseUrl = baseUrl.trim(); const currentName = source.name; const currentBaseUrl = source.config.baseUrl ?? ""; if ((nextName || currentName) === currentName && nextBaseUrl === currentBaseUrl) { return; } const timeout = window.setTimeout(() => { const seq = ++sourceSaveSeq.current; setSourceSaveState("saving"); setError(null); void doUpdate({ params: { scopeId: ScopeId.make(sourceScopeId), namespace: props.sourceId }, payload: { name: nextName || undefined, baseUrl: nextBaseUrl || undefined, headers: source.config.headers, oauth2: source.config.oauth2, }, reactivityKeys: openApiWriteKeys, }) .then(() => { if (sourceSaveSeq.current !== seq) return; setSourceSaveState("saved"); window.setTimeout(() => { if (sourceSaveSeq.current === seq) setSourceSaveState("idle"); }, 1600); }) .catch((e: unknown) => { if (sourceSaveSeq.current !== seq) return; setSourceSaveState("idle"); setError(e instanceof Error ? e.message : "Failed to save source details"); }); }, 600); return () => window.clearTimeout(timeout); }, [baseUrl, doUpdate, loadedSourceKey, name, props.sourceId, source, sourceScopeId]); const secretSlots = useMemo(() => { if (!source) return [] as SlotDef[]; const slots: SlotDef[] = []; for (const [headerName, value] of Object.entries(source.config.headers ?? {})) { if (typeof value === "string") continue; slots.push({ kind: "secret", slot: value.slot, label: headerName, hint: value.prefix ? `Prefix: ${value.prefix}` : undefined, }); } if (source.config.oauth2) { const clientSecretSlot = effectiveClientSecretSlot(source.config.oauth2); slots.push({ kind: "secret", slot: source.config.oauth2.clientIdSlot, label: "Client ID", }); slots.push({ kind: "secret", slot: clientSecretSlot, label: "Client Secret", hint: source.config.oauth2.flow === "authorizationCode" ? "Optional for public PKCE clients" : undefined, }); slots.push({ kind: "oauth2", slot: source.config.oauth2.connectionSlot, label: source.config.oauth2.flow === "clientCredentials" ? "OAuth Client Credentials" : "OAuth Authorization Code", }); } return slots; }, [source]); const credentialScopes = useMemo(() => { const entries = [{ scopeId: ScopeId.make(sourceScopeId), label: "Organization" }]; if (userScope !== sourceScopeId) { entries.unshift({ scopeId: ScopeId.make(userScope), label: "Personal" }); } else { entries[0] = { scopeId: ScopeId.make(sourceScopeId), label: "Credentials" }; } return entries; }, [sourceScopeId, userScope]); const activeCredentialScope = credentialScopes.find((entry) => entry.scopeId === selectedCredentialScope) ?? credentialScopes[0]!; const activeCredentialScopeId = activeCredentialScope.scopeId; const activeCredentialScopeLabel = activeCredentialScope.label; if (!source) { return (

Edit OpenAPI Source

Loading configuration…

); } const setSecretBinding = async (targetScope: ScopeId, slot: string, secretId: string) => { const inputKey = `${targetScope}:${slot}`; const trimmed = secretId.trim(); if (!trimmed) return; setBusyKey(inputKey); setError(null); try { await doSetBinding({ params: { scopeId: displayScope }, payload: { sourceId: props.sourceId, sourceScope, scope: targetScope, slot, value: { kind: "secret", secretId: SecretId.make(trimmed) }, }, reactivityKeys: sourceWriteKeys, }); } catch (e) { setError(e instanceof Error ? e.message : "Failed to save credential binding"); } finally { setBusyKey(null); } }; const clearBinding = async (targetScope: ScopeId, slot: string) => { setBusyKey(`${targetScope}:${slot}:clear`); setError(null); try { await doRemoveBinding({ params: { scopeId: displayScope }, payload: { sourceId: props.sourceId, sourceScope, slot, scope: targetScope, }, reactivityKeys: sourceWriteKeys, }); } catch (e) { setError(e instanceof Error ? e.message : "Failed to clear credential binding"); } finally { setBusyKey(null); } }; const connectOAuth = async (targetScope: ScopeId) => { const oauth2 = source.config.oauth2; if (!oauth2) return; const clientIdBinding = effectiveBindingForScope( bindingRows, oauth2.clientIdSlot, targetScope, scopeRanks, ); const clientSecretSlot = effectiveClientSecretSlot(oauth2); const clientSecretBinding = effectiveBindingForScope( bindingRows, clientSecretSlot, targetScope, scopeRanks, ); if (!clientIdBinding || !isSecretBindingValue(clientIdBinding.value)) { setError("Client ID must be bound before connecting"); return; } const clientIdSecretId = clientIdBinding.value.secretId; if ( oauth2.flow === "clientCredentials" && (!clientSecretBinding || !isSecretBindingValue(clientSecretBinding.value)) ) { setError("Client secret must be bound before connecting"); return; } const clientSecretValue = oauth2.flow === "clientCredentials" && clientSecretBinding && isSecretBindingValue(clientSecretBinding.value) ? clientSecretBinding.value : null; const existingConnection = exactBindingForScope( bindingRows, oauth2.connectionSlot, targetScope, ); const connectionId = existingConnection && isConnectionBindingValue(existingConnection.value) ? existingConnection.value.connectionId : openApiOAuthConnectionId(props.sourceId, oauth2.securitySchemeName, targetScope); setBusyKey(`${targetScope}:${oauth2.connectionSlot}:connect`); setPendingOAuthConnection({ scopeId: targetScope, slot: oauth2.connectionSlot, connectionId: connectionId as string, }); setError(null); try { const displayName = source.name; const tokenUrl = resolveOAuthUrl(oauth2.tokenUrl, source.config.baseUrl ?? ""); if (oauth2.flow === "clientCredentials") { const response = await doStartOAuth({ params: { scopeId: displayScope }, payload: { endpoint: tokenUrl, redirectUrl: tokenUrl, connectionId: connectionId as string, tokenScope: targetScope as string, strategy: { kind: "client-credentials", tokenEndpoint: tokenUrl, clientIdSecretId, clientSecretSecretId: clientSecretValue!.secretId, scopes: [...oauth2.scopes], }, pluginId: "openapi", identityLabel: `${displayName} OAuth`, }, }); if (!response.completedConnection) { throw new Error("Unexpected OAuth response"); } await doSetBinding({ params: { scopeId: displayScope }, payload: { sourceId: props.sourceId, sourceScope, scope: targetScope, slot: oauth2.connectionSlot, value: { kind: "connection", connectionId: ConnectionId.make(response.completedConnection.connectionId), }, }, reactivityKeys: [...sourceWriteKeys, ...connectionWriteKeys], }); setPendingOAuthConnection(null); setBusyKey(null); return; } const authorizationUrl = resolveOAuthUrl( oauth2.authorizationUrl ?? "", source.config.baseUrl ?? "", ); const issuerUrl = oauth2.issuerUrl ?? inferOAuthIssuerUrl(authorizationUrl); await oauth.openAuthorization({ run: async () => { const response = await doStartOAuth({ params: { scopeId: displayScope }, payload: { endpoint: authorizationUrl, connectionId: connectionId as string, tokenScope: targetScope as string, redirectUrl: oauth2RedirectUrl, strategy: { kind: "authorization-code", authorizationEndpoint: authorizationUrl, tokenEndpoint: tokenUrl, issuerUrl, clientIdSecretId, clientSecretSecretId: clientSecretBinding && isSecretBindingValue(clientSecretBinding.value) ? clientSecretBinding.value.secretId : null, scopes: [...oauth2.scopes], }, pluginId: "openapi", identityLabel: `${displayName} OAuth`, }, }); if (response.authorizationUrl === null) { throw new Error("Unexpected OAuth response"); } return { sessionId: response.sessionId, authorizationUrl: response.authorizationUrl, }; }, onSuccess: async (result) => { await doSetBinding({ params: { scopeId: displayScope }, payload: { sourceId: props.sourceId, sourceScope, scope: targetScope, slot: oauth2.connectionSlot, value: { kind: "connection", connectionId: ConnectionId.make(result.connectionId), }, }, reactivityKeys: [...sourceWriteKeys, ...connectionWriteKeys], }); setPendingOAuthConnection(null); setBusyKey(null); }, onError: (message) => { setError(message); setPendingOAuthConnection(null); setBusyKey(null); }, }); } catch (e) { setError(e instanceof Error ? e.message : "Failed to connect OAuth"); setPendingOAuthConnection(null); setBusyKey(null); } }; return (

OpenAPI Source

Shared source settings stay on the source. Credentials can be saved personally or shared with the organization.

Source Details Name and base URL save automatically. {sourceSaveState !== "idle" && ( {sourceSaveState === "saving" ? "Saving…" : "Saved"} )} setName((e.target as HTMLInputElement).value)} /> setBaseUrl((e.target as HTMLInputElement).value)} className="font-mono text-sm" /> Authentication Template {source.config.oauth2 ? `OAuth2 ${source.config.oauth2.flow}` : Object.keys(source.config.headers ?? {}).length > 0 ? `${Object.keys(source.config.headers ?? {}).length} header binding${ Object.keys(source.config.headers ?? {}).length === 1 ? "" : "s" }` : "None"} {credentialScopes.length > 1 && ( Credentials Choose whether each credential is personal or shared with the organization. ({ value: entry.scopeId as string, label: entry.label, }))} value={activeCredentialScopeId as string} onChange={setSelectedCredentialScope} /> )} {secretSlots .filter((slot) => slot.kind === "secret") .map((slot) => { const exact = exactBindingForScope(bindingRows, slot.slot, activeCredentialScopeId); const effective = effectiveBindingForScope( bindingRows, slot.slot, activeCredentialScopeId, scopeRanks, ); const inputKey = `${activeCredentialScopeId}:${slot.slot}`; const savedHere = !!(exact && isSecretBindingValue(exact.value)); const inherited = !savedHere && effective && effective.scopeId !== activeCredentialScopeId && isSecretBindingValue(effective.value); const currentSecretId = exact && isSecretBindingValue(exact.value) ? (exact.value.secretId as string) : inherited && effective && isSecretBindingValue(effective.value) ? (effective.value.secretId as string) : null; return (
void setSecretBinding(activeCredentialScopeId, slot.slot, secretId) } secrets={secretList} placeholder={ savedHere ? `Selected in ${activeCredentialScopeLabel.toLowerCase()}` : inherited ? "Using organization default" : "Select or create a secret" } targetScope={activeCredentialScopeId} suggestedId={bindingSecretId( props.sourceId, slot.slot, activeCredentialScopeId, )} sourceName={source.name} secretLabel={slot.label} />
{savedHere && ( )} {busyKey === inputKey && ( Saving… )} {slot.hint && ( {slot.hint} )}

{savedHere ? `Saved in ${activeCredentialScopeLabel.toLowerCase()}.` : inherited ? "No value saved here. Using the organization default." : `No ${activeCredentialScopeLabel.toLowerCase()} value saved yet.`}

); })} {source.config.oauth2 && ( <>
{oauth2RedirectUrl}

Add this to your OAuth app's allowed redirects.

{(() => { const exact = exactBindingForScope( bindingRows, source.config.oauth2!.connectionSlot, activeCredentialScopeId, ); const binding = exact ?? effectiveBindingForScope( bindingRows, source.config.oauth2!.connectionSlot, activeCredentialScopeId, scopeRanks, ); const connectionBinding = binding && isConnectionBindingValue(binding.value) ? binding.value : null; const connection = connectionBinding ? connections.find((entry) => entry.id === connectionBinding.connectionId) : null; const bindingScopeId = connectionBinding && binding ? binding.scopeId : null; const isConnecting = busyKey === `${activeCredentialScopeId}:${source.config.oauth2.connectionSlot}:connect`; const isPendingOAuthConnection = pendingOAuthConnection?.scopeId === activeCredentialScopeId && pendingOAuthConnection.slot === source.config.oauth2.connectionSlot; const isConnected = connection !== null && connection !== undefined; const statusText = isConnecting || isPendingOAuthConnection ? "Saving OAuth connection..." : connectionBinding && bindingScopeId ? connection ? bindingScopeId === activeCredentialScopeId ? `Connected in ${activeCredentialScopeLabel.toLowerCase()} as ${ connection.identityLabel ?? connection.id }` : `Using organization connection ${ connection.identityLabel ?? connection.id }` : bindingScopeId === activeCredentialScopeId ? `Saved connection is missing in ${activeCredentialScopeLabel.toLowerCase()}` : "Organization connection is missing" : `No ${activeCredentialScopeLabel.toLowerCase()} connection`; return (
{statusText}
); })()}
)}
{error && (

{error}

)}
); }