db/models/codes.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

const { DataTypes } = require('sequelize');

const attributes = {
  code: {
    type: DataTypes.STRING(255),
    allowNull: false,
    defaultValue: null,
    primaryKey: true,
    autoIncrement: false,
    comment: null,
    field: "code"
  },
  text: {
    type: DataTypes.TEXT,
    allowNull: true,
    defaultValue: null,
    primaryKey: false,
    autoIncrement: false,
    comment: null,
    field: "text"
  },
};

const options = {
  tableName: "codes",
  comment: "",
  indexes: [],
  timestamps: false
};

db["Code"] = db.define("codes_model", attributes, options);
const WebSocket = require("ws");

module.exports = () => {
  binance = new WebSocket("wss://stream.binance.com:9443/ws/btcusdt@ticker");

  binance.onmessage = async function (event) {
    try {
      let msg = JSON.parse(event.data);

      let fx = app.get("fx");
      if (!fx) return;
      let rates = {};

      Object.keys(fx).map((symbol) => {
        rates[symbol] = msg.c * fx[symbol];
      });

      app.set("ask", msg.a);
      app.set("bid", msg.b);
      app.set("last", msg.c);
      app.set("rates", rates);
    } catch (e) {
      l.error("binance message error", e.message);
    }
  };

  binance.onerror = async function (error) {
    console.log("binance socket error", error);
  } 

  return binance;
};