118 lines
3.0 KiB
JavaScript
118 lines
3.0 KiB
JavaScript
/* eslint-disable no-console */
|
|
import http from 'http'
|
|
import { pEvent } from 'p-event'
|
|
import { createClient } from 'redis'
|
|
|
|
const redisAddr = process.env.redis_addr || 'redis:6379'
|
|
const transport = process.env.transport
|
|
const isDialer = process.env.is_dialer === 'true'
|
|
|
|
/** @type {import('aegir/types').PartialOptions} */
|
|
export default {
|
|
test: {
|
|
browser: {
|
|
config: {
|
|
// Ignore self signed certificates
|
|
browserContextOptions: { ignoreHTTPSErrors: true }
|
|
}
|
|
},
|
|
async before () {
|
|
// import after build is complete
|
|
const { createRelay } = await import('./dist/test/fixtures/relay.js')
|
|
|
|
let relayNode
|
|
let relayAddr
|
|
if (transport === 'webrtc' && !isDialer) {
|
|
relayNode = await createRelay()
|
|
|
|
const sortByNonLocalIp = (a, b) => {
|
|
if (a.toString().includes('127.0.0.1')) {
|
|
return 1
|
|
}
|
|
return -1
|
|
}
|
|
|
|
relayAddr = relayNode.getMultiaddrs().sort(sortByNonLocalIp)[0].toString()
|
|
}
|
|
|
|
const redisClient = createClient({
|
|
url: `redis://${redisAddr}`
|
|
})
|
|
redisClient.on('error', (err) => {
|
|
console.error('Redis client error:', err)
|
|
})
|
|
await redisClient.connect()
|
|
|
|
const requestListener = async function (req, res) {
|
|
const requestJSON = await new Promise(resolve => {
|
|
let body = ''
|
|
req.on('data', function (data) {
|
|
body += data
|
|
})
|
|
|
|
req.on('end', function () {
|
|
resolve(JSON.parse(body))
|
|
})
|
|
})
|
|
|
|
try {
|
|
const redisRes = await redisClient.sendCommand(requestJSON)
|
|
|
|
if (redisRes == null) {
|
|
console.error('Redis failure - sent', requestJSON, 'received', redisRes)
|
|
|
|
res.writeHead(500, {
|
|
'Access-Control-Allow-Origin': '*'
|
|
})
|
|
res.end(JSON.stringify({
|
|
message: 'Redis sent back null'
|
|
}))
|
|
|
|
return
|
|
}
|
|
|
|
res.writeHead(200, {
|
|
'Access-Control-Allow-Origin': '*'
|
|
})
|
|
res.end(JSON.stringify(redisRes))
|
|
} catch (err) {
|
|
console.error('Error in redis command:', err)
|
|
res.writeHead(500, {
|
|
'Access-Control-Allow-Origin': '*'
|
|
})
|
|
res.end(err.toString())
|
|
}
|
|
}
|
|
|
|
const proxyServer = http.createServer(requestListener)
|
|
proxyServer.listen(0)
|
|
|
|
await pEvent(proxyServer, 'listening', {
|
|
signal: AbortSignal.timeout(5000)
|
|
})
|
|
|
|
return {
|
|
redisClient,
|
|
relayNode,
|
|
proxyServer,
|
|
env: {
|
|
...process.env,
|
|
RELAY_ADDR: relayAddr,
|
|
REDIS_PROXY_PORT: proxyServer.address().port
|
|
}
|
|
}
|
|
},
|
|
async after (_, { proxyServer, redisClient, relayNode }) {
|
|
await new Promise(resolve => {
|
|
proxyServer?.close(() => resolve())
|
|
})
|
|
|
|
try {
|
|
// We don't care if this fails
|
|
await redisClient?.disconnect()
|
|
await relayNode?.stop()
|
|
} catch { }
|
|
}
|
|
}
|
|
}
|