db created, added tests -- tentative

backend/db/index.js

@@ -0,0 +1,13 @@
+import pg from 'pg';
+
+const pool = new pg.Pool({
+  connectionString: process.env.DATABASE_URL,
+});
+
+export const query = (text, params) => pool.query(text, params);
+
+export const getPool = () => pool;
+
+export const close = () => pool.end();
+
+export default pool;

backend/db/migrate.js

@@ -0,0 +1,30 @@
+import 'dotenv/config';
+import { query, close } from './index.js';
+
+const up = `
+CREATE TABLE IF NOT EXISTS notes (
+  id          VARCHAR(64) PRIMARY KEY,
+  text        TEXT NOT NULL,
+  x           INTEGER DEFAULT 0,
+  y           INTEGER DEFAULT 0,
+  author      VARCHAR(128),
+  color       VARCHAR(32) DEFAULT 'yellow',
+  source_meta JSONB DEFAULT '{}',
+  created_at  TIMESTAMPTZ DEFAULT NOW(),
+  updated_at  TIMESTAMPTZ DEFAULT NOW()
+);
+`;
+
+const run = async () => {
+  try {
+    await query(up);
+    console.log('Migration complete — notes table ready.');
+  } catch (err) {
+    console.error('Migration failed:', err.message);
+    process.exit(1);
+  } finally {
+    await close();
+  }
+};
+
+run();

backend/db/notes.dao.js

@@ -0,0 +1,54 @@
+import { query } from './index.js';
+
+export const getAllNotes = async () => {
+  const { rows } = await query(
+    'SELECT id, text, x, y, author, color FROM notes ORDER BY id'
+  );
+  return rows;
+};
+
+export const getNoteById = async (id) => {
+  const { rows } = await query(
+    'SELECT id, text, x, y, author, color FROM notes WHERE id = $1',
+    [id]
+  );
+  return rows[0] || null;
+};
+
+export const createNote = async (note) => {
+  const { rows } = await query(
+    `INSERT INTO notes (id, text, x, y, author, color)
+     VALUES ($1, $2, $3, $4, $5, $6)
+     RETURNING id, text, x, y, author, color`,
+    [note.id, note.text, note.x ?? 0, note.y ?? 0, note.author, note.color ?? 'yellow']
+  );
+  return rows[0];
+};
+
+export const createNotes = async (notes) => {
+  const values = [];
+  const placeholders = [];
+
+  notes.forEach((note, i) => {
+    const offset = i * 6;
+    placeholders.push(
+      `($${offset + 1}, $${offset + 2}, $${offset + 3}, $${offset + 4}, $${offset + 5}, $${offset + 6})`
+    );
+    values.push(
+      note.id,
+      note.text,
+      note.x ?? 0,
+      note.y ?? 0,
+      note.author,
+      note.color ?? 'yellow'
+    );
+  });
+
+  const { rows } = await query(
+    `INSERT INTO notes (id, text, x, y, author, color)
+     VALUES ${placeholders.join(', ')}
+     RETURNING id, text, x, y, author, color`,
+    values
+  );
+  return rows;
+};

backend/db/seed.js

@@ -0,0 +1,40 @@
+import 'dotenv/config';
+import { readFile } from 'fs/promises';
+import { query, close } from './index.js';
+
+const NOTES_PATH = new URL('../data/notes.json', import.meta.url);
+
+const run = async () => {
+  try {
+    const raw = await readFile(NOTES_PATH, 'utf-8');
+    const notes = JSON.parse(raw);
+
+    const insertQuery = `
+      INSERT INTO notes (id, text, x, y, author, color)
+      VALUES ($1, $2, $3, $4, $5, $6)
+      ON CONFLICT (id) DO NOTHING
+    `;
+
+    let inserted = 0;
+    for (const note of notes) {
+      const result = await query(insertQuery, [
+        note.id,
+        note.text,
+        note.x,
+        note.y,
+        note.author,
+        note.color,
+      ]);
+      inserted += result.rowCount;
+    }
+
+    console.log(`Seed complete — ${inserted} notes inserted (${notes.length - inserted} already existed).`);
+  } catch (err) {
+    console.error('Seed failed:', err.message);
+    process.exit(1);
+  } finally {
+    await close();
+  }
+};
+
+run();