import { MacroAPIClient, ChatGPT, StripeAPI, SlackAPI } from 'macro_api';

// Initialize unified client with caching and error handling
const client = new MacroAPIClient({
  cache: {
    type: 'hybrid',
    ttl: 3600, // 1 hour
    redis: { url: process.env.REDIS_URL }
  },
  retries: {
    maxRetries: 3,
    baseDelay: 1000,
    maxDelay: 10000
  }
});

// Initialize API services
const chatgpt = new ChatGPT({ 
  apiKey: process.env.OPENAI_API_KEY! 
});

const stripe = new StripeAPI({ 
  secretKey: process.env.STRIPE_SECRET_KEY! 
});

const slack = new SlackAPI({ 
  botToken: process.env.SLACK_BOT_TOKEN! 
});

// Use with automatic error handling and caching
async function processCustomerQuery(query: string, customerId: string) {
  try {
    // Generate AI response with caching
    const aiResponse = await client.execute(
      () => chatgpt.chat(query, "You are a helpful customer service assistant."),
      {
        service: 'openai',
        method: 'chat',
        params: { query, context: 'customer_service' },
        cacheTtl: 1800 // 30 minutes
      }
    );

    // Get customer data
    const customer = await client.execute(
      () => stripe.getCustomer(customerId),
      {
        service: 'stripe',
        method: 'getCustomer',
        params: { customerId }
      }
    );

    // Send notification to support channel
    await slack.sendMessage('#customer-support', 
      `New query from ${customer.email}: ${aiResponse}`
    );

    return {
      response: aiResponse,
      customer: customer,
      status: 'success'
    };
  } catch (error) {
    console.error('Error processing query:', error);
    throw error;
  }
}