a ,e#@sdddlZddlmZmZmZmZddlZddlmZddlm Z ddl m Z m Z m Z mZddZdS)N)getOccupations get_person getPeakEnergy playerClassconversationInit)messageFunction) sendToUsersendDict sendUserInfosendEventMessagecs|stddS|rt|tr*|d}td|t|}||j}|ddkrxt||IdHtdd|_n\|dd krtd d |_n>|dd krtd d}t }t |_ |j|_ |||j<t||j|IdHd|_ n|ddkr*ddlm}|||dt||IdHn|ddkrt||d}ddlm}ddlm}||||_|||_t|tj|jdddIdHn<|ddkr|d}|j|_d|_ddlm} d} ||j} | jjdkr| jjd8_t| jt |d|j!dIdHt|d|dd krPtd!| | |d"|d#d$} n|dd%krtd%| | |d"|d#|d%d&} t| j"t| j#d'j$n2|dd(krtd(| | |d"|d#|d%d&} | rt|tj| jd)ddIdHn | j%&d*n|dd+krgd,} |j} | |_|dd-kr~| | vr| '| }|d.}|dkrtd/t(| || ||_nf|dd0kr| | vr| '| }|d.}|t)| krtd/t(| || ||_nt*|d|_tt(|jd1t(|jt |d|jd2IdHn|dd3krfdd4lm+}|||dd5|dd6t||IdHnn|dd7ks|dd8krdd9lm,}m-}|dd7kr|||dn|dd8kr|||dt||IdHn|dd:krdd;lm.}|||dt||IdHn|ddkrr|j|_nb|dd?kr|j0j1&d@dA|j0_2|j%&dB|j0j3dC|j0j4dD|j0j5dE7_5|j6&|j0d|_0n|ddFkrddGlm7}dH}|ddHkrdI}|||dJdKdL}dM}t8dN|jj9|}|jj9|}t:;||}||_9||_0tdO|j3dC|j4t ||d|dPIdHnBd|dQ<dR|dvr|d|dT8_>dU|vrP|jj?|dU8_?t@|ddVd|_ |j|_|jA&|d|j%rt)|j%dkr|j%Bd|_$tdW|j$tC|tDdX|j$|dIdHdY|_$dS)ZNz no messageFzutf-8Zreceivedmessagestopzstopped!inactivestartzstarted!activeZrestartzrestart!TtypecharacterSetupr)rZretrievePerson)parseConversations)getPersonDescriptioncSs|jSN__dict__or$/var/www/lichun.app/lichun/ws/api.py.zconsumer..)default conversationr u)r calcEnergyconversationEventinitzinit conversationZ characterIDcType)player characterr'response)r(r)r'r*Z freeResponsecSs|jSrrrrrrrHrz/You don't have enough energy to talk right now.speed)r!ii2-r/zsetting speed to +z -> )r gameSpeedZ focusUpdate) update_focusZ activityIdZnewFocus quitHabit stopQuitHabit)r4r5 purchaseItem)r6purchaseInAppItem)r7Z resetSpeedZ swipeMatch dating_matchz Dating MatchzYou matched with  !(ZgetSwipeCharacter)create_characterFemaleMale random_adultsnone)age relationshipzsending character: )rswipeCharacterkeyz--- energyCost moneyCost diamondCostz/(player,'answer',event['key'],event['message'])zsending message from queue Z answerQueue)Eprint isinstancebytesdecodejsonloadsuserIDr controllerrr occupationsid updateClient functionsrrconversationEventsrravailableConversations descriptionr dumpsrr2previousGameSpeedrcr$energyrr minuteOfHourrr r messageQueueappendindexstrlenintr3r4r5r6r7rE relationshipstitle firstnamelastnameaffinityrr<maxageYearsrandomrandintsplitdictmoneydiamondsevalaskedQuestionspopr r)r websocket playerRecordseventr(rpersonrrrconvZ playerRecordZbuttonSpeedValuesr,Z current_indexZ next_indexr3r4r5r6r7r<sexr)Zage_range_widthZ lower_boundZ upper_boundZ random_agerrrconsumers&                 $     "           $       r|)rmrVrrrrrOrWrrappr r r r r|rrrrs