44//
55
66// Place this right on top
7- import { initialize } from './../initialize' ;
87// The module 'assert' provides assertion methods from node
98import * as assert from 'assert' ;
109
1110// You can import and use all API from the 'vscode' module
1211// as well as import your extension to test it
13- import * as vscode from 'vscode' ;
14- import { SocketStream } from '../../client/common/net/socket/SocketStream' ;
1512import * as net from 'net' ;
16- const uint64be = require ( "uint64be" ) ;
13+ import { SocketStream } from '../../client/common/net/socket/SocketStream' ;
14+ // tslint:disable:no-require-imports no-var-requires
15+ const uint64be = require ( 'uint64be' ) ;
1716
1817class MockSocket {
18+ private _data : string ;
19+ // tslint:disable-next-line:no-any
20+ private _rawDataWritten : any ;
1921 constructor ( ) {
2022 this . _data = '' ;
2123 }
22- private _data : string ;
23- private _rawDataWritten : any ;
2424 public get dataWritten ( ) : string {
2525 return this . _data ;
2626 }
27+ // tslint:disable-next-line:no-any
2728 public get rawDataWritten ( ) : any {
2829 return this . _rawDataWritten ;
2930 }
30- write ( data : any ) {
31- this . _data = data + '' ;
31+ // tslint:disable-next-line:no-any
32+ public write ( data : any ) {
33+ this . _data = `${ data } ` + '' ;
3234 this . _rawDataWritten = data ;
3335 }
3436}
3537// Defines a Mocha test suite to group tests of similar kind together
38+ // tslint:disable-next-line:max-func-body-length
3639suite ( 'SocketStream' , ( ) => {
3740 test ( 'Read Byte' , done => {
38- let buffer = new Buffer ( "X" ) ;
41+ const buffer = new Buffer ( 'X' ) ;
3942 const byteValue = buffer [ 0 ] ;
4043 const socket = new MockSocket ( ) ;
41- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
44+ // tslint:disable-next-line:no-any
45+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
4246
4347 assert . equal ( stream . ReadByte ( ) , byteValue ) ;
4448 done ( ) ;
4549 } ) ;
4650 test ( 'Read Int32' , done => {
4751 const num = 1234 ;
4852 const socket = new MockSocket ( ) ;
49- let buffer = uint64be . encode ( num ) ;
50- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
53+ const buffer = uint64be . encode ( num ) ;
54+ // tslint:disable-next-line:no-any
55+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
5156
5257 assert . equal ( stream . ReadInt32 ( ) , num ) ;
5358 done ( ) ;
5459 } ) ;
5560 test ( 'Read Int64' , done => {
5661 const num = 9007199254740993 ;
5762 const socket = new MockSocket ( ) ;
58- let buffer = uint64be . encode ( num ) ;
59- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
63+ const buffer = uint64be . encode ( num ) ;
64+ // tslint:disable-next-line:no-any
65+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
6066
6167 assert . equal ( stream . ReadInt64 ( ) , num ) ;
6268 done ( ) ;
6369 } ) ;
6470 test ( 'Read Ascii String' , done => {
6571 const message = 'Hello World' ;
6672 const socket = new MockSocket ( ) ;
67- let buffer = Buffer . concat ( [ new Buffer ( 'A' ) , uint64be . encode ( message . length ) , new Buffer ( message ) ] ) ;
68- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
73+ const buffer = Buffer . concat ( [ new Buffer ( 'A' ) , uint64be . encode ( message . length ) , new Buffer ( message ) ] ) ;
74+ // tslint:disable-next-line:no-any
75+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
6976
7077 assert . equal ( stream . ReadString ( ) , message ) ;
7178 done ( ) ;
@@ -74,8 +81,9 @@ suite('SocketStream', () => {
7481 const message = 'Hello World - Функция проверки ИНН и КПП - 说明' ;
7582 const socket = new MockSocket ( ) ;
7683 const stringBuffer = new Buffer ( message ) ;
77- let buffer = Buffer . concat ( [ Buffer . concat ( [ new Buffer ( 'U' ) , uint64be . encode ( stringBuffer . byteLength ) ] ) , stringBuffer ] ) ;
78- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
84+ const buffer = Buffer . concat ( [ Buffer . concat ( [ new Buffer ( 'U' ) , uint64be . encode ( stringBuffer . byteLength ) ] ) , stringBuffer ] ) ;
85+ // tslint:disable-next-line:no-any
86+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
7987
8088 assert . equal ( stream . ReadString ( ) , message ) ;
8189 done ( ) ;
@@ -88,11 +96,12 @@ suite('SocketStream', () => {
8896 // Write part of a second message
8997 const partOfSecondMessage = Buffer . concat ( [ new Buffer ( 'A' ) , uint64be . encode ( message . length ) ] ) ;
9098 buffer = Buffer . concat ( [ buffer , partOfSecondMessage ] ) ;
91- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
99+ // tslint:disable-next-line:no-any
100+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
92101
93102 stream . BeginTransaction ( ) ;
94103 assert . equal ( stream . ReadString ( ) , message , 'First message not read properly' ) ;
95- const secondMessage = stream . ReadString ( ) ;
104+ stream . ReadString ( ) ;
96105 assert . equal ( stream . HasInsufficientDataForReading , true , 'Should not have sufficient data for reading' ) ;
97106 stream . RollBackTransaction ( ) ;
98107 assert . equal ( stream . ReadString ( ) , message , 'First message not read properly after rolling back transaction' ) ;
@@ -106,11 +115,12 @@ suite('SocketStream', () => {
106115 // Write part of a second message
107116 const partOfSecondMessage = Buffer . concat ( [ new Buffer ( 'A' ) , uint64be . encode ( message . length ) ] ) ;
108117 buffer = Buffer . concat ( [ buffer , partOfSecondMessage ] ) ;
109- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
118+ // tslint:disable-next-line:no-any
119+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
110120
111121 stream . BeginTransaction ( ) ;
112122 assert . equal ( stream . ReadString ( ) , message , 'First message not read properly' ) ;
113- const secondMessage = stream . ReadString ( ) ;
123+ stream . ReadString ( ) ;
114124 assert . equal ( stream . HasInsufficientDataForReading , true , 'Should not have sufficient data for reading' ) ;
115125 stream . EndTransaction ( ) ;
116126 stream . RollBackTransaction ( ) ;
@@ -121,50 +131,55 @@ suite('SocketStream', () => {
121131 const message = 'Hello World' ;
122132 const buffer = new Buffer ( '' ) ;
123133 const socket = new MockSocket ( ) ;
124- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
134+ // tslint:disable-next-line:no-any
135+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
125136 stream . Write ( new Buffer ( message ) ) ;
126137
127- assert . equal ( socket . dataWritten , message )
138+ assert . equal ( socket . dataWritten , message ) ;
128139 done ( ) ;
129140 } ) ;
130141 test ( 'Write Int32' , done => {
131142 const num = 1234 ;
132143 const buffer = new Buffer ( '' ) ;
133144 const socket = new MockSocket ( ) ;
134- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
145+ // tslint:disable-next-line:no-any
146+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
135147 stream . WriteInt32 ( num ) ;
136148
137- assert . equal ( uint64be . decode ( socket . rawDataWritten ) , num )
149+ assert . equal ( uint64be . decode ( socket . rawDataWritten ) , num ) ;
138150 done ( ) ;
139151 } ) ;
140152 test ( 'Write Int64' , done => {
141153 const num = 9007199254740993 ;
142154 const buffer = new Buffer ( '' ) ;
143155 const socket = new MockSocket ( ) ;
144- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
156+ // tslint:disable-next-line:no-any
157+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
145158 stream . WriteInt64 ( num ) ;
146159
147- assert . equal ( uint64be . decode ( socket . rawDataWritten ) , num )
160+ assert . equal ( uint64be . decode ( socket . rawDataWritten ) , num ) ;
148161 done ( ) ;
149162 } ) ;
150163 test ( 'Write Ascii String' , done => {
151164 const message = 'Hello World' ;
152165 const buffer = new Buffer ( '' ) ;
153166 const socket = new MockSocket ( ) ;
154- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
167+ // tslint:disable-next-line:no-any
168+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
155169 stream . WriteString ( message ) ;
156170
157- assert . equal ( socket . dataWritten , message )
171+ assert . equal ( socket . dataWritten , message ) ;
158172 done ( ) ;
159173 } ) ;
160174 test ( 'Write Unicode String' , done => {
161175 const message = 'Hello World - Функция проверки ИНН и КПП - 说明' ;
162176 const buffer = new Buffer ( '' ) ;
163177 const socket = new MockSocket ( ) ;
164- const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer )
178+ // tslint:disable-next-line:no-any
179+ const stream = new SocketStream ( ( socket as any ) as net . Socket , buffer ) ;
165180 stream . WriteString ( message ) ;
166181
167- assert . equal ( socket . dataWritten , message )
182+ assert . equal ( socket . dataWritten , message ) ;
168183 done ( ) ;
169184 } ) ;
170185} ) ;
0 commit comments