script.sh

#!/bin/bash

# Dieses Skript dient als robuster Entrypoint für den proffix-api Connector.
# Es wartet nur auf die Verfügbarkeit von Kafka.

# --- Variablen für Kafka ---
KAFKA_HOST=${KAFKA_HOST:-kafka:29092}
KAFKA_BROKER_HOST=$(echo "$KAFKA_HOST" | cut -d ':' -f 1)
KAFKA_BROKER_PORT=$(echo "$KAFKA_HOST" | cut -d ':' -f 2)


# --- AUF KAFKA WARTEN ---
echo "Warte darauf, dass Kafka unter $KAFKA_HOST bereit ist..."

# Korrigierte nc-Syntax für maximale Kompatibilität
while ! nc -w 1 -q 1 $KAFKA_BROKER_HOST $KAFKA_BROKER_PORT < /dev/null; do
  echo "Kafka ist noch nicht erreichbar. Warte 1 Sekunde..."
  sleep 1
done

echo "Kafka ist bereit."

# --- DIENSTE STARTEN ---
echo "Starte die Hintergrund- und Hauptdienste (keine DB-Verbindung nötig)..."

# Startet die Hintergrundaufgabe (z.B. Kafka-Processing)
python entrypoint.py > /dev/null 2>&1 &

# Starte den Hauptdienst im Vordergrund
exec flask run --host=0.0.0.0 --port=9500