Create JsonPost.js
This commit is contained in:
parent
a927d4b54f
commit
24976c8168
57
examples/JsonPost.js
Normal file
57
examples/JsonPost.js
Normal file
@ -0,0 +1,57 @@
|
|||||||
|
/* Simple example of getting JSON from a POST */
|
||||||
|
|
||||||
|
const uWS = require('../dist/uws.js');
|
||||||
|
const port = 9001;
|
||||||
|
|
||||||
|
const app = uWS./*SSL*/App({
|
||||||
|
key_file_name: 'misc/key.pem',
|
||||||
|
cert_file_name: 'misc/cert.pem',
|
||||||
|
passphrase: '1234'
|
||||||
|
}).post('/*', (res, req) => {
|
||||||
|
|
||||||
|
/* Note that you cannot read from req after returning from here */
|
||||||
|
let url = req.getUrl();
|
||||||
|
|
||||||
|
/* Read the body until done or error */
|
||||||
|
readJson(res, (obj) => {
|
||||||
|
console.log('Posted to ' + url + ': ');
|
||||||
|
console.log(obj);
|
||||||
|
|
||||||
|
res.end('Thanks for this json!');
|
||||||
|
}, () => {
|
||||||
|
/* Request was prematurely aborted, stop reading */
|
||||||
|
console.log('Ugh!');
|
||||||
|
});
|
||||||
|
|
||||||
|
}).listen(port, (token) => {
|
||||||
|
if (token) {
|
||||||
|
console.log('Listening to port ' + port);
|
||||||
|
} else {
|
||||||
|
console.log('Failed to listen to port ' + port);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
/* Helper function for reading a posted JSON body */
|
||||||
|
function readJson(res, cb, err) {
|
||||||
|
let buffer;
|
||||||
|
/* Register data cb */
|
||||||
|
res.onData((ab, isLast) => {
|
||||||
|
let chunk = Buffer.from(ab);
|
||||||
|
if (isLast) {
|
||||||
|
if (buffer) {
|
||||||
|
cb(JSON.parse(Buffer.concat([buffer, chunk])));
|
||||||
|
} else {
|
||||||
|
cb(JSON.parse(chunk));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if (buffer) {
|
||||||
|
buffer = Buffer.concat([buffer, chunk]);
|
||||||
|
} else {
|
||||||
|
buffer = Buffer.concat([chunk]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
/* Register error cb */
|
||||||
|
res.onAborted(err);
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user