summaryrefslogtreecommitdiffstats
path: root/sandbox/hyper/influx/http/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/hyper/influx/http/index.js')
-rwxr-xr-xsandbox/hyper/influx/http/index.js57
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 + '/');
- });
-});