/**
 * Event Handlers API Journey — Full lifecycle of event handlers and queue management
 *
 * Demonstrates all EventClient APIs:
 *   - Event handler CRUD (add, get, update, list, delete)
 *   - Event handler filtering (by event, active only)
 *   - Tag management (add, get, delete)
 *   - Queue configuration (list queue names)
 *   - Event execution views
 *
 * Run:
 *   CONDUCTOR_SERVER_URL=http://localhost:8080 npx ts-node examples/api-journeys/event-handlers.ts
 */
import { OrkesClients } from "../../src/sdk";
import type { EventHandler } from "../../src/open-api";

async function main() {
  const clients = await OrkesClients.from();
  const eventClient = clients.getEventClient();

  const handlerName = `example_handler_${Date.now()}`;
  const eventName = "conductor:example_event";

  try {
    // ── 1. Event Handler CRUD ─────────────────────────────────────────
    console.log("=== Event Handler CRUD ===\n");

    // Create an event handler that starts a workflow on event
    const handler: EventHandler = {
      name: handlerName,
      event: eventName,
      active: true,
      actions: [
        {
          action: "start_workflow",
          start_workflow: {
            name: "example_event_workflow",
            version: 1,
          },
        },
      ],
    };

    await eventClient.addEventHandler(handler);
    console.log(`1. Created event handler: ${handlerName}`);

    // Get event handler by name
    const fetched = await eventClient.getEventHandlerByName(handlerName);
    console.log(`2. Fetched handler: ${fetched.name}, active: ${fetched.active}`);

    // Update event handler (deactivate)
    await eventClient.updateEventHandler({
      ...fetched,
      active: false,
    });
    console.log("3. Updated handler (deactivated)");

    // Verify update
    const updated = await eventClient.getEventHandlerByName(handlerName);
    console.log(`4. Handler active: ${updated.active}`);

    // Re-activate
    await eventClient.updateEventHandler({
      ...updated,
      active: true,
    });
    console.log("5. Re-activated handler");

    // ── 2. Event Handler Queries ──────────────────────────────────────
    console.log("\n=== Event Handler Queries ===\n");

    // List all event handlers
    const allHandlers = await eventClient.getAllEventHandlers();
    console.log(`6. Total event handlers: ${allHandlers.length}`);

    // Get handlers for a specific event
    const handlersForEvent = await eventClient.getEventHandlersForEvent(
      eventName
    );
    console.log(
      `7. Handlers for '${eventName}': ${handlersForEvent.length}`
    );

    // Get only active handlers for the event
    const activeHandlers = await eventClient.getEventHandlersForEvent(
      eventName,
      true
    );
    console.log(`8. Active handlers for event: ${activeHandlers.length}`);

    // ── 3. Tag Management ─────────────────────────────────────────────
    console.log("\n=== Tag Management ===\n");

    // Add tags
    await eventClient.putTagForEventHandler(handlerName, [
      { key: "environment", value: "production" },
      { key: "team", value: "platform" },
    ]);
    console.log("9. Added tags to handler");

    // Get tags
    const tags = await eventClient.getTagsForEventHandler(handlerName);
    console.log(`10. Tags: ${JSON.stringify(tags)}`);

    // Delete a single tag
    await eventClient.deleteTagForEventHandler(handlerName, {
      key: "team",
      value: "platform",
    });
    console.log("11. Deleted 'team' tag");

    // Verify
    const remainingTags = await eventClient.getTagsForEventHandler(handlerName);
    console.log(`12. Remaining tags: ${JSON.stringify(remainingTags)}`);

    // Delete remaining tags
    await eventClient.deleteTagsForEventHandler(handlerName, remainingTags);
    console.log("13. Deleted remaining tags");

    // ── 4. Queue Configuration ────────────────────────────────────────
    console.log("\n=== Queue Configuration ===\n");

    // List all queue names/configs
    const queueConfigs = await eventClient.getAllQueueConfigs();
    const queueCount = Object.keys(queueConfigs).length;
    console.log(`14. Queue configs available: ${queueCount}`);
    if (queueCount > 0) {
      const firstKey = Object.keys(queueConfigs)[0];
      console.log(`    First queue: ${firstKey}`);
    }

    // ── 5. Event Execution Views ──────────────────────────────────────
    console.log("\n=== Event Execution Views ===\n");

    // Get all active event handlers (execution view)
    try {
      const activeView = await eventClient.getAllActiveEventHandlers();
      console.log(
        `15. Active handlers (execution view): ${activeView?.results?.length ?? 0} results`
      );
    } catch {
      console.log("15. Active handlers view: not available on this server");
    }

    // Get event handlers with statistics
    try {
      const stats = await eventClient.getEventHandlersWithStats();
      console.log(
        `16. Handlers with stats: ${stats?.results?.length ?? 0} results`
      );
    } catch {
      console.log("16. Handler stats: not available on this server");
    }

    // ── 6. Cleanup ──────────────────────────────────────────────────
    console.log("\n=== Cleanup ===\n");

    await eventClient.removeEventHandler(handlerName);
    console.log(`17. Deleted event handler: ${handlerName}`);
  } catch (err) {
    console.error("Error:", err);

    // Best-effort cleanup
    try {
      await eventClient.removeEventHandler(handlerName);
    } catch {
      /* ignore */
    }
  }

  console.log("\nDone.");
  process.exit(0);
}

main().catch((err) => {
  console.error(err);
  process.exit(1);
});