list_realtime_publications
Retrieve PostgreSQL publications configured for Supabase Realtime to monitor database changes and enable real-time data synchronization.
Instructions
Lists PostgreSQL publications, often used by Supabase Realtime.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The execute function implementing the tool logic: checks for direct PG connection, executes SQL query on pg_catalog.pg_publication, validates output with Zod schema.
execute: async ( input: ListRealtimePublicationsInput, context: ToolContext ): Promise<ListRealtimePublicationsOutput> => { const client = context.selfhostedClient; console.error('Listing Realtime publications...'); // Direct DB connection likely needed for pg_catalog access if (!client.isPgAvailable()) { context.log('Direct database connection (DATABASE_URL) is required to list publications.', 'error'); throw new Error('Direct database connection (DATABASE_URL) is required to list publications.'); } const sql = ` SELECT oid, pubname, pubowner, puballtables, pubinsert, pubupdate, pubdelete, pubtruncate, pubviaroot FROM pg_catalog.pg_publication; `; console.error('Attempting to list publications using direct DB connection...'); // Use executeSqlWithPg as it's a simple read query without parameters const result = await client.executeSqlWithPg(sql); const validatedPublications = handleSqlResponse(result, ListRealtimePublicationsOutputSchema); console.error(`Found ${validatedPublications.length} publications.`); context.log(`Found ${validatedPublications.length} publications.`); return validatedPublications; }, - Zod schemas for input (empty) and output (array of Publication objects matching pg_publication columns).
const ListRealtimePublicationsInputSchema = z.object({}); type ListRealtimePublicationsInput = z.infer<typeof ListRealtimePublicationsInputSchema>; // Output schema based on pg_publication columns const PublicationSchema = z.object({ oid: z.number().int(), pubname: z.string(), pubowner: z.number().int(), // Owner OID puballtables: z.boolean(), pubinsert: z.boolean(), pubupdate: z.boolean(), pubdelete: z.boolean(), pubtruncate: z.boolean(), pubviaroot: z.boolean(), // Potentially add pubownername if needed via join }); const ListRealtimePublicationsOutputSchema = z.array(PublicationSchema); type ListRealtimePublicationsOutput = z.infer<typeof ListRealtimePublicationsOutputSchema>; - src/index.ts:120-120 (registration)The tool is registered in the availableTools object, which is used to populate the MCP server's tool capabilities.
[listRealtimePublicationsTool.name]: listRealtimePublicationsTool as AppTool, - Static JSON schema for MCP input, required for tool capabilities declaration.
export const mcpInputSchema = { type: 'object', properties: {}, required: [], }; - src/index.ts:34-34 (registration)Import of the list_realtime_publications tool module.
import listRealtimePublicationsTool from './tools/list_realtime_publications.js';