o -mj@sdZddlmZddlZddlZddlmZmZmZm Z e e Z dZ d1d d Zd2ddZd3ddZd4ddZd5ddZddddd6d"d#Zddd$dd%d7d(d)Zd8d+d,Zdd-d9d/d0ZdS):ud Opt-in per-call-group configuration helpers. Safety contract: - group_config_enabled defaults to 0 on every BID. - When disabled, all resolvers use the existing BID-level tables/config only. - When enabled: 1) map call groupname → named parameter_scope (if configured in UI) 2) else try exact groupname as scope 3) else fall back to BID defaults ) annotationsN)AnyDictListOptionalvalue Optional[str]returnstrcCst|pdS)zOEmpty string = BID default set. Non-empty = Mcube call groupname or named pack.r)r strip)rr >/home/aiteam/pcaa-dev/dashboard-backend/group_scoped_config.pynormalize_scope_groupnamesr pipeline_cfgOptional[Dict[str, Any]]boolc Cs6zt|pidp ddkWSttfyYdSw)Ngroup_config_enabledrF)intget TypeError ValueError)rr r ris_group_config_enableds r db_handlerrbidc CsVz|||p i}t|WSty*}ztd||WYd}~dSd}~ww)Nz,group_config_enabled check failed for %s: %sF)%ensure_business_pipeline_config_tableget_pipeline_configr Exceptionloggerdebug)rrcfgexcr r ris_group_config_enabled_for_bid$s r#callidc Cst|}t|}|r|sdS|d}z4|%}|}|d|d|f|p1i}t|dWdWS1sDwYWdStyf}zt d|||WYd}~dSd}~ww)z6Read groupname from {bid}_raw_calls; empty if missing.r _raw_callszSELECT groupname FROM `z` WHERE callid = %s LIMIT 1 groupnameNz&Could not load groupname for %s/%s: %s) r r get_connectioncursorexecutefetchonerrrrr )rrr$tableconnr(rowr"r r rget_call_groupname.s(       (r. Optional[Any]r&c Cspt|}|r |dur |Sz|||}|rt|WSW|Sty7}ztd|||WYd}~|Sd}~ww)z Resolve which parameter pack key to load for a call group. Uses UI scope map when present; otherwise the call groupname itself. Nz/parameter scope map lookup failed for %s/%s: %s)rget_parameter_scope_for_grouprrr )rrr&scopemappedr"r r rresolve_parameter_scope_keyCs   r3F)r&rrquality_handlerrList[Dict[str, Any]]c Cst|}|s||pgSt|||}|rB|||pg}|r#|St|}|r4||kr4||p3gS|rB|||p=g}|rB|S||pHgS)u Return quality parameters for analysis. Flag off → always BID default table (current behavior). Flag on → mapped/named scope rows if present, else exact group, else BID default. r r get_parametersr3get_parameters_for_scoper) r4rr&rrr1scopedoriginalexactr r rresolve_quality_parametersXs   r<T)r&r active_onlyrpropensity_handlerr=c Cst|}|s|j||dpgSt|||}|rJ|j|||dp"g}|r'|St|}|r:||kr:|j||dp9gS|rJ|j|||dpEg} | rJ| S|j||dpRgS)N)r=r6) r>rr&rr=rr1r9r:r;r r rresolve_propensity_parameters{s(   r?Dict[str, Any]c Cs t|pi}t|s |St|}|s|Sz|||}t|p |}Wn ty-|}Ynwz|||p6i}|sE||krE|||pDi}Wntyb} ztd||| |WYd} ~ Sd} ~ ww|sg|S|d} | durt |  rt |  |d<|ddur|d|d<|S)z Return pipeline config, optionally overlaying group summary overrides. When flag is off or no group row exists, returns a shallow copy of pipeline_cfg. z&group config load failed for %s/%s: %sN summary_modesummary_instructions) dictrrr0rget_business_group_configrr rr r lower) rrrr&baser1r2lookupoverrider"moder r rmerge_pipeline_config_for_groups<     rJ)rintegration_configc Cs t|pi}|s |St|}|s|Sz|||}t|p|}Wn ty+|}Ynwz|||p4i} | sC||krC|||pBi} Wn tyO|YSw| d} t| trq| rqzt | } Wn typd} Ynwt| tr| rt|} | | | S|S)zAShallow-merge CRM toggle overrides for a call group when enabled. crm_configN) rCrr0rrDr isinstancer r jsonloadsupdate) rrrKr&rrFr1r2rGrHcrmmergedr r rmerge_crm_config_for_groups@        rS)rr r r )rrr r)rrrr r r)rrrr r$r r r )rr/rr r&r r r ) r4rrr r&r rrrr/r r5)r>rrr r&r rrr=rrr/r r5) rrrr rrr&r r r@) rrrr rKrr&r rrr r@)__doc__ __future__rrNloggingtypingrrrr getLogger__name__r DEFAULT_SCOPErrr#r.r3r<r?rJrSr r r rs0      ' 2