BLUE

Edit File Size: 2.33 KB

/usr/share/nodejs/http2-wrapper/source/utils/proxy-socket-handler.js

Text Base64

'use strict';
const {ERR_HTTP2_NO_SOCKET_MANIPULATION} = require('./errors.js');

/* istanbul ignore file */
/* https://github.com/nodejs/node/blob/6eec858f34a40ffa489c1ec54bb24da72a28c781/lib/internal/http2/compat.js#L195-L272 */

const proxySocketHandler = {
	has(stream, property) {
		// Replaced [kSocket] with .socket
		const reference = stream.session === undefined ? stream : stream.session.socket;
		return (property in stream) || (property in reference);
	},

get(stream, property) {
		switch (property) {
			case 'on':
			case 'once':
			case 'end':
			case 'emit':
			case 'destroy':
				return stream[property].bind(stream);
			case 'writable':
			case 'destroyed':
				return stream[property];
			case 'readable':
				if (stream.destroyed) {
					return false;
				}

return stream.readable;
			case 'setTimeout': {
				const {session} = stream;
				if (session !== undefined) {
					return session.setTimeout.bind(session);
				}

return stream.setTimeout.bind(stream);
			}

case 'write':
			case 'read':
			case 'pause':
			case 'resume':
				throw new ERR_HTTP2_NO_SOCKET_MANIPULATION();
			default: {
				// Replaced [kSocket] with .socket
				const reference = stream.session === undefined ? stream : stream.session.socket;
				const value = reference[property];

return typeof value === 'function' ? value.bind(reference) : value;
			}
		}
	},

getPrototypeOf(stream) {
		if (stream.session !== undefined) {
			// Replaced [kSocket] with .socket
			return Reflect.getPrototypeOf(stream.session.socket);
		}

return Reflect.getPrototypeOf(stream);
	},

set(stream, property, value) {
		switch (property) {
			case 'writable':
			case 'readable':
			case 'destroyed':
			case 'on':
			case 'once':
			case 'end':
			case 'emit':
			case 'destroy':
				stream[property] = value;
				return true;
			case 'setTimeout': {
				const {session} = stream;
				if (session === undefined) {
					stream.setTimeout = value;
				} else {
					session.setTimeout = value;
				}

return true;
			}

module.exports = proxySocketHandler;

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
calculate-server-name.js	449 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
check-type.js	473 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
delay-async-destroy.js	652 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
errors.js	1.45 KB	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
is-request-pseudo-header.js	186 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
js-stream-socket.js	237 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
proxy-events.js	149 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
proxy-socket-handler.js	2.33 KB	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
validate-header-name.js	385 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive
validate-header-value.js	400 B	lrw-r--r--	2021-11-20 15:22:42	Edit Download recursive recursive

Directory Contents