mirrors/firefish
1
0
Fork 1
mirror of https://git.joinfirefish.org/firefish/firefish.git synced 2024-05-19 05:31:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix (backend): update note_file table by post imports

Browse source
This commit is contained in:
naskya 2024-04-25 08:22:30 +09:00
parent 7441f0861a
commit 24e6e31b2b
No known key found for this signature in database
GPG key ID: 712D413B3A9FED5C
2 changed files with 20 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
packages/backend/src/queue/processors/db/import-firefish-post.ts
View file

@ -1,6 +1,6 @@
import * as Post from "@/misc/post.js";
import create from "@/services/note/create.js";
import { Users } from "@/models/index.js";
import { NoteFiles, Users } from "@/models/index.js";
import type { DbUserImportMastoPostJobData } from "@/queue/types.js";
import { queueLogger } from "../../logger.js";
import { uploadFromUrl } from "@/services/drive/upload-from-url.js";
@ -59,9 +59,17 @@ export async function importCkPost(
userId: user.id,
});
if (note && (note?.fileIds?.length || 0) < files.length) {
if (note != null && (note.fileIds?.length || 0) < files.length) {
const update: Partial<Note> = {};
update.fileIds = files.map((x) => x.id);
if (update.fileIds != null) {
await NoteFiles.delete({ noteId: note.id });
await NoteFiles.insert(
update.fileIds.map((fileId) => ({ noteId: note?.id, fileId })),
);
}
await Notes.update(note.id, update);
await NoteEdits.insert({
id: genId(),

12
packages/backend/src/queue/processors/db/import-masto-post.ts
View file

@ -1,5 +1,5 @@
import create from "@/services/note/create.js";
import { Users } from "@/models/index.js";
import { NoteFiles, Users } from "@/models/index.js";
import type { DbUserImportMastoPostJobData } from "@/queue/types.js";
import { queueLogger } from "../../logger.js";
import type Bull from "bull";
@ -85,9 +85,17 @@ export async function importMastoPost(
userId: user.id,
});
if (note && (note?.fileIds?.length || 0) < files.length) {
if (note != null && (note.fileIds?.length || 0) < files.length) {
const update: Partial<Note> = {};
update.fileIds = files.map((x) => x.id);
if (update.fileIds != null) {
await NoteFiles.delete({ noteId: note.id });
await NoteFiles.insert(
update.fileIds.map((fileId) => ({ noteId: note?.id, fileId })),
);
}
await Notes.update(note.id, update);
await NoteEdits.insert({
id: genId(),