feat: add storage logs to unified logs (supabase#36556)

* Update UnifiedLogs.queries.ts

* Update Unified Logs QueryOptions to use POST to logs.all

---------

Co-authored-by: Joshen Lim <[email protected]>

Author: MildTomato

apps/studio/components/interfaces/UnifiedLogs/UnifiedLogs.queries.ts

@@ -257,6 +257,7 @@ const getEdgeLogsQuery = () => {
 
     -- ONLY include logs where the path does not include /rest/
     WHERE edge_logs_request.path NOT LIKE '%/rest/%'
+    AND edge_logs_request.path NOT LIKE '%/storage/%'
     
   `
 }
@@ -445,6 +446,41 @@ const getSupavisorLogsQuery = () => {
   `
 }
 
+// WHERE pathname includes `/storage/`
+const getSupabaseStorageLogsQuery = () => {
+  return `
+    select 
+      id,
+      el.timestamp as timestamp,
+      'storage' as log_type,
+      CAST(edge_logs_response.status_code AS STRING) as status,
+      CASE
+          WHEN edge_logs_response.status_code BETWEEN 200 AND 299 THEN 'success'
+          WHEN edge_logs_response.status_code BETWEEN 400 AND 499 THEN 'warning'
+          WHEN edge_logs_response.status_code >= 500 THEN 'error'
+          ELSE 'success'
+      END as level,
+      edge_logs_request.path as path,
+      edge_logs_request.host as host,
+      null as event_message,
+      edge_logs_request.method as method,
+      authorization_payload.role as api_role,
+      COALESCE(sb.auth_user, null) as auth_user,
+      null as log_count,
+      null as logs
+    from edge_logs as el
+    cross join unnest(metadata) as edge_logs_metadata
+    cross join unnest(edge_logs_metadata.request) as edge_logs_request
+    cross join unnest(edge_logs_metadata.response) as edge_logs_response
+    left join unnest(edge_logs_request.sb) as sb
+    left join unnest(sb.jwt) as jwt
+    left join unnest(jwt.authorization) as auth
+    left join unnest(auth.payload) as authorization_payload
+    -- ONLY include logs where the path includes /storage/
+    WHERE edge_logs_request.path LIKE '%/storage/%'
+  `
+}
+
 /**
  * Combine all log sources to create the unified logs CTE
  */
@@ -462,6 +498,8 @@ WITH unified_logs AS (
     ${getAuthLogsQuery()}
     union all
     ${getSupavisorLogsQuery()}
+    union all
+    ${getSupabaseStorageLogsQuery()}
 )
   `
 }