/ usr / share / nodejs / http2-wrapper / source / proxies / [ HOME SHELL ]

Name	Size	Permission
get-auth-headers.js	334 B	-rw-r--r--
h1-over-h2.js	2.04 KB	-rw-r--r--
h2-over-h1.js	1.16 KB	-rw-r--r--
h2-over-h2.js	849 B	-rw-r--r--
h2-over-hx.js	1023 B	-rw-r--r--
initialize.js	672 B	-rw-r--r--
unexpected-status-code-error.j...	253 B	-rw-r--r--

Code Editor : h1-over-h2.js

'use strict';
const tls = require('tls');
const http = require('http');
const https = require('https');
const JSStreamSocket = require('../utils/js-stream-socket.js');
const {globalAgent} = require('../agent.js');
const UnexpectedStatusCodeError = require('./unexpected-status-code-error.js');
const initialize = require('./initialize.js');
const getAuthorizationHeaders = require('./get-auth-headers.js');

const createConnection = (self, options, callback) => {
	(async () => {
		try {
			const {proxyOptions} = self;
			const {url, headers, raw} = proxyOptions;

const stream = await globalAgent.request(url, proxyOptions, {
				...getAuthorizationHeaders(self),
				...headers,
				':method': 'CONNECT',
				':authority': `${options.host}:${options.port}`
			});

stream.once('error', callback);
			stream.once('response', headers => {
				const statusCode = headers[':status'];

if (statusCode !== 200) {
					callback(new UnexpectedStatusCodeError(statusCode));
					return;
				}

const encrypted = self instanceof https.Agent;

if (raw && encrypted) {
					options.socket = stream;
					const secureStream = tls.connect(options);

secureStream.once('close', () => {
						stream.destroy();
					});

callback(null, secureStream);
					return;
				}

const socket = new JSStreamSocket(stream);
				socket.encrypted = false;
				socket._handle.getpeername = out => {
					out.family = undefined;
					out.address = undefined;
					out.port = undefined;
				};

callback(null, socket);
			});
		} catch (error) {
			callback(error);
		}
	})();
};

class HttpOverHttp2 extends http.Agent {
	constructor(options) {
		super(options);

initialize(this, options.proxyOptions);
	}

createConnection(options, callback) {
		createConnection(this, options, callback);
	}
}

class HttpsOverHttp2 extends https.Agent {
	constructor(options) {
		super(options);

initialize(this, options.proxyOptions);
	}

createConnection(options, callback) {
		createConnection(this, options, callback);
	}
}

module.exports = {
	HttpOverHttp2,
	HttpsOverHttp2
};

Urban Research Lab

The Urban Research Lab (URL) at IIIT-Delhi was established in 2020, during a time when the pandemic brought the complexities of urban life more visible than ever. What started as an initiative by faculty and students has grown into a collaborative space for critically exploring and reimagining the urban questions through research, dialogue, and interdisciplinary engagement.

${this.title}

Code Editor : h1-over-h2.js

Urban Research Lab