forked from FoundKeyGang/FoundKey
ローカルタイムラインストリームに認証不要で接続できるように
This commit is contained in:
parent
f42665d4bc
commit
dc1d7fa9d7
2 changed files with 8 additions and 4 deletions
|
@ -9,10 +9,10 @@ export default async function(
|
|||
request: websocket.request,
|
||||
connection: websocket.connection,
|
||||
subscriber: Xev,
|
||||
user: IUser
|
||||
user?: IUser
|
||||
) {
|
||||
const mute = await Mute.find({ muterId: user._id });
|
||||
const mutedUserIds = mute.map(m => m.muteeId.toString());
|
||||
const mute = user ? await Mute.find({ muterId: user._id }) : null;
|
||||
const mutedUserIds = mute ? mute.map(m => m.muteeId.toString()) : [];
|
||||
|
||||
// Subscribe stream
|
||||
subscriber.on('local-timeline', async note => {
|
||||
|
|
|
@ -52,6 +52,11 @@ module.exports = (server: http.Server) => {
|
|||
return;
|
||||
}
|
||||
|
||||
if (request.resourceURL.pathname === '/local-timeline') {
|
||||
localTimelineStream(request, connection, ev, user);
|
||||
return;
|
||||
}
|
||||
|
||||
if (user == null) {
|
||||
connection.send('authentication-failed');
|
||||
connection.close();
|
||||
|
@ -60,7 +65,6 @@ module.exports = (server: http.Server) => {
|
|||
|
||||
const channel: any =
|
||||
request.resourceURL.pathname === '/' ? homeStream :
|
||||
request.resourceURL.pathname === '/local-timeline' ? localTimelineStream :
|
||||
request.resourceURL.pathname === '/hybrid-timeline' ? hybridTimelineStream :
|
||||
request.resourceURL.pathname === '/global-timeline' ? globalTimelineStream :
|
||||
request.resourceURL.pathname === '/user-list' ? userListStream :
|
||||
|
|
Loading…
Reference in a new issue