mirror of
https://github.com/supabase/supabase.git
synced 2026-10-06 09:55:06 +03:00
Francesco Sansalvadore
0bf22ee6fc
workers -> compute <!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit - **New Features** - Added the Compute experience for deploying, viewing, managing, and monitoring compute instances. - Added Compute navigation, instance detail pages, secrets, logs, deployment dialogs, generated snippets, and CLI commands. - Added filtering, status, availability, and data-loading support for compute instances. - **Updates** - Updated labels, icons, links, feature controls, unified logs, and secret-deletion messaging to use Compute terminology. - Compute routes now replace the previous Workers routes and pages. <!-- end of auto-generated comment: release notes by coderabbit.ai -->
82 lines
2.6 KiB
TypeScript
82 lines
2.6 KiB
TypeScript
import { z } from 'zod'
|
|
|
|
import { parseOtelTimestamp } from './otel-inspection.utils'
|
|
import { LEVELS } from '@/components/ui/DataTable/DataTable.constants'
|
|
import { tryParseJson } from '@/lib/helpers'
|
|
|
|
type UnifiedLogMetadataRow = {
|
|
log_type?: string | null
|
|
status?: string | number | null
|
|
method?: string | null
|
|
pathname?: string | null
|
|
event_message?: string | null
|
|
}
|
|
|
|
const unifiedLogsQueryRowSchema = z.object({
|
|
id: z.string(),
|
|
timestamp: z.union([z.string(), z.number()]),
|
|
log_type: z.string(),
|
|
status: z.union([z.string(), z.number()]).nullable(),
|
|
level: z.enum(LEVELS).nullable(),
|
|
pathname: z.string().nullable(),
|
|
event_message: z.string().nullable(),
|
|
method: z.string().nullable(),
|
|
log_count: z.number().nullable(),
|
|
logs: z.array(z.unknown()).nullable(),
|
|
auth_user: z.string().nullish(),
|
|
metadata: z.record(z.string(), z.unknown()).nullish(),
|
|
})
|
|
|
|
export type UnifiedLogsQueryRow = z.infer<typeof unifiedLogsQueryRowSchema>
|
|
|
|
export const parseUnifiedLogsQueryRows = (value: unknown): UnifiedLogsQueryRow[] =>
|
|
z.array(unifiedLogsQueryRowSchema).parse(value ?? [])
|
|
|
|
const extractLeadingStatus = (s?: string) => {
|
|
const m = typeof s === 'string' ? s.match(/^(\d{3})\b/) : null
|
|
return m ? Number(m[1]) : undefined
|
|
}
|
|
|
|
export const extractLogMetadata = (row: UnifiedLogMetadataRow) => {
|
|
if (row.log_type === 'compute') {
|
|
return { status: null, method: null, pathname: null }
|
|
}
|
|
|
|
// [Joshen] For auth logs, these metadata are nested within event_message,
|
|
// so opting to bring them out at the query level
|
|
const eventMessage = tryParseJson(row.event_message)
|
|
const status =
|
|
row.log_type === 'auth'
|
|
? (eventMessage?.status ??
|
|
extractLeadingStatus(eventMessage?.msg) ??
|
|
extractLeadingStatus(eventMessage?.error))
|
|
: (row.status ?? 200)
|
|
const method = row.log_type === 'auth' ? eventMessage?.method : row.method
|
|
const pathname = row.log_type === 'auth' ? eventMessage?.path : row.pathname || ''
|
|
|
|
return { status, method, pathname }
|
|
}
|
|
|
|
export const mapUnifiedLogRow = (row: UnifiedLogsQueryRow) => {
|
|
const isComputeLog = row.log_type === 'compute'
|
|
const { status, method, pathname } = extractLogMetadata(row)
|
|
|
|
const mappedRow = {
|
|
id: row.id,
|
|
date: parseOtelTimestamp(row.timestamp),
|
|
method,
|
|
pathname,
|
|
status,
|
|
timestamp: row.timestamp,
|
|
level: isComputeLog ? null : row.level,
|
|
event_message: row.event_message ?? '',
|
|
log_type: row.log_type,
|
|
log_count: row.log_count ?? null,
|
|
logs: row.logs ?? [],
|
|
auth_user: isComputeLog ? null : row.auth_user || null,
|
|
}
|
|
|
|
if (isComputeLog) return { ...mappedRow, metadata: row.metadata ?? null }
|
|
return mappedRow
|
|
}
|