aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/server/repositories
diff options
context:
space:
mode:
authornsfisis <nsfisis@gmail.com>2026-01-01 22:06:40 +0900
committernsfisis <nsfisis@gmail.com>2026-01-01 22:06:40 +0900
commit8dbe5c2a1d8dc15bbdd6810b2582c680e1c0bb9b (patch)
treebe39e1436f83c716fc45df133106fba7dd4bc23a /src/server/repositories
parent830b370f1b8e0f3a384b2d242ab120812e81977d (diff)
downloadkioku-8dbe5c2a1d8dc15bbdd6810b2582c680e1c0bb9b.tar.gz
kioku-8dbe5c2a1d8dc15bbdd6810b2582c680e1c0bb9b.tar.zst
kioku-8dbe5c2a1d8dc15bbdd6810b2582c680e1c0bb9b.zip
feat(import): add CSV bulk import for notes
Add client-side CSV parsing and bulk import API endpoint for importing notes from CSV files. Supports quoted fields, newlines in values, and escaped quotes. - New POST /api/decks/{deckId}/notes/import endpoint for bulk creation - CSV parser with RFC 4180 compliance - Multi-phase import modal (upload → validate → preview → import) - Client-side validation with per-row error reporting 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
Diffstat (limited to 'src/server/repositories')
-rw-r--r--src/server/repositories/note.test.ts1
-rw-r--r--src/server/repositories/note.ts125
-rw-r--r--src/server/repositories/types.ts19
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>;
}