I'm trying to figure out how to send an HTTP/2 POST request with NodeJS. I have so far from the example in the documentation:
const http2 = require('http2');
const fs = require('fs');
const client = http2.connect('https://localhost:8443', {
ca: fs.readFileSync('localhost-cert.pem')
});
client.on('error', (err) => console.error(err));
client.on('socketError', (err) => console.error(err));
const req = client.request({ ':path': '/' });
req.on('response', (headers, flags) => {
for (const name in headers) {
console.log(`${name}: ${headers[name]}`);
}
});
req.setEncoding('utf8');
let data = '';
req.on('data', (chunk) => { data += chunk; });
req.on('end', () => {
console.log(`\n${data}`);
client.close();
});
req.end();
But there it isn't clear to me how to actually setup data to send as a POST.
If you need to post your objects as json - you should stringify it and wrap in buffer. Here is the code that works in my case:
const http2 = require('http2');
const post = (url, path, body) => new Promise((resolve) => {
const client = http2.connect(url);
const buffer = new Buffer(JSON.stringify(body));
const req = client.request({
[http2.constants.HTTP2_HEADER_SCHEME]: "https",
[http2.constants.HTTP2_HEADER_METHOD]: http2.constants.HTTP2_METHOD_POST,
[http2.constants.HTTP2_HEADER_PATH]: `/${path}`,
"Content-Type": "application/json",
"Content-Length": buffer.length,
});
req.setEncoding('utf8');
let data = [];
req.on('data', (chunk) => {
data.push(chunk);
});
req.write(buffer);
req.end();
req.on('end', () => {
resolve(data: data.join());
});
});
After piecing together little bits of information everywhere, I've finally manage to resolve this issue. Here is a template example. The key is in req.write(). I honestly couldn't find anywhere a direct answer for how to include a body. Nearly every example is without a body! Hope this helps others. NOTE: This is in Node-red hence the global.get statements, but also works by changing those to require('module'):
const fs = global.get('fs');
const http2 = global.get('http2');
fs.readFile('turn-off-the-desklight.raw', function(err, content){
if(err){
node.send(err);
}
var metadata = JSON.stringify(
{
"context": [
{
"header": {
"namespace": "SpeechRecognizer",
"name": "RecognizerState"
},
"payload": {
}
},
{
"header": {
"namespace": "Speaker",
"name": "VolumeState"
},
"payload": {
"volume": 10,
"muted": false
}
},
{
"header": {
"namespace": "Alerts",
"name": "AlertsState"
},
"payload": {
"allAlerts": [],
"activeAlerts": []
}
},
{
"header": {
"namespace": "SpeechSynthesizer",
"name": "SpeechState"
},
"payload": {
"token": "",
"offsetInMilliseconds": 0,
"playerActivity": "FINISHED"
}
},
{
"header": {
"namespace": "AudioPlayer",
"name": "PlaybackState"
},
"payload": {
"token": "",
"offsetInMilliseconds": 0,
"playerActivity": "IDLE"
}
}
],
"event": {
"header": {
"namespace": "SpeechRecognizer",
"name": "Recognize",
"messageId": "1eff3c5e-02e3-4dd3-9ca0-7c38937f005f",
"dialogRequestId": "a905c2bb-1bbd-45cf-9f85-6563d2546492"
},
"payload": {
"profile": "FAR_FIELD",
"format": "AUDIO_L16_RATE_16000_CHANNELS_1"
}
}
});
var data = "--this-is-my-boundary-for-alexa\r\n";
data += 'Content-Disposition: form-data; name="metadata"\r\n';
data +='Content-Type: application/json; charset=UTF-8\r\n\r\n';
data += metadata;
data += "\r\n";
data += "--this-is-my-boundary-for-alexa\r\n";
data += "Content-Disposition: form-data; name=\"audio\"\r\n";
data += "Content-Type:application/octet-stream\r\n\r\n";
var payload = Buffer.concat([
Buffer.from(data, "utf8"),
new Buffer(content, 'binary'),
Buffer.from("\r\n--this-is-my-boundary-for-alexa\r\n", "utf8"),
]);
const client = global.get('alexaClient');
client.on('error', (err) => node.send({payload:err}));
client.on('socketError', (err) => node.send({payload:err}));
var request = {
':method' : 'POST',
':scheme' : 'https',
':path' : '/v20160207/events',
'authorization' : 'Bearer <valid token>',
'content-type' : 'multipart/form-data; boundary=this-is-my-boundary-for-alexa'
};
var req = client.request(request);
req.on('response', (headers, flags) => {
for (const name in headers) {
if(name === ':status') {
node.send({payload:`${name}: ${headers[name]}`});
}
}
});
req.on('error', function(err) {
node.send(err);
});
req.setEncoding('utf8');
let outdata = '';
req.on('data', (chunk) => { outdata += chunk; });
req.on('end', () => {
node.send({payload:outdata});
});
req.write(payload);
req.end();
});
Try to compose your request body as below:
{
method:'POST'
headers:...
body:...
}
There're different ways to post data, in body, or form etc. Download postman, configure your post request in it and it has a feature to generate code samples for different languages. Node.JS is one of them.
I also recommend you use request package. It encapsulates some functions and makes it easier to receive data. request
