mirror of
https://github.com/supabase/supabase.git
synced 2026-06-13 01:39:53 +08:00
143 lines
4.5 KiB
TypeScript
143 lines
4.5 KiB
TypeScript
import { untrustedSql } from '@supabase/pg-meta'
|
||
import { z, type SafeParseReturnType } from 'zod'
|
||
|
||
// Splits markdown into alternating [plain, code, plain, code, ...] segments.
|
||
// Odd-indexed segments are already inside code spans/fences and should be left alone.
|
||
const CODE_SEGMENT_REGEX = /(```[\s\S]*?```|`[^`]*`)/g
|
||
|
||
// Matches bare placeholder URLs like https://xxx/<project-ref>/... outside markdown link
|
||
// syntax. Stops at whitespace, ), or ] to avoid consuming link delimiters. Trailing prose
|
||
// punctuation is stripped in the replacement callback below.
|
||
const PLACEHOLDER_URL_REGEX = /(?<!\()https?:\/\/[^\s)\]]*<[a-z][a-z0-9]*(?:-[a-z0-9]+)*>[^\s)\]]*/g
|
||
|
||
/**
|
||
* Wraps bare URLs containing <placeholder> patterns in backticks so they render in
|
||
* code font, regardless of whether the LLM remembered to wrap them.
|
||
*/
|
||
export function wrapPlaceholderUrls(markdown: string): string {
|
||
if (!markdown.includes('<')) return markdown
|
||
const segments = markdown.split(CODE_SEGMENT_REGEX)
|
||
return segments
|
||
.map((segment, i) => {
|
||
if (i % 2 === 1) return segment
|
||
return segment.replace(PLACEHOLDER_URL_REGEX, (url) => {
|
||
const trailingPunct = url.match(/[.,;:!?'"]+$/)?.[0] ?? ''
|
||
const cleanUrl = url.slice(0, url.length - trailingPunct.length)
|
||
return `\`${cleanUrl}\`` + trailingPunct
|
||
})
|
||
})
|
||
.join('')
|
||
}
|
||
|
||
// [Joshen] From https://github.com/remarkjs/react-markdown/blob/fda7fa560bec901a6103e195f9b1979dab543b17/lib/index.js#L425
|
||
export function defaultUrlTransform(value: string) {
|
||
const safeProtocol = /^(https?|ircs?|mailto|xmpp)$/i
|
||
const colon = value.indexOf(':')
|
||
const questionMark = value.indexOf('?')
|
||
const numberSign = value.indexOf('#')
|
||
const slash = value.indexOf('/')
|
||
|
||
if (
|
||
// If there is no protocol, it’s relative.
|
||
colon === -1 ||
|
||
// If the first colon is after a `?`, `#`, or `/`, it’s not a protocol.
|
||
(slash !== -1 && colon > slash) ||
|
||
(questionMark !== -1 && colon > questionMark) ||
|
||
(numberSign !== -1 && colon > numberSign) ||
|
||
// It is a protocol, it should be allowed.
|
||
safeProtocol.test(value.slice(0, colon))
|
||
) {
|
||
return value
|
||
}
|
||
|
||
return ''
|
||
}
|
||
|
||
const chartArgsSchema = z
|
||
.object({
|
||
view: z.enum(['table', 'chart']).optional(),
|
||
xKey: z.string().optional(),
|
||
xAxis: z.string().optional(),
|
||
yKey: z.string().optional(),
|
||
yAxis: z.string().optional(),
|
||
})
|
||
.passthrough()
|
||
|
||
const chartArgsFieldSchema = z.preprocess((value) => {
|
||
if (!value || typeof value !== 'object') return undefined
|
||
if (Array.isArray(value)) return value[0]
|
||
return value
|
||
}, chartArgsSchema.optional())
|
||
|
||
const executeSqlChartResultSchema = z
|
||
.object({
|
||
sql: z.string().optional(),
|
||
label: z.string().optional(),
|
||
isWriteQuery: z.boolean().optional(),
|
||
chartConfig: chartArgsFieldSchema,
|
||
config: chartArgsFieldSchema,
|
||
})
|
||
.passthrough()
|
||
.transform(({ sql, label, isWriteQuery, chartConfig, config }) => {
|
||
const chartArgs = chartConfig ?? config
|
||
|
||
return {
|
||
sql: untrustedSql(sql ?? ''),
|
||
label,
|
||
isWriteQuery,
|
||
view: chartArgs?.view,
|
||
xAxis: chartArgs?.xKey ?? chartArgs?.xAxis,
|
||
yAxis: chartArgs?.yKey ?? chartArgs?.yAxis,
|
||
}
|
||
})
|
||
|
||
export function parseExecuteSqlChartResult(
|
||
input: unknown
|
||
): SafeParseReturnType<unknown, z.infer<typeof executeSqlChartResultSchema>> {
|
||
return executeSqlChartResultSchema.safeParse(input)
|
||
}
|
||
|
||
export const deployEdgeFunctionInputSchema = z
|
||
.object({
|
||
code: z.string().min(1),
|
||
name: z.string().trim().optional(),
|
||
slug: z.string().trim().optional(),
|
||
functionName: z.string().trim().optional(),
|
||
label: z.string().optional(),
|
||
})
|
||
.passthrough()
|
||
.transform((data) => {
|
||
const rawName = data.functionName ?? data.name ?? data.slug
|
||
const trimmedName = rawName?.trim()
|
||
const functionName = trimmedName && trimmedName.length > 0 ? trimmedName : 'my-function'
|
||
|
||
const rawLabel = data.label ?? rawName
|
||
const trimmedLabel = rawLabel?.trim()
|
||
const label = trimmedLabel && trimmedLabel.length > 0 ? trimmedLabel : 'Edge Function'
|
||
|
||
return {
|
||
code: data.code,
|
||
functionName,
|
||
label,
|
||
}
|
||
})
|
||
|
||
export const deployEdgeFunctionOutputSchema = z
|
||
.object({ success: z.boolean().optional() })
|
||
.passthrough()
|
||
|
||
export const rateMessageResponseSchema = z.object({
|
||
category: z.enum([
|
||
'sql_generation',
|
||
'schema_design',
|
||
'rls_policies',
|
||
'edge_functions',
|
||
'database_optimization',
|
||
'debugging',
|
||
'general_help',
|
||
'other',
|
||
]),
|
||
})
|
||
|
||
export type RateMessageResponse = z.infer<typeof rateMessageResponseSchema>
|