🚀 Big News: Socket Acquires Coana to Bring Reachability Analysis to Every Appsec Team.Learn more

@aws/amazon-q-developer-cli-api-bindings

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@aws/amazon-q-developer-cli-api-bindings - npm Package Compare versions

Comparing version

to
0.2.0

@@ -14,3 +14,3 @@ import { AuthBuilderIdStartDeviceAuthorizationResponse, AuthCancelPkceAuthorizationResponse, AuthStartPkceAuthorizationResponse } from "@aws/amazon-q-developer-cli-proto/fig";

}): Promise<AuthStartPkceAuthorizationResponse>;
export declare function finishPkceAuthorization({ authRequestId, }: AuthFinishPkceAuthorizationRequest): Promise<AuthFinishPkceAuthorizationResponse>;
export declare function finishPkceAuthorization({ authRequestId, }: Omit<AuthFinishPkceAuthorizationRequest, "$typeName">): Promise<AuthFinishPkceAuthorizationResponse>;
export declare function cancelPkceAuthorization(): Promise<AuthCancelPkceAuthorizationResponse>;

@@ -17,0 +17,0 @@ export declare function builderIdStartDeviceAuthorization({ region, startUrl, }?: {

@@ -1,5 +0,4 @@

import { CodewhispererCustomization as Customization } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendCodewhispererListCustomizationRequest } from "./requests.js";
const listCustomizations = async () => (await sendCodewhispererListCustomizationRequest({})).customizations;
export { listCustomizations, Customization };
export { listCustomizations };
//# sourceMappingURL=codewhisperer.js.map

@@ -1,6 +0,6 @@

import { ServerOriginatedMessage, ClientOriginatedMessage } from "@aws/amazon-q-developer-cli-proto/fig";
import { type ServerOriginatedMessage, type ClientOriginatedMessage } from "@aws/amazon-q-developer-cli-proto/fig";
type shouldKeepListening = boolean;
export type APIResponseHandler = (response: ServerOriginatedMessage["submessage"]) => shouldKeepListening | void;
export declare function setHandlerForId(handler: APIResponseHandler, id: number): void;
export declare function sendMessage(message: ClientOriginatedMessage["submessage"], handler?: APIResponseHandler): void;
export declare function setHandlerForId(handler: APIResponseHandler, id: string): void;
export declare function sendMessage(submessage: ClientOriginatedMessage["submessage"], handler?: APIResponseHandler): void;
export {};

@@ -1,3 +0,4 @@

import { ServerOriginatedMessage, ClientOriginatedMessage, } from "@aws/amazon-q-developer-cli-proto/fig";
import { ClientOriginatedMessageSchema, ServerOriginatedMessageSchema, } from "@aws/amazon-q-developer-cli-proto/fig";
import { b64ToBytes, bytesToBase64 } from "./utils.js";
import { create, fromBinary, toBinary } from "@bufbuild/protobuf";
const FigGlobalErrorOccurred = "FigGlobalErrorOccurred";

@@ -14,26 +15,26 @@ const FigProtoMessageReceived = "FigProtoMessageReceived";

}
const handler = handlers[response.id];
const id = response.id.toString();
const handler = handlers[id];
if (!handler) {
return;
}
const keepListeningOnID = handlers[response.id](response.submessage);
const keepListeningOnID = handlers[id](response.submessage);
if (!keepListeningOnID) {
delete handlers[response.id];
delete handlers[id];
}
};
export function sendMessage(message, handler) {
const request = {
id: (messageId += 1),
submessage: message,
};
export function sendMessage(submessage, handler) {
const request = create(ClientOriginatedMessageSchema, {
id: BigInt((messageId += 1)),
submessage,
});
if (handler && request.id) {
handlers[request.id] = handler;
handlers[request.id.toString()] = handler;
}
const buffer = ClientOriginatedMessage.encode(request).finish();
const buffer = toBinary(ClientOriginatedMessageSchema, request);
if (window?.fig?.constants?.supportApiProto &&
window?.fig?.constants?.apiProtoUrl) {
const url = new URL(window.fig.constants.apiProtoUrl);
if (request.submessage?.$case &&
typeof request.submessage?.$case === "string") {
url.pathname = `/${request.submessage.$case}`;
if (typeof request.submessage?.case === "string") {
url.pathname = `/${request.submessage.case}`;
}

@@ -51,4 +52,4 @@ else {

const body = new Uint8Array(await res.arrayBuffer());
const m = ServerOriginatedMessage.decode(body);
receivedMessage(m);
const message = fromBinary(ServerOriginatedMessageSchema, body);
receivedMessage(message);
});

@@ -80,3 +81,3 @@ return;

const bytes = b64ToBytes(raw);
const message = ServerOriginatedMessage.decode(bytes);
const message = fromBinary(ServerOriginatedMessageSchema, bytes);
receivedMessage(message);

@@ -83,0 +84,0 @@ });

@@ -5,5 +5,5 @@ import { NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";

return _subscribe({ type: NotificationType.NOTIFY_ON_EDITBUFFFER_CHANGE }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "editBufferNotification":
return handler(notification.type.editBufferNotification);
return handler(notification.type.value);
default:

@@ -10,0 +10,0 @@ break;

@@ -5,6 +5,5 @@ import { NotificationType } from "@aws/amazon-q-developer-cli-proto/fig";

return _subscribe({ type: NotificationType.NOTIFY_ON_EVENT }, (notification) => {
switch (notification?.type?.$case) {
case "eventNotification":
// eslint-disable-next-line no-case-declarations
const { eventName: name, payload } = notification.type.eventNotification;
switch (notification?.type?.case) {
case "eventNotification": {
const { eventName: name, payload } = notification.type.value;
if (name === eventName) {

@@ -19,2 +18,3 @@ try {

break;
}
default:

@@ -21,0 +21,0 @@ break;

@@ -0,6 +1,11 @@

import { create } from "@bufbuild/protobuf";
import { sendWriteFileRequest, sendReadFileRequest, sendDestinationOfSymbolicLinkRequest, sendContentsOfDirectoryRequest, sendAppendToFileRequest, sendCreateDirectoryRequest, } from "./requests.js";
import { FilePathSchema, } from "@aws/amazon-q-developer-cli-proto/fig";
function filePath(options) {
return create(FilePathSchema, options);
}
export async function write(path, contents) {
return sendWriteFileRequest({
path: { path, expandTildeInPath: true },
data: { $case: "text", text: contents },
path: filePath({ path, expandTildeInPath: true }),
data: { case: "text", value: contents },
});

@@ -10,4 +15,4 @@ }

return sendAppendToFileRequest({
path: { path, expandTildeInPath: true },
data: { $case: "text", text: contents },
path: filePath({ path, expandTildeInPath: true }),
data: { case: "text", value: contents },
});

@@ -17,6 +22,6 @@ }

const response = await sendReadFileRequest({
path: { path, expandTildeInPath: true },
path: filePath({ path, expandTildeInPath: true }),
});
if (response.type?.$case === "text") {
return response.type.text;
if (response.type?.case === "text") {
return response.type.value;
}

@@ -27,3 +32,3 @@ return null;

const response = await sendContentsOfDirectoryRequest({
directory: { path, expandTildeInPath: true },
directory: filePath({ path, expandTildeInPath: true }),
});

@@ -34,3 +39,3 @@ return response.fileNames;

const response = await sendDestinationOfSymbolicLinkRequest({
path: { path, expandTildeInPath: true },
path: filePath({ path, expandTildeInPath: true }),
});

@@ -41,3 +46,3 @@ return response.destination?.path;

return sendCreateDirectoryRequest({
path: { path, expandTildeInPath: true },
path: filePath({ path, expandTildeInPath: true }),
recursive,

@@ -44,0 +49,0 @@ });

@@ -0,43 +1,36 @@

import { HistoryQueryRequest_ParamSchema, } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendHistoryQueryRequest } from "./requests.js";
import { create } from "@bufbuild/protobuf";
import { EmptySchema } from "@aws/amazon-q-developer-cli-proto/fig_common";
function mapParam(param) {
let type;
if (param === null) {
return {
type: {
$case: "null",
null: {},
},
type = {
case: "null",
value: create(EmptySchema),
};
}
if (typeof param === "string") {
return {
type: {
$case: "string",
string: param,
},
};
else if (typeof param === "string") {
type = { case: "string", value: param };
}
if (typeof param === "number" && Number.isInteger(param)) {
return {
type: {
$case: "integer",
integer: param,
},
else if (typeof param === "number" && Number.isInteger(param)) {
type = {
case: "integer",
value: BigInt(param),
};
}
if (typeof param === "number") {
return {
type: {
$case: "float",
float: param,
},
else if (typeof param === "number") {
type = {
case: "float",
value: param,
};
}
if (param instanceof Uint8Array) {
return {
type: {
$case: "blob",
blob: param,
},
else if (param instanceof Uint8Array) {
type = {
case: "blob",
value: param,
};
}
if (type)
return create(HistoryQueryRequest_ParamSchema, { type });
throw new Error("Invalid param type");

@@ -44,0 +37,0 @@ }

@@ -1,35 +0,33 @@

import * as Fig from "@aws/amazon-q-developer-cli-proto/fig";
import * as WindowPosition from "./position.js";
import * as Settings from "./settings.js";
import * as Auth from "./auth.js";
import * as Codewhisperer from "./codewhisperer.js";
import * as EditBufferNotifications from "./editbuffer.js";
import * as PTY from "./pty.js";
import * as Process from "./process.js";
import * as Shell from "./shell.js";
import * as Keybindings from "./keybindings.js";
import * as Event from "./event.js";
import * as Defaults from "./defaults.js";
import * as Telemetry from "./telemetry.js";
import * as Fig from "@aws/amazon-q-developer-cli-proto/fig";
import * as fs from "./filesystem.js";
import * as Config from "./config.js";
import * as History from "./history.js";
import * as Install from "./install.js";
import * as Internal from "./requests.js";
import * as Keybindings from "./keybindings.js";
import * as Native from "./native.js";
import * as Debugger from "./debugger.js";
import * as Platform from "./platform.js";
import * as Process from "./process.js";
import * as Settings from "./settings.js";
import * as Shell from "./shell.js";
import * as State from "./state.js";
import * as Install from "./install.js";
import * as Telemetry from "./telemetry.js";
import * as Types from "./types.js";
import * as User from "./user.js";
import * as History from "./history.js";
import * as Auth from "./auth.js";
import * as Codewhisperer from "./codewhisperer.js";
import * as Platform from "./platform.js";
import * as Internal from "./requests.js";
import * as WindowPosition from "./position.js";
declare const lib: {
Config: typeof Config;
Debugger: typeof Debugger;
Defaults: typeof Defaults;
Auth: typeof Auth;
Codewhisperer: typeof Codewhisperer;
EditBufferNotifications: typeof EditBufferNotifications;
Event: typeof Event;
fs: typeof fs;
History: typeof History;
Install: typeof Install;
Internal: typeof Internal;
Keybindings: typeof Keybindings;
Native: typeof Native;
PTY: typeof PTY;
Platform: typeof Platform;
Process: typeof Process;

@@ -40,13 +38,7 @@ Settings: typeof Settings;

Telemetry: typeof Telemetry;
WindowPosition: typeof WindowPosition;
fs: typeof fs;
Install: typeof Install;
Types: typeof Types;
User: typeof User;
History: typeof History;
Auth: typeof Auth;
Codewhisperer: typeof Codewhisperer;
Platform: typeof Platform;
WindowPosition: typeof WindowPosition;
};
export { Config, Debugger, Defaults, EditBufferNotifications, Event, Fig, fs, History, Install, Internal, Keybindings, Native, Process, PTY, Settings, Shell, State, Telemetry, Types, User, WindowPosition, Auth, Codewhisperer, Platform, };
export { Auth, Codewhisperer, EditBufferNotifications, Event, Fig, fs, History, Install, Internal, Keybindings, Native, Platform, Process, Settings, Shell, State, Telemetry, Types, User, WindowPosition, };
declare global {

@@ -53,0 +45,0 @@ interface Window {

@@ -1,35 +0,33 @@

import * as Fig from "@aws/amazon-q-developer-cli-proto/fig";
import * as WindowPosition from "./position.js";
import * as Settings from "./settings.js";
import * as Auth from "./auth.js";
import * as Codewhisperer from "./codewhisperer.js";
import * as EditBufferNotifications from "./editbuffer.js";
import * as PTY from "./pty.js";
import * as Process from "./process.js";
import * as Shell from "./shell.js";
import * as Keybindings from "./keybindings.js";
import * as Event from "./event.js";
import * as Defaults from "./defaults.js";
import * as Telemetry from "./telemetry.js";
import * as Fig from "@aws/amazon-q-developer-cli-proto/fig";
import * as fs from "./filesystem.js";
import * as Config from "./config.js";
import * as History from "./history.js";
import * as Install from "./install.js";
import * as Internal from "./requests.js";
import * as Keybindings from "./keybindings.js";
import * as Native from "./native.js";
import * as Debugger from "./debugger.js";
import * as Platform from "./platform.js";
import * as Process from "./process.js";
import * as Settings from "./settings.js";
import * as Shell from "./shell.js";
import * as State from "./state.js";
import * as Install from "./install.js";
import * as Telemetry from "./telemetry.js";
import * as Types from "./types.js";
import * as User from "./user.js";
import * as History from "./history.js";
import * as Auth from "./auth.js";
import * as Codewhisperer from "./codewhisperer.js";
import * as Platform from "./platform.js";
import * as Internal from "./requests.js";
import * as WindowPosition from "./position.js";
const lib = {
Config,
Debugger,
Defaults,
Auth,
Codewhisperer,
EditBufferNotifications,
Event,
fs,
History,
Install,
Internal,
Keybindings,
Native,
PTY,
Platform,
Process,

@@ -40,14 +38,8 @@ Settings,

Telemetry,
WindowPosition,
fs,
Install,
Types,
User,
History,
Auth,
Codewhisperer,
Platform,
WindowPosition,
};
export { Config, Debugger, Defaults, EditBufferNotifications, Event, Fig, fs, History, Install, Internal, Keybindings, Native, Process, PTY, Settings, Shell, State, Telemetry, Types, User, WindowPosition, Auth, Codewhisperer, Platform, };
export { Auth, Codewhisperer, EditBufferNotifications, Event, Fig, fs, History, Install, Internal, Keybindings, Native, Platform, Process, Settings, Shell, State, Telemetry, Types, User, WindowPosition, };
window.f = lib;
//# sourceMappingURL=index.js.map

@@ -27,15 +27,15 @@ import { InstallAction, InstallComponent, InstallResponse_InstallationStatus, NotificationType, Result_Result, } from "@aws/amazon-q-developer-cli-proto/fig";

function handleBasicResponse(response) {
switch (response.response?.$case) {
switch (response.response?.case) {
case "result":
if (response.response.result.result === Result_Result.OK) {
if (response.response.value.result === Result_Result.OK) {
return;
}
if (response.response.result.result === Result_Result.ERROR) {
throw Error(response.response.result.error);
if (response.response.value.result === Result_Result.ERROR) {
throw Error(response.response.value.error);
}
else {
throw Error(`Unexpected result: ${response.response.result.result}`);
throw Error(`Unexpected result: ${response.response.value.result}`);
}
default:
throw Error(`Unexpected result: ${response.response?.$case}`);
throw Error(`Unexpected result: ${response.response?.case}`);
}

@@ -62,15 +62,14 @@ }

});
switch (response.response?.$case) {
switch (response.response?.case) {
case "installationStatus":
if (response.response.installationStatus ===
InstallResponse_InstallationStatus.INSTALLED) {
if (response.response.value === InstallResponse_InstallationStatus.INSTALLED) {
return true;
}
if (response.response.installationStatus ===
if (response.response.value ===
InstallResponse_InstallationStatus.NOT_INSTALLED) {
return false;
}
throw Error(`Unexpected result: ${response.response.installationStatus}`);
throw Error(`Unexpected result: ${response.response.value}`);
default:
throw Error(`Unexpected result: ${response.response?.$case}`);
throw Error(`Unexpected result: ${response.response?.case}`);
}

@@ -82,5 +81,5 @@ }

return _subscribe({ type: NotificationType.NOTIFY_ON_ACCESSIBILITY_CHANGE }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "accessibilityChangeNotification":
return handler(notification.type.accessibilityChangeNotification.enabled);
return handler(notification.type.value.enabled);
default:

@@ -87,0 +86,0 @@ break;

import { Action, KeybindingPressedNotification } from "@aws/amazon-q-developer-cli-proto/fig";
import { NotificationResponse } from "./notifications.js";
export declare function pressed(handler: (notification: KeybindingPressedNotification) => NotificationResponse | undefined): Promise<import("./notifications.js").Subscription> | undefined;
export declare function setInterceptKeystrokes(actions: Action[], intercept: boolean, globalIntercept?: boolean, currentTerminalSessionId?: string): void;
export declare function setInterceptKeystrokes(actions: Omit<Action, "$typeName">[], intercept: boolean, globalIntercept?: boolean, currentTerminalSessionId?: string): void;

@@ -1,9 +0,10 @@

import { NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";
import { ActionListSchema, NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendUpdateApplicationPropertiesRequest } from "./requests.js";
import { _subscribe } from "./notifications.js";
import { create } from "@bufbuild/protobuf";
export function pressed(handler) {
return _subscribe({ type: NotificationType.NOTIFY_ON_KEYBINDING_PRESSED }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "keybindingPressedNotification":
return handler(notification.type.keybindingPressedNotification);
return handler(notification.type.value);
default:

@@ -19,3 +20,3 @@ break;

interceptGlobalKeystrokes: globalIntercept,
actionList: { actions },
actionList: create(ActionListSchema, { actions }),
currentTerminalSessionId,

@@ -22,0 +23,0 @@ });

@@ -1,2 +0,2 @@

import { Notification, NotificationRequest, NotificationType } from "@aws/amazon-q-developer-cli-proto/fig";
import { type Notification, type NotificationRequest, NotificationType } from "@aws/amazon-q-developer-cli-proto/fig";
export type NotificationResponse = {

@@ -10,2 +10,2 @@ unsubscribe: boolean;

export declare function _unsubscribe(type: NotificationType, handler?: NotificationHandler): void;
export declare function _subscribe(request: NotificationRequest, handler: NotificationHandler): Promise<Subscription> | undefined;
export declare function _subscribe(request: Omit<NotificationRequest, "$typeName">, handler: NotificationHandler): Promise<Subscription> | undefined;

@@ -1,3 +0,4 @@

import { NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";
import { NotificationRequestSchema, NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendMessage } from "./core.js";
import { create } from "@bufbuild/protobuf";
const handlers = {};

@@ -22,4 +23,7 @@ export function _unsubscribe(type, handler) {

let handlersToRemove;
sendMessage({ $case: "notificationRequest", notificationRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "notificationRequest",
value: create(NotificationRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "notification":

@@ -31,3 +35,3 @@ if (!handlers[type]) {

handlersToRemove = handlers[type]?.filter((existingHandler) => {
const res = existingHandler(response.notification);
const res = existingHandler(response.value);
return Boolean(res?.unsubscribe);

@@ -41,3 +45,3 @@ });

case "error":
reject(new Error(response.error));
reject(new Error(response.value));
break;

@@ -62,7 +66,7 @@ default:

sendMessage({
$case: "notificationRequest",
notificationRequest: {
case: "notificationRequest",
value: create(NotificationRequestSchema, {
subscribe: false,
type: NotificationType.ALL,
},
}),
});

@@ -69,0 +73,0 @@ };

@@ -0,7 +1,9 @@

import { PointSchema, SizeSchema } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendPositionWindowRequest, sendDragWindowRequest, } from "./requests.js";
import { create } from "@bufbuild/protobuf";
// Developer Facing API
export async function isValidFrame(frame) {
return sendPositionWindowRequest({
size: { width: frame.width, height: frame.height },
anchor: { x: frame.anchorX, y: 0 },
size: create(SizeSchema, { width: frame.width, height: frame.height }),
anchor: create(PointSchema, { x: frame.anchorX, y: 0 }),
dryrun: true,

@@ -12,4 +14,7 @@ });

return sendPositionWindowRequest({
size: { width: frame.width, height: frame.height },
anchor: { x: frame.anchorX, y: frame.offsetFromBaseline ?? 0 },
size: create(SizeSchema, { width: frame.width, height: frame.height }),
anchor: create(PointSchema, {
x: frame.anchorX,
y: frame.offsetFromBaseline ?? 0,
}),
});

@@ -16,0 +21,0 @@ }

@@ -0,2 +1,4 @@

import { create } from "@bufbuild/protobuf";
import { sendRunProcessRequest } from "./requests.js";
import { DurationSchema, EnvironmentVariableSchema, } from "@aws/amazon-q-developer-cli-proto/fig_common";
export async function run({ executable, args, environment, workingDirectory, terminalSessionId, timeout, }) {

@@ -7,10 +9,10 @@ const env = environment ?? {};

arguments: args,
env: Object.keys(env).map((key) => ({ key, value: env[key] })),
env: Object.keys(env).map((key) => create(EnvironmentVariableSchema, { key, value: env[key] })),
workingDirectory,
terminalSessionId,
timeout: timeout
? {
? create(DurationSchema, {
nanos: Math.floor((timeout % 1000) * 1000000000),
secs: Math.floor(timeout / 1000),
}
secs: BigInt(Math.floor(timeout / 1000)),
})
: undefined,

@@ -17,0 +19,0 @@ });

@@ -1,48 +0,37 @@

import { AggregateSessionMetricActionRequest, AppendToFileRequest, ApplicationUpdateStatusRequest, ApplicationUpdateStatusResponse, AuthBuilderIdPollCreateTokenRequest, AuthBuilderIdPollCreateTokenResponse, AuthBuilderIdStartDeviceAuthorizationRequest, AuthBuilderIdStartDeviceAuthorizationResponse, AuthCancelPkceAuthorizationRequest, AuthCancelPkceAuthorizationResponse, AuthFinishPkceAuthorizationRequest, AuthFinishPkceAuthorizationResponse, AuthStartPkceAuthorizationRequest, AuthStartPkceAuthorizationResponse, AuthStatusRequest, AuthStatusResponse, CheckForUpdatesRequest, CheckForUpdatesResponse, CodewhispererListCustomizationRequest, CodewhispererListCustomizationResponse, ContentsOfDirectoryRequest, ContentsOfDirectoryResponse, CreateDirectoryRequest, DebuggerUpdateRequest, DestinationOfSymbolicLinkRequest, DestinationOfSymbolicLinkResponse, DragWindowRequest, GetConfigPropertyRequest, GetConfigPropertyResponse, GetDefaultsPropertyRequest, GetDefaultsPropertyResponse, GetLocalStateRequest, GetLocalStateResponse, GetPlatformInfoRequest, GetPlatformInfoResponse, GetSettingsPropertyRequest, GetSettingsPropertyResponse, HistoryQueryRequest, HistoryQueryResponse, InsertTextRequest, InstallRequest, InstallResponse, MacosInputMethodRequest, MacosInputMethodResponse, OnboardingRequest, OpenInExternalApplicationRequest, PingRequest, PingResponse, PositionWindowRequest, PositionWindowResponse, PseudoterminalExecuteRequest, PseudoterminalExecuteResponse, PseudoterminalRestartRequest, PseudoterminalWriteRequest, ReadFileRequest, ReadFileResponse, RunProcessRequest, RunProcessResponse, TelemetryIdentifyRequest, TelemetryPageRequest, TelemetryTrackRequest, TerminalSessionInfoRequest, TerminalSessionInfoResponse, UpdateApplicationPropertiesRequest, UpdateApplicationRequest, UpdateConfigPropertyRequest, UpdateDefaultsPropertyRequest, UpdateLocalStateRequest, UpdateSettingsPropertyRequest, UserLogoutRequest, WindowFocusRequest, WriteFileRequest } from "@aws/amazon-q-developer-cli-proto/fig";
export declare function sendPositionWindowRequest(request: PositionWindowRequest): Promise<PositionWindowResponse>;
export declare function sendPseudoterminalExecuteRequest(request: PseudoterminalExecuteRequest): Promise<PseudoterminalExecuteResponse>;
export declare function sendReadFileRequest(request: ReadFileRequest): Promise<ReadFileResponse>;
export declare function sendContentsOfDirectoryRequest(request: ContentsOfDirectoryRequest): Promise<ContentsOfDirectoryResponse>;
export declare function sendGetSettingsPropertyRequest(request: GetSettingsPropertyRequest): Promise<GetSettingsPropertyResponse>;
export declare function sendDestinationOfSymbolicLinkRequest(request: DestinationOfSymbolicLinkRequest): Promise<DestinationOfSymbolicLinkResponse>;
export declare function sendGetDefaultsPropertyRequest(request: GetDefaultsPropertyRequest): Promise<GetDefaultsPropertyResponse>;
export declare function sendGetConfigPropertyRequest(request: GetConfigPropertyRequest): Promise<GetConfigPropertyResponse>;
export declare function sendTerminalSessionInfoRequest(request: TerminalSessionInfoRequest): Promise<TerminalSessionInfoResponse>;
export declare function sendApplicationUpdateStatusRequest(request: ApplicationUpdateStatusRequest): Promise<ApplicationUpdateStatusResponse>;
export declare function sendGetLocalStateRequest(request: GetLocalStateRequest): Promise<GetLocalStateResponse>;
export declare function sendRunProcessRequest(request: RunProcessRequest): Promise<RunProcessResponse>;
export declare function sendMacosInputMethodRequest(request: MacosInputMethodRequest): Promise<MacosInputMethodResponse>;
export declare function sendInstallRequest(request: InstallRequest): Promise<InstallResponse>;
export declare function sendCheckForUpdatesRequest(request: CheckForUpdatesRequest): Promise<CheckForUpdatesResponse>;
export declare function sendHistoryQueryRequest(request: HistoryQueryRequest): Promise<HistoryQueryResponse>;
export declare function sendAuthStatusRequest(request: AuthStatusRequest): Promise<AuthStatusResponse>;
export declare function sendAuthBuilderIdStartDeviceAuthorizationRequest(request: AuthBuilderIdStartDeviceAuthorizationRequest): Promise<AuthBuilderIdStartDeviceAuthorizationResponse>;
export declare function sendAuthBuilderIdPollCreateTokenRequest(request: AuthBuilderIdPollCreateTokenRequest): Promise<AuthBuilderIdPollCreateTokenResponse>;
export declare function sendPingRequest(request: PingRequest): Promise<PingResponse>;
export declare function sendCodewhispererListCustomizationRequest(request: CodewhispererListCustomizationRequest): Promise<CodewhispererListCustomizationResponse>;
export declare function sendAuthStartPkceAuthorizationRequest(request: AuthStartPkceAuthorizationRequest): Promise<AuthStartPkceAuthorizationResponse>;
export declare function sendAuthFinishPkceAuthorizationRequest(request: AuthFinishPkceAuthorizationRequest): Promise<AuthFinishPkceAuthorizationResponse>;
export declare function sendAuthCancelPkceAuthorizationRequest(request: AuthCancelPkceAuthorizationRequest): Promise<AuthCancelPkceAuthorizationResponse>;
export declare function sendGetPlatformInfoRequest(request: GetPlatformInfoRequest): Promise<GetPlatformInfoResponse>;
export declare function sendPseudoterminalWriteRequest(request: PseudoterminalWriteRequest): Promise<void>;
export declare function sendWriteFileRequest(request: WriteFileRequest): Promise<void>;
export declare function sendUpdateSettingsPropertyRequest(request: UpdateSettingsPropertyRequest): Promise<void>;
export declare function sendInsertTextRequest(request: InsertTextRequest): Promise<void>;
export declare function sendUpdateApplicationPropertiesRequest(request: UpdateApplicationPropertiesRequest): Promise<void>;
export declare function sendUpdateDefaultsPropertyRequest(request: UpdateDefaultsPropertyRequest): Promise<void>;
export declare function sendTelemetryIdentifyRequest(request: TelemetryIdentifyRequest): Promise<void>;
export declare function sendTelemetryTrackRequest(request: TelemetryTrackRequest): Promise<void>;
export declare function sendOnboardingRequest(request: OnboardingRequest): Promise<void>;
export declare function sendWindowFocusRequest(request: WindowFocusRequest): Promise<void>;
export declare function sendOpenInExternalApplicationRequest(request: OpenInExternalApplicationRequest): Promise<void>;
export declare function sendUpdateConfigPropertyRequest(request: UpdateConfigPropertyRequest): Promise<void>;
export declare function sendPseudoterminalRestartRequest(request: PseudoterminalRestartRequest): Promise<void>;
export declare function sendDebuggerUpdateRequest(request: DebuggerUpdateRequest): Promise<void>;
export declare function sendAppendToFileRequest(request: AppendToFileRequest): Promise<void>;
export declare function sendUpdateLocalStateRequest(request: UpdateLocalStateRequest): Promise<void>;
export declare function sendCreateDirectoryRequest(request: CreateDirectoryRequest): Promise<void>;
export declare function sendTelemetryPageRequest(request: TelemetryPageRequest): Promise<void>;
export declare function sendAggregateSessionMetricActionRequest(request: AggregateSessionMetricActionRequest): Promise<void>;
export declare function sendUserLogoutRequest(request: UserLogoutRequest): Promise<void>;
export declare function sendUpdateApplicationRequest(request: UpdateApplicationRequest): Promise<void>;
export declare function sendDragWindowRequest(request: DragWindowRequest): Promise<void>;
import { AggregateSessionMetricActionRequest, AppendToFileRequest, AuthBuilderIdPollCreateTokenRequest, AuthBuilderIdPollCreateTokenResponse, AuthBuilderIdStartDeviceAuthorizationRequest, AuthBuilderIdStartDeviceAuthorizationResponse, AuthCancelPkceAuthorizationRequest, AuthCancelPkceAuthorizationResponse, AuthFinishPkceAuthorizationRequest, AuthFinishPkceAuthorizationResponse, AuthStartPkceAuthorizationRequest, AuthStartPkceAuthorizationResponse, AuthStatusRequest, AuthStatusResponse, CheckForUpdatesRequest, CheckForUpdatesResponse, CodewhispererListCustomizationRequest, CodewhispererListCustomizationResponse, ContentsOfDirectoryRequest, ContentsOfDirectoryResponse, CreateDirectoryRequest, DestinationOfSymbolicLinkRequest, DestinationOfSymbolicLinkResponse, DragWindowRequest, GetLocalStateRequest, GetLocalStateResponse, GetPlatformInfoRequest, GetPlatformInfoResponse, GetSettingsPropertyRequest, GetSettingsPropertyResponse, HistoryQueryRequest, HistoryQueryResponse, InsertTextRequest, InstallRequest, InstallResponse, NotificationRequest, OnboardingRequest, OpenInExternalApplicationRequest, PingRequest, PingResponse, PositionWindowRequest, PositionWindowResponse, ReadFileRequest, ReadFileResponse, RunProcessRequest, RunProcessResponse, TelemetryPageRequest, TelemetryTrackRequest, UpdateApplicationPropertiesRequest, UpdateApplicationRequest, UpdateLocalStateRequest, UpdateSettingsPropertyRequest, UserLogoutRequest, WindowFocusRequest, WriteFileRequest } from "@aws/amazon-q-developer-cli-proto/fig";
export declare function sendPositionWindowRequest(request: Omit<PositionWindowRequest, "$typeName" | "$unknown">): Promise<PositionWindowResponse>;
export declare function sendReadFileRequest(request: Omit<ReadFileRequest, "$typeName" | "$unknown">): Promise<ReadFileResponse>;
export declare function sendContentsOfDirectoryRequest(request: Omit<ContentsOfDirectoryRequest, "$typeName" | "$unknown">): Promise<ContentsOfDirectoryResponse>;
export declare function sendGetSettingsPropertyRequest(request: Omit<GetSettingsPropertyRequest, "$typeName" | "$unknown">): Promise<GetSettingsPropertyResponse>;
export declare function sendDestinationOfSymbolicLinkRequest(request: Omit<DestinationOfSymbolicLinkRequest, "$typeName" | "$unknown">): Promise<DestinationOfSymbolicLinkResponse>;
export declare function sendGetLocalStateRequest(request: Omit<GetLocalStateRequest, "$typeName" | "$unknown">): Promise<GetLocalStateResponse>;
export declare function sendRunProcessRequest(request: Omit<RunProcessRequest, "$typeName" | "$unknown">): Promise<RunProcessResponse>;
export declare function sendInstallRequest(request: Omit<InstallRequest, "$typeName" | "$unknown">): Promise<InstallResponse>;
export declare function sendCheckForUpdatesRequest(request: Omit<CheckForUpdatesRequest, "$typeName" | "$unknown">): Promise<CheckForUpdatesResponse>;
export declare function sendHistoryQueryRequest(request: Omit<HistoryQueryRequest, "$typeName" | "$unknown">): Promise<HistoryQueryResponse>;
export declare function sendAuthStatusRequest(request: Omit<AuthStatusRequest, "$typeName" | "$unknown">): Promise<AuthStatusResponse>;
export declare function sendAuthBuilderIdStartDeviceAuthorizationRequest(request: Omit<AuthBuilderIdStartDeviceAuthorizationRequest, "$typeName" | "$unknown">): Promise<AuthBuilderIdStartDeviceAuthorizationResponse>;
export declare function sendAuthBuilderIdPollCreateTokenRequest(request: Omit<AuthBuilderIdPollCreateTokenRequest, "$typeName" | "$unknown">): Promise<AuthBuilderIdPollCreateTokenResponse>;
export declare function sendPingRequest(request: Omit<PingRequest, "$typeName" | "$unknown">): Promise<PingResponse>;
export declare function sendCodewhispererListCustomizationRequest(request: Omit<CodewhispererListCustomizationRequest, "$typeName" | "$unknown">): Promise<CodewhispererListCustomizationResponse>;
export declare function sendAuthStartPkceAuthorizationRequest(request: Omit<AuthStartPkceAuthorizationRequest, "$typeName" | "$unknown">): Promise<AuthStartPkceAuthorizationResponse>;
export declare function sendAuthFinishPkceAuthorizationRequest(request: Omit<AuthFinishPkceAuthorizationRequest, "$typeName" | "$unknown">): Promise<AuthFinishPkceAuthorizationResponse>;
export declare function sendAuthCancelPkceAuthorizationRequest(request: Omit<AuthCancelPkceAuthorizationRequest, "$typeName" | "$unknown">): Promise<AuthCancelPkceAuthorizationResponse>;
export declare function sendGetPlatformInfoRequest(request: Omit<GetPlatformInfoRequest, "$typeName" | "$unknown">): Promise<GetPlatformInfoResponse>;
export declare function sendWriteFileRequest(request: Omit<WriteFileRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendNotificationRequest(request: Omit<NotificationRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendUpdateSettingsPropertyRequest(request: Omit<UpdateSettingsPropertyRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendInsertTextRequest(request: Omit<InsertTextRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendUpdateApplicationPropertiesRequest(request: Omit<UpdateApplicationPropertiesRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendTelemetryTrackRequest(request: Omit<TelemetryTrackRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendOnboardingRequest(request: Omit<OnboardingRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendWindowFocusRequest(request: Omit<WindowFocusRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendOpenInExternalApplicationRequest(request: Omit<OpenInExternalApplicationRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendAppendToFileRequest(request: Omit<AppendToFileRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendUpdateLocalStateRequest(request: Omit<UpdateLocalStateRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendCreateDirectoryRequest(request: Omit<CreateDirectoryRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendTelemetryPageRequest(request: Omit<TelemetryPageRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendAggregateSessionMetricActionRequest(request: Omit<AggregateSessionMetricActionRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendUserLogoutRequest(request: Omit<UserLogoutRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendUpdateApplicationRequest(request: Omit<UpdateApplicationRequest, "$typeName" | "$unknown">): Promise<void>;
export declare function sendDragWindowRequest(request: Omit<DragWindowRequest, "$typeName" | "$unknown">): Promise<void>;

@@ -1,17 +0,22 @@

/* Autogenerated by generate-requests.ts for proto v0.1.0
/* Autogenerated by generate-requests.ts for proto v0.2.0
* Do not edit directly! Instead run 'npm run generate-requests' in typescript-api-bindings
*/
import { AggregateSessionMetricActionRequestSchema, AppendToFileRequestSchema, AuthBuilderIdPollCreateTokenRequestSchema, AuthBuilderIdStartDeviceAuthorizationRequestSchema, AuthCancelPkceAuthorizationRequestSchema, AuthFinishPkceAuthorizationRequestSchema, AuthStartPkceAuthorizationRequestSchema, AuthStatusRequestSchema, CheckForUpdatesRequestSchema, CodewhispererListCustomizationRequestSchema, ContentsOfDirectoryRequestSchema, CreateDirectoryRequestSchema, DestinationOfSymbolicLinkRequestSchema, DragWindowRequestSchema, GetLocalStateRequestSchema, GetPlatformInfoRequestSchema, GetSettingsPropertyRequestSchema, HistoryQueryRequestSchema, InsertTextRequestSchema, InstallRequestSchema, NotificationRequestSchema, OnboardingRequestSchema, OpenInExternalApplicationRequestSchema, PingRequestSchema, PositionWindowRequestSchema, ReadFileRequestSchema, RunProcessRequestSchema, TelemetryPageRequestSchema, TelemetryTrackRequestSchema, UpdateApplicationPropertiesRequestSchema, UpdateApplicationRequestSchema, UpdateLocalStateRequestSchema, UpdateSettingsPropertyRequestSchema, UserLogoutRequestSchema, WindowFocusRequestSchema, WriteFileRequestSchema, } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendMessage } from "./core.js";
import { create } from "@bufbuild/protobuf";
export async function sendPositionWindowRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "positionWindowRequest", positionWindowRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "positionWindowRequest",
value: create(PositionWindowRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "positionWindowResponse":
resolve(response.positionWindowResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'PositionWindowRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'PositionWindowRequest'`));
}

@@ -21,33 +26,17 @@ });

}
export async function sendPseudoterminalExecuteRequest(request) {
export async function sendReadFileRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "pseudoterminalExecuteRequest",
pseudoterminalExecuteRequest: request,
case: "readFileRequest",
value: create(ReadFileRequestSchema, request),
}, (response) => {
switch (response?.$case) {
case "pseudoterminalExecuteResponse":
resolve(response.pseudoterminalExecuteResponse);
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'PseudoterminalExecuteRequest'`));
}
});
});
}
export async function sendReadFileRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "readFileRequest", readFileRequest: request }, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "readFileResponse":
resolve(response.readFileResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'ReadFileRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'ReadFileRequest'`));
}

@@ -60,14 +49,14 @@ });

sendMessage({
$case: "contentsOfDirectoryRequest",
contentsOfDirectoryRequest: request,
case: "contentsOfDirectoryRequest",
value: create(ContentsOfDirectoryRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "contentsOfDirectoryResponse":
resolve(response.contentsOfDirectoryResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'ContentsOfDirectoryRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'ContentsOfDirectoryRequest'`));
}

@@ -80,14 +69,14 @@ });

sendMessage({
$case: "getSettingsPropertyRequest",
getSettingsPropertyRequest: request,
case: "getSettingsPropertyRequest",
value: create(GetSettingsPropertyRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "getSettingsPropertyResponse":
resolve(response.getSettingsPropertyResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'GetSettingsPropertyRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'GetSettingsPropertyRequest'`));
}

@@ -100,14 +89,14 @@ });

sendMessage({
$case: "destinationOfSymbolicLinkRequest",
destinationOfSymbolicLinkRequest: request,
case: "destinationOfSymbolicLinkRequest",
value: create(DestinationOfSymbolicLinkRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "destinationOfSymbolicLinkResponse":
resolve(response.destinationOfSymbolicLinkResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'DestinationOfSymbolicLinkRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'DestinationOfSymbolicLinkRequest'`));
}

@@ -117,17 +106,17 @@ });

}
export async function sendGetDefaultsPropertyRequest(request) {
export async function sendGetLocalStateRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "getDefaultsPropertyRequest",
getDefaultsPropertyRequest: request,
case: "getLocalStateRequest",
value: create(GetLocalStateRequestSchema, request),
}, (response) => {
switch (response?.$case) {
case "getDefaultsPropertyResponse":
resolve(response.getDefaultsPropertyResponse);
switch (response?.case) {
case "getLocalStateResponse":
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'GetDefaultsPropertyRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'GetLocalStateRequest'`));
}

@@ -137,84 +126,17 @@ });

}
export async function sendGetConfigPropertyRequest(request) {
export async function sendRunProcessRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "getConfigPropertyRequest", getConfigPropertyRequest: request }, (response) => {
switch (response?.$case) {
case "getConfigPropertyResponse":
resolve(response.getConfigPropertyResponse);
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'GetConfigPropertyRequest'`));
}
});
});
}
export async function sendTerminalSessionInfoRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "terminalSessionInfoRequest",
terminalSessionInfoRequest: request,
case: "runProcessRequest",
value: create(RunProcessRequestSchema, request),
}, (response) => {
switch (response?.$case) {
case "terminalSessionInfoResponse":
resolve(response.terminalSessionInfoResponse);
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'TerminalSessionInfoRequest'`));
}
});
});
}
export async function sendApplicationUpdateStatusRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "applicationUpdateStatusRequest",
applicationUpdateStatusRequest: request,
}, (response) => {
switch (response?.$case) {
case "applicationUpdateStatusResponse":
resolve(response.applicationUpdateStatusResponse);
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'ApplicationUpdateStatusRequest'`));
}
});
});
}
export async function sendGetLocalStateRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "getLocalStateRequest", getLocalStateRequest: request }, (response) => {
switch (response?.$case) {
case "getLocalStateResponse":
resolve(response.getLocalStateResponse);
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'GetLocalStateRequest'`));
}
});
});
}
export async function sendRunProcessRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "runProcessRequest", runProcessRequest: request }, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "runProcessResponse":
resolve(response.runProcessResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'RunProcessRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'RunProcessRequest'`));
}

@@ -224,30 +146,14 @@ });

}
export async function sendMacosInputMethodRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "macosInputMethodRequest", macosInputMethodRequest: request }, (response) => {
switch (response?.$case) {
case "macosInputMethodResponse":
resolve(response.macosInputMethodResponse);
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'MacosInputMethodRequest'`));
}
});
});
}
export async function sendInstallRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "installRequest", installRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({ case: "installRequest", value: create(InstallRequestSchema, request) }, (response) => {
switch (response?.case) {
case "installResponse":
resolve(response.installResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'InstallRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'InstallRequest'`));
}

@@ -259,12 +165,15 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "checkForUpdatesRequest", checkForUpdatesRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "checkForUpdatesRequest",
value: create(CheckForUpdatesRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "checkForUpdatesResponse":
resolve(response.checkForUpdatesResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'CheckForUpdatesRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'CheckForUpdatesRequest'`));
}

@@ -276,12 +185,15 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "historyQueryRequest", historyQueryRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "historyQueryRequest",
value: create(HistoryQueryRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "historyQueryResponse":
resolve(response.historyQueryResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'HistoryQueryRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'HistoryQueryRequest'`));
}

@@ -293,12 +205,15 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "authStatusRequest", authStatusRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "authStatusRequest",
value: create(AuthStatusRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "authStatusResponse":
resolve(response.authStatusResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AuthStatusRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AuthStatusRequest'`));
}

@@ -311,14 +226,14 @@ });

sendMessage({
$case: "authBuilderIdStartDeviceAuthorizationRequest",
authBuilderIdStartDeviceAuthorizationRequest: request,
case: "authBuilderIdStartDeviceAuthorizationRequest",
value: create(AuthBuilderIdStartDeviceAuthorizationRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "authBuilderIdStartDeviceAuthorizationResponse":
resolve(response.authBuilderIdStartDeviceAuthorizationResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AuthBuilderIdStartDeviceAuthorizationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AuthBuilderIdStartDeviceAuthorizationRequest'`));
}

@@ -331,14 +246,14 @@ });

sendMessage({
$case: "authBuilderIdPollCreateTokenRequest",
authBuilderIdPollCreateTokenRequest: request,
case: "authBuilderIdPollCreateTokenRequest",
value: create(AuthBuilderIdPollCreateTokenRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "authBuilderIdPollCreateTokenResponse":
resolve(response.authBuilderIdPollCreateTokenResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AuthBuilderIdPollCreateTokenRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AuthBuilderIdPollCreateTokenRequest'`));
}

@@ -350,12 +265,12 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "pingRequest", pingRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({ case: "pingRequest", value: create(PingRequestSchema, request) }, (response) => {
switch (response?.case) {
case "pingResponse":
resolve(response.pingResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'PingRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'PingRequest'`));
}

@@ -368,14 +283,14 @@ });

sendMessage({
$case: "codewhispererListCustomizationRequest",
codewhispererListCustomizationRequest: request,
case: "codewhispererListCustomizationRequest",
value: create(CodewhispererListCustomizationRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "codewhispererListCustomizationResponse":
resolve(response.codewhispererListCustomizationResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'CodewhispererListCustomizationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'CodewhispererListCustomizationRequest'`));
}

@@ -388,14 +303,14 @@ });

sendMessage({
$case: "authStartPkceAuthorizationRequest",
authStartPkceAuthorizationRequest: request,
case: "authStartPkceAuthorizationRequest",
value: create(AuthStartPkceAuthorizationRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "authStartPkceAuthorizationResponse":
resolve(response.authStartPkceAuthorizationResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AuthStartPkceAuthorizationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AuthStartPkceAuthorizationRequest'`));
}

@@ -408,14 +323,14 @@ });

sendMessage({
$case: "authFinishPkceAuthorizationRequest",
authFinishPkceAuthorizationRequest: request,
case: "authFinishPkceAuthorizationRequest",
value: create(AuthFinishPkceAuthorizationRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "authFinishPkceAuthorizationResponse":
resolve(response.authFinishPkceAuthorizationResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AuthFinishPkceAuthorizationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AuthFinishPkceAuthorizationRequest'`));
}

@@ -428,14 +343,14 @@ });

sendMessage({
$case: "authCancelPkceAuthorizationRequest",
authCancelPkceAuthorizationRequest: request,
case: "authCancelPkceAuthorizationRequest",
value: create(AuthCancelPkceAuthorizationRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "authCancelPkceAuthorizationResponse":
resolve(response.authCancelPkceAuthorizationResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AuthCancelPkceAuthorizationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AuthCancelPkceAuthorizationRequest'`));
}

@@ -447,12 +362,15 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "getPlatformInfoRequest", getPlatformInfoRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "getPlatformInfoRequest",
value: create(GetPlatformInfoRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "getPlatformInfoResponse":
resolve(response.getPlatformInfoResponse);
resolve(response.value);
break;
case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'GetPlatformInfoRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'GetPlatformInfoRequest'`));
}

@@ -462,9 +380,9 @@ });

}
export async function sendPseudoterminalWriteRequest(request) {
export async function sendWriteFileRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "pseudoterminalWriteRequest",
pseudoterminalWriteRequest: request,
case: "writeFileRequest",
value: create(WriteFileRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -474,6 +392,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'PseudoterminalWriteRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'WriteFileRequest'`));
}

@@ -483,6 +401,9 @@ });

}
export async function sendWriteFileRequest(request) {
export async function sendNotificationRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "writeFileRequest", writeFileRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "notificationRequest",
value: create(NotificationRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -492,6 +413,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'WriteFileRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'NotificationRequest'`));
}

@@ -504,6 +425,6 @@ });

sendMessage({
$case: "updateSettingsPropertyRequest",
updateSettingsPropertyRequest: request,
case: "updateSettingsPropertyRequest",
value: create(UpdateSettingsPropertyRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -513,6 +434,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UpdateSettingsPropertyRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'UpdateSettingsPropertyRequest'`));
}

@@ -524,4 +445,7 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "insertTextRequest", insertTextRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "insertTextRequest",
value: create(InsertTextRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -531,6 +455,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'InsertTextRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'InsertTextRequest'`));
}

@@ -543,6 +467,6 @@ });

sendMessage({
$case: "updateApplicationPropertiesRequest",
updateApplicationPropertiesRequest: request,
case: "updateApplicationPropertiesRequest",
value: create(UpdateApplicationPropertiesRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -552,6 +476,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UpdateApplicationPropertiesRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'UpdateApplicationPropertiesRequest'`));
}

@@ -561,9 +485,9 @@ });

}
export async function sendUpdateDefaultsPropertyRequest(request) {
export async function sendTelemetryTrackRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "updateDefaultsPropertyRequest",
updateDefaultsPropertyRequest: request,
case: "telemetryTrackRequest",
value: create(TelemetryTrackRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -573,6 +497,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UpdateDefaultsPropertyRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'TelemetryTrackRequest'`));
}

@@ -582,38 +506,9 @@ });

}
export async function sendTelemetryIdentifyRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "telemetryIdentifyRequest", telemetryIdentifyRequest: request }, (response) => {
switch (response?.$case) {
case "success":
resolve();
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'TelemetryIdentifyRequest'`));
}
});
});
}
export async function sendTelemetryTrackRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "telemetryTrackRequest", telemetryTrackRequest: request }, (response) => {
switch (response?.$case) {
case "success":
resolve();
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'TelemetryTrackRequest'`));
}
});
});
}
export async function sendOnboardingRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "onboardingRequest", onboardingRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "onboardingRequest",
value: create(OnboardingRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -623,6 +518,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'OnboardingRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'OnboardingRequest'`));
}

@@ -634,4 +529,7 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "windowFocusRequest", windowFocusRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "windowFocusRequest",
value: create(WindowFocusRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -641,6 +539,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'WindowFocusRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'WindowFocusRequest'`));
}

@@ -653,6 +551,6 @@ });

sendMessage({
$case: "openInExternalApplicationRequest",
openInExternalApplicationRequest: request,
case: "openInExternalApplicationRequest",
value: create(OpenInExternalApplicationRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -662,6 +560,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'OpenInExternalApplicationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'OpenInExternalApplicationRequest'`));
}

@@ -671,9 +569,9 @@ });

}
export async function sendUpdateConfigPropertyRequest(request) {
export async function sendAppendToFileRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "updateConfigPropertyRequest",
updateConfigPropertyRequest: request,
case: "appendToFileRequest",
value: create(AppendToFileRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -683,6 +581,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UpdateConfigPropertyRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AppendToFileRequest'`));
}

@@ -692,9 +590,9 @@ });

}
export async function sendPseudoterminalRestartRequest(request) {
export async function sendUpdateLocalStateRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({
$case: "pseudoterminalRestartRequest",
pseudoterminalRestartRequest: request,
case: "updateLocalStateRequest",
value: create(UpdateLocalStateRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -704,6 +602,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'PseudoterminalRestartRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'UpdateLocalStateRequest'`));
}

@@ -713,54 +611,9 @@ });

}
export async function sendDebuggerUpdateRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "debuggerUpdateRequest", debuggerUpdateRequest: request }, (response) => {
switch (response?.$case) {
case "success":
resolve();
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'DebuggerUpdateRequest'`));
}
});
});
}
export async function sendAppendToFileRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "appendToFileRequest", appendToFileRequest: request }, (response) => {
switch (response?.$case) {
case "success":
resolve();
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AppendToFileRequest'`));
}
});
});
}
export async function sendUpdateLocalStateRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "updateLocalStateRequest", updateLocalStateRequest: request }, (response) => {
switch (response?.$case) {
case "success":
resolve();
break;
case "error":
reject(Error(response.error));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UpdateLocalStateRequest'`));
}
});
});
}
export async function sendCreateDirectoryRequest(request) {
return new Promise((resolve, reject) => {
sendMessage({ $case: "createDirectoryRequest", createDirectoryRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "createDirectoryRequest",
value: create(CreateDirectoryRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -770,6 +623,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'CreateDirectoryRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'CreateDirectoryRequest'`));
}

@@ -781,4 +634,7 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "telemetryPageRequest", telemetryPageRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "telemetryPageRequest",
value: create(TelemetryPageRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -788,6 +644,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'TelemetryPageRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'TelemetryPageRequest'`));
}

@@ -800,6 +656,6 @@ });

sendMessage({
$case: "aggregateSessionMetricActionRequest",
aggregateSessionMetricActionRequest: request,
case: "aggregateSessionMetricActionRequest",
value: create(AggregateSessionMetricActionRequestSchema, request),
}, (response) => {
switch (response?.$case) {
switch (response?.case) {
case "success":

@@ -809,6 +665,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'AggregateSessionMetricActionRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'AggregateSessionMetricActionRequest'`));
}

@@ -820,4 +676,7 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "userLogoutRequest", userLogoutRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "userLogoutRequest",
value: create(UserLogoutRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -827,6 +686,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UserLogoutRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'UserLogoutRequest'`));
}

@@ -838,4 +697,7 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "updateApplicationRequest", updateApplicationRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "updateApplicationRequest",
value: create(UpdateApplicationRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -845,6 +707,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'UpdateApplicationRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'UpdateApplicationRequest'`));
}

@@ -856,4 +718,7 @@ });

return new Promise((resolve, reject) => {
sendMessage({ $case: "dragWindowRequest", dragWindowRequest: request }, (response) => {
switch (response?.$case) {
sendMessage({
case: "dragWindowRequest",
value: create(DragWindowRequestSchema, request),
}, (response) => {
switch (response?.case) {
case "success":

@@ -863,6 +728,6 @@ resolve();

case "error":
reject(Error(response.error));
reject(Error(response.value));
break;
default:
reject(Error(`Invalid response '${response?.$case}' for 'DragWindowRequest'`));
reject(Error(`Invalid response '${response?.case}' for 'DragWindowRequest'`));
}

@@ -869,0 +734,0 @@ });

@@ -7,4 +7,4 @@ import { SettingsChangedNotification } from "@aws/amazon-q-developer-cli-proto/fig";

export declare function get(key: string): Promise<import("@aws/amazon-q-developer-cli-proto/fig").GetSettingsPropertyResponse>;
export declare function set(key: string, value: any): Promise<void>;
export declare function set(key: string, value: unknown): Promise<void>;
export declare function remove(key: string): Promise<void>;
export declare function current(): Promise<any>;

@@ -7,5 +7,5 @@ import { NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";

return _subscribe({ type: NotificationType.NOTIFY_ON_SETTINGS_CHANGE }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "settingsChangedNotification":
return handler(notification.type.settingsChangedNotification);
return handler(notification.type.value);
default:

@@ -23,3 +23,2 @@ break;

}
// eslint-disable-next-line @typescript-eslint/no-explicit-any
export async function set(key, value) {

@@ -26,0 +25,0 @@ return sendUpdateSettingsPropertyRequest({

@@ -12,2 +12,2 @@ import { ProcessChangedNotification, ShellPromptReturnedNotification, TextUpdate, HistoryUpdatedNotification } from "@aws/amazon-q-developer-cli-proto/fig";

};
export declare function insert(text: string, request?: Omit<TextUpdate, "insertion">, terminalSessionId?: string): Promise<void>;
export declare function insert(text: string, request?: Omit<TextUpdate, "insertion" | "$typeName">, terminalSessionId?: string): Promise<void>;

@@ -1,10 +0,11 @@

import { NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";
import { NotificationType, TextUpdateSchema, } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendInsertTextRequest } from "./requests.js";
import { _subscribe } from "./notifications.js";
import { create } from "@bufbuild/protobuf";
export const processDidChange = {
subscribe(handler) {
return _subscribe({ type: NotificationType.NOTIFY_ON_PROCESS_CHANGED }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "processChangeNotification":
return handler(notification.type.processChangeNotification);
return handler(notification.type.value);
default:

@@ -20,5 +21,5 @@ break;

return _subscribe({ type: NotificationType.NOTIFY_ON_PROMPT }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "shellPromptReturnedNotification":
return handler(notification.type.shellPromptReturnedNotification);
return handler(notification.type.value);
default:

@@ -34,5 +35,5 @@ break;

return _subscribe({ type: NotificationType.NOTIFY_ON_HISTORY_UPDATED }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "historyUpdatedNotification":
return handler(notification.type.historyUpdatedNotification);
return handler(notification.type.value);
default:

@@ -49,3 +50,6 @@ break;

terminalSessionId,
type: { $case: "update", update: { ...request, insertion: text } },
type: {
case: "update",
value: create(TextUpdateSchema, { ...request, insertion: text }),
},
});

@@ -55,5 +59,5 @@ }

terminalSessionId,
type: { $case: "text", text },
type: { case: "text", value: text },
});
}
//# sourceMappingURL=shell.js.map

@@ -7,4 +7,4 @@ import { LocalStateChangedNotification } from "@aws/amazon-q-developer-cli-proto/fig";

export declare function get(key: string): Promise<any>;
export declare function set(key: string, value: any): Promise<void>;
export declare function set(key: string, value: unknown): Promise<void>;
export declare function remove(key: string): Promise<void>;
export declare function current(): Promise<any>;

@@ -7,5 +7,5 @@ import { NotificationType, } from "@aws/amazon-q-developer-cli-proto/fig";

return _subscribe({ type: NotificationType.NOTIFY_ON_LOCAL_STATE_CHANGED }, (notification) => {
switch (notification?.type?.$case) {
switch (notification?.type?.case) {
case "localStateChangedNotification":
return handler(notification.type.localStateChangedNotification);
return handler(notification.type.value);
default:

@@ -22,3 +22,2 @@ break;

}
// eslint-disable-next-line @typescript-eslint/no-explicit-any
export async function set(key, value) {

@@ -25,0 +24,0 @@ return sendUpdateLocalStateRequest({

type Property = string | boolean | number | null;
type NamespaceSpecifier = {
username: string;
id?: number;
} | {
id: number;
username?: string;
};
export declare function track(event: string, properties: Record<string, Property>, namespace?: NamespaceSpecifier): Promise<void>;
export declare function identify(traits: Record<string, Property>): Promise<void>;
export declare function track(event: string, properties: Record<string, Property>): Promise<void>;
export declare function page(category: string, name: string, properties: Record<string, Property>): Promise<void>;
export {};

@@ -1,9 +0,11 @@

import { sendTelemetryIdentifyRequest, sendTelemetryPageRequest, sendTelemetryTrackRequest, } from "./requests.js";
export function track(event, properties, namespace) {
import { TelemetryPropertySchema, } from "@aws/amazon-q-developer-cli-proto/fig";
import { sendTelemetryPageRequest, sendTelemetryTrackRequest, } from "./requests.js";
import { create } from "@bufbuild/protobuf";
export function track(event, properties) {
// convert to internal type 'TelemetryProperty'
const props = Object.keys(properties).reduce((array, key) => {
const entry = {
const entry = create(TelemetryPropertySchema, {
key,
value: JSON.stringify(properties[key]),
};
});
array.push(entry);

@@ -16,9 +18,4 @@ return array;

jsonBlob: JSON.stringify(properties),
namespace: namespace?.username,
namespaceId: namespace?.id,
});
}
export function identify(traits) {
return sendTelemetryIdentifyRequest({ jsonBlob: JSON.stringify(traits) });
}
export function page(category, name, properties) {

@@ -25,0 +22,0 @@ // See more: https://segment.com/docs/connections/spec/page/

{
"name": "@aws/amazon-q-developer-cli-api-bindings",
"version": "0.1.0",
"version": "0.2.0",
"license": "MIT OR Apache-2.0",

@@ -16,3 +16,4 @@ "author": "Amazon Web Services",

"dependencies": {
"@aws/amazon-q-developer-cli-proto": "^0.1.0"
"@bufbuild/protobuf": "2.2.3",
"@aws/amazon-q-developer-cli-proto": "^0.2.0"
},

@@ -27,4 +28,2 @@ "devDependencies": {

"ts-morph": "^24.0.0",
"ts-proto": "~2.5.0",
"tslib": "^2.8.1",
"tsx": "^4.19.2",

@@ -31,0 +30,0 @@ "typescript": "^5.7.2",

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet