import fetch from 'node-fetch';
import { TeaQLClient } from '../../../../src';
import { Q } from '../../ts-lib-core/src/generated/Q';
import { Task } from '../../ts-lib-core/src/generated/models/Task';

// 1. Initialize TFP Client, pointing to the Rust backend
const client = new TeaQLClient({
  baseUrl: 'http://127.0.0.1:3001',
  fetch: fetch as any
});

// 2. Prepare request context
const ctx = { client };

async function runNativeExamples() {
  try {
    console.log("=== Native TypeScript Query Examples ===");

    // Example A: Strongly-typed chained calls (Conditional filtering)
    console.log("[Execution]: Q.tasks().withNameContaining('bug').purpose('find bugs')");
    const filterResult = await Q.tasks()
      .withNameContaining("bug")
      .purpose("find bugs")
      .executeForList(ctx);
      
    console.log("Result:", filterResult);

    // Example B: Strongly-typed chained calls (Aggregation and Grouping)
    console.log("\n[Execution]: Q.taskStatuses().groupByDisplayOrder().avgProgress().purpose('calc average')");
    const aggResult = await Q.taskStatuses()
      .groupByDisplayOrder()
      .avgProgress()
      .purpose("calc average")
      .executeForList(ctx);
      
    console.log("Result:", aggResult);

    // Example C: Strongly-typed chained calls (Nested Facet panel aggregation)
    console.log("\n[Execution]: Q.tasks().facetByStatusAs('statusFacet', Q.taskStatuses().count()).purpose('dashboard render')");
    const facetResult = await Q.tasks()
      .facetByStatusAs("statusFacet", Q.taskStatuses().count())
      .purpose("dashboard render")
      .executeForList(ctx);
      
    console.log("Main data (Tasks):", facetResult.data);
    console.log("Statistics panel (Facets):", facetResult.facets);

    // Example D: Data Mutations
    console.log("\n[Execution]: Create Task");
    const task = new Task({ name: 'New Bug Task', status: 1001 });
    const saveResult = await task.auditAs("Create a new bug").save(ctx);
    console.log("Create Result:", JSON.stringify(saveResult, null, 2));

    const newId = saveResult.data[0].saved_data.id;
    const newVersion = saveResult.data[0].saved_data.version;
    console.log(`Retrieved newly created Task ID: ${newId}, Version: ${newVersion}`);

    console.log(`\n[Execution]: Update Task (ID: ${newId})`);
    const updateTask = new Task({ id: newId, name: 'New Bug Task (Fixed)', status: 1004, version: newVersion });
    const updateResult = await updateTask.auditAs("Fix the bug").save(ctx);
    console.log("Update Result:", JSON.stringify(updateResult, null, 2));

    const updatedVersion = updateResult.data[0].saved_data.version;

    console.log(`\n[Execution]: Delete Task (ID: ${newId})`);
    const taskToDelete = new Task({ id: newId, version: updatedVersion });
    const deleteResult = await taskToDelete.markForDeletion().auditAs("Clean up the bug").save(ctx);
    console.log("Delete Result:", JSON.stringify(deleteResult, null, 2));

  } catch (err) {
    console.error("Query execution failed:", err);
  }
}

runNativeExamples();