/* eslint-env mocha */ var assert = require('assert') var tls = require('tls') var net = require('net') var https = require('https') var transport = require('spdy-transport') var util = require('util') var fixtures = require('./fixtures') var spdy = require('../') describe('SPDY Server', function () { fixtures.everyConfig(function (protocol, alpn, version, plain) { var server var client beforeEach(function (done) { server = spdy.createServer(Object.assign({ spdy: { 'x-forwarded-for': true, plain: plain } }, fixtures.keys)) server.listen(fixtures.port, function () { var socket = (plain ? net : tls).connect({ rejectUnauthorized: false, port: fixtures.port, ALPNProtocols: [ alpn ] }, function () { client = transport.connection.create(socket, { protocol: protocol, isServer: false }) client.start(version) done() }) }) }) afterEach(function (done) { client.socket.destroy() server.close(done) }) it('should process GET request', function (done) { var stream = client.request({ method: 'GET', path: '/get', headers: { a: 'b' } }, function (err) { assert(!err) stream.on('error', (err) => { done(err) }) stream.on('response', function (status, headers) { assert.strictEqual(status, 200) assert.strictEqual(headers.ok, 'yes') fixtures.expectData(stream, 'response', done) }) stream.end() }) server.on('request', function (req, res) { assert.strictEqual(req.isSpdy, res.isSpdy) assert.strictEqual(req.spdyVersion, res.spdyVersion) assert(req.isSpdy) if (!plain) { assert(req.socket.encrypted) assert(req.socket.getPeerCertificate()) } // Auto-detection if (version === 3.1) { assert(req.spdyVersion >= 3 && req.spdyVersion <= 3.1) } else { assert.strictEqual(req.spdyVersion, version) } assert(req.spdyStream) assert(res.spdyStream) assert.strictEqual(req.method, 'GET') assert.strictEqual(req.url, '/get') assert.deepStrictEqual(req.headers, { a: 'b', host: 'localhost' }) req.on('end', function () { res.writeHead(200, { ok: 'yes' }) res.end('response') assert(res.finished, 'res.finished should be set') }) req.resume() }) }) it('should process POST request', function (done) { var stream = client.request({ method: 'POST', path: '/post' }, function (err) { assert(!err) stream.on('response', function (status, headers) { assert.strictEqual(status, 200) assert.strictEqual(headers.ok, 'yes') fixtures.expectData(stream, 'response', next) }) stream.end('request') }) server.on('request', function (req, res) { assert.strictEqual(req.method, 'POST') assert.strictEqual(req.url, '/post') res.writeHead(200, { ok: 'yes' }) res.end('response') fixtures.expectData(req, 'request', next) }) var waiting = 2 function next () { if (--waiting === 0) { return done() } } }) it('should process expect-continue request', function (done) { var stream = client.request({ method: 'GET', path: '/get', headers: { Expect: '100-continue' } }, function (err) { assert(!err) stream.on('response', function (status, headers) { assert.strictEqual(status, 100) fixtures.expectData(stream, 'response', done) }) stream.end() }) server.on('request', function (req, res) { req.on('end', function () { res.end('response') }) req.resume() }) }) it('should emit `checkContinue` request', function (done) { var stream = client.request({ method: 'GET', path: '/get', headers: { Expect: '100-continue' } }, function (err) { assert(!err) stream.on('response', function (status, headers) { assert.strictEqual(status, 100) fixtures.expectData(stream, 'response', done) }) stream.end() }) server.on('checkContinue', function (req, res) { req.on('end', function () { res.writeContinue() res.end('response') }) req.resume() }) }) it('should send PUSH_PROMISE', function (done) { var stream = client.request({ method: 'POST', path: '/page' }, function (err) { assert(!err) stream.on('pushPromise', function (push) { assert.strictEqual(push.path, '/push') assert.strictEqual(push.headers.yes, 'push') fixtures.expectData(push, 'push', next) fixtures.expectData(stream, 'response', next) }) stream.end('request') }) server.on('request', function (req, res) { assert.strictEqual(req.method, 'POST') assert.strictEqual(req.url, '/page') res.writeHead(200, { ok: 'yes' }) var push = res.push('/push', { request: { yes: 'push' } }) push.end('push') res.end('response') fixtures.expectData(req, 'request', next) }) var waiting = 3 function next () { if (--waiting === 0) { return done() } } }) it('should receive trailing headers', function (done) { var stream = client.request({ method: 'POST', path: '/post' }, function (err) { assert(!err) stream.sendHeaders({ trai: 'ler' }) stream.end() stream.on('response', function (status, headers) { assert.strictEqual(status, 200) assert.strictEqual(headers.ok, 'yes') fixtures.expectData(stream, 'response', done) }) }) server.on('request', function (req, res) { var gotHeaders = false req.on('trailers', function (headers) { gotHeaders = true assert.strictEqual(headers.trai, 'ler') }) req.on('end', function () { assert(gotHeaders) res.writeHead(200, { ok: 'yes' }) res.end('response') }) req.resume() }) }) it('should call .writeHead() automatically', function (done) { var stream = client.request({ method: 'POST', path: '/post' }, function (err) { assert(!err) stream.on('response', function (status, headers) { assert.strictEqual(status, 300) fixtures.expectData(stream, 'response', done) }) stream.end() }) server.on('request', function (req, res) { req.on('end', function () { res.statusCode = 300 res.end('response') }) req.resume() }) }) it('should not crash on .writeHead() after socket close', function (done) { var stream = client.request({ method: 'POST', path: '/post' }, function (err) { assert(!err) setTimeout(function () { client.socket.destroy() }, 50) stream.on('error', function () {}) stream.end() }) server.on('request', function (req, res) { req.connection.on('close', function () { assert.doesNotThrow(function () { res.writeHead(200) res.end('response') }) done() }) }) }) it('should not crash on .push() after socket close', function (done) { var stream = client.request({ method: 'POST', path: '/post' }, function (err) { assert(!err) setTimeout(function () { client.socket.destroy() }, 50) stream.on('error', function () {}) stream.end() }) server.on('request', function (req, res) { req.connection.on('close', function () { assert.doesNotThrow(function () { assert.strictEqual(res.push('/push', {}), undefined) res.end('response') }) done() }) }) }) it('should end response after writing everything down', function (done) { var stream = client.request({ method: 'GET', path: '/post' }, function (err) { assert(!err) stream.on('response', function (status, headers) { assert.strictEqual(status, 200) fixtures.expectData(stream, 'hello world, what\'s up?', done) }) stream.end() }) server.on('request', function (req, res) { req.resume() res.writeHead(200) res.write('hello ') res.write('world') res.write(', what\'s') res.write(' up?') res.end() }) }) it('should handle x-forwarded-for', function (done) { client.sendXForwardedFor('1.2.3.4') var stream = client.request({ method: 'GET', path: '/post' }, function (err) { assert(!err) stream.resume() stream.on('end', done) stream.end() }) server.on('request', function (req, res) { assert.strictEqual(req.headers['x-forwarded-for'], '1.2.3.4') req.resume() res.end() }) }) it('should destroy request after end', function (done) { var stream = client.request({ method: 'POST', path: '/post' }, function (err) { assert(!err) }) stream.end() stream.on('error', function () {}) server.on('request', function (req, res) { res.end() res.destroy() res.socket.on('close', function () { done() }) }) }) }) it('should respond to http/1.1', function (done) { var server = spdy.createServer(fixtures.keys, function (req, res) { assert.strictEqual(req.isSpdy, res.isSpdy) assert.strictEqual(req.spdyVersion, res.spdyVersion) assert(!req.isSpdy) assert.strictEqual(req.spdyVersion, 1) res.writeHead(200) res.end() }) server.listen(fixtures.port, function () { var req = https.request({ agent: false, rejectUnauthorized: false, NPNProtocols: [ 'http/1.1' ], port: fixtures.port, method: 'GET', path: '/' }, function (res) { assert.strictEqual(res.statusCode, 200) res.resume() res.on('end', function () { server.close(done) }) }) req.end() }) }) it('should support custom base', function (done) { function Pseuver (options, listener) { https.Server.call(this, options, listener) } util.inherits(Pseuver, https.Server) var server = spdy.createServer(Pseuver, fixtures.keys, function (req, res) { assert.strictEqual(req.isSpdy, res.isSpdy) assert.strictEqual(req.spdyVersion, res.spdyVersion) assert(!req.isSpdy) assert.strictEqual(req.spdyVersion, 1) res.writeHead(200) res.end() }) server.listen(fixtures.port, function () { var req = https.request({ agent: false, rejectUnauthorized: false, NPNProtocols: [ 'http/1.1' ], port: fixtures.port, method: 'GET', path: '/' }, function (res) { assert.strictEqual(res.statusCode, 200) res.resume() res.on('end', function () { server.close(done) }) }) req.end() }) }) })