/*
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: Apache-2.0.
 */


import * as test_env from "@test/test_env"
import * as retry from "@test/retry";
import * as mqtt5 from "./mqtt5";
import * as mqtt_request_response from "./mqtt_request_response";
import {v4 as uuid} from "uuid";
import {once} from "events";
import * as mrr_test from "@test/mqtt_request_response";
import * as aws_iot_5 from "./aws_iot_mqtt5";
import * as aws_iot_311 from "./aws_iot";
import * as iot from "./iot";

jest.setTimeout(30000);

function createClientBuilder5() : aws_iot_5.AwsIotMqtt5ClientConfigBuilder {
    let builder = iot.AwsIotMqtt5ClientConfigBuilder.newDirectMqttBuilderWithMtlsFromPath(
        test_env.AWS_IOT_ENV.MQTT5_HOST,
        test_env.AWS_IOT_ENV.MQTT5_RSA_CERT,
        test_env.AWS_IOT_ENV.MQTT5_RSA_KEY
    );

    return builder;
}

function createClientBuilder311() : aws_iot_311.AwsIotMqttConnectionConfigBuilder {
    let builder = iot.AwsIotMqttConnectionConfigBuilder.new_mtls_builder_from_path(test_env.AWS_IOT_ENV.MQTT5_RSA_CERT, test_env.AWS_IOT_ENV.MQTT5_RSA_KEY);
    builder.with_endpoint(test_env.AWS_IOT_ENV.MQTT5_HOST); // yes, 5 not 3

    return builder;
}

function initClientBuilderFactories() {
    // @ts-ignore
    mrr_test.setClientBuilderFactories(createClientBuilder5, createClientBuilder311);
}

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Create Destroy Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        let context = new mrr_test.TestingContext({
            version: mrr_test.ProtocolVersion.Mqtt5
        });
        await context.open();

        await context.close();
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Create Destroy Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        let context = new mrr_test.TestingContext({
            version: mrr_test.ProtocolVersion.Mqtt311
        });
        await context.open();

        await context.close();
    })
});


test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Success Rejected Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_success_rejected_test(mrr_test.ProtocolVersion.Mqtt5, true);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Success Rejected Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_success_rejected_test(mrr_test.ProtocolVersion.Mqtt311, true);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Success Rejected No CorrelationToken Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_success_rejected_test(mrr_test.ProtocolVersion.Mqtt5, false);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Success Rejected No CorrelationToken Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_success_rejected_test(mrr_test.ProtocolVersion.Mqtt311, false);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('UpdateNamedShadow Success Accepted Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_update_named_shadow_success_accepted_test(mrr_test.ProtocolVersion.Mqtt5, true);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('UpdateNamedShadow Success Accepted Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_update_named_shadow_success_accepted_test(mrr_test.ProtocolVersion.Mqtt311, true);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('UpdateNamedShadow Success Accepted No CorrelationToken Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_update_named_shadow_success_accepted_test(mrr_test.ProtocolVersion.Mqtt5, false);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('UpdateNamedShadow Success Accepted No CorrelationToken Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_update_named_shadow_success_accepted_test(mrr_test.ProtocolVersion.Mqtt311, false);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Timeout Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_timeout_test(mrr_test.ProtocolVersion.Mqtt5, true);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Timeout Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_timeout_test(mrr_test.ProtocolVersion.Mqtt311, true);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Timeout No CorrelationToken Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_timeout_test(mrr_test.ProtocolVersion.Mqtt5, false);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Timeout No CorrelationToken Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_timeout_test(mrr_test.ProtocolVersion.Mqtt311, false);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure On Close Mqtt5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_on_close_test(mrr_test.ProtocolVersion.Mqtt5, "timeout");
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure On Close Mqtt311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_on_close_test(mrr_test.ProtocolVersion.Mqtt311, "timeout");
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure zero max request response subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_no_max_request_response_subscriptions, "An invalid argument was passed to a function");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure zero max request response subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_no_max_request_response_subscriptions, "An invalid argument was passed to a function");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure invalid max request response subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_invalid_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure invalid max request response subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_invalid_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure undefined config mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_undefined_config, "required configuration parameter is null");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure undefined config mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_undefined_config, "required configuration parameter is null");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure undefined max request response subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_undefined_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure undefined max request response subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_undefined_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure null max request response subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_null_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure null max request response subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_null_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure missing max request response subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_missing_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure missing max request response subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_missing_max_request_response_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure undefined max streaming subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_undefined_max_streaming_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure undefined max streaming subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_undefined_max_streaming_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure null max streaming subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_null_max_streaming_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure null max streaming subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_null_max_streaming_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure missing max streaming subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_missing_max_streaming_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure missing max streaming subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_missing_max_streaming_subscriptions, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure missing max streaming subscriptions mqtt5', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt5, mrr_test.create_bad_config_invalid_operation_timeout, "invalid configuration options");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Client creation failure missing max streaming subscriptions mqtt311', async() => {
    initClientBuilderFactories();
    mrr_test.do_client_creation_failure_test(mrr_test.ProtocolVersion.Mqtt311, mrr_test.create_bad_config_invalid_operation_timeout, "invalid configuration options");
});

