From a48629288028e3d4204feaa0ade69ce96bc270d2 Mon Sep 17 00:00:00 2001
From: "Torsten Schulz (local)" <tsschulz@gmx.net>
Date: Thu, 18 Dec 2025 14:11:15 +0100
Subject: [PATCH] Activate pgcrypto extension for digest() function in database
 initialization and migration scripts

---
 backend/fix-pgcrypto-extension.js             | 34 +++++++
 .../migrations/add_trigger_for_hashedId.cjs   |  5 ++
 .../add_character_name_to_notification.sql    | 88 +++++++++++++++++++
 backend/utils/sequelize.js                    | 10 +++
 4 files changed, 137 insertions(+)
 create mode 100644 backend/fix-pgcrypto-extension.js
 create mode 100644 backend/sql/add_character_name_to_notification.sql

diff --git a/backend/fix-pgcrypto-extension.js b/backend/fix-pgcrypto-extension.js
new file mode 100644
index 0000000..bb64c06
--- /dev/null
+++ b/backend/fix-pgcrypto-extension.js
@@ -0,0 +1,34 @@
+import { sequelize } from './utils/sequelize.js';
+
+async function fixPgCryptoExtension() {
+    try {
+        console.log('🔧 Aktiviere pgcrypto Erweiterung...');
+        
+        await sequelize.query('CREATE EXTENSION IF NOT EXISTS pgcrypto;');
+        
+        console.log('✅ pgcrypto Erweiterung erfolgreich aktiviert');
+        
+        // Prüfe ob die Erweiterung aktiviert ist
+        const result = await sequelize.query(`
+            SELECT EXISTS(
+                SELECT 1 FROM pg_extension WHERE extname = 'pgcrypto'
+            ) as extension_exists;
+        `, { type: sequelize.QueryTypes.SELECT });
+        
+        if (result[0]?.extension_exists) {
+            console.log('✅ Bestätigung: pgcrypto Erweiterung ist aktiviert');
+        } else {
+            console.warn('⚠️  Warnung: pgcrypto Erweiterung konnte nicht aktiviert werden');
+        }
+        
+        process.exit(0);
+    } catch (error) {
+        console.error('❌ Fehler beim Aktivieren der pgcrypto Erweiterung:', error.message);
+        console.error('Stack:', error.stack);
+        process.exit(1);
+    }
+}
+
+fixPgCryptoExtension();
+
+
diff --git a/backend/migrations/add_trigger_for_hashedId.cjs b/backend/migrations/add_trigger_for_hashedId.cjs
index 030754f..011a603 100644
--- a/backend/migrations/add_trigger_for_hashedId.cjs
+++ b/backend/migrations/add_trigger_for_hashedId.cjs
@@ -2,6 +2,11 @@
 
 module.exports = {
     up: async (queryInterface, Sequelize) => {
+        // Aktiviere die pgcrypto Erweiterung, die die digest() Funktion bereitstellt
+        await queryInterface.sequelize.query(`
+            CREATE EXTENSION IF NOT EXISTS pgcrypto;
+        `);
+
         await queryInterface.sequelize.query(`
             CREATE OR REPLACE FUNCTION community.update_hashed_id() RETURNS TRIGGER AS $$
             BEGIN
diff --git a/backend/sql/add_character_name_to_notification.sql b/backend/sql/add_character_name_to_notification.sql
new file mode 100644
index 0000000..d64dea2
--- /dev/null
+++ b/backend/sql/add_character_name_to_notification.sql
@@ -0,0 +1,88 @@
+-- Migration script: add_character_name_to_notification.sql
+-- Fügt character_name und character_id zur falukant_log.notification Tabelle hinzu,
+-- legt Index an, erzeugt die Helper-Funktion und den Trigger.
+-- Idempotent und mit Down-Schritten zum Entfernen.
+
+BEGIN;
+
+-- 1) Spalten anlegen
+ALTER TABLE IF EXISTS falukant_log.notification
+  ADD COLUMN IF NOT EXISTS character_name text;
+
+ALTER TABLE IF EXISTS falukant_log.notification
+  ADD COLUMN IF NOT EXISTS character_id integer;
+
+-- 2) Index (idempotent)
+CREATE INDEX IF NOT EXISTS idx_notification_character_id
+  ON falukant_log.notification (character_id);
+
+-- 3) Trigger-Funktion anlegen (idempotent)
+CREATE OR REPLACE FUNCTION falukant_log.populate_notification_character_name()
+RETURNS TRIGGER AS $function$
+DECLARE
+  v_first_name TEXT;
+  v_last_name  TEXT;
+  v_char_id    INTEGER;
+  v_column_exists BOOLEAN;
+BEGIN
+  -- prüfen, ob Zielspalte existiert
+  SELECT EXISTS(
+    SELECT 1 FROM information_schema.columns
+    WHERE table_schema = 'falukant_log' AND table_name = 'notification' AND column_name = 'character_name'
+  ) INTO v_column_exists;
+
+  IF NOT v_column_exists THEN
+    RETURN NEW;
+  END IF;
+
+  IF NEW.character_name IS NOT NULL THEN
+    RETURN NEW;
+  END IF;
+
+  v_char_id := NEW.character_id;
+
+  IF v_char_id IS NULL AND NEW.user_id IS NOT NULL THEN
+    SELECT id INTO v_char_id
+    FROM falukant_data.character
+    WHERE user_id = NEW.user_id
+    ORDER BY id DESC
+    LIMIT 1;
+  END IF;
+
+  IF v_char_id IS NOT NULL THEN
+    SELECT pf.name, pl.name
+    INTO v_first_name, v_last_name
+    FROM falukant_data.character c
+    LEFT JOIN falukant_predefine.firstname pf ON pf.id = c.first_name
+    LEFT JOIN falukant_predefine.lastname pl ON pl.id = c.last_name
+    WHERE c.id = v_char_id;
+
+    IF v_first_name IS NOT NULL OR v_last_name IS NOT NULL THEN
+      NEW.character_name := COALESCE(v_first_name, '') || CASE WHEN v_first_name IS NOT NULL AND v_last_name IS NOT NULL THEN ' ' ELSE '' END || COALESCE(v_last_name, '');
+    ELSE
+      NEW.character_name := ('#' || v_char_id::text);
+    END IF;
+  ELSE
+    IF NEW.user_id IS NOT NULL THEN
+      NEW.character_name := ('#u' || NEW.user_id::text);
+    END IF;
+  END IF;
+
+  RETURN NEW;
+END;
+$function$ LANGUAGE plpgsql;
+
+-- 4) Trigger anlegen (BEFORE INSERT)
+DROP TRIGGER IF EXISTS trg_populate_notification_character_name ON falukant_log.notification;
+CREATE TRIGGER trg_populate_notification_character_name
+BEFORE INSERT ON falukant_log.notification
+FOR EACH ROW
+EXECUTE FUNCTION falukant_log.populate_notification_character_name();
+
+COMMIT;
+
+-- Down / Rollback (falls benötigt):
+-- Die folgenden Statements entfernen Trigger, Funktion, Index und Spalten.
+
+-- Hinweis: Ausführbar separat; zur Anwendung einfach die folgenden Zeilen verwenden:
+-- BEGIN; DROP TRIGGER IF EXISTS trg_populate_notification_character_name ON falukant_log.notification; DROP FUNCTION IF EXISTS falukant_log.populate_notification_character_name(); DROP INDEX IF EXISTS falukant_log.idx_notification_character_id; ALTER TABLE IF EXISTS falukant_log.notification DROP COLUMN IF EXISTS character_name; ALTER TABLE IF EXISTS falukant_log.notification DROP COLUMN IF EXISTS character_id; COMMIT;
diff --git a/backend/utils/sequelize.js b/backend/utils/sequelize.js
index afd4338..77697b5 100644
--- a/backend/utils/sequelize.js
+++ b/backend/utils/sequelize.js
@@ -45,6 +45,16 @@ const createSchemas = async () => {
 
 const initializeDatabase = async () => {
     await createSchemas();
+    
+    // Aktiviere die pgcrypto Erweiterung für die digest() Funktion
+    try {
+        await sequelize.query('CREATE EXTENSION IF NOT EXISTS pgcrypto;');
+        console.log('✅ pgcrypto Erweiterung aktiviert');
+    } catch (error) {
+        console.warn('⚠️  Konnte pgcrypto Erweiterung nicht aktivieren:', error.message);
+        // Fortfahren, da die Erweiterung möglicherweise bereits aktiviert ist
+    }
+    
     // Modelle nur laden, aber an dieser Stelle NICHT syncen.
     // Das Syncing (inkl. alter: true bei Bedarf) wird anschließend zentral
     // über syncModelsWithUpdates()/syncModelsAlways gesteuert.