xhesikaruci / post_get_api_requests Goto Github PK

def reply_handler(msg):
    print("Reply:", msg)    

def my_callback_handler(self,msg):
    if msg.field == 4:
        self.price_field = msg.price
    else:
        print(msg)
        
def __init__(self,debug=False):
    self.tws = ibConnection('localhost', 7496, 999)
    self.tws.register(self.my_callback_handler)

    if debug:
        self.tws.registerAll(self.debugHandler)

    self.tws.connect()
    self._reqId = 1 # current request id

def debugHandler(self,msg):
    print ('[debug]', msg)

def tickPriceHandler(self,msg):
    if msg.field == 4:
        self.field4price = msg.price
        print ('[debug12]', msg.price)
    
def closeconn(self):   
    print ('[debug]', self.tws.disconnect())

def requestData(self,contract):
    self.tws.reqMktData(self._reqId,c,'',1)
    self._reqId+=1
    #return "???"

print("disconnect",dl.closeconn())

def tickPrice(self, reqId, tickType, price, attrib):
    #print("Tick Price. Ticker ID", reqId, "ticktype", TickTypeEnum.to_str(tickType), "Price" , price, end=' ')
    if(TickTypeEnum.to_str(tickType) == 'CLOSE'):
        print("Tick Price. Ticker ID", reqId, "ticktype", TickTypeEnum.to_str(tickType), "Price" , price, end=' ')
        self.count += 1
        print("count", self.count)
        **if self.count > 1: 
           self.disconnect()**