import * as couchbase from 'couchbase'

const COUCHBASE_USER = process.env.COUCHBASE_USER
const COUCHBASE_PASSWORD = process.env.COUCHBASE_PASSWORD
const COUCHBASE_ENDPOINT = process.env.COUCHBASE_ENDPOINT || 'localhost'
const COUCHBASE_BUCKET = process.env.COUCHBASE_BUCKET || 'travel-sample'
let IS_CLOUD_INSTANCE = process.env.IS_CLOUD_INSTANCE || 'false'

if (!COUCHBASE_USER) {
  throw new Error(
    'Please define the COUCHBASE_USER environment variable inside .env.local'
  )
}

if (!COUCHBASE_PASSWORD) {
  throw new Error(
    'Please define the COUCHBASE_PASSWORD environment variable inside .env.local'
  )
}

/**
 * Global is used here to maintain a cached connection across hot reloads
 * in development. This prevents connections growing exponentially
 * during API Route usage.
 */
let cached = global.couchbase

if (!cached) {
  cached = global.couchbase = { conn: null }
}

async function createCouchbaseCluster() {
  if (cached.conn) {
    return cached.conn
  }

  cached.conn = await couchbase.connect(
    'couchbase://' +
      COUCHBASE_ENDPOINT +
      (IS_CLOUD_INSTANCE === 'true'
        ? '?ssl=no_verify&console_log_level=5'
        : ''),
    {
      username: COUCHBASE_USER,
      password: COUCHBASE_PASSWORD,
    }
  )

  return cached.conn
}

export async function connectToDatabase() {
  const cluster = await createCouchbaseCluster()

  const bucket = cluster.bucket(COUCHBASE_BUCKET)
  const collection = bucket.defaultCollection()

  let dbConnection = {
    cluster,
    bucket,
    collection,
  }

  return dbConnection
}