o=i>dZddlmZddlmZddlmZmZddlm Z m Z ddl m Z erddl m Z Gdd eZGd d Zy ) z?Default Django repository implementation for wallet operations.) annotations)Decimal) TYPE_CHECKINGProtocol) connection transaction)F)ModelcdeZdZdZddZ d d dZ d d dZd dZd dZy)WalletRepositoryProtocola  Interface for wallet operations. For most use cases, use WalletRepository which implements all methods automatically. You only need to define point types and their decimal places. Custom implementations must implement all methods below. cy)z Return a dictionary mapping point types to their decimal places. Example: { "credit_balance": 2, "reward_points": 0, "crypto_balance": 8, } Nselfs Z/home/cursorai/projects/telegram-earn/packages/wallet_utils/src/wallet_utils/repository.pyget_point_typesz(WalletRepositoryProtocol.get_point_typess cy)z Update user balance by adding amount (positive for add, negative for deduct). Returns the new balance after the update. Should be atomic (use database transactions). Nrruser_id point_typeamountallow_negatives rupdate_balancez'WalletRepositoryProtocol.update_balance&s rcy)a Atomically deduct balance using SQL WHERE clause to prevent race conditions. Uses SQL: UPDATE ... WHERE {point_type} >= {amount} (or >= 0 if allow_negative) Returns: Tuple of (success: bool, new_balance: Decimal) - success: True if row was updated (sufficient balance), False otherwise - new_balance: The balance after deduction (if successful) or current balance (if failed) Should be atomic (use database transactions). Nrrs rdeduct_balance_atomicz.WalletRepositoryProtocol.deduct_balance_atomic5s& rcy)z Get the current balance for a specific point type for a user. Used for reading balance after operations. Nr)rrrs rget_user_balancez)WalletRepositoryProtocol.get_user_balanceJs rcy)z Create a transaction record and return the new transaction ID. Args: record: TransactionRecord dataclass instance Should be atomic (use database transactions). Nr)rrecords rcreate_transaction_recordz2WalletRepositoryProtocol.create_transaction_recordRs rNreturndict[str, int]F rintrstrrrrboolr#r rr'rr(rrrr)r#ztuple[bool, Decimal]rr'rr(r#rr#r') __name__ __module__ __qualname____doc__rrrrr!rrrr r s  $ %            ( %          *   rr ceZdZdZ d ddZddZddZddZddZddZ ddd Z e j d dd Z e j d dd Zdd Ze jdd Zy)WalletRepositorya Default Django implementation of WalletRepositoryProtocol. This repository handles all balance operations and transaction recording automatically. Users only need to define point types and their decimal places - that's it! Example: # Using User model for balances (default) repo = WalletRepository( user_model=User, point_types={ "credit_balance": 2, "reward_points": 0, }, ) # Using separate Wallet model for balances repo = WalletRepository( user_model=User, wallet_balance_model=Wallet, point_types={ "credit_balance": 2, "reward_points": 0, }, ) Nc|ddlm}|}||_||_||_||_|xsi|_||_|xs||_|du|_ y)a Initialize the repository. Args: user_model: Django User model class (used for reference, or as balance model if wallet_balance_model not provided) point_types: Dictionary mapping point types to decimal places wallet_balance_model: Optional separate model for storing wallet balances (must have user_id field). If None, balances are stored on user_model. wallet_model: Optional custom WalletTransaction model (defaults to WalletTransaction) point_type_field_map: Optional mapping from point_type to database field name wallet_user_id_field: Field name in wallet_balance_model that references user_id (default: "user_id") N)WalletTransaction) modelsr5 _user_model_wallet_balance_model _point_types _wallet_model_point_type_field_map_wallet_user_id_field_balance_model_balance_model_is_separate)r user_model point_typeswallet_balance_model wallet_modelpoint_type_field_mapwallet_user_id_fieldr5s r__init__zWalletRepository.__init__zsc,   1,L%%9"')%9%?R"%9"3@j*>d*J'rc|jS)z,Return point types and their decimal places.)r9rs rrz WalletRepository.get_point_typess   rc|jS)zReturn the User model class.)r7rs rget_user_modelzWalletRepository.get_user_modelsrc|jS)z)Return the WalletTransaction model class.)r:rs rget_wallet_modelz!WalletRepository.get_wallet_models!!!rc|jS)z2Return the model used for storing wallet balances.)r=rs rget_wallet_balance_modelz)WalletRepository.get_wallet_balance_models"""rc:|jj||S)z0Return the database field name for a point type.)r;get)rrs rget_point_type_fieldz%WalletRepository.get_point_type_fields))--j*EErc"d}|jr|rA |jjjjd i|j |iS||k(r;|jjjd i|j |idii\}}|S|jjjd i|j |iS|r5 |jjjj |S |jjj |S#|jj $r;||k(r4|jjjd i|j |icYSwxYw#|jj $rp||k(rii}t|jdrd||d<t|jdr d|d|d<|jjjd d |i|cYSwxYw#|jj $rp||k(rii}t|jdrd||d<t|jdr d|d|d<|jjjd d |i|cYSwxYw) a# Get the balance object (wallet or user) for a given user_id. Creates the object if it doesn't exist ONLY for system users (user_id == -100). For regular users, raises DoesNotExist if user doesn't exist. Args: user_id: The user ID for_update: Whether to use select_for_update() for locking Returns: The balance model instance Raises: DoesNotExist: If user doesn't exist and user_id is not -100 (system user) idefaults)pkusername system_user_emailsystem_z @system.localrRr) r>r=objectsselect_for_updaterNr< DoesNotExistcreate get_or_creater7hasattr)rr for_updateSYSTEM_USER_IDobjcreatedrQs r_get_balance_objectz$WalletRepository._get_balance_objects   * * N4..66HHJNN55w?n,#L4#6#6#>#>#L#L$55w?$!#$LCJ:4..66::55w?  ++33EEGKKwKWW ++337777CCQ**77.0At22::AA #997C  4''44 .0#%"4#3#3Z@5A'3KHZ0"4#3#3W=29'-0PHW->t//77>>V'VXVV ''44 .0#%"4#3#3Z@5A'3KHZ0"4#3#3W=29'-0PHW->t//77>>V'VXVV s8?D"3E9<%H"AE64E69BHHBJ Jc|j|}|sA|j|d}t||}||zdkrtd|dt ||j xs |j }|jr |j} nd} | |i} |jjdi| jdi|t||zi|j|d}t||} | S)z Update user balance by adding amount (positive for add, negative for deduct). Returns the new balance after the update. Fr]rzInsufficient balance: z < idr) rOragetattr ValueErrorabsr8r7r>r<rWfilterupdater ) rrrrr field_name balance_objcurrent_balance balance_model user_id_field filter_kwargs new_balances rrzWalletRepository.update_balances..z: 227u2MK%k:>O'!+ #9/9J#cRXk]![\\22Fd6F6F   * * 66M!M'0  =$ $$5}5<< 1Z=612 ..w5.I k:6 rc ~|j|}|jjj}|dk(r|j ||}d|fS|j r8|r|j d}|g} n|j d|d}||g} |j } n|rd}|g} n d|d}||g} d} tj5} d |d |d |d |d } | j| |g| z| j} | dkDrQ| jd|d|d| d|g| j}tt|d}d|fcdddS| jd|d|d| d|g| j}|rtt|d}n|j|dtd}d|fcdddS#1swYyxYw)a Atomically deduct balance using SQL WHERE clause to prevent race conditions. Uses SQL: UPDATE ... WHERE {point_type} >= {amount} (or >= 0 if allow_negative) Returns: Tuple of (success: bool, new_balance: Decimal) - success: True if row was updated (sufficient balance), False otherwise - new_balance: The balance after deduction (if successful) or current balance (if failed) rTz = %sz = %s AND z >= %szid = %sz id = %s AND rdz UPDATE z SET z = z - %s WHERE z zSELECT z FROM z WHERE Nrc0F)rOr=_metadb_tablerr>r<rcursorexecuterowcountfetchonerr(ra)rrrrrrj table_namerl where_clause where_paramsid_fieldrusql rows_affectedrowrps rrz&WalletRepository.deduct_balance_atomic1s$..z: ((..77  Q;"33GZHO( (  * *"&"<"F3A(F33F<cb|j|}|j|d}t||S)z=Get the current balance for a specific point type for a user.Frc)rOrare)rrrrjrks rrz!WalletRepository.get_user_balances4..z: ..w5.I {J//rc ddlm}|j}t|tr|j |}|j j j|j|j|j|j|j|j|j|j||j  }|j"S)z Create a transaction record and return the new transaction ID. Args: record: TransactionRecord dataclass instance r)datetime) wtypeiiduidtyperbalance trans_typedescrcdate extra_data)rr isinstancer( fromisoformatr:rWrZrrrrrrrrrrd)rr rrtransaction_objs rr!z*WalletRepository.create_transaction_records &  eS !**51E,,44;;,,  ==NN((,,((<  !!!r)NNNr) r? type[Model]r@r$rAtype[Model] | NonerBrrCzdict[str, str] | NonerDr(r")r#r)r#r)rr(r#r(r%)rr'r]r)r&r*r+r,)r-r.r/r0rErrHrJrLrOraratomicrrrr!rrrr2r2^sC>48+/6:$-#K#K$#K1 #K ) #K 4 #K"#KJ! "#FM^ % ,,, ,  ,  ,,\ % O.O.O. O.  O.  O.O.b0 ""rr2N)r0 __future__rdecimalrtypingrr django.dbrrdjango.db.modelsr r r r2rrrrs8E"*-&L xL ^G"G"r