Email trigger webhook endpoint (#956)

Author: csansoon

apps/gateway/src/api.routes.ts

@@ -0,0 +1,77 @@
+const BASE_PATH = '/api'
+const V1_PATH = `${BASE_PATH}/v1`
+const V2_PATH = `${BASE_PATH}/v2`
+const V3_PATH = `${BASE_PATH}/v3`
+
+const PROJECTS = 'projects'
+const CONVERSATIONS = 'conversations'
+const PROJECT_DETAIL = `${PROJECTS}/{projectId}`
+const VERSIONS = `${PROJECT_DETAIL}/versions`
+const VERSION_DETAIL = `${VERSIONS}/{versionUuid}`
+const DOCUMENTS = `${VERSION_DETAIL}/documents`
+
+const V1_DOCUMENTS = `${V1_PATH}/${DOCUMENTS}`
+const V2_DOCUMENTS = `${V2_PATH}/${DOCUMENTS}`
+const V3_DOCUMENTS = `${V3_PATH}/${DOCUMENTS}`
+
+const V1_CONVERSATIONS = `${V1_PATH}/${CONVERSATIONS}`
+const V2_CONVERSATIONS = `${V2_PATH}/${CONVERSATIONS}`
+const V3_CONVERSATIONS = `${V3_PATH}/${CONVERSATIONS}`
+
+const V2_CONVERSATION_DETAIL = `${V2_CONVERSATIONS}/{conversationUuid}`
+const V3_CONVERSATION_DETAIL = `${V3_CONVERSATIONS}/{conversationUuid}`
+
+const V2_EVALUATIONS = `${V2_CONVERSATIONS}/{conversationUuid}/evaluations`
+const V3_EVALUATIONS = `${V3_CONVERSATIONS}/{conversationUuid}/evaluations`
+
+const V2_EVALUATION_DETAIL = `${V2_EVALUATIONS}/{evaluationUuid}`
+const V3_EVALUATION_DETAIL = `${V3_EVALUATIONS}/{evaluationUuid}`
+
+const V2_TELEMETRY = `${V2_PATH}/otlp`
+const V3_TELEMETRY = `${V3_PATH}/otlp`
+
+export const API_ROUTES = {
+  v1: {
+    documents: {
+      get: `${V1_DOCUMENTS}/:documentPath{.+}`,
+      run: `${V1_DOCUMENTS}/run`,
+      logs: `${V1_DOCUMENTS}/logs`,
+    },
+    conversations: {
+      chat: `${V1_CONVERSATIONS}/{conversationUuid}/chat`,
+    },
+  },
+  v2: {
+    documents: {
+      get: `${V2_DOCUMENTS}/:documentPath{.+}`,
+      getOrCreate: `${V2_DOCUMENTS}/get-or-create`,
+      run: `${V2_DOCUMENTS}/run`,
+      logs: `${V2_DOCUMENTS}/logs`,
+    },
+    conversations: {
+      chat: `${V2_CONVERSATION_DETAIL}/chat`,
+      evaluate: `${V2_CONVERSATION_DETAIL}/evaluate`,
+      createEvaluationResult: `${V2_EVALUATION_DETAIL}/evaluation-results`,
+    },
+    telemetry: {
+      traces: `${V2_TELEMETRY}/v1/traces`,
+    },
+  },
+  v3: {
+    documents: {
+      getAll: V3_DOCUMENTS,
+      get: `${V3_DOCUMENTS}/:documentPath{.+}`,
+      getOrCreate: `${V3_DOCUMENTS}/get-or-create`,
+      run: `${V3_DOCUMENTS}/run`,
+      logs: `${V3_DOCUMENTS}/logs`,
+    },
+    conversations: {
+      chat: `${V3_CONVERSATION_DETAIL}/chat`,
+      evaluate: `${V3_CONVERSATION_DETAIL}/evaluate`,
+      createEvaluationResult: `${V3_EVALUATION_DETAIL}/evaluation-results`,
+    },
+    telemetry: {
+      traces: `${V3_TELEMETRY}/v1/traces`,
+    },
+  },
+}

apps/gateway/src/routes.ts

@@ -1,77 +1,7 @@
-const BASE_PATH = '/api'
-const V1_PATH = `${BASE_PATH}/v1`
-const V2_PATH = `${BASE_PATH}/v2`
-const V3_PATH = `${BASE_PATH}/v3`
-
-const PROJECTS = 'projects'
-const CONVERSATIONS = 'conversations'
-const PROJECT_DETAIL = `${PROJECTS}/{projectId}`
-const VERSIONS = `${PROJECT_DETAIL}/versions`
-const VERSION_DETAIL = `${VERSIONS}/{versionUuid}`
-const DOCUMENTS = `${VERSION_DETAIL}/documents`
-
-const V1_DOCUMENTS = `${V1_PATH}/${DOCUMENTS}`
-const V2_DOCUMENTS = `${V2_PATH}/${DOCUMENTS}`
-const V3_DOCUMENTS = `${V3_PATH}/${DOCUMENTS}`
-
-const V1_CONVERSATIONS = `${V1_PATH}/${CONVERSATIONS}`
-const V2_CONVERSATIONS = `${V2_PATH}/${CONVERSATIONS}`
-const V3_CONVERSATIONS = `${V3_PATH}/${CONVERSATIONS}`
-
-const V2_CONVERSATION_DETAIL = `${V2_CONVERSATIONS}/{conversationUuid}`
-const V3_CONVERSATION_DETAIL = `${V3_CONVERSATIONS}/{conversationUuid}`
-
-const V2_EVALUATIONS = `${V2_CONVERSATIONS}/{conversationUuid}/evaluations`
-const V3_EVALUATIONS = `${V3_CONVERSATIONS}/{conversationUuid}/evaluations`
-
-const V2_EVALUATION_DETAIL = `${V2_EVALUATIONS}/{evaluationUuid}`
-const V3_EVALUATION_DETAIL = `${V3_EVALUATIONS}/{evaluationUuid}`
-
-const V2_TELEMETRY = `${V2_PATH}/otlp`
-const V3_TELEMETRY = `${V3_PATH}/otlp`
+import { API_ROUTES } from './api.routes'
+import { WEBHOOK_ROUTES } from './webhook.routes'
 
 export const ROUTES = {
-  v1: {
-    documents: {
-      get: `${V1_DOCUMENTS}/:documentPath{.+}`,
-      run: `${V1_DOCUMENTS}/run`,
-      logs: `${V1_DOCUMENTS}/logs`,
-    },
-    conversations: {
-      chat: `${V1_CONVERSATIONS}/{conversationUuid}/chat`,
-    },
-  },
-  v2: {
-    documents: {
-      get: `${V2_DOCUMENTS}/:documentPath{.+}`,
-      getOrCreate: `${V2_DOCUMENTS}/get-or-create`,
-      run: `${V2_DOCUMENTS}/run`,
-      logs: `${V2_DOCUMENTS}/logs`,
-    },
-    conversations: {
-      chat: `${V2_CONVERSATION_DETAIL}/chat`,
-      evaluate: `${V2_CONVERSATION_DETAIL}/evaluate`,
-      createEvaluationResult: `${V2_EVALUATION_DETAIL}/evaluation-results`,
-    },
-    telemetry: {
-      traces: `${V2_TELEMETRY}/v1/traces`,
-    },
-  },
-  v3: {
-    documents: {
-      getAll: V3_DOCUMENTS,
-      get: `${V3_DOCUMENTS}/:documentPath{.+}`,
-      getOrCreate: `${V3_DOCUMENTS}/get-or-create`,
-      run: `${V3_DOCUMENTS}/run`,
-      logs: `${V3_DOCUMENTS}/logs`,
-    },
-    conversations: {
-      chat: `${V3_CONVERSATION_DETAIL}/chat`,
-      evaluate: `${V3_CONVERSATION_DETAIL}/evaluate`,
-      createEvaluationResult: `${V3_EVALUATION_DETAIL}/evaluation-results`,
-    },
-    telemetry: {
-      traces: `${V3_TELEMETRY}/v1/traces`,
-    },
-  },
+  api: API_ROUTES,
+  webhook: WEBHOOK_ROUTES,
 }

apps/gateway/src/routes/api/index.ts

@@ -0,0 +1,16 @@
+import v1Routes from '$/routes/api/v1'
+import v2Routes from '$/routes/api/v2'
+
+import documents from '$/routes/api/v3/documents'
+import conversations from '$/routes/api/v3/conversations'
+import telemetry from '$/routes/api/v3/otlp'
+import { OpenAPIHono } from '@hono/zod-openapi'
+
+export function configureApiRoutes(app: OpenAPIHono) {
+  app.route('/', v1Routes)
+  app.route('/', v2Routes)
+
+  app.route('/', documents)
+  app.route('/', conversations)
+  app.route('/', telemetry)
+}

apps/gateway/src/routes/v1/chat/chat.handler.test.ts renamed to apps/gateway/src/routes/api/v1/chat/chat.handler.test.ts

@@ -5,7 +5,7 @@ import { captureException } from '@sentry/node'
 import { streamSSE } from 'hono/streaming'
 
 import { AppRouteHandler } from '$/openApi/types'
-import { ChatRoute } from '$/routes/v1/chat/chat.route'
+import { ChatRoute } from '$/routes/api/v1/chat/chat.route'
 import { legacyChainEventPresenter } from '$/common/documents/getData'
 import { convertToLegacyChainStream } from '@latitude-data/core/lib/chainStreamManager/index'
 

apps/gateway/src/routes/v1/chat/chat.handler.ts renamed to apps/gateway/src/routes/api/v1/chat/chat.handler.ts

@@ -5,15 +5,15 @@ import {
   internalInfoSchema,
 } from '$/openApi/schemas'
 import { ROUTES } from '$/routes'
-import { conversationsParamsSchema } from '$/routes/v2/conversations/paramsSchema'
+import { conversationsParamsSchema } from '$/routes/api/v2/conversations/paramsSchema'
 import { createRoute, z } from '@hono/zod-openapi'
 import { messageSchema } from '@latitude-data/core/browser'
 
 export const chatRoute = createRoute({
   operationId: 'createChat',
   tags: ['V1_DEPRECATED'],
   method: http.Methods.POST,
-  path: ROUTES.v1.conversations.chat,
+  path: ROUTES.api.v1.conversations.chat,
   request: {
     params: conversationsParamsSchema,
     body: {

apps/gateway/src/routes/v1/chat/chat.route.ts renamed to apps/gateway/src/routes/api/v1/chat/chat.route.ts

@@ -1,7 +1,7 @@
 import { createRouter } from '$/openApi/createApp'
-import { chatHandler, chatRoute } from '$/routes/v1/chat'
+import { chatHandler, chatRoute } from '$/routes/api/v1/chat'
 
-import { runRoute, runHandler } from '$/routes/v1/run'
+import { runRoute, runHandler } from '$/routes/api/v1/run'
 
 const router = createRouter()
   .openapi(runRoute, runHandler)