History

refactor(contracts): keep RPC implementation exports private (#10168)

Julius Marminge committed 2 months ago

Commit 5716dec1 parent dbfd5172 files · +174 −210Browse files

Unified · Split

2 files
  1. packages/contracts/src/providerRuntime.ts +1 −1
  2. packages/contracts/src/rpc.ts +173 −209
packages/contracts/src/providerRuntime.ts+1−1
@@ -103,7 +103,7 @@ const RuntimeErrorClass = Schema.Literals([ · 102 unmodified lines
103103 ]);
104104 export type RuntimeErrorClass = typeof RuntimeErrorClass.Type;
105105
106−export const TOOL_LIFECYCLE_ITEM_TYPES = [
106+const TOOL_LIFECYCLE_ITEM_TYPES = [
107107 "command_execution",
108108 "file_change",
109109 "mcp_tool_call",
packages/contracts/src/rpc.ts+173−209
@@ -378,31 +378,31 @@ export const WS_METHODS = { · 377 unmodified lines
378378 subscribeResourceTelemetry: "subscribeResourceTelemetry",
379379 } as const;
380380
381−export const WsServerUpsertKeybindingRpc = Rpc.make(WS_METHODS.serverUpsertKeybinding, {
381+const WsServerUpsertKeybindingRpc = Rpc.make(WS_METHODS.serverUpsertKeybinding, {
382382 payload: ServerUpsertKeybindingInput,
383383 success: ServerUpsertKeybindingResult,
384384 error: Schema.Union([KeybindingsConfigError, EnvironmentAuthorizationError]),
385385 });
386386
387−export const WsServerRemoveKeybindingRpc = Rpc.make(WS_METHODS.serverRemoveKeybinding, {
387+const WsServerRemoveKeybindingRpc = Rpc.make(WS_METHODS.serverRemoveKeybinding, {
388388 payload: ServerRemoveKeybindingInput,
389389 success: ServerRemoveKeybindingResult,
390390 error: Schema.Union([KeybindingsConfigError, EnvironmentAuthorizationError]),
391391 });
392392
393−export const WsServerProbeRpc = Rpc.make(WS_METHODS.serverProbe, {
393+const WsServerProbeRpc = Rpc.make(WS_METHODS.serverProbe, {
394394 payload: Schema.Struct({}),
395395 success: Schema.Struct({}),
396396 error: EnvironmentAuthorizationError,
397397 });
398398
399−export const WsServerGetConfigRpc = Rpc.make(WS_METHODS.serverGetConfig, {
399+const WsServerGetConfigRpc = Rpc.make(WS_METHODS.serverGetConfig, {
400400 payload: Schema.Struct({}),
401401 success: ServerConfig,
402402 error: Schema.Union([KeybindingsConfigError, ServerSettingsError, EnvironmentAuthorizationError]),
403403 });
404404
405−export const WsServerRefreshProvidersRpc = Rpc.make(WS_METHODS.serverRefreshProviders, {
405+const WsServerRefreshProvidersRpc = Rpc.make(WS_METHODS.serverRefreshProviders, {
406406 payload: Schema.Struct({
407407 /**
408408 * When supplied, only refresh this specific provider instance. When
@@ -419,7 +419,7 @@ export const WsServerRefreshProvidersRpc = Rpc.make(WS_METHODS.serverRefreshProv · 10 unmodified lines
419419 error: Schema.Union([EnvironmentAuthorizationError, ProviderSetupError]),
420420 });
421421
422−export const WsServerUpdateProviderRpc = Rpc.make(WS_METHODS.serverUpdateProvider, {
422+const WsServerUpdateProviderRpc = Rpc.make(WS_METHODS.serverUpdateProvider, {
423423 payload: ServerProviderUpdateInput,
424424 success: ServerProviderUpdatedPayload,
425425 error: Schema.Union([ServerProviderUpdateError, EnvironmentAuthorizationError]),
@@ -427,130 +427,124 @@ export const WsServerUpdateProviderRpc = Rpc.make(WS_METHODS.serverUpdateProvide · 1 unmodified line
427427
428428 const ProviderSetupRpcError = Schema.Union([ProviderSetupError, EnvironmentAuthorizationError]);
429429
430−export const WsProviderConsumeResetCreditRpc = Rpc.make(WS_METHODS.providerConsumeResetCredit, {
430+const WsProviderConsumeResetCreditRpc = Rpc.make(WS_METHODS.providerConsumeResetCredit, {
431431 payload: ProviderConsumeResetCreditInput,
432432 success: ProviderConsumeResetCreditResult,
433433 error: ProviderSetupRpcError,
434434 });
435435
436−export const WsProviderAuthStartRpc = Rpc.make(WS_METHODS.providerAuthStart, {
436+const WsProviderAuthStartRpc = Rpc.make(WS_METHODS.providerAuthStart, {
437437 payload: ProviderSetupInput,
438438 success: ProviderAuthState,
439439 error: ProviderSetupRpcError,
440440 });
441441
442−export const WsProviderAuthCompleteRpc = Rpc.make(WS_METHODS.providerAuthComplete, {
442+const WsProviderAuthCompleteRpc = Rpc.make(WS_METHODS.providerAuthComplete, {
443443 payload: ProviderAuthCompleteInput,
444444 success: ProviderAuthState,
445445 error: ProviderSetupRpcError,
446446 });
447447
448−export const WsProviderAuthCancelRpc = Rpc.make(WS_METHODS.providerAuthCancel, {
448+const WsProviderAuthCancelRpc = Rpc.make(WS_METHODS.providerAuthCancel, {
449449 payload: ProviderAuthCancelInput,
450450 success: ProviderAuthState,
451451 error: ProviderSetupRpcError,
452452 });
453453
454−export const WsProviderAuthLogoutRpc = Rpc.make(WS_METHODS.providerAuthLogout, {
454+const WsProviderAuthLogoutRpc = Rpc.make(WS_METHODS.providerAuthLogout, {
455455 payload: ProviderSetupInput,
456456 success: ProviderAuthState,
457457 error: ProviderSetupRpcError,
458458 });
459459
460−export const WsProviderAuthSubscribeRpc = Rpc.make(WS_METHODS.providerAuthSubscribe, {
460+const WsProviderAuthSubscribeRpc = Rpc.make(WS_METHODS.providerAuthSubscribe, {
461461 payload: ProviderSetupInput,
462462 success: ProviderAuthState,
463463 error: ProviderSetupRpcError,
464464 stream: true,
465465 });
466466
467−export const WsProviderInstallStartRpc = Rpc.make(WS_METHODS.providerInstallStart, {
467+const WsProviderInstallStartRpc = Rpc.make(WS_METHODS.providerInstallStart, {
468468 payload: ProviderSetupInput,
469469 success: ProviderInstallState,
470470 error: ProviderSetupRpcError,
471471 });
472472
473−export const WsProviderInstallCancelRpc = Rpc.make(WS_METHODS.providerInstallCancel, {
473+const WsProviderInstallCancelRpc = Rpc.make(WS_METHODS.providerInstallCancel, {
474474 payload: ProviderInstallCancelInput,
475475 success: ProviderInstallState,
476476 error: ProviderSetupRpcError,
477477 });
478478
479−export const WsProviderInstallSubscribeRpc = Rpc.make(WS_METHODS.providerInstallSubscribe, {
479+const WsProviderInstallSubscribeRpc = Rpc.make(WS_METHODS.providerInstallSubscribe, {
480480 payload: ProviderSetupInput,
481481 success: ProviderInstallState,
482482 error: ProviderSetupRpcError,
483483 stream: true,
484484 });
485485
486−export const WsProviderInstallRemoveRpc = Rpc.make(WS_METHODS.providerInstallRemove, {
486+const WsProviderInstallRemoveRpc = Rpc.make(WS_METHODS.providerInstallRemove, {
487487 payload: ProviderSetupInput,
488488 success: ProviderInstallState,
489489 error: ProviderSetupRpcError,
490490 });
491491
492−export const WsServerUpdateServerRpc = Rpc.make(WS_METHODS.serverUpdateServer, {
492+const WsServerUpdateServerRpc = Rpc.make(WS_METHODS.serverUpdateServer, {
493493 payload: ServerSelfUpdateInput,
494494 success: ServerSelfUpdateResult,
495495 error: Schema.Union([ServerSelfUpdateError, EnvironmentAuthorizationError]),
496496 });
497497
498−export const WsServerUpdateServerWithProgressRpc = Rpc.make(
499− WS_METHODS.serverUpdateServerWithProgress,
500− {
501− payload: ServerSelfUpdateInput,
502− success: ServerSelfUpdateProgressEvent,
503− error: Schema.Union([ServerSelfUpdateError, EnvironmentAuthorizationError]),
504− stream: true,
505− },
506−);
498+const WsServerUpdateServerWithProgressRpc = Rpc.make(WS_METHODS.serverUpdateServerWithProgress, {
499+ payload: ServerSelfUpdateInput,
500+ success: ServerSelfUpdateProgressEvent,
501+ error: Schema.Union([ServerSelfUpdateError, EnvironmentAuthorizationError]),
502+ stream: true,
503+});
507504
508−export const WsServerCommitDesktopUpdateRpc = Rpc.make(WS_METHODS.serverCommitDesktopUpdate, {
505+const WsServerCommitDesktopUpdateRpc = Rpc.make(WS_METHODS.serverCommitDesktopUpdate, {
509506 payload: DesktopUpdateCommitInput,
510507 success: ServerSelfUpdateResult,
511508 error: Schema.Union([ServerSelfUpdateError, EnvironmentAuthorizationError]),
512509 });
513510
514−export const WsServerGetSettingsRpc = Rpc.make(WS_METHODS.serverGetSettings, {
511+const WsServerGetSettingsRpc = Rpc.make(WS_METHODS.serverGetSettings, {
515512 payload: Schema.Struct({}),
516513 success: ServerSettings,
517514 error: Schema.Union([ServerSettingsError, EnvironmentAuthorizationError]),
518515 });
519516
520−export const WsServerUpdateSettingsRpc = Rpc.make(WS_METHODS.serverUpdateSettings, {
517+const WsServerUpdateSettingsRpc = Rpc.make(WS_METHODS.serverUpdateSettings, {
521518 payload: Schema.Struct({ patch: ServerSettingsPatch }),
522519 success: ServerSettings,
523520 error: Schema.Union([ServerSettingsError, EnvironmentAuthorizationError]),
524521 });
525522
526−export const WsServerDiscoverSourceControlRpc = Rpc.make(WS_METHODS.serverDiscoverSourceControl, {
523+const WsServerDiscoverSourceControlRpc = Rpc.make(WS_METHODS.serverDiscoverSourceControl, {
527524 payload: Schema.Struct({}),
528525 success: SourceControlDiscoveryResult,
529526 error: EnvironmentAuthorizationError,
530527 });
531528
532−export const WsServerGetTraceDiagnosticsRpc = Rpc.make(WS_METHODS.serverGetTraceDiagnostics, {
529+const WsServerGetTraceDiagnosticsRpc = Rpc.make(WS_METHODS.serverGetTraceDiagnostics, {
533530 payload: Schema.Struct({}),
534531 success: ServerTraceDiagnosticsResult,
535532 error: EnvironmentAuthorizationError,
536533 });
537534
538−export const WsServerGetProcessDiagnosticsRpc = Rpc.make(WS_METHODS.serverGetProcessDiagnostics, {
535+const WsServerGetProcessDiagnosticsRpc = Rpc.make(WS_METHODS.serverGetProcessDiagnostics, {
539536 payload: Schema.Struct({}),
540537 success: ServerProcessDiagnosticsResult,
541538 error: EnvironmentAuthorizationError,
542539 });
543540
544−export const WsServerGetProcessResourceHistoryRpc = Rpc.make(
545− WS_METHODS.serverGetProcessResourceHistory,
546− {
547− payload: ServerProcessResourceHistoryInput,
548− success: ServerProcessResourceHistoryResult,
549− error: EnvironmentAuthorizationError,
550− },
551−);
541+const WsServerGetProcessResourceHistoryRpc = Rpc.make(WS_METHODS.serverGetProcessResourceHistory, {
542+ payload: ServerProcessResourceHistoryInput,
543+ success: ServerProcessResourceHistoryResult,
544+ error: EnvironmentAuthorizationError,
545+});
552546
553−export const WsServerGetResourceTelemetryHistoryRpc = Rpc.make(
547+const WsServerGetResourceTelemetryHistoryRpc = Rpc.make(
554548 WS_METHODS.serverGetResourceTelemetryHistory,
555549 {
556550 payload: ResourceTelemetryHistoryInput,
@@ -559,13 +553,13 @@ export const WsServerGetResourceTelemetryHistoryRpc = Rpc.make( · 2 unmodified lines
559553 },
560554 );
561555
562−export const WsServerRetryResourceTelemetryRpc = Rpc.make(WS_METHODS.serverRetryResourceTelemetry, {
556+const WsServerRetryResourceTelemetryRpc = Rpc.make(WS_METHODS.serverRetryResourceTelemetry, {
563557 payload: Schema.Struct({}),
564558 success: ResourceTelemetryRetryResult,
565559 error: EnvironmentAuthorizationError,
566560 });
567561
568−export const WsServerGetUsageSummaryRpc = Rpc.make(WS_METHODS.serverGetUsageSummary, {
562+const WsServerGetUsageSummaryRpc = Rpc.make(WS_METHODS.serverGetUsageSummary, {
569563 payload: UsageSummaryInput,
570564 success: UsageSummary,
571565 error: Schema.Union([EnvironmentAuthorizationError, UsageReadError]),
@@ -575,42 +569,42 @@ export const WsServerGetUsageSummaryRpc = Rpc.make(WS_METHODS.serverGetUsageSumm · 3 unmodified lines
575569 * Refetches the model rate table ahead of its daily TTL, so a model released
576570 * since the last fetch gets priced. The next usage summary uses the new table.
577571 */
578−export const WsServerRefreshUsageRatesRpc = Rpc.make(WS_METHODS.serverRefreshUsageRates, {
572+const WsServerRefreshUsageRatesRpc = Rpc.make(WS_METHODS.serverRefreshUsageRates, {
579573 payload: Schema.Struct({}),
580574 success: UsagePricing,
581575 error: EnvironmentAuthorizationError,
582576 });
583577
584−export const WsServerSignalProcessRpc = Rpc.make(WS_METHODS.serverSignalProcess, {
578+const WsServerSignalProcessRpc = Rpc.make(WS_METHODS.serverSignalProcess, {
585579 payload: ServerSignalProcessInput,
586580 success: ServerSignalProcessResult,
587581 error: EnvironmentAuthorizationError,
588582 });
589583
590−export const WsCloudGetRelayClientStatusRpc = Rpc.make(WS_METHODS.cloudGetRelayClientStatus, {
584+const WsCloudGetRelayClientStatusRpc = Rpc.make(WS_METHODS.cloudGetRelayClientStatus, {
591585 payload: Schema.Struct({}),
592586 success: RelayClientStatusSchema,
593587 error: EnvironmentAuthorizationError,
594588 });
595589
596−export const WsCloudInstallRelayClientRpc = Rpc.make(WS_METHODS.cloudInstallRelayClient, {
590+const WsCloudInstallRelayClientRpc = Rpc.make(WS_METHODS.cloudInstallRelayClient, {
597591 payload: Schema.Struct({}),
598592 success: RelayClientInstallProgressEventSchema,
599593 error: Schema.Union([RelayClientInstallFailedError, EnvironmentAuthorizationError]),
600594 stream: true,
601595 });
602596
603−export const WsServerReportClientActivityRpc = Rpc.make(WS_METHODS.serverReportClientActivity, {
597+const WsServerReportClientActivityRpc = Rpc.make(WS_METHODS.serverReportClientActivity, {
604598 payload: ClientActivityReportInput,
605599 error: EnvironmentAuthorizationError,
606600 });
607601
608−export const WsServerReportHostPowerStateRpc = Rpc.make(WS_METHODS.serverReportHostPowerState, {
602+const WsServerReportHostPowerStateRpc = Rpc.make(WS_METHODS.serverReportHostPowerState, {
609603 payload: HostPowerSnapshot,
610604 error: EnvironmentAuthorizationError,
611605 });
612606
613−export const WsServerGetBackgroundPolicyRpc = Rpc.make(WS_METHODS.serverGetBackgroundPolicy, {
607+const WsServerGetBackgroundPolicyRpc = Rpc.make(WS_METHODS.serverGetBackgroundPolicy, {
614608 payload: Schema.Struct({}),
615609 success: BackgroundPolicySnapshot,
616610 error: EnvironmentAuthorizationError,
@@ -622,7 +616,7 @@ const PullRequestRpcError = Schema.Union([ · 5 unmodified lines
622616 EnvironmentAuthorizationError,
623617 ]);
624618
625−export const WsPullRequestsListRpc = Rpc.make(WS_METHODS.pullRequestsList, {
619+const WsPullRequestsListRpc = Rpc.make(WS_METHODS.pullRequestsList, {
626620 payload: PullRequestListInput,
627621 success: PullRequestListResult,
628622 error: PullRequestRpcError,
@@ -633,214 +627,199 @@ export const WsPullRequestsListRpc = Rpc.make(WS_METHODS.pullRequestsList, { · 4 unmodified lines
633627 * 40-60% of the listing read that answers everything else on the row, so the rows arrive first
634628 * and their stats a moment later.
635629 */
636−export const WsPullRequestsListStatsRpc = Rpc.make(WS_METHODS.pullRequestsListStats, {
630+const WsPullRequestsListStatsRpc = Rpc.make(WS_METHODS.pullRequestsListStats, {
637631 payload: PullRequestListStatsInput,
638632 success: PullRequestListStatsResult,
639633 error: PullRequestRpcError,
640634 });
641635
642−export const WsPullRequestsSummaryRpc = Rpc.make(WS_METHODS.pullRequestsSummary, {
636+const WsPullRequestsSummaryRpc = Rpc.make(WS_METHODS.pullRequestsSummary, {
643637 payload: PullRequestRef,
644638 success: PullRequestSummary,
645639 error: PullRequestRpcError,
646640 });
647641
648−export const WsPullRequestsDetailRpc = Rpc.make(WS_METHODS.pullRequestsDetail, {
642+const WsPullRequestsDetailRpc = Rpc.make(WS_METHODS.pullRequestsDetail, {
649643 payload: PullRequestRef,
650644 success: PullRequestDetail,
651645 error: PullRequestRpcError,
652646 });
653647
654−export const WsPullRequestsActivityRpc = Rpc.make(WS_METHODS.pullRequestsActivity, {
648+const WsPullRequestsActivityRpc = Rpc.make(WS_METHODS.pullRequestsActivity, {
655649 payload: PullRequestRef,
656650 success: PullRequestActivity,
657651 error: PullRequestRpcError,
658652 });
659653
660−export const WsPullRequestsThreadCommentsRpc = Rpc.make(WS_METHODS.pullRequestsThreadComments, {
654+const WsPullRequestsThreadCommentsRpc = Rpc.make(WS_METHODS.pullRequestsThreadComments, {
661655 payload: PullRequestThreadCommentsInput,
662656 success: PullRequestThreadCommentsResult,
663657 error: PullRequestRpcError,
664658 });
665659
666−export const WsPullRequestsDiffFileContentsRpc = Rpc.make(WS_METHODS.pullRequestsDiffFileContents, {
660+const WsPullRequestsDiffFileContentsRpc = Rpc.make(WS_METHODS.pullRequestsDiffFileContents, {
667661 payload: PullRequestDiffFileContentsInput,
668662 success: PullRequestDiffFileContentsResult,
669663 error: PullRequestRpcError,
670664 });
671665
672−export const WsPullRequestsRunActionRpc = Rpc.make(WS_METHODS.pullRequestsRunAction, {
666+const WsPullRequestsRunActionRpc = Rpc.make(WS_METHODS.pullRequestsRunAction, {
673667 payload: PullRequestActionInput,
674668 success: Schema.Void,
675669 error: PullRequestRpcError,
676670 });
677671
678−export const WsPullRequestsUpdateRpc = Rpc.make(WS_METHODS.pullRequestsUpdate, {
672+const WsPullRequestsUpdateRpc = Rpc.make(WS_METHODS.pullRequestsUpdate, {
679673 payload: PullRequestUpdateInput,
680674 success: Schema.Void,
681675 error: PullRequestRpcError,
682676 });
683677
684−export const WsPullRequestsCommentRpc = Rpc.make(WS_METHODS.pullRequestsComment, {
678+const WsPullRequestsCommentRpc = Rpc.make(WS_METHODS.pullRequestsComment, {
685679 payload: PullRequestCommentInput,
686680 success: Schema.Void,
687681 error: PullRequestRpcError,
688682 });
689683
690−export const WsPullRequestsUpdateCommentRpc = Rpc.make(WS_METHODS.pullRequestsUpdateComment, {
684+const WsPullRequestsUpdateCommentRpc = Rpc.make(WS_METHODS.pullRequestsUpdateComment, {
691685 payload: PullRequestCommentUpdateInput,
692686 success: Schema.Void,
693687 error: PullRequestRpcError,
694688 });
695689
696−export const WsPullRequestsSubmitReviewRpc = Rpc.make(WS_METHODS.pullRequestsSubmitReview, {
690+const WsPullRequestsSubmitReviewRpc = Rpc.make(WS_METHODS.pullRequestsSubmitReview, {
697691 payload: PullRequestSubmitReviewInput,
698692 success: Schema.Void,
699693 error: PullRequestRpcError,
700694 });
701695
702−export const WsPullRequestsReplyToThreadRpc = Rpc.make(WS_METHODS.pullRequestsReplyToThread, {
696+const WsPullRequestsReplyToThreadRpc = Rpc.make(WS_METHODS.pullRequestsReplyToThread, {
703697 payload: PullRequestThreadReplyInput,
704698 success: Schema.Void,
705699 error: PullRequestRpcError,
706700 });
707701
708−export const WsPullRequestsSetThreadResolutionRpc = Rpc.make(
709− WS_METHODS.pullRequestsSetThreadResolution,
710− {
711− payload: PullRequestThreadResolutionInput,
712− success: Schema.Void,
713− error: PullRequestRpcError,
714− },
715−);
702+const WsPullRequestsSetThreadResolutionRpc = Rpc.make(WS_METHODS.pullRequestsSetThreadResolution, {
703+ payload: PullRequestThreadResolutionInput,
704+ success: Schema.Void,
705+ error: PullRequestRpcError,
706+});
716707
717−export const WsPullRequestsSetReactionRpc = Rpc.make(WS_METHODS.pullRequestsSetReaction, {
708+const WsPullRequestsSetReactionRpc = Rpc.make(WS_METHODS.pullRequestsSetReaction, {
718709 payload: PullRequestReactionInput,
719710 success: Schema.Void,
720711 error: PullRequestRpcError,
721712 });
722713
723−export const WsPullRequestsInvalidateRpc = Rpc.make(WS_METHODS.pullRequestsInvalidate, {
714+const WsPullRequestsInvalidateRpc = Rpc.make(WS_METHODS.pullRequestsInvalidate, {
724715 payload: PullRequestInvalidateInput,
725716 success: Schema.Void,
726717 error: PullRequestRpcError,
727718 });
728719
729−export const WsPullRequestsSubscribeRefreshesRpc = Rpc.make(
730− WS_METHODS.pullRequestsSubscribeRefreshes,
731− {
732− payload: Schema.Struct({}),
733− success: NonNegativeInt,
734− error: EnvironmentAuthorizationError,
735− stream: true,
736− },
737−);
720+const WsPullRequestsSubscribeRefreshesRpc = Rpc.make(WS_METHODS.pullRequestsSubscribeRefreshes, {
721+ payload: Schema.Struct({}),
722+ success: NonNegativeInt,
723+ error: EnvironmentAuthorizationError,
724+ stream: true,
725+});
738726
739727 /**
740728 * Read on its own rather than as part of the detail: the people who may be asked are only wanted
741729 * once somebody opens the menu, and reading them with every change request would spend a request
742730 * per host on a list nobody looked at.
743731 */
744−export const WsPullRequestsReviewerCandidatesRpc = Rpc.make(
745− WS_METHODS.pullRequestsReviewerCandidates,
746− {
747− payload: PullRequestRef,
748− success: PullRequestReviewerCandidateList,
749− error: PullRequestRpcError,
750− },
751−);
732+const WsPullRequestsReviewerCandidatesRpc = Rpc.make(WS_METHODS.pullRequestsReviewerCandidates, {
733+ payload: PullRequestRef,
734+ success: PullRequestReviewerCandidateList,
735+ error: PullRequestRpcError,
736+});
752737
753−export const WsPullRequestsRequestReviewersRpc = Rpc.make(WS_METHODS.pullRequestsRequestReviewers, {
738+const WsPullRequestsRequestReviewersRpc = Rpc.make(WS_METHODS.pullRequestsRequestReviewers, {
754739 payload: PullRequestReviewerRequestInput,
755740 success: Schema.Void,
756741 error: PullRequestRpcError,
757742 });
758743
759744 /** Read when the label menu opens, for the same reason the reviewer candidates are. */
760−export const WsPullRequestsLabelCandidatesRpc = Rpc.make(WS_METHODS.pullRequestsLabelCandidates, {
745+const WsPullRequestsLabelCandidatesRpc = Rpc.make(WS_METHODS.pullRequestsLabelCandidates, {
761746 payload: PullRequestRef,
762747 success: PullRequestLabelCandidateList,
763748 error: PullRequestRpcError,
764749 });
765750
766−export const WsPullRequestsSetLabelsRpc = Rpc.make(WS_METHODS.pullRequestsSetLabels, {
751+const WsPullRequestsSetLabelsRpc = Rpc.make(WS_METHODS.pullRequestsSetLabels, {
767752 payload: PullRequestLabelChangeInput,
768753 success: Schema.Void,
769754 error: PullRequestRpcError,
770755 });
771756
772−export const WsSourceControlLookupRepositoryRpc = Rpc.make(
773− WS_METHODS.sourceControlLookupRepository,
774− {
775− payload: SourceControlRepositoryLookupInput,
776− success: SourceControlRepositoryInfo,
777− error: Schema.Union([SourceControlRepositoryError, EnvironmentAuthorizationError]),
778− },
779−);
757+const WsSourceControlLookupRepositoryRpc = Rpc.make(WS_METHODS.sourceControlLookupRepository, {
758+ payload: SourceControlRepositoryLookupInput,
759+ success: SourceControlRepositoryInfo,
760+ error: Schema.Union([SourceControlRepositoryError, EnvironmentAuthorizationError]),
761+});
780762
781−export const WsSourceControlCloneRepositoryRpc = Rpc.make(WS_METHODS.sourceControlCloneRepository, {
763+const WsSourceControlCloneRepositoryRpc = Rpc.make(WS_METHODS.sourceControlCloneRepository, {
782764 payload: SourceControlCloneRepositoryInput,
783765 success: SourceControlCloneRepositoryResult,
784766 error: Schema.Union([SourceControlRepositoryError, EnvironmentAuthorizationError]),
785767 });
786768
787−export const WsSourceControlPublishRepositoryRpc = Rpc.make(
788− WS_METHODS.sourceControlPublishRepository,
789− {
790− payload: SourceControlPublishRepositoryInput,
791− success: SourceControlPublishRepositoryResult,
792− error: Schema.Union([SourceControlRepositoryError, EnvironmentAuthorizationError]),
793− },
794−);
769+const WsSourceControlPublishRepositoryRpc = Rpc.make(WS_METHODS.sourceControlPublishRepository, {
770+ payload: SourceControlPublishRepositoryInput,
771+ success: SourceControlPublishRepositoryResult,
772+ error: Schema.Union([SourceControlRepositoryError, EnvironmentAuthorizationError]),
773+});
795774
796−export const WsProjectsSearchEntriesRpc = Rpc.make(WS_METHODS.projectsSearchEntries, {
775+const WsProjectsSearchEntriesRpc = Rpc.make(WS_METHODS.projectsSearchEntries, {
797776 payload: ProjectSearchEntriesInput,
798777 success: ProjectSearchEntriesResult,
799778 error: Schema.Union([ProjectSearchEntriesError, EnvironmentAuthorizationError]),
800779 });
801780
802−export const WsProjectsSearchContentsRpc = Rpc.make(WS_METHODS.projectsSearchContents, {
781+const WsProjectsSearchContentsRpc = Rpc.make(WS_METHODS.projectsSearchContents, {
803782 payload: ProjectSearchContentsInput,
804783 success: ProjectSearchContentsResult,
805784 error: Schema.Union([ProjectSearchContentsError, EnvironmentAuthorizationError]),
806785 });
807786
808−export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries, {
787+const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries, {
809788 payload: ProjectListEntriesInput,
810789 success: ProjectListEntriesResult,
811790 error: Schema.Union([ProjectListEntriesError, EnvironmentAuthorizationError]),
812791 });
813792
814−export const WsProjectsReadFileRpc = Rpc.make(WS_METHODS.projectsReadFile, {
793+const WsProjectsReadFileRpc = Rpc.make(WS_METHODS.projectsReadFile, {
815794 payload: ProjectReadFileInput,
816795 success: ProjectReadFileResult,
817796 error: Schema.Union([ProjectReadFileError, EnvironmentAuthorizationError]),
818797 });
819798
820−export const WsProjectsWriteFileRpc = Rpc.make(WS_METHODS.projectsWriteFile, {
799+const WsProjectsWriteFileRpc = Rpc.make(WS_METHODS.projectsWriteFile, {
821800 payload: ProjectWriteFileInput,
822801 success: ProjectWriteFileResult,
823802 error: Schema.Union([ProjectWriteFileError, EnvironmentAuthorizationError]),
824803 });
825804
826−export const WsShellOpenInEditorRpc = Rpc.make(WS_METHODS.shellOpenInEditor, {
805+const WsShellOpenInEditorRpc = Rpc.make(WS_METHODS.shellOpenInEditor, {
827806 payload: LaunchEditorInput,
828807 error: Schema.Union([ExternalLauncherError, EnvironmentAuthorizationError]),
829808 });
830809
831−export const WsFilesystemBrowseRpc = Rpc.make(WS_METHODS.filesystemBrowse, {
810+const WsFilesystemBrowseRpc = Rpc.make(WS_METHODS.filesystemBrowse, {
832811 payload: FilesystemBrowseInput,
833812 success: FilesystemBrowseResult,
834813 error: Schema.Union([FilesystemBrowseError, EnvironmentAuthorizationError]),
835814 });
836815
837−export const WsAgentSessionsScanRpc = Rpc.make(WS_METHODS.agentSessionsScan, {
816+const WsAgentSessionsScanRpc = Rpc.make(WS_METHODS.agentSessionsScan, {
838817 payload: AgentSessionScanInput,
839818 success: AgentSessionScanResult,
840819 error: Schema.Union([AgentSessionScanError, EnvironmentAuthorizationError]),
841820 });
842821
843−export const WsAgentSessionsImportRpc = Rpc.make(WS_METHODS.agentSessionsImport, {
822+const WsAgentSessionsImportRpc = Rpc.make(WS_METHODS.agentSessionsImport, {
844823 payload: AgentSessionImportInput,
845824 success: AgentSessionImportResult,
846825 error: Schema.Union([
@@ -851,97 +830,97 @@ export const WsAgentSessionsImportRpc = Rpc.make(WS_METHODS.agentSessionsImport, · 4 unmodified lines
851830 ]),
852831 });
853832
854−export const WsAssetsCreateUrlRpc = Rpc.make(WS_METHODS.assetsCreateUrl, {
833+const WsAssetsCreateUrlRpc = Rpc.make(WS_METHODS.assetsCreateUrl, {
855834 payload: AssetCreateUrlInput,
856835 success: AssetCreateUrlResult,
857836 error: Schema.Union([AssetAccessError, EnvironmentAuthorizationError]),
858837 });
859838
860−export const WsAttachmentsCreateUploadUrlRpc = Rpc.make(WS_METHODS.attachmentsCreateUploadUrl, {
839+const WsAttachmentsCreateUploadUrlRpc = Rpc.make(WS_METHODS.attachmentsCreateUploadUrl, {
861840 payload: AttachmentCreateUploadUrlInput,
862841 success: AttachmentCreateUploadUrlResult,
863842 error: Schema.Union([AttachmentUploadSigningKeyError, EnvironmentAuthorizationError]),
864843 });
865844
866−export const WsAttachmentsDeleteRpc = Rpc.make(WS_METHODS.attachmentsDelete, {
845+const WsAttachmentsDeleteRpc = Rpc.make(WS_METHODS.attachmentsDelete, {
867846 payload: AttachmentDeleteInput,
868847 error: EnvironmentAuthorizationError,
869848 });
870849
871−export const WsProviderUploadFeedbackRpc = Rpc.make(WS_METHODS.providerUploadFeedback, {
850+const WsProviderUploadFeedbackRpc = Rpc.make(WS_METHODS.providerUploadFeedback, {
872851 payload: ProviderUploadFeedbackInput,
873852 success: ProviderUploadFeedbackResult,
874853 error: Schema.Union([ProviderUploadFeedbackError, EnvironmentAuthorizationError]),
875854 });
876855
877−export const WsSubscribeVcsStatusRpc = Rpc.make(WS_METHODS.subscribeVcsStatus, {
856+const WsSubscribeVcsStatusRpc = Rpc.make(WS_METHODS.subscribeVcsStatus, {
878857 payload: VcsStatusInput,
879858 success: VcsStatusStreamEvent,
880859 error: Schema.Union([GitManagerServiceError, EnvironmentAuthorizationError]),
881860 stream: true,
882861 });
883862
884−export const WsVcsPullRpc = Rpc.make(WS_METHODS.vcsPull, {
863+const WsVcsPullRpc = Rpc.make(WS_METHODS.vcsPull, {
885864 payload: VcsPullInput,
886865 success: VcsPullResult,
887866 error: Schema.Union([GitCommandError, EnvironmentAuthorizationError]),
888867 });
889868
890−export const WsVcsRefreshStatusRpc = Rpc.make(WS_METHODS.vcsRefreshStatus, {
869+const WsVcsRefreshStatusRpc = Rpc.make(WS_METHODS.vcsRefreshStatus, {
891870 payload: VcsStatusInput,
892871 success: VcsStatusResult,
893872 error: Schema.Union([GitManagerServiceError, EnvironmentAuthorizationError]),
894873 });
895874
896−export const WsGitRunStackedActionRpc = Rpc.make(WS_METHODS.gitRunStackedAction, {
875+const WsGitRunStackedActionRpc = Rpc.make(WS_METHODS.gitRunStackedAction, {
897876 payload: GitRunStackedActionInput,
898877 success: GitActionProgressEvent,
899878 error: Schema.Union([GitManagerServiceError, EnvironmentAuthorizationError]),
900879 stream: true,
901880 });
902881
903−export const WsGitResolvePullRequestRpc = Rpc.make(WS_METHODS.gitResolvePullRequest, {
882+const WsGitResolvePullRequestRpc = Rpc.make(WS_METHODS.gitResolvePullRequest, {
904883 payload: GitPullRequestRefInput,
905884 success: GitResolvePullRequestResult,
906885 error: Schema.Union([GitManagerServiceError, EnvironmentAuthorizationError]),
907886 });
908887
909−export const WsGitPreparePullRequestThreadRpc = Rpc.make(WS_METHODS.gitPreparePullRequestThread, {
888+const WsGitPreparePullRequestThreadRpc = Rpc.make(WS_METHODS.gitPreparePullRequestThread, {
910889 payload: GitPreparePullRequestThreadInput,
911890 success: GitPreparePullRequestThreadResult,
912891 error: Schema.Union([GitManagerServiceError, EnvironmentAuthorizationError]),
913892 });
914893
915−export const WsVcsListRefsRpc = Rpc.make(WS_METHODS.vcsListRefs, {
894+const WsVcsListRefsRpc = Rpc.make(WS_METHODS.vcsListRefs, {
916895 payload: VcsListRefsInput,
917896 success: VcsListRefsResult,
918897 error: Schema.Union([GitCommandError, EnvironmentAuthorizationError]),
919898 });
920899
921−export const WsVcsCreateWorktreeRpc = Rpc.make(WS_METHODS.vcsCreateWorktree, {
900+const WsVcsCreateWorktreeRpc = Rpc.make(WS_METHODS.vcsCreateWorktree, {
922901 payload: VcsCreateWorktreeInput,
923902 success: VcsCreateWorktreeResult,
924903 error: Schema.Union([GitCommandError, EnvironmentAuthorizationError]),
925904 });
926905
927−export const WsVcsRemoveWorktreeRpc = Rpc.make(WS_METHODS.vcsRemoveWorktree, {
906+const WsVcsRemoveWorktreeRpc = Rpc.make(WS_METHODS.vcsRemoveWorktree, {
928907 payload: VcsRemoveWorktreeInput,
929908 error: Schema.Union([GitCommandError, EnvironmentAuthorizationError]),
930909 });
931910
932−export const WsVcsCreateRefRpc = Rpc.make(WS_METHODS.vcsCreateRef, {
911+const WsVcsCreateRefRpc = Rpc.make(WS_METHODS.vcsCreateRef, {
933912 payload: VcsCreateRefInput,
934913 success: VcsCreateRefResult,
935914 error: Schema.Union([GitCommandError, EnvironmentAuthorizationError]),
936915 });
937916
938−export const WsVcsSwitchRefRpc = Rpc.make(WS_METHODS.vcsSwitchRef, {
917+const WsVcsSwitchRefRpc = Rpc.make(WS_METHODS.vcsSwitchRef, {
939918 payload: VcsSwitchRefInput,
940919 success: VcsSwitchRefResult,
941920 error: Schema.Union([GitCommandError, EnvironmentAuthorizationError]),
942921 });
943922
944−export const WsVcsInitRpc = Rpc.make(WS_METHODS.vcsInit, {
923+const WsVcsInitRpc = Rpc.make(WS_METHODS.vcsInit, {
945924 payload: VcsInitInput,
946925 error: Schema.Union([VcsError, EnvironmentAuthorizationError]),
947926 });
@@ -951,172 +930,160 @@ export const WsVcsInitRpc = Rpc.make(WS_METHODS.vcsInit, { · 3 unmodified lines
951930 * Not the persisted T3 Review model. Future review sessions should use
952931 * review.open* + review.getSnapshot.
953932 */
954−export const WsReviewGetDiffPreviewRpc = Rpc.make(WS_METHODS.reviewGetDiffPreview, {
933+const WsReviewGetDiffPreviewRpc = Rpc.make(WS_METHODS.reviewGetDiffPreview, {
955934 payload: ReviewDiffPreviewInput,
956935 success: ReviewDiffPreviewResult,
957936 error: Schema.Union([ReviewDiffPreviewError, EnvironmentAuthorizationError]),
958937 });
959938
960−export const WsReviewGetDiffFileContentsRpc = Rpc.make(WS_METHODS.reviewGetDiffFileContents, {
939+const WsReviewGetDiffFileContentsRpc = Rpc.make(WS_METHODS.reviewGetDiffFileContents, {
961940 payload: ReviewDiffFileContentsInput,
962941 success: ReviewDiffFileContentsResult,
963942 error: Schema.Union([ReviewDiffPreviewError, EnvironmentAuthorizationError]),
964943 });
965944
966−export const WsTerminalOpenRpc = Rpc.make(WS_METHODS.terminalOpen, {
945+const WsTerminalOpenRpc = Rpc.make(WS_METHODS.terminalOpen, {
967946 payload: TerminalOpenInput,
968947 success: TerminalSessionSnapshot,
969948 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
970949 });
971950
972−export const WsTerminalAttachRpc = Rpc.make(WS_METHODS.terminalAttach, {
951+const WsTerminalAttachRpc = Rpc.make(WS_METHODS.terminalAttach, {
973952 payload: TerminalAttachInput,
974953 success: TerminalAttachStreamEvent,
975954 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
976955 stream: true,
977956 });
978957
979−export const WsTerminalWriteRpc = Rpc.make(WS_METHODS.terminalWrite, {
958+const WsTerminalWriteRpc = Rpc.make(WS_METHODS.terminalWrite, {
980959 payload: TerminalWriteInput,
981960 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
982961 });
983962
984−export const WsTerminalResizeRpc = Rpc.make(WS_METHODS.terminalResize, {
963+const WsTerminalResizeRpc = Rpc.make(WS_METHODS.terminalResize, {
985964 payload: TerminalResizeInput,
986965 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
987966 });
988967
989−export const WsTerminalClearRpc = Rpc.make(WS_METHODS.terminalClear, {
968+const WsTerminalClearRpc = Rpc.make(WS_METHODS.terminalClear, {
990969 payload: TerminalClearInput,
991970 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
992971 });
993972
994−export const WsTerminalRestartRpc = Rpc.make(WS_METHODS.terminalRestart, {
973+const WsTerminalRestartRpc = Rpc.make(WS_METHODS.terminalRestart, {
995974 payload: TerminalRestartInput,
996975 success: TerminalSessionSnapshot,
997976 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
998977 });
999978
1000−export const WsTerminalCloseRpc = Rpc.make(WS_METHODS.terminalClose, {
979+const WsTerminalCloseRpc = Rpc.make(WS_METHODS.terminalClose, {
1001980 payload: TerminalCloseInput,
1002981 error: Schema.Union([TerminalError, EnvironmentAuthorizationError]),
1003982 });
1004983
1005−export const WsPreviewOpenRpc = Rpc.make(WS_METHODS.previewOpen, {
984+const WsPreviewOpenRpc = Rpc.make(WS_METHODS.previewOpen, {
1006985 payload: PreviewOpenInput,
1007986 success: PreviewSessionSnapshot,
1008987 error: Schema.Union([PreviewError, EnvironmentAuthorizationError]),
1009988 });
1010989
1011−export const WsPreviewNavigateRpc = Rpc.make(WS_METHODS.previewNavigate, {
990+const WsPreviewNavigateRpc = Rpc.make(WS_METHODS.previewNavigate, {
1012991 payload: PreviewNavigateInput,
1013992 success: PreviewSessionSnapshot,
1014993 error: Schema.Union([PreviewError, EnvironmentAuthorizationError]),
1015994 });
1016995
1017−export const WsPreviewResizeRpc = Rpc.make(WS_METHODS.previewResize, {
996+const WsPreviewResizeRpc = Rpc.make(WS_METHODS.previewResize, {
1018997 payload: PreviewResizeInput,
1019998 success: PreviewSessionSnapshot,
1020999 error: Schema.Union([PreviewError, EnvironmentAuthorizationError]),
10211000 });
10221001
1023−export const WsPreviewRefreshRpc = Rpc.make(WS_METHODS.previewRefresh, {
1002+const WsPreviewRefreshRpc = Rpc.make(WS_METHODS.previewRefresh, {
10241003 payload: PreviewRefreshInput,
10251004 error: Schema.Union([PreviewError, EnvironmentAuthorizationError]),
10261005 });
10271006
1028−export const WsPreviewCloseRpc = Rpc.make(WS_METHODS.previewClose, {
1007+const WsPreviewCloseRpc = Rpc.make(WS_METHODS.previewClose, {
10291008 payload: PreviewCloseInput,
10301009 error: Schema.Union([PreviewError, EnvironmentAuthorizationError]),
10311010 });
10321011
1033−export const WsPreviewListRpc = Rpc.make(WS_METHODS.previewList, {
1012+const WsPreviewListRpc = Rpc.make(WS_METHODS.previewList, {
10341013 payload: PreviewListInput,
10351014 success: PreviewListResult,
10361015 error: EnvironmentAuthorizationError,
10371016 });
10381017
1039−export const WsPreviewReportStatusRpc = Rpc.make(WS_METHODS.previewReportStatus, {
1018+const WsPreviewReportStatusRpc = Rpc.make(WS_METHODS.previewReportStatus, {
10401019 payload: PreviewReportStatusInput,
10411020 error: Schema.Union([PreviewError, EnvironmentAuthorizationError]),
10421021 });
10431022
1044−export const WsPreviewAutomationConnectRpc = Rpc.make(WS_METHODS.previewAutomationConnect, {
1023+const WsPreviewAutomationConnectRpc = Rpc.make(WS_METHODS.previewAutomationConnect, {
10451024 payload: PreviewAutomationHost,
10461025 success: PreviewAutomationStreamEvent,
10471026 error: Schema.Union([PreviewAutomationError, EnvironmentAuthorizationError]),
10481027 stream: true,
10491028 });
10501029
1051−export const WsPreviewAutomationRespondRpc = Rpc.make(WS_METHODS.previewAutomationRespond, {
1030+const WsPreviewAutomationRespondRpc = Rpc.make(WS_METHODS.previewAutomationRespond, {
10521031 payload: PreviewAutomationResponse,
10531032 error: Schema.Union([PreviewAutomationError, EnvironmentAuthorizationError]),
10541033 });
10551034
1056−export const WsPreviewAutomationFocusHostRpc = Rpc.make(WS_METHODS.previewAutomationFocusHost, {
1035+const WsPreviewAutomationFocusHostRpc = Rpc.make(WS_METHODS.previewAutomationFocusHost, {
10571036 payload: PreviewAutomationHostFocus,
10581037 error: EnvironmentAuthorizationError,
10591038 });
10601039
1061−export const WsSubscribePreviewEventsRpc = Rpc.make(WS_METHODS.subscribePreviewEvents, {
1040+const WsSubscribePreviewEventsRpc = Rpc.make(WS_METHODS.subscribePreviewEvents, {
10621041 payload: Schema.Struct({}),
10631042 success: PreviewEvent,
10641043 error: EnvironmentAuthorizationError,
10651044 stream: true,
10661045 });
10671046
1068−export const WsSubscribeDiscoveredLocalServersRpc = Rpc.make(
1069− WS_METHODS.subscribeDiscoveredLocalServers,
1070− {
1071− payload: Schema.Struct({
1072− configuredUrls: Schema.optional(ConfiguredLocalServerUrls),
1073− }),
1074− success: DiscoveredLocalServerList,
1075− error: EnvironmentAuthorizationError,
1076− stream: true,
1077− },
1078−);
1047+const WsSubscribeDiscoveredLocalServersRpc = Rpc.make(WS_METHODS.subscribeDiscoveredLocalServers, {
1048+ payload: Schema.Struct({
1049+ configuredUrls: Schema.optional(ConfiguredLocalServerUrls),
1050+ }),
1051+ success: DiscoveredLocalServerList,
1052+ error: EnvironmentAuthorizationError,
1053+ stream: true,
1054+});
10791055
1080−export const WsOrchestrationDispatchCommandRpc = Rpc.make(
1081− ORCHESTRATION_WS_METHODS.dispatchCommand,
1082− {
1083− payload: ClientOrchestrationCommand,
1084− success: OrchestrationRpcSchemas.dispatchCommand.output,
1085− error: Schema.Union([OrchestrationDispatchCommandError, EnvironmentAuthorizationError]),
1086− },
1087−);
1056+const WsOrchestrationDispatchCommandRpc = Rpc.make(ORCHESTRATION_WS_METHODS.dispatchCommand, {
1057+ payload: ClientOrchestrationCommand,
1058+ success: OrchestrationRpcSchemas.dispatchCommand.output,
1059+ error: Schema.Union([OrchestrationDispatchCommandError, EnvironmentAuthorizationError]),
1060+});
10881061
1089−export const WsOrchestrationGetWorkflowScriptRpc = Rpc.make(
1090− ORCHESTRATION_WS_METHODS.getWorkflowScript,
1091− {
1092− payload: OrchestrationRpcSchemas.getWorkflowScript.input,
1093− success: OrchestrationRpcSchemas.getWorkflowScript.output,
1094− error: Schema.Union([OrchestrationGetWorkflowScriptError, EnvironmentAuthorizationError]),
1095− },
1096−);
1062+const WsOrchestrationGetWorkflowScriptRpc = Rpc.make(ORCHESTRATION_WS_METHODS.getWorkflowScript, {
1063+ payload: OrchestrationRpcSchemas.getWorkflowScript.input,
1064+ success: OrchestrationRpcSchemas.getWorkflowScript.output,
1065+ error: Schema.Union([OrchestrationGetWorkflowScriptError, EnvironmentAuthorizationError]),
1066+});
10971067
1098−export const WsOrchestrationGetTurnDiffRpc = Rpc.make(ORCHESTRATION_WS_METHODS.getTurnDiff, {
1068+const WsOrchestrationGetTurnDiffRpc = Rpc.make(ORCHESTRATION_WS_METHODS.getTurnDiff, {
10991069 payload: OrchestrationGetTurnDiffInput,
11001070 success: OrchestrationRpcSchemas.getTurnDiff.output,
11011071 error: Schema.Union([OrchestrationGetTurnDiffError, EnvironmentAuthorizationError]),
11021072 });
11031073
1104−export const WsOrchestrationGetFullThreadDiffRpc = Rpc.make(
1105− ORCHESTRATION_WS_METHODS.getFullThreadDiff,
1106− {
1107− payload: OrchestrationGetFullThreadDiffInput,
1108− success: OrchestrationRpcSchemas.getFullThreadDiff.output,
1109− error: Schema.Union([OrchestrationGetFullThreadDiffError, EnvironmentAuthorizationError]),
1110− },
1111−);
1074+const WsOrchestrationGetFullThreadDiffRpc = Rpc.make(ORCHESTRATION_WS_METHODS.getFullThreadDiff, {
1075+ payload: OrchestrationGetFullThreadDiffInput,
1076+ success: OrchestrationRpcSchemas.getFullThreadDiff.output,
1077+ error: Schema.Union([OrchestrationGetFullThreadDiffError, EnvironmentAuthorizationError]),
1078+});
11121079
1113−export const WsOrchestrationSearchThreadsRpc = Rpc.make(ORCHESTRATION_WS_METHODS.searchThreads, {
1080+const WsOrchestrationSearchThreadsRpc = Rpc.make(ORCHESTRATION_WS_METHODS.searchThreads, {
11141081 payload: OrchestrationSearchThreadsInput,
11151082 success: OrchestrationRpcSchemas.searchThreads.output,
11161083 error: Schema.Union([OrchestrationSearchThreadsError, EnvironmentAuthorizationError]),
11171084 });
11181085
1119−export const WsOrchestrationGetArchivedShellSnapshotRpc = Rpc.make(
1086+const WsOrchestrationGetArchivedShellSnapshotRpc = Rpc.make(
11201087 ORCHESTRATION_WS_METHODS.getArchivedShellSnapshot,
11211088 {
11221089 payload: OrchestrationRpcSchemas.getArchivedShellSnapshot.input,
@@ -1125,31 +1092,28 @@ export const WsOrchestrationGetArchivedShellSnapshotRpc = Rpc.make( · 2 unmodified lines
11251092 },
11261093 );
11271094
1128−export const WsOrchestrationSubscribeShellRpc = Rpc.make(ORCHESTRATION_WS_METHODS.subscribeShell, {
1095+const WsOrchestrationSubscribeShellRpc = Rpc.make(ORCHESTRATION_WS_METHODS.subscribeShell, {
11291096 payload: OrchestrationRpcSchemas.subscribeShell.input,
11301097 success: OrchestrationRpcSchemas.subscribeShell.output,
11311098 error: Schema.Union([OrchestrationGetSnapshotError, EnvironmentAuthorizationError]),
11321099 stream: true,
11331100 });
11341101
1135−export const WsOrchestrationSubscribeThreadRpc = Rpc.make(
1136− ORCHESTRATION_WS_METHODS.subscribeThread,
1137− {
1138− payload: OrchestrationRpcSchemas.subscribeThread.input,
1139− success: OrchestrationRpcSchemas.subscribeThread.output,
1140− error: Schema.Union([OrchestrationGetSnapshotError, EnvironmentAuthorizationError]),
1141− stream: true,
1142− },
1143−);
1102+const WsOrchestrationSubscribeThreadRpc = Rpc.make(ORCHESTRATION_WS_METHODS.subscribeThread, {
1103+ payload: OrchestrationRpcSchemas.subscribeThread.input,
1104+ success: OrchestrationRpcSchemas.subscribeThread.output,
1105+ error: Schema.Union([OrchestrationGetSnapshotError, EnvironmentAuthorizationError]),
1106+ stream: true,
1107+});
11441108
1145−export const WsSubscribeTerminalEventsRpc = Rpc.make(WS_METHODS.subscribeTerminalEvents, {
1109+const WsSubscribeTerminalEventsRpc = Rpc.make(WS_METHODS.subscribeTerminalEvents, {
11461110 payload: Schema.Struct({}),
11471111 success: TerminalEvent,
11481112 error: EnvironmentAuthorizationError,
11491113 stream: true,
11501114 });
11511115
1152−export const WsSubscribeTerminalMetadataRpc = Rpc.make(WS_METHODS.subscribeTerminalMetadata, {
1116+const WsSubscribeTerminalMetadataRpc = Rpc.make(WS_METHODS.subscribeTerminalMetadata, {
11531117 payload: Schema.Struct({}),
11541118 success: TerminalMetadataStreamEvent,
11551119 error: EnvironmentAuthorizationError,
@@ -1174,28 +1138,28 @@ export const WsSubscribeServerConfigRpc = Rpc.make(WS_METHODS.subscribeServerCon · 18 unmodified lines
11741138 stream: true,
11751139 });
11761140
1177−export const WsSubscribeServerLifecycleRpc = Rpc.make(WS_METHODS.subscribeServerLifecycle, {
1141+const WsSubscribeServerLifecycleRpc = Rpc.make(WS_METHODS.subscribeServerLifecycle, {
11781142 payload: Schema.Struct({}),
11791143 success: ServerLifecycleStreamEvent,
11801144 error: EnvironmentAuthorizationError,
11811145 stream: true,
11821146 });
11831147
1184−export const WsSubscribeAuthAccessRpc = Rpc.make(WS_METHODS.subscribeAuthAccess, {
1148+const WsSubscribeAuthAccessRpc = Rpc.make(WS_METHODS.subscribeAuthAccess, {
11851149 payload: Schema.Struct({}),
11861150 success: AuthAccessStreamEvent,
11871151 error: Schema.Union([AuthAccessStreamError, EnvironmentAuthorizationError]),
11881152 stream: true,
11891153 });
11901154
1191−export const WsSubscribeBackgroundPolicyRpc = Rpc.make(WS_METHODS.subscribeBackgroundPolicy, {
1155+const WsSubscribeBackgroundPolicyRpc = Rpc.make(WS_METHODS.subscribeBackgroundPolicy, {
11921156 payload: Schema.Struct({}),
11931157 success: BackgroundPolicySnapshot,
11941158 error: EnvironmentAuthorizationError,
11951159 stream: true,
11961160 });
11971161
1198−export const WsSubscribeResourceTelemetryRpc = Rpc.make(WS_METHODS.subscribeResourceTelemetry, {
1162+const WsSubscribeResourceTelemetryRpc = Rpc.make(WS_METHODS.subscribeResourceTelemetry, {
11991163 payload: Schema.Struct({}),
12001164 success: ResourceTelemetrySnapshot,
12011165 error: EnvironmentAuthorizationError,