Lloyd Brookes
9 years ago
27 changed files with 371 additions and 367 deletions
-
2bin/cli.js
-
2lib/local-web-server.js
-
11lib/middleware-stack.js
-
2lib/middleware.js
-
2package.json
-
22test/common.js
-
0test/compress/big-file.txt
-
22test/compress/compress.js
-
21test/forbid/forbid.js
-
0test/forbid/one.html
-
0test/forbid/two.php
-
25test/log/log.js
-
22test/mime/mime.js
-
0test/mime/something.php
-
150test/mock/mock.js
-
1test/mock/one.html
-
29test/proxy/rewrite-proxy.js
-
1test/rewrite/one.html
-
19test/rewrite/rewrite.js
-
18test/serve-index/serve-index.js
-
1test/spa/one.txt
-
28test/spa/spa.js
-
1test/spa/two.txt
-
33test/static.js
-
1test/static/file.txt
-
18test/static/static.js
-
305test/test.js
@ -0,0 +1,22 @@ |
|||||
|
'use strict' |
||||
|
const arrayify = require('array-back') |
||||
|
|
||||
|
exports.checkResponse = checkResponse |
||||
|
exports.fail = fail |
||||
|
|
||||
|
function checkResponse (t, status, bodyTests) { |
||||
|
return function (response) { |
||||
|
if (status) t.strictEqual(response.res.statusCode, status) |
||||
|
if (bodyTests) { |
||||
|
arrayify(bodyTests).forEach(body => { |
||||
|
t.ok(body.test(response.data), 'correct data') |
||||
|
}) |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
function fail (t) { |
||||
|
return function (err) { |
||||
|
t.fail('failed: ' + err.stack) |
||||
|
} |
||||
|
} |
@ -0,0 +1,22 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('compress', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addCompression(true) |
||||
|
ws.addStatic(__dirname) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/big-file.txt', { headers: { 'Accept-Encoding': 'gzip' } }) |
||||
|
.then(response => { |
||||
|
t.strictEqual(response.res.statusCode, 200) |
||||
|
t.strictEqual(response.res.headers['content-encoding'], 'gzip') |
||||
|
}) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1,21 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('forbid', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addBlacklist([ '*.php', '*.html' ]) |
||||
|
ws.addStatic(__dirname) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/two.php') |
||||
|
.then(c.checkResponse(t, 403)) |
||||
|
.then(() => request('http://localhost:8100/one.html')) |
||||
|
.then(c.checkResponse(t, 403)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1,25 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('logging', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
|
||||
|
const stream = require('stream').PassThrough() |
||||
|
stream.on('readable', () => { |
||||
|
let chunk = stream.read() |
||||
|
if (chunk) t.ok(/GET/.test(chunk.toString())) |
||||
|
}) |
||||
|
|
||||
|
ws.addLogging('common', { stream: stream }) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/') |
||||
|
.then(c.checkResponse(t, 404)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1,22 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('mime override', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMimeOverride({ 'text/plain': [ 'php' ] }) |
||||
|
ws.addStatic(__dirname) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/something.php') |
||||
|
.then(response => { |
||||
|
t.strictEqual(response.res.statusCode, 200) |
||||
|
t.ok(/text\/plain/.test(response.res.headers['content-type'])) |
||||
|
}) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1,150 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('mock: simple response', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ route: '/test', response: { body: 'test' } } |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test') |
||||
|
.then(c.checkResponse(t, 200, /test/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
||||
|
|
||||
|
test('mock: method request filter', function (t) { |
||||
|
t.plan(3) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ |
||||
|
route: '/test', |
||||
|
request: { method: 'POST' }, |
||||
|
response: { body: 'test' } |
||||
|
} |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test') |
||||
|
.then(c.checkResponse(t, 404)) |
||||
|
.then(() => request('http://localhost:8100/test', { data: 'something' })) |
||||
|
.then(c.checkResponse(t, 200, /test/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
||||
|
|
||||
|
test('mock: accepts request filter', function (t) { |
||||
|
t.plan(3) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ |
||||
|
route: '/test', |
||||
|
request: { accepts: 'text' }, |
||||
|
response: { body: 'test' } |
||||
|
} |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test', { headers: { Accept: '*/json' } }) |
||||
|
.then(c.checkResponse(t, 404)) |
||||
|
.then(() => request('http://localhost:8100/test', { headers: { Accept: 'text/plain' } })) |
||||
|
.then(c.checkResponse(t, 200, /test/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
}) |
||||
|
}) |
||||
|
|
||||
|
test('mock: responses array', function (t) { |
||||
|
t.plan(4) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ |
||||
|
route: '/test', |
||||
|
responses: [ |
||||
|
{ request: { method: 'GET' }, response: { body: 'get' } }, |
||||
|
{ request: { method: 'POST' }, response: { body: 'post' } } |
||||
|
] |
||||
|
} |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test') |
||||
|
.then(c.checkResponse(t, 200, /get/)) |
||||
|
.then(() => request('http://localhost:8100/test', { method: 'POST' })) |
||||
|
.then(c.checkResponse(t, 200, /post/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
}) |
||||
|
}) |
||||
|
|
||||
|
test('mock: response function', function (t) { |
||||
|
t.plan(4) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ |
||||
|
route: '/test', |
||||
|
responses: [ |
||||
|
{ request: { method: 'GET' }, response: ctx => ctx.body = 'get' }, |
||||
|
{ request: { method: 'POST' }, response: ctx => ctx.body = 'post' } |
||||
|
] |
||||
|
} |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test') |
||||
|
.then(c.checkResponse(t, 200, /get/)) |
||||
|
.then(() => request('http://localhost:8100/test', { method: 'POST' })) |
||||
|
.then(c.checkResponse(t, 200, /post/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
}) |
||||
|
}) |
||||
|
|
||||
|
test('mock: response function args', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ |
||||
|
route: '/test/:one', |
||||
|
responses: [ |
||||
|
{ request: { method: 'GET' }, response: (ctx, one) => ctx.body = one } |
||||
|
] |
||||
|
} |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test/yeah') |
||||
|
.then(c.checkResponse(t, 200, /yeah/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
}) |
||||
|
}) |
||||
|
|
||||
|
test('mock: async response function', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addMockResponses([ |
||||
|
{ |
||||
|
route: '/test', |
||||
|
responses: { |
||||
|
response: function (ctx) { |
||||
|
return new Promise((resolve, reject) => { |
||||
|
setTimeout(() => { |
||||
|
ctx.body = 'test' |
||||
|
resolve() |
||||
|
}, 10) |
||||
|
}) |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
]) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/test') |
||||
|
.then(c.checkResponse(t, 200, /test/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1 @@ |
|||||
|
one |
@ -0,0 +1 @@ |
|||||
|
one |
@ -0,0 +1,19 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('rewrite local', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addRewrite([ { from: '/two.html', to: '/one.html' } ]) |
||||
|
ws.addStatic(__dirname) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/two.html') |
||||
|
.then(c.checkResponse(t, 200, /one/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1,18 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('static', function (t) { |
||||
|
t.plan(3) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addIndex(__dirname, { icons: true }) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/') |
||||
|
.then(c.checkResponse(t, 200, [ /listing directory/, /class="icon/ ])) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1 @@ |
|||||
|
one |
@ -0,0 +1,28 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('spa', function (t) { |
||||
|
t.plan(6) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addSpa('one.txt') |
||||
|
ws.addStatic(__dirname) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/asdf', { headers: { accept: 'text/html' } }) |
||||
|
.then(c.checkResponse(t, 200, /one/)) |
||||
|
/* html requests for missing files with extensions do not redirect to spa */ |
||||
|
.then(() => request('http://localhost:8100/asdf.txt', { headers: { accept: 'text/html' } })) |
||||
|
.then(c.checkResponse(t, 404)) |
||||
|
/* existing static file */ |
||||
|
.then(() => request('http://localhost:8100/two.txt')) |
||||
|
.then(c.checkResponse(t, 200, /two/)) |
||||
|
/* not a text/html request - does not redirect to spa */ |
||||
|
.then(() => request('http://localhost:8100/asdf', { headers: { accept: 'application/json' } })) |
||||
|
.then(c.checkResponse(t, 404)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -0,0 +1 @@ |
|||||
|
two |
@ -1,33 +0,0 @@ |
|||||
'use strict' |
|
||||
const test = require('tape') |
|
||||
const request = require('req-then') |
|
||||
const localWebServer = require('../') |
|
||||
const http = require('http') |
|
||||
|
|
||||
function launchServer (app, options) { |
|
||||
options = options || {} |
|
||||
const path = `http://localhost:8100${options.path || '/'}` |
|
||||
const server = http.createServer(app.callback()) |
|
||||
return server.listen(options.port || 8100, () => { |
|
||||
const req = request(path, options.reqOptions) |
|
||||
if (options.onSuccess) req.then(options.onSuccess) |
|
||||
if (!options.leaveOpen) req.then(() => server.close()) |
|
||||
req.catch(err => console.error('LAUNCH ERROR', err.stack)) |
|
||||
}) |
|
||||
} |
|
||||
|
|
||||
test('static', function (t) { |
|
||||
t.plan(1) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
static: { |
|
||||
root: __dirname + '/fixture', |
|
||||
options: { |
|
||||
index: 'file.txt' |
|
||||
} |
|
||||
} |
|
||||
}) |
|
||||
launchServer(app, { onSuccess: response => { |
|
||||
t.ok(/test/.test(response.data)) |
|
||||
}}) |
|
||||
}) |
|
@ -0,0 +1 @@ |
|||||
|
test |
@ -0,0 +1,18 @@ |
|||||
|
'use strict' |
||||
|
const test = require('tape') |
||||
|
const request = require('req-then') |
||||
|
const LocalWebServer = require('../../') |
||||
|
const c = require('../common') |
||||
|
|
||||
|
test('static', function (t) { |
||||
|
t.plan(2) |
||||
|
const ws = new LocalWebServer() |
||||
|
ws.addStatic(__dirname, { index: 'file.txt' }) |
||||
|
const server = ws.getServer() |
||||
|
server.listen(8100, () => { |
||||
|
request('http://localhost:8100/') |
||||
|
.then(c.checkResponse(t, 200, /test/)) |
||||
|
.then(server.close.bind(server)) |
||||
|
.catch(c.fail(t)) |
||||
|
}) |
||||
|
}) |
@ -1,305 +0,0 @@ |
|||||
'use strict' |
|
||||
const test = require('tape') |
|
||||
const request = require('req-then') |
|
||||
const localWebServer = require('../') |
|
||||
const http = require('http') |
|
||||
const PassThrough = require('stream').PassThrough |
|
||||
|
|
||||
function launchServer (app, options) { |
|
||||
options = options || {} |
|
||||
const path = `http://localhost:8100${options.path || '/'}` |
|
||||
const server = http.createServer(app.callback()) |
|
||||
return server.listen(options.port || 8100, () => { |
|
||||
const req = request(path, options.reqOptions) |
|
||||
if (options.onSuccess) req.then(options.onSuccess) |
|
||||
if (!options.leaveOpen) req.then(() => server.close()) |
|
||||
req.catch(err => console.error('LAUNCH ERROR', err.stack)) |
|
||||
}) |
|
||||
} |
|
||||
|
|
||||
function checkResponse (t, status, body) { |
|
||||
return function (response) { |
|
||||
if (status) t.strictEqual(response.res.statusCode, status) |
|
||||
if (body) t.ok(body.test(response.data)) |
|
||||
} |
|
||||
} |
|
||||
|
|
||||
test('serve-index', function (t) { |
|
||||
t.plan(2) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
serveIndex: { |
|
||||
path: __dirname + '/fixture', |
|
||||
options: { |
|
||||
icons: true |
|
||||
} |
|
||||
} |
|
||||
}) |
|
||||
launchServer(app, { onSuccess: response => { |
|
||||
t.ok(/listing directory/.test(response.data)) |
|
||||
t.ok(/class="icon/.test(response.data)) |
|
||||
}}) |
|
||||
}) |
|
||||
|
|
||||
test('single page app', function (t) { |
|
||||
t.plan(6) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
static: { root: __dirname + '/fixture/spa' }, |
|
||||
spa: 'one.txt' |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
/* text/html requests for missing files redirect to spa */ |
|
||||
request('http://localhost:8100/asdf', { headers: { accept: 'text/html' } }) |
|
||||
.then(checkResponse(t, 200, /one/)) |
|
||||
/* html requests for missing files with extensions do not redirect to spa */ |
|
||||
.then(() => request('http://localhost:8100/asdf.txt', { headers: { accept: 'text/html' } })) |
|
||||
.then(checkResponse(t, 404)) |
|
||||
/* existing static file */ |
|
||||
.then(() => request('http://localhost:8100/two.txt')) |
|
||||
.then(checkResponse(t, 200, /two/)) |
|
||||
/* not a text/html request - does not redirect to spa */ |
|
||||
.then(() => request('http://localhost:8100/asdf')) |
|
||||
.then(checkResponse(t, 404)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('log: common', function (t) { |
|
||||
t.plan(1) |
|
||||
const stream = PassThrough() |
|
||||
|
|
||||
stream.on('readable', () => { |
|
||||
let chunk = stream.read() |
|
||||
if (chunk) t.ok(/GET/.test(chunk.toString())) |
|
||||
}) |
|
||||
|
|
||||
const app = localWebServer({ |
|
||||
log: { |
|
||||
format: 'common', |
|
||||
options: { |
|
||||
stream: stream |
|
||||
} |
|
||||
} |
|
||||
}) |
|
||||
launchServer(app) |
|
||||
}) |
|
||||
|
|
||||
test('compress', function (t) { |
|
||||
t.plan(1) |
|
||||
const app = localWebServer({ |
|
||||
compress: true, |
|
||||
log: { format: 'none' }, |
|
||||
static: { root: __dirname + '/fixture' } |
|
||||
}) |
|
||||
launchServer( |
|
||||
app, |
|
||||
{ |
|
||||
reqOptions: { headers: { 'Accept-Encoding': 'gzip' } }, |
|
||||
path: '/big-file.txt', |
|
||||
onSuccess: response => { |
|
||||
t.strictEqual(response.res.headers['content-encoding'], 'gzip') |
|
||||
} |
|
||||
} |
|
||||
) |
|
||||
}) |
|
||||
|
|
||||
test('mime', function (t) { |
|
||||
t.plan(2) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
static: { root: __dirname + '/fixture' }, |
|
||||
mime: { 'text/plain': [ 'php' ] } |
|
||||
}) |
|
||||
launchServer(app, { path: '/something.php', onSuccess: response => { |
|
||||
t.strictEqual(response.res.statusCode, 200) |
|
||||
t.ok(/text\/plain/.test(response.res.headers['content-type'])) |
|
||||
}}) |
|
||||
}) |
|
||||
|
|
||||
test('forbid', function (t) { |
|
||||
t.plan(2) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
static: { root: __dirname + '/fixture/forbid' }, |
|
||||
forbid: [ '*.php', '*.html' ] |
|
||||
}) |
|
||||
const server = launchServer(app, { leaveOpen: true }) |
|
||||
request('http://localhost:8100/two.php') |
|
||||
.then(response => { |
|
||||
t.strictEqual(response.res.statusCode, 403) |
|
||||
request('http://localhost:8100/one.html') |
|
||||
.then(response => { |
|
||||
t.strictEqual(response.res.statusCode, 403) |
|
||||
server.close() |
|
||||
}) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('rewrite: local', function (t) { |
|
||||
t.plan(1) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
static: { root: __dirname + '/fixture/rewrite' }, |
|
||||
rewrite: [ { from: '/two.html', to: '/one.html' } ] |
|
||||
}) |
|
||||
launchServer(app, { path: '/two.html', onSuccess: response => { |
|
||||
t.ok(/one/.test(response.data)) |
|
||||
}}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: simple response', function (t) { |
|
||||
t.plan(2) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ route: '/test', response: { body: 'test' } } |
|
||||
] |
|
||||
}) |
|
||||
launchServer(app, { path: '/test', onSuccess: response => { |
|
||||
t.strictEqual(response.res.statusCode, 200) |
|
||||
t.ok(/test/.test(response.data)) |
|
||||
}}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: method request filter', function (t) { |
|
||||
t.plan(3) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ |
|
||||
route: '/test', |
|
||||
request: { method: 'POST' }, |
|
||||
response: { body: 'test' } |
|
||||
} |
|
||||
] |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
request('http://localhost:8100/test') |
|
||||
.then(checkResponse(t, 404)) |
|
||||
.then(() => request('http://localhost:8100/test', { data: 'something' })) |
|
||||
.then(checkResponse(t, 200, /test/)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: accepts request filter', function (t) { |
|
||||
t.plan(3) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ |
|
||||
route: '/test', |
|
||||
request: { accepts: 'text' }, |
|
||||
response: { body: 'test' } |
|
||||
} |
|
||||
] |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
request('http://localhost:8100/test', { headers: { Accept: '*/json' } }) |
|
||||
.then(checkResponse(t, 404)) |
|
||||
.then(() => request('http://localhost:8100/test', { headers: { Accept: 'text/plain' } })) |
|
||||
.then(checkResponse(t, 200, /test/)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: responses array', function (t) { |
|
||||
t.plan(4) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ |
|
||||
route: '/test', |
|
||||
responses: [ |
|
||||
{ request: { method: 'GET' }, response: { body: 'get' } }, |
|
||||
{ request: { method: 'POST' }, response: { body: 'post' } } |
|
||||
] |
|
||||
} |
|
||||
] |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
request('http://localhost:8100/test') |
|
||||
.then(checkResponse(t, 200, /get/)) |
|
||||
.then(() => request('http://localhost:8100/test', { method: 'POST' })) |
|
||||
.then(checkResponse(t, 200, /post/)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: response function', function (t) { |
|
||||
t.plan(4) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ |
|
||||
route: '/test', |
|
||||
responses: [ |
|
||||
{ request: { method: 'GET' }, response: ctx => ctx.body = 'get' }, |
|
||||
{ request: { method: 'POST' }, response: ctx => ctx.body = 'post' } |
|
||||
] |
|
||||
} |
|
||||
] |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
request('http://localhost:8100/test') |
|
||||
.then(checkResponse(t, 200, /get/)) |
|
||||
.then(() => request('http://localhost:8100/test', { method: 'POST' })) |
|
||||
.then(checkResponse(t, 200, /post/)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: response function args', function (t) { |
|
||||
t.plan(2) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ |
|
||||
route: '/test/:one', |
|
||||
responses: [ |
|
||||
{ request: { method: 'GET' }, response: (ctx, one) => ctx.body = one } |
|
||||
] |
|
||||
} |
|
||||
] |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
request('http://localhost:8100/test/yeah') |
|
||||
.then(checkResponse(t, 200, /yeah/)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
||||
|
|
||||
test('mock: async response function', function (t) { |
|
||||
t.plan(2) |
|
||||
const app = localWebServer({ |
|
||||
log: { format: 'none' }, |
|
||||
mocks: [ |
|
||||
{ |
|
||||
route: '/test', |
|
||||
responses: { |
|
||||
response: function (ctx) { |
|
||||
return new Promise((resolve, reject) => { |
|
||||
setTimeout(() => { |
|
||||
ctx.body = 'test' |
|
||||
resolve() |
|
||||
}, 10) |
|
||||
}) |
|
||||
} |
|
||||
} |
|
||||
} |
|
||||
] |
|
||||
}) |
|
||||
const server = http.createServer(app.callback()) |
|
||||
server.listen(8100, () => { |
|
||||
request('http://localhost:8100/test') |
|
||||
.then(checkResponse(t, 200, /test/)) |
|
||||
.then(server.close.bind(server)) |
|
||||
}) |
|
||||
}) |
|
Write
Preview
Loading…
Cancel
Save
Reference in new issue