mirror of
https://github.com/supabase/supabase.git
synced 2026-10-13 05:09:12 +03:00
Jordi Enricandgithub-actions[bot]
a806f7dc44
<!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit * **New Features** * Added OpenTelemetry Protocol (OTLP) as a log drain destination with configurable endpoint, protocol (HTTP/Protobuf), gzip compression, and custom headers. * OTLP appears as a selectable destination in the Log Drains UI with its own icon and form fields. * **Documentation** * Added a full OTLP guide including HTTP/Protobuf details, Collector example, and authentication examples. <!-- end of auto-generated comment: release notes by coderabbit.ai --> --------- Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
78 lines
2.2 KiB
TypeScript
78 lines
2.2 KiB
TypeScript
/**
|
|
* Utility functions for log drain management
|
|
* Extracted for testability
|
|
*/
|
|
|
|
import { z } from 'zod'
|
|
|
|
import { LogDrainType } from './LogDrains.constants'
|
|
|
|
/**
|
|
* Get the description text for the custom headers section based on log drain type
|
|
*/
|
|
export function getHeadersSectionDescription(type: LogDrainType): string {
|
|
if (type === 'webhook') {
|
|
return 'Set custom headers when draining logs to the Endpoint URL'
|
|
}
|
|
if (type === 'loki') {
|
|
return 'Set custom headers when draining logs to the Loki HTTP(S) endpoint'
|
|
}
|
|
if (type === 'otlp') {
|
|
return 'Set custom headers for OTLP authentication (e.g., Authorization, X-API-Key)'
|
|
}
|
|
return ''
|
|
}
|
|
|
|
/**
|
|
* Validation errors for header management
|
|
*/
|
|
export const HEADER_VALIDATION_ERRORS = {
|
|
MAX_LIMIT: 'You can only have 20 custom headers',
|
|
DUPLICATE: 'Header name already exists',
|
|
REQUIRED: 'Header name and value are required',
|
|
} as const
|
|
|
|
/**
|
|
* Validates if a new header can be added to the existing headers
|
|
*/
|
|
export function validateNewHeader(
|
|
existingHeaders: Record<string, string>,
|
|
newHeader: { name: string; value: string }
|
|
): { valid: boolean; error?: string } {
|
|
const headerKeys = Object.keys(existingHeaders)
|
|
|
|
if (headerKeys.length >= 20) {
|
|
return { valid: false, error: HEADER_VALIDATION_ERRORS.MAX_LIMIT }
|
|
}
|
|
|
|
if (headerKeys.includes(newHeader.name)) {
|
|
return { valid: false, error: HEADER_VALIDATION_ERRORS.DUPLICATE }
|
|
}
|
|
|
|
if (!newHeader.name || !newHeader.value) {
|
|
return { valid: false, error: HEADER_VALIDATION_ERRORS.REQUIRED }
|
|
}
|
|
|
|
return { valid: true }
|
|
}
|
|
|
|
/**
|
|
* Zod schema for OTLP log drain configuration
|
|
* Extracted for testing purposes
|
|
*/
|
|
export const otlpConfigSchema = z.object({
|
|
type: z.literal('otlp'),
|
|
endpoint: z
|
|
.string()
|
|
.min(1, { message: 'OTLP endpoint is required' })
|
|
.refine(
|
|
(url) => url.startsWith('http://') || url.startsWith('https://'),
|
|
'OTLP endpoint must start with http:// or https://'
|
|
),
|
|
protocol: z.string().optional().default('http/protobuf'),
|
|
gzip: z.boolean().optional().default(true),
|
|
headers: z.record(z.string(), z.string()).optional(),
|
|
})
|
|
|
|
export type OtlpConfig = z.infer<typeof otlpConfigSchema>
|