?HAMA

Edit File Size: 2.08 KB

//proc/thread-self/root/home/byroehnu/.trash/node_modules11/pg/lib/stream.js

Text Base64

const { getStream, getSecureStream } = getStreamFuncs()

module.exports = {
  /**
   * Get a socket stream compatible with the current runtime environment.
   * @returns {Duplex}
   */
  getStream,
  /**
   * Get a TLS secured socket, compatible with the current environment,
   * using the socket and other settings given in `options`.
   * @returns {Duplex}
   */
  getSecureStream,
}

/**
 * The stream functions that work in Node.js
 */
function getNodejsStreamFuncs() {
  function getStream(ssl) {
    const net = require('net')
    return new net.Socket()
  }

function getSecureStream(options) {
    const tls = require('tls')
    return tls.connect(options)
  }
  return {
    getStream,
    getSecureStream,
  }
}

/**
 * The stream functions that work in Cloudflare Workers
 */
function getCloudflareStreamFuncs() {
  function getStream(ssl) {
    const { CloudflareSocket } = require('pg-cloudflare')
    return new CloudflareSocket(ssl)
  }

function getSecureStream(options) {
    options.socket.startTls(options)
    return options.socket
  }
  return {
    getStream,
    getSecureStream,
  }
}

/**
 * Are we running in a Cloudflare Worker?
 *
 * @returns true if the code is currently running inside a Cloudflare Worker.
 */
function isCloudflareRuntime() {
  // Since 2022-03-21 the `global_navigator` compatibility flag is on for Cloudflare Workers
  // which means that `navigator.userAgent` will be defined.
  // eslint-disable-next-line no-undef
  if (typeof navigator === 'object' && navigator !== null && typeof navigator.userAgent === 'string') {
    // eslint-disable-next-line no-undef
    return navigator.userAgent === 'Cloudflare-Workers'
  }
  // In case `navigator` or `navigator.userAgent` is not defined then try a more sneaky approach
  if (typeof Response === 'function') {
    const resp = new Response(null, { cf: { thing: true } })
    if (typeof resp.cf === 'object' && resp.cf !== null && resp.cf.thing) {
      return true
    }
  }
  return false
}

function getStreamFuncs() {
  if (isCloudflareRuntime()) {
    return getCloudflareStreamFuncs()
  }
  return getNodejsStreamFuncs()
}

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

Name	Size	Perms	Modified	Actions
crypto DIR	-	drwxr-xr-x	2026-02-03 15:06:18	Edit Download recursive recursive
native DIR	-	drwxr-xr-x	2026-02-03 15:06:18	Edit Download recursive recursive
client.js	20.90 KB	lrw-r--r--	2026-02-03 15:06:16	Edit Download recursive recursive
connection-parameters.js	5.16 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
connection.js	5.03 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
defaults.js	2.45 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
index.js	1.77 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
query.js	7.14 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
result.js	2.75 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
stream.js	2.08 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
type-overrides.js	770 B	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive
utils.js	5.51 KB	lrw-r--r--	2026-02-03 15:06:18	Edit Download recursive recursive

Directory Contents