/*
* Copyright (c) Microsoft Corporation.
* Licensed under the MIT License.
*
* Code generated by Microsoft (R) AutoRest Code Generator.
* Changes may cause incorrect behavior and will be lost if the code is regenerated.
*/
import { PagedAsyncIterableIterator, PageSettings } from "@azure/core-paging";
import { setContinuationToken } from "../pagingHelper";
import { DevBoxDefinitions } from "../operationsInterfaces";
import * as coreClient from "@azure/core-client";
import * as Mappers from "../models/mappers";
import * as Parameters from "../models/parameters";
import { DevCenterClient } from "../devCenterClient";
import {
SimplePollerLike,
OperationState,
createHttpPoller,
} from "@azure/core-lro";
import { createLroSpec } from "../lroImpl";
import {
DevBoxDefinition,
DevBoxDefinitionsListByDevCenterNextOptionalParams,
DevBoxDefinitionsListByDevCenterOptionalParams,
DevBoxDefinitionsListByDevCenterResponse,
DevBoxDefinitionsListByProjectNextOptionalParams,
DevBoxDefinitionsListByProjectOptionalParams,
DevBoxDefinitionsListByProjectResponse,
DevBoxDefinitionsGetOptionalParams,
DevBoxDefinitionsGetResponse,
DevBoxDefinitionsCreateOrUpdateOptionalParams,
DevBoxDefinitionsCreateOrUpdateResponse,
DevBoxDefinitionUpdate,
DevBoxDefinitionsUpdateOptionalParams,
DevBoxDefinitionsUpdateResponse,
DevBoxDefinitionsDeleteOptionalParams,
DevBoxDefinitionsDeleteResponse,
DevBoxDefinitionsGetByProjectOptionalParams,
DevBoxDefinitionsGetByProjectResponse,
DevBoxDefinitionsListByDevCenterNextResponse,
DevBoxDefinitionsListByProjectNextResponse,
} from "../models";
///
/** Class containing DevBoxDefinitions operations. */
export class DevBoxDefinitionsImpl implements DevBoxDefinitions {
private readonly client: DevCenterClient;
/**
* Initialize a new instance of the class DevBoxDefinitions class.
* @param client Reference to the service client
*/
constructor(client: DevCenterClient) {
this.client = client;
}
/**
* List Dev Box definitions for a devcenter.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param options The options parameters.
*/
public listByDevCenter(
resourceGroupName: string,
devCenterName: string,
options?: DevBoxDefinitionsListByDevCenterOptionalParams,
): PagedAsyncIterableIterator {
const iter = this.listByDevCenterPagingAll(
resourceGroupName,
devCenterName,
options,
);
return {
next() {
return iter.next();
},
[Symbol.asyncIterator]() {
return this;
},
byPage: (settings?: PageSettings) => {
if (settings?.maxPageSize) {
throw new Error("maxPageSize is not supported by this operation.");
}
return this.listByDevCenterPagingPage(
resourceGroupName,
devCenterName,
options,
settings,
);
},
};
}
private async *listByDevCenterPagingPage(
resourceGroupName: string,
devCenterName: string,
options?: DevBoxDefinitionsListByDevCenterOptionalParams,
settings?: PageSettings,
): AsyncIterableIterator {
let result: DevBoxDefinitionsListByDevCenterResponse;
let continuationToken = settings?.continuationToken;
if (!continuationToken) {
result = await this._listByDevCenter(
resourceGroupName,
devCenterName,
options,
);
let page = result.value || [];
continuationToken = result.nextLink;
setContinuationToken(page, continuationToken);
yield page;
}
while (continuationToken) {
result = await this._listByDevCenterNext(
resourceGroupName,
devCenterName,
continuationToken,
options,
);
continuationToken = result.nextLink;
let page = result.value || [];
setContinuationToken(page, continuationToken);
yield page;
}
}
private async *listByDevCenterPagingAll(
resourceGroupName: string,
devCenterName: string,
options?: DevBoxDefinitionsListByDevCenterOptionalParams,
): AsyncIterableIterator {
for await (const page of this.listByDevCenterPagingPage(
resourceGroupName,
devCenterName,
options,
)) {
yield* page;
}
}
/**
* List Dev Box definitions configured for a project.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param projectName The name of the project.
* @param options The options parameters.
*/
public listByProject(
resourceGroupName: string,
projectName: string,
options?: DevBoxDefinitionsListByProjectOptionalParams,
): PagedAsyncIterableIterator {
const iter = this.listByProjectPagingAll(
resourceGroupName,
projectName,
options,
);
return {
next() {
return iter.next();
},
[Symbol.asyncIterator]() {
return this;
},
byPage: (settings?: PageSettings) => {
if (settings?.maxPageSize) {
throw new Error("maxPageSize is not supported by this operation.");
}
return this.listByProjectPagingPage(
resourceGroupName,
projectName,
options,
settings,
);
},
};
}
private async *listByProjectPagingPage(
resourceGroupName: string,
projectName: string,
options?: DevBoxDefinitionsListByProjectOptionalParams,
settings?: PageSettings,
): AsyncIterableIterator {
let result: DevBoxDefinitionsListByProjectResponse;
let continuationToken = settings?.continuationToken;
if (!continuationToken) {
result = await this._listByProject(
resourceGroupName,
projectName,
options,
);
let page = result.value || [];
continuationToken = result.nextLink;
setContinuationToken(page, continuationToken);
yield page;
}
while (continuationToken) {
result = await this._listByProjectNext(
resourceGroupName,
projectName,
continuationToken,
options,
);
continuationToken = result.nextLink;
let page = result.value || [];
setContinuationToken(page, continuationToken);
yield page;
}
}
private async *listByProjectPagingAll(
resourceGroupName: string,
projectName: string,
options?: DevBoxDefinitionsListByProjectOptionalParams,
): AsyncIterableIterator {
for await (const page of this.listByProjectPagingPage(
resourceGroupName,
projectName,
options,
)) {
yield* page;
}
}
/**
* List Dev Box definitions for a devcenter.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param options The options parameters.
*/
private _listByDevCenter(
resourceGroupName: string,
devCenterName: string,
options?: DevBoxDefinitionsListByDevCenterOptionalParams,
): Promise {
return this.client.sendOperationRequest(
{ resourceGroupName, devCenterName, options },
listByDevCenterOperationSpec,
);
}
/**
* Gets a Dev Box definition
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param options The options parameters.
*/
get(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
options?: DevBoxDefinitionsGetOptionalParams,
): Promise {
return this.client.sendOperationRequest(
{ resourceGroupName, devCenterName, devBoxDefinitionName, options },
getOperationSpec,
);
}
/**
* Creates or updates a Dev Box definition.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param body Represents a Dev Box definition.
* @param options The options parameters.
*/
async beginCreateOrUpdate(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
body: DevBoxDefinition,
options?: DevBoxDefinitionsCreateOrUpdateOptionalParams,
): Promise<
SimplePollerLike<
OperationState,
DevBoxDefinitionsCreateOrUpdateResponse
>
> {
const directSendOperation = async (
args: coreClient.OperationArguments,
spec: coreClient.OperationSpec,
): Promise => {
return this.client.sendOperationRequest(args, spec);
};
const sendOperationFn = async (
args: coreClient.OperationArguments,
spec: coreClient.OperationSpec,
) => {
let currentRawResponse: coreClient.FullOperationResponse | undefined =
undefined;
const providedCallback = args.options?.onResponse;
const callback: coreClient.RawResponseCallback = (
rawResponse: coreClient.FullOperationResponse,
flatResponse: unknown,
) => {
currentRawResponse = rawResponse;
providedCallback?.(rawResponse, flatResponse);
};
const updatedArgs = {
...args,
options: {
...args.options,
onResponse: callback,
},
};
const flatResponse = await directSendOperation(updatedArgs, spec);
return {
flatResponse,
rawResponse: {
statusCode: currentRawResponse!.status,
body: currentRawResponse!.parsedBody,
headers: currentRawResponse!.headers.toJSON(),
},
};
};
const lro = createLroSpec({
sendOperationFn,
args: {
resourceGroupName,
devCenterName,
devBoxDefinitionName,
body,
options,
},
spec: createOrUpdateOperationSpec,
});
const poller = await createHttpPoller<
DevBoxDefinitionsCreateOrUpdateResponse,
OperationState
>(lro, {
restoreFrom: options?.resumeFrom,
intervalInMs: options?.updateIntervalInMs,
resourceLocationConfig: "azure-async-operation",
});
await poller.poll();
return poller;
}
/**
* Creates or updates a Dev Box definition.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param body Represents a Dev Box definition.
* @param options The options parameters.
*/
async beginCreateOrUpdateAndWait(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
body: DevBoxDefinition,
options?: DevBoxDefinitionsCreateOrUpdateOptionalParams,
): Promise {
const poller = await this.beginCreateOrUpdate(
resourceGroupName,
devCenterName,
devBoxDefinitionName,
body,
options,
);
return poller.pollUntilDone();
}
/**
* Partially updates a Dev Box definition.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param body Represents a Dev Box definition.
* @param options The options parameters.
*/
async beginUpdate(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
body: DevBoxDefinitionUpdate,
options?: DevBoxDefinitionsUpdateOptionalParams,
): Promise<
SimplePollerLike<
OperationState,
DevBoxDefinitionsUpdateResponse
>
> {
const directSendOperation = async (
args: coreClient.OperationArguments,
spec: coreClient.OperationSpec,
): Promise => {
return this.client.sendOperationRequest(args, spec);
};
const sendOperationFn = async (
args: coreClient.OperationArguments,
spec: coreClient.OperationSpec,
) => {
let currentRawResponse: coreClient.FullOperationResponse | undefined =
undefined;
const providedCallback = args.options?.onResponse;
const callback: coreClient.RawResponseCallback = (
rawResponse: coreClient.FullOperationResponse,
flatResponse: unknown,
) => {
currentRawResponse = rawResponse;
providedCallback?.(rawResponse, flatResponse);
};
const updatedArgs = {
...args,
options: {
...args.options,
onResponse: callback,
},
};
const flatResponse = await directSendOperation(updatedArgs, spec);
return {
flatResponse,
rawResponse: {
statusCode: currentRawResponse!.status,
body: currentRawResponse!.parsedBody,
headers: currentRawResponse!.headers.toJSON(),
},
};
};
const lro = createLroSpec({
sendOperationFn,
args: {
resourceGroupName,
devCenterName,
devBoxDefinitionName,
body,
options,
},
spec: updateOperationSpec,
});
const poller = await createHttpPoller<
DevBoxDefinitionsUpdateResponse,
OperationState
>(lro, {
restoreFrom: options?.resumeFrom,
intervalInMs: options?.updateIntervalInMs,
resourceLocationConfig: "azure-async-operation",
});
await poller.poll();
return poller;
}
/**
* Partially updates a Dev Box definition.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param body Represents a Dev Box definition.
* @param options The options parameters.
*/
async beginUpdateAndWait(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
body: DevBoxDefinitionUpdate,
options?: DevBoxDefinitionsUpdateOptionalParams,
): Promise {
const poller = await this.beginUpdate(
resourceGroupName,
devCenterName,
devBoxDefinitionName,
body,
options,
);
return poller.pollUntilDone();
}
/**
* Deletes a Dev Box definition
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param options The options parameters.
*/
async beginDelete(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
options?: DevBoxDefinitionsDeleteOptionalParams,
): Promise<
SimplePollerLike<
OperationState,
DevBoxDefinitionsDeleteResponse
>
> {
const directSendOperation = async (
args: coreClient.OperationArguments,
spec: coreClient.OperationSpec,
): Promise => {
return this.client.sendOperationRequest(args, spec);
};
const sendOperationFn = async (
args: coreClient.OperationArguments,
spec: coreClient.OperationSpec,
) => {
let currentRawResponse: coreClient.FullOperationResponse | undefined =
undefined;
const providedCallback = args.options?.onResponse;
const callback: coreClient.RawResponseCallback = (
rawResponse: coreClient.FullOperationResponse,
flatResponse: unknown,
) => {
currentRawResponse = rawResponse;
providedCallback?.(rawResponse, flatResponse);
};
const updatedArgs = {
...args,
options: {
...args.options,
onResponse: callback,
},
};
const flatResponse = await directSendOperation(updatedArgs, spec);
return {
flatResponse,
rawResponse: {
statusCode: currentRawResponse!.status,
body: currentRawResponse!.parsedBody,
headers: currentRawResponse!.headers.toJSON(),
},
};
};
const lro = createLroSpec({
sendOperationFn,
args: { resourceGroupName, devCenterName, devBoxDefinitionName, options },
spec: deleteOperationSpec,
});
const poller = await createHttpPoller<
DevBoxDefinitionsDeleteResponse,
OperationState
>(lro, {
restoreFrom: options?.resumeFrom,
intervalInMs: options?.updateIntervalInMs,
resourceLocationConfig: "azure-async-operation",
});
await poller.poll();
return poller;
}
/**
* Deletes a Dev Box definition
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param options The options parameters.
*/
async beginDeleteAndWait(
resourceGroupName: string,
devCenterName: string,
devBoxDefinitionName: string,
options?: DevBoxDefinitionsDeleteOptionalParams,
): Promise {
const poller = await this.beginDelete(
resourceGroupName,
devCenterName,
devBoxDefinitionName,
options,
);
return poller.pollUntilDone();
}
/**
* List Dev Box definitions configured for a project.
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param projectName The name of the project.
* @param options The options parameters.
*/
private _listByProject(
resourceGroupName: string,
projectName: string,
options?: DevBoxDefinitionsListByProjectOptionalParams,
): Promise {
return this.client.sendOperationRequest(
{ resourceGroupName, projectName, options },
listByProjectOperationSpec,
);
}
/**
* Gets a Dev Box definition configured for a project
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param projectName The name of the project.
* @param devBoxDefinitionName The name of the Dev Box definition.
* @param options The options parameters.
*/
getByProject(
resourceGroupName: string,
projectName: string,
devBoxDefinitionName: string,
options?: DevBoxDefinitionsGetByProjectOptionalParams,
): Promise {
return this.client.sendOperationRequest(
{ resourceGroupName, projectName, devBoxDefinitionName, options },
getByProjectOperationSpec,
);
}
/**
* ListByDevCenterNext
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param devCenterName The name of the devcenter.
* @param nextLink The nextLink from the previous successful call to the ListByDevCenter method.
* @param options The options parameters.
*/
private _listByDevCenterNext(
resourceGroupName: string,
devCenterName: string,
nextLink: string,
options?: DevBoxDefinitionsListByDevCenterNextOptionalParams,
): Promise {
return this.client.sendOperationRequest(
{ resourceGroupName, devCenterName, nextLink, options },
listByDevCenterNextOperationSpec,
);
}
/**
* ListByProjectNext
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param projectName The name of the project.
* @param nextLink The nextLink from the previous successful call to the ListByProject method.
* @param options The options parameters.
*/
private _listByProjectNext(
resourceGroupName: string,
projectName: string,
nextLink: string,
options?: DevBoxDefinitionsListByProjectNextOptionalParams,
): Promise {
return this.client.sendOperationRequest(
{ resourceGroupName, projectName, nextLink, options },
listByProjectNextOperationSpec,
);
}
}
// Operation Specifications
const serializer = coreClient.createSerializer(Mappers, /* isXml */ false);
const listByDevCenterOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/devboxdefinitions",
httpMethod: "GET",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinitionListResult,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
queryParameters: [Parameters.apiVersion, Parameters.top],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.devCenterName,
],
headerParameters: [Parameters.accept],
serializer,
};
const getOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/devboxdefinitions/{devBoxDefinitionName}",
httpMethod: "GET",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinition,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
queryParameters: [Parameters.apiVersion],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.devCenterName,
Parameters.devBoxDefinitionName,
],
headerParameters: [Parameters.accept],
serializer,
};
const createOrUpdateOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/devboxdefinitions/{devBoxDefinitionName}",
httpMethod: "PUT",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinition,
},
201: {
bodyMapper: Mappers.DevBoxDefinition,
},
202: {
bodyMapper: Mappers.DevBoxDefinition,
},
204: {
bodyMapper: Mappers.DevBoxDefinition,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
requestBody: Parameters.body12,
queryParameters: [Parameters.apiVersion],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.devCenterName,
Parameters.devBoxDefinitionName,
],
headerParameters: [Parameters.accept, Parameters.contentType],
mediaType: "json",
serializer,
};
const updateOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/devboxdefinitions/{devBoxDefinitionName}",
httpMethod: "PATCH",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinition,
},
201: {
bodyMapper: Mappers.DevBoxDefinition,
},
202: {
bodyMapper: Mappers.DevBoxDefinition,
},
204: {
bodyMapper: Mappers.DevBoxDefinition,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
requestBody: Parameters.body13,
queryParameters: [Parameters.apiVersion],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.devCenterName,
Parameters.devBoxDefinitionName,
],
headerParameters: [Parameters.accept, Parameters.contentType],
mediaType: "json",
serializer,
};
const deleteOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/devboxdefinitions/{devBoxDefinitionName}",
httpMethod: "DELETE",
responses: {
200: {
headersMapper: Mappers.DevBoxDefinitionsDeleteHeaders,
},
201: {
headersMapper: Mappers.DevBoxDefinitionsDeleteHeaders,
},
202: {
headersMapper: Mappers.DevBoxDefinitionsDeleteHeaders,
},
204: {
headersMapper: Mappers.DevBoxDefinitionsDeleteHeaders,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
queryParameters: [Parameters.apiVersion],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.devCenterName,
Parameters.devBoxDefinitionName,
],
headerParameters: [Parameters.accept],
serializer,
};
const listByProjectOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/projects/{projectName}/devboxdefinitions",
httpMethod: "GET",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinitionListResult,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
queryParameters: [Parameters.apiVersion, Parameters.top],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.projectName,
],
headerParameters: [Parameters.accept],
serializer,
};
const getByProjectOperationSpec: coreClient.OperationSpec = {
path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/projects/{projectName}/devboxdefinitions/{devBoxDefinitionName}",
httpMethod: "GET",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinition,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
queryParameters: [Parameters.apiVersion],
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.projectName,
Parameters.devBoxDefinitionName,
],
headerParameters: [Parameters.accept],
serializer,
};
const listByDevCenterNextOperationSpec: coreClient.OperationSpec = {
path: "{nextLink}",
httpMethod: "GET",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinitionListResult,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.devCenterName,
Parameters.nextLink,
],
headerParameters: [Parameters.accept],
serializer,
};
const listByProjectNextOperationSpec: coreClient.OperationSpec = {
path: "{nextLink}",
httpMethod: "GET",
responses: {
200: {
bodyMapper: Mappers.DevBoxDefinitionListResult,
},
default: {
bodyMapper: Mappers.ErrorResponse,
},
},
urlParameters: [
Parameters.$host,
Parameters.subscriptionId,
Parameters.resourceGroupName,
Parameters.nextLink,
Parameters.projectName,
],
headerParameters: [Parameters.accept],
serializer,
};