From 4c03cfdd5e415c1a19cd66a119103a8e79616396 Mon Sep 17 00:00:00 2001
From: Johannes Baumeister <jba@enwelo.de>
Date: Tue, 28 Apr 2026 12:47:10 +0200
Subject: [PATCH] debug: add logging and fix db port/creds in deploy

---
 .gitea/workflows/deploy.yml |  4 ++--
 server.js                   | 12 ++++++++++--
 2 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/.gitea/workflows/deploy.yml b/.gitea/workflows/deploy.yml
index 103fcb2..83b866e 100644
--- a/.gitea/workflows/deploy.yml
+++ b/.gitea/workflows/deploy.yml
@@ -15,9 +15,9 @@ jobs:
       - name: .env erstellen
         run: |
           echo "DB_HOST=${{ secrets.DB_HOST }}" > .env
-          echo "DB_PORT=5433" >> .env
+          echo "DB_PORT=5432" >> .env
           echo "DB_USER=${{ secrets.DB_USER }}" >> .env
-          echo "DB_PASSWORD='${{ secrets.DB_PASSWORD }}'" >> .env
+          echo "DB_PASSWORD=${{ secrets.DB_PASSWORD }}" >> .env
           echo "DB_NAME=${{ secrets.DB_NAME }}" >> .env
           echo "DB_SCHEMA=geodaten" >> .env
 
diff --git a/server.js b/server.js
index f7a026d..d597acc 100644
--- a/server.js
+++ b/server.js
@@ -30,15 +30,22 @@ pool.connect()
 // API to save turbines
 app.post('/api/wea', async (req, res) => {
     const { projekt_id, turbines } = req.body;
+    console.log(`Empfange Speicheranfrage für Projekt: ${projekt_id}, Anzahl WEAs: ${turbines?.length}`);
+    
+    if (!turbines || !Array.isArray(turbines)) {
+        return res.status(400).json({ error: 'Keine validen Turbinen-Daten empfangen' });
+    }
+
     const client = await pool.connect();
     
     try {
         await client.query('BEGIN');
         
-        // Delete existing turbines for this project before saving new state
+        console.log(`Lösche alte Einträge für Projekt ${projekt_id}...`);
         await client.query('DELETE FROM geodaten.wea_standorte WHERE projekt_id = $1', [projekt_id]);
         
         for(let t of turbines) {
+            console.log(`Speichere WEA ${t.nr} (${t.type}) an Position ${t.latlng.lat}, ${t.latlng.lng}`);
             await client.query(
               `INSERT INTO geodaten.wea_standorte (
                 wea_nummer, hersteller, anlagentyp, nabenhoehe, rotordurchmesser, ksf_drehung, projekt_id, geom
@@ -58,10 +65,11 @@ app.post('/api/wea', async (req, res) => {
         }
         
         await client.query('COMMIT');
+        console.log('Speichervorgang erfolgreich abgeschlossen.');
         res.status(200).json({ message: 'Windenergieanlagen erfolgreich in Datenbank gespeichert' });
     } catch (e) {
         await client.query('ROLLBACK');
-        console.error('Error saving turbines', e);
+        console.error('Fehler beim Speichern in die Datenbank:', e);
         res.status(500).json({ error: e.message });
     } finally {
         client.release();