()
| 28 | |
| 29 | |
| 30 | def main(): |
| 31 | sender = MySender() |
| 32 | |
| 33 | # Enable logging |
| 34 | sender.logging = True |
| 35 | |
| 36 | # Create and send a new order |
| 37 | order = proto.Order(1, "EURUSD", proto.OrderSide.buy, proto.OrderType.market, 1.23456, 1000.0) |
| 38 | sender.send(proto.OrderMessage(order)) |
| 39 | |
| 40 | # Create and send a new balance wallet |
| 41 | balance = proto.Balance("USD", 1000.0) |
| 42 | sender.send(proto.BalanceMessage(balance)) |
| 43 | |
| 44 | # Create and send a new account with some orders |
| 45 | account = proto.Account(1, "Test", proto.State.good, proto.Balance("USD", 1000.0), proto.Balance("EUR", 100.0)) |
| 46 | account.orders.append(proto.Order(1, "EURUSD", proto.OrderSide.buy, proto.OrderType.market, 1.23456, 1000.0)) |
| 47 | account.orders.append(proto.Order(2, "EURUSD", proto.OrderSide.sell, proto.OrderType.limit, 1.0, 100.0)) |
| 48 | account.orders.append(proto.Order(3, "EURUSD", proto.OrderSide.buy, proto.OrderType.stop, 1.5, 10.0)) |
| 49 | sender.send(proto.AccountMessage(account)) |
| 50 | |
| 51 | receiver = MyReceiver() |
| 52 | |
| 53 | # Enable logging |
| 54 | receiver.logging = True |
| 55 | |
| 56 | # Receive all data from the sender |
| 57 | receiver.receive(sender.buffer) |
| 58 | |
| 59 | |
| 60 | if __name__ == "__main__": |
no test coverage detected