Skip to content

Commit ab56adf

Browse files
Modify pg tests
1 parent a8d4e8f commit ab56adf

File tree

9 files changed

+33
-6941
lines changed

9 files changed

+33
-6941
lines changed

package.json

+2-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@
2626
"eslint-plugin-prettier": "^3.1.4",
2727
"lerna": "^4.0.0",
2828
"prettier": "2.1.2",
29-
"typescript": "^4.0.3"
29+
"typescript": "^4.0.3",
30+
"webpack-cli": "^4.9.2"
3031
},
3132
"prettier": {
3233
"semi": false,

packages/pg/lib/connection.js

+1-2
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ class Connection extends EventEmitter {
5252
if(port && host) {
5353
var url = 'ws://'+host+':'+port;
5454
} else {
55-
var url = 'ws://localhost:5901'
55+
var url = 'ws://localhost:5432'
5656
}
5757
this.stream = new WebSocketStream(url)
5858
this.placeholderStream = false
@@ -131,7 +131,6 @@ class Connection extends EventEmitter {
131131
this.emit('message', msg)
132132
}
133133
this.emit(eventName, msg)
134-
// console.log(msg)
135134
})
136135
}
137136

packages/pg/lib/defaults.js

+3-6
Original file line numberDiff line numberDiff line change
@@ -6,23 +6,20 @@ module.exports = {
66

77
// database user's name
88
user: process.platform === 'win32' ? process.env.USERNAME : process.env.USER,
9-
// user: 'postgres',
109

1110
// name of database to connect
12-
// database: undefined,
13-
database: 'postgres',
11+
database: undefined,
1412

1513
// database user's password
16-
// password: null,
17-
password: 'password',
14+
password: null,
1815

1916
// a Postgres connection string to be used instead of setting individual connection items
2017
// NOTE: Setting this value will cause it to override any other value (such as database or user) defined
2118
// in the defaults object.
2219
connectionString: undefined,
2320

2421
// database port
25-
port: 5901,
22+
port: 5432,
2623

2724
// number of rows to return at a time from a prepared statement's
2825
// portal. 0 will return all rows at once

packages/pg/package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "pg-browser",
3-
"version": "1.0.3",
3+
"version": "1.0.5",
44
"description": "PostgreSQL with websockets",
55
"keywords": [
66
"database",

packages/pg/test/integration/client/configuration-tests.js

+6-6
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,9 @@ for (var key in process.env) {
1414
suite.test('default values are used in new clients', function () {
1515
assert.same(pg.defaults, {
1616
user: process.env.USER,
17-
database: 'postgres',
18-
password: 'password',
19-
port: 5901,
17+
database: undefined,
18+
password: null,
19+
port: 5432,
2020
rows: 0,
2121
max: 10,
2222
binary: false,
@@ -31,9 +31,9 @@ suite.test('default values are used in new clients', function () {
3131
var client = new pg.Client()
3232
assert.same(client, {
3333
user: process.env.USER,
34-
database: 'postgres',
35-
password: 'password',
36-
port: 5901,
34+
database: process.env.USER,
35+
password: null,
36+
port: 5432,
3737
})
3838
})
3939

packages/pg/test/integration/connection/test-helper.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ var connect = function (callback) {
88
var username = helper.args.user
99
var database = helper.args.database
1010
// var con = new Connection({ stream: new net.Stream() })
11-
var con = new Connection({stream: new WebSocketStream('ws://localhost:5901')})
11+
var con = new Connection({stream: new WebSocketStream('ws://localhost:5432')})
1212
con.on('error', function (error) {
1313
console.log(error)
1414
throw new Error('Connection error')

packages/pg/test/unit/client/configuration-tests.js

+5-5
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@ require('./test-helper')
33
var assert = require('assert')
44

55
var pguser = process.env['PGUSER'] || process.env.USER
6-
var pgdatabase = process.env['PGDATABASE'] || 'postgres'
7-
var pgport = process.env['PGPORT'] || 5901
6+
var pgdatabase = process.env['PGDATABASE'] || process.env.USER
7+
var pgport = process.env['PGPORT'] || 5432
88

99
test('client settings', function () {
1010
test('defaults', function () {
@@ -90,10 +90,10 @@ test('initializing from a config string', function () {
9090
test('when not including all values the defaults are used', function () {
9191
var client = new Client('postgres://host1')
9292
assert.equal(client.user, process.env['PGUSER'] || process.env.USER)
93-
assert.equal(client.password, process.env['PGPASSWORD'] || 'password')
93+
assert.equal(client.password, process.env['PGPASSWORD'] || null)
9494
assert.equal(client.host, 'host1')
95-
assert.equal(client.port, process.env['PGPORT'] || 5901)
96-
assert.equal(client.database, process.env['PGDATABASE'] || 'postgres')
95+
assert.equal(client.port, process.env['PGPORT'] || 5432)
96+
assert.equal(client.database, process.env['PGDATABASE'] || process.env.USER)
9797
})
9898

9999
test('when not including all values the environment variables are used', function () {

packages/pg/test/unit/connection/startup-tests.js

+14-14
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ test('connection can take existing stream', function () {
77
assert.equal(con.stream, stream)
88
})
99

10-
// test('using any stream', function () {
10+
test('using any stream', function () {
1111
// var makeStream = function () {
1212
// var stream = new MemoryStream()
1313

@@ -20,10 +20,10 @@ test('connection can take existing stream', function () {
2020
// }
2121

2222
// var stream = makeStream()
23-
24-
// var con = new Connection({ stream: stream })
25-
// con = new Client({connection: con})
26-
// con.connect()
23+
var stream = new MemoryStream()
24+
var con = new Connection({ stream: stream })
25+
con = new Client({connection: con})
26+
con.connect()
2727
// con.websocket.close()
2828
// con.end()
2929
// test('makes stream connect', function () {
@@ -38,16 +38,16 @@ test('connection can take existing stream', function () {
3838
// assert.equal(stream.host, 'bang')
3939
// })
4040

41-
// test('after stream connects client emits connected event', function () {
42-
// var hit = false
41+
test('after stream connects client emits connected event', function () {
42+
var hit = false
4343

44-
// con.once('connect', function () {
45-
// hit = true
46-
// })
44+
con.once('connect', function () {
45+
hit = true
46+
})
4747

48-
// assert.ok(stream.emit('connect'))
49-
// assert.ok(hit)
50-
// })
48+
assert.ok(con.emit('connect'))
49+
assert.ok(hit)
50+
})
5151

5252
// TCP-keepalive not relevant for websockets
5353

@@ -67,4 +67,4 @@ test('connection can take existing stream', function () {
6767
// assert.equal(res, true)
6868
// })
6969
// })
70-
// })
70+
})

0 commit comments

Comments
 (0)