%fj2 nddlmZddlmZddlmZddlmZddlm Z m Z ddl m Z ddl mZd:d;dZddZd?dZd@d Zd!d!d!d!d!d!d!d!d!d!d!d!d" dAd/Zed d0dBd3ZdCd4Zed d!d5dDd6Zed d!ed d!d7dEd8Zed d!ed d!d7dFd9Zd!S)G) annotations)Decimal) Connection)record_audit_event) stable_idutc_now) create_alert)calculate_crypto_holdings0valueobjectdefaultstrreturnrc|%t|dkrt|Stt|S)N)rstripr)r rs )src/jarvis_finance/crypto/transactions.py_dr sE }E ((**b00w 3u::  Decimal | None str | Nonec*|t|dndS)Nf)format)r s r_dsrs!&!26%    0) ValueError)r!s r_ensure_positiver%s!1}}/000}rconnr wallet_idasset_idct|}|j||f}|r|jnt dS)Nr )r wallet_holdingsgetr!r)r&r'r(resultholdings r_current_quantityr.!sC &t , ,F$(()X)>??G& 87  GCLL8r attempted availablect|ddd|dd|t|t|d|dS)Nkritischcrypto crypto_walletcrypto_negative_wallet_balancezJCrypto transaction would create a negative wallet balance and was blocked.)r(attempted_deltar0prioritycategory entity_type entity_idrule_idmessageevidence)r rcommit)r&r'r(r/r0s r_critical_negative_alertr@'s^ #0\&3y>>X[\eXfXfgg     KKMMMMMrN) from_wallet_id to_wallet_idtransaction_idprice_originalcurrencygross_amount_original fee_quantity fee_original fee_currencyrtx_hashnotetx_typerArBrCrDrErFrGrHrIrJrKcft}td||||pd|pd|}|d||||t|t||t| t| t| | t| | t | | nd||||||f|S)Ncryptotxra INSERT INTO crypto_transactions( crypto_transaction_id, transaction_id, transaction_type, asset_id, quantity, price_original, currency_original, gross_amount_original, fee_quantity, fee_original, fee_currency, fx_rate_to_chf, amount_chf, from_wallet_id, to_wallet_id, transaction_datetime, tx_hash, source, confirmation_status, parse_confidence, notes, created_at ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'manual', 'confirmed', 1, ?, ?) )rrexecuterr )r&rLr(r!rArBrCrDrErFrGrHrIrrJrKnow crypto_txids r_insert_crypto_transactionrR5s& ))CJ8^EYWY[g[mkmorssKLL  (CMM    c/00       #n--;P;\D& 7 7 7bf L#wc * r)rH account_id source_idcDt} tdd|||||} |dnd} |dnd} |dvr||z n|} |d| ||| ddt|t|t| |t|| t ||t ||t | ||| || f|D|d kr,t |d dd | d d ||d| S)Nledgerr3okmissing incomplete> full_sell partial_sella INSERT INTO transactions( transaction_id, transaction_type, account_id, trade_date, gross_amount_original, fee_original, net_amount_original, currency_original, fx_rate_to_chf, fx_status, gross_amount_chf, fee_chf, net_amount_chf, source_type, source_id, is_confirmed, quality_status, notes, created_at ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'crypto', ?, 1, ?, ?, ?) CHFr2 transaction missing_fxzGCrypto fiat ledger transaction is missing FX; CHF impact is incomplete.)rErTr7)rrrOrupperr r )r&rLrSrTrFrErrKrHrPtxid fx_statusqualitysign_nets r_insert_ledger_transactionrebsd ))C Xx*iI^`l m mD&2 I$0ddlG7>B_7_7_$|33ezHLL  ':s3B3x5J1K1KSQ]M^M^`cdl`m`m NN  c.119 & 7 7lN9[9[]abjlz]{]{ wc   (.."2"2e";"; % ]"*.."2"2KK  Krc |dkrdS|s(t|ddd|dddt|idSt|d |||||| S) Nrwarnungr3crypto_transactioncrypto_fee_currency_unclearzXCrypto fiat fee currency is unclear; ledger fee is not created to avoid double counting.rHr7feerLrSrTrFrErrK)r rre)r&rSrTrHrIrrKs r_insert_fee_ledgerrlsqt   ,1n$c,&7&78 t % *%     r)rGrJct||dkrtd||krtd||z}t|||} | |kr"t||||| tdt |d||||||| } t |ddd | |||t |t|d |d d || S)Nrzfee_quantity must be >= 0z+source and target wallets must be differentnegative wallet balance blockedtransfer)rLr(r!rGrArBrJrKcrypto_transactionscrypto_transferrh)r(rArBr!rGTsystemsourceactionr:r; new_valuesuser_text_note confirmed created_by) r%r$r.r@rRrrrr?) r&r(rArBr!rGrJrKrequiredr0rQs rrecord_crypto_transferr{sNXa4555%%FGGG,&H!$AAI8 ~x9UUU:;;;, !%!    K $ ( (N\hvy{CwDwDVYZfVgVghh     KKMMM r)rHrIrGrc t|| dks|dkrtdtd|||t} t |d|| ||| |} t |d|||| || || || | }|d|| ft||||| | |t|d d d |||t|| d |d d | |S)Nrfees must be >= 0 cryptobuybuyrk) rLr(r!rBrCrFrGrHrIrErrK:UPDATE transactions SET source_id=? WHERE transaction_id=?)rSrTrHrIrrKrp crypto_buyrh)r(rBr!ledger_transaction_idTrrrs) r%r$rrrerRr`rOrlrrr?)r&rSr(rBr!rFrErKrHrIrGr provisional ledger_txidrQs rrecord_crypto_buyrs}XarsF""""""777777<<<<<<<<666666////// ===='''' 1111 9999    ("&#!%%),0#'#'#%)#******n$GCLL,,,,,,^!!!!V$GCLL,,,,,,r$GCLL##GCLL%);;;;;;P$GCLL##GCLL%)KKKKKKKKr