Add social filter to threads

This commit is contained in:
Cecilia Lindskog 2021-01-27 12:12:40 +01:00
parent 04d52b9947
commit bb5dfced9b
1 changed files with 2 additions and 0 deletions

View File

@ -1261,10 +1261,12 @@ module.exports = ({ cooler, isPublic }) => {
],
})
);
const basicSocialFilter = await socialFilter();
const messages = await new Promise((resolve, reject) => {
pull(
source,
basicSocialFilter,
pull.filter((message) => isNotPrivate(message) && hasNoRoot(message)),
pull.take(maxMessages),
pullParallelMap(async (message, cb) => {