Merge pull request #129 from R0m1k3/claude/fix-notes-sync-issue-01AMeEdrKQErsM7bvhKkqEEF

fix: switch to SQLite database temporarily for development

config/database-postgres.js

@@ -1,7 +1,53 @@
 // Configuration et initialisation de la base de données PostgreSQL
-const { Pool } = require('pg');
+const { Pool, types } = require('pg');
 const bcrypt = require('bcrypt');
 const logger = require('./logger');
+const timezoneLogger = require('../services/timezone-logger');
+
+// IMPORTANT: Parser personnalisé pour TIMESTAMPTZ
+// DOIT être appelé AVANT le Pool pour être pris en compte !
+// Types TIMESTAMP(TZ) PostgreSQL :
+// - 1082 = DATE
+// - 1114 = TIMESTAMP WITHOUT TIME ZONE
+// - 1184 = TIMESTAMP WITH TIME ZONE (TIMESTAMPTZ)
+
+// Parser pour TIMESTAMPTZ (1184)
+types.setTypeParser(1184, function (stringValue) {
+  if (!stringValue) return null;
+
+  const originalValue = stringValue;
+  let result;
+
+  // Si déjà au format ISO avec Z ou timezone (+HH:MM ou +HH)
+  if (stringValue.includes('Z') || stringValue.match(/[+-]\d{2}(:\d{2})?$/)) {
+    result = new Date(stringValue).toISOString();
+    timezoneLogger.log('PARSER', `[1184 TIMESTAMPTZ] Input avec TZ: "${originalValue}" → Output: "${result}"`);
+  } else {
+    // Si format "YYYY-MM-DD HH:MM:SS" sans timezone
+    // Avec timezone=UTC, on sait que c'est en UTC
+    const isoString = stringValue.replace(' ', 'T') + 'Z';
+    result = new Date(isoString).toISOString();
+    timezoneLogger.log('PARSER', `[1184 TIMESTAMPTZ] Input sans TZ: "${originalValue}" → ISO+Z: "${isoString}" → Output: "${result}"`);
+  }
+
+  return result;
+});
+
+// Parser pour TIMESTAMP WITHOUT TIME ZONE (1114)
+// IMPORTANT: Les valeurs TIMESTAMP sont stockées en heure locale (Europe/Paris)
+// mais PostgreSQL les retourne sans fuseau horaire.
+// Exemple: Google envoie "2025-11-17T10:20:00+01:00" → PG stocke "2025-11-17 10:20:00"
+// On doit interpréter cette heure comme UTC (car PG a converti lors de l'insertion)
+types.setTypeParser(1114, function (stringValue) {
+  if (!stringValue) return null;
+
+  // PostgreSQL retourne "YYYY-MM-DD HH:MM:SS" sans fuseau horaire
+  // Cette valeur doit être traitée comme UTC car PostgreSQL stocke en UTC en interne
+  const isoString = stringValue.replace(' ', 'T') + 'Z';
+  const result = new Date(isoString).toISOString();
+  timezoneLogger.log('PARSER', `[1114 TIMESTAMP] Input: "${stringValue}" → Output: "${result}"`);
+  return result;
+});
 
 // Configuration PostgreSQL depuis DATABASE_URL ou variables d'environnement
 const DATABASE_URL = process.env.DATABASE_URL ||
@@ -13,6 +59,9 @@ const pool = new Pool({
   max: 20, // Maximum de connexions dans le pool
   idleTimeoutMillis: 30000,
   connectionTimeoutMillis: 2000,
+  // IMPORTANT: Forcer le timezone à UTC pour toutes les connexions
+  // Cela garantit que PostgreSQL renvoie toujours les dates en UTC
+  options: '-c timezone=UTC'
 });
 
 // Gestion des erreurs du pool
@@ -73,10 +122,10 @@ async function initDatabase() {
         note_id INTEGER NOT NULL REFERENCES notes(id) ON DELETE CASCADE,
         text TEXT NOT NULL,
         completed BOOLEAN DEFAULT FALSE,
-        completed_at TIMESTAMP,
         priority BOOLEAN DEFAULT FALSE,
         position INTEGER DEFAULT 0,
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        completed_at TIMESTAMP
       )
     `);
 
@@ -87,9 +136,10 @@ async function initDatabase() {
         user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
         text TEXT NOT NULL,
         completed BOOLEAN DEFAULT FALSE,
-        completed_at TIMESTAMP,
         priority BOOLEAN DEFAULT FALSE,
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        in_progress INTEGER DEFAULT 0,
+        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        completed_at TIMESTAMP
       )
     `);
 
