IBM i MCP Server

/** * @fileoverview Initializes and exports a singleton Supabase client instance. * This module ensures that the Supabase client is initialized once and shared * across the application, using credentials from the central configuration. * It handles both the standard client and the admin client (using the service role key). * * @module src/services/supabase/supabaseClient */ import { createClient, SupabaseClient } from "@supabase/supabase-js"; import { config } from "@/config/index.js"; import { JsonRpcErrorCode, McpError } from "@/types-global/errors.js"; import { logger, requestContextService } from "@/utils/index.js"; // Define a type for our database schema if we have one. // For now, we'll use `Record<string, unknown>` but this should be replaced with generated types. type Database = Record<string, unknown>; let supabase: SupabaseClient<Database> | null = null; let supabaseAdmin: SupabaseClient<Database> | null = null; const initializeSupabase = () => { const context = requestContextService.createRequestContext({ operation: "initializeSupabase", }); if (config.supabase?.url && config.supabase?.anonKey) { if (!supabase) { supabase = createClient<Database>( config.supabase.url, config.supabase.anonKey, { auth: { persistSession: false, autoRefreshToken: false, }, }, ); logger.info(context, "Supabase client initialized."); } if (!supabaseAdmin && config.supabase.serviceRoleKey) { supabaseAdmin = createClient<Database>( config.supabase.url, config.supabase.serviceRoleKey, { auth: { persistSession: false, autoRefreshToken: false, }, }, ); logger.info(context, "Supabase admin client initialized."); } } else { logger.warning( context, "Supabase URL or anon key is missing. Supabase clients not initialized.", ); } }; // Initialize on load initializeSupabase(); /** * Returns the singleton Supabase client instance. * Throws an McpError if the client is not initialized. * @returns The Supabase client. */ export const getSupabaseClient = (): SupabaseClient<Database> => { if (!supabase) { throw new McpError( JsonRpcErrorCode.ServiceUnavailable, "Supabase client has not been initialized. Please check your SUPABASE_URL and SUPABASE_ANON_KEY environment variables.", ); } return supabase; }; /** * Returns the singleton Supabase admin client instance. * This client uses the service role key and bypasses RLS. * Throws an McpError if the admin client is not initialized. * @returns The Supabase admin client. */ export const getSupabaseAdminClient = (): SupabaseClient<Database> => { if (!supabaseAdmin) { throw new McpError( JsonRpcErrorCode.ServiceUnavailable, "Supabase admin client has not been initialized. Please check your SUPABASE_SERVICE_ROLE_KEY environment variable.", ); } return supabaseAdmin; };