commit 1be1c5af5ad185cb0d4e32aabca1d568aba8d13e Author: Denis Tereshkin Date: Sun Sep 26 12:04:10 2021 +0700 Initial commit diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..bc59db9 --- /dev/null +++ b/LICENSE @@ -0,0 +1,30 @@ +Copyright Author name here (c) 2021 + +All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions are met: + + * Redistributions of source code must retain the above copyright + notice, this list of conditions and the following disclaimer. + + * Redistributions in binary form must reproduce the above + copyright notice, this list of conditions and the following + disclaimer in the documentation and/or other materials provided + with the distribution. + + * Neither the name of Author name here nor the names of other + contributors may be used to endorse or promote products derived + from this software without specific prior written permission. + +THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000..c3310f5 --- /dev/null +++ b/README.md @@ -0,0 +1 @@ +# broker-client-test diff --git a/Setup.hs b/Setup.hs new file mode 100644 index 0000000..9a994af --- /dev/null +++ b/Setup.hs @@ -0,0 +1,2 @@ +import Distribution.Simple +main = defaultMain diff --git a/broker-client-test.cabal b/broker-client-test.cabal new file mode 100644 index 0000000..9a3c85a --- /dev/null +++ b/broker-client-test.cabal @@ -0,0 +1,28 @@ +name: broker-client-test +version: 0.1.0.0 +-- synopsis: +-- description: +homepage: https://github.com/githubuser/broker-client-test#readme +license: BSD3 +license-file: LICENSE +author: Author name here +maintainer: example@example.com +copyright: 2021 Author name here +category: Web +build-type: Simple +cabal-version: >=1.10 +extra-source-files: README.md + +executable broker-client-test + hs-source-dirs: src + main-is: Main.hs + default-language: Haskell2010 + ghc-options: -threaded -Wall + build-depends: base >= 4.7 && < 5 + , time + , hslogger + , zeromq4-haskell-zap + , zeromq4-haskell + , containers + , optparse-applicative + , libatrade \ No newline at end of file diff --git a/src/Main.hs b/src/Main.hs new file mode 100644 index 0000000..69643d8 --- /dev/null +++ b/src/Main.hs @@ -0,0 +1,69 @@ +{-# LANGUAGE OverloadedStrings #-} + +module Main where + +import ATrade.Broker.Client (NotificationCallback, cancelOrder, + startBrokerClient, stopBrokerClient, + submitOrder) +import ATrade.Types (Operation (..), Order (..), + OrderPrice (..), + OrderState (Unsubmitted), + SignalId (..), + defaultClientSecurityParams) +import Control.Concurrent (threadDelay) +import Control.Monad (forever, void) +import System.IO +import System.Log.Formatter +import System.Log.Handler (setFormatter) +import System.Log.Handler.Simple +import System.Log.Logger +import System.ZMQ4 +import System.ZMQ4.ZAP + +initLogging :: [Char] -> IO () +initLogging inst = do + handler <- streamHandler stderr DEBUG >>= + (\x -> return $ + setFormatter x (simpleLogFormatter $ + "$utcTime\t[" ++ inst ++ "]\t\t{$loggername}\t\t<$prio> -> $msg")) + + hSetBuffering stderr LineBuffering + updateGlobalLogger rootLoggerName (setLevel DEBUG) + updateGlobalLogger rootLoggerName (setHandlers [handler]) + +callback :: NotificationCallback +callback = infoM "notification" . show + +main :: IO () +main = do + initLogging "broker-client-test" + infoM "broker-client-test" "Starting" + withContext (\ctx -> do + bro <- startBrokerClient "test" ctx "tcp://127.0.0.1:5530" "tcp://127.0.0.1:5531" [callback] defaultClientSecurityParams + + void $ submitAndCancelOrder bro 1 + void $ forever $ do + threadDelay 10000000 + stopBrokerClient bro) + where + submitAndCancelOrder bro oid = do + threadDelay 1000000 + infoM "broker-client-test" "Submitting order" + void $ submitOrder bro Order + { + orderId = oid, + orderAccountId = "test", + orderSecurity = "TEST", + orderPrice = Market, + orderQuantity = 10, + orderExecutedQuantity = 0, + orderOperation = Buy, + orderState = Unsubmitted, + orderSignalId = SignalId "" "" "" + } + threadDelay 1000000 + infoM "broker-client-test" "Cancelling order" + void $ cancelOrder bro oid + submitAndCancelOrder bro (oid + 1) + + diff --git a/stack.yaml b/stack.yaml new file mode 100644 index 0000000..4cfecd9 --- /dev/null +++ b/stack.yaml @@ -0,0 +1,71 @@ +# This file was automatically generated by 'stack init' +# +# Some commonly used options have been documented as comments in this file. +# For advanced use and comprehensive documentation of the format, please see: +# https://docs.haskellstack.org/en/stable/yaml_configuration/ + +# Resolver to choose a 'specific' stackage snapshot or a compiler version. +# A snapshot resolver dictates the compiler version and the set of packages +# to be used for project dependencies. For example: +# +# resolver: lts-3.5 +# resolver: nightly-2015-09-21 +# resolver: ghc-7.10.2 +# +# The location of a snapshot can be provided as a file or url. Stack assumes +# a snapshot provided as a file might change, whereas a url resource does not. +# +# resolver: ./custom-snapshot.yaml +# resolver: https://example.com/snapshots/2018-01-01.yaml +#resolver: +# url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/18/11.yaml +resolver: lts-17.14 + +# User packages to be built. +# Various formats can be used as shown in the example below. +# +# packages: +# - some-directory +# - https://example.com/foo/bar/baz-0.0.2.tar.gz +# subdirs: +# - auto-update +# - wai +packages: +- . +- '../libatrade' +- '../zeromq4-haskell-zap' +# Dependency packages to be pulled from upstream that are not in the resolver. +# These entries can reference officially published versions as well as +# forks / in-progress versions pinned to a git hash. For example: +# +# extra-deps: +# - acme-missiles-0.3 +# - git: https://github.com/commercialhaskell/stack.git +# commit: e7b331f14bcffb8367cd58fbfc8b40ec7642100a +# +# extra-deps: [] +extra-deps: [ 'datetime-0.3.1' ] + +# Override default flag values for local packages and extra-deps +# flags: {} + +# Extra package databases containing global packages +# extra-package-dbs: [] + +# Control whether we use the GHC we find on the path +# system-ghc: true +# +# Require a specific version of stack, using version ranges +# require-stack-version: -any # Default +# require-stack-version: ">=2.7" +# +# Override the architecture used by stack, especially useful on Windows +# arch: i386 +# arch: x86_64 +# +# Extra directories used by stack for building +# extra-include-dirs: [/path/to/dir] +# extra-lib-dirs: [/path/to/dir] +# +# Allow a newer minor version of GHC than the snapshot specifies +# compiler-check: newer-minor