import {
  calculateOffset,
  calculateRetryDelay,
  createPaginationResult,
  DatabaseNotFoundError,
  DEFAULT_RETRY_CONFIG,
  isConnectionError,
  isConstraintViolation,
  NotFoundError,
  normalizePagination,
  PaginationParams,
  PaginationResult,
  RetryConfig,
  retryOperation,
  sleep,
  TransactionCallback,
  takeFirst,
  takeFirstOrThrow,
} from '@g-1/util'

import { text } from 'drizzle-orm/sqlite-core'
import { InternalError, NotFound } from '../utils/exceptions.js'

// Re-export database utilities
export {
  calculateOffset,
  calculateRetryDelay,
  createPaginationResult,
  DatabaseNotFoundError,
  DEFAULT_RETRY_CONFIG,
  isConnectionError,
  isConstraintViolation,
  normalizePagination,
  NotFoundError,
  PaginationParams,
  PaginationResult,
  RetryConfig,
  retryOperation,
  sleep,
  takeFirst,
  takeFirstOrThrow,
  TransactionCallback,
}

// Legacy alias
export const QueryNotFoundError = DatabaseNotFoundError

/* -------------------------------------------------------------------------- */
/*                                 Repository                                 */
/* -------------------------------------------------------------------------- */

/**
 * Take the first result from a query or throw a generic error
 */
export function takeFirstOrThrowGeneric<T>(values: T[], message?: string): T {
  if (values.length === 0) {
    throw new NotFoundError(message || 'Record not found')
  }
  return values[0]
}

/**
 * Take the first result from a query or throw an HTTP error
 */
export function takeFirstOrThrowHttp<T>(values: T[], message?: string): T {
  try {
    return takeFirstOrThrowGeneric(values, message)
  } catch (error) {
    if (error instanceof NotFoundError) {
      throw NotFound(error.message)
    } else {
      throw InternalError((error as Error).message)
    }
  }
}

/* -------------------------------------------------------------------------- */
/*                                   Tables                                   */
/* -------------------------------------------------------------------------- */

// timestamps for created_at and updated_at
// Using ISO strings for better performance and consistency
const getCurrentISOString = () => new Date().toISOString()

export const timestamps = {
  createdAt: text('created_at').$defaultFn(getCurrentISOString),
  updatedAt: text('updated_at').$defaultFn(getCurrentISOString).$onUpdate(getCurrentISOString),
  deletedAt: text('deleted_at'),
}