idZddlmZddlmZmZddlmZddlmZddl m Z ddl m Z ddlmZeeZd Zd Zd Zd Zd ZdZdZdZdddZddZddZddZddZddZd dZ y)!u services/participant_repo.py ============================ Data-access layer for the `participant` table in the e-Recruit Postgres DB. Responsibilities: • Look up a participant by `access_key` (case-insensitive). • Log the full DB row during initial bring-up (LOG_DB_PAYLOAD env flag). • Map raw DB columns to a canonical, route-friendly dict. • Be tolerant of column-name variations (e.g., participant_id vs id, candidate_name vs name, stage vs current_stage). • Optionally update last-login timestamp without breaking if the column doesn't exist in the target schema. Nothing else in the codebase should query the participant table directly. ) annotations)datetimetimezone)Any)sql)settings)database) get_logger)idparticipant_id candidate_iduiduuid)namecandidate_nameparticipant_name full_name display_name)emailemail_id email_address)phonemobile mobile_no contact_no) current_stagestagestage_nointerview_stage) access_key accesskey access_code login_key)position_appliedposition role_appliedjob_role designation) skill_setskillsskillNc6|D]}||vs||||cS|S)zCReturn the value from the first key present in `row`, else default.)row candidatesdefaultcs t/Users/priyanka/Documents/AI_Agent_Assessment/pepole_hub_candidate/people_hub_candidate/services/participant_repo.py_first_presentr3-s,  8A*q6M Nct|gSt|trA|Dcgc]5}t|jst|j7c}St|tr>|j dDcgc]#}|js|j%c}St|gScc}wcc}w)zKSkills column might be text[] or comma-separated string. Normalize to list.,) isinstanceliststrstripsplit)valuevss r2_coerce_skillsr?5s } %(-@1QA @@%#(;;s#3A#3aqwwy #3AA J<AAsB0B09B5B5cv|y t|S#ttf$rtj d|YywxYw)zBStage column might be int, str or NULL. Default to 1 (Assessment).u4Could not parse current_stage=%r — defaulting to 1)int TypeError ValueErrorlogwarning)r<s r2 _coerce_stagerG@s? }5z z " JERs %88ct|td}t|td}t|td}t|td}t t|t d}t|td}t|td}tt|td}| t|ndt|xsdt|xsdt|xsd|t|xsdjt|xsd||jd|jd|jD cic](\} } | t| t s| n| j#*c} } d Scc} } w)u Map a raw participant row → canonical dict used by the rest of the app. Original raw row is preserved under `_raw` for debugging. CandidaterAN last_loginlast_question_attempt) r rrrrr r$r)rKrL_raw)r3_ID_COLS _NAME_COLS _EMAIL_COLS _PHONE_COLSrG _STAGE_COLS _KEY_COLS_POSITION_COLSr? _SKILLS_COLSr9uppergetitemsr7r isoformat) r.pidrrrrkeyr%r*kr=s r2 _normalizer]Ks; sHb1CsJ  WHERE UPPER(access_key) = UPPER(%s) Returns the normalized participant dict, or None. Nz:SELECT * FROM {table} WHERE UPPER(access_key) = %s LIMIT 1)tableu,[participant] login lookup → access_key=%sz![participant] DB query failed: %sz4[participant] no participant found for access_key=%su[participant] raw DB row → %su&[participant] columns available → %su@[participant] login resolved → id=%s name=%s stage=%d email=%sr rrr)r:rVr IdentifierrDB_TABLE_PARTICIPANTSQLformatrEinfodb get_cursorexecutefetchone Exception exceptionrFdictLOG_DB_PAYLOADsortedkeysr])raw_keyr[r_querycurr.exc normalizeds r2find_by_access_keyrtksP  --/   !C NN888 9E GGD  f5f HH ;SA ]]_ KKv &,,.C  JCP s)C 2C8 96#((*;MNCJHHJ4*V,?#Z%8 1_  93? s0E6$E*9E6*E3/E66 F?FFcF|sytjtj}d}tD]}tj dj |tj|} tj5}|j|t|f|j}dddrtt|cS|rtj#d|y#1swY<rs| #' #FY 4 < G E \/ @,^8Sr4