mirrors/insomnia
1
0
Fork 0
mirror of https://github.com/Kong/insomnia synced 2024-11-08 06:39:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Move WRITEFUNCTION definition lower (Fixes #633)

Browse Source 
I have no idea why moving this function down works, but it did.
This commit is contained in:
Gregory Schier 2017-11-30 11:06:04 +00:00
parent feecc8f203
commit a0685c882e
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
packages/insomnia-app/app/network/network.js
View File

@ -471,19 +471,6 @@ export async function _actuallySend (
setOpt(Curl.option.POSTFIELDS, requestBody); setOpt(Curl.option.POSTFIELDS, requestBody);
} }
let responseBodyBytes = 0;
const responsesDir = pathJoin(app.getPath('userData'), 'responses');
mkdirp.sync(responsesDir);
const responseBodyPath = pathJoin(responsesDir, uuid.v4() + '.response');
const responseBodyWriteStream = fs.createWriteStream(responseBodyPath);
curl.on('end', () => responseBodyWriteStream.end());
curl.on('error', () => responseBodyWriteStream.end());
setOpt(Curl.option.WRITEFUNCTION, (buff: Buffer) => {
responseBodyBytes += buff.length;
responseBodyWriteStream.write(buff);
return buff.length;
});
// Handle Authorization header // Handle Authorization header
if (!hasAuthHeader(headers) && !renderedRequest.authentication.disabled) { if (!hasAuthHeader(headers) && !renderedRequest.authentication.disabled) {
if (renderedRequest.authentication.type === AUTH_BASIC) { if (renderedRequest.authentication.type === AUTH_BASIC) {
@ -562,6 +549,19 @@ export async function _actuallySend (
.map(h => `${(h.name || '').trim()}: ${h.value}`); .map(h => `${(h.name || '').trim()}: ${h.value}`);
setOpt(Curl.option.HTTPHEADER, headerStrings); setOpt(Curl.option.HTTPHEADER, headerStrings);
let responseBodyBytes = 0;
const responsesDir = pathJoin(app.getPath('userData'), 'responses');
mkdirp.sync(responsesDir);
const responseBodyPath = pathJoin(responsesDir, uuid.v4() + '.response');
const responseBodyWriteStream = fs.createWriteStream(responseBodyPath);
curl.on('end', () => responseBodyWriteStream.end());
curl.on('error', () => responseBodyWriteStream.end());
setOpt(Curl.option.WRITEFUNCTION, (buff: Buffer) => {
responseBodyBytes += buff.length;
responseBodyWriteStream.write(buff);
return buff.length;
});
// Handle the response ending // Handle the response ending
curl.on('end', async (_1, _2, rawHeaders) => { curl.on('end', async (_1, _2, rawHeaders) => {
const allCurlHeadersObjects = _parseHeaders(rawHeaders); const allCurlHeadersObjects = _parseHeaders(rawHeaders);