import * as Schema from "effect/Schema";import * as Rpc from "effect/unstable/rpc/Rpc";import * as RpcGroup from "effect/unstable/rpc/RpcGroup"; import { ExternalLauncherError, LaunchEditorInput } from "./editor.ts";import {  AuthAccessStreamError,  AuthAccessStreamEvent,  EnvironmentAuthorizationError,} from "./auth.ts";import {  BackgroundPolicySnapshot,  ClientActivityReportInput,  HostPowerSnapshot,} from "./background.ts";import {  FilesystemBrowseInput,  FilesystemBrowseResult,  FilesystemBrowseError,} from "./filesystem.ts";import {  AssetAccessError,  AssetCreateUrlInput,  AssetCreateUrlResult,  AttachmentCreateUploadUrlInput,  AttachmentCreateUploadUrlResult,  AttachmentDeleteInput,  AttachmentUploadSigningKeyError,} from "./assets.ts";import {  GitActionProgressEvent,  VcsSwitchRefInput,  VcsSwitchRefResult,  GitCommandError,  VcsCreateRefInput,  VcsCreateRefResult,  VcsCreateWorktreeInput,  VcsCreateWorktreeResult,  VcsInitInput,  VcsListRefsInput,  VcsListRefsResult,  GitManagerServiceError,  GitPreparePullRequestThreadInput,  GitPreparePullRequestThreadResult,  VcsPullInput,  GitPullRequestRefInput,  VcsPullResult,  VcsRemoveWorktreeInput,  GitResolvePullRequestResult,  GitRunStackedActionInput,  VcsStatusInput,  VcsStatusResult,  VcsStatusStreamEvent,} from "./git.ts";import {  ReviewDiffFileContentsInput,  ReviewDiffFileContentsResult,  ReviewDiffPreviewError,  ReviewDiffPreviewInput,  ReviewDiffPreviewResult,} from "./review.ts";import { KeybindingsConfigError } from "./keybindings.ts";import {  ClientOrchestrationCommand,  ORCHESTRATION_WS_METHODS,  OrchestrationDispatchCommandError,  OrchestrationGetFullThreadDiffError,  OrchestrationGetFullThreadDiffInput,  OrchestrationGetSnapshotError,  OrchestrationSearchThreadsError,  OrchestrationSearchThreadsInput,  OrchestrationGetTurnDiffError,  OrchestrationGetTurnDiffInput,  OrchestrationRpcSchemas,  OrchestrationGetWorkflowScriptError,} from "./orchestration.ts";import {  ProviderUploadFeedbackError,  ProviderUploadFeedbackInput,  ProviderUploadFeedbackResult,} from "./provider.ts";import { ProviderInstanceId } from "./providerInstance.ts";import {  PullRequestActionInput,  PullRequestActivity,  PullRequestCommentInput,  PullRequestCommentUpdateInput,  PullRequestDetail,  PullRequestDiffFileContentsInput,  PullRequestDiffFileContentsResult,  PullRequestInvalidateInput,  PullRequestListInput,  PullRequestListResult,  PullRequestListStatsInput,  PullRequestListStatsResult,  PullRequestOperationError,  PullRequestReactionInput,  PullRequestRef,  PullRequestReviewerCandidateList,  PullRequestReviewerRequestInput,  PullRequestSubmitReviewInput,  PullRequestThreadCommentsInput,  PullRequestThreadCommentsResult,  PullRequestThreadReplyInput,  PullRequestThreadResolutionInput,  PullRequestUnavailableError,  PullRequestUpdateInput,} from "./pullRequest.ts";import {  RelayClientInstallFailedError,  RelayClientInstallProgressEventSchema,  RelayClientStatusSchema,} from "./relayClient.ts";import {  ProjectListEntriesError,  ProjectListEntriesInput,  ProjectListEntriesResult,  ProjectReadFileError,  ProjectReadFileInput,  ProjectReadFileResult,  ProjectSearchContentsError,  ProjectSearchContentsInput,  ProjectSearchContentsResult,  ProjectSearchEntriesError,  ProjectSearchEntriesInput,  ProjectSearchEntriesResult,  ProjectWriteFileError,  ProjectWriteFileInput,  ProjectWriteFileResult,} from "./project.ts";import {  TerminalAttachInput,  TerminalAttachStreamEvent,  TerminalClearInput,  TerminalCloseInput,  TerminalError,  TerminalEvent,  TerminalMetadataStreamEvent,  TerminalOpenInput,  TerminalResizeInput,  TerminalRestartInput,  TerminalSessionSnapshot,  TerminalWriteInput,} from "./terminal.ts";import {  DiscoveredLocalServerList,  ConfiguredLocalServerUrls,  PreviewCloseInput,  PreviewError,  PreviewEvent,  PreviewListInput,  PreviewListResult,  PreviewNavigateInput,  PreviewOpenInput,  PreviewRefreshInput,  PreviewReportStatusInput,  PreviewResizeInput,  PreviewSessionSnapshot,} from "./preview.ts";import {  PreviewAutomationError,  PreviewAutomationHost,  PreviewAutomationHostFocus,  PreviewAutomationResponse,  PreviewAutomationStreamEvent,} from "./previewAutomation.ts";import {  ServerConfigStreamEvent,  ServerConfig,  ServerProviderUpdateError,  ServerProviderUpdateInput,  ServerLifecycleStreamEvent,  ServerRemoveKeybindingInput,  ServerRemoveKeybindingResult,  ServerProviderUpdatedPayload,  ServerSelfUpdateError,  ServerSelfUpdateInput,  ServerSelfUpdateProgressEvent,  ServerSelfUpdateResult,  ServerTraceDiagnosticsResult,  ServerProcessDiagnosticsResult,  ServerProcessResourceHistoryInput,  ServerProcessResourceHistoryResult,  ServerSignalProcessInput,  ServerSignalProcessResult,  ServerUpsertKeybindingInput,  ServerUpsertKeybindingResult,} from "./server.ts";import {  ResourceTelemetryHistory,  ResourceTelemetryHistoryInput,  ResourceTelemetryRetryResult,  ResourceTelemetrySnapshot,} from "./resourceTelemetry.ts";import { UsageReadError, UsageSummary, UsageSummaryInput } from "./usage.ts";import { ServerSettings, ServerSettingsError, ServerSettingsPatch } from "./settings.ts";import {  SourceControlCloneRepositoryInput,  SourceControlCloneRepositoryResult,  SourceControlDiscoveryResult,  SourceControlPublishRepositoryInput,  SourceControlPublishRepositoryResult,  SourceControlRepositoryError,  SourceControlRepositoryInfo,  SourceControlRepositoryLookupInput,} from "./sourceControl.ts";import { VcsError } from "./vcs.ts"; export const WS_METHODS = {  // Project registry methods  projectsList: "projects.list",  projectsAdd: "projects.add",  projectsRemove: "projects.remove",  projectsListEntries: "projects.listEntries",  projectsReadFile: "projects.readFile",  projectsSearchContents: "projects.searchContents",  projectsSearchEntries: "projects.searchEntries",  projectsWriteFile: "projects.writeFile",   // Shell methods  shellOpenInEditor: "shell.openInEditor",   // Filesystem methods  filesystemBrowse: "filesystem.browse",  assetsCreateUrl: "assets.createUrl",  attachmentsCreateUploadUrl: "attachments.createUploadUrl",  attachmentsDelete: "attachments.delete",   // Provider methods  providerUploadFeedback: "provider.uploadFeedback",   // VCS methods  vcsPull: "vcs.pull",  vcsRefreshStatus: "vcs.refreshStatus",  vcsListRefs: "vcs.listRefs",  vcsCreateWorktree: "vcs.createWorktree",  vcsRemoveWorktree: "vcs.removeWorktree",  vcsCreateRef: "vcs.createRef",  vcsSwitchRef: "vcs.switchRef",  vcsInit: "vcs.init",   // Git workflow methods  gitRunStackedAction: "git.runStackedAction",  gitResolvePullRequest: "git.resolvePullRequest",  gitPreparePullRequestThread: "git.preparePullRequestThread",   // Review methods  reviewGetDiffPreview: "review.getDiffPreview",  reviewGetDiffFileContents: "review.getDiffFileContents",   // Terminal methods  terminalOpen: "terminal.open",  terminalAttach: "terminal.attach",  terminalWrite: "terminal.write",  terminalResize: "terminal.resize",  terminalClear: "terminal.clear",  terminalRestart: "terminal.restart",  terminalClose: "terminal.close",   // Preview methods  previewOpen: "preview.open",  previewNavigate: "preview.navigate",  previewResize: "preview.resize",  previewRefresh: "preview.refresh",  previewClose: "preview.close",  previewList: "preview.list",  previewReportStatus: "preview.reportStatus",  previewAutomationConnect: "previewAutomation.connect",  previewAutomationRespond: "previewAutomation.respond",  previewAutomationFocusHost: "previewAutomation.focusHost",   // Server meta  serverProbe: "server.probe",  serverGetConfig: "server.getConfig",  serverRefreshProviders: "server.refreshProviders",  serverUpdateProvider: "server.updateProvider",  serverUpdateServer: "server.updateServer",  serverUpdateServerWithProgress: "server.updateServerWithProgress",  serverUpsertKeybinding: "server.upsertKeybinding",  serverRemoveKeybinding: "server.removeKeybinding",  serverGetSettings: "server.getSettings",  serverUpdateSettings: "server.updateSettings",  serverDiscoverSourceControl: "server.discoverSourceControl",  serverGetTraceDiagnostics: "server.getTraceDiagnostics",  serverGetProcessDiagnostics: "server.getProcessDiagnostics",  serverGetProcessResourceHistory: "server.getProcessResourceHistory",  serverGetResourceTelemetryHistory: "server.getResourceTelemetryHistory",  serverRetryResourceTelemetry: "server.retryResourceTelemetry",  serverSignalProcess: "server.signalProcess",  serverReportClientActivity: "server.reportClientActivity",  serverReportHostPowerState: "server.reportHostPowerState",  serverGetBackgroundPolicy: "server.getBackgroundPolicy",  serverGetUsageSummary: "server.getUsageSummary",   // Cloud environment methods  cloudGetRelayClientStatus: "cloud.getRelayClientStatus",  cloudInstallRelayClient: "cloud.installRelayClient",   // Pull request methods  pullRequestsList: "pullRequests.list",  pullRequestsListStats: "pullRequests.listStats",  pullRequestsDetail: "pullRequests.detail",  pullRequestsActivity: "pullRequests.activity",  pullRequestsThreadComments: "pullRequests.threadComments",  pullRequestsDiffFileContents: "pullRequests.diffFileContents",  pullRequestsRunAction: "pullRequests.runAction",  pullRequestsUpdate: "pullRequests.update",  pullRequestsComment: "pullRequests.comment",  pullRequestsUpdateComment: "pullRequests.updateComment",  pullRequestsSubmitReview: "pullRequests.submitReview",  pullRequestsReplyToThread: "pullRequests.replyToThread",  pullRequestsSetThreadResolution: "pullRequests.setThreadResolution",  pullRequestsSetReaction: "pullRequests.setReaction",  pullRequestsInvalidate: "pullRequests.invalidate",  pullRequestsReviewerCandidates: "pullRequests.reviewerCandidates",  pullRequestsRequestReviewers: "pullRequests.requestReviewers",   // Source control methods  sourceControlLookupRepository: "sourceControl.lookupRepository",  sourceControlCloneRepository: "sourceControl.cloneRepository",  sourceControlPublishRepository: "sourceControl.publishRepository",   // Streaming subscriptions  subscribeVcsStatus: "subscribeVcsStatus",  subscribeTerminalEvents: "subscribeTerminalEvents",  subscribeTerminalMetadata: "subscribeTerminalMetadata",  subscribePreviewEvents: "subscribePreviewEvents",  subscribeDiscoveredLocalServers: "subscribeDiscoveredLocalServers",  subscribeServerConfig: "subscribeServerConfig",  subscribeServerLifecycle: "subscribeServerLifecycle",  subscribeAuthAccess: "subscribeAuthAccess",  subscribeBackgroundPolicy: "subscribeBackgroundPolicy",  subscribeResourceTelemetry: "subscribeResourceTelemetry",} as const; export const WsServerUpsertKeybindingRpc = Rpc.make(WS_METHODS.serverUpsertKeybinding, {  payload: ServerUpsertKeybindingInput,  success: ServerUpsertKeybindingResult,  error: Schema.Union([KeybindingsConfigError, EnvironmentAuthorizationError]),}); export const WsServerRemoveKeybindingRpc = Rpc.make(WS_METHODS.serverRemoveKeybinding, {  payload: ServerRemoveKeybindingInput,  success: ServerRemoveKeybindingResult,  error: Schema.Union([KeybindingsConfigError, EnvironmentAuthorizationError]),}); export const WsServerProbeRpc = Rpc.make(WS_METHODS.serverProbe, {  payload: Schema.Struct({}),  success: Schema.Struct({}),  error: EnvironmentAuthorizationError,}); export const WsServerGetConfigRpc = Rpc.make(WS_METHODS.serverGetConfig, {  payload: Schema.Struct({}),  success: ServerConfig,  error: Schema.Union([KeybindingsConfigError, ServerSettingsError, EnvironmentAuthorizationError]),}); export const WsServerRefreshProvidersRpc = Rpc.make(WS_METHODS.serverRefreshProviders, {  payload: Schema.Struct({    /**     * When supplied, only refresh this specific provider instance. When     * omitted, refresh all configured instances — the legacy `refresh()`     * behaviour retained for transports that still dispatch untargeted     * refreshes.     */    instanceId: Schema.optional(ProviderInstanceId),  }),  success: ServerProviderUpdatedPayload,  error: EnvironmentAuthorizationError,}); export const WsServerUpdateProviderRpc = Rpc.make(WS_METHODS.serverUpdateProvider, {  payload: ServerProviderUpdateInput,  success: ServerProviderUpdatedPayload,  error: Schema.Union([ServerProviderUpdateError, EnvironmentAuthorizationError]),}); export const WsServerUpdateServerRpc = Rpc.make(WS_METHODS.serverUpdateServer, {  payload: ServerSelfUpdateInput,  success: ServerSelfUpdateResult,  error: Schema.Union([ServerSelfUpdateError, EnvironmentAuthorizationError]),}); export const WsServerUpdateServerWithProgressRpc = Rpc.make(  WS_METHODS.serverUpdateServerWithProgress,  {    payload: ServerSelfUpdateInput,    success: ServerSelfUpdateProgressEvent,    error: Schema.Union([ServerSelfUpdateError, EnvironmentAuthorizationError]),    stream: true,  },); export const WsServerGetSettingsRpc = Rpc.make(WS_METHODS.serverGetSettings, {  payload: Schema.Struct({}),  success: ServerSettings,  error: Schema.Union([ServerSettingsError, EnvironmentAuthorizationError]),}); export const WsServerUpdateSettingsRpc = Rpc.make(WS_METHODS.serverUpdateSettings, {  payload: Schema.Struct({ patch: ServerSettingsPatch }),  success: ServerSettings,  error: Schema.Union([ServerSettingsError, EnvironmentAuthorizationError]),}); export const WsServerDiscoverSourceControlRpc = Rpc.make(WS_METHODS.serverDiscoverSourceControl, {  payload: Schema.Struct({}),  success: SourceControlDiscoveryResult,  error: EnvironmentAuthorizationError,}); export const WsServerGetTraceDiagnosticsRpc = Rpc.make(WS_METHODS.serverGetTraceDiagnostics, {  payload: Schema.Struct({}),  success: ServerTraceDiagnosticsResult,  error: EnvironmentAuthorizationError,}); export const WsServerGetProcessDiagnosticsRpc = Rpc.make(WS_METHODS.serverGetProcessDiagnostics, {  payload: Schema.Struct({}),  success: ServerProcessDiagnosticsResult,  error: EnvironmentAuthorizationError,}); export const WsServerGetProcessResourceHistoryRpc = Rpc.make(  WS_METHODS.serverGetProcessResourceHistory,  {    payload: ServerProcessResourceHistoryInput,    success: ServerProcessResourceHistoryResult,    error: EnvironmentAuthorizationError,  },); export const WsServerGetResourceTelemetryHistoryRpc = Rpc.make(  WS_METHODS.serverGetResourceTelemetryHistory,  {    payload: ResourceTelemetryHistoryInput,    success: ResourceTelemetryHistory,    error: EnvironmentAuthorizationError,  },); export const WsServerRetryResourceTelemetryRpc = Rpc.make(WS_METHODS.serverRetryResourceTelemetry, {  payload: Schema.Struct({}),  success: ResourceTelemetryRetryResult,  error: EnvironmentAuthorizationError,}); export const WsServerGetUsageSummaryRpc = Rpc.make(WS_METHODS.serverGetUsageSummary, {  payload: UsageSummaryInput,  success: UsageSummary,  error: Schema.Union([EnvironmentAuthorizationError, UsageReadError]),}); export const WsServerSignalProcessRpc = Rpc.make(WS_METHODS.serverSignalProcess, {  payload: ServerSignalProcessInput,  success: ServerSignalProcessResult,  error: EnvironmentAuthorizationError,}); export const WsCloudGetRelayClientStatusRpc = Rpc.make(WS_METHODS.cloudGetRelayClientStatus, {  payload: Schema.Struct({}),  success: RelayClientStatusSchema,  error: EnvironmentAuthorizationError,}); export const WsCloudInstallRelayClientRpc = Rpc.make(WS_METHODS.cloudInstallRelayClient, {  payload: Schema.Struct({}),  success: RelayClientInstallProgressEventSchema,  error: Schema.Union([RelayClientInstallFailedError, EnvironmentAuthorizationError]),  stream: true,}); export const WsServerReportClientActivityRpc = Rpc.make(WS_METHODS.serverReportClientActivity, {  payload: ClientActivityReportInput,  error: EnvironmentAuthorizationError,}); export const WsServerReportHostPowerStateRpc = Rpc.make(WS_METHODS.serverReportHostPowerState, {  payload: HostPowerSnapshot,  error: EnvironmentAuthorizationError,}); export const WsServerGetBackgroundPolicyRpc = Rpc.make(WS_METHODS.serverGetBackgroundPolicy, {  payload: Schema.Struct({}),  success: BackgroundPolicySnapshot,  error: EnvironmentAuthorizationError,}); const PullRequestRpcError = Schema.Union([  PullRequestUnavailableError,  PullRequestOperationError,  EnvironmentAuthorizationError,]); export const WsPullRequestsListRpc = Rpc.make(WS_METHODS.pullRequestsList, {  payload: PullRequestListInput,  success: PullRequestListResult,  error: PullRequestRpcError,

Lines 1–500 of 1132. Load more