j UdZddlmZddlZddlZddlmZddlmZddl m Z ddl Z dZ de d <d Zde d <ed GddZGddZGddZy)zEPrivate durable addresses for the profile-gated Telegram check-in UI.) annotationsN) dataclass)Path)Finaliz Final[int]_MODEi _DIR_MODET)slotsceZdZUdZded<ded<ded<ded<ded<ded <ded <ded <d Zd ed<eddZddZy) WizardBindingzENo health values: only the exact Telegram address of a wizard prompt.str session_idowner_idchat_idtopic_idstepintversion message_id expires_atFbool awaiting_textcvttsyd}tfd|Dry tj d}tj d}|dks|dkry|dddd d |d |tj d d  S#t t f$rYywxYw)N)r rrrrrc3nK|],}tj|t xs| .ywN) isinstancegetr ).0keyvalues j/home/cube/projects/richard/.worktrees/nutricoach-v140-impl/gateway/platforms/physique_checkin_bindings.py z*WizardBinding.from_dict..%s4YPX:eiinc22D%*nDPXs25rrrr rrrrrrF r rrrrrrrr)rdictanyrr TypeError ValueErrorr)clsrrequiredrrs ` r from_dictzWizardBinding.from_dict s%&Z YPXY Y %))I./GUYY|45J Q;*/\*U:5FPUV_P`:&U6]G\*zuyy%@A   :&  s4B&&B87B8c |j|j|j|j|j|j |j |j|jd S)Nr"r"selfs r to_dictzWizardBinding.to_dict5sK//t}}QUQ]Q] tyyT\\//!//   N)robjectreturnzWizardBinding | None)r0zdict[str, str | int | bool]) __name__ __module__ __qualname____doc____annotations__r classmethodr)r-r.r r r sNOOM LM I LOOM4  ( r.r c6eZdZdZddZd dZd dZd dZdZy) BindingStorezKAtomic owner-only persistence for prompt addresses across gateway restarts.cX||_|j|jdz|_y)Nz.lock)_path with_suffixsuffix _lock_path)r,paths r __init__zBindingStore.__init__As$ **4;;+@Ar.c*|j5|j}t|tr|j dgng}i}t|t r|ngD]b}t j|} | | j|kr*| j| j| jf|||fk7rT| || j<dt|tr|j dnd} t| tr| |vr| nd} || fcdddS#1swYyxYw)Nbindingsactive_session_id)_locked_read_unlockedrr#rlistr r)rrrrr r ) r,rrr now_epochrawvaluesrBitembindingactive active_ids r loadzBindingStore.loadEs \\^%%'C0:30ESWWZ,2F13H",VT":B'11$7?g&8&8I&E$$goow7G7GHXW^`hLii/6++, C6@T5JSWW01PTF",VS"9f>PVZIY&^^s C.D  DcV|j5d||jDcgc]}|jc}d}|jjj ddt |jjjt |jj|jjdz}|jdd5}|jttj||d d |jtj |j#dddtj$||j|jjtdddycc}w#1swYVxYw#1swYyxYw) N)rrCrBTparentsexist_okmodez.tmpwutf-8encoding),:) separators sort_keys)rDrIr-r;parentmkdirrchmodr<r=openrjsondumpflushosfsyncfilenoreplace)r,rBrCrKpayload temporaryhandles r savezBindingStore.saveUs* \\^%6>Foo>OP>O7W__.>OPG JJ   # #D4i # P JJ   # #I . ..tzz/@/@6/IJIg6&& '6jDQ ) 7 JJy$** - JJ  U #^Q 76^s6FF BFA"F>AFFF FF(c|jjsiS tj|jj dS#t tj f$ricYSwxYw)NrVrW)r;existsraloads read_textOSErrorJSONDecodeErrorr+s r rEzBindingStore._read_unlockedgs\zz  "I ::djj22G2DE E--. I s.A A+*A+c|jjjddt|jjj t|jj dd}|jj t tj|jtjt|S)NTrQarVrW) r>r]r^rr_r`rfcntlflockrfLOCK_EX _BindingLockr,rjs r rDzBindingStore._lockedos $$TDy$Q $$Y/%%cG%< e$ FMMOU]]3F##r.N)r?rr0None) rr rr rr rGrr0z+tuple[dict[str, WizardBinding], str | None])rBzdict[str, WizardBinding]rCz str | Noner0ry)r0r/) r1r2r3r4r@rNrkrErDr7r.r r9r9>sUB' $$$r.r9c$eZdZddZddZddZy)rwc||_yr)_handlerxs r r@z_BindingLock.__init__ys  r.cyrr7r+s r __enter__z_BindingLock.__enter__|sr.ctj|jjtj|jj yr)rtrur|rfLOCK_UNclose)r,exc_typeexc tracebacks r __exit__z_BindingLock.__exit__s1 DLL'')5==9 r.N)r0ry)r1r2r3r@r~rr7r.r rwrwxsr.rw)r4 __future__rrard dataclassesrpathlibrtypingrrtrr5rr r9rwr7r.r rsgK" ! z : ( ( ( V7$7$t  r.