How to use withProtocolVersion method in Cypress

...118                        // Connection started119                        this.#logger.debug(`Opening connection to ${this.host}:${this.port}`);120                        this.#connected = false;121                        const request = new smData.ConnectRequest()122                            .withProtocolVersion(PROTOCOL_VERSION)123                            .withSdkVersion(SDK_VERSION)124                            .withAuthToken(this.#authToken)125                            .withRequestId(util.uuidv4());126                        // Write the connect version127                        newSock.write(util.intToBuffer(CONNECT_VERSION, 1));128                        // Write request to socket129                        const frame = new smData.MessageFrame(smData.Operation.Connect, cbor.encode(request.asMap()));130                        const byteFrame = util.encodeFrame(frame);131                        newSock.write(byteFrame.header);132                        newSock.write(byteFrame.payload);133                        await this.__read(newSock);134                        // Only now that we're connected should we set/replace the socket135                        this.#socket = newSock;136                        resolve();...

...82    });83    describe('parsing the variable header', function() {84        beforeEach(function() {85            subject = subject.withProtocolName('MQTT')86                .withProtocolVersion(4)87                .withConnectFlags({88                    reserved: true,89                    cleanSession: true,90                    willFlag: true,91                    willQos: constants.qualityOfService.AT_MOST_ONCE,92                    willRetain: true,93                    passwordFlag: true,94                    usernameFlag: true95                })96                .withKeepAlive(60);97        });98        it('parses the protocol name', function(done) {99            parseConnectMessage(subject.buffer(), function(err, message) {100                var headers = message.headers;101                headers.variable.protocol.name.should.eql(constants.protocol.name);102                done();103            });104        });105        it('parses the protocol version', function(done) {106            parseConnectMessage(subject.buffer(), function(err, message) {107                var headers = message.headers;108                headers.variable.protocol.version.should.eql(constants.protocol.version);109                done();110            });111        });112        describe('parses the CONNECT flags', function() {113            /* There are tests that the parseConnectFlags defaults its values114             * if not set.  So only checking for truthy here.  I think this has it covered115             * */116            beforeEach(function(done) {117                var self = this;118                subject = subject;119                parseConnectMessage(subject.buffer(), function(err, message) {120                    var headers = message.headers;121                    self.connectFlags = headers.variable.connectFlags;122                    done();123                });124            });125            it('parses the reserved flag as true', function() {126                this.connectFlags.reserved.should.eql(true);127            });128            it('parses the clean session flag as true', function() {129                this.connectFlags.cleanSession.should.eql(true);130            });131            it('parses the will flag as true', function() {132                this.connectFlags.willFlag.should.eql(true);133            });134            it('parses the will qos as AT_MOST_ONCE', function() {135                subject = subject.withConnectFlags({136                    willQos: constants.qualityOfService.AT_MOST_ONCE137                });138                this.connectFlags.willQos.should.eql(constants.qualityOfService.AT_MOST_ONCE);139            });140            it('parses the will qos as AT_LEAST_ONCE', function(done) {141                subject = subject.withConnectFlags({142                    willQos: constants.qualityOfService.AT_LEAST_ONCE143                });144                parseConnectMessage(subject.buffer(), function(err, message) {145                    var headers = message.headers;146                    var connectFlags = headers.variable.connectFlags;147                    connectFlags.willQos.should.eql(constants.qualityOfService.AT_LEAST_ONCE);148                    done();149                });150            });151            it('parses the will qos as EXACTLY_ONCE', function(done) {152                subject = subject.withConnectFlags({153                    willQos: constants.qualityOfService.EXACTLY_ONCE154                });155                parseConnectMessage(subject.buffer(), function(err, message) {156                    var headers = message.headers;157                    var connectFlags = headers.variable.connectFlags;158                    connectFlags.willQos.should.eql(constants.qualityOfService.EXACTLY_ONCE);159                    done();160                });161            });162            it('parses the will qos as RESERVED', function(done) {163                subject = subject.withConnectFlags({164                    willQos: constants.qualityOfService.RESERVED165                });166                parseConnectMessage(subject.buffer(), function(err, message) {167                    var headers = message.headers;168                    var connectFlags = headers.variable.connectFlags;169                    connectFlags.willQos.should.eql(constants.qualityOfService.RESERVED);170                    done();171                });172            });173            it('parses the will retain as true', function() {174                this.connectFlags.willRetain.should.eql(true);175            });176            it('parses the password flag as true', function() {177                this.connectFlags.passwordFlag.should.eql(true);178            });179            it('parses the username flag as true', function() {180                this.connectFlags.usernameFlag.should.eql(true);181            });182        });183        it('parses the keep alive', function(done) {184            parseConnectMessage(subject.buffer(), function(err, message) {185                var headers = message.headers;186                headers.variable.keepAlive.should.eql(60);187                done();188            });189        });190    });191    describe('parsing the client identifier', function() {192        it('parses', function(done) {193            var expectedIdentifier = 'someIdentifier';194            subject = subject.withClientIdentifier(expectedIdentifier);195            parseConnectMessage(subject.buffer(), function(err, message) {196                message.payload.client.id.should.eql(expectedIdentifier);197                done();198            });199        });200    });201    describe('parsing the will', function() {202        var expectedTopic, expectedMessage;203        beforeEach(function() {204            expectedTopic = 'someTopic';205            expectedMessage = 'someMessage';206            subject = subject.withConnectFlags({207                willFlag: true208            }).withWillTopic(expectedTopic)209                .withWillMessage(expectedMessage);210        });211        it('parses the will topic', function(done) {212            parseConnectMessage(subject.buffer(), function(err, message) {213                message.payload.will.topic.should.eql(expectedTopic);214                done();215            });216        });217        it('parses the will message', function(done) {218            parseConnectMessage(subject.buffer(), function(err, message) {219                message.payload.will.message.should.eql(expectedMessage);220                done();221            });222        });223    });224    describe('parsing the username', function() {225        it('parses', function(done) {226            var expectedUsername = 'foobar';227            subject = subject.withConnectFlags({228                usernameFlag: true229            }).withUsername(expectedUsername);230            parseConnectMessage(subject.buffer(), function(err, message) {231                message.payload.username.should.eql(expectedUsername);232                done();233            });234        });235    });236    describe('parsing the password', function() {237        it('parses', function(done) {238            var expectedPassword = 'barfoo';239            subject = subject.withConnectFlags({240                passwordFlag: true241            }).withPassword(expectedPassword);242            parseConnectMessage(subject.buffer(), function(err, message) {243                message.payload.password.should.eql(expectedPassword);244                done();245            });246        });247    });248});249describe('Parsing a ConnAck Message', function() {250    var connect = packets.connack;251    var subject;252    beforeEach(function() {253        subject = connect.message()254            .withMessageType(constants.messageTypes.CONNACK);255    });256    it('parses the message type', function() {257        var message = connect.parsePacket(subject.buffer());258        message.payload.type.should.eql(constants.messageTypes.CONNACK);259    });260    describe.skip('parsing the remaining length', function() {261        function assertRemainingLength(number) {262            var remainingLength = services.remainingLength.upperLimit(number);263            console.log('remainingLength', remainingLength.toString(2));264            var buffer = subject.withRemainingLength(remainingLength).buffer();265            parseConnectMessage(buffer, function(err, message) {266                var headers = message.headers;267                headers.fixed.remainingLength.should.eql(remainingLength);268            });269        }270        var lengths = [1, 2, 3, 4];271        lengths.map(function(length) {272            it('parses when the remaining length is the ' + length + ' byte upper limit', function() {273                assertRemainingLength(length);274            });275        });276        it('return malformedRemainingLength code when the remaining length is 5 or more bytes', function() {277            var remainingLength = services.remainingLength.upperLimit(5);278            var buffer = subject.withRemainingLength(remainingLength).buffer();279            parseConnectMessage(buffer, function(err) {280                should.exist(err);281                err.should.eql(constants.errorCodes.connect.malformedRemainingLength);282            });283        });284    });285    describe.skip('parsing the variable header', function() {286        beforeEach(function() {287            subject = subject.withProtocolName('MQTT')288                .withProtocolVersion(4)289                .withConnectFlags({290                    reserved: true,291                    cleanSession: true,292                    willFlag: true,293                    willQos: constants.qualityOfService.AT_MOST_ONCE,294                    willRetain: true,295                    passwordFlag: true,296                    usernameFlag: true297                })298                .withKeepAlive(60);299        });300        it('parses the protocol name', function(done) {301            parseConnectMessage(subject.buffer(), function(err, message) {302                var headers = message.headers;...

1Search.appendIndex(2    [3                {4            "fqsen": "\\models\\Dbh",5            "name": "Dbh",6            "summary": "Dbh.\u0020Class\u0020for\u0020PDO\u0020Database\u0020connection.",7            "url": "classes/models-Dbh.html"8        },                {9            "fqsen": "\\models\\Dbh\u003A\u003A__construct\u0028\u0029",10            "name": "__construct",11            "summary": "Sets\u0020data\u0020for\u0020connection",12            "url": "classes/models-Dbh.html#method___construct"13        },                {14            "fqsen": "\\models\\Dbh\u003A\u003Aconnect\u0028\u0029",15            "name": "connect",16            "summary": "Connection\u0020to\u0020database\u0020using\u0020PDO",17            "url": "classes/models-Dbh.html#method_connect"18        },                {19            "fqsen": "\\models\\Dbh\u003A\u003A\u0024host",20            "name": "host",21            "summary": "Hostname",22            "url": "classes/models-Dbh.html#property_host"23        },                {24            "fqsen": "\\models\\Dbh\u003A\u003A\u0024pass",25            "name": "pass",26            "summary": "Database\u0020user\u0020password",27            "url": "classes/models-Dbh.html#property_pass"28        },                {29            "fqsen": "\\models\\Dbh\u003A\u003A\u0024user",30            "name": "user",31            "summary": "Database\u0020user\u0020name",32            "url": "classes/models-Dbh.html#property_user"33        },                {34            "fqsen": "\\models\\Dbh\u003A\u003A\u0024db",35            "name": "db",36            "summary": "Database\u0020name",37            "url": "classes/models-Dbh.html#property_db"38        },                {39            "fqsen": "\\models\\Dbh\u003A\u003A\u0024charset",40            "name": "charset",41            "summary": "Database\u0020charset",42            "url": "classes/models-Dbh.html#property_charset"43        },                {44            "fqsen": "\\models\\Dbh\u003A\u003A\u0024opt",45            "name": "opt",46            "summary": "PDO\u0020options\u0020array",47            "url": "classes/models-Dbh.html#property_opt"48        },                {49            "fqsen": "\\models\\Dbh\u003A\u003A\u0024dsn",50            "name": "dsn",51            "summary": "PDO\u0020dsn\u0020for\u0020connection",52            "url": "classes/models-Dbh.html#property_dsn"53        },                {54            "fqsen": "\\models\\Filter",55            "name": "Filter",56            "summary": "Filter.\u0020Class\u0020filters\u0020data\u0020by\u0020specified\u0020parameters",57            "url": "classes/models-Filter.html"58        },                {59            "fqsen": "\\models\\Filter\u003A\u003AfilterProducts\u0028\u0029",60            "name": "filterProducts",61            "summary": "Implements\u0020filtering\u0020products",62            "url": "classes/models-Filter.html#method_filterProducts"63        },                {64            "fqsen": "\\models\\Model",65            "name": "Model",66            "summary": "Model.\u0020Provides\u0020a\u0020basic\u0020CRUD\u0020operations\u0020and\u0020works\u0020with\u0020database.",67            "url": "classes/models-Model.html"68        },                {69            "fqsen": "\\models\\Model\u003A\u003Arender\u0028\u0029",70            "name": "render",71            "summary": "Stores\u0020fetched\u0020data",72            "url": "classes/models-Model.html#method_render"73        },                {74            "fqsen": "\\models\\Model\u003A\u003AmakeResponse\u0028\u0029",75            "name": "makeResponse",76            "summary": "Returns\u0020json\u0020encoded\u0020data",77            "url": "classes/models-Model.html#method_makeResponse"78        },                {79            "fqsen": "\\models\\Model\u003A\u003AloadAll\u0028\u0029",80            "name": "loadAll",81            "summary": "Reads\u0020all\u0020the\u0020data\u0020from\u0020the\u0020selected\u0020table",82            "url": "classes/models-Model.html#method_loadAll"83        },                {84            "fqsen": "\\models\\Model\u003A\u003Aload\u0028\u0029",85            "name": "load",86            "summary": "Reads\u0020selected\u0020data\u0020from\u0020selected\u0020table",87            "url": "classes/models-Model.html#method_load"88        },                {89            "fqsen": "\\models\\Model\u003A\u003Acreate\u0028\u0029",90            "name": "create",91            "summary": "Inserts\u0020selected\u0020data\u0020to\u0020selected\u0020table",92            "url": "classes/models-Model.html#method_create"93        },                {94            "fqsen": "\\models\\Model\u003A\u003Aupdate\u0028\u0029",95            "name": "update",96            "summary": "Updates\u0020data\u0020in\u0020table",97            "url": "classes/models-Model.html#method_update"98        },                {99            "fqsen": "\\models\\Model\u003A\u003AgetProtocolVersion\u0028\u0029",100            "name": "getProtocolVersion",101            "summary": "Retrieves\u0020the\u0020HTTP\u0020protocol\u0020version\u0020as\u0020a\u0020string.",102            "url": "classes/models-Model.html#method_getProtocolVersion"103        },                {104            "fqsen": "\\models\\Model\u003A\u003AwithProtocolVersion\u0028\u0029",105            "name": "withProtocolVersion",106            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020HTTP\u0020protocol\u0020version.",107            "url": "classes/models-Model.html#method_withProtocolVersion"108        },                {109            "fqsen": "\\models\\Model\u003A\u003AgetHeaders\u0028\u0029",110            "name": "getHeaders",111            "summary": "Retrieves\u0020all\u0020message\u0020header\u0020values.",112            "url": "classes/models-Model.html#method_getHeaders"113        },                {114            "fqsen": "\\models\\Model\u003A\u003AhasHeader\u0028\u0029",115            "name": "hasHeader",116            "summary": "Checks\u0020if\u0020a\u0020header\u0020exists\u0020by\u0020the\u0020given\u0020case\u002Dinsensitive\u0020name.",117            "url": "classes/models-Model.html#method_hasHeader"118        },                {119            "fqsen": "\\models\\Model\u003A\u003AgetHeader\u0028\u0029",120            "name": "getHeader",121            "summary": "Retrieves\u0020a\u0020message\u0020header\u0020value\u0020by\u0020the\u0020given\u0020case\u002Dinsensitive\u0020name.",122            "url": "classes/models-Model.html#method_getHeader"123        },                {124            "fqsen": "\\models\\Model\u003A\u003AgetHeaderLine\u0028\u0029",125            "name": "getHeaderLine",126            "summary": "Retrieves\u0020a\u0020comma\u002Dseparated\u0020string\u0020of\u0020the\u0020values\u0020for\u0020a\u0020single\u0020header.",127            "url": "classes/models-Model.html#method_getHeaderLine"128        },                {129            "fqsen": "\\models\\Model\u003A\u003AwithHeader\u0028\u0029",130            "name": "withHeader",131            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020provided\u0020value\u0020replacing\u0020the\u0020specified\u0020header.",132            "url": "classes/models-Model.html#method_withHeader"133        },                {134            "fqsen": "\\models\\Model\u003A\u003AwithAddedHeader\u0028\u0029",135            "name": "withAddedHeader",136            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020header\u0020appended\u0020with\u0020the\u0020given\u0020value.",137            "url": "classes/models-Model.html#method_withAddedHeader"138        },                {139            "fqsen": "\\models\\Model\u003A\u003AwithoutHeader\u0028\u0029",140            "name": "withoutHeader",141            "summary": "Return\u0020an\u0020instance\u0020without\u0020the\u0020specified\u0020header.",142            "url": "classes/models-Model.html#method_withoutHeader"143        },                {144            "fqsen": "\\models\\Model\u003A\u003AgetBody\u0028\u0029",145            "name": "getBody",146            "summary": "Gets\u0020the\u0020body\u0020of\u0020the\u0020message.",147            "url": "classes/models-Model.html#method_getBody"148        },                {149            "fqsen": "\\models\\Model\u003A\u003AwithBody\u0028\u0029",150            "name": "withBody",151            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020message\u0020body.",152            "url": "classes/models-Model.html#method_withBody"153        },                {154            "fqsen": "\\models\\Model\u003A\u003AgetRequestTarget\u0028\u0029",155            "name": "getRequestTarget",156            "summary": "Retrieves\u0020the\u0020message\u0027s\u0020request\u0020target.",157            "url": "classes/models-Model.html#method_getRequestTarget"158        },                {159            "fqsen": "\\models\\Model\u003A\u003AwithRequestTarget\u0028\u0029",160            "name": "withRequestTarget",161            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specific\u0020request\u002Dtarget.",162            "url": "classes/models-Model.html#method_withRequestTarget"163        },                {164            "fqsen": "\\models\\Model\u003A\u003AgetMethod\u0028\u0029",165            "name": "getMethod",166            "summary": "Retrieves\u0020the\u0020HTTP\u0020method\u0020of\u0020the\u0020request.",167            "url": "classes/models-Model.html#method_getMethod"168        },                {169            "fqsen": "\\models\\Model\u003A\u003AwithMethod\u0028\u0029",170            "name": "withMethod",171            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020provided\u0020HTTP\u0020method.",172            "url": "classes/models-Model.html#method_withMethod"173        },                {174            "fqsen": "\\models\\Model\u003A\u003AgetUri\u0028\u0029",175            "name": "getUri",176            "summary": "Retrieves\u0020the\u0020URI\u0020instance.",177            "url": "classes/models-Model.html#method_getUri"178        },                {179            "fqsen": "\\models\\Model\u003A\u003AwithUri\u0028\u0029",180            "name": "withUri",181            "summary": "Returns\u0020an\u0020instance\u0020with\u0020the\u0020provided\u0020URI.",182            "url": "classes/models-Model.html#method_withUri"183        },                {184            "fqsen": "\\models\\Model\u003A\u003AgetServerParams\u0028\u0029",185            "name": "getServerParams",186            "summary": "Retrieve\u0020server\u0020parameters.",187            "url": "classes/models-Model.html#method_getServerParams"188        },                {189            "fqsen": "\\models\\Model\u003A\u003AgetCookieParams\u0028\u0029",190            "name": "getCookieParams",191            "summary": "Retrieve\u0020cookies.",192            "url": "classes/models-Model.html#method_getCookieParams"193        },                {194            "fqsen": "\\models\\Model\u003A\u003AwithCookieParams\u0028\u0029",195            "name": "withCookieParams",196            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020cookies.",197            "url": "classes/models-Model.html#method_withCookieParams"198        },                {199            "fqsen": "\\models\\Model\u003A\u003AgetQueryParams\u0028\u0029",200            "name": "getQueryParams",201            "summary": "Retrieve\u0020query\u0020string\u0020arguments.",202            "url": "classes/models-Model.html#method_getQueryParams"203        },                {204            "fqsen": "\\models\\Model\u003A\u003AwithQueryParams\u0028\u0029",205            "name": "withQueryParams",206            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020query\u0020string\u0020arguments.",207            "url": "classes/models-Model.html#method_withQueryParams"208        },                {209            "fqsen": "\\models\\Model\u003A\u003AgetUploadedFiles\u0028\u0029",210            "name": "getUploadedFiles",211            "summary": "Retrieve\u0020normalized\u0020file\u0020upload\u0020data.",212            "url": "classes/models-Model.html#method_getUploadedFiles"213        },                {214            "fqsen": "\\models\\Model\u003A\u003AwithUploadedFiles\u0028\u0029",215            "name": "withUploadedFiles",216            "summary": "Create\u0020a\u0020new\u0020instance\u0020with\u0020the\u0020specified\u0020uploaded\u0020files.",217            "url": "classes/models-Model.html#method_withUploadedFiles"218        },                {219            "fqsen": "\\models\\Model\u003A\u003AgetParsedBody\u0028\u0029",220            "name": "getParsedBody",221            "summary": "Retrieve\u0020any\u0020parameters\u0020provided\u0020in\u0020the\u0020request\u0020body.",222            "url": "classes/models-Model.html#method_getParsedBody"223        },                {224            "fqsen": "\\models\\Model\u003A\u003AwithParsedBody\u0028\u0029",225            "name": "withParsedBody",226            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020body\u0020parameters.",227            "url": "classes/models-Model.html#method_withParsedBody"228        },                {229            "fqsen": "\\models\\Model\u003A\u003AgetAttributes\u0028\u0029",230            "name": "getAttributes",231            "summary": "Retrieve\u0020attributes\u0020derived\u0020from\u0020the\u0020request.",232            "url": "classes/models-Model.html#method_getAttributes"233        },                {234            "fqsen": "\\models\\Model\u003A\u003AgetAttribute\u0028\u0029",235            "name": "getAttribute",236            "summary": "Retrieve\u0020a\u0020single\u0020derived\u0020request\u0020attribute.",237            "url": "classes/models-Model.html#method_getAttribute"238        },                {239            "fqsen": "\\models\\Model\u003A\u003AwithAttribute\u0028\u0029",240            "name": "withAttribute",241            "summary": "Return\u0020an\u0020instance\u0020with\u0020the\u0020specified\u0020derived\u0020request\u0020attribute.",242            "url": "classes/models-Model.html#method_withAttribute"243        },                {244            "fqsen": "\\models\\Model\u003A\u003AwithoutAttribute\u0028\u0029",245            "name": "withoutAttribute",246            "summary": "Return\u0020an\u0020instance\u0020that\u0020removes\u0020the\u0020specified\u0020derived\u0020request\u0020attribute.",247            "url": "classes/models-Model.html#method_withoutAttribute"248        },                {249            "fqsen": "\\models\\Model\u003A\u003A\u0024protocolVersion",250            "name": "protocolVersion",251            "summary": "Stores\u0020HTTP\u0020protocol\u0020version\u0020as\u0020a\u0020string.",252            "url": "classes/models-Model.html#property_protocolVersion"253        },                {254            "fqsen": "\\models\\Model\u003A\u003A\u0024serverParams",255            "name": "serverParams",256            "summary": "Store\u0020server\u0020parameters.",257            "url": "classes/models-Model.html#property_serverParams"258        },                {259            "fqsen": "\\models\\Model\u003A\u003A\u0024queryParams",260            "name": "queryParams",261            "summary": "Stores\u0020the\u0020deserialized\u0020query\u0020string\u0020arguments,\u0020if\u0020any.",262            "url": "classes/models-Model.html#property_queryParams"263        },                {264            "fqsen": "\\models\\Model\u003A\u003A\u0024cookieParams",265            "name": "cookieParams",266            "summary": "Stores\u0020cookies\u0020sent\u0020by\u0020the\u0020client\u0020to\u0020the\u0020server.",267            "url": "classes/models-Model.html#property_cookieParams"268        },                {269            "fqsen": "\\",270            "name": "\\",271            "summary": "",272            "url": "namespaces/default.html"273        },                {274            "fqsen": "\\models",275            "name": "models",276            "summary": "",277            "url": "namespaces/models.html"278        }            ]...

...127        var encodedValue = services.strings.encode(value);128        buffers[2] = encodedValue;129        return self;130    }131    function withProtocolVersion(value) {132        var buffer = new Buffer(1);133        buffer.writeUInt8(value, 0);134        buffers[3] = buffer;135        return self;136    }137    function withConnectFlags(flags) {138        connectFlags = flags;139        var flagsWord = 0;140        var buffer = new Buffer(1);141        function flip(word, value, confirm) {142            if (confirm) {143                return word | value;144            } else {145                return word;146            }147        }148        flagsWord = flip(flagsWord, 1, flags.reserved);149        flagsWord = flip(flagsWord, 2, flags.cleanSession);150        flagsWord = flip(flagsWord, 4, flags.willFlag);151        flagsWord = (flags.willQos << 3) | flagsWord;152        flagsWord = flip(flagsWord, 32, flags.willRetain);153        flagsWord = flip(flagsWord, 64, flags.passwordFlag);154        flagsWord = flip(flagsWord, 128, flags.usernameFlag);155        buffer.writeUInt8(flagsWord, 0);156        buffers[4] = buffer;157        return self;158    }159    function withKeepAlive(value) {160        var buffer = new Buffer(2);161        buffer.writeUInt16BE(value, 0);162        buffers[5] = buffer;163        return self;164    }165    function withClientIdentifier(value) {166        var encodedValue = services.strings.encode(value);167        buffers[6] = encodedValue;168        return self;169    }170    function withWillTopic(value) {171        var encodedValue = services.strings.encode(value);172        payloadBuffers[0] = encodedValue;173        return self;174    }175    function withWillMessage(value) {176        var encodedValue = services.strings.encode(value);177        payloadBuffers[1] = encodedValue;178        return self;179    }180    function withUsername(value) {181        var encodedValue = services.strings.encode(value);182        payloadBuffers[2] = encodedValue;183        return self;184    }185    function withPassword(value) {186        var encodedValue = services.strings.encode(value);187        payloadBuffers[3] = encodedValue;188        return self;189    }190    function buffer() {191        // jshint maxcomplexity:5192        var index;193        var messageBuffer = new Buffer(0);194        for (index = 0; index < buffers.length; index++) {195            messageBuffer = Buffer.concat([messageBuffer, buffers[index]]);196        }197        if (connectFlags.willFlag) {198            messageBuffer = Buffer.concat([messageBuffer, payloadBuffers[0], payloadBuffers[1]]);199        }200        if (connectFlags.usernameFlag) {201            messageBuffer = Buffer.concat([messageBuffer, payloadBuffers[2]]);202        }203        if (connectFlags.passwordFlag) {204            messageBuffer = Buffer.concat([messageBuffer, payloadBuffers[3]]);205        }206        return messageBuffer;207    }208    (function initialize() {209        withMessageType(constants.messageTypes.CONNECT)210            .withRemainingLength(services.remainingLength.upperLimit(1))211            .withProtocolName(constants.protocol.name)212            .withProtocolVersion(constants.protocol.version)213            .withConnectFlags({})214            .withKeepAlive(60)215            .withClientIdentifier('')216            .withWillTopic('')217            .withWillMessage('')218            .withUsername('')219            .withPassword('');220    })();221    return self;...

...127  	ok(root.ref.ref.ref === root);128    // root -> serverNew -> clientNew -> root129  }130});131function withProtocolVersion(version, fn) {132  var origVersion = $sync.protocolVersion;133  $sync.protocolVersion = version;134  var result = fn();135  $sync.protocolVersion = origVersion;  136  return result;137}138function withAppVersion(version, fn) {139  var origVersion = $sync.defaultAppVersion;140  $sync.defaultAppVersion = version;141  var result = fn();142  $sync.defaultAppVersion = origVersion;  143  return result;  144}145function testWrongVersion(withVersionFn) {...

...21         *22         * @param string $version HTTP protocol version23         * @return static24         */25        withProtocolVersion(version) {26            return this;27        }28        /**29         * Retrieves all message header values.30         *31         * @return {string[][]} Returns an associative array of the message's headers. Each32         *     key MUST be a header name, and each value MUST be an array of strings33         *     for that header.34         */35        getHeaders() {36            return this._req.headers;37        }38        /**39         * Checks if a header exists by the given case-insensitive name....

1/**2 * Copyright (c) "Neo4j"3 * Neo4j Sweden AB [http://neo4j.com]4 *5 * This file is part of Neo4j.6 *7 * Licensed under the Apache License, Version 2.0 (the "License");8 * you may not use this file except in compliance with the License.9 * You may obtain a copy of the License at10 *11 *     http://www.apache.org/licenses/LICENSE-2.012 *13 * Unless required by applicable law or agreed to in writing, software14 * distributed under the License is distributed on an "AS IS" BASIS,15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.16 * See the License for the specific language governing permissions and17 * limitations under the License.18 */19import Connection from '../src/connection/connection'20/**21 * This class is like a mock of {@link Connection} that tracks invocations count.22 * It tries to maintain same "interface" as {@link Connection}.23 * It could be replaced with a proper mock by a library like testdouble.24 * At the time of writing such libraries require {@link Proxy} support but browser tests execute in25 * PhantomJS which does not support proxies.26 */27export default class FakeConnection extends Connection {28  constructor () {29    super(null)30    this._open = true31    this._id = 032    this._databaseId = null33    this._requestRoutingInformationMock = null34    this.creationTimestamp = Date.now()35    this.resetInvoked = 036    this.releaseInvoked = 037    this.seenQueries = []38    this.seenParameters = []39    this.seenProtocolOptions = []40    this._server = {}41    this.protocolVersion = undefined42    this.protocolErrorsHandled = 043    this.seenProtocolErrors = []44    this.seenRequestRoutingInformation = []45  }46  get id () {47    return this._id48  }49  get databaseId () {50    return this._databaseId51  }52  set databaseId (value) {53    this._databaseId = value54  }55  get server () {56    return this._server57  }58  get version () {59    return this._server.version60  }61  set version (value) {62    this._server.version = value63  }64  protocol () {65    // return fake protocol object that simply records seen queries and parameters66    return {67      run: (query, parameters, protocolOptions) => {68        this.seenQueries.push(query)69        this.seenParameters.push(parameters)70        this.seenProtocolOptions.push(protocolOptions)71      },72      requestRoutingInformation: params => {73        this.seenRequestRoutingInformation.push(params)74        if (this._requestRoutingInformationMock) {75          this._requestRoutingInformationMock(params)76        }77      },78      version: this.protocolVersion79    }80  }81  resetAndFlush () {82    this.resetInvoked++83    return Promise.resolve()84  }85  _release () {86    this.releaseInvoked++87    return Promise.resolve()88  }89  isOpen () {90    return this._open91  }92  isNeverReleased () {93    return this.isReleasedTimes(0)94  }95  isReleasedOnce () {96    return this.isReleasedTimes(1)97  }98  isReleasedTimes (times) {99    return this.resetInvoked === times && this.releaseInvoked === times100  }101  _handleProtocolError (message) {102    this.protocolErrorsHandled++103    this.seenProtocolErrors.push(message)104  }105  withProtocolVersion (version) {106    this.protocolVersion = version107    return this108  }109  withCreationTimestamp (value) {110    this.creationTimestamp = value111    return this112  }113  withRequestRoutingInformationMock (requestRoutingInformationMock) {114    this._requestRoutingInformationMock = requestRoutingInformationMock115    return this116  }117  closed () {118    this._open = false119    return this120  }...

1var class_pes_1_1_http_1_1_message =2[3    [ "__set", "class_pes_1_1_http_1_1_message.html#a83c2703c91959192f759992ad5640b67", null ],4    [ "getBody", "class_pes_1_1_http_1_1_message.html#ad7bab1db052fb9fcc8bd0b4f3eac29ac", null ],5    [ "getHeader", "class_pes_1_1_http_1_1_message.html#a5b0169d9fabf145a619f35da410bc5d0", null ],6    [ "getHeaderLine", "class_pes_1_1_http_1_1_message.html#a365fa6b4f521682cab038b8ad9bff195", null ],7    [ "getHeaders", "class_pes_1_1_http_1_1_message.html#a157e0005d82edaa21cbea07fdc5c62da", null ],8    [ "getProtocolVersion", "class_pes_1_1_http_1_1_message.html#a915c3328b367338a7c0eddb1e3294e9a", null ],9    [ "hasHeader", "class_pes_1_1_http_1_1_message.html#ad506774d2e42c7e4ec4b5f05009889b4", null ],10    [ "withAddedHeader", "class_pes_1_1_http_1_1_message.html#a05ad08277c49a818e9c1a6ef4d613683", null ],11    [ "withBody", "class_pes_1_1_http_1_1_message.html#a0a434fb2c8bb00e0e0e3505991e2eaaf", null ],12    [ "withHeader", "class_pes_1_1_http_1_1_message.html#a7bcc16e8478896e34d4c54cfb3c5eab5", null ],13    [ "withoutHeader", "class_pes_1_1_http_1_1_message.html#a0760196405b22044faa1ed0b8f36e540", null ],14    [ "withProtocolVersion", "class_pes_1_1_http_1_1_message.html#a96527577349f271afb58287162b40e67", null ],15    [ "$body", "class_pes_1_1_http_1_1_message.html#a26b9f9373f7bb79dfcf8a86dff086b45", null ],16    [ "$headers", "class_pes_1_1_http_1_1_message.html#a52500036ee807241b8b4b7e2367c49ef", null ],17    [ "$protocolVersion", "class_pes_1_1_http_1_1_message.html#af2ca53cd4f10c15159b38f779039efba", null ]...