#!/bin/bash
set -euo pipefail

# Get CRM contact information via n8n workflow

if [[ -f .env ]]; then
  source .env
fi

N8N_BASE_URL="${N8N_BASE_URL:-http://localhost:5678}"
N8N_API_KEY="${N8N_API_KEY:-}"

CONTACT_ID=""
EMAIL=""
INCLUDE_HISTORY="false"

while [[ $# -gt 0 ]]; do
  case $1 in
    --contact-id)
      CONTACT_ID="$2"
      shift 2
      ;;
    --email)
      EMAIL="$2"
      shift 2
      ;;
    --include-history)
      INCLUDE_HISTORY="$2"
      shift 2
      ;;
    *)
      echo "Unknown parameter: $1" >&2
      exit 1
      ;;
  esac
done

if [[ -z "$CONTACT_ID" ]] && [[ -z "$EMAIL" ]]; then
  echo "Error: Either --contact-id or --email is required" >&2
  exit 1
fi

# Validate include-history boolean
if [[ ! "$INCLUDE_HISTORY" =~ ^(true|false)$ ]]; then
  echo "Error: --include-history must be true or false" >&2
  exit 1
fi

PAYLOAD=$(jq -n \
  --arg contactId "$CONTACT_ID" \
  --arg email "$EMAIL" \
  --argjson includeHistory "$(if [[ $INCLUDE_HISTORY == "true" ]]; then echo true; else echo false; fi)" \
  '{
    contactId: $contactId,
    email: $email,
    includeHistory: $includeHistory
  }')

RESPONSE=$(curl -s -w "\n%{http_code}" \
  -X POST \
  -H "Content-Type: application/json" \
  -H "X-N8N-API-KEY: $N8N_API_KEY" \
  -d "$PAYLOAD" \
  "${N8N_BASE_URL}/webhook/marketing/crm/get-contact" || echo -e "\n000")

HTTP_CODE=$(echo "$RESPONSE" | tail -n1)
BODY=$(echo "$RESPONSE" | sed '$d')

if [[ "$HTTP_CODE" == "000" ]]; then
  echo '{"success":false,"message":"Network error: Unable to connect to n8n"}' >&2
  exit 2
elif [[ "$HTTP_CODE" == "401" ]] || [[ "$HTTP_CODE" == "403" ]]; then
  echo '{"success":false,"message":"Authentication error: Invalid API key"}' >&2
  exit 3
elif [[ ! "$HTTP_CODE" =~ ^2 ]]; then
  echo "{\"success\":false,\"message\":\"API error: HTTP $HTTP_CODE\",\"response\":$BODY}" >&2
  exit 2
fi

if echo "$BODY" | jq -e '.success' >/dev/null 2>&1; then
  echo "$BODY"
  exit 0
else
  echo '{"success":false,"message":"Invalid response format from n8n"}' >&2
  exit 2
fi