Base Strategy

config/config.json

@@ -2,21 +2,21 @@
   "development": {
     "username": "root",
     "password": "example",
-    "database": "bot",
+    "database": "tradebot",
     "host": "127.0.0.1",
     "dialect": "postgres"
   },
   "test": {
     "username": "root",
     "password": "example",
-    "database": "bot",
+    "database": "tradebot",
     "host": "127.0.0.1",
     "dialect": "postgres"
   },
   "production": {
     "username": "root",
     "password": "example",
-    "database": "bot",
+    "database": "tradebot",
     "host": "127.0.0.1",
     "dialect": "postgres"
   }

constant.js

@@ -67,8 +67,19 @@ const SYMBOL = {
   ETHUSDT: 'ETHUSDT',
   BTCUSDT: 'BTCUSDT',
 }
+
+
+const STRATEGY = {
+  STATUS:{
+    WAIT_ENTRY_POINT:'WAIT_ENTRY_POINT',
+    IN_PROGRESS:'IN_PROGRESS',
+    COMPLETED:'COMPLETED'
+  }
+}
+
 module.exports = {
   ORDER,
   K_LINE,
   SYMBOL,
+  STRATEGY
 }

db/index.js

@@ -1,6 +1,7 @@
 const defineModels = require('../models');
 const defineProviders = require('../providers');
 const { Sequelize } = require('sequelize');
