import { DucklingClient } from '@chittihq/duckling';

// Initialize client - auto-connect and auto-ping enabled by default
const client = new DucklingClient({
  url: 'ws://localhost:3001/ws',
  apiKey: process.env.DUCKLING_API_KEY,
  databaseName: 'default'  // Optional - defaults to 'default'
});

// Just query - client auto-connects on first query!
const users = await client.query('SELECT * FROM User LIMIT 10');

// Auto-ping keeps connection alive
// Close when done
client.close();

// Connect to different databases
const lmsClient = new DucklingClient({
  url: 'ws://localhost:3001/ws',
  apiKey: process.env.DUCKLING_API_KEY,
  databaseName: 'lms'
});

const chittiClient = new DucklingClient({
  url: 'ws://localhost:3001/ws',
  apiKey: process.env.DUCKLING_API_KEY,
  databaseName: 'chitti_common'
});

// Each client queries its own database
const lmsUsers = await lmsClient.query('SELECT * FROM User');
const chittiActions = await chittiClient.query('SELECT * FROM Action');

// Clean up
lmsClient.close();
chittiClient.close();

Dashboard → SDK → WebSocket → DuckDB Server
            ↓
     [Connection Pool]
     [Auto-Reconnect]
     [Query Queuing]

// Update dashboard every second with fresh data
setInterval(async () => {
  const stats = await client.query('SELECT * FROM dashboard_stats');
  updateUI(stats);
}, 1000);

// Process 1000 queries efficiently
const queries = generateQueries(1000);
const batchSize = 50;

for (let i = 0; i < queries.length; i += batchSize) {
  const batch = queries.slice(i, i + batchSize);
  const results = await client.queryBatch(batch);
  processBatch(results);
}

// API endpoint handler
app.get('/api/users/:id', async (req, res) => {
  const user = await client.query(
    'SELECT * FROM User WHERE id = ?',
    [req.params.id]
  );
  res.json(user[0]);
});