Compass/backend/api/src/update-options.ts

import {APIError, APIHandler} from 'api/helpers/endpoint'
import {createSupabaseDirectClient} from 'shared/supabase/init'
import {log} from 'shared/utils'
import {tryCatch} from 'common/util/try-catch'
import {OPTION_TABLES} from "common/profiles/constants";

export const updateOptions: APIHandler<'update-options'> = async (
  {table, names},
  auth
) => {
  if (!OPTION_TABLES.includes(table)) throw new APIError(400, 'Invalid table')
  if (!names || !Array.isArray(names) || names.length === 0) {
    throw new APIError(400, 'No names provided')
  }

  log('Updating profile options', {table, names})

  const pg = createSupabaseDirectClient()

  const profileIdResult = await pg.oneOrNone<{ id: number }>(
    'SELECT id FROM profiles WHERE user_id = $1',
    [auth.uid]
  )
  if (!profileIdResult) throw new APIError(404, 'Profile not found')
  const profileId = profileIdResult.id

  const result = await tryCatch(pg.tx(async (t) => {
    const ids: number[] = []
    for (const name of names) {
      const row = await t.one<{ id: number }>(
        `INSERT INTO ${table} (name, creator_id)
         VALUES ($1, $2)
         ON CONFLICT (name) DO UPDATE
             SET name = ${table}.name
         RETURNING id`,
        [name, auth.uid]
      )
      ids.push(row.id)
    }

    // Delete old options for this profile
    await t.none(`DELETE FROM profile_${table} WHERE profile_id = $1`, [profileId])

    // Insert new option_ids
    if (ids.length > 0) {
      const values = ids.map((id, i) => `($1, $${i + 2})`).join(', ')
      await t.none(
        `INSERT INTO profile_${table} (profile_id, option_id) VALUES ${values}`,
        [profileId, ...ids]
      )
    }

    return ids
  }))

  if (result.error) {
    log('Error updating profile options', result.error)
    throw new APIError(500, 'Error updating profile options')
  }

  return {updatedIds: result.data}
}