View GitHub Repository tradehub-python

Schedule Inspection
Subscribe
Completed
Push — main ( 5e6d02...339f4c )
by
unknown
15s queued 12s
created

websocket   A

↳ Parent: Project

Complexity

Total Complexity 2

Size/Duplication

Total Lines 18
Duplicated Lines 0 %

Importance

Changes 0
Metric Value
wmc 2
eloc 12
dl 0
loc 18
rs 10
c 0
b 0
f 0
1 
from tradehub.websocket_client import DemexWebsocket
2 
import asyncio
3 

            


            
                                                        
            
                                    
            
            

                
                    4
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    5
                

                                    
                                                    
                
                
                
async def on_connect():

            


            
                                                        
            
                                    
            
            

                
                    6
                

                                    
                                                    
                
                
                
    print("I am connect to demex websocket!")

            


            
                                                        
            
                                    
            
            

                
                    7
                

                                    
                                                    
                
                
                
    await demex.subscribe_books("orderbook", "swth_eth1")

            


            
                                                        
            
                                    
            
            

                
                    8
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    9
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    10
                

                                    
                                                    
                
                
                
async def on_receive_message(message: dict):

            


            
                                                        
            
                                    
            
            

                
                    11
                

                                    
                                                    
                
                
                
    print("I received a message")

            


            
                                                        
            
                                    
            
            

                
                    12
                

                                    
                                                    
                
                
                
    print(message)

            


            
                                                        
            
                                    
            
            

                
                    13
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    14
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    15
                

                                    
                                                    
                
                
                
if __name__ == '__main__':

            


            
                                                        
            
                                    
            
            

                
                    16
                

                                    
                                                    
                
                
                
    demex: DemexWebsocket = DemexWebsocket('ws://164.132.169.19:5000/ws')

            


            
                                                        
            
                                    
            
            

                
                    17
                

                                    
                                                    
                
                
                
    asyncio.get_event_loop().run_until_complete(demex.connect(on_receive_message, on_connect))

            


            
                                                        
            
                                    
            
            

                
                    18