Agregar proxy para clips y snapshots de Frigate
All checks were successful
build-and-deploy / build-and-deploy (push) Successful in 1m1s

- Crear /api/frigate/events/:eventId/clip con soporte de range requests
- Crear /api/frigate/events/:eventId/snapshot
- Usar IP interna 192.168.87.29:5000 para evitar autenticacion Authentik
- Actualizar URLs en useFrigateEvents para usar proxies internos
This commit is contained in:
2025-12-30 04:05:05 -06:00
parent 8e555b543d
commit adce97f193
3 changed files with 173 additions and 5 deletions

View File

@@ -0,0 +1,95 @@
/**
* Proxy endpoint para obtener clips de eventos de Frigate
* GET /api/frigate/events/:eventId/clip
* Soporta range requests para seeking en video
*/
export default defineEventHandler(async (event) => {
// Verificar autenticación via headers de Authentik
const headers = getRequestHeaders(event)
const username = headers['x-authentik-username']
if (!username) {
throw createError({
statusCode: 401,
message: 'No autenticado'
})
}
const eventId = getRouterParam(event, 'eventId')
if (!eventId) {
throw createError({
statusCode: 400,
message: 'Se requiere eventId'
})
}
// URL interna de Frigate
const FRIGATE_URL = process.env.FRIGATE_URL || 'http://192.168.87.29:5000'
try {
// Pasar headers de range si existen (para seeking)
const requestHeaders: Record<string, string> = {
'Accept': 'video/mp4'
}
const rangeHeader = headers['range']
if (rangeHeader) {
requestHeaders['Range'] = rangeHeader
}
const response = await fetch(
`${FRIGATE_URL}/api/events/${eventId}/clip.mp4`,
{
method: 'GET',
headers: requestHeaders
}
)
if (!response.ok && response.status !== 206) {
throw createError({
statusCode: response.status,
message: `Error al obtener clip: ${response.statusText}`
})
}
// Configurar headers de respuesta
const responseHeaders: Record<string, string> = {
'Content-Type': 'video/mp4',
'Accept-Ranges': 'bytes'
}
const contentLength = response.headers.get('content-length')
if (contentLength) {
responseHeaders['Content-Length'] = contentLength
}
const contentRange = response.headers.get('content-range')
if (contentRange) {
responseHeaders['Content-Range'] = contentRange
}
// Establecer headers
for (const [key, value] of Object.entries(responseHeaders)) {
setResponseHeader(event, key, value)
}
// Establecer status code (200 o 206 para partial content)
setResponseStatus(event, response.status)
// Retornar el stream del video
return response.body
} catch (error: unknown) {
console.error('[Frigate Clip Proxy] Error:', error)
if ((error as any).statusCode) {
throw error
}
throw createError({
statusCode: 500,
message: (error as Error)?.message || 'Error al obtener clip'
})
}
})

View File

@@ -0,0 +1,73 @@
/**
* Proxy endpoint para obtener snapshots de eventos de Frigate
* GET /api/frigate/events/:eventId/snapshot
*/
export default defineEventHandler(async (event) => {
// Verificar autenticación via headers de Authentik
const headers = getRequestHeaders(event)
const username = headers['x-authentik-username']
if (!username) {
throw createError({
statusCode: 401,
message: 'No autenticado'
})
}
const eventId = getRouterParam(event, 'eventId')
if (!eventId) {
throw createError({
statusCode: 400,
message: 'Se requiere eventId'
})
}
// URL interna de Frigate
const FRIGATE_URL = process.env.FRIGATE_URL || 'http://192.168.87.29:5000'
try {
const response = await fetch(
`${FRIGATE_URL}/api/events/${eventId}/snapshot.jpg`,
{
method: 'GET',
headers: {
'Accept': 'image/jpeg'
}
}
)
if (!response.ok) {
throw createError({
statusCode: response.status,
message: `Error al obtener snapshot: ${response.statusText}`
})
}
// Configurar headers de respuesta
setResponseHeader(event, 'Content-Type', 'image/jpeg')
const contentLength = response.headers.get('content-length')
if (contentLength) {
setResponseHeader(event, 'Content-Length', contentLength)
}
// Cache por 5 minutos (los snapshots no cambian)
setResponseHeader(event, 'Cache-Control', 'public, max-age=300')
// Retornar el stream de la imagen
return response.body
} catch (error: unknown) {
console.error('[Frigate Snapshot Proxy] Error:', error)
if ((error as any).statusCode) {
throw error
}
throw createError({
statusCode: 500,
message: (error as Error)?.message || 'Error al obtener snapshot'
})
}
})