import knex from './services/knex';
import User from './models/User';
import fluorite from './services/fluorite';

beforeEach(async () => {
  await knex.schema.createTable('users', (table) => {
    table.increments();
    table.string('name').unsigned().notNullable();
  });

  await knex('users').insert({ id: 1, name: 'John Doe' });
  await knex('users').insert({ id: 2, name: 'Bob Marley' });
  await knex('users').insert({ id: 3, name: 'Billy Boy' });

  await knex.schema.createTable('posts', (table) => {
    table.increments();
    table.string('title').notNullable();
    table.integer('user_id').unsigned().notNullable().references('users.id');
  });

  await knex('posts').insert({ id: 1, title: 'Post #1', user_id: 1 });
  await knex('posts').insert({ id: 2, title: 'Post #2', user_id: 1 });
  await knex('posts').insert({ id: 3, title: 'Post #3', user_id: 2 });
});

afterEach(async () => {
  await knex.schema.dropTable('posts');
  await knex.schema.dropTable('users');
});

describe('Transactions', () => {
  it('Single action', async () => {
    await fluorite.transaction(async () => {
      const user = await User.find(1);
      await user.save({ name: 'Alan Davey' });
    });
  });

  it('Multiple action', async () => {
    await fluorite.transaction(async () => {
      const user = await User.find<User>(1);
      await user.posts().update({ title: 'New Title' });
    });
  });

  it('Return value from transaction', async () => {
    const posts = await fluorite.transaction(async () => {
      const user = await User.find<User>(1);
      await user.posts().update({ title: 'New Title' });
      return user.posts();
    });
    expect(posts).toBeInstanceOf(Array);
    expect(posts.length).toBe(2);
    posts.forEach(post => expect(post.get('title')).toBe('New Title'));
  });
});