+const config = require('../config');
 
 async function initDB(config) {
   const sequelize = new Sequelize({
@@ -26,4 +27,4 @@ async function initDB(config) {
   });
 }
 
-module.exports = initDB;
+module.exports = initDB(config);

docker-compose.yml

@@ -9,7 +9,7 @@ services:
     environment:
       POSTGRES_USER: root
       POSTGRES_PASSWORD: example
-      POSTGRES_DB: bot
+      POSTGRES_DB: tradebot
     ports:
       - 5432:5432
     networks:

helpers/asynQueue.js

@@ -0,0 +1,42 @@
+class AsyncQueue {
+  constructor(options = {}) {
+    const { log, error } = options;
+    this.log = log || console.log;
+    this.error = error || console.error;
+    this.queue = [];
+    this.isRunning = false;
+  }
+
+  addToQueue(func, data) {
+    this.queue.push({ func, data });
+  }
+
+  emitInQueue = (func, data) => {
+    this.addToQueue(func, data);
+    this.runQueue();
+  };
+
+  runQueue() {
+    if (this.isRunning) {
+      return;
+    }
+    this.isRunning = true;
+    this.runNext().catch((e) => this.error('runQueue error', e));
+  }
+
+  async runNext() {
+    if (this.queue.length === 0) {
+      this.isRunning = false;
+      return;
+    }
+    const { func, data } = this.queue.splice(0, 1)[0];
+    if (typeof func === 'function') {
+      await func(data);
+    } else {
+      this.log('function in queue not found', { func, data });
+    }
+    await this.runNext();
+  }
+}
+
+module.exports = AsyncQueue;

index.js

@@ -0,0 +1,17 @@
+const path = require('path')
+const initConfig = require('./config')
+const initDB = require('./db')
+
+const ROOT_PATH = process.cwd();
+
+(async function () {
+  const config = await initConfig(path.resolve(ROOT_PATH, 'config'))
+
+  const db = await initDB()
+  application.services = { db, config }
+
+
+  await application.start(true)
+
+  logger.info('Application started')
+})()

migrations/20210602202235-order.js

@@ -39,23 +39,23 @@ module.exports = {
         allowNull: true
       },
       price: {
-        type: Sequelize.REAL, // ???
+        type: Sequelize.REAL,
         allowNull: true
       },
       avg_price: {
-        type: Sequelize.REAL, // ???
+        type: Sequelize.REAL,
         allowNull: true
       },
       activate_price: {
-        type: Sequelize.REAL, // ???
+        type: Sequelize.REAL,
         allowNull: true
       },
       price_rate: {
-        type: Sequelize.REAL, // ???
+        type: Sequelize.REAL,
         allowNull: true
       },
       stop_price: {
-        type: Sequelize.REAL, // ???
+        type: Sequelize.REAL,
         allowNull: true
       },
       side: {
@@ -83,7 +83,7 @@ module.exports = {
         allowNull: true
       },
       update_time: {
-        type: Sequelize.STRING, // ??? DATE
+        type: Sequelize.STRING,
         allowNull: true
       },
       working_type: {
@@ -94,19 +94,6 @@ module.exports = {
         type: Sequelize.JSONB,
         allowNull: true
       },
-      created_at: {
-        type: Sequelize.DATE,
-        allowNull: true,
-        defaultValue: Sequelize.literal('CURRENT_TIMESTAMP')
-      },
-      updated_at: {
-        type: Sequelize.DATE,
-        allowNull: true
-      },
-      deleted_at: {
-        type: Sequelize.DATE,
-        allowNull: true
-      },
       commission: {
         type: Sequelize.REAL,
         allowNull: true

migrations/20210703122401-strategy.js

@@ -0,0 +1,68 @@
+'use strict';
+
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    await queryInterface.createTable('strategy', {
+      id: {
+        autoIncrement: true,
+        type: Sequelize.BIGINT,
+        allowNull: false,
+        primaryKey: true
+      },
+      status: {
+        type: Sequelize.STRING,
+        allowNull: false
+      },
+      profit: {
+        type: Sequelize.REAL,
+        allowNull: true
+      },
+      position_side: {
+        type: Sequelize.STRING,
+        allowNull: true
+      },
+      symbol: {
+        type: Sequelize.STRING,
+        allowNull: true
+      },
+      type: {
+        type: Sequelize.STRING,
+        allowNull: true
+      },
+      options:{
+        type: Sequelize.JSONB,
+        allowNull: true,
+      },
+      user_id: {
+        type: Sequelize.BIGINT,
+        allowNull: false,
+        references: {
+          model: {
+            tableName: 'user'
+          },
+          key: 'id'
+        },
+        onUpdate: 'cascade',
+        onDelete: 'cascade'
+      },
+      createdAt: {
+        type: Sequelize.DATE,
+        allowNull: false,
+        defaultValue: Sequelize.literal('CURRENT_TIMESTAMP'),
+      },
+      updatedAt: {
+        type: Sequelize.DATE,
+        allowNull: false,
+        defaultValue: Sequelize.literal('CURRENT_TIMESTAMP'),
+      },
+      deletedAt: {
+        type: Sequelize.DATE,
+        allowNull: true,
+      },
+    })
+  },
+
+  down: (queryInterface) => {
+    return queryInterface.dropTable('strategy');
+  }
+};

models/index.js

@@ -1,6 +1,7 @@
 'use strict'
 const user = require('./user')
 const order = require('./order')
+const strategy = require('./strategy')
 
 /**
  *
@@ -11,6 +12,7 @@ function defineModels(sequelize) {
   [
     order(sequelize),
     user(sequelize),
+    strategy(sequelize),
   ].map((model) => {
     if (model.associate) {
       model.associate(sequelize.models)

models/strategy.js

@@ -0,0 +1,66 @@
+const { Model, DataTypes } = require('sequelize')
+
+class Strategy extends Model {
+  static associate(models) {
+    Strategy.hasMany(models.Order, {
+      foreignKey: 'strategyId',
+      sourceKey: 'id',
+      as: 'orders'
+    });
+  }
+}
+module.exports = function (sequelize) {
+  return Strategy.init(
+    {
+      id: {
+        autoIncrement: true,
+        type: DataTypes.BIGINT,
+        allowNull: false,
+        primaryKey: true
+      },
+      status: {
+        type: DataTypes.STRING,
+        allowNull: false
+      },
+      profit: {
+        type: DataTypes.REAL,
+        allowNull: true
+      },
+      positionSide: {
+        type: DataTypes.STRING,
+        allowNull: true
+      },
+      symbol: {
+        type: DataTypes.STRING,
+        allowNull: true
+      },
+      type: {
+        type: DataTypes.STRING,
+        allowNull: true
+      },
+      options:{
+        type: DataTypes.JSONB,
+        allowNull: true,
+      },
+      userId: {
+        type: DataTypes.BIGINT,
+        allowNull: false,
+        references: {
+          model: {
+            tableName: 'user'
+          },
+          key: 'id'
+        },
+        onUpdate: 'cascade',
+        onDelete: 'cascade'
+      },
+    },
+    {
+      sequelize,
+      tableName: 'strategy',
+      timestamps: true,
+    },
+  )
+}
+
+module.exports.Strategy = Strategy

models/user.js

@@ -19,11 +19,11 @@ module.exports = function (sequelize) {
         type: DataTypes.STRING,
         allowNull: false
       },
-      binance_api_key: {
+      binanceApiKey: {
         type: DataTypes.STRING,
         allowNull: true
       },
-      binance_api_secret: {
+      binanceApiSecret: {
         type: DataTypes.STRING,
         allowNull: true
       },

package.json

@@ -8,6 +8,7 @@
     "migrate": "node_modules/sequelize-cli/lib/sequelize db:migrate",
     "migrate:undo": "sequelize-cli db:migrate:undo",
     "migrate:undo:all": "sequelize-cli db:migrate:undo:all",
+    "migrate:add": "sequelize-cli migration:generate --name x",
     "seed": "sequelize-cli db:seed:all",
     "seed:undo": "sequelize-cli db:seed:undo",
     "seed:undo:all": "sequelize-cli db:seed:undo:all"