Redis and sentinel configs

.gitignore

@@ -1,3 +1,10 @@
+test/matchengine/cli
+accesshttp/accesshttp
+accessws/accessws
+alertcenter/alertcenter
+marketprice/marketprice
+readhistroy/readhistory
+
 # Compiled Object files
 *.slo
 *.lo
@@ -260,7 +267,6 @@ $RECYCLE.BIN/
 x64/
 x86/
 bld/
-[Bb]in/
 [Oo]bj/
 [Ll]og/
 

accesshttp/makefile

@@ -1,4 +1,4 @@
-TARGET  := accesshttp.exe
+TARGET  := accesshttp
 INCS = -I ../network -I ../utils
 LIBS = -L ../utils -lutils -L ../network -lnetwork -Wl,-Bstatic -lev -ljansson -lmpdec -lrdkafka -lz -lssl -lcrypto -lhiredis -Wl,-Bdynamic -lm -lpthread -ldl
 include ../makefile.inc

accesshttp/restart.sh

@@ -1,5 +1,5 @@
 #!/bin/bash
 
-killall -s SIGQUIT accesshttp.exe
+killall -s SIGQUIT accesshttp
 sleep 1
-./accesshttp.exe config.json
+./accesshttp config.json

accessws/makefile

@@ -1,4 +1,4 @@
-TARGET  := accessws.exe
+TARGET  := accessws
 INCS = -I ../network -I ../utils
-LIBS = -L ../utils -lutils -L ../network -lnetwork -Wl,-Bstatic -lev -ljansson -lmpdec -lrdkafka -lz -lssl -lcrypto -lhiredis -lcurl -Wl,-Bdynamic -lm -lpthread -ldl
+LIBS = -L ../utils -lutils -L ../network -lnetwork -Wl,-Bstatic -lev -ljansson -lmpdec -lrdkafka -lz -lssl -lcrypto -lhiredis -Wl,-Bdynamic -lm -lpthread -ldl -lcurl
 include ../makefile.inc

accessws/restart.sh

@@ -1,5 +1,5 @@
 #!/bin/bash
 
-killall -s SIGQUIT accessws.exe
+killall -s SIGQUIT accessws
 sleep 1
-./accessws.exe config.json
+./accessws config.json

alertcenter/makefile

@@ -1,4 +1,4 @@
-TARGET  := alertcenter.exe
+TARGET  := alertcenter
 INCS = -I ../network -I ../utils
-LIBS = -L ../utils -lutils -L ../network -lnetwork -Wl,-Bstatic -lev -lhiredis -ljansson -lmpdec -lcurl -lssl -lcrypto -Wl,-Bdynamic -lm
+LIBS = -L ../utils -lutils -L ../network -lnetwork -Wl,-Bstatic -lev -lhiredis -ljansson -lmpdec -lssl -lcrypto -Wl,-Bdynamic -lm -lcurl 
 include ../makefile.inc

alertcenter/restart.sh

@@ -1,5 +1,5 @@
 #!/bin/bash
 
-killall -s SIGQUIT alertcenter.exe
+killall -s SIGQUIT alertcenter
 sleep 1
-./alertcenter.exe config.json
+./alertcenter config.json

bin/accesshttp

