graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-11-26 23:23:08 +02:00
Code Issues Projects Releases Packages Wiki Activity

upd: filter fallback to db for silenced users

Browse source
This commit is contained in:
Mar0xy 2023-10-18 19:51:10 +02:00
parent 4b230d792c
commit bb54909d8e
No known key found for this signature in database
GPG key ID: 56569BBE47D2C828
3 changed files with 19 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
packages/backend/src/server/api/endpoints/notes/hybrid-timeline.ts
View file

@ -238,7 +238,12 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
}
//#endregion
const timeline = await query.limit(ps.limit).getMany();
let timeline = await query.limit(ps.limit).getMany();
timeline = timeline.filter(note => {
if (note.user?.isSilenced && note.userId !== me.id && !followings[note.userId]) return false;
return true;
});
process.nextTick(() => {
this.activeUsersChart.read(me);

7
packages/backend/src/server/api/endpoints/notes/local-timeline.ts
View file

@ -171,7 +171,12 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
query.andWhere('note.fileIds != \'{}\'');
}
const timeline = await query.limit(ps.limit).getMany();
let timeline = await query.limit(ps.limit).getMany();
timeline = timeline.filter(note => {
if (note.user?.isSilenced && me && followings && note.userId !== me.id && !followings[note.userId]) return false;
return true;
});
process.nextTick(() => {
if (me) {

7
packages/backend/src/server/api/endpoints/notes/timeline.ts
View file

@ -199,7 +199,12 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
}
//#endregion
const timeline = await query.limit(ps.limit).getMany();
let timeline = await query.limit(ps.limit).getMany();
timeline = timeline.filter(note => {
if (note.user?.isSilenced && note.userId !== me.id && !followings[note.userId]) return false;
return true;
});
process.nextTick(() => {
this.activeUsersChart.read(me);