mirror of
https://github.com/brianc/node-postgres.git
synced 2026-01-18 15:55:05 +00:00
74714b0ff9
The previous approach to detecting whether to use Cloudflare's sockets was to check for missing polyfills. But as we improve the polyfills that Wrangler can provide these checks are no longer valid. Now we just try to use the Cloudflare API first and fallback to Node.js if those are not available.
58 lines
1.7 KiB
JavaScript
58 lines
1.7 KiB
JavaScript
let isCloudflareRuntime
|
|
|
|
/**
|
|
* Get a socket stream compatible with the current runtime environment.
|
|
* @returns {Duplex}
|
|
*/
|
|
module.exports.getStream = function getStream(ssl) {
|
|
if (isCloudflareRuntime === undefined) {
|
|
isCloudflareRuntime = computeIsCloudflareRuntime()
|
|
}
|
|
if (isCloudflareRuntime) {
|
|
const { CloudflareSocket } = require('pg-cloudflare')
|
|
return new CloudflareSocket(ssl)
|
|
} else {
|
|
const net = require('net')
|
|
return new net.Socket()
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get a TLS secured socket, compatible with the current environment,
|
|
* using the socket and other settings given in `options`.
|
|
* @returns {Duplex}
|
|
*/
|
|
module.exports.getSecureStream = function getSecureStream(options) {
|
|
if (isCloudflareRuntime === undefined) {
|
|
isCloudflareRuntime = computeIsCloudflareRuntime()
|
|
}
|
|
if (isCloudflareRuntime) {
|
|
options.socket.startTls(options)
|
|
return options.socket
|
|
} else {
|
|
var tls = require('tls')
|
|
return tls.connect(options)
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Are we running in a Cloudflare Worker?
|
|
*
|
|
* @returns true if the code is currently running inside a Cloudflare Worker.
|
|
*/
|
|
function computeIsCloudflareRuntime() {
|
|
// Since 2022-03-21 the `global_navigator` compatibility flag is on for Cloudflare Workers
|
|
// which means that `navigator.userAgent` will be defined.
|
|
if (typeof navigator === 'object' && navigator !== null && typeof navigator.userAgent === 'string') {
|
|
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
|
|
}
|