personae/server/utils/executeQuery.js

const LOG_RESULT = false
const RESPONSE_DELAY = null

export default async function executeQuery({
  callback,
  user,
  resource,
  permissions,
  id,
  data,
  idValidator = _identity,
  validator = _identity,
  mutator = _identity,
  query = _noop
}) {
  try {
    if (permissions) {
      await authorize(user, resource, permissions)
    }

    let validId, validData

    if (id) {
      validId = idValidator(id)
    }

    if (data) {
      validData = validator(data)
    }

    const rawResult = await query({ id: validId, data: validData })
    const result = mutator(rawResult)

    if (LOG_RESULT) {
      console.log("[executeQuery]")
      console.dir(result)
    }

    if (RESPONSE_DELAY) {
      console.log("[executeQuery] [response delay]", RESPONSE_DELAY)
      await sleep(RESPONSE_DELAY)
    }

    callback({ data: result })
    return result
  } catch (error) {
    console.error("[executeQuery]", error)

    callback({ error })
  }
}