@@ -5,7 +5,7 @@ var con = new Connection({
5
5
stream : stream
6
6
} ) ;
7
7
8
- assert . recieved = function ( stream , buffer ) {
8
+ assert . received = function ( stream , buffer ) {
9
9
assert . length ( stream . packets , 1 ) ;
10
10
var packet = stream . packets . pop ( ) ;
11
11
assert . equalBuffers ( packet , buffer ) ;
@@ -16,7 +16,7 @@ test("sends startup message", function() {
16
16
user : 'brian' ,
17
17
database : 'bang'
18
18
} ) ;
19
- assert . recieved ( stream , new BufferList ( )
19
+ assert . received ( stream , new BufferList ( )
20
20
. addInt16 ( 3 )
21
21
. addInt16 ( 0 )
22
22
. addCString ( 'user' )
@@ -28,13 +28,13 @@ test("sends startup message", function() {
28
28
29
29
test ( 'sends password message' , function ( ) {
30
30
con . password ( "!" ) ;
31
- assert . recieved ( stream , new BufferList ( ) . addCString ( "!" ) . join ( true , 'p' ) ) ;
31
+ assert . received ( stream , new BufferList ( ) . addCString ( "!" ) . join ( true , 'p' ) ) ;
32
32
} ) ;
33
33
34
34
test ( 'sends query message' , function ( ) {
35
35
var txt = 'select * from boom' ;
36
36
con . query ( txt ) ;
37
- assert . recieved ( stream , new BufferList ( ) . addCString ( txt ) . join ( true , 'Q' ) ) ;
37
+ assert . received ( stream , new BufferList ( ) . addCString ( txt ) . join ( true , 'Q' ) ) ;
38
38
} ) ;
39
39
40
40
test ( 'sends parse message' , function ( ) {
@@ -43,7 +43,7 @@ test('sends parse message', function() {
43
43
. addCString ( "" )
44
44
. addCString ( "!" )
45
45
. addInt16 ( 0 ) . join ( true , 'P' ) ;
46
- assert . recieved ( stream , expected ) ;
46
+ assert . received ( stream , expected ) ;
47
47
} ) ;
48
48
49
49
test ( 'sends parse message with named query' , function ( ) {
@@ -56,7 +56,7 @@ test('sends parse message with named query', function() {
56
56
. addCString ( "boom" )
57
57
. addCString ( "select * from boom" )
58
58
. addInt16 ( 0 ) . join ( true , 'P' ) ;
59
- assert . recieved ( stream , expected ) ;
59
+ assert . received ( stream , expected ) ;
60
60
61
61
test ( 'with multiple parameters' , function ( ) {
62
62
con . parse ( {
@@ -72,7 +72,7 @@ test('sends parse message with named query', function() {
72
72
. addInt32 ( 2 )
73
73
. addInt32 ( 3 )
74
74
. addInt32 ( 4 ) . join ( true , 'P' ) ;
75
- assert . recieved ( stream , expected ) ;
75
+ assert . received ( stream , expected ) ;
76
76
} ) ;
77
77
} ) ;
78
78
@@ -87,7 +87,7 @@ test('bind messages', function() {
87
87
. addInt16 ( 0 )
88
88
. addInt16 ( 0 )
89
89
. join ( true , "B" ) ;
90
- assert . recieved ( stream , expectedBuffer ) ;
90
+ assert . received ( stream , expectedBuffer ) ;
91
91
} ) ;
92
92
93
93
test ( 'with named statement, portal, and values' , function ( ) {
@@ -110,7 +110,7 @@ test('bind messages', function() {
110
110
. add ( Buffer ( 'zing' ) )
111
111
. addInt16 ( 0 )
112
112
. join ( true , 'B' ) ;
113
- assert . recieved ( stream , expectedBuffer ) ;
113
+ assert . received ( stream , expectedBuffer ) ;
114
114
} ) ;
115
115
} ) ;
116
116
@@ -123,7 +123,7 @@ test("sends execute message", function() {
123
123
. addCString ( '' )
124
124
. addInt32 ( 0 )
125
125
. join ( true , 'E' ) ;
126
- assert . recieved ( stream , expectedBuffer ) ;
126
+ assert . received ( stream , expectedBuffer ) ;
127
127
} ) ;
128
128
129
129
test ( "for named portal with row limit" , function ( ) {
@@ -135,38 +135,38 @@ test("sends execute message", function() {
135
135
. addCString ( "my favorite portal" )
136
136
. addInt32 ( 100 )
137
137
. join ( true , 'E' ) ;
138
- assert . recieved ( stream , expectedBuffer ) ;
138
+ assert . received ( stream , expectedBuffer ) ;
139
139
} ) ;
140
140
} ) ;
141
141
142
142
test ( 'sends flush command' , function ( ) {
143
143
con . flush ( ) ;
144
144
var expected = new BufferList ( ) . join ( true , 'H' ) ;
145
- assert . recieved ( stream , expected ) ;
145
+ assert . received ( stream , expected ) ;
146
146
} ) ;
147
147
148
148
test ( 'sends sync command' , function ( ) {
149
149
con . sync ( ) ;
150
150
var expected = new BufferList ( ) . join ( true , 'S' ) ;
151
- assert . recieved ( stream , expected ) ;
151
+ assert . received ( stream , expected ) ;
152
152
} ) ;
153
153
154
154
test ( 'sends end command' , function ( ) {
155
155
con . end ( ) ;
156
156
var expected = new Buffer ( [ 0x58 , 0 , 0 , 0 , 4 ] ) ;
157
- assert . recieved ( stream , expected ) ;
157
+ assert . received ( stream , expected ) ;
158
158
} ) ;
159
159
160
160
test ( 'sends describe command' , function ( ) {
161
161
test ( 'describe statement' , function ( ) {
162
162
con . describe ( { type : 'S' , name : 'bang' } ) ;
163
163
var expected = new BufferList ( ) . addChar ( 'S' ) . addCString ( 'bang' ) . join ( true , 'D' )
164
- assert . recieved ( stream , expected ) ;
164
+ assert . received ( stream , expected ) ;
165
165
} ) ;
166
166
167
167
test ( "describe unnamed portal" , function ( ) {
168
168
con . describe ( { type : 'P' } ) ;
169
169
var expected = new BufferList ( ) . addChar ( 'P' ) . addCString ( "" ) . join ( true , "D" ) ;
170
- assert . recieved ( stream , expected ) ;
170
+ assert . received ( stream , expected ) ;
171
171
} ) ;
172
172
} ) ;
0 commit comments