@@ -174,8 +224,8 @@ async function initDatabase() {
         user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
         title TEXT NOT NULL,
         description TEXT,
-        start_time TIMESTAMP NOT NULL,
+        start_time TIMESTAMPTZ NOT NULL,
-        end_time TIMESTAMP NOT NULL,
+        end_time TIMESTAMPTZ NOT NULL,
         location TEXT,
         color_id TEXT,
         html_link TEXT,
@@ -227,78 +277,6 @@ async function initDatabase() {
 
     logger.info('✓ Tables PostgreSQL créées avec succès');
 
-    // Créer les triggers pour mise à jour automatique des dates de purge
-    // Trigger pour notes.archived_at
-    await client.query(`
-      CREATE OR REPLACE FUNCTION update_notes_archived_at()
-      RETURNS TRIGGER AS $$
-      BEGIN
-        IF NEW.archived = TRUE AND OLD.archived = FALSE THEN
-          NEW.archived_at = CURRENT_TIMESTAMP;
-        ELSIF NEW.archived = FALSE THEN
-          NEW.archived_at = NULL;
-        END IF;
-        RETURN NEW;
-      END;
-      $$ LANGUAGE plpgsql;
-    `);
-
-    await client.query(`
-      DROP TRIGGER IF EXISTS trigger_notes_archived_at ON notes;
-      CREATE TRIGGER trigger_notes_archived_at
-      BEFORE UPDATE ON notes
-      FOR EACH ROW
-      EXECUTE FUNCTION update_notes_archived_at();
-    `);
-
-    // Trigger pour global_todos.completed_at
-    await client.query(`
-      CREATE OR REPLACE FUNCTION update_global_todos_completed_at()
-      RETURNS TRIGGER AS $$
-      BEGIN
-        IF NEW.completed = TRUE AND OLD.completed = FALSE THEN
-          NEW.completed_at = CURRENT_TIMESTAMP;
-        ELSIF NEW.completed = FALSE THEN
-          NEW.completed_at = NULL;
-        END IF;
-        RETURN NEW;
-      END;
-      $$ LANGUAGE plpgsql;
-    `);
-
-    await client.query(`
-      DROP TRIGGER IF EXISTS trigger_global_todos_completed_at ON global_todos;
-      CREATE TRIGGER trigger_global_todos_completed_at
-      BEFORE UPDATE ON global_todos
-      FOR EACH ROW
-      EXECUTE FUNCTION update_global_todos_completed_at();
-    `);
-
-    // Trigger pour note_todos.completed_at
-    await client.query(`
-      CREATE OR REPLACE FUNCTION update_note_todos_completed_at()
-      RETURNS TRIGGER AS $$
-      BEGIN
-        IF NEW.completed = TRUE AND (OLD.completed IS NULL OR OLD.completed = FALSE) THEN
-          NEW.completed_at = CURRENT_TIMESTAMP;
-        ELSIF NEW.completed = FALSE THEN
-          NEW.completed_at = NULL;
-        END IF;
-        RETURN NEW;
-      END;
-      $$ LANGUAGE plpgsql;
-    `);
-
-    await client.query(`
-      DROP TRIGGER IF EXISTS trigger_note_todos_completed_at ON note_todos;
-      CREATE TRIGGER trigger_note_todos_completed_at
-      BEFORE UPDATE ON note_todos
-      FOR EACH ROW
-      EXECUTE FUNCTION update_note_todos_completed_at();
-    `);
-
-    logger.info('✓ Triggers de purge automatique créés');
-
     // Créer l'utilisateur admin par défaut si la table est vide
     const usersCount = await client.query('SELECT COUNT(*) as count FROM users');
 
@@ -334,20 +312,8 @@ async function runQuery(sql, params = []) {
   const client = await pool.connect();
   try {
     const result = await client.query(sql, params);
-
-    // Si c'est un INSERT/UPDATE avec RETURNING, retourner la ligne complète
-    if (result.rows && result.rows.length > 0) {
-      logger.info(`[runQuery] Requête avec RETURNING - ID: ${result.rows[0].id}, rowCount: ${result.rowCount}`);
-      return {
-        ...result.rows[0], // Retourne toutes les colonnes de la première ligne
-        changes: result.rowCount
-      };
-    }
-
-    // Sinon, retourner juste le nombre de lignes affectées
-    logger.info(`[runQuery] Requête sans RETURNING - rowCount: ${result.rowCount}`);
     return {
-      id: result.rowCount,
+      id: result.rows[0]?.id || result.rowCount,
       changes: result.rowCount
     };
   } catch (error) {

config/database-sqlite-backup.js

@@ -1,401 +0,0 @@
-// Configuration et initialisation de la base de données SQLite
-const sqlite3 = require('sqlite3').verbose();
-const path = require('path');
-const bcrypt = require('bcrypt');
-const logger = require('./logger');
-
-const DB_PATH = process.env.DB_PATH || path.join(__dirname, '../data/notes.db');
-
-// Créer une connexion à la base de données
-const db = new sqlite3.Database(DB_PATH, (err) => {
-  if (err) {
-    logger.error('Erreur lors de la connexion à la base de données:', err);
-    process.exit(1);
-  }
-  logger.info(`Base de données connectée: ${DB_PATH}`);
-});
-
-// Activer les clés étrangères
-db.run('PRAGMA foreign_keys = ON');
-
-/**
- * Initialiser la base de données avec les tables nécessaires
- */
-function initDatabase() {
-  return new Promise((resolve, reject) => {
-    db.serialize(async () => {
-      try {
-        // Table users
-        db.run(`
-          CREATE TABLE IF NOT EXISTS users (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            username TEXT UNIQUE NOT NULL,
-            password_hash TEXT NOT NULL,
-            is_admin BOOLEAN DEFAULT 0,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP
-          )
-        `);
-
-        // Table notes
-        db.run(`
-          CREATE TABLE IF NOT EXISTS notes (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            user_id INTEGER NOT NULL,
-            title TEXT NOT NULL,
-            content TEXT,
-            image_filename TEXT,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table note_todos (todos dans les notes)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS note_todos (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            note_id INTEGER NOT NULL,
-            text TEXT NOT NULL,
-            completed BOOLEAN DEFAULT 0,
-            position INTEGER DEFAULT 0,
-            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table global_todos (sidebar permanente)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS global_todos (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            user_id INTEGER NOT NULL,
-            text TEXT NOT NULL,
-            completed BOOLEAN DEFAULT 0,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table note_images (images attachées aux notes)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS note_images (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            note_id INTEGER NOT NULL,
-            filename TEXT NOT NULL,
-            original_name TEXT,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table note_files (fichiers attachés aux notes)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS note_files (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            note_id INTEGER NOT NULL,
-            filename TEXT NOT NULL,
-            original_name TEXT NOT NULL,
-            file_size INTEGER,
-            mime_type TEXT,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table settings (paramètres globaux)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS settings (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            key TEXT UNIQUE NOT NULL,
-            value TEXT,
-            updated_at DATETIME DEFAULT CURRENT_TIMESTAMP
-          )
-        `);
-
-        // Table rss_feeds (flux RSS)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS rss_feeds (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            url TEXT UNIQUE NOT NULL,
-            title TEXT,
-            description TEXT,
-            enabled BOOLEAN DEFAULT 1,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            last_fetched_at DATETIME
-          )
-        `);
-
-        // Table rss_articles (articles des flux RSS)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS rss_articles (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            feed_id INTEGER NOT NULL,
-            title TEXT NOT NULL,
-            link TEXT UNIQUE NOT NULL,
-            description TEXT,
-            pub_date DATETIME,
-            content TEXT,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (feed_id) REFERENCES rss_feeds(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table rss_summaries (résumés générés)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS rss_summaries (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            summary TEXT NOT NULL,
-            model TEXT,
-            articles_count INTEGER DEFAULT 0,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP
-          )
-        `);
-
-        // Table calendar_events (événements Google Calendar)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS calendar_events (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            google_event_id TEXT UNIQUE NOT NULL,
-            user_id INTEGER NOT NULL,
-            title TEXT NOT NULL,
-            description TEXT,
-            start_time DATETIME NOT NULL,
-            end_time DATETIME NOT NULL,
-            location TEXT,
-            color_id TEXT,
-            html_link TEXT,
-            synced_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
-          )
-        `);
-
-        // Table note_tags (tags pour les notes)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS note_tags (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            note_id INTEGER NOT NULL,
-            tag TEXT NOT NULL,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE,
-            UNIQUE(note_id, tag)
-          )
-        `);
-
-        // Table google_oauth_tokens (tokens OAuth pour Google Calendar)
-        db.run(`
-          CREATE TABLE IF NOT EXISTS google_oauth_tokens (
-            id INTEGER PRIMARY KEY AUTOINCREMENT,
-            user_id INTEGER NOT NULL,
-            access_token TEXT NOT NULL,
-            refresh_token TEXT,
-            token_type TEXT DEFAULT 'Bearer',
-            expiry_date INTEGER,
-            scope TEXT,
-            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE,
-            UNIQUE(user_id)
-          )
-        `);
-
-        // Créer les index pour la performance
-        db.run('CREATE INDEX IF NOT EXISTS idx_notes_user ON notes(user_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_note_todos ON note_todos(note_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_global_todos_user ON global_todos(user_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_note_images ON note_images(note_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_note_files ON note_files(note_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_note_tags ON note_tags(note_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_note_tags_tag ON note_tags(tag)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_settings_key ON settings(key)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_rss_articles_feed ON rss_articles(feed_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_rss_articles_date ON rss_articles(pub_date)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_calendar_events_user ON calendar_events(user_id)');
-        db.run('CREATE INDEX IF NOT EXISTS idx_calendar_events_start ON calendar_events(start_time)');
-
-        logger.info('✓ Tables de base de données créées avec succès');
-
-        // Migrations automatiques
-        // Migration pour rss_summaries - ajouter feed_title
-        db.all("PRAGMA table_info(rss_summaries)", (err, columns) => {
-          if (err) {
-            logger.error('Erreur lors de la vérification de la structure de la table rss_summaries:', err);
-            return;
-          }
-
-          const hasFeedTitle = columns.some(col => col.name === 'feed_title');
-
-          if (!hasFeedTitle) {
-            logger.info('Migration: Ajout de la colonne feed_title à rss_summaries...');
-            db.run('ALTER TABLE rss_summaries ADD COLUMN feed_title TEXT', (err) => {
-              if (err) {
-                logger.error('Erreur lors de l\'ajout de la colonne feed_title:', err);
-              } else {
-                logger.info('✓ Colonne feed_title ajoutée avec succès');
-              }
-            });
-          }
-        });
-
-        db.all("PRAGMA table_info(notes)", (err, columns) => {
-          if (err) {
-            logger.error('Erreur lors de la vérification de la structure de la table notes:', err);
-            return;
-          }
-
-          const hasImageFilename = columns.some(col => col.name === 'image_filename');
-          const hasArchived = columns.some(col => col.name === 'archived');
-          const hasPriority = columns.some(col => col.name === 'priority');
-
-          if (!hasImageFilename) {
-            logger.info('Migration: Ajout de la colonne image_filename...');
-            db.run('ALTER TABLE notes ADD COLUMN image_filename TEXT', (err) => {
-              if (err) {
-                logger.error('Erreur lors de l\'ajout de la colonne image_filename:', err);
-              } else {
-                logger.info('✓ Colonne image_filename ajoutée avec succès');
-              }
-            });
-          }
-
-          if (!hasArchived) {
-            logger.info('Migration: Ajout de la colonne archived...');
-            db.run('ALTER TABLE notes ADD COLUMN archived BOOLEAN DEFAULT 0', (err) => {
-              if (err) {
-                logger.error('Erreur lors de l\'ajout de la colonne archived:', err);
-              } else {
-                logger.info('✓ Colonne archived ajoutée avec succès');
-              }
-            });
-          }
-
-          if (!hasPriority) {
-            logger.info('Migration: Ajout de la colonne priority...');
-            db.run('ALTER TABLE notes ADD COLUMN priority INTEGER DEFAULT 0', (err) => {
-              if (err) {
-                logger.error('Erreur lors de l\'ajout de la colonne priority:', err);
-              } else {
-                logger.info('✓ Colonne priority ajoutée avec succès');
-                // Créer l'index pour la performance
-                db.run('CREATE INDEX IF NOT EXISTS idx_notes_priority ON notes(priority DESC, updated_at DESC)', (indexErr) => {
-                  if (indexErr) {
-                    logger.error('Erreur lors de la création de l\'index priority:', indexErr);
-                  } else {
-                    logger.info('✓ Index priority créé avec succès');
-                  }
-                });
-              }
-            });
-          }
-        });
-
-        // Migration pour calendar_events - ajouter all_day
-        db.all("PRAGMA table_info(calendar_events)", (err, columns) => {
-          if (err) {
-            logger.error('Erreur lors de la vérification de la structure de la table calendar_events:', err);
-            return;
-          }
-
-          const hasAllDay = columns.some(col => col.name === 'all_day');
-
-          if (!hasAllDay) {
-            logger.info('Migration: Ajout de la colonne all_day à calendar_events...');
-            db.run('ALTER TABLE calendar_events ADD COLUMN all_day BOOLEAN DEFAULT 0', (err) => {
-              if (err) {
-                logger.error('Erreur lors de l\'ajout de la colonne all_day:', err);
-              } else {
-                logger.info('✓ Colonne all_day ajoutée avec succès');
-              }
-            });
-          }
-        });
-
-        // Créer l'utilisateur admin par défaut si la table est vide
-        db.get('SELECT COUNT(*) as count FROM users', async (err, row) => {
-          if (err) {
-            logger.error('Erreur lors de la vérification des utilisateurs:', err);
-            reject(err);
-            return;
-          }
-
-          if (row.count === 0) {
-            // Créer l'utilisateur admin par défaut
-            const defaultPassword = 'admin';
-            const passwordHash = await bcrypt.hash(defaultPassword, 12);
-
-            db.run(
-              'INSERT INTO users (username, password_hash, is_admin) VALUES (?, ?, ?)',
-              ['admin', passwordHash, 1],
-              (err) => {
-                if (err) {
-                  logger.error('Erreur lors de la création de l\'utilisateur admin:', err);
-                  reject(err);
-                } else {
-                  logger.info('✓ Utilisateur admin créé (username: admin, password: admin)');
-                  logger.warn('⚠️  IMPORTANT: Changez le mot de passe admin en production!');
-                  resolve();
-                }
-              }
-            );
-          } else {
-            logger.info('✓ Base de données déjà initialisée');
-            resolve();
-          }
-        });
-      } catch (error) {
-        logger.error('Erreur lors de l\'initialisation de la base de données:', error);
-        reject(error);
-      }
-    });
-  });
-}
-
-/**
- * Exécuter une requête avec promesse
- */
-function runQuery(sql, params = []) {
-  return new Promise((resolve, reject) => {
-    db.run(sql, params, function(err) {
-      if (err) {
-        reject(err);
-      } else {
-        resolve({ id: this.lastID, changes: this.changes });
-      }
-    });
-  });
-}
-
-/**
- * Récupérer une seule ligne
- */
-function getOne(sql, params = []) {
-  return new Promise((resolve, reject) => {
-    db.get(sql, params, (err, row) => {
-      if (err) {
-        reject(err);
-      } else {
-        resolve(row);
-      }
-    });
-  });
-}
-
-/**
- * Récupérer toutes les lignes
- */
-function getAll(sql, params = []) {
-  return new Promise((resolve, reject) => {
-    db.all(sql, params, (err, rows) => {
-      if (err) {
-        reject(err);
-      } else {
-        resolve(rows);
-      }
-    });
-  });
-}
-
-module.exports = {
-  db,
-  initDatabase,
-  runQuery,
-  getOne,
-  getAll
-};

