|
|
@ -334,6 +334,12 @@ const startWorker = (workerId) => { |
|
|
|
return; |
|
|
|
return; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Only send local-only statuses to logged-in users
|
|
|
|
|
|
|
|
if (payload.local_only && !req.accountId) { |
|
|
|
|
|
|
|
log.silly(req.requestId, `Message ${payload.id} filtered because it was local-only`); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// Only messages that may require filtering are statuses, since notifications
|
|
|
|
// Only messages that may require filtering are statuses, since notifications
|
|
|
|
// are already personalized and deletes do not matter
|
|
|
|
// are already personalized and deletes do not matter
|
|
|
|
if (!needsFiltering || event !== 'update') { |
|
|
|
if (!needsFiltering || event !== 'update') { |
|
|
|