# -*- coding: utf-8 -*-
"""
- for download in MT4 -> 
a) 
"""
# ----- import -------------------------------------------------------------------
import zmq
#import sys
#import time, threading, datetime
#import os
# ----------- sample -------------------------------------------------------------
# context = zmq.Context()
# socket = context.socket(zmq.REQ)
# socket.connect("tcp://"+argv)
#
# print('ZeroListener listen ' + "tcp://"+argv)
#
# msg = 'dtreeOpen;eurusd;15;100000;s;1.12478;1.12301'
#
# socket.send_string(msg)

#retMsg = socket.recv_string()
#print(retMsg)


# ------ New version ---- class -----------------------------------------
SERVER = "7.0.0.6"
PORT="11111"

class _0MQ:
    # ? obsluha comunikace s PROD serverem
    # static - context - share for all socket
    context=0

    def __init__(self):
        self.socket = self.context.socket(zmq.REQ)
        argv = "%s:%s"%(SERVER,PORT)
        self.socket.connect("tcp://"+argv)

    def sendPred(self,msg):
        # send data from PROD server
        self.socket.send_string(msg)
        mesg = self.socket.recv_string()
        return mesg

    def __del__(self):
        self.socket.close()

#! definovat conteiner
_0MQ.context = zmq.Context()

sendMsg=""
retMsg=-1
# --------------------------- MAIN --------------------------------------

def Main():
  Server=_0MQ()
  ret=Server.sendPred(sendMsg)
  if (ret.find("ok")>0): 
    retMsg=1
    return
  if (ret.find("duplicate")>0): 
    retMsg=2
    return
  retMsg=0



#2019-08-04 12:33:24.402729 ok
#2019-08-04 12:33:53.935716 duplicate key value violates unique constraint "zorro_eurusd_pkey"
#DETAIL:  Key (time_stamp, tf, system)=(100000, 15, DTREE) already exists.
if __name__ == "__main__": 
  Server=_0MQ()
  retMsg=Server.sendPred("DTREE;eurusd;15;100010;L;1.12478;1.12301")
  if (retMsg.find("ok")>0): 
    print("return OK" )
  if (retMsg.find("duplicate")>0): 
    print("return dup" )
  print(retMsg)