diff options
Diffstat (limited to 'src/server/repositories')
| -rw-r--r-- | src/server/repositories/note.test.ts | 1 | ||||
| -rw-r--r-- | src/server/repositories/note.ts | 125 | ||||
| -rw-r--r-- | src/server/repositories/types.ts | 19 |
3 files changed, 145 insertions, 0 deletions
diff --git a/src/server/repositories/note.test.ts b/src/server/repositories/note.test.ts index 0fe1c9f..2c4b900 100644 --- a/src/server/repositories/note.test.ts +++ b/src/server/repositories/note.test.ts @@ -109,6 +109,7 @@ function createMockNoteRepo(): NoteRepository { create: vi.fn(), update: vi.fn(), softDelete: vi.fn(), + createMany: vi.fn(), }; } diff --git a/src/server/repositories/note.ts b/src/server/repositories/note.ts index eb1aa28..6f607cf 100644 --- a/src/server/repositories/note.ts +++ b/src/server/repositories/note.ts @@ -9,6 +9,8 @@ import { noteTypes, } from "../db/schema.js"; import type { + BulkCreateNoteInput, + BulkCreateNoteResult, Card, CreateNoteResult, Note, @@ -265,6 +267,129 @@ export const noteRepository: NoteRepository = { return result.length > 0; }, + + async createMany( + deckId: string, + notesInput: BulkCreateNoteInput[], + ): Promise<BulkCreateNoteResult> { + const failed: { index: number; error: string }[] = []; + let created = 0; + + // Pre-fetch all note types and their field types for validation + const noteTypeCache = new Map< + string, + { + noteType: { + frontTemplate: string; + backTemplate: string; + isReversible: boolean; + }; + fieldTypes: { id: string; name: string }[]; + } + >(); + + for (let i = 0; i < notesInput.length; i++) { + const input = notesInput[i]; + if (!input) continue; + + try { + // Get note type from cache or fetch + let cached = noteTypeCache.get(input.noteTypeId); + if (!cached) { + const noteType = await db + .select() + .from(noteTypes) + .where( + and( + eq(noteTypes.id, input.noteTypeId), + isNull(noteTypes.deletedAt), + ), + ); + + if (!noteType[0]) { + failed.push({ index: i, error: "Note type not found" }); + continue; + } + + const fieldTypes = await db + .select() + .from(noteFieldTypes) + .where( + and( + eq(noteFieldTypes.noteTypeId, input.noteTypeId), + isNull(noteFieldTypes.deletedAt), + ), + ) + .orderBy(noteFieldTypes.order); + + cached = { noteType: noteType[0], fieldTypes }; + noteTypeCache.set(input.noteTypeId, cached); + } + + // Create note + const [note] = await db + .insert(notes) + .values({ + deckId, + noteTypeId: input.noteTypeId, + }) + .returning(); + + if (!note) { + failed.push({ index: i, error: "Failed to create note" }); + continue; + } + + // Create field values + const fieldValuesResult: NoteFieldValue[] = []; + for (const fieldType of cached.fieldTypes) { + const value = input.fields[fieldType.id] ?? ""; + const [fieldValue] = await db + .insert(noteFieldValues) + .values({ + noteId: note.id, + noteFieldTypeId: fieldType.id, + value, + }) + .returning(); + if (fieldValue) { + fieldValuesResult.push(fieldValue); + } + } + + // Create normal card + await createCardForNote( + deckId, + note.id, + cached.noteType, + fieldValuesResult, + cached.fieldTypes, + false, + ); + + // Create reversed card if reversible + if (cached.noteType.isReversible) { + await createCardForNote( + deckId, + note.id, + cached.noteType, + fieldValuesResult, + cached.fieldTypes, + true, + ); + } + + created++; + } catch (error) { + failed.push({ + index: i, + error: error instanceof Error ? error.message : "Unknown error", + }); + } + } + + return { created, failed }; + }, }; async function createCardForNote( diff --git a/src/server/repositories/types.ts b/src/server/repositories/types.ts index a986cad..4768d49 100644 --- a/src/server/repositories/types.ts +++ b/src/server/repositories/types.ts @@ -310,6 +310,21 @@ export interface CreateNoteResult { cards: Card[]; } +export interface BulkCreateNoteInput { + noteTypeId: string; + fields: Record<string, string>; +} + +export interface BulkCreateNoteFailure { + index: number; + error: string; +} + +export interface BulkCreateNoteResult { + created: number; + failed: BulkCreateNoteFailure[]; +} + export interface NoteRepository { findByDeckId(deckId: string): Promise<Note[]>; findById(id: string, deckId: string): Promise<Note | undefined>; @@ -330,4 +345,8 @@ export interface NoteRepository { fields: Record<string, string>, ): Promise<NoteWithFieldValues | undefined>; softDelete(id: string, deckId: string): Promise<boolean>; + createMany( + deckId: string, + notes: BulkCreateNoteInput[], + ): Promise<BulkCreateNoteResult>; } |
