import { createClient, ConnectionState, ErrorType, type KickError } from "@retconned/kick-js";
import "dotenv/config";

// Create client with enhanced configuration
const client = createClient("xqc", { 
  logger: true, 
  readOnly: false,
  // Enhanced error handling
  onError: (error: KickError) => {
    console.error(`❌ ${error.type}: ${error.message}`);
  },
  // Connection state monitoring
  onConnectionStateChange: (state: ConnectionState) => {
    console.log(`🔄 Connection: ${state}`);
  }
});

// Authentication with login credentials
client.login({
  type: "login",
  credentials: {
    username: "your-username",
    password: "your-password",
    otp_secret: "your-2fa-secret", // Get from https://kick.com/settings/security
  },
});

// Or authenticate with tokens from browser
client.login({
  type: "tokens",
  credentials: {
    bearerToken: process.env.BEARER_TOKEN!,
    xsrfToken: process.env.XSRF_TOKEN!,
    cookies: process.env.COOKIES!,
  },
});

client.on("ready", () => {
  console.log(`Bot ready & logged into ${client.user?.tag}!`);
  console.log(`Connection state: ${client.getConnectionState()}`);
});

client.on("ChatMessage", async (message) => {
  console.log(`${message.sender.username}: ${message.content}`);
  
  // Bot commands
  if (message.content === "!ping") {
    await client.sendMessage("Pong! 🏓");
  }
  
  if (message.content === "!disconnect") {
    client.disconnect(); // Proper cleanup
  }
});

// Graceful shutdown
process.on('SIGINT', () => {
  console.log('Shutting down...');
  client.disconnect();
  process.exit(0);
});

const client = createClient("channel-name", {
  websocket: {
    // Custom Pusher WebSocket URL
    pusherUrl: "wss://custom-websocket-url.com/app/12345",
    
    // Custom WebSocket headers
    headers: {
      "User-Agent": "MyBot/1.0",
      "Custom-Header": "custom-value"
    },
    
    // WebSocket options
    wsOptions: {
      handshakeTimeout: 10000,
      // Remove default WebSocket headers if needed
    }
  }
});

client.on("error", (error: KickError) => {
  switch (error.type) {
    case ErrorType.CONNECTION:
      console.log("Connection lost - implement reconnection logic");
      break;
    case ErrorType.AUTHENTICATION:
      console.log("Auth failed - check credentials");
      break;
    case ErrorType.WEBSOCKET:
      console.log("WebSocket error occurred");
      break;
    case ErrorType.API_REQUEST:
      console.log("API request failed");
      break;
    case ErrorType.VALIDATION:
      console.log("Input validation error");
      break;
  }
});