From 6a6836653ba38ec29de5d201a8c302ec72b43364 Mon Sep 17 00:00:00 2001 From: awstools Date: Fri, 1 Sep 2023 18:12:34 +0000 Subject: [PATCH] feat(client-chime-sdk-media-pipelines): This release adds support for the Voice Analytics feature for customer-owned KVS streams as part of the Amazon Chime SDK call analytics. --- .../README.md | 48 ++ .../src/ChimeSDKMediaPipelines.ts | 138 ++++ .../src/ChimeSDKMediaPipelinesClient.ts | 36 + .../commands/DeleteMediaPipelineCommand.ts | 4 + .../commands/GetSpeakerSearchTaskCommand.ts | 173 ++++ .../GetVoiceToneAnalysisTaskCommand.ts | 173 ++++ .../commands/StartSpeakerSearchTaskCommand.ts | 191 +++++ .../StartVoiceToneAnalysisTaskCommand.ts | 196 +++++ .../commands/StopSpeakerSearchTaskCommand.ts | 170 ++++ .../StopVoiceToneAnalysisTaskCommand.ts | 173 ++++ .../src/commands/index.ts | 6 + .../src/models/models_0.ts | 309 ++++++- .../src/protocols/Aws_restJson1.ts | 760 ++++++++++++++++-- .../aws-models/chime-sdk-media-pipelines.json | 702 +++++++++++++++- 14 files changed, 3000 insertions(+), 79 deletions(-) create mode 100644 clients/client-chime-sdk-media-pipelines/src/commands/GetSpeakerSearchTaskCommand.ts create mode 100644 clients/client-chime-sdk-media-pipelines/src/commands/GetVoiceToneAnalysisTaskCommand.ts create mode 100644 clients/client-chime-sdk-media-pipelines/src/commands/StartSpeakerSearchTaskCommand.ts create mode 100644 clients/client-chime-sdk-media-pipelines/src/commands/StartVoiceToneAnalysisTaskCommand.ts create mode 100644 clients/client-chime-sdk-media-pipelines/src/commands/StopSpeakerSearchTaskCommand.ts create mode 100644 clients/client-chime-sdk-media-pipelines/src/commands/StopVoiceToneAnalysisTaskCommand.ts diff --git a/clients/client-chime-sdk-media-pipelines/README.md b/clients/client-chime-sdk-media-pipelines/README.md index 842f5a9c4c58..19a8a83af6eb 100644 --- a/clients/client-chime-sdk-media-pipelines/README.md +++ b/clients/client-chime-sdk-media-pipelines/README.md @@ -297,6 +297,22 @@ GetMediaPipeline [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/getmediapipelinecommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/getmediapipelinecommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/getmediapipelinecommandoutput.html) + +
+ +GetSpeakerSearchTask + + +[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/getspeakersearchtaskcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/getspeakersearchtaskcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/getspeakersearchtaskcommandoutput.html) + +
+
+ +GetVoiceToneAnalysisTask + + +[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/getvoicetoneanalysistaskcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/getvoicetoneanalysistaskcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/getvoicetoneanalysistaskcommandoutput.html) +
@@ -329,6 +345,38 @@ ListTagsForResource [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/listtagsforresourcecommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/listtagsforresourcecommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/listtagsforresourcecommandoutput.html) +
+
+ +StartSpeakerSearchTask + + +[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/startspeakersearchtaskcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/startspeakersearchtaskcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/startspeakersearchtaskcommandoutput.html) + +
+
+ +StartVoiceToneAnalysisTask + + +[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/startvoicetoneanalysistaskcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/startvoicetoneanalysistaskcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/startvoicetoneanalysistaskcommandoutput.html) + +
+
+ +StopSpeakerSearchTask + + +[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/stopspeakersearchtaskcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/stopspeakersearchtaskcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/stopspeakersearchtaskcommandoutput.html) + +
+
+ +StopVoiceToneAnalysisTask + + +[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/classes/stopvoicetoneanalysistaskcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/stopvoicetoneanalysistaskcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-chime-sdk-media-pipelines/interfaces/stopvoicetoneanalysistaskcommandoutput.html) +
diff --git a/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelines.ts b/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelines.ts index ee59a5485a8f..99f18d7331e6 100644 --- a/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelines.ts +++ b/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelines.ts @@ -58,6 +58,16 @@ import { GetMediaPipelineCommandInput, GetMediaPipelineCommandOutput, } from "./commands/GetMediaPipelineCommand"; +import { + GetSpeakerSearchTaskCommand, + GetSpeakerSearchTaskCommandInput, + GetSpeakerSearchTaskCommandOutput, +} from "./commands/GetSpeakerSearchTaskCommand"; +import { + GetVoiceToneAnalysisTaskCommand, + GetVoiceToneAnalysisTaskCommandInput, + GetVoiceToneAnalysisTaskCommandOutput, +} from "./commands/GetVoiceToneAnalysisTaskCommand"; import { ListMediaCapturePipelinesCommand, ListMediaCapturePipelinesCommandInput, @@ -78,6 +88,26 @@ import { ListTagsForResourceCommandInput, ListTagsForResourceCommandOutput, } from "./commands/ListTagsForResourceCommand"; +import { + StartSpeakerSearchTaskCommand, + StartSpeakerSearchTaskCommandInput, + StartSpeakerSearchTaskCommandOutput, +} from "./commands/StartSpeakerSearchTaskCommand"; +import { + StartVoiceToneAnalysisTaskCommand, + StartVoiceToneAnalysisTaskCommandInput, + StartVoiceToneAnalysisTaskCommandOutput, +} from "./commands/StartVoiceToneAnalysisTaskCommand"; +import { + StopSpeakerSearchTaskCommand, + StopSpeakerSearchTaskCommandInput, + StopSpeakerSearchTaskCommandOutput, +} from "./commands/StopSpeakerSearchTaskCommand"; +import { + StopVoiceToneAnalysisTaskCommand, + StopVoiceToneAnalysisTaskCommandInput, + StopVoiceToneAnalysisTaskCommandOutput, +} from "./commands/StopVoiceToneAnalysisTaskCommand"; import { TagResourceCommand, TagResourceCommandInput, TagResourceCommandOutput } from "./commands/TagResourceCommand"; import { UntagResourceCommand, @@ -107,10 +137,16 @@ const commands = { GetMediaCapturePipelineCommand, GetMediaInsightsPipelineConfigurationCommand, GetMediaPipelineCommand, + GetSpeakerSearchTaskCommand, + GetVoiceToneAnalysisTaskCommand, ListMediaCapturePipelinesCommand, ListMediaInsightsPipelineConfigurationsCommand, ListMediaPipelinesCommand, ListTagsForResourceCommand, + StartSpeakerSearchTaskCommand, + StartVoiceToneAnalysisTaskCommand, + StopSpeakerSearchTaskCommand, + StopVoiceToneAnalysisTaskCommand, TagResourceCommand, UntagResourceCommand, UpdateMediaInsightsPipelineConfigurationCommand, @@ -305,6 +341,40 @@ export interface ChimeSDKMediaPipelines { cb: (err: any, data?: GetMediaPipelineCommandOutput) => void ): void; + /** + * @see {@link GetSpeakerSearchTaskCommand} + */ + getSpeakerSearchTask( + args: GetSpeakerSearchTaskCommandInput, + options?: __HttpHandlerOptions + ): Promise; + getSpeakerSearchTask( + args: GetSpeakerSearchTaskCommandInput, + cb: (err: any, data?: GetSpeakerSearchTaskCommandOutput) => void + ): void; + getSpeakerSearchTask( + args: GetSpeakerSearchTaskCommandInput, + options: __HttpHandlerOptions, + cb: (err: any, data?: GetSpeakerSearchTaskCommandOutput) => void + ): void; + + /** + * @see {@link GetVoiceToneAnalysisTaskCommand} + */ + getVoiceToneAnalysisTask( + args: GetVoiceToneAnalysisTaskCommandInput, + options?: __HttpHandlerOptions + ): Promise; + getVoiceToneAnalysisTask( + args: GetVoiceToneAnalysisTaskCommandInput, + cb: (err: any, data?: GetVoiceToneAnalysisTaskCommandOutput) => void + ): void; + getVoiceToneAnalysisTask( + args: GetVoiceToneAnalysisTaskCommandInput, + options: __HttpHandlerOptions, + cb: (err: any, data?: GetVoiceToneAnalysisTaskCommandOutput) => void + ): void; + /** * @see {@link ListMediaCapturePipelinesCommand} */ @@ -373,6 +443,74 @@ export interface ChimeSDKMediaPipelines { cb: (err: any, data?: ListTagsForResourceCommandOutput) => void ): void; + /** + * @see {@link StartSpeakerSearchTaskCommand} + */ + startSpeakerSearchTask( + args: StartSpeakerSearchTaskCommandInput, + options?: __HttpHandlerOptions + ): Promise; + startSpeakerSearchTask( + args: StartSpeakerSearchTaskCommandInput, + cb: (err: any, data?: StartSpeakerSearchTaskCommandOutput) => void + ): void; + startSpeakerSearchTask( + args: StartSpeakerSearchTaskCommandInput, + options: __HttpHandlerOptions, + cb: (err: any, data?: StartSpeakerSearchTaskCommandOutput) => void + ): void; + + /** + * @see {@link StartVoiceToneAnalysisTaskCommand} + */ + startVoiceToneAnalysisTask( + args: StartVoiceToneAnalysisTaskCommandInput, + options?: __HttpHandlerOptions + ): Promise; + startVoiceToneAnalysisTask( + args: StartVoiceToneAnalysisTaskCommandInput, + cb: (err: any, data?: StartVoiceToneAnalysisTaskCommandOutput) => void + ): void; + startVoiceToneAnalysisTask( + args: StartVoiceToneAnalysisTaskCommandInput, + options: __HttpHandlerOptions, + cb: (err: any, data?: StartVoiceToneAnalysisTaskCommandOutput) => void + ): void; + + /** + * @see {@link StopSpeakerSearchTaskCommand} + */ + stopSpeakerSearchTask( + args: StopSpeakerSearchTaskCommandInput, + options?: __HttpHandlerOptions + ): Promise; + stopSpeakerSearchTask( + args: StopSpeakerSearchTaskCommandInput, + cb: (err: any, data?: StopSpeakerSearchTaskCommandOutput) => void + ): void; + stopSpeakerSearchTask( + args: StopSpeakerSearchTaskCommandInput, + options: __HttpHandlerOptions, + cb: (err: any, data?: StopSpeakerSearchTaskCommandOutput) => void + ): void; + + /** + * @see {@link StopVoiceToneAnalysisTaskCommand} + */ + stopVoiceToneAnalysisTask( + args: StopVoiceToneAnalysisTaskCommandInput, + options?: __HttpHandlerOptions + ): Promise; + stopVoiceToneAnalysisTask( + args: StopVoiceToneAnalysisTaskCommandInput, + cb: (err: any, data?: StopVoiceToneAnalysisTaskCommandOutput) => void + ): void; + stopVoiceToneAnalysisTask( + args: StopVoiceToneAnalysisTaskCommandInput, + options: __HttpHandlerOptions, + cb: (err: any, data?: StopVoiceToneAnalysisTaskCommandOutput) => void + ): void; + /** * @see {@link TagResourceCommand} */ diff --git a/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelinesClient.ts b/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelinesClient.ts index f1311e4d2cf0..7f292872dfd5 100644 --- a/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelinesClient.ts +++ b/clients/client-chime-sdk-media-pipelines/src/ChimeSDKMediaPipelinesClient.ts @@ -91,6 +91,14 @@ import { GetMediaInsightsPipelineConfigurationCommandOutput, } from "./commands/GetMediaInsightsPipelineConfigurationCommand"; import { GetMediaPipelineCommandInput, GetMediaPipelineCommandOutput } from "./commands/GetMediaPipelineCommand"; +import { + GetSpeakerSearchTaskCommandInput, + GetSpeakerSearchTaskCommandOutput, +} from "./commands/GetSpeakerSearchTaskCommand"; +import { + GetVoiceToneAnalysisTaskCommandInput, + GetVoiceToneAnalysisTaskCommandOutput, +} from "./commands/GetVoiceToneAnalysisTaskCommand"; import { ListMediaCapturePipelinesCommandInput, ListMediaCapturePipelinesCommandOutput, @@ -104,6 +112,22 @@ import { ListTagsForResourceCommandInput, ListTagsForResourceCommandOutput, } from "./commands/ListTagsForResourceCommand"; +import { + StartSpeakerSearchTaskCommandInput, + StartSpeakerSearchTaskCommandOutput, +} from "./commands/StartSpeakerSearchTaskCommand"; +import { + StartVoiceToneAnalysisTaskCommandInput, + StartVoiceToneAnalysisTaskCommandOutput, +} from "./commands/StartVoiceToneAnalysisTaskCommand"; +import { + StopSpeakerSearchTaskCommandInput, + StopSpeakerSearchTaskCommandOutput, +} from "./commands/StopSpeakerSearchTaskCommand"; +import { + StopVoiceToneAnalysisTaskCommandInput, + StopVoiceToneAnalysisTaskCommandOutput, +} from "./commands/StopVoiceToneAnalysisTaskCommand"; import { TagResourceCommandInput, TagResourceCommandOutput } from "./commands/TagResourceCommand"; import { UntagResourceCommandInput, UntagResourceCommandOutput } from "./commands/UntagResourceCommand"; import { @@ -140,10 +164,16 @@ export type ServiceInputTypes = | GetMediaCapturePipelineCommandInput | GetMediaInsightsPipelineConfigurationCommandInput | GetMediaPipelineCommandInput + | GetSpeakerSearchTaskCommandInput + | GetVoiceToneAnalysisTaskCommandInput | ListMediaCapturePipelinesCommandInput | ListMediaInsightsPipelineConfigurationsCommandInput | ListMediaPipelinesCommandInput | ListTagsForResourceCommandInput + | StartSpeakerSearchTaskCommandInput + | StartVoiceToneAnalysisTaskCommandInput + | StopSpeakerSearchTaskCommandInput + | StopVoiceToneAnalysisTaskCommandInput | TagResourceCommandInput | UntagResourceCommandInput | UpdateMediaInsightsPipelineConfigurationCommandInput @@ -164,10 +194,16 @@ export type ServiceOutputTypes = | GetMediaCapturePipelineCommandOutput | GetMediaInsightsPipelineConfigurationCommandOutput | GetMediaPipelineCommandOutput + | GetSpeakerSearchTaskCommandOutput + | GetVoiceToneAnalysisTaskCommandOutput | ListMediaCapturePipelinesCommandOutput | ListMediaInsightsPipelineConfigurationsCommandOutput | ListMediaPipelinesCommandOutput | ListTagsForResourceCommandOutput + | StartSpeakerSearchTaskCommandOutput + | StartVoiceToneAnalysisTaskCommandOutput + | StopSpeakerSearchTaskCommandOutput + | StopVoiceToneAnalysisTaskCommandOutput | TagResourceCommandOutput | UntagResourceCommandOutput | UpdateMediaInsightsPipelineConfigurationCommandOutput diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/DeleteMediaPipelineCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/DeleteMediaPipelineCommand.ts index f8c4c7c98fb9..2001342c65f1 100644 --- a/clients/client-chime-sdk-media-pipelines/src/commands/DeleteMediaPipelineCommand.ts +++ b/clients/client-chime-sdk-media-pipelines/src/commands/DeleteMediaPipelineCommand.ts @@ -65,6 +65,10 @@ export interface DeleteMediaPipelineCommandOutput extends __MetadataBearer {} * @throws {@link BadRequestException} (client fault) *

The input parameters don't match the service's restrictions.

* + * @throws {@link ConflictException} (client fault) + *

The request could not be processed because of conflict in the current state of the + * resource.

+ * * @throws {@link ForbiddenException} (client fault) *

The client is permanently forbidden from making the request.

* diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/GetSpeakerSearchTaskCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/GetSpeakerSearchTaskCommand.ts new file mode 100644 index 000000000000..8534316c276e --- /dev/null +++ b/clients/client-chime-sdk-media-pipelines/src/commands/GetSpeakerSearchTaskCommand.ts @@ -0,0 +1,173 @@ +// smithy-typescript generated code +import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint"; +import { getSerdePlugin } from "@smithy/middleware-serde"; +import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http"; +import { Command as $Command } from "@smithy/smithy-client"; +import { + FinalizeHandlerArguments, + Handler, + HandlerExecutionContext, + HttpHandlerOptions as __HttpHandlerOptions, + MetadataBearer as __MetadataBearer, + MiddlewareStack, + SerdeContext as __SerdeContext, +} from "@smithy/types"; + +import { + ChimeSDKMediaPipelinesClientResolvedConfig, + ServiceInputTypes, + ServiceOutputTypes, +} from "../ChimeSDKMediaPipelinesClient"; +import { GetSpeakerSearchTaskRequest, GetSpeakerSearchTaskResponse } from "../models/models_0"; +import { de_GetSpeakerSearchTaskCommand, se_GetSpeakerSearchTaskCommand } from "../protocols/Aws_restJson1"; + +/** + * @public + */ +export { __MetadataBearer, $Command }; +/** + * @public + * + * The input for {@link GetSpeakerSearchTaskCommand}. + */ +export interface GetSpeakerSearchTaskCommandInput extends GetSpeakerSearchTaskRequest {} +/** + * @public + * + * The output of {@link GetSpeakerSearchTaskCommand}. + */ +export interface GetSpeakerSearchTaskCommandOutput extends GetSpeakerSearchTaskResponse, __MetadataBearer {} + +/** + * @public + *

Retrieves the details of the specified speaker search task.

+ * @example + * Use a bare-bones client and the command you need to make an API call. + * ```javascript + * import { ChimeSDKMediaPipelinesClient, GetSpeakerSearchTaskCommand } from "@aws-sdk/client-chime-sdk-media-pipelines"; // ES Modules import + * // const { ChimeSDKMediaPipelinesClient, GetSpeakerSearchTaskCommand } = require("@aws-sdk/client-chime-sdk-media-pipelines"); // CommonJS import + * const client = new ChimeSDKMediaPipelinesClient(config); + * const input = { // GetSpeakerSearchTaskRequest + * Identifier: "STRING_VALUE", // required + * SpeakerSearchTaskId: "STRING_VALUE", // required + * }; + * const command = new GetSpeakerSearchTaskCommand(input); + * const response = await client.send(command); + * // { // GetSpeakerSearchTaskResponse + * // SpeakerSearchTask: { // SpeakerSearchTask + * // SpeakerSearchTaskId: "STRING_VALUE", + * // SpeakerSearchTaskStatus: "NotStarted" || "Initializing" || "InProgress" || "Failed" || "Stopping" || "Stopped", + * // CreatedTimestamp: new Date("TIMESTAMP"), + * // UpdatedTimestamp: new Date("TIMESTAMP"), + * // }, + * // }; + * + * ``` + * + * @param GetSpeakerSearchTaskCommandInput - {@link GetSpeakerSearchTaskCommandInput} + * @returns {@link GetSpeakerSearchTaskCommandOutput} + * @see {@link GetSpeakerSearchTaskCommandInput} for command's `input` shape. + * @see {@link GetSpeakerSearchTaskCommandOutput} for command's `response` shape. + * @see {@link ChimeSDKMediaPipelinesClientResolvedConfig | config} for ChimeSDKMediaPipelinesClient's `config` shape. + * + * @throws {@link BadRequestException} (client fault) + *

The input parameters don't match the service's restrictions.

+ * + * @throws {@link ForbiddenException} (client fault) + *

The client is permanently forbidden from making the request.

+ * + * @throws {@link NotFoundException} (client fault) + *

One or more of the resources in the request does not exist in the system.

+ * + * @throws {@link ServiceFailureException} (server fault) + *

The service encountered an unexpected error.

+ * + * @throws {@link ServiceUnavailableException} (server fault) + *

The service is currently unavailable.

+ * + * @throws {@link ThrottledClientException} (client fault) + *

The client exceeded its request rate limit.

+ * + * @throws {@link UnauthorizedClientException} (client fault) + *

The client is not currently authorized to make the request.

+ * + * @throws {@link ChimeSDKMediaPipelinesServiceException} + *

Base exception class for all service exceptions from ChimeSDKMediaPipelines service.

+ * + */ +export class GetSpeakerSearchTaskCommand extends $Command< + GetSpeakerSearchTaskCommandInput, + GetSpeakerSearchTaskCommandOutput, + ChimeSDKMediaPipelinesClientResolvedConfig +> { + // Start section: command_properties + // End section: command_properties + + public static getEndpointParameterInstructions(): EndpointParameterInstructions { + return { + UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, + Endpoint: { type: "builtInParams", name: "endpoint" }, + Region: { type: "builtInParams", name: "region" }, + UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }, + }; + } + + /** + * @public + */ + constructor(readonly input: GetSpeakerSearchTaskCommandInput) { + // Start section: command_constructor + super(); + // End section: command_constructor + } + + /** + * @internal + */ + resolveMiddleware( + clientStack: MiddlewareStack, + configuration: ChimeSDKMediaPipelinesClientResolvedConfig, + options?: __HttpHandlerOptions + ): Handler { + this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize)); + this.middlewareStack.use( + getEndpointPlugin(configuration, GetSpeakerSearchTaskCommand.getEndpointParameterInstructions()) + ); + + const stack = clientStack.concat(this.middlewareStack); + + const { logger } = configuration; + const clientName = "ChimeSDKMediaPipelinesClient"; + const commandName = "GetSpeakerSearchTaskCommand"; + const handlerExecutionContext: HandlerExecutionContext = { + logger, + clientName, + commandName, + inputFilterSensitiveLog: (_: any) => _, + outputFilterSensitiveLog: (_: any) => _, + }; + const { requestHandler } = configuration; + return stack.resolve( + (request: FinalizeHandlerArguments) => + requestHandler.handle(request.request as __HttpRequest, options || {}), + handlerExecutionContext + ); + } + + /** + * @internal + */ + private serialize(input: GetSpeakerSearchTaskCommandInput, context: __SerdeContext): Promise<__HttpRequest> { + return se_GetSpeakerSearchTaskCommand(input, context); + } + + /** + * @internal + */ + private deserialize(output: __HttpResponse, context: __SerdeContext): Promise { + return de_GetSpeakerSearchTaskCommand(output, context); + } + + // Start section: command_body_extra + // End section: command_body_extra +} diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/GetVoiceToneAnalysisTaskCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/GetVoiceToneAnalysisTaskCommand.ts new file mode 100644 index 000000000000..c35b58726147 --- /dev/null +++ b/clients/client-chime-sdk-media-pipelines/src/commands/GetVoiceToneAnalysisTaskCommand.ts @@ -0,0 +1,173 @@ +// smithy-typescript generated code +import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint"; +import { getSerdePlugin } from "@smithy/middleware-serde"; +import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http"; +import { Command as $Command } from "@smithy/smithy-client"; +import { + FinalizeHandlerArguments, + Handler, + HandlerExecutionContext, + HttpHandlerOptions as __HttpHandlerOptions, + MetadataBearer as __MetadataBearer, + MiddlewareStack, + SerdeContext as __SerdeContext, +} from "@smithy/types"; + +import { + ChimeSDKMediaPipelinesClientResolvedConfig, + ServiceInputTypes, + ServiceOutputTypes, +} from "../ChimeSDKMediaPipelinesClient"; +import { GetVoiceToneAnalysisTaskRequest, GetVoiceToneAnalysisTaskResponse } from "../models/models_0"; +import { de_GetVoiceToneAnalysisTaskCommand, se_GetVoiceToneAnalysisTaskCommand } from "../protocols/Aws_restJson1"; + +/** + * @public + */ +export { __MetadataBearer, $Command }; +/** + * @public + * + * The input for {@link GetVoiceToneAnalysisTaskCommand}. + */ +export interface GetVoiceToneAnalysisTaskCommandInput extends GetVoiceToneAnalysisTaskRequest {} +/** + * @public + * + * The output of {@link GetVoiceToneAnalysisTaskCommand}. + */ +export interface GetVoiceToneAnalysisTaskCommandOutput extends GetVoiceToneAnalysisTaskResponse, __MetadataBearer {} + +/** + * @public + *

Retrieves the details of a voice tone analysis task.

+ * @example + * Use a bare-bones client and the command you need to make an API call. + * ```javascript + * import { ChimeSDKMediaPipelinesClient, GetVoiceToneAnalysisTaskCommand } from "@aws-sdk/client-chime-sdk-media-pipelines"; // ES Modules import + * // const { ChimeSDKMediaPipelinesClient, GetVoiceToneAnalysisTaskCommand } = require("@aws-sdk/client-chime-sdk-media-pipelines"); // CommonJS import + * const client = new ChimeSDKMediaPipelinesClient(config); + * const input = { // GetVoiceToneAnalysisTaskRequest + * Identifier: "STRING_VALUE", // required + * VoiceToneAnalysisTaskId: "STRING_VALUE", // required + * }; + * const command = new GetVoiceToneAnalysisTaskCommand(input); + * const response = await client.send(command); + * // { // GetVoiceToneAnalysisTaskResponse + * // VoiceToneAnalysisTask: { // VoiceToneAnalysisTask + * // VoiceToneAnalysisTaskId: "STRING_VALUE", + * // VoiceToneAnalysisTaskStatus: "NotStarted" || "Initializing" || "InProgress" || "Failed" || "Stopping" || "Stopped", + * // CreatedTimestamp: new Date("TIMESTAMP"), + * // UpdatedTimestamp: new Date("TIMESTAMP"), + * // }, + * // }; + * + * ``` + * + * @param GetVoiceToneAnalysisTaskCommandInput - {@link GetVoiceToneAnalysisTaskCommandInput} + * @returns {@link GetVoiceToneAnalysisTaskCommandOutput} + * @see {@link GetVoiceToneAnalysisTaskCommandInput} for command's `input` shape. + * @see {@link GetVoiceToneAnalysisTaskCommandOutput} for command's `response` shape. + * @see {@link ChimeSDKMediaPipelinesClientResolvedConfig | config} for ChimeSDKMediaPipelinesClient's `config` shape. + * + * @throws {@link BadRequestException} (client fault) + *

The input parameters don't match the service's restrictions.

+ * + * @throws {@link ForbiddenException} (client fault) + *

The client is permanently forbidden from making the request.

+ * + * @throws {@link NotFoundException} (client fault) + *

One or more of the resources in the request does not exist in the system.

+ * + * @throws {@link ServiceFailureException} (server fault) + *

The service encountered an unexpected error.

+ * + * @throws {@link ServiceUnavailableException} (server fault) + *

The service is currently unavailable.

+ * + * @throws {@link ThrottledClientException} (client fault) + *

The client exceeded its request rate limit.

+ * + * @throws {@link UnauthorizedClientException} (client fault) + *

The client is not currently authorized to make the request.

+ * + * @throws {@link ChimeSDKMediaPipelinesServiceException} + *

Base exception class for all service exceptions from ChimeSDKMediaPipelines service.

+ * + */ +export class GetVoiceToneAnalysisTaskCommand extends $Command< + GetVoiceToneAnalysisTaskCommandInput, + GetVoiceToneAnalysisTaskCommandOutput, + ChimeSDKMediaPipelinesClientResolvedConfig +> { + // Start section: command_properties + // End section: command_properties + + public static getEndpointParameterInstructions(): EndpointParameterInstructions { + return { + UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, + Endpoint: { type: "builtInParams", name: "endpoint" }, + Region: { type: "builtInParams", name: "region" }, + UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }, + }; + } + + /** + * @public + */ + constructor(readonly input: GetVoiceToneAnalysisTaskCommandInput) { + // Start section: command_constructor + super(); + // End section: command_constructor + } + + /** + * @internal + */ + resolveMiddleware( + clientStack: MiddlewareStack, + configuration: ChimeSDKMediaPipelinesClientResolvedConfig, + options?: __HttpHandlerOptions + ): Handler { + this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize)); + this.middlewareStack.use( + getEndpointPlugin(configuration, GetVoiceToneAnalysisTaskCommand.getEndpointParameterInstructions()) + ); + + const stack = clientStack.concat(this.middlewareStack); + + const { logger } = configuration; + const clientName = "ChimeSDKMediaPipelinesClient"; + const commandName = "GetVoiceToneAnalysisTaskCommand"; + const handlerExecutionContext: HandlerExecutionContext = { + logger, + clientName, + commandName, + inputFilterSensitiveLog: (_: any) => _, + outputFilterSensitiveLog: (_: any) => _, + }; + const { requestHandler } = configuration; + return stack.resolve( + (request: FinalizeHandlerArguments) => + requestHandler.handle(request.request as __HttpRequest, options || {}), + handlerExecutionContext + ); + } + + /** + * @internal + */ + private serialize(input: GetVoiceToneAnalysisTaskCommandInput, context: __SerdeContext): Promise<__HttpRequest> { + return se_GetVoiceToneAnalysisTaskCommand(input, context); + } + + /** + * @internal + */ + private deserialize(output: __HttpResponse, context: __SerdeContext): Promise { + return de_GetVoiceToneAnalysisTaskCommand(output, context); + } + + // Start section: command_body_extra + // End section: command_body_extra +} diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/StartSpeakerSearchTaskCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/StartSpeakerSearchTaskCommand.ts new file mode 100644 index 000000000000..420ac49f0330 --- /dev/null +++ b/clients/client-chime-sdk-media-pipelines/src/commands/StartSpeakerSearchTaskCommand.ts @@ -0,0 +1,191 @@ +// smithy-typescript generated code +import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint"; +import { getSerdePlugin } from "@smithy/middleware-serde"; +import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http"; +import { Command as $Command } from "@smithy/smithy-client"; +import { + FinalizeHandlerArguments, + Handler, + HandlerExecutionContext, + HttpHandlerOptions as __HttpHandlerOptions, + MetadataBearer as __MetadataBearer, + MiddlewareStack, + SerdeContext as __SerdeContext, +} from "@smithy/types"; + +import { + ChimeSDKMediaPipelinesClientResolvedConfig, + ServiceInputTypes, + ServiceOutputTypes, +} from "../ChimeSDKMediaPipelinesClient"; +import { + StartSpeakerSearchTaskRequest, + StartSpeakerSearchTaskRequestFilterSensitiveLog, + StartSpeakerSearchTaskResponse, +} from "../models/models_0"; +import { de_StartSpeakerSearchTaskCommand, se_StartSpeakerSearchTaskCommand } from "../protocols/Aws_restJson1"; + +/** + * @public + */ +export { __MetadataBearer, $Command }; +/** + * @public + * + * The input for {@link StartSpeakerSearchTaskCommand}. + */ +export interface StartSpeakerSearchTaskCommandInput extends StartSpeakerSearchTaskRequest {} +/** + * @public + * + * The output of {@link StartSpeakerSearchTaskCommand}. + */ +export interface StartSpeakerSearchTaskCommandOutput extends StartSpeakerSearchTaskResponse, __MetadataBearer {} + +/** + * @public + *

Starts a speaker search task.

+ * + *

Before starting any speaker search tasks, you must provide all notices and obtain all consents from the speaker as required under applicable privacy and biometrics laws, and as required under the + * AWS service terms for the Amazon Chime SDK.

+ *
+ * @example + * Use a bare-bones client and the command you need to make an API call. + * ```javascript + * import { ChimeSDKMediaPipelinesClient, StartSpeakerSearchTaskCommand } from "@aws-sdk/client-chime-sdk-media-pipelines"; // ES Modules import + * // const { ChimeSDKMediaPipelinesClient, StartSpeakerSearchTaskCommand } = require("@aws-sdk/client-chime-sdk-media-pipelines"); // CommonJS import + * const client = new ChimeSDKMediaPipelinesClient(config); + * const input = { // StartSpeakerSearchTaskRequest + * Identifier: "STRING_VALUE", // required + * VoiceProfileDomainArn: "STRING_VALUE", // required + * KinesisVideoStreamSourceTaskConfiguration: { // KinesisVideoStreamSourceTaskConfiguration + * StreamArn: "STRING_VALUE", // required + * ChannelId: Number("int"), // required + * FragmentNumber: "STRING_VALUE", + * }, + * ClientRequestToken: "STRING_VALUE", + * }; + * const command = new StartSpeakerSearchTaskCommand(input); + * const response = await client.send(command); + * // { // StartSpeakerSearchTaskResponse + * // SpeakerSearchTask: { // SpeakerSearchTask + * // SpeakerSearchTaskId: "STRING_VALUE", + * // SpeakerSearchTaskStatus: "NotStarted" || "Initializing" || "InProgress" || "Failed" || "Stopping" || "Stopped", + * // CreatedTimestamp: new Date("TIMESTAMP"), + * // UpdatedTimestamp: new Date("TIMESTAMP"), + * // }, + * // }; + * + * ``` + * + * @param StartSpeakerSearchTaskCommandInput - {@link StartSpeakerSearchTaskCommandInput} + * @returns {@link StartSpeakerSearchTaskCommandOutput} + * @see {@link StartSpeakerSearchTaskCommandInput} for command's `input` shape. + * @see {@link StartSpeakerSearchTaskCommandOutput} for command's `response` shape. + * @see {@link ChimeSDKMediaPipelinesClientResolvedConfig | config} for ChimeSDKMediaPipelinesClient's `config` shape. + * + * @throws {@link BadRequestException} (client fault) + *

The input parameters don't match the service's restrictions.

+ * + * @throws {@link ConflictException} (client fault) + *

The request could not be processed because of conflict in the current state of the + * resource.

+ * + * @throws {@link ForbiddenException} (client fault) + *

The client is permanently forbidden from making the request.

+ * + * @throws {@link NotFoundException} (client fault) + *

One or more of the resources in the request does not exist in the system.

+ * + * @throws {@link ServiceFailureException} (server fault) + *

The service encountered an unexpected error.

+ * + * @throws {@link ServiceUnavailableException} (server fault) + *

The service is currently unavailable.

+ * + * @throws {@link ThrottledClientException} (client fault) + *

The client exceeded its request rate limit.

+ * + * @throws {@link UnauthorizedClientException} (client fault) + *

The client is not currently authorized to make the request.

+ * + * @throws {@link ChimeSDKMediaPipelinesServiceException} + *

Base exception class for all service exceptions from ChimeSDKMediaPipelines service.

+ * + */ +export class StartSpeakerSearchTaskCommand extends $Command< + StartSpeakerSearchTaskCommandInput, + StartSpeakerSearchTaskCommandOutput, + ChimeSDKMediaPipelinesClientResolvedConfig +> { + // Start section: command_properties + // End section: command_properties + + public static getEndpointParameterInstructions(): EndpointParameterInstructions { + return { + UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, + Endpoint: { type: "builtInParams", name: "endpoint" }, + Region: { type: "builtInParams", name: "region" }, + UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }, + }; + } + + /** + * @public + */ + constructor(readonly input: StartSpeakerSearchTaskCommandInput) { + // Start section: command_constructor + super(); + // End section: command_constructor + } + + /** + * @internal + */ + resolveMiddleware( + clientStack: MiddlewareStack, + configuration: ChimeSDKMediaPipelinesClientResolvedConfig, + options?: __HttpHandlerOptions + ): Handler { + this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize)); + this.middlewareStack.use( + getEndpointPlugin(configuration, StartSpeakerSearchTaskCommand.getEndpointParameterInstructions()) + ); + + const stack = clientStack.concat(this.middlewareStack); + + const { logger } = configuration; + const clientName = "ChimeSDKMediaPipelinesClient"; + const commandName = "StartSpeakerSearchTaskCommand"; + const handlerExecutionContext: HandlerExecutionContext = { + logger, + clientName, + commandName, + inputFilterSensitiveLog: StartSpeakerSearchTaskRequestFilterSensitiveLog, + outputFilterSensitiveLog: (_: any) => _, + }; + const { requestHandler } = configuration; + return stack.resolve( + (request: FinalizeHandlerArguments) => + requestHandler.handle(request.request as __HttpRequest, options || {}), + handlerExecutionContext + ); + } + + /** + * @internal + */ + private serialize(input: StartSpeakerSearchTaskCommandInput, context: __SerdeContext): Promise<__HttpRequest> { + return se_StartSpeakerSearchTaskCommand(input, context); + } + + /** + * @internal + */ + private deserialize(output: __HttpResponse, context: __SerdeContext): Promise { + return de_StartSpeakerSearchTaskCommand(output, context); + } + + // Start section: command_body_extra + // End section: command_body_extra +} diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/StartVoiceToneAnalysisTaskCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/StartVoiceToneAnalysisTaskCommand.ts new file mode 100644 index 000000000000..0f2bc77151f8 --- /dev/null +++ b/clients/client-chime-sdk-media-pipelines/src/commands/StartVoiceToneAnalysisTaskCommand.ts @@ -0,0 +1,196 @@ +// smithy-typescript generated code +import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint"; +import { getSerdePlugin } from "@smithy/middleware-serde"; +import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http"; +import { Command as $Command } from "@smithy/smithy-client"; +import { + FinalizeHandlerArguments, + Handler, + HandlerExecutionContext, + HttpHandlerOptions as __HttpHandlerOptions, + MetadataBearer as __MetadataBearer, + MiddlewareStack, + SerdeContext as __SerdeContext, +} from "@smithy/types"; + +import { + ChimeSDKMediaPipelinesClientResolvedConfig, + ServiceInputTypes, + ServiceOutputTypes, +} from "../ChimeSDKMediaPipelinesClient"; +import { + StartVoiceToneAnalysisTaskRequest, + StartVoiceToneAnalysisTaskRequestFilterSensitiveLog, + StartVoiceToneAnalysisTaskResponse, +} from "../models/models_0"; +import { de_StartVoiceToneAnalysisTaskCommand, se_StartVoiceToneAnalysisTaskCommand } from "../protocols/Aws_restJson1"; + +/** + * @public + */ +export { __MetadataBearer, $Command }; +/** + * @public + * + * The input for {@link StartVoiceToneAnalysisTaskCommand}. + */ +export interface StartVoiceToneAnalysisTaskCommandInput extends StartVoiceToneAnalysisTaskRequest {} +/** + * @public + * + * The output of {@link StartVoiceToneAnalysisTaskCommand}. + */ +export interface StartVoiceToneAnalysisTaskCommandOutput extends StartVoiceToneAnalysisTaskResponse, __MetadataBearer {} + +/** + * @public + *

Starts a voice tone analysis task. For more information about voice tone analysis, see + * Using Amazon Chime SDK voice analytics + * in the Amazon Chime SDK Developer Guide.

+ * + *

Before starting any voice tone analysis tasks, you must provide all notices and obtain all consents from the speaker as required under applicable privacy and biometrics laws, and as required under the + * AWS service terms for the Amazon Chime SDK.

+ *
+ * @example + * Use a bare-bones client and the command you need to make an API call. + * ```javascript + * import { ChimeSDKMediaPipelinesClient, StartVoiceToneAnalysisTaskCommand } from "@aws-sdk/client-chime-sdk-media-pipelines"; // ES Modules import + * // const { ChimeSDKMediaPipelinesClient, StartVoiceToneAnalysisTaskCommand } = require("@aws-sdk/client-chime-sdk-media-pipelines"); // CommonJS import + * const client = new ChimeSDKMediaPipelinesClient(config); + * const input = { // StartVoiceToneAnalysisTaskRequest + * Identifier: "STRING_VALUE", // required + * LanguageCode: "en-US", // required + * KinesisVideoStreamSourceTaskConfiguration: { // KinesisVideoStreamSourceTaskConfiguration + * StreamArn: "STRING_VALUE", // required + * ChannelId: Number("int"), // required + * FragmentNumber: "STRING_VALUE", + * }, + * ClientRequestToken: "STRING_VALUE", + * }; + * const command = new StartVoiceToneAnalysisTaskCommand(input); + * const response = await client.send(command); + * // { // StartVoiceToneAnalysisTaskResponse + * // VoiceToneAnalysisTask: { // VoiceToneAnalysisTask + * // VoiceToneAnalysisTaskId: "STRING_VALUE", + * // VoiceToneAnalysisTaskStatus: "NotStarted" || "Initializing" || "InProgress" || "Failed" || "Stopping" || "Stopped", + * // CreatedTimestamp: new Date("TIMESTAMP"), + * // UpdatedTimestamp: new Date("TIMESTAMP"), + * // }, + * // }; + * + * ``` + * + * @param StartVoiceToneAnalysisTaskCommandInput - {@link StartVoiceToneAnalysisTaskCommandInput} + * @returns {@link StartVoiceToneAnalysisTaskCommandOutput} + * @see {@link StartVoiceToneAnalysisTaskCommandInput} for command's `input` shape. + * @see {@link StartVoiceToneAnalysisTaskCommandOutput} for command's `response` shape. + * @see {@link ChimeSDKMediaPipelinesClientResolvedConfig | config} for ChimeSDKMediaPipelinesClient's `config` shape. + * + * @throws {@link BadRequestException} (client fault) + *

The input parameters don't match the service's restrictions.

+ * + * @throws {@link ConflictException} (client fault) + *

The request could not be processed because of conflict in the current state of the + * resource.

+ * + * @throws {@link ForbiddenException} (client fault) + *

The client is permanently forbidden from making the request.

+ * + * @throws {@link NotFoundException} (client fault) + *

One or more of the resources in the request does not exist in the system.

+ * + * @throws {@link ServiceFailureException} (server fault) + *

The service encountered an unexpected error.

+ * + * @throws {@link ServiceUnavailableException} (server fault) + *

The service is currently unavailable.

+ * + * @throws {@link ThrottledClientException} (client fault) + *

The client exceeded its request rate limit.

+ * + * @throws {@link UnauthorizedClientException} (client fault) + *

The client is not currently authorized to make the request.

+ * + * @throws {@link ChimeSDKMediaPipelinesServiceException} + *

Base exception class for all service exceptions from ChimeSDKMediaPipelines service.

+ * + */ +export class StartVoiceToneAnalysisTaskCommand extends $Command< + StartVoiceToneAnalysisTaskCommandInput, + StartVoiceToneAnalysisTaskCommandOutput, + ChimeSDKMediaPipelinesClientResolvedConfig +> { + // Start section: command_properties + // End section: command_properties + + public static getEndpointParameterInstructions(): EndpointParameterInstructions { + return { + UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, + Endpoint: { type: "builtInParams", name: "endpoint" }, + Region: { type: "builtInParams", name: "region" }, + UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }, + }; + } + + /** + * @public + */ + constructor(readonly input: StartVoiceToneAnalysisTaskCommandInput) { + // Start section: command_constructor + super(); + // End section: command_constructor + } + + /** + * @internal + */ + resolveMiddleware( + clientStack: MiddlewareStack, + configuration: ChimeSDKMediaPipelinesClientResolvedConfig, + options?: __HttpHandlerOptions + ): Handler { + this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize)); + this.middlewareStack.use( + getEndpointPlugin(configuration, StartVoiceToneAnalysisTaskCommand.getEndpointParameterInstructions()) + ); + + const stack = clientStack.concat(this.middlewareStack); + + const { logger } = configuration; + const clientName = "ChimeSDKMediaPipelinesClient"; + const commandName = "StartVoiceToneAnalysisTaskCommand"; + const handlerExecutionContext: HandlerExecutionContext = { + logger, + clientName, + commandName, + inputFilterSensitiveLog: StartVoiceToneAnalysisTaskRequestFilterSensitiveLog, + outputFilterSensitiveLog: (_: any) => _, + }; + const { requestHandler } = configuration; + return stack.resolve( + (request: FinalizeHandlerArguments) => + requestHandler.handle(request.request as __HttpRequest, options || {}), + handlerExecutionContext + ); + } + + /** + * @internal + */ + private serialize(input: StartVoiceToneAnalysisTaskCommandInput, context: __SerdeContext): Promise<__HttpRequest> { + return se_StartVoiceToneAnalysisTaskCommand(input, context); + } + + /** + * @internal + */ + private deserialize( + output: __HttpResponse, + context: __SerdeContext + ): Promise { + return de_StartVoiceToneAnalysisTaskCommand(output, context); + } + + // Start section: command_body_extra + // End section: command_body_extra +} diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/StopSpeakerSearchTaskCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/StopSpeakerSearchTaskCommand.ts new file mode 100644 index 000000000000..732c778fddfa --- /dev/null +++ b/clients/client-chime-sdk-media-pipelines/src/commands/StopSpeakerSearchTaskCommand.ts @@ -0,0 +1,170 @@ +// smithy-typescript generated code +import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint"; +import { getSerdePlugin } from "@smithy/middleware-serde"; +import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http"; +import { Command as $Command } from "@smithy/smithy-client"; +import { + FinalizeHandlerArguments, + Handler, + HandlerExecutionContext, + HttpHandlerOptions as __HttpHandlerOptions, + MetadataBearer as __MetadataBearer, + MiddlewareStack, + SerdeContext as __SerdeContext, +} from "@smithy/types"; + +import { + ChimeSDKMediaPipelinesClientResolvedConfig, + ServiceInputTypes, + ServiceOutputTypes, +} from "../ChimeSDKMediaPipelinesClient"; +import { StopSpeakerSearchTaskRequest } from "../models/models_0"; +import { de_StopSpeakerSearchTaskCommand, se_StopSpeakerSearchTaskCommand } from "../protocols/Aws_restJson1"; + +/** + * @public + */ +export { __MetadataBearer, $Command }; +/** + * @public + * + * The input for {@link StopSpeakerSearchTaskCommand}. + */ +export interface StopSpeakerSearchTaskCommandInput extends StopSpeakerSearchTaskRequest {} +/** + * @public + * + * The output of {@link StopSpeakerSearchTaskCommand}. + */ +export interface StopSpeakerSearchTaskCommandOutput extends __MetadataBearer {} + +/** + * @public + *

Stops a speaker search task.

+ * @example + * Use a bare-bones client and the command you need to make an API call. + * ```javascript + * import { ChimeSDKMediaPipelinesClient, StopSpeakerSearchTaskCommand } from "@aws-sdk/client-chime-sdk-media-pipelines"; // ES Modules import + * // const { ChimeSDKMediaPipelinesClient, StopSpeakerSearchTaskCommand } = require("@aws-sdk/client-chime-sdk-media-pipelines"); // CommonJS import + * const client = new ChimeSDKMediaPipelinesClient(config); + * const input = { // StopSpeakerSearchTaskRequest + * Identifier: "STRING_VALUE", // required + * SpeakerSearchTaskId: "STRING_VALUE", // required + * }; + * const command = new StopSpeakerSearchTaskCommand(input); + * const response = await client.send(command); + * // {}; + * + * ``` + * + * @param StopSpeakerSearchTaskCommandInput - {@link StopSpeakerSearchTaskCommandInput} + * @returns {@link StopSpeakerSearchTaskCommandOutput} + * @see {@link StopSpeakerSearchTaskCommandInput} for command's `input` shape. + * @see {@link StopSpeakerSearchTaskCommandOutput} for command's `response` shape. + * @see {@link ChimeSDKMediaPipelinesClientResolvedConfig | config} for ChimeSDKMediaPipelinesClient's `config` shape. + * + * @throws {@link BadRequestException} (client fault) + *

The input parameters don't match the service's restrictions.

+ * + * @throws {@link ConflictException} (client fault) + *

The request could not be processed because of conflict in the current state of the + * resource.

+ * + * @throws {@link ForbiddenException} (client fault) + *

The client is permanently forbidden from making the request.

+ * + * @throws {@link NotFoundException} (client fault) + *

One or more of the resources in the request does not exist in the system.

+ * + * @throws {@link ServiceFailureException} (server fault) + *

The service encountered an unexpected error.

+ * + * @throws {@link ServiceUnavailableException} (server fault) + *

The service is currently unavailable.

+ * + * @throws {@link ThrottledClientException} (client fault) + *

The client exceeded its request rate limit.

+ * + * @throws {@link UnauthorizedClientException} (client fault) + *

The client is not currently authorized to make the request.

+ * + * @throws {@link ChimeSDKMediaPipelinesServiceException} + *

Base exception class for all service exceptions from ChimeSDKMediaPipelines service.

+ * + */ +export class StopSpeakerSearchTaskCommand extends $Command< + StopSpeakerSearchTaskCommandInput, + StopSpeakerSearchTaskCommandOutput, + ChimeSDKMediaPipelinesClientResolvedConfig +> { + // Start section: command_properties + // End section: command_properties + + public static getEndpointParameterInstructions(): EndpointParameterInstructions { + return { + UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, + Endpoint: { type: "builtInParams", name: "endpoint" }, + Region: { type: "builtInParams", name: "region" }, + UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }, + }; + } + + /** + * @public + */ + constructor(readonly input: StopSpeakerSearchTaskCommandInput) { + // Start section: command_constructor + super(); + // End section: command_constructor + } + + /** + * @internal + */ + resolveMiddleware( + clientStack: MiddlewareStack, + configuration: ChimeSDKMediaPipelinesClientResolvedConfig, + options?: __HttpHandlerOptions + ): Handler { + this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize)); + this.middlewareStack.use( + getEndpointPlugin(configuration, StopSpeakerSearchTaskCommand.getEndpointParameterInstructions()) + ); + + const stack = clientStack.concat(this.middlewareStack); + + const { logger } = configuration; + const clientName = "ChimeSDKMediaPipelinesClient"; + const commandName = "StopSpeakerSearchTaskCommand"; + const handlerExecutionContext: HandlerExecutionContext = { + logger, + clientName, + commandName, + inputFilterSensitiveLog: (_: any) => _, + outputFilterSensitiveLog: (_: any) => _, + }; + const { requestHandler } = configuration; + return stack.resolve( + (request: FinalizeHandlerArguments) => + requestHandler.handle(request.request as __HttpRequest, options || {}), + handlerExecutionContext + ); + } + + /** + * @internal + */ + private serialize(input: StopSpeakerSearchTaskCommandInput, context: __SerdeContext): Promise<__HttpRequest> { + return se_StopSpeakerSearchTaskCommand(input, context); + } + + /** + * @internal + */ + private deserialize(output: __HttpResponse, context: __SerdeContext): Promise { + return de_StopSpeakerSearchTaskCommand(output, context); + } + + // Start section: command_body_extra + // End section: command_body_extra +} diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/StopVoiceToneAnalysisTaskCommand.ts b/clients/client-chime-sdk-media-pipelines/src/commands/StopVoiceToneAnalysisTaskCommand.ts new file mode 100644 index 000000000000..0fa066a05a81 --- /dev/null +++ b/clients/client-chime-sdk-media-pipelines/src/commands/StopVoiceToneAnalysisTaskCommand.ts @@ -0,0 +1,173 @@ +// smithy-typescript generated code +import { EndpointParameterInstructions, getEndpointPlugin } from "@smithy/middleware-endpoint"; +import { getSerdePlugin } from "@smithy/middleware-serde"; +import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http"; +import { Command as $Command } from "@smithy/smithy-client"; +import { + FinalizeHandlerArguments, + Handler, + HandlerExecutionContext, + HttpHandlerOptions as __HttpHandlerOptions, + MetadataBearer as __MetadataBearer, + MiddlewareStack, + SerdeContext as __SerdeContext, +} from "@smithy/types"; + +import { + ChimeSDKMediaPipelinesClientResolvedConfig, + ServiceInputTypes, + ServiceOutputTypes, +} from "../ChimeSDKMediaPipelinesClient"; +import { StopVoiceToneAnalysisTaskRequest } from "../models/models_0"; +import { de_StopVoiceToneAnalysisTaskCommand, se_StopVoiceToneAnalysisTaskCommand } from "../protocols/Aws_restJson1"; + +/** + * @public + */ +export { __MetadataBearer, $Command }; +/** + * @public + * + * The input for {@link StopVoiceToneAnalysisTaskCommand}. + */ +export interface StopVoiceToneAnalysisTaskCommandInput extends StopVoiceToneAnalysisTaskRequest {} +/** + * @public + * + * The output of {@link StopVoiceToneAnalysisTaskCommand}. + */ +export interface StopVoiceToneAnalysisTaskCommandOutput extends __MetadataBearer {} + +/** + * @public + *

Stops a voice tone analysis task.

+ * @example + * Use a bare-bones client and the command you need to make an API call. + * ```javascript + * import { ChimeSDKMediaPipelinesClient, StopVoiceToneAnalysisTaskCommand } from "@aws-sdk/client-chime-sdk-media-pipelines"; // ES Modules import + * // const { ChimeSDKMediaPipelinesClient, StopVoiceToneAnalysisTaskCommand } = require("@aws-sdk/client-chime-sdk-media-pipelines"); // CommonJS import + * const client = new ChimeSDKMediaPipelinesClient(config); + * const input = { // StopVoiceToneAnalysisTaskRequest + * Identifier: "STRING_VALUE", // required + * VoiceToneAnalysisTaskId: "STRING_VALUE", // required + * }; + * const command = new StopVoiceToneAnalysisTaskCommand(input); + * const response = await client.send(command); + * // {}; + * + * ``` + * + * @param StopVoiceToneAnalysisTaskCommandInput - {@link StopVoiceToneAnalysisTaskCommandInput} + * @returns {@link StopVoiceToneAnalysisTaskCommandOutput} + * @see {@link StopVoiceToneAnalysisTaskCommandInput} for command's `input` shape. + * @see {@link StopVoiceToneAnalysisTaskCommandOutput} for command's `response` shape. + * @see {@link ChimeSDKMediaPipelinesClientResolvedConfig | config} for ChimeSDKMediaPipelinesClient's `config` shape. + * + * @throws {@link BadRequestException} (client fault) + *

The input parameters don't match the service's restrictions.

+ * + * @throws {@link ConflictException} (client fault) + *

The request could not be processed because of conflict in the current state of the + * resource.

+ * + * @throws {@link ForbiddenException} (client fault) + *

The client is permanently forbidden from making the request.

+ * + * @throws {@link NotFoundException} (client fault) + *

One or more of the resources in the request does not exist in the system.

+ * + * @throws {@link ServiceFailureException} (server fault) + *

The service encountered an unexpected error.

+ * + * @throws {@link ServiceUnavailableException} (server fault) + *

The service is currently unavailable.

+ * + * @throws {@link ThrottledClientException} (client fault) + *

The client exceeded its request rate limit.

+ * + * @throws {@link UnauthorizedClientException} (client fault) + *

The client is not currently authorized to make the request.

+ * + * @throws {@link ChimeSDKMediaPipelinesServiceException} + *

Base exception class for all service exceptions from ChimeSDKMediaPipelines service.

+ * + */ +export class StopVoiceToneAnalysisTaskCommand extends $Command< + StopVoiceToneAnalysisTaskCommandInput, + StopVoiceToneAnalysisTaskCommandOutput, + ChimeSDKMediaPipelinesClientResolvedConfig +> { + // Start section: command_properties + // End section: command_properties + + public static getEndpointParameterInstructions(): EndpointParameterInstructions { + return { + UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, + Endpoint: { type: "builtInParams", name: "endpoint" }, + Region: { type: "builtInParams", name: "region" }, + UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }, + }; + } + + /** + * @public + */ + constructor(readonly input: StopVoiceToneAnalysisTaskCommandInput) { + // Start section: command_constructor + super(); + // End section: command_constructor + } + + /** + * @internal + */ + resolveMiddleware( + clientStack: MiddlewareStack, + configuration: ChimeSDKMediaPipelinesClientResolvedConfig, + options?: __HttpHandlerOptions + ): Handler { + this.middlewareStack.use(getSerdePlugin(configuration, this.serialize, this.deserialize)); + this.middlewareStack.use( + getEndpointPlugin(configuration, StopVoiceToneAnalysisTaskCommand.getEndpointParameterInstructions()) + ); + + const stack = clientStack.concat(this.middlewareStack); + + const { logger } = configuration; + const clientName = "ChimeSDKMediaPipelinesClient"; + const commandName = "StopVoiceToneAnalysisTaskCommand"; + const handlerExecutionContext: HandlerExecutionContext = { + logger, + clientName, + commandName, + inputFilterSensitiveLog: (_: any) => _, + outputFilterSensitiveLog: (_: any) => _, + }; + const { requestHandler } = configuration; + return stack.resolve( + (request: FinalizeHandlerArguments) => + requestHandler.handle(request.request as __HttpRequest, options || {}), + handlerExecutionContext + ); + } + + /** + * @internal + */ + private serialize(input: StopVoiceToneAnalysisTaskCommandInput, context: __SerdeContext): Promise<__HttpRequest> { + return se_StopVoiceToneAnalysisTaskCommand(input, context); + } + + /** + * @internal + */ + private deserialize( + output: __HttpResponse, + context: __SerdeContext + ): Promise { + return de_StopVoiceToneAnalysisTaskCommand(output, context); + } + + // Start section: command_body_extra + // End section: command_body_extra +} diff --git a/clients/client-chime-sdk-media-pipelines/src/commands/index.ts b/clients/client-chime-sdk-media-pipelines/src/commands/index.ts index 8c9298525373..ec2178c7623e 100644 --- a/clients/client-chime-sdk-media-pipelines/src/commands/index.ts +++ b/clients/client-chime-sdk-media-pipelines/src/commands/index.ts @@ -10,10 +10,16 @@ export * from "./DeleteMediaPipelineCommand"; export * from "./GetMediaCapturePipelineCommand"; export * from "./GetMediaInsightsPipelineConfigurationCommand"; export * from "./GetMediaPipelineCommand"; +export * from "./GetSpeakerSearchTaskCommand"; +export * from "./GetVoiceToneAnalysisTaskCommand"; export * from "./ListMediaCapturePipelinesCommand"; export * from "./ListMediaInsightsPipelineConfigurationsCommand"; export * from "./ListMediaPipelinesCommand"; export * from "./ListTagsForResourceCommand"; +export * from "./StartSpeakerSearchTaskCommand"; +export * from "./StartVoiceToneAnalysisTaskCommand"; +export * from "./StopSpeakerSearchTaskCommand"; +export * from "./StopVoiceToneAnalysisTaskCommand"; export * from "./TagResourceCommand"; export * from "./UntagResourceCommand"; export * from "./UpdateMediaInsightsPipelineConfigurationCommand"; diff --git a/clients/client-chime-sdk-media-pipelines/src/models/models_0.ts b/clients/client-chime-sdk-media-pipelines/src/models/models_0.ts index 116c46e0a5d7..0b17dc878d32 100644 --- a/clients/client-chime-sdk-media-pipelines/src/models/models_0.ts +++ b/clients/client-chime-sdk-media-pipelines/src/models/models_0.ts @@ -1804,7 +1804,7 @@ export interface FragmentSelector { /** * @public *

The origin of the timestamps to use, Server or Producer. For more information, see - * StartSelectorType in the Amazon Kinesis Video Streams Developer Guide.

+ * StartSelectorType in the Amazon Kinesis Video Streams Developer Guide.

*/ FragmentSelectorType: FragmentSelectorType | string | undefined; @@ -2348,7 +2348,7 @@ export interface MediaInsightsPipelineConfigurationElement { /** * @public - *

The configuration settings for the VoiceEnhancementSinkConfiguration element.

+ *

The configuration settings for voice enhancement sink in a media insights pipeline configuration element.

*/ VoiceEnhancementSinkConfiguration?: VoiceEnhancementSinkConfiguration; } @@ -2976,6 +2976,141 @@ export interface GetMediaPipelineResponse { MediaPipeline?: MediaPipeline; } +/** + * @public + */ +export interface GetSpeakerSearchTaskRequest { + /** + * @public + *

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

+ */ + Identifier: string | undefined; + + /** + * @public + *

The ID of the speaker search task.

+ */ + SpeakerSearchTaskId: string | undefined; +} + +/** + * @public + * @enum + */ +export const MediaPipelineTaskStatus = { + Failed: "Failed", + InProgress: "InProgress", + Initializing: "Initializing", + NotStarted: "NotStarted", + Stopped: "Stopped", + Stopping: "Stopping", +} as const; + +/** + * @public + */ +export type MediaPipelineTaskStatus = (typeof MediaPipelineTaskStatus)[keyof typeof MediaPipelineTaskStatus]; + +/** + * @public + *

A representation of an asynchronous request to perform speaker search analysis on a + * media insights pipeline.

+ */ +export interface SpeakerSearchTask { + /** + * @public + *

The speaker search task ID.

+ */ + SpeakerSearchTaskId?: string; + + /** + * @public + *

The status of the speaker search task.

+ */ + SpeakerSearchTaskStatus?: MediaPipelineTaskStatus | string; + + /** + * @public + *

The time at which a speaker search task was created.

+ */ + CreatedTimestamp?: Date; + + /** + * @public + *

The time at which a speaker search task was updated.

+ */ + UpdatedTimestamp?: Date; +} + +/** + * @public + */ +export interface GetSpeakerSearchTaskResponse { + /** + * @public + *

The details of the speaker search task.

+ */ + SpeakerSearchTask?: SpeakerSearchTask; +} + +/** + * @public + */ +export interface GetVoiceToneAnalysisTaskRequest { + /** + * @public + *

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

+ */ + Identifier: string | undefined; + + /** + * @public + *

The ID of the voice tone anlysis task.

+ */ + VoiceToneAnalysisTaskId: string | undefined; +} + +/** + * @public + *

A representation of an asynchronous request to perform voice tone analysis on a media insights pipeline.

+ */ +export interface VoiceToneAnalysisTask { + /** + * @public + *

The ID of the voice tone analysis task.

+ */ + VoiceToneAnalysisTaskId?: string; + + /** + * @public + *

The status of a voice tone analysis task.

+ */ + VoiceToneAnalysisTaskStatus?: MediaPipelineTaskStatus | string; + + /** + * @public + *

The time at which a voice tone analysis task was created.

+ */ + CreatedTimestamp?: Date; + + /** + * @public + *

The time at which a voice tone analysis task was updated.

+ */ + UpdatedTimestamp?: Date; +} + +/** + * @public + */ +export interface GetVoiceToneAnalysisTaskResponse { + /** + * @public + *

The details of the voice tone analysis task.

+ */ + VoiceToneAnalysisTask?: VoiceToneAnalysisTask; +} + /** * @public */ @@ -3160,6 +3295,159 @@ export interface ListTagsForResourceResponse { Tags?: Tag[]; } +/** + * @public + *

The task configuration settings for the Kinesis video stream source.

+ */ +export interface KinesisVideoStreamSourceTaskConfiguration { + /** + * @public + *

The ARN of the stream.

+ */ + StreamArn: string | undefined; + + /** + * @public + *

The channel ID.

+ */ + ChannelId: number | undefined; + + /** + * @public + *

The unique identifier of the fragment to begin processing.

+ */ + FragmentNumber?: string; +} + +/** + * @public + */ +export interface StartSpeakerSearchTaskRequest { + /** + * @public + *

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

+ */ + Identifier: string | undefined; + + /** + * @public + *

The ARN of the voice profile domain that will store the voice profile.

+ */ + VoiceProfileDomainArn: string | undefined; + + /** + * @public + *

The task configuration for the Kinesis video stream source of the media insights + * pipeline.

+ */ + KinesisVideoStreamSourceTaskConfiguration?: KinesisVideoStreamSourceTaskConfiguration; + + /** + * @public + *

The unique identifier for the client request. Use a different token for different speaker search tasks.

+ */ + ClientRequestToken?: string; +} + +/** + * @public + */ +export interface StartSpeakerSearchTaskResponse { + /** + * @public + *

The details of the speaker search task.

+ */ + SpeakerSearchTask?: SpeakerSearchTask; +} + +/** + * @public + * @enum + */ +export const VoiceAnalyticsLanguageCode = { + EN_US: "en-US", +} as const; + +/** + * @public + */ +export type VoiceAnalyticsLanguageCode = (typeof VoiceAnalyticsLanguageCode)[keyof typeof VoiceAnalyticsLanguageCode]; + +/** + * @public + */ +export interface StartVoiceToneAnalysisTaskRequest { + /** + * @public + *

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

+ */ + Identifier: string | undefined; + + /** + * @public + *

The language code.

+ */ + LanguageCode: VoiceAnalyticsLanguageCode | string | undefined; + + /** + * @public + *

The task configuration for the Kinesis video stream source of the media insights + * pipeline.

+ */ + KinesisVideoStreamSourceTaskConfiguration?: KinesisVideoStreamSourceTaskConfiguration; + + /** + * @public + *

The unique identifier for the client request. Use a different token for different voice tone analysis tasks.

+ */ + ClientRequestToken?: string; +} + +/** + * @public + */ +export interface StartVoiceToneAnalysisTaskResponse { + /** + * @public + *

The details of the voice tone analysis task.

+ */ + VoiceToneAnalysisTask?: VoiceToneAnalysisTask; +} + +/** + * @public + */ +export interface StopSpeakerSearchTaskRequest { + /** + * @public + *

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

+ */ + Identifier: string | undefined; + + /** + * @public + *

The speaker search task ID.

+ */ + SpeakerSearchTaskId: string | undefined; +} + +/** + * @public + */ +export interface StopVoiceToneAnalysisTaskRequest { + /** + * @public + *

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

+ */ + Identifier: string | undefined; + + /** + * @public + *

The ID of the voice tone analysis task.

+ */ + VoiceToneAnalysisTaskId: string | undefined; +} + /** * @public */ @@ -3722,6 +4010,23 @@ export const ListMediaInsightsPipelineConfigurationsResponseFilterSensitiveLog = }), }); +/** + * @internal + */ +export const StartSpeakerSearchTaskRequestFilterSensitiveLog = (obj: StartSpeakerSearchTaskRequest): any => ({ + ...obj, + ...(obj.VoiceProfileDomainArn && { VoiceProfileDomainArn: SENSITIVE_STRING }), + ...(obj.ClientRequestToken && { ClientRequestToken: SENSITIVE_STRING }), +}); + +/** + * @internal + */ +export const StartVoiceToneAnalysisTaskRequestFilterSensitiveLog = (obj: StartVoiceToneAnalysisTaskRequest): any => ({ + ...obj, + ...(obj.ClientRequestToken && { ClientRequestToken: SENSITIVE_STRING }), +}); + /** * @internal */ diff --git a/clients/client-chime-sdk-media-pipelines/src/protocols/Aws_restJson1.ts b/clients/client-chime-sdk-media-pipelines/src/protocols/Aws_restJson1.ts index 664bfddd7b55..af7de975287b 100644 --- a/clients/client-chime-sdk-media-pipelines/src/protocols/Aws_restJson1.ts +++ b/clients/client-chime-sdk-media-pipelines/src/protocols/Aws_restJson1.ts @@ -64,6 +64,14 @@ import { GetMediaInsightsPipelineConfigurationCommandOutput, } from "../commands/GetMediaInsightsPipelineConfigurationCommand"; import { GetMediaPipelineCommandInput, GetMediaPipelineCommandOutput } from "../commands/GetMediaPipelineCommand"; +import { + GetSpeakerSearchTaskCommandInput, + GetSpeakerSearchTaskCommandOutput, +} from "../commands/GetSpeakerSearchTaskCommand"; +import { + GetVoiceToneAnalysisTaskCommandInput, + GetVoiceToneAnalysisTaskCommandOutput, +} from "../commands/GetVoiceToneAnalysisTaskCommand"; import { ListMediaCapturePipelinesCommandInput, ListMediaCapturePipelinesCommandOutput, @@ -77,6 +85,22 @@ import { ListTagsForResourceCommandInput, ListTagsForResourceCommandOutput, } from "../commands/ListTagsForResourceCommand"; +import { + StartSpeakerSearchTaskCommandInput, + StartSpeakerSearchTaskCommandOutput, +} from "../commands/StartSpeakerSearchTaskCommand"; +import { + StartVoiceToneAnalysisTaskCommandInput, + StartVoiceToneAnalysisTaskCommandOutput, +} from "../commands/StartVoiceToneAnalysisTaskCommand"; +import { + StopSpeakerSearchTaskCommandInput, + StopSpeakerSearchTaskCommandOutput, +} from "../commands/StopSpeakerSearchTaskCommand"; +import { + StopVoiceToneAnalysisTaskCommandInput, + StopVoiceToneAnalysisTaskCommandOutput, +} from "../commands/StopVoiceToneAnalysisTaskCommand"; import { TagResourceCommandInput, TagResourceCommandOutput } from "../commands/TagResourceCommand"; import { UntagResourceCommandInput, UntagResourceCommandOutput } from "../commands/UntagResourceCommand"; import { @@ -118,6 +142,7 @@ import { KinesisDataStreamSinkConfiguration, KinesisVideoStreamRecordingSourceRuntimeConfiguration, KinesisVideoStreamSourceRuntimeConfiguration, + KinesisVideoStreamSourceTaskConfiguration, LambdaFunctionSinkConfiguration, LiveConnectorRTMPConfiguration, LiveConnectorSinkConfiguration, @@ -147,6 +172,7 @@ import { ServiceUnavailableException, SnsTopicSinkConfiguration, SourceConfiguration, + SpeakerSearchTask, SqsQueueSinkConfiguration, StreamChannelDefinition, StreamConfiguration, @@ -161,6 +187,7 @@ import { VideoConcatenationConfiguration, VoiceAnalyticsProcessorConfiguration, VoiceEnhancementSinkConfiguration, + VoiceToneAnalysisTask, } from "../models/models_0"; /** @@ -513,6 +540,72 @@ export const se_GetMediaPipelineCommand = async ( }); }; +/** + * serializeAws_restJson1GetSpeakerSearchTaskCommand + */ +export const se_GetSpeakerSearchTaskCommand = async ( + input: GetSpeakerSearchTaskCommandInput, + context: __SerdeContext +): Promise<__HttpRequest> => { + const { hostname, protocol = "https", port, path: basePath } = await context.endpoint(); + const headers: any = {}; + let resolvedPath = + `${basePath?.endsWith("/") ? basePath.slice(0, -1) : basePath || ""}` + + "/media-insights-pipelines/{Identifier}/speaker-search-tasks/{SpeakerSearchTaskId}"; + resolvedPath = __resolvedPath(resolvedPath, input, "Identifier", () => input.Identifier!, "{Identifier}", false); + resolvedPath = __resolvedPath( + resolvedPath, + input, + "SpeakerSearchTaskId", + () => input.SpeakerSearchTaskId!, + "{SpeakerSearchTaskId}", + false + ); + let body: any; + return new __HttpRequest({ + protocol, + hostname, + port, + method: "GET", + headers, + path: resolvedPath, + body, + }); +}; + +/** + * serializeAws_restJson1GetVoiceToneAnalysisTaskCommand + */ +export const se_GetVoiceToneAnalysisTaskCommand = async ( + input: GetVoiceToneAnalysisTaskCommandInput, + context: __SerdeContext +): Promise<__HttpRequest> => { + const { hostname, protocol = "https", port, path: basePath } = await context.endpoint(); + const headers: any = {}; + let resolvedPath = + `${basePath?.endsWith("/") ? basePath.slice(0, -1) : basePath || ""}` + + "/media-insights-pipelines/{Identifier}/voice-tone-analysis-tasks/{VoiceToneAnalysisTaskId}"; + resolvedPath = __resolvedPath(resolvedPath, input, "Identifier", () => input.Identifier!, "{Identifier}", false); + resolvedPath = __resolvedPath( + resolvedPath, + input, + "VoiceToneAnalysisTaskId", + () => input.VoiceToneAnalysisTaskId!, + "{VoiceToneAnalysisTaskId}", + false + ); + let body: any; + return new __HttpRequest({ + protocol, + hostname, + port, + method: "GET", + headers, + path: resolvedPath, + body, + }); +}; + /** * serializeAws_restJson1ListMediaCapturePipelinesCommand */ @@ -622,6 +715,156 @@ export const se_ListTagsForResourceCommand = async ( }); }; +/** + * serializeAws_restJson1StartSpeakerSearchTaskCommand + */ +export const se_StartSpeakerSearchTaskCommand = async ( + input: StartSpeakerSearchTaskCommandInput, + context: __SerdeContext +): Promise<__HttpRequest> => { + const { hostname, protocol = "https", port, path: basePath } = await context.endpoint(); + const headers: any = { + "content-type": "application/json", + }; + let resolvedPath = + `${basePath?.endsWith("/") ? basePath.slice(0, -1) : basePath || ""}` + + "/media-insights-pipelines/{Identifier}/speaker-search-tasks"; + resolvedPath = __resolvedPath(resolvedPath, input, "Identifier", () => input.Identifier!, "{Identifier}", false); + const query: any = map({ + operation: [, "start"], + }); + let body: any; + body = JSON.stringify( + take(input, { + ClientRequestToken: [true, (_) => _ ?? generateIdempotencyToken()], + KinesisVideoStreamSourceTaskConfiguration: (_) => _json(_), + VoiceProfileDomainArn: [], + }) + ); + return new __HttpRequest({ + protocol, + hostname, + port, + method: "POST", + headers, + path: resolvedPath, + query, + body, + }); +}; + +/** + * serializeAws_restJson1StartVoiceToneAnalysisTaskCommand + */ +export const se_StartVoiceToneAnalysisTaskCommand = async ( + input: StartVoiceToneAnalysisTaskCommandInput, + context: __SerdeContext +): Promise<__HttpRequest> => { + const { hostname, protocol = "https", port, path: basePath } = await context.endpoint(); + const headers: any = { + "content-type": "application/json", + }; + let resolvedPath = + `${basePath?.endsWith("/") ? basePath.slice(0, -1) : basePath || ""}` + + "/media-insights-pipelines/{Identifier}/voice-tone-analysis-tasks"; + resolvedPath = __resolvedPath(resolvedPath, input, "Identifier", () => input.Identifier!, "{Identifier}", false); + const query: any = map({ + operation: [, "start"], + }); + let body: any; + body = JSON.stringify( + take(input, { + ClientRequestToken: [true, (_) => _ ?? generateIdempotencyToken()], + KinesisVideoStreamSourceTaskConfiguration: (_) => _json(_), + LanguageCode: [], + }) + ); + return new __HttpRequest({ + protocol, + hostname, + port, + method: "POST", + headers, + path: resolvedPath, + query, + body, + }); +}; + +/** + * serializeAws_restJson1StopSpeakerSearchTaskCommand + */ +export const se_StopSpeakerSearchTaskCommand = async ( + input: StopSpeakerSearchTaskCommandInput, + context: __SerdeContext +): Promise<__HttpRequest> => { + const { hostname, protocol = "https", port, path: basePath } = await context.endpoint(); + const headers: any = {}; + let resolvedPath = + `${basePath?.endsWith("/") ? basePath.slice(0, -1) : basePath || ""}` + + "/media-insights-pipelines/{Identifier}/speaker-search-tasks/{SpeakerSearchTaskId}"; + resolvedPath = __resolvedPath(resolvedPath, input, "Identifier", () => input.Identifier!, "{Identifier}", false); + resolvedPath = __resolvedPath( + resolvedPath, + input, + "SpeakerSearchTaskId", + () => input.SpeakerSearchTaskId!, + "{SpeakerSearchTaskId}", + false + ); + const query: any = map({ + operation: [, "stop"], + }); + let body: any; + return new __HttpRequest({ + protocol, + hostname, + port, + method: "POST", + headers, + path: resolvedPath, + query, + body, + }); +}; + +/** + * serializeAws_restJson1StopVoiceToneAnalysisTaskCommand + */ +export const se_StopVoiceToneAnalysisTaskCommand = async ( + input: StopVoiceToneAnalysisTaskCommandInput, + context: __SerdeContext +): Promise<__HttpRequest> => { + const { hostname, protocol = "https", port, path: basePath } = await context.endpoint(); + const headers: any = {}; + let resolvedPath = + `${basePath?.endsWith("/") ? basePath.slice(0, -1) : basePath || ""}` + + "/media-insights-pipelines/{Identifier}/voice-tone-analysis-tasks/{VoiceToneAnalysisTaskId}"; + resolvedPath = __resolvedPath(resolvedPath, input, "Identifier", () => input.Identifier!, "{Identifier}", false); + resolvedPath = __resolvedPath( + resolvedPath, + input, + "VoiceToneAnalysisTaskId", + () => input.VoiceToneAnalysisTaskId!, + "{VoiceToneAnalysisTaskId}", + false + ); + const query: any = map({ + operation: [, "stop"], + }); + let body: any; + return new __HttpRequest({ + protocol, + hostname, + port, + method: "POST", + headers, + path: resolvedPath, + query, + body, + }); +}; + /** * serializeAws_restJson1TagResourceCommand */ @@ -1245,6 +1488,9 @@ const de_DeleteMediaPipelineCommandError = async ( case "BadRequestException": case "com.amazonaws.chimesdkmediapipelines#BadRequestException": throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ConflictException": + case "com.amazonaws.chimesdkmediapipelines#ConflictException": + throw await de_ConflictExceptionRes(parsedOutput, context); case "ForbiddenException": case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": throw await de_ForbiddenExceptionRes(parsedOutput, context); @@ -1469,34 +1715,33 @@ const de_GetMediaPipelineCommandError = async ( }; /** - * deserializeAws_restJson1ListMediaCapturePipelinesCommand + * deserializeAws_restJson1GetSpeakerSearchTaskCommand */ -export const de_ListMediaCapturePipelinesCommand = async ( +export const de_GetSpeakerSearchTaskCommand = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { if (output.statusCode !== 200 && output.statusCode >= 300) { - return de_ListMediaCapturePipelinesCommandError(output, context); + return de_GetSpeakerSearchTaskCommandError(output, context); } const contents: any = map({ $metadata: deserializeMetadata(output), }); const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); const doc = take(data, { - MediaCapturePipelines: _json, - NextToken: __expectString, + SpeakerSearchTask: (_) => de_SpeakerSearchTask(_, context), }); Object.assign(contents, doc); return contents; }; /** - * deserializeAws_restJson1ListMediaCapturePipelinesCommandError + * deserializeAws_restJson1GetSpeakerSearchTaskCommandError */ -const de_ListMediaCapturePipelinesCommandError = async ( +const de_GetSpeakerSearchTaskCommandError = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { const parsedOutput: any = { ...output, body: await parseErrorBody(output.body, context), @@ -1509,9 +1754,9 @@ const de_ListMediaCapturePipelinesCommandError = async ( case "ForbiddenException": case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": throw await de_ForbiddenExceptionRes(parsedOutput, context); - case "ResourceLimitExceededException": - case "com.amazonaws.chimesdkmediapipelines#ResourceLimitExceededException": - throw await de_ResourceLimitExceededExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); case "ServiceFailureException": case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": throw await de_ServiceFailureExceptionRes(parsedOutput, context); @@ -1535,34 +1780,33 @@ const de_ListMediaCapturePipelinesCommandError = async ( }; /** - * deserializeAws_restJson1ListMediaInsightsPipelineConfigurationsCommand + * deserializeAws_restJson1GetVoiceToneAnalysisTaskCommand */ -export const de_ListMediaInsightsPipelineConfigurationsCommand = async ( +export const de_GetVoiceToneAnalysisTaskCommand = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { if (output.statusCode !== 200 && output.statusCode >= 300) { - return de_ListMediaInsightsPipelineConfigurationsCommandError(output, context); + return de_GetVoiceToneAnalysisTaskCommandError(output, context); } const contents: any = map({ $metadata: deserializeMetadata(output), }); const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); const doc = take(data, { - MediaInsightsPipelineConfigurations: _json, - NextToken: __expectString, + VoiceToneAnalysisTask: (_) => de_VoiceToneAnalysisTask(_, context), }); Object.assign(contents, doc); return contents; }; /** - * deserializeAws_restJson1ListMediaInsightsPipelineConfigurationsCommandError + * deserializeAws_restJson1GetVoiceToneAnalysisTaskCommandError */ -const de_ListMediaInsightsPipelineConfigurationsCommandError = async ( +const de_GetVoiceToneAnalysisTaskCommandError = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { const parsedOutput: any = { ...output, body: await parseErrorBody(output.body, context), @@ -1575,9 +1819,9 @@ const de_ListMediaInsightsPipelineConfigurationsCommandError = async ( case "ForbiddenException": case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": throw await de_ForbiddenExceptionRes(parsedOutput, context); - case "ResourceLimitExceededException": - case "com.amazonaws.chimesdkmediapipelines#ResourceLimitExceededException": - throw await de_ResourceLimitExceededExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); case "ServiceFailureException": case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": throw await de_ServiceFailureExceptionRes(parsedOutput, context); @@ -1601,21 +1845,21 @@ const de_ListMediaInsightsPipelineConfigurationsCommandError = async ( }; /** - * deserializeAws_restJson1ListMediaPipelinesCommand + * deserializeAws_restJson1ListMediaCapturePipelinesCommand */ -export const de_ListMediaPipelinesCommand = async ( +export const de_ListMediaCapturePipelinesCommand = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { if (output.statusCode !== 200 && output.statusCode >= 300) { - return de_ListMediaPipelinesCommandError(output, context); + return de_ListMediaCapturePipelinesCommandError(output, context); } const contents: any = map({ $metadata: deserializeMetadata(output), }); const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); const doc = take(data, { - MediaPipelines: _json, + MediaCapturePipelines: _json, NextToken: __expectString, }); Object.assign(contents, doc); @@ -1623,12 +1867,12 @@ export const de_ListMediaPipelinesCommand = async ( }; /** - * deserializeAws_restJson1ListMediaPipelinesCommandError + * deserializeAws_restJson1ListMediaCapturePipelinesCommandError */ -const de_ListMediaPipelinesCommandError = async ( +const de_ListMediaCapturePipelinesCommandError = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { const parsedOutput: any = { ...output, body: await parseErrorBody(output.body, context), @@ -1667,33 +1911,34 @@ const de_ListMediaPipelinesCommandError = async ( }; /** - * deserializeAws_restJson1ListTagsForResourceCommand + * deserializeAws_restJson1ListMediaInsightsPipelineConfigurationsCommand */ -export const de_ListTagsForResourceCommand = async ( +export const de_ListMediaInsightsPipelineConfigurationsCommand = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { if (output.statusCode !== 200 && output.statusCode >= 300) { - return de_ListTagsForResourceCommandError(output, context); + return de_ListMediaInsightsPipelineConfigurationsCommandError(output, context); } const contents: any = map({ $metadata: deserializeMetadata(output), }); const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); const doc = take(data, { - Tags: _json, + MediaInsightsPipelineConfigurations: _json, + NextToken: __expectString, }); Object.assign(contents, doc); return contents; }; /** - * deserializeAws_restJson1ListTagsForResourceCommandError + * deserializeAws_restJson1ListMediaInsightsPipelineConfigurationsCommandError */ -const de_ListTagsForResourceCommandError = async ( +const de_ListMediaInsightsPipelineConfigurationsCommandError = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { +): Promise => { const parsedOutput: any = { ...output, body: await parseErrorBody(output.body, context), @@ -1706,9 +1951,9 @@ const de_ListTagsForResourceCommandError = async ( case "ForbiddenException": case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": throw await de_ForbiddenExceptionRes(parsedOutput, context); - case "NotFoundException": - case "com.amazonaws.chimesdkmediapipelines#NotFoundException": - throw await de_NotFoundExceptionRes(parsedOutput, context); + case "ResourceLimitExceededException": + case "com.amazonaws.chimesdkmediapipelines#ResourceLimitExceededException": + throw await de_ResourceLimitExceededExceptionRes(parsedOutput, context); case "ServiceFailureException": case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": throw await de_ServiceFailureExceptionRes(parsedOutput, context); @@ -1732,13 +1977,408 @@ const de_ListTagsForResourceCommandError = async ( }; /** - * deserializeAws_restJson1TagResourceCommand + * deserializeAws_restJson1ListMediaPipelinesCommand */ -export const de_TagResourceCommand = async ( +export const de_ListMediaPipelinesCommand = async ( output: __HttpResponse, context: __SerdeContext -): Promise => { - if (output.statusCode !== 204 && output.statusCode >= 300) { +): Promise => { + if (output.statusCode !== 200 && output.statusCode >= 300) { + return de_ListMediaPipelinesCommandError(output, context); + } + const contents: any = map({ + $metadata: deserializeMetadata(output), + }); + const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); + const doc = take(data, { + MediaPipelines: _json, + NextToken: __expectString, + }); + Object.assign(contents, doc); + return contents; +}; + +/** + * deserializeAws_restJson1ListMediaPipelinesCommandError + */ +const de_ListMediaPipelinesCommandError = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + const parsedOutput: any = { + ...output, + body: await parseErrorBody(output.body, context), + }; + const errorCode = loadRestJsonErrorCode(output, parsedOutput.body); + switch (errorCode) { + case "BadRequestException": + case "com.amazonaws.chimesdkmediapipelines#BadRequestException": + throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ForbiddenException": + case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": + throw await de_ForbiddenExceptionRes(parsedOutput, context); + case "ResourceLimitExceededException": + case "com.amazonaws.chimesdkmediapipelines#ResourceLimitExceededException": + throw await de_ResourceLimitExceededExceptionRes(parsedOutput, context); + case "ServiceFailureException": + case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": + throw await de_ServiceFailureExceptionRes(parsedOutput, context); + case "ServiceUnavailableException": + case "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException": + throw await de_ServiceUnavailableExceptionRes(parsedOutput, context); + case "ThrottledClientException": + case "com.amazonaws.chimesdkmediapipelines#ThrottledClientException": + throw await de_ThrottledClientExceptionRes(parsedOutput, context); + case "UnauthorizedClientException": + case "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException": + throw await de_UnauthorizedClientExceptionRes(parsedOutput, context); + default: + const parsedBody = parsedOutput.body; + return throwDefaultError({ + output, + parsedBody, + errorCode, + }); + } +}; + +/** + * deserializeAws_restJson1ListTagsForResourceCommand + */ +export const de_ListTagsForResourceCommand = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + if (output.statusCode !== 200 && output.statusCode >= 300) { + return de_ListTagsForResourceCommandError(output, context); + } + const contents: any = map({ + $metadata: deserializeMetadata(output), + }); + const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); + const doc = take(data, { + Tags: _json, + }); + Object.assign(contents, doc); + return contents; +}; + +/** + * deserializeAws_restJson1ListTagsForResourceCommandError + */ +const de_ListTagsForResourceCommandError = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + const parsedOutput: any = { + ...output, + body: await parseErrorBody(output.body, context), + }; + const errorCode = loadRestJsonErrorCode(output, parsedOutput.body); + switch (errorCode) { + case "BadRequestException": + case "com.amazonaws.chimesdkmediapipelines#BadRequestException": + throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ForbiddenException": + case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": + throw await de_ForbiddenExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); + case "ServiceFailureException": + case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": + throw await de_ServiceFailureExceptionRes(parsedOutput, context); + case "ServiceUnavailableException": + case "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException": + throw await de_ServiceUnavailableExceptionRes(parsedOutput, context); + case "ThrottledClientException": + case "com.amazonaws.chimesdkmediapipelines#ThrottledClientException": + throw await de_ThrottledClientExceptionRes(parsedOutput, context); + case "UnauthorizedClientException": + case "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException": + throw await de_UnauthorizedClientExceptionRes(parsedOutput, context); + default: + const parsedBody = parsedOutput.body; + return throwDefaultError({ + output, + parsedBody, + errorCode, + }); + } +}; + +/** + * deserializeAws_restJson1StartSpeakerSearchTaskCommand + */ +export const de_StartSpeakerSearchTaskCommand = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + if (output.statusCode !== 201 && output.statusCode >= 300) { + return de_StartSpeakerSearchTaskCommandError(output, context); + } + const contents: any = map({ + $metadata: deserializeMetadata(output), + }); + const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); + const doc = take(data, { + SpeakerSearchTask: (_) => de_SpeakerSearchTask(_, context), + }); + Object.assign(contents, doc); + return contents; +}; + +/** + * deserializeAws_restJson1StartSpeakerSearchTaskCommandError + */ +const de_StartSpeakerSearchTaskCommandError = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + const parsedOutput: any = { + ...output, + body: await parseErrorBody(output.body, context), + }; + const errorCode = loadRestJsonErrorCode(output, parsedOutput.body); + switch (errorCode) { + case "BadRequestException": + case "com.amazonaws.chimesdkmediapipelines#BadRequestException": + throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ConflictException": + case "com.amazonaws.chimesdkmediapipelines#ConflictException": + throw await de_ConflictExceptionRes(parsedOutput, context); + case "ForbiddenException": + case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": + throw await de_ForbiddenExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); + case "ServiceFailureException": + case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": + throw await de_ServiceFailureExceptionRes(parsedOutput, context); + case "ServiceUnavailableException": + case "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException": + throw await de_ServiceUnavailableExceptionRes(parsedOutput, context); + case "ThrottledClientException": + case "com.amazonaws.chimesdkmediapipelines#ThrottledClientException": + throw await de_ThrottledClientExceptionRes(parsedOutput, context); + case "UnauthorizedClientException": + case "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException": + throw await de_UnauthorizedClientExceptionRes(parsedOutput, context); + default: + const parsedBody = parsedOutput.body; + return throwDefaultError({ + output, + parsedBody, + errorCode, + }); + } +}; + +/** + * deserializeAws_restJson1StartVoiceToneAnalysisTaskCommand + */ +export const de_StartVoiceToneAnalysisTaskCommand = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + if (output.statusCode !== 201 && output.statusCode >= 300) { + return de_StartVoiceToneAnalysisTaskCommandError(output, context); + } + const contents: any = map({ + $metadata: deserializeMetadata(output), + }); + const data: Record = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body"); + const doc = take(data, { + VoiceToneAnalysisTask: (_) => de_VoiceToneAnalysisTask(_, context), + }); + Object.assign(contents, doc); + return contents; +}; + +/** + * deserializeAws_restJson1StartVoiceToneAnalysisTaskCommandError + */ +const de_StartVoiceToneAnalysisTaskCommandError = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + const parsedOutput: any = { + ...output, + body: await parseErrorBody(output.body, context), + }; + const errorCode = loadRestJsonErrorCode(output, parsedOutput.body); + switch (errorCode) { + case "BadRequestException": + case "com.amazonaws.chimesdkmediapipelines#BadRequestException": + throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ConflictException": + case "com.amazonaws.chimesdkmediapipelines#ConflictException": + throw await de_ConflictExceptionRes(parsedOutput, context); + case "ForbiddenException": + case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": + throw await de_ForbiddenExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); + case "ServiceFailureException": + case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": + throw await de_ServiceFailureExceptionRes(parsedOutput, context); + case "ServiceUnavailableException": + case "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException": + throw await de_ServiceUnavailableExceptionRes(parsedOutput, context); + case "ThrottledClientException": + case "com.amazonaws.chimesdkmediapipelines#ThrottledClientException": + throw await de_ThrottledClientExceptionRes(parsedOutput, context); + case "UnauthorizedClientException": + case "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException": + throw await de_UnauthorizedClientExceptionRes(parsedOutput, context); + default: + const parsedBody = parsedOutput.body; + return throwDefaultError({ + output, + parsedBody, + errorCode, + }); + } +}; + +/** + * deserializeAws_restJson1StopSpeakerSearchTaskCommand + */ +export const de_StopSpeakerSearchTaskCommand = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + if (output.statusCode !== 204 && output.statusCode >= 300) { + return de_StopSpeakerSearchTaskCommandError(output, context); + } + const contents: any = map({ + $metadata: deserializeMetadata(output), + }); + await collectBody(output.body, context); + return contents; +}; + +/** + * deserializeAws_restJson1StopSpeakerSearchTaskCommandError + */ +const de_StopSpeakerSearchTaskCommandError = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + const parsedOutput: any = { + ...output, + body: await parseErrorBody(output.body, context), + }; + const errorCode = loadRestJsonErrorCode(output, parsedOutput.body); + switch (errorCode) { + case "BadRequestException": + case "com.amazonaws.chimesdkmediapipelines#BadRequestException": + throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ConflictException": + case "com.amazonaws.chimesdkmediapipelines#ConflictException": + throw await de_ConflictExceptionRes(parsedOutput, context); + case "ForbiddenException": + case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": + throw await de_ForbiddenExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); + case "ServiceFailureException": + case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": + throw await de_ServiceFailureExceptionRes(parsedOutput, context); + case "ServiceUnavailableException": + case "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException": + throw await de_ServiceUnavailableExceptionRes(parsedOutput, context); + case "ThrottledClientException": + case "com.amazonaws.chimesdkmediapipelines#ThrottledClientException": + throw await de_ThrottledClientExceptionRes(parsedOutput, context); + case "UnauthorizedClientException": + case "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException": + throw await de_UnauthorizedClientExceptionRes(parsedOutput, context); + default: + const parsedBody = parsedOutput.body; + return throwDefaultError({ + output, + parsedBody, + errorCode, + }); + } +}; + +/** + * deserializeAws_restJson1StopVoiceToneAnalysisTaskCommand + */ +export const de_StopVoiceToneAnalysisTaskCommand = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + if (output.statusCode !== 204 && output.statusCode >= 300) { + return de_StopVoiceToneAnalysisTaskCommandError(output, context); + } + const contents: any = map({ + $metadata: deserializeMetadata(output), + }); + await collectBody(output.body, context); + return contents; +}; + +/** + * deserializeAws_restJson1StopVoiceToneAnalysisTaskCommandError + */ +const de_StopVoiceToneAnalysisTaskCommandError = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + const parsedOutput: any = { + ...output, + body: await parseErrorBody(output.body, context), + }; + const errorCode = loadRestJsonErrorCode(output, parsedOutput.body); + switch (errorCode) { + case "BadRequestException": + case "com.amazonaws.chimesdkmediapipelines#BadRequestException": + throw await de_BadRequestExceptionRes(parsedOutput, context); + case "ConflictException": + case "com.amazonaws.chimesdkmediapipelines#ConflictException": + throw await de_ConflictExceptionRes(parsedOutput, context); + case "ForbiddenException": + case "com.amazonaws.chimesdkmediapipelines#ForbiddenException": + throw await de_ForbiddenExceptionRes(parsedOutput, context); + case "NotFoundException": + case "com.amazonaws.chimesdkmediapipelines#NotFoundException": + throw await de_NotFoundExceptionRes(parsedOutput, context); + case "ServiceFailureException": + case "com.amazonaws.chimesdkmediapipelines#ServiceFailureException": + throw await de_ServiceFailureExceptionRes(parsedOutput, context); + case "ServiceUnavailableException": + case "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException": + throw await de_ServiceUnavailableExceptionRes(parsedOutput, context); + case "ThrottledClientException": + case "com.amazonaws.chimesdkmediapipelines#ThrottledClientException": + throw await de_ThrottledClientExceptionRes(parsedOutput, context); + case "UnauthorizedClientException": + case "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException": + throw await de_UnauthorizedClientExceptionRes(parsedOutput, context); + default: + const parsedBody = parsedOutput.body; + return throwDefaultError({ + output, + parsedBody, + errorCode, + }); + } +}; + +/** + * deserializeAws_restJson1TagResourceCommand + */ +export const de_TagResourceCommand = async ( + output: __HttpResponse, + context: __SerdeContext +): Promise => { + if (output.statusCode !== 204 && output.statusCode >= 300) { return de_TagResourceCommandError(output, context); } const contents: any = map({ @@ -2257,6 +2897,8 @@ const se_KinesisVideoStreamRecordingSourceRuntimeConfiguration = ( // se_KinesisVideoStreamSourceRuntimeConfiguration omitted. +// se_KinesisVideoStreamSourceTaskConfiguration omitted. + // se_LambdaFunctionSinkConfiguration omitted. // se_LiveConnectorRTMPConfiguration omitted. @@ -2594,6 +3236,18 @@ const de_MediaPipeline = (output: any, context: __SerdeContext): MediaPipeline = // de_SourceConfiguration omitted. +/** + * deserializeAws_restJson1SpeakerSearchTask + */ +const de_SpeakerSearchTask = (output: any, context: __SerdeContext): SpeakerSearchTask => { + return take(output, { + CreatedTimestamp: (_: any) => __expectNonNull(__parseRfc3339DateTimeWithOffset(_)), + SpeakerSearchTaskId: __expectString, + SpeakerSearchTaskStatus: __expectString, + UpdatedTimestamp: (_: any) => __expectNonNull(__parseRfc3339DateTimeWithOffset(_)), + }) as any; +}; + // de_SqsQueueSinkConfiguration omitted. // de_StreamChannelDefinition omitted. @@ -2630,6 +3284,18 @@ const de_TimestampRange = (output: any, context: __SerdeContext): TimestampRange // de_VoiceEnhancementSinkConfiguration omitted. +/** + * deserializeAws_restJson1VoiceToneAnalysisTask + */ +const de_VoiceToneAnalysisTask = (output: any, context: __SerdeContext): VoiceToneAnalysisTask => { + return take(output, { + CreatedTimestamp: (_: any) => __expectNonNull(__parseRfc3339DateTimeWithOffset(_)), + UpdatedTimestamp: (_: any) => __expectNonNull(__parseRfc3339DateTimeWithOffset(_)), + VoiceToneAnalysisTaskId: __expectString, + VoiceToneAnalysisTaskStatus: __expectString, + }) as any; +}; + const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({ httpStatusCode: output.statusCode, requestId: diff --git a/codegen/sdk-codegen/aws-models/chime-sdk-media-pipelines.json b/codegen/sdk-codegen/aws-models/chime-sdk-media-pipelines.json index ad6f8405c7ab..47616dbd3dd2 100644 --- a/codegen/sdk-codegen/aws-models/chime-sdk-media-pipelines.json +++ b/codegen/sdk-codegen/aws-models/chime-sdk-media-pipelines.json @@ -777,6 +777,12 @@ { "target": "com.amazonaws.chimesdkmediapipelines#GetMediaPipeline" }, + { + "target": "com.amazonaws.chimesdkmediapipelines#GetSpeakerSearchTask" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#GetVoiceToneAnalysisTask" + }, { "target": "com.amazonaws.chimesdkmediapipelines#ListMediaCapturePipelines" }, @@ -789,6 +795,18 @@ { "target": "com.amazonaws.chimesdkmediapipelines#ListTagsForResource" }, + { + "target": "com.amazonaws.chimesdkmediapipelines#StartSpeakerSearchTask" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#StartVoiceToneAnalysisTask" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#StopSpeakerSearchTask" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#StopVoiceToneAnalysisTask" + }, { "target": "com.amazonaws.chimesdkmediapipelines#TagResource" }, @@ -2489,6 +2507,9 @@ { "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ConflictException" + }, { "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" }, @@ -2639,7 +2660,7 @@ "FragmentSelectorType": { "target": "com.amazonaws.chimesdkmediapipelines#FragmentSelectorType", "traits": { - "smithy.api#documentation": "

The origin of the timestamps to use, Server or Producer. For more information, see \n StartSelectorType in the Amazon Kinesis Video Streams Developer Guide.

", + "smithy.api#documentation": "

The origin of the timestamps to use, Server or Producer. For more information, see \n StartSelectorType in the Amazon Kinesis Video Streams Developer Guide.

", "smithy.api#required": {} } }, @@ -2882,6 +2903,162 @@ "smithy.api#output": {} } }, + "com.amazonaws.chimesdkmediapipelines#GetSpeakerSearchTask": { + "type": "operation", + "input": { + "target": "com.amazonaws.chimesdkmediapipelines#GetSpeakerSearchTaskRequest" + }, + "output": { + "target": "com.amazonaws.chimesdkmediapipelines#GetSpeakerSearchTaskResponse" + }, + "errors": [ + { + "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#NotFoundException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceFailureException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ThrottledClientException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException" + } + ], + "traits": { + "smithy.api#documentation": "

Retrieves the details of the specified speaker search task.

", + "smithy.api#http": { + "method": "GET", + "uri": "/media-insights-pipelines/{Identifier}/speaker-search-tasks/{SpeakerSearchTaskId}", + "code": 200 + } + } + }, + "com.amazonaws.chimesdkmediapipelines#GetSpeakerSearchTaskRequest": { + "type": "structure", + "members": { + "Identifier": { + "target": "com.amazonaws.chimesdkmediapipelines#NonEmptyString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + }, + "SpeakerSearchTaskId": { + "target": "com.amazonaws.chimesdkmediapipelines#GuidString", + "traits": { + "smithy.api#documentation": "

The ID of the speaker search task.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#input": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#GetSpeakerSearchTaskResponse": { + "type": "structure", + "members": { + "SpeakerSearchTask": { + "target": "com.amazonaws.chimesdkmediapipelines#SpeakerSearchTask", + "traits": { + "smithy.api#documentation": "

The details of the speaker search task.

" + } + } + }, + "traits": { + "smithy.api#output": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#GetVoiceToneAnalysisTask": { + "type": "operation", + "input": { + "target": "com.amazonaws.chimesdkmediapipelines#GetVoiceToneAnalysisTaskRequest" + }, + "output": { + "target": "com.amazonaws.chimesdkmediapipelines#GetVoiceToneAnalysisTaskResponse" + }, + "errors": [ + { + "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#NotFoundException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceFailureException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ThrottledClientException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException" + } + ], + "traits": { + "smithy.api#documentation": "

Retrieves the details of a voice tone analysis task.

", + "smithy.api#http": { + "method": "GET", + "uri": "/media-insights-pipelines/{Identifier}/voice-tone-analysis-tasks/{VoiceToneAnalysisTaskId}", + "code": 200 + } + } + }, + "com.amazonaws.chimesdkmediapipelines#GetVoiceToneAnalysisTaskRequest": { + "type": "structure", + "members": { + "Identifier": { + "target": "com.amazonaws.chimesdkmediapipelines#NonEmptyString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + }, + "VoiceToneAnalysisTaskId": { + "target": "com.amazonaws.chimesdkmediapipelines#GuidString", + "traits": { + "smithy.api#documentation": "

The ID of the voice tone anlysis task.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#input": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#GetVoiceToneAnalysisTaskResponse": { + "type": "structure", + "members": { + "VoiceToneAnalysisTask": { + "target": "com.amazonaws.chimesdkmediapipelines#VoiceToneAnalysisTask", + "traits": { + "smithy.api#documentation": "

The details of the voice tone analysis task.

" + } + } + }, + "traits": { + "smithy.api#output": {} + } + }, "com.amazonaws.chimesdkmediapipelines#GridViewConfiguration": { "type": "structure", "members": { @@ -3180,6 +3357,35 @@ "smithy.api#documentation": "

The runtime configuration settings for the Kinesis video stream source.

" } }, + "com.amazonaws.chimesdkmediapipelines#KinesisVideoStreamSourceTaskConfiguration": { + "type": "structure", + "members": { + "StreamArn": { + "target": "com.amazonaws.chimesdkmediapipelines#KinesisVideoStreamArn", + "traits": { + "smithy.api#documentation": "

The ARN of the stream.

", + "smithy.api#required": {} + } + }, + "ChannelId": { + "target": "com.amazonaws.chimesdkmediapipelines#ChannelId", + "traits": { + "smithy.api#default": 0, + "smithy.api#documentation": "

The channel ID.

", + "smithy.api#required": {} + } + }, + "FragmentNumber": { + "target": "com.amazonaws.chimesdkmediapipelines#FragmentNumberString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the fragment to begin processing.

" + } + } + }, + "traits": { + "smithy.api#documentation": "

The task configuration settings for the Kinesis video stream source.

" + } + }, "com.amazonaws.chimesdkmediapipelines#LambdaFunctionSinkConfiguration": { "type": "structure", "members": { @@ -4042,7 +4248,7 @@ "VoiceEnhancementSinkConfiguration": { "target": "com.amazonaws.chimesdkmediapipelines#VoiceEnhancementSinkConfiguration", "traits": { - "smithy.api#documentation": "

The configuration settings for the VoiceEnhancementSinkConfiguration element.

" + "smithy.api#documentation": "

The configuration settings for voice enhancement sink in a media insights pipeline configuration element.

" } } }, @@ -4442,6 +4648,47 @@ "smithy.api#documentation": "

The summary of the media pipeline.

" } }, + "com.amazonaws.chimesdkmediapipelines#MediaPipelineTaskStatus": { + "type": "enum", + "members": { + "NotStarted": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "NotStarted" + } + }, + "Initializing": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "Initializing" + } + }, + "InProgress": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "InProgress" + } + }, + "Failed": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "Failed" + } + }, + "Stopping": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "Stopping" + } + }, + "Stopped": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "Stopped" + } + } + } + }, "com.amazonaws.chimesdkmediapipelines#MediaSampleRateHertz": { "type": "integer", "traits": { @@ -5044,52 +5291,404 @@ "smithy.api#documentation": "

Source configuration for a specified media pipeline.

" } }, - "com.amazonaws.chimesdkmediapipelines#SqsQueueSinkConfiguration": { + "com.amazonaws.chimesdkmediapipelines#SpeakerSearchTask": { "type": "structure", "members": { - "InsightsTarget": { - "target": "com.amazonaws.chimesdkmediapipelines#Arn", + "SpeakerSearchTaskId": { + "target": "com.amazonaws.chimesdkmediapipelines#GuidString", "traits": { - "smithy.api#documentation": "

The ARN of the SQS sink.

" + "smithy.api#documentation": "

The speaker search task ID.

" } - } - }, - "traits": { - "smithy.api#documentation": "

The configuration settings for the SQS sink.

" - } - }, - "com.amazonaws.chimesdkmediapipelines#StreamChannelDefinition": { - "type": "structure", - "members": { - "NumberOfChannels": { - "target": "com.amazonaws.chimesdkmediapipelines#NumberOfChannels", + }, + "SpeakerSearchTaskStatus": { + "target": "com.amazonaws.chimesdkmediapipelines#MediaPipelineTaskStatus", "traits": { - "smithy.api#documentation": "

The number of channels in a streaming channel.

", - "smithy.api#required": {} + "smithy.api#documentation": "

The status of the speaker search task.

" } }, - "ChannelDefinitions": { - "target": "com.amazonaws.chimesdkmediapipelines#ChannelDefinitions", + "CreatedTimestamp": { + "target": "com.amazonaws.chimesdkmediapipelines#Iso8601Timestamp", "traits": { - "smithy.api#documentation": "

The definitions of the channels in a streaming channel.

" + "smithy.api#documentation": "

The time at which a speaker search task was created.

" + } + }, + "UpdatedTimestamp": { + "target": "com.amazonaws.chimesdkmediapipelines#Iso8601Timestamp", + "traits": { + "smithy.api#documentation": "

The time at which a speaker search task was updated.

" } } }, "traits": { - "smithy.api#documentation": "

Defines a streaming channel.

" + "smithy.api#documentation": "

A representation of an asynchronous request to perform speaker search analysis on a\n media insights pipeline.

" } }, - "com.amazonaws.chimesdkmediapipelines#StreamConfiguration": { + "com.amazonaws.chimesdkmediapipelines#SqsQueueSinkConfiguration": { "type": "structure", "members": { - "StreamArn": { - "target": "com.amazonaws.chimesdkmediapipelines#KinesisVideoStreamArn", + "InsightsTarget": { + "target": "com.amazonaws.chimesdkmediapipelines#Arn", "traits": { - "smithy.api#documentation": "

The ARN of the stream.

", - "smithy.api#required": {} + "smithy.api#documentation": "

The ARN of the SQS sink.

" } - }, - "FragmentNumber": { + } + }, + "traits": { + "smithy.api#documentation": "

The configuration settings for the SQS sink.

" + } + }, + "com.amazonaws.chimesdkmediapipelines#StartSpeakerSearchTask": { + "type": "operation", + "input": { + "target": "com.amazonaws.chimesdkmediapipelines#StartSpeakerSearchTaskRequest" + }, + "output": { + "target": "com.amazonaws.chimesdkmediapipelines#StartSpeakerSearchTaskResponse" + }, + "errors": [ + { + "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ConflictException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#NotFoundException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceFailureException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ThrottledClientException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException" + } + ], + "traits": { + "smithy.api#documentation": "

Starts a speaker search task.

\n \n

Before starting any speaker search tasks, you must provide all notices and obtain all consents from the speaker as required under applicable privacy and biometrics laws, and as required under the\n AWS service terms for the Amazon Chime SDK.

\n
", + "smithy.api#http": { + "method": "POST", + "uri": "/media-insights-pipelines/{Identifier}/speaker-search-tasks?operation=start", + "code": 201 + } + } + }, + "com.amazonaws.chimesdkmediapipelines#StartSpeakerSearchTaskRequest": { + "type": "structure", + "members": { + "Identifier": { + "target": "com.amazonaws.chimesdkmediapipelines#NonEmptyString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + }, + "VoiceProfileDomainArn": { + "target": "com.amazonaws.chimesdkmediapipelines#Arn", + "traits": { + "smithy.api#documentation": "

The ARN of the voice profile domain that will store the voice profile.

", + "smithy.api#required": {} + } + }, + "KinesisVideoStreamSourceTaskConfiguration": { + "target": "com.amazonaws.chimesdkmediapipelines#KinesisVideoStreamSourceTaskConfiguration", + "traits": { + "smithy.api#documentation": "

The task configuration for the Kinesis video stream source of the media insights\n pipeline.

" + } + }, + "ClientRequestToken": { + "target": "com.amazonaws.chimesdkmediapipelines#ClientRequestToken", + "traits": { + "smithy.api#documentation": "

The unique identifier for the client request. Use a different token for different speaker search tasks.

", + "smithy.api#idempotencyToken": {} + } + } + }, + "traits": { + "smithy.api#input": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#StartSpeakerSearchTaskResponse": { + "type": "structure", + "members": { + "SpeakerSearchTask": { + "target": "com.amazonaws.chimesdkmediapipelines#SpeakerSearchTask", + "traits": { + "smithy.api#documentation": "

The details of the speaker search task.

" + } + } + }, + "traits": { + "smithy.api#output": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#StartVoiceToneAnalysisTask": { + "type": "operation", + "input": { + "target": "com.amazonaws.chimesdkmediapipelines#StartVoiceToneAnalysisTaskRequest" + }, + "output": { + "target": "com.amazonaws.chimesdkmediapipelines#StartVoiceToneAnalysisTaskResponse" + }, + "errors": [ + { + "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ConflictException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#NotFoundException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceFailureException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ThrottledClientException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException" + } + ], + "traits": { + "smithy.api#documentation": "

Starts a voice tone analysis task. For more information about voice tone analysis, see\n Using Amazon Chime SDK voice analytics\n in the Amazon Chime SDK Developer Guide.

\n \n

Before starting any voice tone analysis tasks, you must provide all notices and obtain all consents from the speaker as required under applicable privacy and biometrics laws, and as required under the\n AWS service terms for the Amazon Chime SDK.

\n
", + "smithy.api#http": { + "method": "POST", + "uri": "/media-insights-pipelines/{Identifier}/voice-tone-analysis-tasks?operation=start", + "code": 201 + } + } + }, + "com.amazonaws.chimesdkmediapipelines#StartVoiceToneAnalysisTaskRequest": { + "type": "structure", + "members": { + "Identifier": { + "target": "com.amazonaws.chimesdkmediapipelines#NonEmptyString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + }, + "LanguageCode": { + "target": "com.amazonaws.chimesdkmediapipelines#VoiceAnalyticsLanguageCode", + "traits": { + "smithy.api#documentation": "

The language code.

", + "smithy.api#required": {} + } + }, + "KinesisVideoStreamSourceTaskConfiguration": { + "target": "com.amazonaws.chimesdkmediapipelines#KinesisVideoStreamSourceTaskConfiguration", + "traits": { + "smithy.api#documentation": "

The task configuration for the Kinesis video stream source of the media insights\n pipeline.

" + } + }, + "ClientRequestToken": { + "target": "com.amazonaws.chimesdkmediapipelines#ClientRequestToken", + "traits": { + "smithy.api#documentation": "

The unique identifier for the client request. Use a different token for different voice tone analysis tasks.

", + "smithy.api#idempotencyToken": {} + } + } + }, + "traits": { + "smithy.api#input": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#StartVoiceToneAnalysisTaskResponse": { + "type": "structure", + "members": { + "VoiceToneAnalysisTask": { + "target": "com.amazonaws.chimesdkmediapipelines#VoiceToneAnalysisTask", + "traits": { + "smithy.api#documentation": "

The details of the voice tone analysis task.

" + } + } + }, + "traits": { + "smithy.api#output": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#StopSpeakerSearchTask": { + "type": "operation", + "input": { + "target": "com.amazonaws.chimesdkmediapipelines#StopSpeakerSearchTaskRequest" + }, + "output": { + "target": "smithy.api#Unit" + }, + "errors": [ + { + "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ConflictException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#NotFoundException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceFailureException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ThrottledClientException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException" + } + ], + "traits": { + "smithy.api#documentation": "

Stops a speaker search task.

", + "smithy.api#http": { + "method": "POST", + "uri": "/media-insights-pipelines/{Identifier}/speaker-search-tasks/{SpeakerSearchTaskId}?operation=stop", + "code": 204 + } + } + }, + "com.amazonaws.chimesdkmediapipelines#StopSpeakerSearchTaskRequest": { + "type": "structure", + "members": { + "Identifier": { + "target": "com.amazonaws.chimesdkmediapipelines#NonEmptyString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + }, + "SpeakerSearchTaskId": { + "target": "com.amazonaws.chimesdkmediapipelines#GuidString", + "traits": { + "smithy.api#documentation": "

The speaker search task ID.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#input": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#StopVoiceToneAnalysisTask": { + "type": "operation", + "input": { + "target": "com.amazonaws.chimesdkmediapipelines#StopVoiceToneAnalysisTaskRequest" + }, + "output": { + "target": "smithy.api#Unit" + }, + "errors": [ + { + "target": "com.amazonaws.chimesdkmediapipelines#BadRequestException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ConflictException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ForbiddenException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#NotFoundException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceFailureException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ServiceUnavailableException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#ThrottledClientException" + }, + { + "target": "com.amazonaws.chimesdkmediapipelines#UnauthorizedClientException" + } + ], + "traits": { + "smithy.api#documentation": "

Stops a voice tone analysis task.

", + "smithy.api#http": { + "method": "POST", + "uri": "/media-insights-pipelines/{Identifier}/voice-tone-analysis-tasks/{VoiceToneAnalysisTaskId}?operation=stop", + "code": 204 + } + } + }, + "com.amazonaws.chimesdkmediapipelines#StopVoiceToneAnalysisTaskRequest": { + "type": "structure", + "members": { + "Identifier": { + "target": "com.amazonaws.chimesdkmediapipelines#NonEmptyString", + "traits": { + "smithy.api#documentation": "

The unique identifier of the resource to be updated. Valid values include the ID and ARN of the media insights pipeline.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + }, + "VoiceToneAnalysisTaskId": { + "target": "com.amazonaws.chimesdkmediapipelines#GuidString", + "traits": { + "smithy.api#documentation": "

The ID of the voice tone analysis task.

", + "smithy.api#httpLabel": {}, + "smithy.api#required": {} + } + } + }, + "traits": { + "smithy.api#input": {} + } + }, + "com.amazonaws.chimesdkmediapipelines#StreamChannelDefinition": { + "type": "structure", + "members": { + "NumberOfChannels": { + "target": "com.amazonaws.chimesdkmediapipelines#NumberOfChannels", + "traits": { + "smithy.api#documentation": "

The number of channels in a streaming channel.

", + "smithy.api#required": {} + } + }, + "ChannelDefinitions": { + "target": "com.amazonaws.chimesdkmediapipelines#ChannelDefinitions", + "traits": { + "smithy.api#documentation": "

The definitions of the channels in a streaming channel.

" + } + } + }, + "traits": { + "smithy.api#documentation": "

Defines a streaming channel.

" + } + }, + "com.amazonaws.chimesdkmediapipelines#StreamConfiguration": { + "type": "structure", + "members": { + "StreamArn": { + "target": "com.amazonaws.chimesdkmediapipelines#KinesisVideoStreamArn", + "traits": { + "smithy.api#documentation": "

The ARN of the stream.

", + "smithy.api#required": {} + } + }, + "FragmentNumber": { "target": "com.amazonaws.chimesdkmediapipelines#FragmentNumberString", "traits": { "smithy.api#documentation": "

The unique identifier of the fragment to begin processing.

" @@ -5814,6 +6413,17 @@ } } }, + "com.amazonaws.chimesdkmediapipelines#VoiceAnalyticsLanguageCode": { + "type": "enum", + "members": { + "EN_US": { + "target": "smithy.api#Unit", + "traits": { + "smithy.api#enumValue": "en-US" + } + } + } + }, "com.amazonaws.chimesdkmediapipelines#VoiceAnalyticsProcessorConfiguration": { "type": "structure", "members": { @@ -5848,6 +6458,38 @@ "traits": { "smithy.api#documentation": "

A static structure that contains the configuration data for a VoiceEnhancementSinkConfiguration element.

" } + }, + "com.amazonaws.chimesdkmediapipelines#VoiceToneAnalysisTask": { + "type": "structure", + "members": { + "VoiceToneAnalysisTaskId": { + "target": "com.amazonaws.chimesdkmediapipelines#GuidString", + "traits": { + "smithy.api#documentation": "

The ID of the voice tone analysis task.

" + } + }, + "VoiceToneAnalysisTaskStatus": { + "target": "com.amazonaws.chimesdkmediapipelines#MediaPipelineTaskStatus", + "traits": { + "smithy.api#documentation": "

The status of a voice tone analysis task.

" + } + }, + "CreatedTimestamp": { + "target": "com.amazonaws.chimesdkmediapipelines#Iso8601Timestamp", + "traits": { + "smithy.api#documentation": "

The time at which a voice tone analysis task was created.

" + } + }, + "UpdatedTimestamp": { + "target": "com.amazonaws.chimesdkmediapipelines#Iso8601Timestamp", + "traits": { + "smithy.api#documentation": "

The time at which a voice tone analysis task was updated.

" + } + } + }, + "traits": { + "smithy.api#documentation": "

A representation of an asynchronous request to perform voice tone analysis on a media insights pipeline.

" + } } } }