<`gddlmZmZddlmZddlZddlZddlmZmZddl m Z ddl m Z ddl mZdZed Zed Zed Zed Zed Zej*Zd eefdZy))datetimedate)ObjectIdN)ListDict)reactor) KiteTicker) MongoClientct|d|d<|jD]H\}}t|trt|||<%t|ts6|j ||<J|S)z5Convert MongoDB document to a JSON-compatible format._id)stritems isinstancerr isoformat)orderkeyvalues 1/var/www/html/trade_iq/helper_functions/orders.pyserialize_order_or siuU|$E%Lkkm+ U eX &UE#J x (*E#J + Lz.on_connect6sF )* T)..*+, CLL$y~~'7"89rc4K|D]}|d}|jd}|s|s |}|d}|d}t|t|z}|d} |d} tjj d} | |||| d} t j d|i} t|d | r| d d | gz}td |D}td |D}td|D}d| |||t|dddi}t jd|i|jd|d|d|d-||| d| | | g|t|dt|dddd}t j|jd|d|d|dtdyw)Nr last_pricesymbolquantityactionexchangez%Y-%m-%dT%H:%M:%S)r3r2 avg_priceinvested_amount executed_atzFOUND!!!rsummaryc38K|]}t|dyw)r2N)int.0items r z4place_order..process_tick..Xs([4T*-=)>([c38K|]}t|dyw)r5Nfloatr;s rr>z4place_order..process_tick..Ys)_t%[0A*B)_r?c38K|]}t|dyw)r6NrAr;s rr>z4place_order..process_tick..Zs(dDt4E/F)G(dr?z$set)total_quantitytotal_avg_pricetotal_invested) last_updatedzholdings.summaryzholdings.totalzUpdated holding for z at price z with quantity .i)r8total)rr1r4allocated_balance created_atrHrzCreated new entry for zProcess Finished) getrBrutcnowstrftimeholdings_collectionfind_oneprintsumround update_oner# insert_one)r)tickstickrltprr1r2r6r3r4 timestampnew_summary_entryexisting_entryupdated_summaryrErFrGupdated_holding_entrynew_holding_entryr,r-s r process_tickz!place_order..process_tick;sD lD#$67 ((<(CC!"23x ,"'/E#J">x ,$OO-667JK % (!$'6#, %!"5!=!=?QSc>d!e& 3!&4Z&@&KO`Na&aO%(([?([%[N&))_)_&_O%((dTc(d%dN,50?2@3B272J/! -)(22+-=>-KK"6vhj_]e\ffg hi-="($,-1&/(1(9':2:38a=272K&%)%"(223DEKK"8 3%_g^hhi jkID lJ  !sFFE2Fcjd|tj|||jy)NzTicks received: %s)r#asyncio create_taskclose)r)rWr,r`s ron_tickszplace_order..on_tickss0 (%0LU34  rcjd|d|tjrjtjdj y)NzWebSocket closed: Code=z , Reason=rD)r#rrunningstop callLaterconnect)r)codereasonr+r,s ron_closezplace_order..on_closesA -dV9VHEF ?? HHJ!S[[)rz"Error during WebSocket operation: )rRcreds_collectionrQr today ValueErrorr logging basicConfigINFO getLogger__name__r.rermrrgrj Exceptionerrorrh) rrcredsrr.rermer+r,r-r`s @@@@r place_orderrz&sT?EFe)*E1FI ,-  % %vs5z&:ASTcdrsz#$-  S T * 12X&z* sd4jsr