HoovesSocial/hippofish
2
0
Fork 0
Code Issues 3 Pull requests 1 Projects Releases Packages Wiki Activity Actions

fix: thread muting

Browse source
This commit is contained in:
Namekuji 2023-08-22 09:25:17 -04:00
parent 64aaff1f3d
commit 3f43f3d801
No known key found for this signature in database
GPG key ID: 1D62332C07FBA532
1 changed files with 14 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
packages/backend/src/server/api/endpoints/notes/thread-muting/create.ts
View file

@ -4,6 +4,7 @@ import readNote from "@/services/note/read.js";
import define from "../../../define.js"; import define from "../../../define.js";
import { getNote } from "../../../common/getters.js"; import { getNote } from "../../../common/getters.js";
import { ApiError } from "../../../error.js"; import { ApiError } from "../../../error.js";
import { scyllaClient } from "@/db/scylla.js";
export const meta = { export const meta = {
tags: ["notes"], tags: ["notes"],
@ -36,18 +37,20 @@ export default define(meta, paramDef, async (ps, user) => {
throw err; throw err;
}); });
const mutedNotes = await Notes.find({ if (!scyllaClient) {
where: [ const mutedNotes = await Notes.find({
{ where: [
id: note.threadId || note.id, {
}, id: note.threadId || note.id,
{ },
threadId: note.threadId || note.id, {
}, threadId: note.threadId || note.id,
], },
}); ],
});
await readNote(user.id, mutedNotes); await readNote(user.id, mutedNotes);
}
await NoteThreadMutings.insert({ await NoteThreadMutings.insert({
id: genId(), id: genId(),