import { FastifyPluginCallback, FastifyRequest, FastifyInstance } from 'fastify'; import { FastifyCorsOptions } from '@fastify/cors'; import { SemanticQuery, SecurityContext, DatabaseExecutor, DrizzleDatabase, Cube, CacheConfig, RLSSetupFn } from '../../server/index.js'; import { AgentConfig } from '../../server/agent/types.js'; import { PostgresJsDatabase } from 'drizzle-orm/postgres-js'; import { MySql2Database } from 'drizzle-orm/mysql2'; import { BetterSQLite3Database } from 'drizzle-orm/better-sqlite3'; import { MCPOptions } from '../utils.js'; export interface FastifyAdapterOptions { /** * Array of cube definitions to register */ cubes: Cube[]; /** * Drizzle database instance (REQUIRED) * This is the core of drizzle-cube - Drizzle ORM integration * Accepts PostgreSQL, MySQL, or SQLite database instances */ drizzle: PostgresJsDatabase | MySql2Database | BetterSQLite3Database | DrizzleDatabase; /** * Database schema for type inference (RECOMMENDED) * Provides full type safety for cube definitions */ schema?: any; /** * Extract security context from incoming HTTP request. * Called for EVERY API request to determine user permissions and multi-tenant isolation. * * This is your security boundary - ensure proper authentication and authorization here. * * @param request - Fastify Request object containing the incoming HTTP request * @returns Security context with organisationId, userId, roles, etc. * * @example * extractSecurityContext: async (request) => { * // Extract JWT from Authorization header * const token = request.headers.authorization?.replace('Bearer ', '') * const decoded = await verifyJWT(token) * * // Return context that will be available in all cube SQL functions * return { * organisationId: decoded.orgId, * userId: decoded.userId, * roles: decoded.roles * } * } */ extractSecurityContext: (request: FastifyRequest) => SecurityContext | Promise; /** * Database engine type (optional - auto-detected if not provided) */ engineType?: 'postgres' | 'mysql' | 'sqlite' | 'singlestore' | 'duckdb' | 'databend' | 'snowflake'; /** * CORS configuration (optional) */ cors?: FastifyCorsOptions; /** * API base path (default: '/cubejs-api/v1') */ basePath?: string; /** * JSON body parser limit (default: 10485760 - 10MB) */ bodyLimit?: number; /** * Cache configuration for query result caching * When provided, query results will be cached using the specified provider */ cache?: CacheConfig; /** * MCP (AI-Ready) endpoint configuration * Enables AI agents to discover and query your data * @default { enabled: true } */ mcp?: MCPOptions; /** * Agent configuration for the agentic AI notebook feature. * When provided, enables the POST /agent/chat SSE endpoint. * Requires `@anthropic-ai/sdk` as a peer dependency. */ agent?: AgentConfig; /** * Row-Level Security setup function. * When provided, every query execution opens a transaction, calls this function * to configure RLS (e.g., set JWT claims and switch Postgres roles), then runs the query. */ rlsSetup?: RLSSetupFn; } /** * Fastify plugin for Cube.js-compatible API */ export declare const cubePlugin: FastifyPluginCallback; /** * Helper function to register cube routes on an existing Fastify instance */ export declare function registerCubeRoutes(fastify: FastifyInstance, options: FastifyAdapterOptions): Promise; /** * Create a complete Fastify instance with Cube.js routes * * @example * const app = createCubeApp({ * cubes: [salesCube, employeesCube], * drizzle: db, * schema, * extractSecurityContext: async (request) => { * const token = request.headers.authorization?.replace('Bearer ', '') * const decoded = await verifyJWT(token) * return { organisationId: decoded.orgId, userId: decoded.userId } * } * }) */ export declare function createCubeApp(options: FastifyAdapterOptions): FastifyInstance; export type { SecurityContext, DatabaseExecutor, SemanticQuery, DrizzleDatabase, FastifyCorsOptions };