syndicate-lang
/
syndicate-js
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Support for reading post bodies from incoming HTTP requests

This commit is contained in:
Tony Garnock-Jones 2018-12-13 16:40:24 +00:00
parent d1877a890c
commit 074f7f1d35
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
packages/driver-http-node/package.json
View File

@ -20,6 +20,7 @@
}, },
"dependencies": { "dependencies": {
"@syndicate-lang/core": "^0.0.20", "@syndicate-lang/core": "^0.0.20",
"@syndicate-lang/driver-streams-node": "^0.0.2",
"ws": "^6.1.2" "ws": "^6.1.2"
} }
} }

2
packages/driver-http-node/src/index.js
View File

@ -22,6 +22,7 @@ import { parse as parseUrl } from "url";
const http = require('http'); const http = require('http');
const https = require('https'); const https = require('https');
const _WebSocket = require('ws'); const _WebSocket = require('ws');
const S = activate require("@syndicate-lang/driver-streams-node");
assertion type HttpServer(host, port); assertion type HttpServer(host, port);
assertion type HttpsServer(host, port, options); assertion type HttpsServer(host, port, options);
@ -169,6 +170,7 @@ function _server(host, port, httpsOptions) {
res.writeHead(500, "Internal server error", {}); res.writeHead(500, "Internal server error", {});
res.end(); res.end();
} }
on asserted Observe(S.Readable(id)) react S.readableStreamBehaviour(id, req);
on asserted Response(id, $code, $message, $headers, $detail) on asserted Response(id, $code, $message, $headers, $detail)
{ {
res.writeHead(code, message, headers.toJS()); res.writeHead(code, message, headers.toJS());