Merge branch 'master' into glitch-soc/merge-upstream

Conflicts:
- `Gemfile.lock`:
  glitch-soc-only dependency textually too close to updated upstream
  dependencies. Updated to upsteam dependencies.
This commit is contained in:
Thibaut Girka
2020-11-25 15:31:45 +01:00
22 changed files with 452 additions and 327 deletions

View File

@@ -230,13 +230,13 @@ const startWorker = (workerId) => {
const FALSE_VALUES = [
false,
0,
"0",
"f",
"F",
"false",
"FALSE",
"off",
"OFF"
'0',
'f',
'F',
'false',
'FALSE',
'off',
'OFF',
];
/**
@@ -378,6 +378,8 @@ const startWorker = (workerId) => {
return 'direct';
case '/api/v1/streaming/list':
return 'list';
default:
return undefined;
}
};
@@ -476,7 +478,7 @@ const startWorker = (workerId) => {
log.verbose(req.requestId, `Closing connection for ${req.accountId} due to expired access token`);
eventHandlers.onKill();
}
}
};
};
/**
@@ -531,7 +533,8 @@ const startWorker = (workerId) => {
log.error(req.requestId, err.toString());
if (res.headersSent) {
return next(err);
next(err);
return;
}
res.writeHead(err.status || 500, { 'Content-Type': 'application/json' });
@@ -1054,7 +1057,7 @@ const startWorker = (workerId) => {
if (type === 'subscribe') {
subscribeWebsocketToChannel(session, firstParam(stream), params);
} else if (type === 'unsubscribe') {
unsubscribeWebsocketFromChannel(session, firstParam(stream), params)
unsubscribeWebsocketFromChannel(session, firstParam(stream), params);
} else {
// Unknown action type
}