Function postGravityIndex

web/src/app/api/v1/gravity-index/_post.ts:122–263

(params: {
  req: NextRequest
  getUserInfoFromApiKey: GetUserInfoFromApiKeyFn
  logger: Logger
  loggerWithContext: LoggerWithContextFn
  trackEvent: TrackEventFn
  fetch: typeof globalThis.fetch
  serverEnv: {
    GRAVITY_API_KEY?: string
  }
})

}

export async function postGravityIndex(params: {
  req: NextRequest
  getUserInfoFromApiKey: GetUserInfoFromApiKeyFn
  logger: Logger
  loggerWithContext: LoggerWithContextFn
  trackEvent: TrackEventFn
  fetch: typeof globalThis.fetch
  serverEnv: {
    GRAVITY_API_KEY?: string
  }
}) {
  const {
    req,
    getUserInfoFromApiKey,
    loggerWithContext,
    trackEvent,
    fetch,
    serverEnv,
  } = params
  const baseLogger = params.logger

  const parsedBody = await parseJsonBody({
    req,
    schema: gravityIndexInputSchema,
    logger: baseLogger,
    trackEvent,
    validationErrorEvent: AnalyticsEvent.GRAVITY_INDEX_VALIDATION_ERROR,
  })
  if (!parsedBody.ok) return parsedBody.response

  const authed = await requireUserFromApiKey({
    req,
    getUserInfoFromApiKey,
    logger: baseLogger,
    loggerWithContext,
    trackEvent,
    authErrorEvent: AnalyticsEvent.GRAVITY_INDEX_AUTH_ERROR,
  })
  if (!authed.ok) return authed.response

  const { userId, logger } = authed.data
  const input = parsedBody.data
  const gravityApiKey = serverEnv.GRAVITY_API_KEY

  trackEvent({
    event: AnalyticsEvent.GRAVITY_INDEX_REQUEST,
    userId,
    properties: { action: input.action },
    logger,
  })

  if (gravityIndexActionRequiresApiKey(input.action) && !gravityApiKey) {
    logger.error('GRAVITY_API_KEY is not configured')
    trackEvent({
      event: AnalyticsEvent.GRAVITY_INDEX_ERROR,
      userId,
      properties: { reason: 'missing_gravity_api_key' },
      logger,