PersistentAI API Documentation / @persistentai/fireflow-trpc / server / handleLakeFSWebhook

Function: handleLakeFSWebhook()

handleLakeFSWebhook(req, res, secret): Promise<void>

Defined in: packages/fireflow-trpc/server/webhook/lakefs-handler.ts:59

Handle incoming lakeFS webhook

This handler is triggered by lakeFS after commits, merges, and branch operations. It generates VFS events and publishes them to Redis for real-time client updates.

Flow:

1. Validate webhook secret (constant-time comparison)
2. Parse and validate payload
3. Skip system commits (action file deployment)
4. Resolve workspace from repository_id
5. Resolve user from commit metadata
6. Fetch diff and generate events for each changed file
7. Publish to Redis, insert to DB, queue for flow routing

Parameters

req

IncomingMessage

res

ServerResponse

secret

string

Returns

Promise<void>