@@ -0,0 +1,98 @@
+#!/bin/bash
+
+echo @=$@
+
+if [ x$1 = x--help -o x$1 = x-h ];then
+	echo "With params calls http access service"
+	echo "  $0 METHOD [comma separated params]"
+	echo "Without params adds the highlevel functions to the environment"
+	echo "  $0"
+	echo "Exported functions are:"
+	echo "  rpc METHOD [comma separated params]"
+	echo "  balance_update user_id asset deposit | withdraw op_id amount"
+	echo "  order_put_market user_id 1(sell)|2(buy) amount taker_fee_rate [source]"
+	exit 0
+fi
+
+shdir=`dirname ${0}`
+
+if [ -z $HTTP_URL ];then
+	. ${shdir}/config.sh
+	HTTP_URL="http://$( accesshttp_bind )"
+fi
+
+function rpc () {
+	method=$1
+	shift
+	if [ ! -z $DEBUG ];then
+	 echo  "{\"method\":\"${method}\",\"params\":[$1],\"id\":${RANDOM}}" 
+	fi
+  curl -i -H 'Accept: application/json' \
+		   -X POST \
+			 -d "{\"method\":\"${method}\",\"params\":[$1],\"id\":${RANDOM}}" \
+	     $HTTP_URL
+  RESULT=$?
+	echo
+	return $RESULT
+}
+
+function balance.query () {
+	if [ $# -lt 1 ]; then
+		echo "bad arguments: $@"
+		echo 'usage: user_id'
+		return 1
+	fi
+	rpc balance.query $1
+}
+
+# user_id
+# asset
+# deposit | withdraw
+# op_id
+# amount
+function balance.update () {
+	rpc balance.update "$1,\"$2\",\"$3\",$4,\"$5\",{}"
+}
+
+function order.put_market () {
+	if [ $# -lt 5 ]; then
+		echo "bad arguments: $@"
+		echo 'usage: user_id market 1(sell)|2(buy) amount taker_fee_rate [source]'
+		return 1
+	fi
+	source=$6 
+	test $source || source="shell command"
+	rpc order.put_market "$1,\"$2\",$3,\"$4\",\"$5\",\"$source\""
+}
+
+function order.put_market () {
+	if [ $# -lt 5 ]; then
+		echo "bad arguments: $@"
+		echo 'usage: user_id market 1(sell)|2(buy) amount taker_fee_rate [source]'
+		return 1
+	fi
+	source=$6 
+	test $source || source="shell command"
+	rpc order.put_market "$1,\"$2\",$3,\"$4\",\"$5\",\"$source\""
+}
+
+function market.status () {
+	if [ $# -lt 2 ]; then
+		echo "bad arguments: $@"
+		echo 'usage: market period'
+		return 1
+	fi
+	rpc "market.status" "\"$1\",$2"
+}
+
+function market.list () {
+	rpc "market.list"
+}
+
+function asset.list () {
+	rpc "asset.list"
+}
+
+# if [ $# -gt 0 ];then
+# rpc $@
+# fi

bin/asset.list

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+asset.list

bin/balance.query

@@ -0,0 +1,5 @@
+#!/bin/bash
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+balance.query $@

bin/balance.update

@@ -0,0 +1,10 @@
+#!/bin/bash
+if [ $# -eq 0 -o x$1 = x--help -o x$1 = x-h ];then
+	echo "$0 user_id asset deposit | withdraw op_id amount"
+	exit 0
+fi
+
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+balance.update $@

bin/config.sh

@@ -0,0 +1,42 @@
+#!/bin/bash
+# Exports functions parsing the services configs
+
+# Internal utils
+servicesdir="`dirname ${0}`/.."
+
+function get () {
+	filter=$1
+	service=$2
+  config="${servicesdir}/$service/config.json"
+	ret=`jq "$filter[0]" < $config`
+	test -z $ret || test $ret = null && $ret=''
+	if [ -z $ret ]; then
+	  ret=`jq $filter[0] < $config`
+		test -z ret && return 1
+	fi
+	echo $ret
+}
+
+function trim_quotes () {
+	echo $1|sed -e's/^"//'|sed -e's/"$//'
+}
+
+function trim_port() {
+	echo $1|sed -e's/^[^@]*@//'
+}
+
+function trim_quotes_port() {
+	echo $1|sed -e's/^"//'|sed -e's/"$//'|sed -e's/^[^@]*@//'
+}
+
+# Exported functions
+function accesshttp_bind () {
+	if [ -z $REMOTE ]; then
+		# get .svr.bind accesshttp
+		ip=$( get .svr.bind accesshttp )
+		# echo "ip=$ip"
+		trim_quotes_port $ip
+	else
+		echo $REMOTE
+  fi
+}

bin/init

@@ -0,0 +1,27 @@
+#!/bin/bash
+
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+OP=3
+
+balance.update 1 BTC deposit $OP 1000
+balance.update 1 ETH deposit $OP 1000
+balance.update 1 BCH deposit $OP 1000
+balance.update 1 LTC deposit $OP 1000
+balance.update 1 DASH deposit $OP 1000
+
+balance.update 2 BTC deposit $OP 1000
+balance.update 2 ETH deposit $OP 1000
+balance.update 2 BCH deposit $OP 1000
+balance.update 2 LTC deposit $OP 1000
+balance.update 2 DASH deposit $OP 1000
+
+balance.update 1121516550 BTC deposit $OP 1000
+balance.update 1121516550 ETH deposit $OP 1000
+balance.update 1121516550 BCH deposit $OP 1000
+balance.update 1121516550 LTC deposit $OP 1000
+balance.update 1121516550 DASH deposit $OP 1000
+
+order.put_market 1121516550 BTCETH 1 0.00001 0.0000001
+order.put_market 1121516550 BTCBCH 1 0.00001 0.0000001

bin/market.list

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+market.list

bin/market.status

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+market.status $@

bin/order.put_market

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+shdir=`dirname ${0}`
+. ${shdir}/accesshttp
+
+order.put_market $@

docker/cli/Dockerfile

@@ -0,0 +1,16 @@
+FROM ubuntu:16.04
+MAINTAINER Sergey Dolin <[email protected]>
+
+RUN apt-get update && \
+    apt-get upgrade -y && \
+    apt-get install -y \
+      mysql-client \
+      inetutils-ping \
+      net-tools \
+      lsof \
+      telnet && \
+    rm -rf /var/lib/apt/lists/* 
+
+RUN echo 'while true;do sleep 3600;done' > /wait
+RUN chmod +x /wait
+CMD /wait