'use strict'; const common = require('../common'); if (!common.hasCrypto) common.skip('missing crypto'); const assert = require('assert'); const h2 = require('http2'); const body = '

this is some data

'; const trailerKey = 'test-trailer'; const trailerValue = 'testing'; const server = h2.createServer(); // we use the lower-level API here server.on('stream', common.mustCall(onStream)); function onStream(stream, headers, flags) { stream.on('trailers', common.mustCall((headers) => { assert.strictEqual(headers[trailerKey], trailerValue); stream.end(body); })); stream.respond({ 'content-type': 'text/html', ':status': 200 }, { waitForTrailers: true }); stream.on('wantTrailers', () => { stream.sendTrailers({ [trailerKey]: trailerValue }); common.expectsError( () => stream.sendTrailers({}), { code: 'ERR_HTTP2_TRAILERS_ALREADY_SENT', type: Error } ); }); common.expectsError( () => stream.sendTrailers({}), { code: 'ERR_HTTP2_TRAILERS_NOT_READY', type: Error } ); } server.listen(0); server.on('listening', common.mustCall(function() { const client = h2.connect(`http://localhost:${this.address().port}`); const req = client.request({ ':path': '/', ':method': 'POST' }, { waitForTrailers: true }); req.on('wantTrailers', () => { req.sendTrailers({ [trailerKey]: trailerValue }); }); req.on('data', common.mustCall()); req.on('trailers', common.mustCall((headers) => { assert.strictEqual(headers[trailerKey], trailerValue); })); req.on('close', common.mustCall(() => { common.expectsError( () => req.sendTrailers({}), { code: 'ERR_HTTP2_INVALID_STREAM', type: Error } ); server.close(); client.close(); })); req.end('data'); }));