Elasticsearch

import { createAgent } from '@forestadmin/agent';
import { createElasticsearchDataSource } from '@forestadmin-experimental/datasource-elasticsearch';

const agent = createAgent(options);

agent.addDataSource(
  createElasticsearchDataSource({
    node: 'http://localhost:9200',
    auth: {
      username: 'elastic',
      password: 'your-password'
    }
  })
);

createElasticsearchDataSource({
  node: 'http://localhost:9200',
  indices: [
    {
      name: 'products',
      fields: {
        id: { type: 'Number' },
        name: { type: 'String' },
        price: { type: 'Number' },
        category: { type: 'String' },
        tags: { type: 'StringList' },
        created_at: { type: 'Date' }
      }
    }
  ]
})

createElasticsearchDataSource({
  node: 'http://localhost:9200',
  templates: [
    {
      name: 'logs-*',
      fields: {
        timestamp: { type: 'Date' },
        level: { type: 'String' },
        message: { type: 'String' }
      }
    }
  ]
})

// Basic authentication
createElasticsearchDataSource({
  node: 'https://elastic.example.com:9200',
  auth: {
    username: 'elastic',
    password: 'password'
  }
})

// API key authentication
createElasticsearchDataSource({
  node: 'https://elastic.example.com:9200',
  auth: {
    apiKey: 'your-api-key'
  }
})

// Bearer token
createElasticsearchDataSource({
  node: 'https://elastic.example.com:9200',
  auth: {
    bearer: 'your-bearer-token'
  }
})

createElasticsearchDataSource({
  node: 'https://elastic.example.com:9200',
  tls: {
    ca: fs.readFileSync('./ca.crt'),
    rejectUnauthorized: true
  }
})

// Forest UI automatically generates queries with sorting
// Example: GET /products?sort=-price (descending by price)

agent.customizeCollection('products', collection => {
  collection.addAction('Run SQL Query', {
    scope: 'Global',
    execute: async (context) => {
      const result = await context.dataSource.executeNativeQuery(
        'SELECT category, AVG(price) FROM products GROUP BY category'
      );
      return result;
    }
  });
});