File Explorer

1/*2 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.3 * SPDX-License-Identifier: Apache-2.0.4 */5 6import * as mqtt from "mqtt";7import * as mqtt5 from "./mqtt5";8import {InboundTopicAliasBehaviorType, OutboundTopicAliasBehaviorType} from "./mqtt5";9import * as mqtt5_utils from "./mqtt5_utils";10import * as mqtt_shared from "../common/mqtt_shared";11import {normalize_payload_to_buffer} from "../common/mqtt_shared";12 13 14test('MQTT.JS User Properties to CRT User Properties undefined', async () => {15    let crtUserProperties : mqtt5.UserProperty[] | undefined = mqtt5_utils.transform_mqtt_js_user_properties_to_crt_user_properties(undefined);16 17    expect(crtUserProperties).toBeUndefined();18});19 20test('MQTT.JS User Properties to CRT User Properties single', async () => {21    let mqttJsUserProperties : mqtt.UserProperties = {22        prop1 : "value1",23        prop2 : "value2"24    }25 26    let crtUserProperties : mqtt5.UserProperty[] | undefined = mqtt5_utils.transform_mqtt_js_user_properties_to_crt_user_properties(mqttJsUserProperties);27 28    expect(crtUserProperties).toBeDefined();29    expect(crtUserProperties?.length).toEqual(2);30    expect(crtUserProperties).toEqual( expect.arrayContaining([31            {32                name: "prop1",33                value: "value1",34            },35            {36                name: "prop2",37                value: "value2",38            }39        ]40    ));41});42 43test('MQTT.JS User Properties to CRT User Properties multi', async () => {44    let mqttJsUserProperties : mqtt.UserProperties = {45        prop1 : "value1",46        prop2 : ["value2_1", "value2_2", "value2_3"]47    }48 49    let crtUserProperties : mqtt5.UserProperty[] | undefined = mqtt5_utils.transform_mqtt_js_user_properties_to_crt_user_properties(mqttJsUserProperties);50 51    expect(crtUserProperties).toBeDefined();52    expect(crtUserProperties?.length).toEqual(4);53    expect(crtUserProperties).toEqual( expect.arrayContaining([54            {55                name: "prop1",56                value: "value1",57            },58            {59                name: "prop2",60                value: "value2_1",61            },62            {63                name: "prop2",64                value: "value2_2",65            },66            {67                name: "prop2",68                value: "value2_3",69            }70        ]71    ));72});73 74test('CRT User Properties to MQTT.js User Properties undefined', async () => {75    let mqttJsUserProperties : mqtt.UserProperties | undefined = mqtt5_utils.transform_crt_user_properties_to_mqtt_js_user_properties(undefined);76 77    expect(mqttJsUserProperties).toBeUndefined();78});79 80test('CRT User Properties to MQTT.js User Properties single', async () => {81    let crtUserProperties : mqtt5.UserProperty[] = [82        { name : "prop1", value: "value1"},83        { name : "prop2", value: "value2"}84    ]85 86    let mqttJsUserProperties : mqtt.UserProperties | undefined = mqtt5_utils.transform_crt_user_properties_to_mqtt_js_user_properties(crtUserProperties);87 88    expect(mqttJsUserProperties).toEqual(89        {90            prop1: ["value1"],91            prop2: ["value2"]92        } );93});94 95test('CRT User Properties to MQTT.js User Properties single', async () => {96    let crtUserProperties : mqtt5.UserProperty[] = [97        { name : "prop1", value: "value1"},98        { name : "prop2", value: "value2_1"},99        { name : "prop2", value: "value2_2"},100        { name : "prop2", value: "value2_3"}101    ]102 103    let mqttJsUserProperties : mqtt.UserProperties | undefined = mqtt5_utils.transform_crt_user_properties_to_mqtt_js_user_properties(crtUserProperties);104    expect(mqttJsUserProperties).toBeDefined();105    let definedProperties : mqtt.UserProperties = mqttJsUserProperties ?? {};106 107    const {prop1 : propOne, prop2: propTwo, ...rest} = definedProperties;108 109    expect(rest).toEqual({});110    expect(propOne).toEqual(["value1"]);111    expect(propTwo.length).toEqual(3);112    expect(propTwo).toEqual(expect.arrayContaining(["value2_1", "value2_2", "value2_3"]));113});114 115test('transform_mqtt_js_connack_to_crt_connack minimal', async() => {116    let mqttJsConnack : mqtt.IConnackPacket = {117        cmd: 'connack',118        sessionPresent: true119    }120 121    let crtConnack : mqtt5.ConnackPacket = mqtt5_utils.transform_mqtt_js_connack_to_crt_connack(mqttJsConnack);122 123    expect(crtConnack).toEqual({124        type: mqtt5.PacketType.Connack,125        sessionPresent : true,126        reasonCode : mqtt5.ConnectReasonCode.Success127    });128});129 130test('transform_mqtt_js_connack_to_crt_connack maximal', async() => {131    let mqttJsConnack : mqtt.IConnackPacket = {132        cmd: 'connack',133        sessionPresent: false,134        reasonCode : mqtt5.ConnectReasonCode.UnspecifiedError,135        properties: {136            sessionExpiryInterval: 3600,137            receiveMaximum: 10,138            maximumQoS: 1,139            retainAvailable: false,140            maximumPacketSize: 128 * 1024,141            assignedClientIdentifier: "your-new-client-id-01",142            topicAliasMaximum: 5,143            reasonString: "Not sure really",144            userProperties: {145                prop1: "Value1",146                prop2: "Value2"147            },148            wildcardSubscriptionAvailable: true,149            subscriptionIdentifiersAvailable: true,150            sharedSubscriptionAvailable: true,151            serverKeepAlive: 1800,152            responseInformation: "some/topic/prefix",153            serverReference: "somewhere-else.com",154            authenticationMethod: "don't support this atm"155        }156    }157 158    let crtConnack : mqtt5.ConnackPacket = mqtt5_utils.transform_mqtt_js_connack_to_crt_connack(mqttJsConnack);159 160    expect(crtConnack).toEqual({161        type: mqtt5.PacketType.Connack,162        sessionPresent : false,163        reasonCode : mqtt5.ConnectReasonCode.UnspecifiedError,164        sessionExpiryInterval: 3600,165        receiveMaximum: 10,166        maximumQos: mqtt5.QoS.AtLeastOnce,167        retainAvailable: false,168        maximumPacketSize: 128 * 1024,169        assignedClientIdentifier: "your-new-client-id-01",170        topicAliasMaximum: 5,171        reasonString: "Not sure really",172        wildcardSubscriptionsAvailable: true,173        subscriptionIdentifiersAvailable: true,174        sharedSubscriptionsAvailable: true,175        serverKeepAlive: 1800,176        responseInformation: "some/topic/prefix",177        serverReference: "somewhere-else.com",178        userProperties: [179            { name: "prop1", value: "Value1" },180            { name: "prop2", value: "Value2" },181        ]182    });183});184 185test('create_negotiated_settings empty connack, empty connect', async() => {186    let clientConfig : mqtt5.Mqtt5ClientConfig = {187        hostName: "derp.com",188        port: 8883189    };190 191    let connack : mqtt5.ConnackPacket = {192        sessionPresent: true,193        reasonCode: mqtt5.ConnectReasonCode.Success,194        assignedClientIdentifier: "assignedId"195    }196 197    let settings = mqtt5_utils.create_negotiated_settings(clientConfig, connack);198 199    expect(settings).toEqual({200        maximumQos: mqtt5.QoS.AtLeastOnce,201        sessionExpiryInterval: 0,202        receiveMaximumFromServer: 65535,203        maximumPacketSizeToServer: mqtt5_utils.MAXIMUM_PACKET_SIZE,204        topicAliasMaximumToServer: 0,205        topicAliasMaximumToClient: 0,206        serverKeepAlive: 1200,207        retainAvailable: true,208        wildcardSubscriptionsAvailable: true,209        subscriptionIdentifiersAvailable: true,210        sharedSubscriptionsAvailable: true,211        rejoinedSession: true,212        clientId: "assignedId"213    });214});215 216test('create_negotiated_settings empty connack, full connect', async() => {217    let clientConfig : mqtt5.Mqtt5ClientConfig = {218        hostName: "derp.com",219        port: 8883,220        connectProperties: {221            clientId: "myClientId",222            keepAliveIntervalSeconds: 1800,223            sessionExpiryIntervalSeconds: 3600224        }225    };226 227    let connack : mqtt5.ConnackPacket = {228        sessionPresent: true,229        reasonCode: mqtt5.ConnectReasonCode.Success230    }231 232    let settings = mqtt5_utils.create_negotiated_settings(clientConfig, connack);233 234    expect(settings).toEqual({235        maximumQos: mqtt5.QoS.AtLeastOnce,236        sessionExpiryInterval: 3600,237        receiveMaximumFromServer: 65535,238        maximumPacketSizeToServer: mqtt5_utils.MAXIMUM_PACKET_SIZE,239        topicAliasMaximumToServer: 0,240        topicAliasMaximumToClient: 0,241        serverKeepAlive: 1800,242        retainAvailable: true,243        wildcardSubscriptionsAvailable: true,244        subscriptionIdentifiersAvailable: true,245        sharedSubscriptionsAvailable: true,246        rejoinedSession: true,247        clientId: "myClientId"248    });249});250 251test('create_negotiated_settings full connack, empty connect', async() => {252    let clientConfig : mqtt5.Mqtt5ClientConfig = {253        hostName: "derp.com",254        port: 8883255    };256 257    let connack : mqtt5.ConnackPacket = {258        sessionPresent: false,259        reasonCode: mqtt5.ConnectReasonCode.Success,260        assignedClientIdentifier: "autoAssignedId",261        topicAliasMaximum: 10,262        maximumQos : mqtt5.QoS.AtLeastOnce,263        sessionExpiryInterval : 120,264        receiveMaximum : 100,265        maximumPacketSize : 128 * 1024,266        serverKeepAlive : 600,267        retainAvailable : false,268        wildcardSubscriptionsAvailable : false,269        subscriptionIdentifiersAvailable : false,270        sharedSubscriptionsAvailable : false271    }272 273    let settings = mqtt5_utils.create_negotiated_settings(clientConfig, connack);274 275    expect(settings).toEqual({276        maximumQos: mqtt5.QoS.AtLeastOnce,277        sessionExpiryInterval: 120,278        receiveMaximumFromServer: 100,279        maximumPacketSizeToServer: 128 * 1024,280        topicAliasMaximumToServer: 0,281        topicAliasMaximumToClient: 0,282        serverKeepAlive: 600,283        retainAvailable: false,284        wildcardSubscriptionsAvailable: false,285        subscriptionIdentifiersAvailable: false,286        sharedSubscriptionsAvailable: false,287        rejoinedSession: false,288        clientId: "autoAssignedId"289    });290});291 292test('create_negotiated_settings full connack, full connect', async() => {293    let clientConfig : mqtt5.Mqtt5ClientConfig = {294        hostName: "derp.com",295        port: 8883,296        connectProperties: {297            clientId: "myClientId",298            keepAliveIntervalSeconds: 1800,299            sessionExpiryIntervalSeconds: 3600300        },301        topicAliasingOptions: {302            outboundBehavior: OutboundTopicAliasBehaviorType.LRU,303            outboundCacheMaxSize: 7,304            inboundBehavior: InboundTopicAliasBehaviorType.Enabled,305            inboundCacheMaxSize: 5,306        }307    };308 309    let connack : mqtt5.ConnackPacket = {310        sessionPresent: false,311        reasonCode: mqtt5.ConnectReasonCode.Success,312        maximumQos : mqtt5.QoS.AtLeastOnce,313        sessionExpiryInterval : 1200,314        receiveMaximum : 100,315        maximumPacketSize : 128 * 1024,316        topicAliasMaximum: 10,317        serverKeepAlive : 600,318        retainAvailable : false,319        wildcardSubscriptionsAvailable : false,320        subscriptionIdentifiersAvailable : false,321        sharedSubscriptionsAvailable : false322    }323 324    let settings = mqtt5_utils.create_negotiated_settings(clientConfig, connack);325 326    expect(settings).toEqual({327        maximumQos: mqtt5.QoS.AtLeastOnce,328        sessionExpiryInterval: 1200,329        receiveMaximumFromServer: 100,330        maximumPacketSizeToServer: 128 * 1024,331        topicAliasMaximumToServer: 7,332        topicAliasMaximumToClient: 5,333        serverKeepAlive: 600,334        retainAvailable: false,335        wildcardSubscriptionsAvailable: false,336        subscriptionIdentifiersAvailable: false,337        sharedSubscriptionsAvailable: false,338        rejoinedSession: false,339        clientId: "myClientId"340    });341});342 343function create_base_expected_mqtt_js_config() : mqtt.IClientOptions {344    return {345        keepalive: mqtt_shared.DEFAULT_KEEP_ALIVE,346        connectTimeout: mqtt5_utils.DEFAULT_CONNECT_TIMEOUT_MS,347        clean: true,348        protocolVersion : 5,349        reconnectPeriod: mqtt5_utils.compute_mqtt_js_reconnect_delay_from_crt_max_delay(mqtt5_utils.DEFAULT_MAX_RECONNECT_DELAY_MS),350        queueQoSZero : false,351        // @ts-ignore352        autoUseTopicAlias : false,353        // @ts-ignore354        autoAssignTopicAlias : false,355        transformWsUrl: undefined, /* TOFIX */356        resubscribe : false,357        clientId : ""358    };359}360 361test('create_mqtt_js_client_config_from_crt_client_config minimal', async() => {362    let crtClientConfig : mqtt5.Mqtt5ClientConfig = {363        hostName: "derp.com",364        port: 8883365    };366 367    let mqttJsClientOptions : mqtt.IClientOptions = mqtt5_utils.create_mqtt_js_client_config_from_crt_client_config(crtClientConfig);368 369    let expectedOptions : mqtt.IClientOptions = create_base_expected_mqtt_js_config();370 371    expect(mqttJsClientOptions).toEqual(expectedOptions);372});373 374test('create_mqtt_js_client_config_from_crt_client_config maximal, minimal will', async() => {375    let myPassword: Buffer = Buffer.from("SekritPassword", "utf-8");376 377    let crtClientConfig : mqtt5.Mqtt5ClientConfig = {378        hostName: "derp.com",379        port: 8883,380        sessionBehavior: mqtt5.ClientSessionBehavior.RejoinPostSuccess,381        retryJitterMode: mqtt5.RetryJitterType.Decorrelated,382        minReconnectDelayMs : 1000,383        maxReconnectDelayMs : 60000,384        minConnectedTimeToResetReconnectDelayMs : 30000,385        connectTimeoutMs : 10000,386        connectProperties: {387            keepAliveIntervalSeconds : 120,388            clientId : "MyClientId",389            username : "Larry",390            password : myPassword,391            sessionExpiryIntervalSeconds : 3600,392            requestResponseInformation : true,393            requestProblemInformation : true,394            receiveMaximum : 20,395            maximumPacketSizeBytes : 65536,396            userProperties : [397                { name: "prop1", value: "value1"}398            ],399            will: {400                topicName : "Ohno",401                qos : mqtt5.QoS.AtLeastOnce402            }403        }404    };405 406    let mqttJsClientOptions : mqtt.IClientOptions = mqtt5_utils.create_mqtt_js_client_config_from_crt_client_config(crtClientConfig);407 408    let expectedOptions : mqtt.IClientOptions = create_base_expected_mqtt_js_config();409    expectedOptions["clean"] = false;410    expectedOptions["keepalive"] = 120;411    expectedOptions["clientId"] = "MyClientId";412    expectedOptions["connectTimeout"] = 10000;413    expectedOptions["reconnectPeriod"] = mqtt5_utils.compute_mqtt_js_reconnect_delay_from_crt_max_delay(60000);414    expectedOptions["username"] = "Larry";415    // @ts-ignore416    expectedOptions["password"] = myPassword;417    expectedOptions["will"] = {418        topic : "Ohno",419        payload : normalize_payload_to_buffer(""),420        qos : mqtt5.QoS.AtLeastOnce,421        retain : false422    }423    expectedOptions["properties"] = {424        sessionExpiryInterval: 3600,425        receiveMaximum: 20,426        maximumPacketSize: 65536,427        requestResponseInformation: true,428        requestProblemInformation: true,429        userProperties : {430            prop1: [ "value1" ]431        }432    };433 434    expect(mqttJsClientOptions).toEqual(expectedOptions);435});436 437test('create_mqtt_js_client_config_from_crt_client_config maximal, maximal will', async() => {438    let myPassword: Buffer = Buffer.from("SekritPassword", "utf-8");439    let willPayload: Buffer = Buffer.from("ImportantData", "utf-8");440    let correlationData: Buffer = Buffer.from("UniqueId", "utf-8");441 442    let crtClientConfig : mqtt5.Mqtt5ClientConfig = {443        hostName: "derp.com",444        port: 8883,445        sessionBehavior: mqtt5.ClientSessionBehavior.RejoinPostSuccess,446        retryJitterMode: mqtt5.RetryJitterType.Decorrelated,447        minReconnectDelayMs : 1000,448        maxReconnectDelayMs : 60000,449        minConnectedTimeToResetReconnectDelayMs : 30000,450        connectTimeoutMs : 10000,451        connectProperties: {452            keepAliveIntervalSeconds : 120,453            clientId : "MyClientId",454            username : "Larry",455            password : myPassword,456            sessionExpiryIntervalSeconds : 3600,457            requestResponseInformation : true,458            requestProblemInformation : true,459            receiveMaximum : 20,460            maximumPacketSizeBytes : 65536,461            userProperties : [462                { name: "prop1", value: "value1"}463            ],464            willDelayIntervalSeconds : 60,465            will: {466                topicName : "Ohno",467                qos : mqtt5.QoS.AtMostOnce,468                payload: willPayload,469                retain: true,470                payloadFormat: mqtt5.PayloadFormatIndicator.Bytes,471                messageExpiryIntervalSeconds: 300,472                contentType: "not-json",473                responseTopic: "hello/world",474                correlationData: correlationData,475                userProperties: [476                    {name: "prop1", value: "value1" }477                ]478            }479        }480    };481 482    let mqttJsClientOptions : mqtt.IClientOptions = mqtt5_utils.create_mqtt_js_client_config_from_crt_client_config(crtClientConfig);483 484    let expectedOptions : mqtt.IClientOptions = create_base_expected_mqtt_js_config();485    expectedOptions["clean"] = false;486    expectedOptions["keepalive"] = 120;487    expectedOptions["clientId"] = "MyClientId";488    expectedOptions["connectTimeout"] = 10000;489    expectedOptions["reconnectPeriod"] = mqtt5_utils.compute_mqtt_js_reconnect_delay_from_crt_max_delay(60000);490    expectedOptions["username"] = "Larry";491    // @ts-ignore492    expectedOptions["password"] = myPassword;493    expectedOptions["will"] = {494        topic : "Ohno",495        payload : willPayload,496        qos : mqtt5.QoS.AtMostOnce,497        retain : true,498        properties : {499            willDelayInterval: 60,500            payloadFormatIndicator: false,501            messageExpiryInterval: 300,502            contentType: "not-json",503            responseTopic: "hello/world",504            correlationData: correlationData,505            userProperties: {506                prop1: [ "value1" ]507            }508        }509    }510    expectedOptions["properties"] = {511        sessionExpiryInterval: 3600,512        receiveMaximum: 20,513        maximumPacketSize: 65536,514        requestResponseInformation: true,515        requestProblemInformation: true,516        userProperties : {517            prop1: [ "value1" ]518        }519    };520 521    expect(mqttJsClientOptions).toEqual(expectedOptions);522});523 524test('transform_mqtt_js_disconnect_to_crt_disconnect minimal', async() => {525    let mqttJsDisconnect : mqtt.IDisconnectPacket = {526        cmd: "disconnect"527    }528 529    let crtDisconnect : mqtt5.DisconnectPacket = mqtt5_utils.transform_mqtt_js_disconnect_to_crt_disconnect(mqttJsDisconnect);530 531    expect(crtDisconnect).toEqual( {532            type: mqtt5.PacketType.Disconnect,533            reasonCode: mqtt5.DisconnectReasonCode.NormalDisconnection534        }535    )536});537 538test('transform_mqtt_js_disconnect_to_crt_disconnect maximal', async() => {539    let mqttJsDisconnect : mqtt.IDisconnectPacket = {540        cmd: "disconnect",541        reasonCode : mqtt5.DisconnectReasonCode.AdministrativeAction,542        properties : {543            sessionExpiryInterval: 120,544            reasonString: "Misbehavior",545            serverReference: "somewhere-else.com",546            userProperties: {547                prop1: ["value1"]548            }549        }550    }551 552    let crtDisconnect : mqtt5.DisconnectPacket = mqtt5_utils.transform_mqtt_js_disconnect_to_crt_disconnect(mqttJsDisconnect);553 554    expect(crtDisconnect).toEqual({555        type: mqtt5.PacketType.Disconnect,556        reasonCode : mqtt5.DisconnectReasonCode.AdministrativeAction,557        sessionExpiryIntervalSeconds : 120,558        reasonString : "Misbehavior",559        serverReference : "somewhere-else.com",560        userProperties : [561            { name: "prop1", value: "value1" }562        ]563    })564});565 566test('transform_crt_disconnect_to_mqtt_js_disconnect minimal', async() => {567    let crtDisconnect : mqtt5.DisconnectPacket = {568        reasonCode : mqtt5.DisconnectReasonCode.NormalDisconnection569    }570 571    let mqttJsDisconnect : mqtt.IDisconnectPacket = mqtt5_utils.transform_crt_disconnect_to_mqtt_js_disconnect(crtDisconnect);572 573    expect(mqttJsDisconnect).toEqual( {574            cmd: "disconnect",575            reasonCode : 0576        }577    )578});579 580test('transform_crt_disconnect_to_mqtt_js_disconnect maximal', async() => {581    let crtDisconnect : mqtt5.DisconnectPacket = {582        reasonCode : mqtt5.DisconnectReasonCode.AdministrativeAction,583        sessionExpiryIntervalSeconds : 120,584        reasonString : "Misbehavior",585        serverReference : "somewhere-else.com",586        userProperties : [587            { name: "prop1", value: "value1" }588        ]589    }590 591    let mqttJsDisconnect : mqtt.IDisconnectPacket = mqtt5_utils.transform_crt_disconnect_to_mqtt_js_disconnect(crtDisconnect);592 593    expect(mqttJsDisconnect).toEqual({594        cmd: "disconnect",595        reasonCode : mqtt5.DisconnectReasonCode.AdministrativeAction,596        properties : {597            sessionExpiryInterval: 120,598            reasonString: "Misbehavior",599            serverReference: "somewhere-else.com",600            userProperties: {601                prop1: ["value1"]602            }603        }604    })605});606 607test('transform_crt_subscribe_to_mqtt_js_subscription_map', async() => {608    let subscribe : mqtt5.SubscribePacket = {609        subscriptions: [610            {611                qos: mqtt5.QoS.AtLeastOnce,612                topicFilter: "hello/world",613                noLocal: true,614                retainAsPublished: true,615                retainHandlingType: mqtt5.RetainHandlingType.SendOnSubscribeIfNew616            },617            {618                qos: mqtt5.QoS.ExactlyOnce,619                topicFilter: "hello/world2"620            }621        ]622    }623 624    let mqttJsSubscriptionMap : mqtt.ISubscriptionMap = mqtt5_utils.transform_crt_subscribe_to_mqtt_js_subscription_map(subscribe);625 626    expect(mqttJsSubscriptionMap).toEqual({627        "hello/world": {628            qos: mqtt5.QoS.AtLeastOnce,629            nl: true,630            rap: true,631            rh: mqtt5.RetainHandlingType.SendOnSubscribeIfNew632        },633        "hello/world2": {634            qos: mqtt5.QoS.ExactlyOnce,635            nl: false,636            rap: false,637            rh: mqtt5.RetainHandlingType.SendOnSubscribe638        }639    });640});641 642test('transform_crt_subscribe_to_mqtt_js_subscribe_options minimal', async() => {643    let subscribe : mqtt5.SubscribePacket = {644        subscriptions: [645            {646                qos: mqtt5.QoS.ExactlyOnce,647                topicFilter: "hello/world2"648            }649        ]650    };651 652    let mqttJsSubscribeOptions : mqtt.IClientSubscribeOptions = mqtt5_utils.transform_crt_subscribe_to_mqtt_js_subscribe_options(subscribe);653 654    expect(mqttJsSubscribeOptions).toEqual({655        qos: 0 // unfortunately, the typescript definition requires this parameter despite it not being used by us656    });657});658 659test('transform_crt_subscribe_to_mqtt_js_subscribe_options maximal', async() => {660    let subscribe : mqtt5.SubscribePacket = {661        subscriptions: [662            {663                qos: mqtt5.QoS.ExactlyOnce,664                topicFilter: "hello/world2"665            }666        ],667        subscriptionIdentifier: 5,668        userProperties: [669            { name: "prop1", value: "value1" }670        ]671    };672 673    let mqttJsSubscribeOptions : mqtt.IClientSubscribeOptions = mqtt5_utils.transform_crt_subscribe_to_mqtt_js_subscribe_options(subscribe);674 675    expect(mqttJsSubscribeOptions).toEqual({676        qos: 0, // unfortunately, the typescript definition requires this parameter despite it not being used by us677        properties: {678            subscriptionIdentifier: 5,679            userProperties: {680                prop1: [ "value1" ]681            }682        }683    });684});685 686test('transform_mqtt_js_subscription_grants_to_crt_suback', async() => {687    let subscriptionsGranted : mqtt.ISubscriptionGrant[] = [688        {689            topic: "my/topic",690            qos: 2691        },692        {693            topic: "a/different/topic",694            qos: mqtt5.SubackReasonCode.UnspecifiedError,695            nl: true,696            rap: true,697            rh: 2698        }699    ];700 701    let suback : mqtt5.SubackPacket = mqtt5_utils.transform_mqtt_js_subscription_grants_to_crt_suback(subscriptionsGranted);702 703    expect(suback).toEqual({704        type: mqtt5.PacketType.Suback,705        reasonCodes: [2, mqtt5.SubackReasonCode.UnspecifiedError]706    });707});708 709test('transform_crt_publish_to_mqtt_js_publish_options minimal', async() => {710    let publish : mqtt5.PublishPacket = {711        topicName: "hello/there",712        qos: mqtt5.QoS.AtMostOnce713    };714 715    let publishOptions: mqtt.IClientPublishOptions = mqtt5_utils.transform_crt_publish_to_mqtt_js_publish_options(publish);716 717    expect(publishOptions).toEqual({718        qos: mqtt5.QoS.AtMostOnce,719        retain: false720    });721});722 723test('transform_crt_publish_to_mqtt_js_publish_options maximal', async() => {724    let payload: Buffer = Buffer.from("warglgarbl", "utf-8");725    let correlationData: Buffer = Buffer.from("VeryUnique", "utf-8");726 727    let publish : mqtt5.PublishPacket = {728        topicName: "hello/there",729        qos: mqtt5.QoS.ExactlyOnce,730        retain: true,731        payload: payload,732        payloadFormat: mqtt5.PayloadFormatIndicator.Bytes,733        messageExpiryIntervalSeconds: 60,734        responseTopic: "the/answer",735        correlationData: correlationData,736        userProperties: [737            { name: "prop1", value: "value1" }738        ],739        contentType: "not-xml"740    };741 742    let publishOptions: mqtt.IClientPublishOptions = mqtt5_utils.transform_crt_publish_to_mqtt_js_publish_options(publish);743 744    expect(publishOptions).toEqual({745        qos: mqtt5.QoS.ExactlyOnce,746        retain: true,747        properties: {748            payloadFormatIndicator: false,749            messageExpiryInterval: 60,750            responseTopic: "the/answer",751            correlationData: correlationData,752            userProperties: {753                prop1: ["value1"]754            },755            contentType: "not-xml"756        }757    });758});759 760test('transform_mqtt_js_publish_to_crt_publish minimal', async() => {761    let payload : Buffer = Buffer.from("", "utf-8");762 763    let mqttJsPublish : mqtt.IPublishPacket = {764        cmd: 'publish',765        qos: mqtt5.QoS.AtMostOnce,766        dup: false,767        retain: false,768        topic: 'hello/there',769        payload: payload770    };771 772    let crtPublish : mqtt5.PublishPacket = mqtt5_utils.transform_mqtt_js_publish_to_crt_publish(mqttJsPublish);773 774    expect(crtPublish).toEqual({775        type: mqtt5.PacketType.Publish,776        topicName: "hello/there",777        qos: mqtt5.QoS.AtMostOnce,778        payload: payload,779        retain: false780    });781});782 783test('transform_mqtt_js_publish_to_crt_publish maximal', async() => {784    let payload : Buffer = Buffer.from("Actual data", "utf-8");785    let correlationData : Buffer = Buffer.from("some-id", "utf-8");786 787    let mqttJsPublish : mqtt.IPublishPacket = {788        cmd: 'publish',789        qos: mqtt5.QoS.AtMostOnce,790        dup: false,791        retain: true,792        topic: 'hello/there',793        payload: payload,794        properties: {795            payloadFormatIndicator: false,796            messageExpiryInterval: 30,797            topicAlias: 1,798            responseTopic: "response/goes/here",799            correlationData: correlationData,800            userProperties: {801                prop1: "value1"802            },803            subscriptionIdentifier: 5,804            contentType: "cbor"805        }806    };807 808    let crtPublish : mqtt5.PublishPacket = mqtt5_utils.transform_mqtt_js_publish_to_crt_publish(mqttJsPublish);809 810    expect(crtPublish).toEqual({811        type: mqtt5.PacketType.Publish,812        topicName: "hello/there",813        qos: mqtt5.QoS.AtMostOnce,814        payload: payload,815        retain: true,816        payloadFormat: mqtt5.PayloadFormatIndicator.Bytes,817        messageExpiryIntervalSeconds: 30,818        responseTopic: "response/goes/here",819        correlationData: correlationData,820        userProperties: [821            { name: "prop1", value: "value1" }822        ],823        subscriptionIdentifiers: [ 5 ],824        contentType: "cbor"825    });826});827 828test('transform_mqtt_js_puback_to_crt_puback minimal', async() => {829    let mqttJsPuback : mqtt.IPubackPacket = {830        cmd: 'puback'831    };832 833    let crtPuback : mqtt5.PubackPacket = mqtt5_utils.transform_mqtt_js_puback_to_crt_puback(mqttJsPuback);834 835    expect(crtPuback).toEqual({836        type: mqtt5.PacketType.Puback,837        reasonCode: mqtt5.PubackReasonCode.Success838    });839});840 841test('transform_mqtt_js_puback_to_crt_puback maximal', async() => {842    let mqttJsPuback : mqtt.IPubackPacket = {843        cmd: 'puback',844        reasonCode: mqtt5.PubackReasonCode.NotAuthorized,845        properties: {846            reasonString: "Insufficient privilege",847            userProperties: {848                prop1: "value1"849            }850        }851    };852 853    let crtPuback : mqtt5.PubackPacket = mqtt5_utils.transform_mqtt_js_puback_to_crt_puback(mqttJsPuback);854 855    expect(crtPuback).toEqual({856        type: mqtt5.PacketType.Puback,857        reasonCode: mqtt5.PubackReasonCode.NotAuthorized,858        reasonString: "Insufficient privilege",859        userProperties: [860            { name: "prop1", value: "value1" }861        ]862    });863});864 865test('transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options minimal', async() => {866    let crtUnsubscribe : mqtt5.UnsubscribePacket = {867        topicFilters: [ "hello/there" ]868    };869 870    let mqttJsUnsubscribeOptions : Object = mqtt5_utils.transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options(crtUnsubscribe);871 872    expect(mqttJsUnsubscribeOptions).toEqual({});873});874 875test('transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options maximal', async() => {876    let crtUnsubscribe : mqtt5.UnsubscribePacket = {877        topicFilters: [ "hello/there" ],878        userProperties: [879            { name: "prop1", value: "value1" }880        ]881    };882 883    let mqttJsUnsubscribeOptions : Object = mqtt5_utils.transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options(crtUnsubscribe);884 885    expect(mqttJsUnsubscribeOptions).toEqual({886        properties: {887            userProperties: {888                prop1: [ "value1" ]889            }890        }891    });892});893 894test('transform_mqtt_js_unsuback_to_crt_unsuback minimal', async() => {895    let mqttJsUnsuback : mqtt.IUnsubackPacket = {896        cmd: 'unsuback',897        reasonCode: mqtt5.UnsubackReasonCode.NoSubscriptionExisted898    };899 900    let crtUnsuback : mqtt5.UnsubackPacket = mqtt5_utils.transform_mqtt_js_unsuback_to_crt_unsuback(mqttJsUnsuback);901 902    expect(crtUnsuback).toEqual({903        type: mqtt5.PacketType.Unsuback,904        reasonCodes: [ mqtt5.UnsubackReasonCode.NoSubscriptionExisted ]905    });906});907 908test('transform_mqtt_js_unsuback_to_crt_unsuback maximal', async() => {909    let mqttJsUnsuback : mqtt.IUnsubackPacket = {910        cmd: 'unsuback',911        // @ts-ignore912        reasonCode: [mqtt5.UnsubackReasonCode.NoSubscriptionExisted, mqtt5.UnsubackReasonCode.ImplementationSpecificError],913        properties: {914            reasonString: "Dunno",915            userProperties: {916                prop1: "value1"917            }918        }919    };920 921    let crtUnsuback : mqtt5.UnsubackPacket = mqtt5_utils.transform_mqtt_js_unsuback_to_crt_unsuback(mqttJsUnsuback);922 923    expect(crtUnsuback).toEqual({924        type: mqtt5.PacketType.Unsuback,925        reasonCodes: [ mqtt5.UnsubackReasonCode.NoSubscriptionExisted, mqtt5.UnsubackReasonCode.ImplementationSpecificError ],926        reasonString: "Dunno",927        userProperties: [928            { name: "prop1", value: "value1" }929        ]930    });931});932