testing/xpcshell/node-http2/node_modules/http2-protocol/example/server.js

Wed, 31 Dec 2014 06:09:35 +0100

author
Michael Schloh von Bennewitz <michael@schloh.com>
date
Wed, 31 Dec 2014 06:09:35 +0100
changeset 0
6474c204b198
permissions
-rw-r--r--

Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.

     1 var fs = require('fs');
     2 var path = require('path');
     3 var http2 = require('..');
     4 var tls = require('tls');
     6 var exists = fs.existsSync;
     7 var stat = fs.statSync;
     8 var read = fs.createReadStream;
     9 var join = path.join;
    11 // Advertised protocol version
    12 var implementedVersion = http2.ImplementedVersion;
    14 // Bunyan logger
    15 var log = require('../test/util').createLogger('server');
    17 // We cache one file to be able to do simple performance tests without waiting for the disk
    18 var cachedFile = fs.readFileSync(path.join(__dirname, './server.js'));
    19 var cachedUrl = '/server.js';
    21 // Creating the server
    22 tls.createServer({
    23   ALPNProtocols: [implementedVersion],
    24   NPNProtocols: [implementedVersion],
    25   key: fs.readFileSync(path.join(__dirname, '/localhost.key')),
    26   cert: fs.readFileSync(path.join(__dirname, '/localhost.crt'))
    27 }).on('secureConnection', onConnection).listen(process.env.HTTP2_PORT || 8080);
    29 // Handling incoming connections
    30 function onConnection(socket) {
    31   var endpoint = new http2.Endpoint(log, 'SERVER', {});
    32   endpoint.pipe(socket).pipe(endpoint);
    34   endpoint.on('stream', function(stream) {
    35     stream.on('headers', function(headers) {
    36       var path = headers[':path'];
    37       var filename = join(__dirname, path);
    39       // Serving server.js from cache. Useful for microbenchmarks.
    40       if (path == cachedUrl) {
    41         stream.headers({ ':status': 200 });
    42         stream.end(cachedFile);
    43       }
    45       // Reading file from disk if it exists and is safe.
    46       else if ((filename.indexOf(__dirname) === 0) && exists(filename) && stat(filename).isFile()) {
    47         stream.headers({ ':status': 200 });
    49         // If they download the certificate, push the private key too, they might need it.
    50         if (path === '/localhost.crt') {
    51           var push = stream.promise({
    52             ':method': 'GET',
    53             ':scheme': headers[':scheme'],
    54             ':authority': headers[':authority'],
    55             ':path': '/localhost.key'
    56           });
    57           push.headers({ ':status': 200 });
    58           read(join(__dirname, '/localhost.key')).pipe(push);
    59         }
    61         read(filename).pipe(stream);
    62       }
    64       // Otherwise responding with 404.
    65       else {
    66         stream.headers({ ':status': 404 });
    67         stream.end();
    68       }
    69     });
    70   });
    71 }

mercurial