export const dynamic = 'force-dynamic';
import { NextRequest, NextResponse } from "next/server";

const HA_URL = process.env.HA_URL || "http://192.168.31.110:8123";
const HA_TOKEN = process.env.HA_TOKEN || "";

// Real entity IDs → normalized keys used in the dashboard
const REAL_ENTITY_ALIASES: Record<string, string> = {
  "fan.zhimi_rmb1_9528_air_purifier": "fan.air_purifier",
};

// Mock data for entities that don't exist yet (квартира строится)
const MOCK_MISSING: Record<string, any> = {
  "light.living_room": {
    entity_id: "light.living_room",
    state: "off",
    attributes: { brightness: 0, friendly_name: "Свет Гостиная" },
  },
  "light.bedroom": {
    entity_id: "light.bedroom",
    state: "off",
    attributes: { friendly_name: "Свет Спальня" },
  },
  "climate.thermostat": {
    entity_id: "climate.thermostat",
    state: "off",
    attributes: {
      current_temperature: null,
      temperature: 22,
      friendly_name: "Термостат",
    },
  },
  "fan.air_purifier": {
    entity_id: "fan.air_purifier",
    state: "on",
    attributes: {
      preset_mode: "Auto",
      friendly_name: "Очиститель воздуха",
      preset_modes: ["Auto", "Night", "High"],
    },
  },
};

const RELEVANT_KEYS = [
  "light.living_room",
  "light.bedroom",
  "climate.thermostat",
  "fan.air_purifier",
];

export async function GET(req: NextRequest) {
  if (!HA_TOKEN) {
    return NextResponse.json({ demo: true, states: MOCK_MISSING });
  }

  try {
    const res = await fetch(`${HA_URL}/api/states`, {
      headers: {
        Authorization: `Bearer ${HA_TOKEN}`,
        "Content-Type": "application/json",
      },
      next: { revalidate: 0 },
    });

    if (!res.ok) throw new Error(`HA responded ${res.status}`);
    const states: any[] = await res.json();

    // Build filtered map with normalized keys
    const filtered: Record<string, any> = {};
    for (const s of states) {
      // Direct match
      if (RELEVANT_KEYS.includes(s.entity_id)) {
        filtered[s.entity_id] = s;
      }
      // Alias match (real entity → normalized key)
      if (REAL_ENTITY_ALIASES[s.entity_id]) {
        const normalizedKey = REAL_ENTITY_ALIASES[s.entity_id];
        filtered[normalizedKey] = {
          ...s,
          entity_id: normalizedKey,
          _real_entity_id: s.entity_id,
        };
      }
    }

    // Fill in missing entities with mock data (but mark them)
    for (const key of RELEVANT_KEYS) {
      if (!filtered[key]) {
        filtered[key] = { ...MOCK_MISSING[key], _mock: true };
      }
    }

    // demo = true only if ALL entities are mock (no real HA devices connected)
    const hasAnyReal = RELEVANT_KEYS.some(k => !filtered[k]?._mock);

    return NextResponse.json({ demo: !hasAnyReal, states: filtered });
  } catch (e) {
    // Fallback to full mock
    return NextResponse.json({ demo: true, states: MOCK_MISSING });
  }
}

export async function POST(req: NextRequest) {
  const { domain, service, entity_id, ...serviceData } = await req.json();

  if (!HA_TOKEN) {
    return NextResponse.json({ success: true, demo: true });
  }

  // Resolve alias: if normalized key, find real entity
  const realEntityId = Object.keys(REAL_ENTITY_ALIASES).find(
    k => REAL_ENTITY_ALIASES[k] === entity_id
  ) || entity_id;

  try {
    const res = await fetch(`${HA_URL}/api/services/${domain}/${service}`, {
      method: "POST",
      headers: {
        Authorization: `Bearer ${HA_TOKEN}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ entity_id: realEntityId, ...serviceData }),
    });

    if (!res.ok) throw new Error(`HA responded ${res.status}`);
    return NextResponse.json({ success: true });
  } catch (e) {
    return NextResponse.json({ success: false, error: String(e) }, { status: 500 });
  }
}