test.js

'use strict'

const { test } = require('tap')
const Fastify = require('fastify')
const { createConnection } = require('typeorm')
const fastifyORM = require('./index')

test('Postgres available', async t => {
  const fastify = Fastify()
  fastify.register(fastifyORM, {
    host: 'localhost',
    type: 'postgres',
    port: '5432',
    password: '',
    database: 'postgres',
    username: 'postgres'
  })

  await fastify.ready()
  t.strictEqual(fastify.orm.name, 'default')
  await fastify.close()
})

test('Postgres available through env variables', async t => {
  process.env.TYPEORM_CONNECTION = 'postgres'
  process.env.TYPEORM_HOST = 'localhost'
  process.env.TYPEORM_USERNAME = 'postgres'
  process.env.TYPEORM_DATABASE = 'postgres'
  process.env.TYPEORM_PORT = '5432'
  const fastify = Fastify()
  fastify.register(fastifyORM)

  await fastify.ready()
  t.strictEqual(fastify.orm.name, 'default')
  await fastify.close()
})

test('with unreachable db', async t => {
  const fastify = Fastify()
  fastify.register(fastifyORM, { host: 'localhost', type: 'orm' })

  try {
    await fastify.ready()
    t.fail('should not boot successfully')
  } catch (err) {
    t.ok(err)
    await fastify.close()
  }
})

test('namespaced', async t => {
  const fastify = Fastify()
  fastify.register(fastifyORM, {
    host: 'localhost',
    type: 'postgres',
    port: '5432',
    password: '',
    database: 'postgres',
    username: 'postgres',
    namespace: 'con1'
  })

  await fastify.ready()
  t.strictEqual(fastify.orm.con1.name, 'default')
  await fastify.close()
})

test('custom client', async t => {
  const connection = await createConnection({
    host: 'localhost',
    type: 'postgres',
    port: '5432',
    password: '',
    database: 'postgres',
    username: 'postgres'
  })

  const fastify = Fastify()
  fastify.register(fastifyORM, { connection })

  await fastify.ready()
  t.strictEqual(fastify.orm.name, 'default')
  await fastify.close()
})

test('multiple bindings to the same namespace', async t => {
  const connection = await createConnection({
    host: 'localhost',
    type: 'postgres',
    port: '5432',
    password: '',
    database: 'postgres',
    username: 'postgres'
  })

  const fastify = Fastify()
  fastify.register(fastifyORM, { connection, namespace: 'test' })
  fastify.register(fastifyORM, { connection, namespace: 'test' })

  try {
    await fastify.ready()
    t.fail('should not boot successfully')
  } catch (err) {
    t.ok(err)
    await fastify.close()
  }
})