| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent fdc072b commit 96e8250
34 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -25,8 +25,8 @@ const net = require('net'); | |||
| 25 | 25 | const util = require('util'); | |
| 26 | 26 | const EventEmitter = require('events'); | |
| 27 | 27 | const debug = util.debuglog('http'); | |
| 28 | - const async_id_symbol = process.binding('async_wrap').async_id_symbol; | ||
| 29 | - const nextTick = require('internal/process/next_tick').nextTick; | ||
| 28 | + const { async_id_symbol } = process.binding('async_wrap'); | ||
| 29 | + const { nextTick } = require('internal/process/next_tick'); | ||
| 30 | 30 | ||
| 31 | 31 | // New Agent code. | |
| 32 | 32 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -24,19 +24,21 @@ | |||
| 24 | 24 | const util = require('util'); | |
| 25 | 25 | const net = require('net'); | |
| 26 | 26 | const url = require('url'); | |
| 27 | - const HTTPParser = process.binding('http_parser').HTTPParser; | ||
| 27 | + const { HTTPParser } = process.binding('http_parser'); | ||
| 28 | 28 | const assert = require('assert').ok; | |
| 29 | - const common = require('_http_common'); | ||
| 30 | - const httpSocketSetup = common.httpSocketSetup; | ||
| 31 | - const parsers = common.parsers; | ||
| 32 | - const freeParser = common.freeParser; | ||
| 33 | - const debug = common.debug; | ||
| 34 | - const OutgoingMessage = require('_http_outgoing').OutgoingMessage; | ||
| 29 | + const { | ||
| 30 | + _checkIsHttpToken: checkIsHttpToken, | ||
| 31 | + debug, | ||
| 32 | + freeParser, | ||
| 33 | + httpSocketSetup, | ||
| 34 | + parsers | ||
| 35 | + } = require('_http_common'); | ||
| 36 | + const { OutgoingMessage } = require('_http_outgoing'); | ||
| 35 | 37 | const Agent = require('_http_agent'); | |
| 36 | - const Buffer = require('buffer').Buffer; | ||
| 38 | + const { Buffer } = require('buffer'); | ||
| 37 | 39 | const { urlToOptions, searchParamsSymbol } = require('internal/url'); | |
| 38 | - const outHeadersKey = require('internal/http').outHeadersKey; | ||
| 39 | - const nextTick = require('internal/process/next_tick').nextTick; | ||
| 40 | + const { outHeadersKey } = require('internal/http'); | ||
| 41 | + const { nextTick } = require('internal/process/next_tick'); | ||
| 40 | 42 | ||
| 41 | 43 | // The actual list of disallowed characters in regexp form is more like: | |
| 42 | 44 | // /[^A-Za-z0-9\-._~!$&'()*+,;=/:@]/ | |
@@ -149,7 +151,7 @@ function ClientRequest(options, cb) { | |||
| 149 | 151 | } | |
| 150 | 152 | ||
| 151 | 153 | if (methodIsString && method) { | |
| 152 | - if (!common._checkIsHttpToken(method)) { | ||
| 154 | + if (!checkIsHttpToken(method)) { | ||
| 153 | 155 | throw new TypeError('Method must be a valid HTTP token'); | |
| 154 | 156 | } | |
| 155 | 157 | method = this.method = method.toUpperCase(); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -22,16 +22,17 @@ | |||
| 22 | 22 | 'use strict'; | |
| 23 | 23 | ||
| 24 | 24 | const binding = process.binding('http_parser'); | |
| 25 | - const methods = binding.methods; | ||
| 26 | - const HTTPParser = binding.HTTPParser; | ||
| 25 | + const { methods, HTTPParser } = binding; | ||
| 27 | 26 | ||
| 28 | 27 | const FreeList = require('internal/freelist'); | |
| 29 | - const ondrain = require('internal/http').ondrain; | ||
| 28 | + const { ondrain } = require('internal/http'); | ||
| 30 | 29 | const incoming = require('_http_incoming'); | |
| 31 | - const emitDestroy = require('async_hooks').emitDestroy; | ||
| 32 | - const IncomingMessage = incoming.IncomingMessage; | ||
| 33 | - const readStart = incoming.readStart; | ||
| 34 | - const readStop = incoming.readStop; | ||
| 30 | + const { emitDestroy } = require('async_hooks'); | ||
| 31 | + const { | ||
| 32 | + IncomingMessage, | ||
| 33 | + readStart, | ||
| 34 | + readStop | ||
| 35 | + } = incoming; | ||
| 35 | 36 | ||
| 36 | 37 | const debug = require('util').debuglog('http'); | |
| 37 | 38 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -26,17 +26,16 @@ const Stream = require('stream'); | |||
| 26 | 26 | const util = require('util'); | |
| 27 | 27 | const internalUtil = require('internal/util'); | |
| 28 | 28 | const internalHttp = require('internal/http'); | |
| 29 | - const Buffer = require('buffer').Buffer; | ||
| 29 | + const { Buffer } = require('buffer'); | ||
| 30 | 30 | const common = require('_http_common'); | |
| 31 | 31 | const checkIsHttpToken = common._checkIsHttpToken; | |
| 32 | 32 | const checkInvalidHeaderChar = common._checkInvalidHeaderChar; | |
| 33 | - const outHeadersKey = require('internal/http').outHeadersKey; | ||
| 34 | - const async_id_symbol = process.binding('async_wrap').async_id_symbol; | ||
| 35 | - const nextTick = require('internal/process/next_tick').nextTick; | ||
| 33 | + const { outHeadersKey } = require('internal/http'); | ||
| 34 | + const { async_id_symbol } = process.binding('async_wrap'); | ||
| 35 | + const { nextTick } = require('internal/process/next_tick'); | ||
| 36 | 36 | ||
| 37 | - const CRLF = common.CRLF; | ||
| 38 | - const debug = common.debug; | ||
| 39 | - const utcDate = internalHttp.utcDate; | ||
| 37 | + const { CRLF, debug } = common; | ||
| 38 | + const { utcDate } = internalHttp; | ||
| 40 | 39 | ||
| 41 | 40 | var RE_FIELDS = | |
| 42 | 41 | /^(?:Connection|Transfer-Encoding|Content-Length|Date|Expect|Trailer|Upgrade)$/i; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -23,17 +23,19 @@ | |||
| 23 | 23 | ||
| 24 | 24 | const util = require('util'); | |
| 25 | 25 | const net = require('net'); | |
| 26 | - const HTTPParser = process.binding('http_parser').HTTPParser; | ||
| 26 | + const { HTTPParser } = process.binding('http_parser'); | ||
| 27 | 27 | const assert = require('assert').ok; | |
| 28 | - const common = require('_http_common'); | ||
| 29 | - const parsers = common.parsers; | ||
| 30 | - const freeParser = common.freeParser; | ||
| 31 | - const debug = common.debug; | ||
| 32 | - const CRLF = common.CRLF; | ||
| 33 | - const continueExpression = common.continueExpression; | ||
| 34 | - const chunkExpression = common.chunkExpression; | ||
| 35 | - const httpSocketSetup = common.httpSocketSetup; | ||
| 36 | - const OutgoingMessage = require('_http_outgoing').OutgoingMessage; | ||
| 28 | + const { | ||
| 29 | + parsers, | ||
| 30 | + freeParser, | ||
| 31 | + debug, | ||
| 32 | + CRLF, | ||
| 33 | + continueExpression, | ||
| 34 | + chunkExpression, | ||
| 35 | + httpSocketSetup, | ||
| 36 | + _checkInvalidHeaderChar: checkInvalidHeaderChar | ||
| 37 | + } = require('_http_common'); | ||
| 38 | + const { OutgoingMessage } = require('_http_outgoing'); | ||
| 37 | 39 | const { outHeadersKey, ondrain } = require('internal/http'); | |
| 38 | 40 | ||
| 39 | 41 | const STATUS_CODES = { | |
@@ -222,7 +224,7 @@ function writeHead(statusCode, reason, obj) { | |||
| 222 | 224 | headers = obj; | |
| 223 | 225 | } | |
| 224 | 226 | ||
| 225 | - if (common._checkInvalidHeaderChar(this.statusMessage)) | ||
| 227 | + if (checkInvalidHeaderChar(this.statusMessage)) | ||
| 226 | 228 | throw new Error('Invalid character in statusMessage.'); | |
| 227 | 229 | ||
| 228 | 230 | var statusLine = 'HTTP/1.1 ' + statusCode + ' ' + this.statusMessage + CRLF; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -26,7 +26,7 @@ Readable.ReadableState = ReadableState; | |||
| 26 | 26 | ||
| 27 | 27 | const EE = require('events'); | |
| 28 | 28 | const Stream = require('stream'); | |
| 29 | - const Buffer = require('buffer').Buffer; | ||
| 29 | + const { Buffer } = require('buffer'); | ||
| 30 | 30 | const util = require('util'); | |
| 31 | 31 | const debug = util.debuglog('stream'); | |
| 32 | 32 | const BufferList = require('internal/streams/BufferList'); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -2,11 +2,11 @@ | |||
| 2 | 2 | ||
| 3 | 3 | const assert = require('assert'); | |
| 4 | 4 | const util = require('util'); | |
| 5 | - const Socket = require('net').Socket; | ||
| 6 | - const JSStream = process.binding('js_stream').JSStream; | ||
| 7 | 5 | // TODO(bmeurer): Change this back to const once hole checks are | |
| 8 | 6 | // properly optimized away early in Ignition+TurboFan. | |
| 9 | 7 | var Buffer = require('buffer').Buffer; | |
| 8 | + const { Socket } = require('net'); | ||
| 9 | + const { JSStream } = process.binding('js_stream'); | ||
| 10 | 10 | const uv = process.binding('uv'); | |
| 11 | 11 | const debug = util.debuglog('stream_wrap'); | |
| 12 | 12 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -31,7 +31,7 @@ Writable.WritableState = WritableState; | |||
| 31 | 31 | const util = require('util'); | |
| 32 | 32 | const internalUtil = require('internal/util'); | |
| 33 | 33 | const Stream = require('stream'); | |
| 34 | - const Buffer = require('buffer').Buffer; | ||
| 34 | + const { Buffer } = require('buffer'); | ||
| 35 | 35 | const destroyImpl = require('internal/streams/destroy'); | |
| 36 | 36 | ||
| 37 | 37 | util.inherits(Writable, Stream); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -23,8 +23,7 @@ | |||
| 23 | 23 | ||
| 24 | 24 | const tls = require('tls'); | |
| 25 | 25 | ||
| 26 | - const SSL_OP_CIPHER_SERVER_PREFERENCE = | ||
| 27 | - process.binding('constants').crypto.SSL_OP_CIPHER_SERVER_PREFERENCE; | ||
| 26 | + const { SSL_OP_CIPHER_SERVER_PREFERENCE } = process.binding('constants').crypto; | ||
| 28 | 27 | ||
| 29 | 28 | // Lazily loaded | |
| 30 | 29 | var crypto = null; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -25,12 +25,12 @@ const internalUtil = require('internal/util'); | |||
| 25 | 25 | internalUtil.assertCrypto(); | |
| 26 | 26 | ||
| 27 | 27 | const assert = require('assert'); | |
| 28 | - const Buffer = require('buffer').Buffer; | ||
| 28 | + const { Buffer } = require('buffer'); | ||
| 29 | 29 | const common = require('_tls_common'); | |
| 30 | - const Connection = process.binding('crypto').Connection; | ||
| 30 | + const { Connection } = process.binding('crypto'); | ||
| 31 | 31 | const EventEmitter = require('events'); | |
| 32 | 32 | const stream = require('stream'); | |
| 33 | - const Timer = process.binding('timer_wrap').Timer; | ||
| 33 | + const { Timer } = process.binding('timer_wrap'); | ||
| 34 | 34 | const tls = require('tls'); | |
| 35 | 35 | const util = require('util'); | |
| 36 | 36 | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments