indentation fix
This commit is contained in:
parent
301cf54cff
commit
247ccbc265
@ -660,19 +660,20 @@ const startWorker = (workerId) => {
|
|||||||
streamFrom(channel, req, streamToWs(req, ws), streamWsEnd(req, ws, subscriptionHeartbeat(channel)));
|
streamFrom(channel, req, streamToWs(req, ws), streamWsEnd(req, ws, subscriptionHeartbeat(channel)));
|
||||||
});
|
});
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 'group':
|
case 'group':
|
||||||
const groupId = location.query.group;
|
const groupId = location.query.group;
|
||||||
|
|
||||||
authorizeGroupAccess(groupId, req, authorized => {
|
authorizeGroupAccess(groupId, req, authorized => {
|
||||||
if (!authorized) {
|
if (!authorized) {
|
||||||
ws.close();
|
ws.close();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
channel = `timeline:group:${groupId}`;
|
channel = `timeline:group:${groupId}`;
|
||||||
streamFrom(channel, req, streamToWs(req, ws), streamWsEnd(req, ws, subscriptionHeartbeat(channel)));
|
streamFrom(channel, req, streamToWs(req, ws), streamWsEnd(req, ws, subscriptionHeartbeat(channel)));
|
||||||
});
|
});
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
ws.close();
|
ws.close();
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user