import { Option, Schema } from "effect"; export const DEFAULT_EXECUTOR_SERVER_ORIGIN = "http://127.0.0.1:4000";export const DEFAULT_EXECUTOR_SERVER_USERNAME = "executor"; export type ExecutorServerConnectionKind = "http" | "desktop-sidecar";export type ExecutorLocalServerKind = "cli-daemon" | "desktop-sidecar" | "foreground"; export type ExecutorServerAuth =  | {      readonly kind: "basic";      readonly username?: string;      readonly password: string;    }  | {      readonly kind: "bearer";      readonly token: string;    }; export interface ExecutorServerConnection {  readonly kind: ExecutorServerConnectionKind;  readonly key: string;  readonly origin: string;  readonly apiBaseUrl: string;  readonly displayName: string;  readonly auth?: ExecutorServerAuth;} export interface ExecutorServerConnectionInput {  readonly kind?: ExecutorServerConnectionKind;  readonly key?: string;  readonly origin?: string;  readonly apiBaseUrl?: string;  readonly displayName?: string;  readonly auth?: ExecutorServerAuth;} export interface ExecutorLocalServerManifest {  readonly version: 1;  readonly kind: ExecutorLocalServerKind;  readonly pid: number;  readonly startedAt: string;  readonly dataDir: string;  readonly scopeDir: string | null;  readonly connection: ExecutorServerConnection;  readonly owner: {    readonly client: "cli" | "desktop";    readonly version: string | null;    readonly executablePath: string | null;  };} const stripTrailingSlash = (value: string): string => value.replace(/\/+$/, ""); const displayNameFromOrigin = (origin: string): string =>  origin.replace(/^https?:\/\//, "").replace(/\/+$/, ""); export const normalizeExecutorServerOrigin = (raw: string): string => {  const trimmed = stripTrailingSlash(raw.trim());  if (!trimmed) return DEFAULT_EXECUTOR_SERVER_ORIGIN;   const parsed = new URL(/^https?:\/\//.test(trimmed) ? trimmed : `http://${trimmed}`);  if (parsed.pathname === "/api") {    parsed.pathname = "/";  }  parsed.search = "";  parsed.hash = "";  return stripTrailingSlash(parsed.toString());}; export const apiBaseUrlForServerOrigin = (origin: string): string => `${origin}/api`; export const originFromApiBaseUrl = (raw: string): string => {  const parsed = new URL(raw);  if (parsed.pathname.endsWith("/api")) {    parsed.pathname = parsed.pathname.slice(0, -"/api".length) || "/";  }  parsed.search = "";  parsed.hash = "";  return normalizeExecutorServerOrigin(parsed.toString());}; export const normalizeExecutorServerConnection = (  input: ExecutorServerConnectionInput = {},): ExecutorServerConnection => {  const origin = normalizeExecutorServerOrigin(    input.origin ??      (input.apiBaseUrl ? originFromApiBaseUrl(input.apiBaseUrl) : DEFAULT_EXECUTOR_SERVER_ORIGIN),  );  const apiBaseUrl = stripTrailingSlash(input.apiBaseUrl ?? apiBaseUrlForServerOrigin(origin));  const kind = input.kind ?? "http";   return {    kind,    key: input.key ?? `${kind}:${origin}`,    origin,    apiBaseUrl,    displayName: input.displayName ?? displayNameFromOrigin(origin),    ...(input.auth ? { auth: input.auth } : {}),  };}; const encodeBasicCredentials = (credentials: string): string | null => {  if (typeof globalThis.btoa === "function") {    return globalThis.btoa(credentials);  }   const buffer = (    globalThis as {      readonly Buffer?: {        readonly from: (value: string) => { readonly toString: (encoding: "base64") => string };      };    }  ).Buffer;  if (buffer) {    return buffer.from(credentials).toString("base64");  }   return null;}; export const getExecutorServerAuthorizationHeader = (  connection: ExecutorServerConnection,): string | null => {  const auth = connection.auth;  if (!auth) return null;  if (auth.kind === "bearer") return `Bearer ${auth.token}`;  const encoded = encodeBasicCredentials(    `${auth.username ?? DEFAULT_EXECUTOR_SERVER_USERNAME}:${auth.password}`,  );  return encoded ? `Basic ${encoded}` : null;}; const ExecutorServerAuthJson = Schema.Union([  Schema.Struct({    kind: Schema.Literal("basic"),    username: Schema.optional(Schema.String),    password: Schema.String,  }),  Schema.Struct({    kind: Schema.Literal("bearer"),    token: Schema.String,  }),]); const ExecutorServerConnectionJson = Schema.Struct({  kind: Schema.optional(Schema.Literals(["http", "desktop-sidecar"])),  key: Schema.optional(Schema.String),  origin: Schema.String,  apiBaseUrl: Schema.optional(Schema.String),  displayName: Schema.optional(Schema.String),  auth: Schema.optional(ExecutorServerAuthJson),}); const ExecutorLocalServerManifestJson = Schema.Struct({  version: Schema.Literal(1),  kind: Schema.Literals(["cli-daemon", "desktop-sidecar", "foreground"]),  pid: Schema.Number,  startedAt: Schema.String,  dataDir: Schema.String,  scopeDir: Schema.NullOr(Schema.String),  connection: ExecutorServerConnectionJson,  owner: Schema.Struct({    client: Schema.Literals(["cli", "desktop"]),    version: Schema.NullOr(Schema.String),    executablePath: Schema.NullOr(Schema.String),  }),}); const decodeUnknownJsonOption = Schema.decodeUnknownOption(Schema.UnknownFromJsonString);const decodeExecutorLocalServerManifestJson = Schema.decodeUnknownOption(  ExecutorLocalServerManifestJson,); const canNormalizeServerOrigin = (origin: string): boolean => {  const trimmed = stripTrailingSlash(origin.trim());  if (!trimmed) return true;  return URL.canParse(/^https?:\/\//.test(trimmed) ? trimmed : `http://${trimmed}`);}; export const parseExecutorLocalServerManifest = (  raw: string,): ExecutorLocalServerManifest | null => {  const json = decodeUnknownJsonOption(raw);  if (Option.isNone(json)) return null;  const decoded = decodeExecutorLocalServerManifestJson(json.value);  if (Option.isNone(decoded)) return null;  const parsed = decoded.value;  if (    !Number.isInteger(parsed.pid) ||    parsed.pid <= 0 ||    !canNormalizeServerOrigin(parsed.connection.origin)  ) {    return null;  }   const connection = normalizeExecutorServerConnection(parsed.connection);  return {    version: 1,    kind: parsed.kind,    pid: parsed.pid,    startedAt: parsed.startedAt,    dataDir: parsed.dataDir,    scopeDir: parsed.scopeDir,    connection,    owner: {      client: parsed.owner.client,      version: parsed.owner.version,      executablePath: parsed.owner.executablePath,    },  };}; export const serializeExecutorLocalServerManifest = (  manifest: ExecutorLocalServerManifest,): string => `${JSON.stringify(manifest, null, 2)}\n`;