import { KickWebSocket } from 'kick-wss';

// Create instance
const kickWS = new KickWebSocket({ debug: true });

// Connect to a channel
kickWS.connect('channel-name');

// Listen to chat messages
kickWS.on('ChatMessage', (message) => {
  console.log(`${message.sender.username}: ${message.content}`);
});

// Listen to connection events
kickWS.on('ready', () => {
  console.log('✅ Successfully connected');
});

kickWS.on('disconnect', ({ reason }) => {
  console.log('❌ Disconnected:', reason);
});

kickWS.on('error', (error) => {
  console.error('⚠️ Error:', error);
});

// Chat messages only
kickWS.onChatMessage((message) => {
  console.log('Message:', message.content);
});

// User bans only
kickWS.onUserBanned((ban) => {
  console.log('Banned user:', ban.username);
});

// Subscriptions only
kickWS.onSubscription((sub) => {
  console.log('New subscription:', sub.username);
});

// All chat events
kickWS.onChatEvents((event) => {
  console.log('Chat event:', event);
});

// All user events
kickWS.onUserEvents((event) => {
  console.log('User event:', event);
});

// All events in general
kickWS.onAllEvents((event) => {
  console.log('Event:', event);
});

const options = {
  debug: false,              // Show debug logs
  autoReconnect: true,       // Reconnect automatically
  reconnectInterval: 5000,   // Reconnection interval (ms)
  enableBuffer: false,       // Enable message buffer
  bufferSize: 1000,          // Maximum buffer size
  filteredEvents: []         // Events to listen to (empty = all)
};

const kickWS = new KickWebSocket(options);

// Listen only to messages and bans
kickWS = new KickWebSocket({
  filteredEvents: ['ChatMessage', 'UserBanned', 'Subscription']
});

// Or use the KICK_EVENTS constant for all available events
import { KICK_EVENTS } from 'kick-wss';

// Listen to all events
kickWS = new KickWebSocket({
  filteredEvents: KICK_EVENTS
});

// Listen to specific categories
kickWS = new KickWebSocket({
  filteredEvents: KICK_EVENTS.filter(event => 
    event.includes('Chat') || event.includes('User')
  )
});

kickWS = new KickWebSocket({
  enableBuffer: true,
  bufferSize: 2000
});

// Get messages from buffer
const messages = kickWS.getMessageBuffer();
console.log(`Buffer has ${messages.length} messages`);

// Clear buffer
kickWS.clearMessageBuffer();

const kickWS = KickWebSocket.createDebug('channel-name');

interface ChatMessageEvent {
  id: string;
  content: string;
  type: 'message';
  created_at: string;
  sender: {
    id: number;
    username: string;
    slug: string;
    identity: {
      color: string;
      badges: string[];
    };
  };
  chatroom: {
    id: number;
  };
}

import { KickWebSocket } from 'kick-wss';

const kickWS = new KickWebSocket({ debug: true });

// Connect to multiple channels
const channels = ['streamer1', 'streamer2', 'streamer3'];

channels.forEach(channel => {
  const ws = new KickWebSocket();

  ws.connect(channel);

  ws.onChatMessage((message) => {
    // Save to database
    saveToDatabase({
      channel,
      user: message.sender.username,
      message: message.content,
      timestamp: message.created_at
    });
  });

  ws.onUserBanned((ban) => {
    console.log(`🚫 ${ban.username} banned in ${channel}`);
  });
});

const kickWS = new KickWebSocket({
  debug: true,
  enableBuffer: true,
  bufferSize: 2000,
  filteredEvents: [
    'ChatMessage',
    'UserBanned', 
    'Subscription',
    'GiftedSubscriptions'
  ]
});

kickWS.connect('popular-streamer');

let messageCount = 0;
let subscriberCount = 0;
let banCount = 0;

kickWS.onChatMessage(() => messageCount++);
kickWS.onSubscription(() => subscriberCount++);
kickWS.onUserBanned(() => banCount++);

// Report every minute
setInterval(() => {
  console.log(`📊 Statistics for the last minute:
    Messages: ${messageCount}
    Subscriptions: ${subscriberCount}
    Bans: ${banCount}
  `);

  // Reset counters
  messageCount = 0;
  subscriberCount = 0;
  banCount = 0;
}, 60000);

const kickWS = new KickWebSocket();

kickWS.connect('monitored-channel');

kickWS.onChatMessage((message) => {
  // Detect keywords
  if (message.content.includes('!help') || message.content.includes('!admin')) {
    sendNotification(`🚨 Help requested by ${message.sender.username}`);
  }
});

kickWS.onUserBanned((ban) => {
  sendNotification(`🔨 Banned user: ${ban.username}`);
});

kickWS.onSubscription((sub) => {
  sendNotification(`⭐ New subscription: ${sub.username}`);
});

function sendNotification(message: string) {
  // Implement your notification system
  console.log('NOTIFICATION:', message);
}