import { Rcon } from '@callowayisweird/source-rcon'

const rcon = new Rcon({
  host: '127.0.0.1',
  port: 27015,
  password: 'your_rcon_password',
})

await rcon.connect()

const status = await rcon.execute('status')
console.log(status)

await rcon.disconnect()

const rcon = new Rcon({
  host: '127.0.0.1',
  port: 27015,
  password: 'secret',
})

rcon.on('connect', () => console.log('Connected'))
rcon.on('disconnect', () => console.log('Disconnected'))
rcon.on('error', (err) => console.error('Error:', err))

await rcon.connect()

const rcon = new Rcon({
  host: '127.0.0.1',
  port: 27015,
  password: 'secret',
  autoReconnect: true,
  maxReconnectAttempts: 5,
  reconnectDelay: 3000,
})

rcon.on('reconnecting', (attempt) => {
  console.log(`Reconnecting... attempt ${attempt}`)
})

await rcon.connect()

import { RconPool } from '@callowayisweird/source-rcon'

const pool = new RconPool([
  { host: '10.0.0.1', port: 27015, password: 'pass1' },
  { host: '10.0.0.2', port: 27015, password: 'pass2' },
  { host: '10.0.0.3', port: 27015, password: 'pass3' },
])

await pool.connectAll()

// Execute on a specific server
const status = await pool.execute('10.0.0.1:27015', 'status')

// Execute on all servers
const results = await pool.executeAll('status')
for (const [server, response] of results) {
  console.log(`${server}: ${response}`)
}

await pool.disconnectAll()

import { Rcon, GatedRcon } from '@callowayisweird/source-rcon'

const rcon = new Rcon({
  host: '127.0.0.1',
  port: 27015,
  password: 'secret',
})

await rcon.connect()

const gated = new GatedRcon(rcon, {
  allowedUsers: ['STEAM_0:1:12345678', 'STEAM_0:1:87654321'],
  permissions: {
    'STEAM_0:1:12345678': ['say *', 'status', 'changelevel *'], // admin
    'STEAM_0:1:87654321': ['say *', 'status'],                   // moderator
  },
  rateLimit: {
    windowMs: 60000,  // 1 minute
    maxCommands: 10,   // max 10 commands per minute
  },
  onExecute: (steamId, command, response) => {
    console.log(`[RCON] ${steamId} executed: ${command}`)
  },
  onBlocked: (steamId, command, reason) => {
    console.warn(`[RCON] Blocked ${steamId}: ${command} (${reason})`)
  },
})

// Will succeed for allowed users with matching permissions
await gated.execute('STEAM_0:1:12345678', 'say Hello everyone!')

// Will throw PermissionDeniedError
await gated.execute('STEAM_0:1:87654321', 'changelevel gm_flatgrass')

import {
  Rcon,
  AuthFailedError,
  ConnectionRefusedError,
  TimeoutError,
  DisconnectedError,
} from '@callowayisweird/source-rcon'

const rcon = new Rcon({
  host: '127.0.0.1',
  port: 27015,
  password: 'secret',
  timeout: 5000,
})

try {
  await rcon.connect()
} catch (err) {
  if (err instanceof AuthFailedError) {
    console.error('Wrong RCON password')
  } else if (err instanceof ConnectionRefusedError) {
    console.error('Server refused connection')
  } else if (err instanceof TimeoutError) {
    console.error('Connection timed out')
  }
}

try {
  await rcon.execute('status')
} catch (err) {
  if (err instanceof DisconnectedError) {
    console.error('Not connected to server')
  } else if (err instanceof TimeoutError) {
    console.error('Command timed out')
  }
}