%fj<pddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZmZdd lmZgd Zhd Zed GddZdddFdZdGdZdHdZdIdZdJd#ZdKd'Z dLd*Z!dMd-Z"dNd0Z#dOd2Z$dPd4Z%d5d6d7dQd:Z&dRd<Z'dSd>Z(d5d?dTdCZ)dUdEZ*d5S)V) annotations) dataclassfield)DecimalInvalidOperation) Connection)record_audit_event)create_crypto_asset)calculate_crypto_holdingscreate_initial_holding_snapshot)record_crypto_transfer) stable_idutc_now) create_alert)z ADA CardanoAmpzAvalanche AVAXz Bitcoin BTC ChainlinkDOGEzDecentraland MANAz Ethereum ETHzHIGH HighstreetzIOTA IOTz LUNA TerrazLUNC Terra ClassicNETVRz NuCypher NUzOx ZRXz Polygon MATICz Ripple XRPzSAND The SandboxSAROSSKYz SOL SolanaSundaezUSTC Terra Classic> crypto_buymanual_adjustmentinitial_snapshot_additionT)frozencbeZdZUded<ded<dZded<dZded<eeZd ed <dS) CryptoManageResultstrasset_id wallet_idN str | None holding_idtransaction_id)default_factoryz list[str]warnings) __name__ __module__ __qualname____annotations__r"r#rlistr%#src/jarvis_finance/crypto/manage.pyrr+sdMMMNNN!J!!!!!%N%%%%%555H555555r,rquantity field_namevaluerr0returnrc6t|}|st|d t|}n,#ttf$r}t|d|d}~wwxYw|st|d|S)Nz is requiredz must be a Decimal stringz must be finite)rstrip ValueErrorrr is_finite)r1r0textdecexcs r-parse_decimal_textr:4s u::    D 6J444555Ldmm j )LLLJAAABBKL ==??9J777888 JsAA0A++A0c"t|dS)Nf)format)r1s r- decimal_textr>As %  r,confirmboolNonec(|stddS)Nz*explicit confirm is required before saving)r5)r?s r-_require_confirmrCEs& GEFFFGGr,effective_datec t|}|std|d}t |dkst d|Dstd|S)Nzdate is required-c3>K|]}|VdS)N)isdigit).0parts r- z _require_date..Ps*!C!CT$,,..!C!C!C!C!C!Cr,zdate must be ISO YYYY-MM-DD)rr4r5splitlenall)rDr7partss r- _require_daterQJs ~   $ $ & &D -+,,, JJsOOE 5zzQc!C!CU!C!C!CCC6777 Kr,connrr ct|}|std|d|f}|td|S)Nzwallet is requiredz6SELECT wallet_id FROM crypto_wallets WHERE wallet_id=?zwallet not found)rr4r5executefetchone)rRr rows r-_require_walletrWUsnI$$&&I /-... ,,OR[Q] ^ ^ g g i iC {+,,, r, coin_namesymboltuple[str, str]ct|}t|}|std|std||fS)Nzcoin name is requiredzsymbol is required)rr4upperr5)rXrYs r-_require_coin_fieldsr]_suI$$&&I [[   & & ( (F 20111 /-... f r,notereasonctt|pd}|std||S)Nznote is required for )rr4r5)r^r_s r- _require_noterbisA tzr?? " "D ;999::: Kr, coingecko_idr!c|rE|d|f}|r|dS|d||f}|r|dndS)Nz7SELECT asset_id FROM crypto_assets WHERE coingecko_id=?rz]SELECT asset_id FROM crypto_assets WHERE lower(coin_name)=lower(?) AND upper(symbol)=upper(?))rTr4rU)rRrXrYrcrVs r- _find_assetreps#llTWcWiWiWkWkVmnnwwyy  #z? " ,,g F  hjj" +3z??t+r,coingecko_statustuple[str, list[str]]c g}|r(|r|nd}t||||}|r|} nt|||||} |s|d|dvrS|dkrdnd} t |ddd | | d |||d | || |vr|| | |fS) N)rXrYrc)rXrYrcnotesmissing_coingecko_id> uncertainmissing_confirmedrk"crypto_coingecko_mapping_uncertainwarnungcrypto crypto_assetz9Crypto asset CoinGecko mapping needs manual confirmation.)rYrXrfprioritycategory entity_type entity_idrule_idmessageevidence fingerprint)r4rer appendrcommit) rRrXrYrcrfr^r%cgexistingrrules r- _ensure_assetr|s'H!- P,2D2D2F2F P     DB49VRTUUUHn&ty^`hlmmm 0.///===7G;7V7V33\r &O &YTdee(  x   OOD ! ! ! X r,rct|}|j||f}|r|jnt dS)N0)r wallet_holdingsgetr.r)rRr rresultholdings r-current_wallet_asset_quantityrsC &t , ,F$(()X)>??G& 87  GCLL8r,deltac ,|dkrtdt}t|}tdd||t |||}|dkr|nd} |dkr|nd} |d||t || | |||f|S)Nrz(manual adjustment delta must not be zerocryptotxrak INSERT INTO crypto_transactions( crypto_transaction_id, transaction_type, asset_id, quantity, from_wallet_id, to_wallet_id, transaction_datetime, source, confirmation_status, parse_confidence, notes, created_at ) VALUES (?, 'manual_adjustment', ?, ?, ?, ?, ?, 'manual_dashboard', 'confirmed', 1, ?, ?) )r5rabsrr>rT) rRrr rrDr^nowqtytx_idfrom_wallet_id to_wallet_ids r-%_insert_manual_adjustment_transactionrs zzCDDD ))C e**C j"5xLY^L_L_aoqt u uE"'!))YYN % 99tLLL  ,s++^\>[_ade    Lr,Nselected)rcrf quantity_textoperation_typec t||tvrtd|dkrtdt|}t ||}t ||\}}t |} | dkrtd|dkrt|d}n%t|pd pd }t|||| | | \} } | d | |f }|d kr;|rtd t|| || d|||}t| ||| St||| }t!|| || ||}|| z}t#|ddd|| |t%|d| |t%|t%| d|dd |t| ||| S)Nz,unsupported crypto management operation typerzucrypto_buy requires the dedicated ledger buy workflow; use manual_adjustment or initial_snapshot_addition in this MVPrquantity must be > 0rr_raz manual initial snapshot addition)rXrYrcrfr^zNSELECT crypto_holding_id FROM crypto_holdings WHERE asset_id=? AND wallet_id=?rzTinitial snapshot addition would overwrite an existing holding; use manual_adjustmentverified)rr r.verification_statuslast_verified_atlegacy_snapshot_dater^)rr r"r%r rrr rrDr^ crypto_managecrypto_manual_adjustmentcrypto_transactionrr r.rr r.rT dashboard sourceactionrtru old_values new_valuesuser_text_note confirmed created_by)rr r#r%)rCVALID_ADD_TYPESr5rQrWr]r:rbrr4rrTrUr rrrr r>r{)rRrXrYr rrDrr^r?rcrfr.rr%existing_holdingr"beforerafters r-add_crypto_positionrsW_,,GHHH%%QRR R">22Ni00I,Y??Iv!-00H1}}/000,,,T*=>>>4:2$$&&L*L&ty^j~NUYZZZHh||X 9hjj444  ustt t4  *+!/    "8yU_jrssss *49x X X XF 1$U^fn@NUY Z Z ZE X E )( (yl[aNbNbcc (yl[`NaNalxzBmCmCDD     KKMMM x9UZem n n nnr,new_quantity_textc t|t|}t||}t|d}t |d}|dkrt d|d|f}|t dt||| } || z } | | zdkrt d t|||| || } t|d d d| ||t| d||t|t| d|dd | dkr7|| z tdks|dkrt|ddd| dd||dd |t||| S)Nrrz new quantityr/rznew quantity must be >= 03SELECT asset_id FROM crypto_assets WHERE asset_id=?asset not foundrnegative holding blockedrrrrrrTrr10hinweisrocrypto_manual_adjustment_reviewzVManual crypto adjustment should be reviewed because it materially changes the holding.)rr manual_adjustment_reviewrqrr r#)rCrQrWrbr:r5rTrUrrr r>rrr{r) rRrr rrDr^r? new_quantityassetrrrs r-adjust_crypto_positionrsW">22Ni00I &9 : : :D%&7NSSSLa4555 LLNQYP[ \ \ e e g gE }*+++ *49x X X XF 6 !E ~3444 1$U^fk}KRV W W WE )( (yl[aNbNbcc (yl[gNhNhsAFtGtGHH    {{ v->>,RSBSBS ,5l"*CC2  KKMMM x9UZ [ [ [[r,reduction_quantity_textc  t|t|d}|dkrtdt|||}||z } | dkrtdt |||t | |||S)Nzreduction quantityr/rzreduction quantity must be > 0rr)rr rrDr^r?)rCr:r5rrr>) rRrr rrDr^r? reductioncurrentrs r-reduce_crypto_positionr<sW"#:G[\\\IA~~9:::+DIPXYYYGY&La3444 ! &|44%    r,)fee_quantity_textrrrc $t|t|t||}t||}t|pdpd}|d|f} | tdt|} | dkrtdt|pdd } | dkrtd t||||| | | } t||| S) Nrazmanual wallet transferrrrrrz fee quantityr/zfee quantity must be >= 0)rrrr. fee_quantityr^r) rCrQrWrr4rTrUr5r:r r) rRrrrrrDr^r?rrr.rrs r-transfer_crypto_positionrYs/W.!!!$T>::N"466L tzr?? " " >&>D LLNQYP[ \ \ e e g gE }*+++!-00H1}}/000%&7&>3>ZZZLa4555 " %!!    E xg|]}|d|d|ddS)r wallet_name wallet_type)r rrr+rJrVs r- z1get_crypto_management_options..sC +&s=7IZ]^kZlmmr,zeSELECT wallet_id, wallet_name, wallet_type FROM crypto_wallets WHERE is_active=1 ORDER BY wallet_namecPg|]#}|d|d|d|dpdd$S)rrXrYrcra)rrXrYrcr+rs r-rz1get_crypto_management_options..se _3{3CsS[}nqsAoBoHFH I Ir,zpSELECT asset_id, coin_name, symbol, coingecko_id FROM crypto_assets WHERE is_active=1 ORDER BY coin_name, symbolc hg|]/}|d|d|d|d|d|dd0S)rr rXrYrr.)rr rXrYrr.r+rs r-rz1get_crypto_management_options..s^ J[)[)(m}-J   r,a4 SELECT h.asset_id, h.wallet_id, a.coin_name, a.symbol, w.wallet_name, h.quantity FROM crypto_holdings h JOIN crypto_assets a ON a.asset_id=h.asset_id JOIN crypto_wallets w ON w.wallet_id=h.wallet_id ORDER BY a.coin_name, w.wallet_name )walletsassetsholdingsmanual_review_coin_labels)rTfetchallr* CRYPTO_MANUAL_REVIEW_COIN_LABELS)rRrrrs r-get_crypto_management_optionsrs<<!HIIRRTTG<<!STT]]__F<<    (**#H(%)*J%K%K   r,)r1rr0rr2r)r1rr2r)r?r@r2rA)rDrr2r)rRrr rr2r)rXrrYrr2rZ)r^rr_rr2r) rRrrXrrYrrcr!r2r!)rRrrXrrYrrcr!rfrr^r!r2rg)rRrr rrrr2r)rRrrrr rrrrDrr^rr2r)rRrrXrrYrr rrrrDrrrr^rr?r@rcr!rfrr2r)rRrrrr rrrrDrr^rr?r@r2r)rRrrrr rrrrDrr^rr?r@r2r)rRrrrrrrrrrrDrr^rr?r@rr!r2r)rRrr2r)+ __future__r dataclassesrrdecimalrrsqlite3rjarvis_finance.audit.logr jarvis_finance.crypto.assetsr jarvis_finance.crypto.holdingsr r "jarvis_finance.crypto.transactionsr jarvis_finance.imports.commonrrjarvis_finance.quality.alertsrrrrr:r>rCrQrWr]rbrerrrrrrrrr+r,r-rs""""""((((((((--------777777<<<<<<eeeeeeeeEEEEEE<<<<<<<<666666$$$ 4SRR $666666669C      GGGG  , , , ,""""J9999 P $&@o@o@o@o@o@oF2\2\2\2\jN%)#_#_#_#_#_#_N!!!!!!r,