bwscheddebrock_trassenplaner/server.js

require('dotenv').config();
const express = require('express');
const { Pool } = require('pg');
const cors = require('cors');

const app = express();
const port = process.env.PORT || 80;

// Database Connection
const pool = new Pool({
  host: process.env.DB_HOST,
  port: process.env.DB_PORT,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  database: process.env.DB_NAME,
  idleTimeoutMillis: 30000,
  connectionTimeoutMillis: 2000,
});

pool.on('error', (err) => {
  console.error('Unexpected error on idle client', err);
});

// Middleware
app.use(cors());
app.use(express.json({ limit: '50mb' }));
app.use(express.static(__dirname));

// Helper to run the schema isolation command
async function setSchema(client) {
  const schema = process.env.DB_SCHEMA || 'wind_projekt_bwscheddebrock';
  await client.query(`set search_path to ${schema}, public;`);
}

// Database Initial Setup / Migration Logic Removed
// (Now treating existing tables as the read-only 'Source of Truth')

// --- API Routes ---
app.get('/api/health', (req, res) => {
  res.json({ status: 'OK', schema: process.env.DB_SCHEMA, time: new Date().toISOString() });
});

// 1. Get Owner Data
app.get('/api/owners', async (req, res) => {
  const client = await pool.connect();
  try {
    await setSchema(client);
    
    // Pure lowercase SQL without quotes on identifiers, using aliases for frontend
    const query = `
      select 
        id, 
        nachname as "Nachname", 
        vorname as "Vorname", 
        ort as "Ort", 
        flur as "Flur", 
        flurstueck as "Flurstueck", 
        gemarkung as "Gemarkung", 
        status, 
        notiz,
        str_hnr as "Str_HNr",
        st_asgeojson(st_transform(geom, 4326)) as geometry
      from eigentuemerdaten
    `;
    const result = await client.query(query);
    
    const geojson = {
      type: "FeatureCollection",
      features: result.rows.map(row => {
        const { geometry, ...properties } = row;
        return {
          type: "Feature",
          id: row.id,
          geometry: JSON.parse(geometry),
          properties: properties
        };
      })
    };
    res.json(geojson);
  } catch (err) {
    console.error("Owner Fetch Error:", err);
    res.status(500).json({ error: 'Failed to fetch owner data' });
  } finally {
    client.release();
  }
});

// 2. Get Usage Data (Nutzung)
app.get('/api/usage', async (req, res) => {
  const client = await pool.connect();
  try {
    await setSchema(client);
    const query = `
      select 
        id,
        nutzart,
        st_asgeojson(st_transform(geom, 4326)) as geometry
      from nutzung
    `;
    const result = await client.query(query);
    
    const geojson = {
      type: "FeatureCollection",
      features: result.rows.map(row => {
        const { geometry, ...properties } = row;
        return {
          type: "Feature",
          geometry: JSON.parse(geometry),
          properties: properties
        };
      })
    };
    res.json(geojson);
  } catch (err) {
    console.error("Usage Fetch Error:", err);
    res.status(500).json({ error: 'Failed to fetch usage data' });
  } finally {
    client.release();
  }
});

// 2.5 Get WEA Data
app.get('/api/wea', async (req, res) => {
  const client = await pool.connect();
  try {
    await setSchema(client);
    const query = `
      select 
        id, 
        name as "Name",
        st_asgeojson(st_transform(geom, 4326)) as geometry
      from wea
    `;
    const result = await client.query(query);
    
    const geojson = {
      type: "FeatureCollection",
      features: result.rows.map(row => {
        const { geometry, ...properties } = row;
        return {
          type: "Feature",
          geometry: JSON.parse(geometry),
          properties: properties
        };
      })
    };
    res.json(geojson);
  } catch (err) {
    res.json({ type: "FeatureCollection", features: [] });
  } finally {
    client.release();
  }
});

// 2.7 Get Infrastructure Data
app.get('/api/infrastructure', async (req, res) => {
  const client = await pool.connect();
  try {
    await setSchema(client);
    const query = `
      select 
        id, 
        st_asgeojson(st_transform(geom, 4326)) as geometry
      from infrastruktur
    `;
    const result = await client.query(query);
    
    const geojson = {
      type: "FeatureCollection",
      features: result.rows.map(row => {
        const { geometry, ...properties } = row;
        return {
          type: "Feature",
          geometry: JSON.parse(geometry),
          properties: properties
        };
      })
    };
    res.json(geojson);
  } catch (err) {
    res.json({ type: "FeatureCollection", features: [] });
  } finally {
    client.release();
  }
});

// 3. Get Variants (Kabeltrasse)
app.get('/api/variants', async (req, res) => {
  const client = await pool.connect();
  try {
    await setSchema(client);
    const query = `
      select 
        id, name, variante as "Variante",
        st_asgeojson(st_transform(st_setsrid(geom, 25832), 4326)) as geometry
      from kabeltrasse
      order by id desc
    `;
    const result = await client.query(query);
    
    const featureCollection = {
      type: "FeatureCollection",
      features: result.rows.map(row => {
        return {
          type: "Feature",
          id: row.id,
          geometry: JSON.parse(row.geometry || 'null'),
          properties: {
            id: row.id,
            name: row.name || (row.Variante ? `Variante ${row.Variante}` : 'Neue Trasse'),
            Variante: row.Variante
          }
        };
      })
    };
    res.json(featureCollection);
  } catch (err) {
    console.error("Variants Fetch Error:", err);
    res.status(500).json({ error: 'Failed to fetch variants' });
  } finally {
    client.release();
  }
});

// 4. Save/Update Variant
app.post('/api/variants', async (req, res) => {
  const { geometry, properties } = req.body;
  const client = await pool.connect();
  try {
    await setSchema(client);
    
    const routeName = properties.name || 'Neue Trasse';
    const varianteValue = properties.Variante || (properties.name ? properties.name.replace('Variante ', '') : 'A');
    const geoJsonStr = JSON.stringify(geometry);

    // Save with pure lowercase identifiers
    const upsertQuery = `
      insert into kabeltrasse (geom, name, variante)
      values (
        st_makevalid(st_transform(st_setsrid(st_geomfromgeojson($1), 4326), 25832)), 
        $2, 
        $3
      )
      on conflict (variante) 
      do update set 
        geom = excluded.geom,
        name = excluded.name
      returning id
    `;
    
    const upsertRes = await client.query(upsertQuery, [geoJsonStr, routeName, varianteValue]);
    res.json({ success: true, id: upsertRes.rows[0].id });
  } catch (err) {
    console.error("SQL-FEHLER (SAVE):", err.message);
    res.status(500).json({ error: 'Failed to save variant' });
  } finally {
    client.release();
  }
});

// 5. Update Owner Note/Status
app.patch('/api/owners/:id', async (req, res) => {
  const { id } = req.params;
  const { status, notiz } = req.body;
  const client = await pool.connect();
  try {
    await setSchema(client);
    const query = `
      update eigentuemerdaten
      set status = $1, notiz = $2
      where id = $3
      returning id;
    `;
    const result = await client.query(query, [status, notiz, id]);
    if (result.rowCount === 0) return res.status(404).json({ error: 'Owner not found' });
    res.json({ success: true, id: result.rows[0].id });
  } catch (err) {
    console.error("Update Owner Error:", err);
    res.status(500).json({ error: 'Failed to update owner' });
  } finally {
    client.release();
  }
});

app.listen(port, () => {
  console.log(`Server running at http://localhost:${port}`);
});