Merge pull request #18 from supabase-community/feat/branch-logs

feat: add branch action logs

Author: sweatybridge

packages/mcp-server-supabase/src/logs.ts

@@ -3,6 +3,7 @@ import { stripIndent } from 'common-tags';
 export function getLogQuery(
   service:
     | 'api'
+    | 'branch-action'
     | 'postgres'
     | 'edge-function'
     | 'auth'
@@ -21,6 +22,12 @@ export function getLogQuery(
         order by timestamp desc
         limit ${limit}
       `;
+    case 'branch-action':
+      return stripIndent`
+          select workflow_run, workflow_run_logs.timestamp, id, event_message from workflow_run_logs
+          order by timestamp desc
+          limit ${limit}
+        `;
     case 'postgres':
       return stripIndent`
         select identifier, postgres_logs.timestamp, id, event_message, parsed.error_severity from postgres_logs

packages/mcp-server-supabase/src/server.test.ts

@@ -456,6 +456,7 @@ describe('tools', () => {
     const project = mockProjects.values().next().value!;
     const services = [
       'api',
+      'branch-action',
       'postgres',
       'edge-function',
       'auth',

packages/mcp-server-supabase/src/server.ts

@@ -337,6 +337,7 @@ export function createSupabaseMcpServer(options: SupabaseMcpServerOptions) {
           service: z
             .enum([
               'api',
+              'branch-action',
               'postgres',
               'edge-function',
               'auth',
@@ -346,7 +347,13 @@ export function createSupabaseMcpServer(options: SupabaseMcpServerOptions) {
             .describe('The service to fetch logs for'),
         }),
         execute: async ({ project_id, service }) => {
-          const now = Date.now();
+          // Omitting start and end time defaults to the last minute.
+          // But since branch actions are async, we need to wait longer
+          // for jobs to be scheduled and run to completion.
+          const timestamp =
+            service === 'branch-action'
+              ? new Date(Date.now() - 5 * 60 * 1000)
+              : undefined;
           const response = await managementApiClient.GET(
             '/v1/projects/{ref}/analytics/endpoints/logs.all',
             {
@@ -355,7 +362,7 @@ export function createSupabaseMcpServer(options: SupabaseMcpServerOptions) {
                   ref: project_id,
                 },
                 query: {
-                  // Omitting start and end time defaults to the last minute
+                  iso_timestamp_start: timestamp?.toISOString(),
                   sql: getLogQuery(service),
                 },
               },