diff options
| author | root <root@pigstarter.de> | 2013-11-05 13:24:42 +0100 | 
|---|---|---|
| committer | root <root@pigstarter.de> | 2013-11-05 13:24:42 +0100 | 
| commit | 5e326f51c58e500285ea3daee91986ee1ea518eb (patch) | |
| tree | 2b3eccf15e10e4331dcb2d01c9f53620d749f55f /sandbox/hyper/influx/http | |
| parent | ae627d2aa73ea6862af3985f1c07e95c6d493275 (diff) | |
sandbox -> .graveyard
Diffstat (limited to 'sandbox/hyper/influx/http')
| -rwxr-xr-x | sandbox/hyper/influx/http/index.js | 57 | 
1 files changed, 0 insertions, 57 deletions
| diff --git a/sandbox/hyper/influx/http/index.js b/sandbox/hyper/influx/http/index.js deleted file mode 100755 index 346dde3b..00000000 --- a/sandbox/hyper/influx/http/index.js +++ /dev/null @@ -1,57 +0,0 @@ -#! /usr/bin/env node - -name = '//hyper/influx/http' -port = process.env.port || 1337 -host = process.env.host || '127.0.0.1' - - -console.info(name); - -fs = require('fs'); -path = require('path'); -http = require('http'); - -fifo_path = path.resolve(process.argv[2] || path.join(process.cwd(), '0')); - -// check configuration -try { -  (function (stat) { -    if ((stat.mode & 0010000) === 0) { -      throw { code: 'E_not_fifo', path: fifo_path }; -    }; -  })(fs.statSync(fifo_path)); -} catch (exn) { -  console.error(exn); -  process.exit(23); -}; - -process.stdin.destroy(); -fifo = fs.createWriteStream(fifo_path); -fifo.on('open', function (fd) { -  console.info('fifo open as fd', fd); - -  http.createServer(function (req, res) { -    var rhost = req.connection.remoteAddress; -    var rport = req.connection.remotePort; -    var id = rhost + ':' + rport; -   -    console.info(id, 'request', req.method, req.url); - -    req.on('data', function (data) { -      console.info(id, 'data', data.length); -    }); - -    req.on('end', function (data) { -      console.info(id, 'end'); -      res.writeHead(202, { -        'Content-Length': 0, -        'Connection': 'close' -      }); -      res.end(); -    }); - -    req.pipe(fifo, { end: false }); -  }).listen(port, host, function () { -    console.info('server running at http://' + host + ':' + port + '/'); -  }); -}); | 
