/* * 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 { Catalogs } 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 { Catalog, CatalogsListByDevCenterNextOptionalParams, CatalogsListByDevCenterOptionalParams, CatalogsListByDevCenterResponse, CatalogsGetOptionalParams, CatalogsGetResponse, CatalogsCreateOrUpdateOptionalParams, CatalogsCreateOrUpdateResponse, CatalogUpdate, CatalogsUpdateOptionalParams, CatalogsUpdateResponse, CatalogsDeleteOptionalParams, CatalogsDeleteResponse, CatalogsGetSyncErrorDetailsOptionalParams, CatalogsGetSyncErrorDetailsResponse, CatalogsSyncOptionalParams, CatalogsSyncResponse, CatalogsConnectOptionalParams, CatalogsConnectResponse, CatalogsListByDevCenterNextResponse, } from "../models"; /// /** Class containing Catalogs operations. */ export class CatalogsImpl implements Catalogs { private readonly client: DevCenterClient; /** * Initialize a new instance of the class Catalogs class. * @param client Reference to the service client */ constructor(client: DevCenterClient) { this.client = client; } /** * Lists catalogs 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?: CatalogsListByDevCenterOptionalParams, ): 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?: CatalogsListByDevCenterOptionalParams, settings?: PageSettings, ): AsyncIterableIterator { let result: CatalogsListByDevCenterResponse; 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?: CatalogsListByDevCenterOptionalParams, ): AsyncIterableIterator { for await (const page of this.listByDevCenterPagingPage( resourceGroupName, devCenterName, options, )) { yield* page; } } /** * Lists catalogs 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?: CatalogsListByDevCenterOptionalParams, ): Promise { return this.client.sendOperationRequest( { resourceGroupName, devCenterName, options }, listByDevCenterOperationSpec, ); } /** * Gets a catalog * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ get( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsGetOptionalParams, ): Promise { return this.client.sendOperationRequest( { resourceGroupName, devCenterName, catalogName, options }, getOperationSpec, ); } /** * Creates or updates a catalog. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param body Represents a catalog. * @param options The options parameters. */ async beginCreateOrUpdate( resourceGroupName: string, devCenterName: string, catalogName: string, body: Catalog, options?: CatalogsCreateOrUpdateOptionalParams, ): Promise< SimplePollerLike< OperationState, CatalogsCreateOrUpdateResponse > > { 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, catalogName, body, options }, spec: createOrUpdateOperationSpec, }); const poller = await createHttpPoller< CatalogsCreateOrUpdateResponse, OperationState >(lro, { restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, resourceLocationConfig: "azure-async-operation", }); await poller.poll(); return poller; } /** * Creates or updates a catalog. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param body Represents a catalog. * @param options The options parameters. */ async beginCreateOrUpdateAndWait( resourceGroupName: string, devCenterName: string, catalogName: string, body: Catalog, options?: CatalogsCreateOrUpdateOptionalParams, ): Promise { const poller = await this.beginCreateOrUpdate( resourceGroupName, devCenterName, catalogName, body, options, ); return poller.pollUntilDone(); } /** * Partially updates a catalog. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param body Updatable catalog properties. * @param options The options parameters. */ async beginUpdate( resourceGroupName: string, devCenterName: string, catalogName: string, body: CatalogUpdate, options?: CatalogsUpdateOptionalParams, ): Promise< SimplePollerLike< OperationState, CatalogsUpdateResponse > > { 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, catalogName, body, options }, spec: updateOperationSpec, }); const poller = await createHttpPoller< CatalogsUpdateResponse, OperationState >(lro, { restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, resourceLocationConfig: "azure-async-operation", }); await poller.poll(); return poller; } /** * Partially updates a catalog. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param body Updatable catalog properties. * @param options The options parameters. */ async beginUpdateAndWait( resourceGroupName: string, devCenterName: string, catalogName: string, body: CatalogUpdate, options?: CatalogsUpdateOptionalParams, ): Promise { const poller = await this.beginUpdate( resourceGroupName, devCenterName, catalogName, body, options, ); return poller.pollUntilDone(); } /** * Deletes a catalog resource. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ async beginDelete( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsDeleteOptionalParams, ): Promise< SimplePollerLike< OperationState, CatalogsDeleteResponse > > { 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, catalogName, options }, spec: deleteOperationSpec, }); const poller = await createHttpPoller< CatalogsDeleteResponse, OperationState >(lro, { restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, resourceLocationConfig: "azure-async-operation", }); await poller.poll(); return poller; } /** * Deletes a catalog resource. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ async beginDeleteAndWait( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsDeleteOptionalParams, ): Promise { const poller = await this.beginDelete( resourceGroupName, devCenterName, catalogName, options, ); return poller.pollUntilDone(); } /** * Gets catalog synchronization error details * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ getSyncErrorDetails( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsGetSyncErrorDetailsOptionalParams, ): Promise { return this.client.sendOperationRequest( { resourceGroupName, devCenterName, catalogName, options }, getSyncErrorDetailsOperationSpec, ); } /** * Syncs templates for a template source. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ async beginSync( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsSyncOptionalParams, ): Promise< SimplePollerLike, CatalogsSyncResponse> > { 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, catalogName, options }, spec: syncOperationSpec, }); const poller = await createHttpPoller< CatalogsSyncResponse, OperationState >(lro, { restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, resourceLocationConfig: "azure-async-operation", }); await poller.poll(); return poller; } /** * Syncs templates for a template source. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ async beginSyncAndWait( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsSyncOptionalParams, ): Promise { const poller = await this.beginSync( resourceGroupName, devCenterName, catalogName, options, ); return poller.pollUntilDone(); } /** * Connects a catalog to enable syncing. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ async beginConnect( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsConnectOptionalParams, ): Promise< SimplePollerLike< OperationState, CatalogsConnectResponse > > { 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, catalogName, options }, spec: connectOperationSpec, }); const poller = await createHttpPoller< CatalogsConnectResponse, OperationState >(lro, { restoreFrom: options?.resumeFrom, intervalInMs: options?.updateIntervalInMs, resourceLocationConfig: "azure-async-operation", }); await poller.poll(); return poller; } /** * Connects a catalog to enable syncing. * @param resourceGroupName The name of the resource group. The name is case insensitive. * @param devCenterName The name of the devcenter. * @param catalogName The name of the Catalog. * @param options The options parameters. */ async beginConnectAndWait( resourceGroupName: string, devCenterName: string, catalogName: string, options?: CatalogsConnectOptionalParams, ): Promise { const poller = await this.beginConnect( resourceGroupName, devCenterName, catalogName, options, ); return poller.pollUntilDone(); } /** * 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?: CatalogsListByDevCenterNextOptionalParams, ): Promise { return this.client.sendOperationRequest( { resourceGroupName, devCenterName, nextLink, options }, listByDevCenterNextOperationSpec, ); } } // Operation Specifications const serializer = coreClient.createSerializer(Mappers, /* isXml */ false); const listByDevCenterOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs", httpMethod: "GET", responses: { 200: { bodyMapper: Mappers.CatalogListResult, }, 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}/catalogs/{catalogName}", httpMethod: "GET", responses: { 200: { bodyMapper: Mappers.Catalog, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept], serializer, }; const createOrUpdateOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs/{catalogName}", httpMethod: "PUT", responses: { 200: { bodyMapper: Mappers.Catalog, }, 201: { bodyMapper: Mappers.Catalog, }, 202: { bodyMapper: Mappers.Catalog, }, 204: { bodyMapper: Mappers.Catalog, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, requestBody: Parameters.body5, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept, Parameters.contentType], mediaType: "json", serializer, }; const updateOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs/{catalogName}", httpMethod: "PATCH", responses: { 200: { bodyMapper: Mappers.Catalog, }, 201: { bodyMapper: Mappers.Catalog, }, 202: { bodyMapper: Mappers.Catalog, }, 204: { bodyMapper: Mappers.Catalog, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, requestBody: Parameters.body6, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept, Parameters.contentType], mediaType: "json", serializer, }; const deleteOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs/{catalogName}", httpMethod: "DELETE", responses: { 200: { headersMapper: Mappers.CatalogsDeleteHeaders, }, 201: { headersMapper: Mappers.CatalogsDeleteHeaders, }, 202: { headersMapper: Mappers.CatalogsDeleteHeaders, }, 204: { headersMapper: Mappers.CatalogsDeleteHeaders, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept], serializer, }; const getSyncErrorDetailsOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs/{catalogName}/getSyncErrorDetails", httpMethod: "POST", responses: { 200: { bodyMapper: Mappers.SyncErrorDetails, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept], serializer, }; const syncOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs/{catalogName}/sync", httpMethod: "POST", responses: { 200: { headersMapper: Mappers.CatalogsSyncHeaders, }, 201: { headersMapper: Mappers.CatalogsSyncHeaders, }, 202: { headersMapper: Mappers.CatalogsSyncHeaders, }, 204: { headersMapper: Mappers.CatalogsSyncHeaders, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept], serializer, }; const connectOperationSpec: coreClient.OperationSpec = { path: "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DevCenter/devcenters/{devCenterName}/catalogs/{catalogName}/connect", httpMethod: "POST", responses: { 200: { headersMapper: Mappers.CatalogsConnectHeaders, }, 201: { headersMapper: Mappers.CatalogsConnectHeaders, }, 202: { headersMapper: Mappers.CatalogsConnectHeaders, }, 204: { headersMapper: Mappers.CatalogsConnectHeaders, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, queryParameters: [Parameters.apiVersion], urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.catalogName, ], headerParameters: [Parameters.accept], serializer, }; const listByDevCenterNextOperationSpec: coreClient.OperationSpec = { path: "{nextLink}", httpMethod: "GET", responses: { 200: { bodyMapper: Mappers.CatalogListResult, }, default: { bodyMapper: Mappers.ErrorResponse, }, }, urlParameters: [ Parameters.$host, Parameters.subscriptionId, Parameters.resourceGroupName, Parameters.devCenterName, Parameters.nextLink, ], headerParameters: [Parameters.accept], serializer, };