VjlddlmZddlZddlmZmZddlmZddlm Z eGddZ dS)) annotationsN) dataclassfield)Path)AnyceZdZUded<eeZded<eeZded<eeZ ded <d#d Z d#d Z d#dZ e d$dZd%dZd&d'dZd(d!Zd)d"ZdS)* PaperExchanger state_path)default_factoryzdict[str, dict[str, Any]] positionslist[dict[str, Any]]orderszdict[str, float]leveragereturnNonect|j|_|dS)N)rr expanduser_loadselfs paper_trading.py __post_init__zPaperExchange.__post_init__s0t//::<< c8|jsdStj|jd}|di|_|dg|_|di|_dS)Nutf-8encodingr rr) r existsjsonloads read_textgetr rr)rdatas rrzPaperExchange._loads%%''  Fz$/33W3EEFF+r22hhx,, R00 rc|jjdd|jt j|j|j|jdddddS)NT)parentsexist_ok)r rr)indent sort_keysrr) r parentmkdir write_textrdumpsr rrrs r_savezPaperExchange._saves $$TD$AAA ""4:k / / t $%$%$%07 # 8 8 8 8 8rsymbolstrc8|ddS)N/r)split)r/s r_coinzPaperExchange._coin$s||C  ##r int | floatdict[str, Any]cht||j|<|ddd||dS)NokT set_leverage)statuspaperactionr/r)floatrr.)rrr/s rr9zPaperExchange.set_leverage(s7 %h f SYgoppprN order_typesideamountr=price float | Noneparamsdict[str, Any] | Nonec |td|pi}||}|dkrt|nt| }|j|dddd} t| dd} | |z} t | dkrd} | dkrd} d} n| dks| dk| dkkrt|} | dkrdnd } nmt| d |t | zt|t |zzt | z } | dkrdnd } t | | | |d | dkrin#t |d pi|j|<d d|||t|t||d}|j|| |S)Nu.PaperExchange benötigt einen expliziten Preisbuylong) contracts entryPricer?rIg-q=rshortrJ)rIrJr?r/paper_position_stater8T)r:r;r/typer?r@rArC) ValueErrorr4r=r r"absdictrappendr.)rr/r>r?r@rArCcoin signed_amountcurrent old_contracts new_contracts entry_pricepos_sideorders r create_orderzPaperExchange.create_order-sN =MNN N2zz&!!)-f U6]]N .$$TCY_+`+`aagkk+s;;<< % 5 }   % %M C  KHH c ! !ma&7]Q=N%O%O,,K!.!2!2vvHH!'++lE"B"BCCc-FXFXX]bch]i]ilop}l~l~]~DGHUDVDVVK!.!2!2vvH]++%   #c))rrtFJJ?U4V4V4\Z\/]/]  t $&*^bnstzn{n{GLMRGSGS_eff 5!!!  rrRmetadatac|}||jvrht|j|dddkr8|j|||dSdSdS)NrIrGr)upperr r=r"updater.)rrRr[s rupdate_position_statez#PaperExchange.update_position_stateNszz|| 4> ! !eDN4,@,D,D[RU,V,V&W&WZ[&[&[ N4 ' ' 1 1 1 JJLLLLL " !&[&[rc g}t|jD]\}}t|dd}|dkr/|dp|d}||t|ddt |j|d|ddd }d D]}||vr ||||<|||S) NrIrGr/z /USDC:USDCrJr?rH)r/rIrJrr?)entryTs highPriceatrSlPxbeActivetrailingActive)sortedr itemsr=r"intrrQ)rr rRposrIr/rowkeys rfetch_positionszPaperExchange.fetch_positionsTs  4 4 6 677 " "ID#cggk37788ICWWX&&=T*=*=*=F &#CGGL#$>$>?? 1 1&! < <==// CY ( (#::"3xCH   S ! ! ! !r)rr)r/r0rr0)rr5r/r0rr6)NN)r/r0r>r0r?r0r@r=rArBrCrDrr6)rRr0r[r6rr)rr )__name__ __module__ __qualname____annotations__rrPr listrrrrr. staticmethodr4r9rZr_rmrrr r s2+05+F+F+FIFFFF#(5#>#>#>F>>>>!&t!rys"""""" (((((((( \\\\\\\ \\\r