kosmos/mastodon
kosmos/mastodon
8
0
Fork 0
Code Pull Requests Activity

Streaming: Fix BIND IPv6 handling (#31624)

Browse Source
This commit is contained in:
Emelia Smith 2024-08-28 12:40:37 +02:00 committed by GitHub
parent 3c412578c9
commit f6fb9b75db
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
streaming/index.js
View File

@ -1351,15 +1351,23 @@ const startServer = async () => {
* @param {function(string): void} [onSuccess] * @param {function(string): void} [onSuccess]
*/ */
const attachServerWithConfig = (server, onSuccess) => { const attachServerWithConfig = (server, onSuccess) => {
if (process.env.SOCKET || process.env.PORT && isNaN(+process.env.PORT)) { if (process.env.SOCKET) {
server.listen(process.env.SOCKET || process.env.PORT, () => { server.listen(process.env.SOCKET, () => {
if (onSuccess) { if (onSuccess) {
fs.chmodSync(server.address(), 0o666); fs.chmodSync(server.address(), 0o666);
onSuccess(server.address()); onSuccess(server.address());
} }
}); });
} else { } else {
server.listen(+(process.env.PORT || 4000), process.env.BIND || '127.0.0.1', () => { const port = +(process.env.PORT || 4000);
let bind = process.env.BIND ?? '127.0.0.1';
// Web uses the URI syntax for BIND, which means IPv6 addresses may
// be wrapped in square brackets:
if (bind.startsWith('[') && bind.endsWith(']')) {
bind = bind.slice(1, -1);
}
server.listen(port, bind, () => {
if (onSuccess) { if (onSuccess) {
onSuccess(`${server.address().address}:${server.address().port}`); onSuccess(`${server.address().address}:${server.address().port}`);
} }