5092 lines
161 KiB
JavaScript
5092 lines
161 KiB
JavaScript
module.exports = {
|
|
/**
|
|
* @param {QueryInterface} queryInterface
|
|
* @param {Sequelize} Sequelize
|
|
* @returns {Promise<void>}
|
|
*/
|
|
async up(queryInterface, Sequelize) {
|
|
/**
|
|
* @type {Transaction}
|
|
*/
|
|
const transaction = await queryInterface.sequelize.transaction();
|
|
try {
|
|
|
|
|
|
await queryInterface.createTable('users', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('roles', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('permissions', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('exchanges', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('api_credentials', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('trading_pairs', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('strategies', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('strategy_parameters', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('news_sources', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('bot_sessions', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('session_strategies', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('market_candles', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('technical_indicators', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('trade_signals', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('orders', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('positions', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('session_events', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('roi_snapshots', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('backtest_runs', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
await queryInterface.createTable('optimization_runs', {
|
|
id: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
defaultValue: Sequelize.DataTypes.UUIDV4,
|
|
primaryKey: true,
|
|
},
|
|
createdById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
updatedById: {
|
|
type: Sequelize.DataTypes.UUID,
|
|
references: {
|
|
key: 'id',
|
|
model: 'users',
|
|
},
|
|
},
|
|
createdAt: { type: Sequelize.DataTypes.DATE },
|
|
updatedAt: { type: Sequelize.DataTypes.DATE },
|
|
deletedAt: { type: Sequelize.DataTypes.DATE },
|
|
importHash: {
|
|
type: Sequelize.DataTypes.STRING(255),
|
|
allowNull: true,
|
|
unique: true,
|
|
},
|
|
}, { transaction });
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'firstName',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'lastName',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'phoneNumber',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'email',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'disabled',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'password',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'emailVerified',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'emailVerificationToken',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'emailVerificationTokenExpiresAt',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'passwordResetToken',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'passwordResetTokenExpiresAt',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'provider',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'users',
|
|
'app_roleId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'roles',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roles',
|
|
'name',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roles',
|
|
'role_customization',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'permissions',
|
|
'name',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'exchanges',
|
|
'name',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'exchanges',
|
|
'exchange_code',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['binance','kraken'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'exchanges',
|
|
'base_url',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'exchanges',
|
|
'supports_spot',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'exchanges',
|
|
'supports_futures',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'exchanges',
|
|
'is_enabled',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'userId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'users',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'exchangeId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'exchanges',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'label',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'api_key',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'api_secret',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'passphrase',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'is_active',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'api_credentials',
|
|
'last_validated_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'exchangeId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'exchanges',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'symbol',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'base_asset',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'quote_asset',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'price_precision',
|
|
{
|
|
type: Sequelize.DataTypes.INTEGER,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'quantity_precision',
|
|
{
|
|
type: Sequelize.DataTypes.INTEGER,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trading_pairs',
|
|
'is_active',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategies',
|
|
'name',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategies',
|
|
'category',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['moving_averages','breakout','price_action','pullback','mean_reversion','news_trading'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategies',
|
|
'description',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategies',
|
|
'is_active',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategies',
|
|
'default_timeframe_minutes',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategies',
|
|
'min_history_bars',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'strategyId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'strategies',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'param_name',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'param_type',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['int','decimal','boolean','string','enum'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'default_value',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'min_value',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'max_value',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'allowed_values',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'strategy_parameters',
|
|
'notes',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'news_sources',
|
|
'name',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'news_sources',
|
|
'provider',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'news_sources',
|
|
'endpoint_url',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'news_sources',
|
|
'importance_filter',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['low','medium','high','all'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'news_sources',
|
|
'is_enabled',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'userId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'users',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'exchangeId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'exchanges',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'api_credentialId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'api_credentials',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'trading_pairId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trading_pairs',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'status',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['created','running','paused','stopped','error'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'simulation_mode',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'investment_amount',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'risk_percent',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'target_profit_percent',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'timeframe',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['1m','3m','5m','15m','30m','1h','4h','1d'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'started_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'stopped_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'bot_sessions',
|
|
'notes',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'strategyId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'strategies',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'is_enabled',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'weight',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'parameter_overrides',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'enabled_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_strategies',
|
|
'disabled_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'trading_pairId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trading_pairs',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'timeframe',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['1m','3m','5m','15m','30m','1h','4h','1d'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'open_time',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'close_time',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'open_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'high_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'low_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'close_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'volume',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'quote_volume',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'market_candles',
|
|
'trade_count',
|
|
{
|
|
type: Sequelize.DataTypes.INTEGER,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'market_candleId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'market_candles',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'indicator_type',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['sma','ema','rsi','macd','atr','bollinger_bands','stochastic','adx'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'period',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'value_primary',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'value_secondary',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'value_tertiary',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'meta',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'technical_indicators',
|
|
'computed_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'strategyId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'strategies',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'market_candleId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'market_candles',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'signal_type',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['buy','sell','close','hold'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'confidence_level',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['low','medium','high'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'confidence_score',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'suggested_entry_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'suggested_stop_loss_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'suggested_take_profit_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'rationale',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'trade_signals',
|
|
'signaled_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'trade_signalId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trade_signals',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'trading_pairId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trading_pairs',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'side',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['buy','sell'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'order_type',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['market','limit','stop','take_profit'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'status',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['new','submitted','partially_filled','filled','canceled','rejected','error'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'quantity',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'filled_quantity',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'avg_fill_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'exchange_order_ref',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'is_simulated',
|
|
{
|
|
type: Sequelize.DataTypes.BOOLEAN,
|
|
|
|
defaultValue: false,
|
|
allowNull: false,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'submitted_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'finalized_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'orders',
|
|
'error_message',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'trading_pairId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trading_pairs',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'side',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['long','short'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'status',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['open','closing','closed'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'entry_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'quantity',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'stop_loss_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'take_profit_price',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'realized_pnl',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'unrealized_pnl',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'opened_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'positions',
|
|
'closed_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_events',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_events',
|
|
'event_type',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['bot_start','bot_stop','bot_pause','bot_resume','data_update','signal_generated','order_submitted','order_filled','position_opened','position_closed','risk_check','error','info'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_events',
|
|
'severity',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['debug','info','warning','error','critical'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_events',
|
|
'message',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_events',
|
|
'payload',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'session_events',
|
|
'event_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'bot_sessionId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'bot_sessions',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'period_start_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'period_end_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'starting_equity',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'ending_equity',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'profit_loss_amount',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'roi_percent',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'roi_snapshots',
|
|
'closed_trades_count',
|
|
{
|
|
type: Sequelize.DataTypes.INTEGER,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'userId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'users',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'strategyId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'strategies',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'exchangeId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'exchanges',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'trading_pairId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trading_pairs',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'status',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['queued','running','completed','failed','canceled'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'timeframe',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['1m','3m','5m','15m','30m','1h','4h','1d'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'from_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'to_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'starting_balance',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'ending_balance',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'net_profit',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'max_drawdown_percent',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'win_rate_percent',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'trades_count',
|
|
{
|
|
type: Sequelize.DataTypes.INTEGER,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'backtest_runs',
|
|
'report_notes',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'userId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'users',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'strategyId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'strategies',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'exchangeId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'exchanges',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'trading_pairId',
|
|
{
|
|
type: Sequelize.DataTypes.UUID,
|
|
|
|
|
|
|
|
references: {
|
|
model: 'trading_pairs',
|
|
key: 'id',
|
|
},
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'status',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['queued','running','completed','failed','canceled'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'objective',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['max_profit','max_sharpe','min_drawdown','max_profit_factor','custom'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'timeframe',
|
|
{
|
|
type: Sequelize.DataTypes.ENUM,
|
|
|
|
|
|
values: ['1m','3m','5m','15m','30m','1h','4h','1d'],
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'from_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'to_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'iterations',
|
|
{
|
|
type: Sequelize.DataTypes.INTEGER,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'search_space',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'best_score',
|
|
{
|
|
type: Sequelize.DataTypes.DECIMAL,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'best_parameters',
|
|
{
|
|
type: Sequelize.DataTypes.TEXT,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await queryInterface.addColumn(
|
|
'optimization_runs',
|
|
'completed_at',
|
|
{
|
|
type: Sequelize.DataTypes.DATE,
|
|
|
|
|
|
|
|
},
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
await transaction.commit();
|
|
} catch (err) {
|
|
await transaction.rollback();
|
|
throw err;
|
|
}
|
|
},
|
|
/**
|
|
* @param {QueryInterface} queryInterface
|
|
* @param {Sequelize} Sequelize
|
|
* @returns {Promise<void>}
|
|
*/
|
|
async down(queryInterface, Sequelize) {
|
|
/**
|
|
* @type {Transaction}
|
|
*/
|
|
const transaction = await queryInterface.sequelize.transaction();
|
|
try {
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'completed_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'best_parameters',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'best_score',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'search_space',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'iterations',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'to_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'from_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'timeframe',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'objective',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'status',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'trading_pairId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'exchangeId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'strategyId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'optimization_runs',
|
|
'userId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'report_notes',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'trades_count',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'win_rate_percent',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'max_drawdown_percent',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'net_profit',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'ending_balance',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'starting_balance',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'to_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'from_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'timeframe',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'status',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'trading_pairId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'exchangeId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'strategyId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'backtest_runs',
|
|
'userId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'closed_trades_count',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'roi_percent',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'profit_loss_amount',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'ending_equity',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'starting_equity',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'period_end_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'period_start_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roi_snapshots',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_events',
|
|
'event_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_events',
|
|
'payload',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_events',
|
|
'message',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_events',
|
|
'severity',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_events',
|
|
'event_type',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_events',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'closed_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'opened_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'unrealized_pnl',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'realized_pnl',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'take_profit_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'stop_loss_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'quantity',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'entry_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'status',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'side',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'trading_pairId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'positions',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'error_message',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'finalized_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'submitted_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'is_simulated',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'exchange_order_ref',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'avg_fill_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'filled_quantity',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'quantity',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'status',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'order_type',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'side',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'trading_pairId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'trade_signalId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'orders',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'signaled_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'rationale',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'suggested_take_profit_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'suggested_stop_loss_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'suggested_entry_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'confidence_score',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'confidence_level',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'signal_type',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'market_candleId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'strategyId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trade_signals',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'computed_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'meta',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'value_tertiary',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'value_secondary',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'value_primary',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'period',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'indicator_type',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'market_candleId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'technical_indicators',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'trade_count',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'quote_volume',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'volume',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'close_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'low_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'high_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'open_price',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'close_time',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'open_time',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'timeframe',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'market_candles',
|
|
'trading_pairId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'disabled_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'enabled_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'parameter_overrides',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'weight',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'is_enabled',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'strategyId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'session_strategies',
|
|
'bot_sessionId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'notes',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'stopped_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'started_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'timeframe',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'target_profit_percent',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'risk_percent',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'investment_amount',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'simulation_mode',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'status',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'trading_pairId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'api_credentialId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'exchangeId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'bot_sessions',
|
|
'userId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'news_sources',
|
|
'is_enabled',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'news_sources',
|
|
'importance_filter',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'news_sources',
|
|
'endpoint_url',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'news_sources',
|
|
'provider',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'news_sources',
|
|
'name',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'notes',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'allowed_values',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'max_value',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'min_value',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'default_value',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'param_type',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'param_name',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategy_parameters',
|
|
'strategyId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategies',
|
|
'min_history_bars',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategies',
|
|
'default_timeframe_minutes',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategies',
|
|
'is_active',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategies',
|
|
'description',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategies',
|
|
'category',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'strategies',
|
|
'name',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'is_active',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'quantity_precision',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'price_precision',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'quote_asset',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'base_asset',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'symbol',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'trading_pairs',
|
|
'exchangeId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'last_validated_at',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'is_active',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'passphrase',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'api_secret',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'api_key',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'label',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'exchangeId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'api_credentials',
|
|
'userId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'exchanges',
|
|
'is_enabled',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'exchanges',
|
|
'supports_futures',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'exchanges',
|
|
'supports_spot',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'exchanges',
|
|
'base_url',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'exchanges',
|
|
'exchange_code',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'exchanges',
|
|
'name',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'permissions',
|
|
'name',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roles',
|
|
'role_customization',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'roles',
|
|
'name',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'app_roleId',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'provider',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'passwordResetTokenExpiresAt',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'passwordResetToken',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'emailVerificationTokenExpiresAt',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'emailVerificationToken',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'emailVerified',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'password',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'disabled',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'email',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'phoneNumber',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'lastName',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.removeColumn(
|
|
'users',
|
|
'firstName',
|
|
{ transaction }
|
|
);
|
|
|
|
|
|
|
|
await queryInterface.dropTable('optimization_runs', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('backtest_runs', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('roi_snapshots', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('session_events', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('positions', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('orders', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('trade_signals', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('technical_indicators', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('market_candles', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('session_strategies', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('bot_sessions', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('news_sources', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('strategy_parameters', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('strategies', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('trading_pairs', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('api_credentials', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('exchanges', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('permissions', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('roles', { transaction });
|
|
|
|
|
|
|
|
await queryInterface.dropTable('users', { transaction });
|
|
|
|
|
|
await transaction.commit();
|
|
} catch (err) {
|
|
await transaction.rollback();
|
|
throw err;
|
|
}
|
|
}
|
|
};
|