// Actual event payload structure from Kibo's API documentation
{
  "eventId": "15d3d789-322e-41c1-90a6-16f0b480749e",
  "topic": "product.created",
  "entityId": "12345", // The ID of the product that was created
  "tenantId": 1234,
  "masterCatalogId": 1,
  "catalogId": 1,
  "siteId": 5678,
  "correlationId": "ABC-DEF-GHI",
  "isTest": false,
  "data": {
    // The actual data for the entity can be extended here
    // but often you use the entityId to fetch the full object
  }
}

// We'll build this step by step:
// 1. **Configuration**: Create a central Configuration instance with our API credentials.
// 2. **API Client Instantiation**: Create a dedicated client for the Event Push Subscriptions resource.
// 3. **API Call**: Use the 'EventApi' client to call the 'getSubscriptions' method.
// 4. **Process Results**: Log the retrieved subscriptions to the console.

// Essential imports for Event/Webhook operations.
// These imports are verified from @kibocommerce/rest-sdk documentation.
import { Configuration } from "@kibocommerce/rest-sdk";
import { EventApi, SubscriptionApi } from "@kibocommerce/rest-sdk/clients/Event";

// Configuration setup - this single object is reused for all API clients.
// It holds all necessary credentials for authentication and routing.
const configuration = new Configuration({
    tenantId: process.env.KIBO_TENANT_ID,
    siteId: process.env.KIBO_SITE_ID,
    clientId: process.env.KIBO_CLIENT_ID,
    sharedSecret: process.env.KIBO_SHARED_SECRET,
    authHost: process.env.KIBO_AUTH_HOST,
});

// Complete working example that ACTUALLY WORKS with the Kibo API
// This function fetches and displays all event subscriptions.

async function listAllEventSubscriptions() {
    // 1. Instantiate a dedicated client for the Event Push API.
    const subscriptionApi = new SubscriptionApi(configuration);
    
    console.log("Attempting to fetch all event subscriptions...");

    // 2. Call the 'getSubscriptions' method on the client.
    //    Always wrap API calls in a try/catch block.
    try {
        const subscriptionCollection = await subscriptionApi.getSubscriptions();

        if (subscriptionCollection.items && subscriptionCollection.items.length > 0) {
            console.log(`Success: Found ${subscriptionCollection.totalCount} subscriptions:`);
            subscriptionCollection.items.forEach(sub => {
                console.log(`
------------------------------------
  ID:         ${sub.id}
  Endpoint:   ${sub.endpoint}
  Active:     ${sub.isActive}
  Topics:     ${sub.topics?.join(', ')}
------------------------------------
                `);
            });
        } else {
            console.log("No event subscriptions found for this tenant.");
        }

        return subscriptionCollection;

    } catch (error: any) {
        console.error("API Error:", JSON.stringify(error, null, 2));
    }
}

listAllEventSubscriptions();

import { Configuration } from "@kibocommerce/rest-sdk";
import { EventApi } from "@kibocommerce/rest-sdk/clients/Event";

// (Use the same 'configuration' object as defined previously)

async function checkDeadLetterQueue() {
    const subscriptionApi = new SubscriptionApi(configuration);

    try {
        const deadLetterEvents = await subscriptionApi.getDeliveryAttemptSummariesAllSubscriptions();
        
        if (deadLetterEvents.items && deadLetterEvents.items.length > 0) {
            console.warn(`Warning: Found ${deadLetterEvents.totalCount} failed events in the DLQ!`);
            deadLetterEvents.items.forEach(event => {
                console.log(`  - Event ID: ${event.id}, Next Attempt: ${event.nextExecutionDate}`);
            });
        } else {
            console.log("The Dead Letter Queue is empty. All deliveries were successful.");
        }
        return deadLetterEvents;

    } catch (error: any) {
        console.error("API Error:", JSON.stringify(error, null, 2));
        if (error.body?.errorCode === 'ITEM_NOT_FOUND') {
             console.error("Could not find a subscription with that ID.");
        }
    }
}

// Usage
// checkDeadLetterQueue();

import { Configuration } from "@kibocommerce/rest-sdk";
import { EventApi } from "@kibocommerce/rest-sdk/clients/Event";

// (Use the same 'configuration' object as defined previously)

async function pullSentEventsFromQueue() {
    const eventApi = new EventApi(configuration);
    console.log("Attempting to pull events from the queue...");
    
    try {
        // This fetches a batch of events. You would run this on a schedule (e.g., every 5 minutes).
        const eventCollection = await eventApi.getEvents();
        
        if (eventCollection.items && eventCollection.items.length > 0) {
            console.log(`Success: Pulled ${eventCollection.events.length} events.`);
            eventCollection.items.forEach(event => {
                console.log(`  - Processing Event ID: ${event.id}, Topic: ${event.topic}`);
            });
        } else {
            console.log("No new events in the pull queue.");
        }
        return eventCollection;

    } catch (error: any) {
        console.error("API Error:", JSON.stringify(error, null, 2));
    }
}

// Usage
// pullEventsFromQueue();

// ... imports and configuration setup ...
import { EventApi } from "@kibocommerce/rest-sdk/clients/Event";

async function getEventsByTopic(eventTopic: string) {
    const eventApi = new EventApi(configuration);
    console.log(`Fetching details for event topic: ${eventTopic}`);

    try {
        const subscription = await eventApi.getEvents({ filter: `topic eq ${eventTopic}` });
        console.log("Success: Found subscription:", JSON.stringify(subscription, null, 2));
        return subscription;
    } catch (error: any) {
        console.error("API Error:", JSON.stringify(error, null, 2));
    }
}

// Usage
// getEventsByTopic("order.opened");

// Actual error structure from Kibo API documentation
interface KiboApiError {
  body: {
    message: string;             // Human-readable description of the error
    errorCode: string;           // A specific code for programmatic handling
    correlationId: string;       // Unique ID for this request, useful for support tickets
  }
}