Refactor structure

bridgedb/README.md

@@ -0,0 +1,12 @@
+<p align="center">
+  <a href="https://www.proximax.io/">
+    <img src="https://www.proximax.io/user/themes/proximaxvrs1/images/logo.png" alt="Logo" width=280 height=60>
+  </a>
+  <h3 align="center">ProximaX Dex bridedb</h3>
+</p>
+  <p>
+
+</p>
+<p align="center">
+    <a href="https://t.me/proximaxhelpdesk">Report bug</a>
+  </p>

bridgedb/lib/blockchain-provider.js

@@ -0,0 +1,18 @@
+const sdk = require('tsjs-xpx-chain-sdk')
+
+class BlockchainProvider {
+  constructor (node) {
+    console.log(node)
+  }
+
+  /**
+   *
+   * @param {(string | number[])} id
+   * @returns {MosaicId}
+   * @memberof BlockchainProvider
+   */
+  getMosaicId (id) {
+    return new sdk.MosaicId(id)
+  }
+}
+module.exports = BlockchainProvider

bridgedb/lib/db.js

@@ -0,0 +1,83 @@
+const r = require('rethinkdb')
+const Log = require('./log')
+
+const DB = {
+  conn: null,
+  connStruc: null,
+  name: 'dexWallet',
+  host: 'localhost',
+  port: 32769,
+  tables: [
+    { table: 'executeOffers', options: {} },
+    { table: 'mosaicInfo', options: { primaryKey: 'mosaicIdHex' } }
+  ],
+  // host: '192.168.1.70',
+  async connect () {
+    try {
+      Log.info('   >> Connecting to RethinkDB...')
+      const host = process.env.db_host || DB.host // 192.168.3.242
+      const port = process.env.db_port || DB.port //
+      const db = process.env.db_name || undefined
+      const user = process.env.db_user || undefined
+      const password = process.env.db_password || undefined
+
+      DB.conn = await r.connect({ host, port, db, user, password })
+      DB.dbCreateStrusture()
+      Log.info('   >> RethinkDB connected')
+    } catch (error) {
+      console.error(error)
+      process.exit(-1)
+    }
+  },
+  async close () {
+    DB.conn
+      .close({ noreplyWait: true })
+      .then(function () {
+        // conn is now closed
+        Log.info('   >> RethinkDB disconnect!')
+      })
+      .error(function (err) {
+        console.error(err)
+        // process the error
+      })
+  },
+
+  async dbCreateStrusture () {
+    try {
+      Log.info('   >> Create strusture  RethinkDB...')
+      const bd = process.env.db_user || DB.name
+      // DB.connStruc = await r.connect({ host, port, db, user, password })
+      const data = await r.dbCreate(bd).run(DB.conn)
+      // console.log('data', data)
+      if (data.config_changes.length > 0) {
+        Log.info(`   >> Created dataBase '${data.config_changes[0]['new_val']['name']}'`)
+        DB.conn.use(bd)
+        for (let element of DB.tables) {
+          await DB.createTable(bd, element.table, element.options, DB.conn)
+        }
+      }
+    } catch (error) {
+      if (error.msg) {
+        Log.info(`   >> ${error.msg}`)
+      } else {
+        console.error(error)
+        process.exit(-1)
+      }
+    }
+  },
+  createTable (db, name, options, connect) {
+    return r
+      .db(db)
+      .tableCreate(name, options)
+      .run(connect)
+      .then(data => {
+        if (data.config_changes.length > 0) {
+          Log.info(`        >> Created Table '${data.config_changes[0]['new_val']['name']}'`)
+        }
+      })
+      .catch(error => {
+        console.log('RETHINKDB: Table', error)
+      })
+  }
+}
+module.exports = DB

bridgedb/lib/log.js

@@ -0,0 +1,38 @@
+const winston = require('winston')
+const path = require('path')
+
+const filename = path.join(__dirname, '../log/bridge.log')
+const config = {
+  levels: {
+    error: 0,
+    debug: 1,
+    warn: 2,
+    data: 3,
+    info: 4,
+    verbose: 5,
+    silly: 6,
+    custom: 7
+  },
+  colors: {
+    error: 'red',
+    debug: 'blue',
+    warn: 'yellow',
+    data: 'grey',
+    info: 'green',
+    verbose: 'cyan',
+    silly: 'magenta',
+    custom: 'yellow'
+  }
+}
+//
+winston.addColors(config.colors)
+const Log = winston.createLogger({
+  levels: config.levels,
+  format: winston.format.combine(winston.format.colorize({ all: true }), winston.format.simple()),
+  transports: [
+    new winston.transports.Console({ handleExceptions: true }),
+    new winston.transports.File({ filename })
+  ]
+})
+
+module.exports = Log

bridgedb/lib/queries.js

@@ -0,0 +1,56 @@
+const r = require('rethinkdb')
+const DB = require('./db')
+//
+// const standardValue = { includeInitial: true, includeTypes: true, includeStates: true }
+// const standardQuery = {
+//   includeInitial: true,
+//   includeTypes: true,
+//   includeStates: true,
+//   includeOffsets: true
+// }
+// const noRangeQuery = { includeInitial: true, includeTypes: true }
+
+const Queries = {}
+// A simple value query for a public user record. We do not emit sensitive fields (tx proximax, etc.) here. Note that the
+// pluck operation has to come after the changefeed request.
+Queries.changesTable = params => {
+  DB.conn.use(DB.name)
+  return r
+    .table('offers')
+    .changes()
+    .run(DB.conn)
+}
+
+Queries.getAlloffertTx = params => {
+  DB.conn.use(DB.name)
+  return r.table('offers').run(DB.conn)
+}
+Queries.getMosaicInfo = params => {
+  console.log('DB', DB)
+  DB.conn.use(DB.name)
+  return r.table('mosaicInfo').run(DB.conn)
+}
+
+Queries.insertMoisaicsInfo = params => {
+  DB.conn.use(DB.name)
+  return r
+    .table('mosaicInfo')
+    .insert(params, { returnChanges: true, conflict: 'replace' })
+    .run(DB.conn)
+}
+Queries.insertOffert = params => {
+  DB.conn.use(DB.name)
+  return r
+    .table('offers')
+    .insert(params, { returnChanges: true })
+    .run(DB.conn)
+}
+Queries.insertExecuteOffers = params => {
+  DB.conn.use(DB.name)
+  return r
+    .table('executeOffers')
+    .insert(params, { returnChanges: true })
+    .run(DB.conn)
+}
+
+module.exports = Queries