const Sequelize = require('sequelize');
const extendSequelize = require('sequelize-extension');
const enhanceTracking = require('sequelize-extension-tracking');

const sequelize = new Sequelize(...);

const db = {};
db.Project = sequelize.define('project', {
  name: Sequelize.STRING(255),
}, { 
  history: true 
});
db.Task = sequelize.define('task', {
  name: Sequelize.STRING(255),
}, { 
  history: false 
});
db.User = sequelize.define('user', {
  username: Sequelize.STRING(255),
}, { 
  history: false 
});
db.Task.belongsTo(Project);
db.User.belongsToMany(Project, { through: 'userProjects' });
db.Project.belongsToMany(User, { through: 'userProjects', extendHistory: true });
db.Project.hasMany(Task, { extendHistory: true });

extendSequelize(db, {
  tracking: enhanceTracking({
    log: logs => console.log(logs),
  }),
});

const project = await db.Project.create({ name: 'My Project' });
// [
//   type: 'UPDATE',
//   reference: 'project-1',
//   data: {
//     id: 1,
//     type: 'project',
//     before: {},
//     after: { name: 'My Project' }
//   },
//   executionTime: 1000 (nanoseconds)
// ]
const user = await db.User.create({ username: 'gabriel@test.com' });
await project.addUser(user);
// [
//   reference: 'project-1',
//   ...
//     before: { users: [] },
//     after: { users: [{ id: 1, username: 'gabriel@test.com' }] }
//   ...
// ]
const task = await db.Task.create({ name: 'Test', projectId: 1 });
// [
//   reference: 'project-1',
//   ...
//     before: { tasks: [] },
//     after: { tasks: [{ id: 1, name: 'Test'}] }
//   ...
// ]

const Sequelize = require('sequelize');
const extendSequelize = require('sequelize-extension');
const enhanceTracking = require('sequelize-extension-tracking');

const sequelize = new Sequelize(...);

const db = {};
db.Log = sequelize.define('log', {
  id: {
    allowNull: false,
    autoIncrement: true,
    primaryKey: true,
    type: Sequelize.BIGINT,
  },
  type: {
    allowNull: false,
    type: Sequelize.ENUM('UPDATE', 'ERROR', 'REQUEST', 'DELETE'),
  },
  reference: {
    allowNull: true,
    type: Sequelize.STRING(64),
  },
  data: {
    allowNull: false,
    type: Sequelize.TEXT,
  },
  executionTime: {
    allowNull: true,
    type: Sequelize.FLOAT,
  },
  createdAt: {
    allowNull: true,
    type: Sequelize.DATE,
  },
}, {
  timestamps: true,
  updatedAt: false,
  tableName: 'logs',
  freezeTableName: true,
  history: false, // make sure the logging table has no history
});

db.Log.log = async function log(values, options) {
  values.forEach((v) => {
    v.data = JSON.stringify(v.data);
  });
  return this.bulkCreate(values, { transaction: options.transaction });
};

// ...

extendSequelize(db, {
  tracking: enhanceTracking({
    log: async (logs, options) => {
      return db.Log.log(logs, options);
    },
  }),
});