Compass/backend/shared/src/utils.ts

import {convertPrivateUser, convertUser} from 'common/supabase/users'
import {PrivateUser, User} from 'common/user'
import {log, type Logger} from 'shared/monitoring/log'
import {metrics} from 'shared/monitoring/metrics'
import {createSupabaseDirectClient, SupabaseDirectClient} from 'shared/supabase/init'

export {metrics}
export {log, type Logger}

export const getUser = async (
  userId: string,
  pg: SupabaseDirectClient = createSupabaseDirectClient(),
) => {
  return await pg.oneOrNone(
    `select *
     from users
     where id = $1
     limit 1`,
    [userId],
    convertUser,
  )
}

export const getPrivateUser = async (
  userId: string,
  pg: SupabaseDirectClient = createSupabaseDirectClient(),
) => {
  return await pg.oneOrNone(
    `select *
     from private_users
     where id = $1
     limit 1`,
    [userId],
    convertPrivateUser,
  )
}

export const getUserByUsername = async (
  username: string,
  pg: SupabaseDirectClient = createSupabaseDirectClient(),
) => {
  const res = await pg.oneOrNone(
    `select *
     from users
     where username ilike $1`,
    username,
  )

  return res ? convertUser(res) : null
}

export const getPrivateUserByKey = async (
  apiKey: string,
  pg: SupabaseDirectClient = createSupabaseDirectClient(),
) => {
  return await pg.oneOrNone(
    `select *
     from private_users
     where data ->> 'apiKey' = $1
     limit 1`,
    [apiKey],
    convertPrivateUser,
  )
}

export const getAllUsers = async (): Promise<User[]> => {
  const pg: SupabaseDirectClient = createSupabaseDirectClient()
  const res = await pg.manyOrNone(`select * from users`)
  return res.map(convertUser)
}

export const getAllPrivateUsers = async (): Promise<PrivateUser[]> => {
  const pg: SupabaseDirectClient = createSupabaseDirectClient()
  const res = await pg.manyOrNone(`select * from private_users`)
  return res.map(convertPrivateUser)
}