test('Client creation failure null protocol client mqtt311', async() => {
    initClientBuilderFactories();
    let config : mqtt_request_response.RequestResponseClientOptions = {
        maxRequestResponseSubscriptions: 2,
        maxStreamingSubscriptions : 2,
        operationTimeoutInSeconds : 5,
    };

    // @ts-ignore
    expect(() => {mqtt_request_response.RequestResponseClient.newFromMqtt311(null, config)}).toThrow("protocol client is null");
});

test('Client creation failure null protocol client mqtt5', async() => {
    initClientBuilderFactories();
    let config : mqtt_request_response.RequestResponseClientOptions = {
        maxRequestResponseSubscriptions: 2,
        maxStreamingSubscriptions : 2,
        operationTimeoutInSeconds : 5,
    };

    // @ts-ignore
    expect(() => {mqtt_request_response.RequestResponseClient.newFromMqtt5(null, config)}).toThrow("protocol client is null");
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure No Subscription Topic Filters', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            delete new_options.subscriptionTopicFilters;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Null Subscription Topic Filters', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.subscriptionTopicFilters = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Subscription Topic Filters Not An Array', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.subscriptionTopicFilters = "null";

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Subscription Topic Filters Empty', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.subscriptionTopicFilters = [];

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure No Response Paths', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            delete new_options.responsePaths;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Null Response Paths', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Paths Not An Array', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths = "null";

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Paths Empty', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths = [];

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Path No Topic', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            delete new_options.responsePaths[0].topic;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Path Null Topic', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths[0].topic = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Path Bad Topic Type', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths[0].topic = 5;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Path Null Correlation Token Json Path', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths[0].correlationTokenJsonPath = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Response Path Bad Correlation Token Json Path Type', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.responsePaths[0].correlationTokenJsonPath = {};

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure No Publish Topic', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            delete new_options.publishTopic;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Null Publish Topic', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.publishTopic = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Bad Publish Topic Type', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.publishTopic = {someValue: null};

            return new_options;
        });
    })
});


test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure No Payload', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            delete new_options.payload;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Null Payload', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.payload = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Bad Payload Type', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.payload = {notAStringOrBuffer: 21};

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Null Correlation Token', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.correlationToken = null;

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Bad Correlation Token Type', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "invalid request options", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            // @ts-ignore
            new_options.correlationToken = ["something"];

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Protocol Invalid Topic', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "failure invoking native client submit_request", (options: mqtt_request_response.RequestResponseOperationOptions) => {
            let new_options = options;
            new_options.publishTopic = "#/illegal/#/topic";

            return new_options;
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Null Options', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_get_named_shadow_failure_invalid_test(true, "null request options",
            // @ts-ignore
            (options: mqtt_request_response.RequestResponseOperationOptions) => {
                return null;
            });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('GetNamedShadow Failure Submit After Close', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        let context = new mrr_test.TestingContext({
            version: mrr_test.ProtocolVersion.Mqtt5
        });

        await context.open();
        await context.close();

        let requestOptions = mrr_test.createRejectedGetNamedShadowRequest(true);
        try {
            await context.client.submitRequest(requestOptions);
            expect(false);
        } catch (err: any) {
            expect(err.message).toContain("already been closed");
        }
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('ShadowUpdated Streaming Operation Success Open/Close MQTT5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_streaming_operation_new_open_close_test(mrr_test.ProtocolVersion.Mqtt5);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('ShadowUpdated Streaming Operation Success Open/Close MQTT311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_streaming_operation_new_open_close_test(mrr_test.ProtocolVersion.Mqtt311);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('ShadowUpdated Streaming Operation Success Incoming Publish MQTT5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_streaming_operation_incoming_publish_test(mrr_test.ProtocolVersion.Mqtt5);
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('ShadowUpdated Streaming Operation Success Incoming Publish MQTT311', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_streaming_operation_incoming_publish_test(mrr_test.ProtocolVersion.Mqtt311);
    })
});

