FastBinaryEncoding/projects/JavaScript/tests/test_send_receive.js at main · chronoxor/FastBinaryEncoding · GitHub

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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
/* eslint-disable prefer-const,no-loss-of-precision */
'use strict'

const test = require('tape')

const proto = require('../proto/proto')

class MySender extends proto.Sender {
  // noinspection JSUnusedLocalSymbols
  onSend (buffer, offset, size) {
    //  Send nothing...
    return 0
  }
}

class MyReceiver extends proto.Receiver {
  constructor () {
    super()
    this._order = false
    this._balance = false
    this._account = false
  }

  check () {
    return (this._order && this._balance && this._account)
  }

  // noinspection JSUnusedLocalSymbols
  onReceive_OrderMessage (value) { this._order = true } // eslint-disable-line
  // noinspection JSUnusedLocalSymbols
  onReceive_BalanceMessage (value) { this._balance = true } // eslint-disable-line
  // noinspection JSUnusedLocalSymbols
  onReceive_AccountMessage (value) { this._account = true } // eslint-disable-line
}

function sendAndReceive (index1, index2) {
  let sender = new MySender()

  // Create and send a new order
  let order = new proto.Order(1, 'EURUSD', proto.OrderSide.buy, proto.OrderType.market, 1.23456, 1000.0)
  sender.send(new proto.OrderMessage(order))

  // Create and send a new balance wallet
  let balance = new proto.Balance('USD', 1000.0)
  sender.send(new proto.BalanceMessage(balance))

  // Create and send a new account with some orders
  let account = new proto.Account(1, 'Test', proto.State.good, new proto.Balance('USD', 1000.0), new proto.Balance('EUR', 100.0))
  account.orders.push(new proto.Order(1, 'EURUSD', proto.OrderSide.buy, proto.OrderType.market, 1.23456, 1000.0))
  account.orders.push(new proto.Order(2, 'EURUSD', proto.OrderSide.sell, proto.OrderType.limit, 1.0, 100.0))
  account.orders.push(new proto.Order(3, 'EURUSD', proto.OrderSide.buy, proto.OrderType.stop, 1.5, 10.0))
  sender.send(new proto.AccountMessage(account))

  let receiver = new MyReceiver()

  // Receive data from the sender
  index1 %= sender.buffer.size
  index2 %= sender.buffer.size
  index2 = Math.max(index1, index2)
  receiver.receive(sender.buffer, 0, index1)
  receiver.receive(sender.buffer, index1, index2 - index1)
  receiver.receive(sender.buffer, index2, sender.buffer.size - index2)
  return receiver.check()
}

test('Send & Receive', function (t) {
  for (let i = 0; i < 100; i++) {
    for (let j = 0; j < 100; j++) {
      t.true(sendAndReceive(i, j))
    }
  }
  t.end()
})