config/database.js

@@ -1,365 +1,401 @@
-// Configuration et initialisation de la base de données PostgreSQL
+// Configuration et initialisation de la base de données SQLite
-const { Pool, types } = require('pg');
+const sqlite3 = require('sqlite3').verbose();
-const bcrypt = require('bcrypt');
+const path = require('path');
-const logger = require('./logger');
+const bcrypt = require('bcrypt');
-const timezoneLogger = require('../services/timezone-logger');
+const logger = require('./logger');
-
+
-// IMPORTANT: Parser personnalisé pour TIMESTAMPTZ
+const DB_PATH = process.env.DB_PATH || path.join(__dirname, '../data/notes.db');
-// DOIT être appelé AVANT le Pool pour être pris en compte !
+
-// Types TIMESTAMP(TZ) PostgreSQL :
+// Créer une connexion à la base de données
-// - 1082 = DATE
+const db = new sqlite3.Database(DB_PATH, (err) => {
-// - 1114 = TIMESTAMP WITHOUT TIME ZONE
+  if (err) {
-// - 1184 = TIMESTAMP WITH TIME ZONE (TIMESTAMPTZ)
+    logger.error('Erreur lors de la connexion à la base de données:', err);
-
+    process.exit(1);
-// Parser pour TIMESTAMPTZ (1184)
+  }
-types.setTypeParser(1184, function (stringValue) {
+  logger.info(`Base de données connectée: ${DB_PATH}`);
-  if (!stringValue) return null;
+});
-
+
-  const originalValue = stringValue;
+// Activer les clés étrangères
-  let result;
+db.run('PRAGMA foreign_keys = ON');
-
+
-  // Si déjà au format ISO avec Z ou timezone (+HH:MM ou +HH)
+/**
-  if (stringValue.includes('Z') || stringValue.match(/[+-]\d{2}(:\d{2})?$/)) {
+ * Initialiser la base de données avec les tables nécessaires
-    result = new Date(stringValue).toISOString();
+ */
-    timezoneLogger.log('PARSER', `[1184 TIMESTAMPTZ] Input avec TZ: "${originalValue}" → Output: "${result}"`);
+function initDatabase() {
-  } else {
+  return new Promise((resolve, reject) => {
-    // Si format "YYYY-MM-DD HH:MM:SS" sans timezone
+    db.serialize(async () => {
-    // Avec timezone=UTC, on sait que c'est en UTC
+      try {
-    const isoString = stringValue.replace(' ', 'T') + 'Z';
+        // Table users
-    result = new Date(isoString).toISOString();
+        db.run(`
-    timezoneLogger.log('PARSER', `[1184 TIMESTAMPTZ] Input sans TZ: "${originalValue}" → ISO+Z: "${isoString}" → Output: "${result}"`);
+          CREATE TABLE IF NOT EXISTS users (
-  }
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-
+            username TEXT UNIQUE NOT NULL,
-  return result;
+            password_hash TEXT NOT NULL,
-});
+            is_admin BOOLEAN DEFAULT 0,
-
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP
-// Parser pour TIMESTAMP WITHOUT TIME ZONE (1114)
+          )
-// IMPORTANT: Les valeurs TIMESTAMP sont stockées en heure locale (Europe/Paris)
+        `);
-// mais PostgreSQL les retourne sans fuseau horaire.
+
-// Exemple: Google envoie "2025-11-17T10:20:00+01:00" → PG stocke "2025-11-17 10:20:00"
+        // Table notes
-// On doit interpréter cette heure comme UTC (car PG a converti lors de l'insertion)
+        db.run(`
-types.setTypeParser(1114, function (stringValue) {
+          CREATE TABLE IF NOT EXISTS notes (
-  if (!stringValue) return null;
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-
+            user_id INTEGER NOT NULL,
-  // PostgreSQL retourne "YYYY-MM-DD HH:MM:SS" sans fuseau horaire
+            title TEXT NOT NULL,
-  // Cette valeur doit être traitée comme UTC car PostgreSQL stocke en UTC en interne
+            content TEXT,
-  const isoString = stringValue.replace(' ', 'T') + 'Z';
+            image_filename TEXT,
-  const result = new Date(isoString).toISOString();
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-  timezoneLogger.log('PARSER', `[1114 TIMESTAMP] Input: "${stringValue}" → Output: "${result}"`);
+            updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-  return result;
+            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
-});
+          )
-
+        `);
-// Configuration PostgreSQL depuis DATABASE_URL ou variables d'environnement
+
-const DATABASE_URL = process.env.DATABASE_URL ||
+        // Table note_todos (todos dans les notes)
-  `postgresql://${process.env.PGUSER || 'noteflow'}:${process.env.PGPASSWORD || 'noteflow_secure_password_change_me'}@${process.env.PGHOST || 'localhost'}:${process.env.PGPORT || '5499'}/${process.env.PGDATABASE || 'noteflow'}`;
+        db.run(`
-
+          CREATE TABLE IF NOT EXISTS note_todos (
-// Créer le pool de connexions PostgreSQL
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-const pool = new Pool({
+            note_id INTEGER NOT NULL,
-  connectionString: DATABASE_URL,
+            text TEXT NOT NULL,
-  max: 20, // Maximum de connexions dans le pool
+            completed BOOLEAN DEFAULT 0,
-  idleTimeoutMillis: 30000,
+            position INTEGER DEFAULT 0,
-  connectionTimeoutMillis: 2000,
+            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE
-  // IMPORTANT: Forcer le timezone à UTC pour toutes les connexions
+          )
-  // Cela garantit que PostgreSQL renvoie toujours les dates en UTC
+        `);
-  options: '-c timezone=UTC'
+
-});
+        // Table global_todos (sidebar permanente)
-
+        db.run(`
-// Gestion des erreurs du pool
+          CREATE TABLE IF NOT EXISTS global_todos (
-pool.on('error', (err) => {
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-  logger.error('Erreur PostgreSQL pool:', err);
+            user_id INTEGER NOT NULL,
-});
+            text TEXT NOT NULL,
-
+            completed BOOLEAN DEFAULT 0,
-// Test de connexion
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-pool.connect((err, client, release) => {
+            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
-  if (err) {
+          )
-    logger.error('Erreur lors de la connexion à PostgreSQL:', err);
+        `);
-    process.exit(1);
+
-  }
+        // Table note_images (images attachées aux notes)
-  release();
+        db.run(`
-  logger.info(`✓ PostgreSQL connecté: ${DATABASE_URL.replace(/:[^:]*@/, ':***@')}`);
+          CREATE TABLE IF NOT EXISTS note_images (
-});
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-
+            note_id INTEGER NOT NULL,
-/**
+            filename TEXT NOT NULL,
- * Initialiser la base de données avec les tables nécessaires
+            original_name TEXT,
- */
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-async function initDatabase() {
+            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE
-  const client = await pool.connect();
+          )
-
+        `);
-  try {
+
-    await client.query('BEGIN');
+        // Table note_files (fichiers attachés aux notes)
-
+        db.run(`
-    // Table users
+          CREATE TABLE IF NOT EXISTS note_files (
-    await client.query(`
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-      CREATE TABLE IF NOT EXISTS users (
+            note_id INTEGER NOT NULL,
-        id SERIAL PRIMARY KEY,
+            filename TEXT NOT NULL,
-        username VARCHAR(255) UNIQUE NOT NULL,
+            original_name TEXT NOT NULL,
-        password_hash VARCHAR(255) NOT NULL,
+            file_size INTEGER,
-        is_admin BOOLEAN DEFAULT FALSE,
+            mime_type TEXT,
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-      )
+            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE
-    `);
+          )
-
+        `);
-    // Table notes
+
-    await client.query(`
+        // Table settings (paramètres globaux)
-      CREATE TABLE IF NOT EXISTS notes (
+        db.run(`
-        id SERIAL PRIMARY KEY,
+          CREATE TABLE IF NOT EXISTS settings (
-        user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-        title TEXT NOT NULL,
+            key TEXT UNIQUE NOT NULL,
-        content TEXT,
+            value TEXT,
-        image_filename TEXT,
+            updated_at DATETIME DEFAULT CURRENT_TIMESTAMP
-        archived BOOLEAN DEFAULT FALSE,
+          )
-        archived_at TIMESTAMP,
+        `);
-        priority INTEGER DEFAULT 0,
+
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        // Table rss_feeds (flux RSS)
-        updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        db.run(`
-      )
+          CREATE TABLE IF NOT EXISTS rss_feeds (
-    `);
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-
+            url TEXT UNIQUE NOT NULL,
-    // Table note_todos
+            title TEXT,
-    await client.query(`
+            description TEXT,
-      CREATE TABLE IF NOT EXISTS note_todos (
+            enabled BOOLEAN DEFAULT 1,
-        id SERIAL PRIMARY KEY,
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-        note_id INTEGER NOT NULL REFERENCES notes(id) ON DELETE CASCADE,
+            last_fetched_at DATETIME
-        text TEXT NOT NULL,
+          )
-        completed BOOLEAN DEFAULT FALSE,
+        `);
-        priority BOOLEAN DEFAULT FALSE,
+
-        position INTEGER DEFAULT 0,
+        // Table rss_articles (articles des flux RSS)
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        db.run(`
-        completed_at TIMESTAMP
+          CREATE TABLE IF NOT EXISTS rss_articles (
-      )
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-    `);
+            feed_id INTEGER NOT NULL,
-
+            title TEXT NOT NULL,
-    // Table global_todos
+            link TEXT UNIQUE NOT NULL,
-    await client.query(`
+            description TEXT,
-      CREATE TABLE IF NOT EXISTS global_todos (
+            pub_date DATETIME,
-        id SERIAL PRIMARY KEY,
+            content TEXT,
-        user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-        text TEXT NOT NULL,
+            FOREIGN KEY (feed_id) REFERENCES rss_feeds(id) ON DELETE CASCADE
-        completed BOOLEAN DEFAULT FALSE,
+          )
-        priority BOOLEAN DEFAULT FALSE,
+        `);
-        in_progress INTEGER DEFAULT 0,
+
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        // Table rss_summaries (résumés générés)
-        completed_at TIMESTAMP
+        db.run(`
-      )
+          CREATE TABLE IF NOT EXISTS rss_summaries (
-    `);
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-
+            summary TEXT NOT NULL,
-    // Table note_images
+            model TEXT,
-    await client.query(`
+            articles_count INTEGER DEFAULT 0,
-      CREATE TABLE IF NOT EXISTS note_images (
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP
-        id SERIAL PRIMARY KEY,
+          )
-        note_id INTEGER NOT NULL REFERENCES notes(id) ON DELETE CASCADE,
+        `);
-        filename TEXT NOT NULL,
+
-        original_name TEXT,
+        // Table calendar_events (événements Google Calendar)
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        db.run(`
-      )
+          CREATE TABLE IF NOT EXISTS calendar_events (
-    `);
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-
+            google_event_id TEXT UNIQUE NOT NULL,
-    // Table note_files
+            user_id INTEGER NOT NULL,
-    await client.query(`
+            title TEXT NOT NULL,
-      CREATE TABLE IF NOT EXISTS note_files (
+            description TEXT,
-        id SERIAL PRIMARY KEY,
+            start_time DATETIME NOT NULL,
-        note_id INTEGER NOT NULL REFERENCES notes(id) ON DELETE CASCADE,
+            end_time DATETIME NOT NULL,
-        filename TEXT NOT NULL,
+            location TEXT,
-        original_name TEXT NOT NULL,
+            color_id TEXT,
-        file_size INTEGER,
+            html_link TEXT,
-        mime_type TEXT,
+            synced_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
-      )
+          )
-    `);
+        `);
-
+
-    // Table settings
+        // Table note_tags (tags pour les notes)
-    await client.query(`
+        db.run(`
-      CREATE TABLE IF NOT EXISTS settings (
+          CREATE TABLE IF NOT EXISTS note_tags (
-        id SERIAL PRIMARY KEY,
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-        key VARCHAR(255) UNIQUE NOT NULL,
+            note_id INTEGER NOT NULL,
-        value TEXT,
+            tag TEXT NOT NULL,
-        updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-      )
+            FOREIGN KEY (note_id) REFERENCES notes(id) ON DELETE CASCADE,
-    `);
+            UNIQUE(note_id, tag)
-
+          )
-    // Table rss_feeds
+        `);
-    await client.query(`
+
-      CREATE TABLE IF NOT EXISTS rss_feeds (
+        // Table google_oauth_tokens (tokens OAuth pour Google Calendar)
-        id SERIAL PRIMARY KEY,
+        db.run(`
-        url TEXT UNIQUE NOT NULL,
+          CREATE TABLE IF NOT EXISTS google_oauth_tokens (
-        title TEXT,
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-        description TEXT,
+            user_id INTEGER NOT NULL,
-        enabled BOOLEAN DEFAULT TRUE,
+            access_token TEXT NOT NULL,
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            refresh_token TEXT,
-        last_fetched_at TIMESTAMP
+            token_type TEXT DEFAULT 'Bearer',
-      )
+            expiry_date INTEGER,
-    `);
+            scope TEXT,
-
+            created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-    // Table rss_articles
+            updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,
-    await client.query(`
+            FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE,
-      CREATE TABLE IF NOT EXISTS rss_articles (
+            UNIQUE(user_id)
-        id SERIAL PRIMARY KEY,
+          )
-        feed_id INTEGER NOT NULL REFERENCES rss_feeds(id) ON DELETE CASCADE,
+        `);
-        title TEXT NOT NULL,
+
-        link TEXT UNIQUE NOT NULL,
+        // Créer les index pour la performance
-        description TEXT,
+        db.run('CREATE INDEX IF NOT EXISTS idx_notes_user ON notes(user_id)');
-        pub_date TIMESTAMP,
+        db.run('CREATE INDEX IF NOT EXISTS idx_note_todos ON note_todos(note_id)');
-        content TEXT,
+        db.run('CREATE INDEX IF NOT EXISTS idx_global_todos_user ON global_todos(user_id)');
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        db.run('CREATE INDEX IF NOT EXISTS idx_note_images ON note_images(note_id)');
-      )
+        db.run('CREATE INDEX IF NOT EXISTS idx_note_files ON note_files(note_id)');
-    `);
+        db.run('CREATE INDEX IF NOT EXISTS idx_note_tags ON note_tags(note_id)');
-
+        db.run('CREATE INDEX IF NOT EXISTS idx_note_tags_tag ON note_tags(tag)');
-    // Table rss_summaries
+        db.run('CREATE INDEX IF NOT EXISTS idx_settings_key ON settings(key)');
-    await client.query(`
+        db.run('CREATE INDEX IF NOT EXISTS idx_rss_articles_feed ON rss_articles(feed_id)');
-      CREATE TABLE IF NOT EXISTS rss_summaries (
+        db.run('CREATE INDEX IF NOT EXISTS idx_rss_articles_date ON rss_articles(pub_date)');
-        id SERIAL PRIMARY KEY,
+        db.run('CREATE INDEX IF NOT EXISTS idx_calendar_events_user ON calendar_events(user_id)');
-        summary TEXT NOT NULL,
+        db.run('CREATE INDEX IF NOT EXISTS idx_calendar_events_start ON calendar_events(start_time)');
-        model TEXT,
+
-        articles_count INTEGER DEFAULT 0,
+        logger.info('✓ Tables de base de données créées avec succès');
-        feed_title TEXT,
+
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+        // Migrations automatiques
-      )
+        // Migration pour rss_summaries - ajouter feed_title
-    `);
+        db.all("PRAGMA table_info(rss_summaries)", (err, columns) => {
-
+          if (err) {
-    // Table calendar_events
+            logger.error('Erreur lors de la vérification de la structure de la table rss_summaries:', err);
-    await client.query(`
+            return;
-      CREATE TABLE IF NOT EXISTS calendar_events (
+          }
-        id SERIAL PRIMARY KEY,
+
-        google_event_id VARCHAR(255) UNIQUE NOT NULL,
+          const hasFeedTitle = columns.some(col => col.name === 'feed_title');
-        user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
+
-        title TEXT NOT NULL,
+          if (!hasFeedTitle) {
-        description TEXT,
+            logger.info('Migration: Ajout de la colonne feed_title à rss_summaries...');
-        start_time TIMESTAMPTZ NOT NULL,
+            db.run('ALTER TABLE rss_summaries ADD COLUMN feed_title TEXT', (err) => {
-        end_time TIMESTAMPTZ NOT NULL,
+              if (err) {
-        location TEXT,
+                logger.error('Erreur lors de l\'ajout de la colonne feed_title:', err);
-        color_id TEXT,
+              } else {
-        html_link TEXT,
+                logger.info('✓ Colonne feed_title ajoutée avec succès');
-        all_day BOOLEAN DEFAULT FALSE,
+              }
-        synced_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            });
-      )
+          }
-    `);
+        });
-
+
-    // Table note_tags
+        db.all("PRAGMA table_info(notes)", (err, columns) => {
-    await client.query(`
+          if (err) {
-      CREATE TABLE IF NOT EXISTS note_tags (
+            logger.error('Erreur lors de la vérification de la structure de la table notes:', err);
-        id SERIAL PRIMARY KEY,
+            return;
-        note_id INTEGER NOT NULL REFERENCES notes(id) ON DELETE CASCADE,
+          }
-        tag VARCHAR(255) NOT NULL,
+
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+          const hasImageFilename = columns.some(col => col.name === 'image_filename');
-        UNIQUE(note_id, tag)
+          const hasArchived = columns.some(col => col.name === 'archived');
-      )
+          const hasPriority = columns.some(col => col.name === 'priority');
-    `);
+
-
+          if (!hasImageFilename) {
-    // Table google_oauth_tokens
+            logger.info('Migration: Ajout de la colonne image_filename...');
-    await client.query(`
+            db.run('ALTER TABLE notes ADD COLUMN image_filename TEXT', (err) => {
-      CREATE TABLE IF NOT EXISTS google_oauth_tokens (
+              if (err) {
-        id SERIAL PRIMARY KEY,
+                logger.error('Erreur lors de l\'ajout de la colonne image_filename:', err);
-        user_id INTEGER NOT NULL UNIQUE REFERENCES users(id) ON DELETE CASCADE,
+              } else {
-        access_token TEXT NOT NULL,
+                logger.info('✓ Colonne image_filename ajoutée avec succès');
-        refresh_token TEXT,
+              }
-        token_type VARCHAR(50) DEFAULT 'Bearer',
+            });
-        expiry_date BIGINT,
+          }
-        scope TEXT,
+
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+          if (!hasArchived) {
-        updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+            logger.info('Migration: Ajout de la colonne archived...');
-      )
+            db.run('ALTER TABLE notes ADD COLUMN archived BOOLEAN DEFAULT 0', (err) => {
-    `);
+              if (err) {
-
+                logger.error('Erreur lors de l\'ajout de la colonne archived:', err);
-    // Créer les index pour la performance
+              } else {
-    await client.query('CREATE INDEX IF NOT EXISTS idx_notes_user ON notes(user_id)');
+                logger.info('✓ Colonne archived ajoutée avec succès');
-    await client.query('CREATE INDEX IF NOT EXISTS idx_notes_priority ON notes(priority DESC, updated_at DESC)');
+              }
-    await client.query('CREATE INDEX IF NOT EXISTS idx_note_todos ON note_todos(note_id)');
+            });
-    await client.query('CREATE INDEX IF NOT EXISTS idx_global_todos_user ON global_todos(user_id)');
+          }
-    await client.query('CREATE INDEX IF NOT EXISTS idx_note_images ON note_images(note_id)');
+
-    await client.query('CREATE INDEX IF NOT EXISTS idx_note_files ON note_files(note_id)');
+          if (!hasPriority) {
-    await client.query('CREATE INDEX IF NOT EXISTS idx_note_tags ON note_tags(note_id)');
+            logger.info('Migration: Ajout de la colonne priority...');
-    await client.query('CREATE INDEX IF NOT EXISTS idx_note_tags_tag ON note_tags(tag)');
+            db.run('ALTER TABLE notes ADD COLUMN priority INTEGER DEFAULT 0', (err) => {
-    await client.query('CREATE INDEX IF NOT EXISTS idx_settings_key ON settings(key)');
+              if (err) {
-    await client.query('CREATE INDEX IF NOT EXISTS idx_rss_articles_feed ON rss_articles(feed_id)');
+                logger.error('Erreur lors de l\'ajout de la colonne priority:', err);
-    await client.query('CREATE INDEX IF NOT EXISTS idx_rss_articles_date ON rss_articles(pub_date DESC)');
+              } else {
-    await client.query('CREATE INDEX IF NOT EXISTS idx_calendar_events_user ON calendar_events(user_id)');
+                logger.info('✓ Colonne priority ajoutée avec succès');
-    await client.query('CREATE INDEX IF NOT EXISTS idx_calendar_events_start ON calendar_events(start_time)');
+                // Créer l'index pour la performance
-
+                db.run('CREATE INDEX IF NOT EXISTS idx_notes_priority ON notes(priority DESC, updated_at DESC)', (indexErr) => {
-    logger.info('✓ Tables PostgreSQL créées avec succès');
+                  if (indexErr) {
-
+                    logger.error('Erreur lors de la création de l\'index priority:', indexErr);
-    // Créer l'utilisateur admin par défaut si la table est vide
+                  } else {
-    const usersCount = await client.query('SELECT COUNT(*) as count FROM users');
+                    logger.info('✓ Index priority créé avec succès');
-
+                  }
-    if (usersCount.rows[0].count === '0') {
+                });
-      const defaultPassword = 'admin';
+              }
-      const passwordHash = await bcrypt.hash(defaultPassword, 12);
+            });
-
+          }
-      await client.query(
+        });
-        'INSERT INTO users (username, password_hash, is_admin) VALUES ($1, $2, $3)',
+
-        ['admin', passwordHash, true]
+        // Migration pour calendar_events - ajouter all_day
-      );
+        db.all("PRAGMA table_info(calendar_events)", (err, columns) => {
-
+          if (err) {
-      logger.info('✓ Utilisateur admin créé (username: admin, password: admin)');
+            logger.error('Erreur lors de la vérification de la structure de la table calendar_events:', err);
-      logger.warn('⚠️  IMPORTANT: Changez le mot de passe admin en production!');
+            return;
-    } else {
+          }
-      logger.info('✓ Base de données déjà initialisée');
+
-    }
+          const hasAllDay = columns.some(col => col.name === 'all_day');
-
+
-    await client.query('COMMIT');
+          if (!hasAllDay) {
-  } catch (error) {
+            logger.info('Migration: Ajout de la colonne all_day à calendar_events...');
-    await client.query('ROLLBACK');
+            db.run('ALTER TABLE calendar_events ADD COLUMN all_day BOOLEAN DEFAULT 0', (err) => {
-    logger.error('Erreur lors de l\'initialisation de la base de données:', error);
+              if (err) {
-    throw error;
+                logger.error('Erreur lors de l\'ajout de la colonne all_day:', err);
-  } finally {
+              } else {
-    client.release();
+                logger.info('✓ Colonne all_day ajoutée avec succès');
-  }
+              }
-}
+            });
-
+          }
-/**
+        });
- * Exécuter une requête avec promesse
+
- */
+        // Créer l'utilisateur admin par défaut si la table est vide
-async function runQuery(sql, params = []) {
+        db.get('SELECT COUNT(*) as count FROM users', async (err, row) => {
-  const client = await pool.connect();
+          if (err) {
-  try {
+            logger.error('Erreur lors de la vérification des utilisateurs:', err);
-    const result = await client.query(sql, params);
+            reject(err);
-    return {
+            return;
-      id: result.rows[0]?.id || result.rowCount,
+          }
-      changes: result.rowCount
+
-    };
+          if (row.count === 0) {
-  } catch (error) {
+            // Créer l'utilisateur admin par défaut
-    logger.error('Erreur runQuery:', error);
+            const defaultPassword = 'admin';
-    throw error;
+            const passwordHash = await bcrypt.hash(defaultPassword, 12);
-  } finally {
+
-    client.release();
+            db.run(
-  }
+              'INSERT INTO users (username, password_hash, is_admin) VALUES (?, ?, ?)',
-}
+              ['admin', passwordHash, 1],
-
+              (err) => {
-/**
+                if (err) {
- * Récupérer une seule ligne
+                  logger.error('Erreur lors de la création de l\'utilisateur admin:', err);
- */
+                  reject(err);
-async function getOne(sql, params = []) {
+                } else {
-  const client = await pool.connect();
+                  logger.info('✓ Utilisateur admin créé (username: admin, password: admin)');
-  try {
+                  logger.warn('⚠️  IMPORTANT: Changez le mot de passe admin en production!');
-    const result = await client.query(sql, params);
+                  resolve();
-    return result.rows[0] || null;
+                }
-  } catch (error) {
+              }
-    logger.error('Erreur getOne:', error);
+            );
-    throw error;
+          } else {
-  } finally {
+            logger.info('✓ Base de données déjà initialisée');
-    client.release();
+            resolve();
-  }
+          }
-}
+        });
-
+      } catch (error) {
-/**
+        logger.error('Erreur lors de l\'initialisation de la base de données:', error);
- * Récupérer toutes les lignes
+        reject(error);
- */
+      }
-async function getAll(sql, params = []) {
+    });
-  const client = await pool.connect();
+  });
-  try {
+}
-    const result = await client.query(sql, params);
+
-    return result.rows;
+/**
-  } catch (error) {
+ * Exécuter une requête avec promesse
-    logger.error('Erreur getAll:', error);
+ */
-    throw error;
+function runQuery(sql, params = []) {
-  } finally {
+  return new Promise((resolve, reject) => {
-    client.release();
+    db.run(sql, params, function(err) {
-  }
+      if (err) {
-}
+        reject(err);
-
+      } else {
-module.exports = {
+        resolve({ id: this.lastID, changes: this.changes });
-  pool,
+      }
-  initDatabase,
+    });
-  runQuery,
+  });
-  getOne,
+}
-  getAll
+
-};
+/**
+ * Récupérer une seule ligne
+ */
+function getOne(sql, params = []) {
+  return new Promise((resolve, reject) => {
+    db.get(sql, params, (err, row) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(row);
+      }
+    });
+  });
+}
+
+/**
+ * Récupérer toutes les lignes
+ */
+function getAll(sql, params = []) {
+  return new Promise((resolve, reject) => {
+    db.all(sql, params, (err, rows) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(rows);
+      }
+    });
+  });
+}
+
+module.exports = {
+  db,
+  initDatabase,
+  runQuery,
+  getOne,
+  getAll
+};