// We only have a 5-based test because there's no way to stop the 311 client without destroying it in the process.
test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('ShadowUpdated Streaming Operation Success Subscription Events MQTT5', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();

        await mrr_test.do_streaming_operation_subscription_events_test({
            version: mrr_test.ProtocolVersion.Mqtt5,
            builder_mutator5: (builder) => {
                builder.withSessionBehavior(mqtt5.ClientSessionBehavior.Clean);
                return builder;
            }
        });
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Failure Reopen', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        let context = new mrr_test.TestingContext({
            version: mrr_test.ProtocolVersion.Mqtt5
        });

        await context.open();

        let topic_filter = `not/a/real/shadow/${uuid()}`;
        let streaming_options: mqtt_request_response.StreamingOperationOptions = {
            subscriptionTopicFilter: topic_filter,
        }

        let stream = context.client.createStream(streaming_options);

        let initialSubscriptionComplete = once(stream, mqtt_request_response.StreamingOperationBase.SUBSCRIPTION_STATUS);

        stream.open();

        await initialSubscriptionComplete;

        stream.open();

        stream.close();

        // multi-opening or multi-closing are fine, but opening after a close is not
        expect(() => {
            stream.open()
        }).toThrow();

        stream.close();

        await context.close();
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Auto Close', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        let context = new mrr_test.TestingContext({
            version: mrr_test.ProtocolVersion.Mqtt5
        });

        await context.open();

        let topic_filter = `not/a/real/shadow/${uuid()}`;
        let streaming_options: mqtt_request_response.StreamingOperationOptions = {
            subscriptionTopicFilter: topic_filter,
        }

        let stream = context.client.createStream(streaming_options);

        let initialSubscriptionComplete = once(stream, mqtt_request_response.StreamingOperationBase.SUBSCRIPTION_STATUS);

        stream.open();

        await initialSubscriptionComplete;

        stream.open();

        await context.close();

        // Closing the client should close the operation automatically; verify that by verifying that open now generates
        // an exception
        expect(() => {
            stream.open()
        }).toThrow();
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Creation Failure Null Options', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        // @ts-ignore
        await mrr_test.do_invalid_streaming_operation_config_test(null, "invalid configuration");
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Creation Failure Undefined Options', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        // @ts-ignore
        await mrr_test.do_invalid_streaming_operation_config_test(undefined, "invalid configuration");
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Creation Failure Null Filter', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_invalid_streaming_operation_config_test({
            // @ts-ignore
            subscriptionTopicFilter: null,
        }, "invalid configuration");
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Creation Failure Invalid Filter Type', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_invalid_streaming_operation_config_test({
            // @ts-ignore
            subscriptionTopicFilter: 5,
        }, "invalid configuration");
    })
});

test_env.conditional_test(test_env.AWS_IOT_ENV.mqtt5_is_valid_mtls_rsa())('Streaming Operation Creation Failure Invalid Filter Value', async () => {
    await retry.networkTimeoutRetryWrapper( async () => {
        initClientBuilderFactories();
        await mrr_test.do_invalid_streaming_operation_config_test({
            subscriptionTopicFilter: "#/hello/#",
        }, "Failed to create");
    })
});