@netlify/functions
Advanced tools
Comparing version 0.7.3-streaming.1 to 0.7.3-streaming.2
@@ -5,3 +5,3 @@ { | ||
"types": "./src/main.d.ts", | ||
"version": "0.7.3-streaming.1", | ||
"version": "0.7.3-streaming.2", | ||
"description": "JavaScript utilities for Netlify Functions", | ||
@@ -8,0 +8,0 @@ "files": [ |
/* eslint-disable no-underscore-dangle , promise/prefer-await-to-callbacks, */ | ||
// @ts-check | ||
const { request } = require('http') | ||
const { request: sRequest } = require('https') | ||
const { Buffer } = require('buffer') | ||
const http = require('http') | ||
const https = require('https') | ||
const { PassThrough } = require('stream') | ||
@@ -13,3 +14,2 @@ | ||
_metadataSent = false | ||
METADATA_BOUNDARY = `___x_nf-metadata_boundary-${Date.now()}` | ||
outgoingMessage | ||
@@ -21,4 +21,3 @@ | ||
const parsedUrl = new URL(url) | ||
this.outgoingMessage = parsedUrl.protocol === 'https:' ? sRequest(url) : request(url) | ||
this.outgoingMessage.setHeader('x-nf-metadata-boundary', this.METADATA_BOUNDARY) | ||
this.outgoingMessage = parsedUrl.protocol === 'https:' ? https.request(url) : http.request(url) | ||
this.pipe(this.outgoingMessage) | ||
@@ -36,7 +35,7 @@ } | ||
_getMetadata() { | ||
return `${JSON.stringify({ | ||
return JSON.stringify({ | ||
// eslint-disable-next-line node/no-unsupported-features/es-builtins | ||
headers: Object.fromEntries(this._clientHeaders.entries()), | ||
statusCode: this.statusCode, | ||
})}\r\n${this.METADATA_BOUNDARY}` | ||
}) | ||
} | ||
@@ -47,2 +46,3 @@ | ||
super.write(this._getMetadata()) | ||
super.write(Buffer.from([0x00])) | ||
this._metadataSent = true | ||
@@ -49,0 +49,0 @@ } |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
13897