\Pi UdZddlmZddlZddlZddlZddlmZmZddlm Z ddl m Z iZ de d<dd Zdd Zdd Zdd Zdd ZddZddZddZddZddZddZdd dZd!dZy)"u~ utils/json_db.py — Thread-safe JSON file storage Same interface as a real DB layer — swap later without touching routes. ) annotationsN)datetimetimezone)Path)Anyzdict[str, threading.Lock]_locksct|j}|tvrtjt|<t|SN)strresolver threadingLock)pathkeys V/Users/priyanka/Documents/Gols_Ai_Dev/public_hub_candidate/people_hub/utils/json_db.py_lockr s4 dlln C &nn&s #;c0|jjdd|jsgS t|d5}t j |}t |tr|ngcdddS#1swYyxYw#tj$rgcYSwxYw)NTparentsexist_okutf-8encoding) parentmkdirexistsopenjsonload isinstancelistJSONDecodeError)rfdatas r_readr&szKKdT2 ;;=  $ )Q99Q+s tE$K  s*3c t|5t|D]:tfd|jDs&t ccdddS dddy#1swYyxYw)Nc3LK|]\}}j||k(ywr get).0kvrecs r zfind_one..2s"?tq!3771:?!$rr&allitemsdict)rfiltersrFs @rfind_onerN/sP t;C?w}}??Cy      s1A  A A  A)c t|5t|Dcgc]/tfd|jDr t 1c}cdddScc}w#1swYyxYw)Nc3LK|]\}}j||k(ywr rA)rCrDrErs rrGzfind_many..9s"AAquuQx1}rHrI)rrMrQs `r find_manyrR6sV t!&tCAAAAQC C sA!4AA!A!!A*ct|5t|D],}|jd|k(st|ccdddS dddy#1swYyxYwNid)rr&rBrL)r record_idrFs r find_by_idrW;sK t;Cwwt} )Cy      s#A AAAcFt|5t|}|jdt|jdt |jdt |j |t ||t|cdddS#1swYyxYw)NrU created_at updated_at)rr& setdefaultr<r8appendr2rL)rrecordr0s rinsertr^Bso t+$), 2, 2vtWF| s BBB ct|5t|}t|D]S\}}|jd|k(si||dt i||<t ||t ||ccdddS dddy#1swYyxYw)NrUrZ)rr& enumeraterBr8r2rL)rrVupdatesr0irFs rupdatercLs t+(FAswwt} )HHwH giH tW%GAJ'' (    s1B0B8BB c|j|}|r t|fi||i}|rt||d|St||SrT)rBrNrcr^)rr] key_fieldkey_valexistings rupsertrhVsJjj#GD9Y$89 $7 7 $ rct|5t|}|Dcgc]}|jd|k7s|}}t|t|k(r dddyt || dddycc}w#1swYyxYw)NrUFT)rr&rBlenr2)rrVr0rQ new_recordss r delete_by_idrl^sq t+")F'QQUU4[I-Eq' F { s7| +  t[! F s&A8A3A3A8 A83A88B)rrreturnzthreading.Lock)rrrm list[dict])rrr0rnrmNone)rmr )rrrMrrm dict | None)rrrMrrmrn)rrrVr rmrp)rrr]rLrmrL)rrrVr rarLrmrp)rU)rrr]rLrer rmrL)rrrVr rmbool)__doc__ __future__rrr r:rrpathlibrtypingrr__annotations__rr&r2r8r<r>rNrRrWr^rcrhrlr7rrrwsk#'$&!& 2!C  r