Function assertSchemaCompatibility

apps/realtime/src/database/preflight.ts:65–98

()

 *   across {@link MAX_CONNECT_ATTEMPTS} attempts.
 */
export async function assertSchemaCompatibility(): Promise<void> {
  let lastError: unknown

  for (let attempt = 1; attempt <= MAX_CONNECT_ATTEMPTS; attempt++) {
    try {
      await db.select().from(workflow).limit(1)
      logger.info('Schema-compatibility check passed')
      return
    } catch (error) {
      lastError = error

      if (isSchemaMismatch(error)) {
        throw new Error(
          `Deployed image is incompatible with the live database schema: ${getErrorMessage(error)}`
        )
      }

      if (attempt === MAX_CONNECT_ATTEMPTS) {
        break
      }

      const delay = backoffWithJitter(attempt, null)
      logger.warn(
        `Schema-compatibility check could not reach the database (attempt ${attempt}/${MAX_CONNECT_ATTEMPTS}), retrying in ${Math.round(delay)}ms`,
        getErrorMessage(error)
      )
      await sleep(delay)
    }
  }

  throw new Error(
    `Schema-compatibility check failed after ${MAX_CONNECT_ATTEMPTS} attempts — database unreachable: ${getErrorMessage(lastError)}`
  )
}