Function postFeedback

web/src/app/api/v1/feedback/_post.ts:15–105

(params: {
  req: NextRequest
  getUserInfoFromApiKey: GetUserInfoFromApiKeyFn
  logger: Logger
  loggerWithContext: LoggerWithContextFn
  trackEvent: TrackEventFn
})

import type { NextRequest } from 'next/server'

export async function postFeedback(params: {
  req: NextRequest
  getUserInfoFromApiKey: GetUserInfoFromApiKeyFn
  logger: Logger
  loggerWithContext: LoggerWithContextFn
  trackEvent: TrackEventFn
}) {
  const {
    req,
    getUserInfoFromApiKey,
    logger: baseLogger,
    loggerWithContext,
    trackEvent,
  } = params

  // TODO: Persist feedback to a database table for durability and queryability
  // TODO: Add rate limiting (e.g., 10 requests/minute per userId)

  try {
    const userResult = await requireUserFromApiKey({
      req,
      getUserInfoFromApiKey,
      logger: baseLogger,
      loggerWithContext,
      trackEvent,
      authErrorEvent: AnalyticsEvent.FEEDBACK_AUTH_ERROR,
    })

    if (!userResult.ok) {
      return userResult.response
    }

    const { userId, logger } = userResult.data

    const bodyResult = await parseJsonBody({
      req,
      schema: feedbackRequestSchema,
      logger,
      trackEvent,
      validationErrorEvent: AnalyticsEvent.FEEDBACK_VALIDATION_ERROR,
      userId,
    })

    if (!bodyResult.ok) {
      return bodyResult.response
    }

    const feedback = bodyResult.data

    try {
      const {
        clientFeedbackId, source, messageId, messageVariant,
        completionTime, credits, agentMode, sessionCreditsUsed,
        recentMessages, text, category, type, errors,
      } = feedback

      trackEvent({
        event: AnalyticsEvent.FEEDBACK_SUBMITTED,