o 3iw @sddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZmZedZed Zd gZd Zd Zd ZdZdZdZeeZeeeeeZGdddeZ GdddeZ!d=de"de"de"defddZ#ddZ$ddZ% d>d d!Z&d"d#Z'd>d$d%Z(dddddd&defd'd(Z)  d?dd)de*fd*d+Z+de*fd,d-Z,    d@de*fd.d/Z-    d@de*fd0d1Z.d2e"deejfd3d4Z/d2e"de0fd5d6Z1d2e"de0fd7d8Z2d2e"de0fd9d:Z3d2e"de0fd;d<Z4dS)AN)Optional)parser) relativedelta)utils) FlagValue)convert_to_datetime_awareis_valid_regexlposthogis_not)exactr is_set is_not_set) icontains not_icontainsregex not_regexgtgteltlteis_date_before is_date_after) semver_eq semver_neq semver_gt semver_gte semver_lt semver_lte) semver_tilde semver_caretsemver_wildcardc@s eZdZdS)InconclusiveMatchErrorN)__name__ __module__ __qualname__r'r'c/lsinfo/ai/hellotax_ai/llm_service/venv_embed/lib/python3.10/site-packages/posthog/feature_flags.pyr#.sr#c@seZdZdZdS)RequiresServerEvaluationa& Raised when feature flag evaluation requires server-side data that is not available locally (e.g., static cohorts, experience continuity). This error should propagate immediately to trigger API fallback, unlike InconclusiveMatchError which allows trying other conditions. N)r$r%r&__doc__r'r'r'r(r)2sr)keybucketing_valuesaltreturncCs<|d||}tt|dddd}|tS)N.zutf-8)inthashlibsha1encode hexdigest__LONG_SCALE__)r,r-r.hash_keyhash_valr'r'r(_hashBs"r;cCsHt|d|dd}t|D]}||dkr!||dkr!|dSq dS)Nr,variant)r. value_min value_max)r;variant_lookup_table)flagr- hash_valuer<r'r'r(get_matching_variantHs   rBcCsbg}d}|dp idpidpg}|D]}||dd}||||dd|}q|S) Nrfilters multivariatevariantsrollout_percentagedr,)r=r>r,)getappend) feature_flag lookup_tabler= multivariatesr<r>r'r'r(r?Psr?c Cs|dus|durtd|dddd|vr$td|ddd|d}t|d krEtd |dtd |ddd |D]}||vr||} | s`d||<td |d| dsjd||<nGz+| dpqi} | d} | dur~|} nt| ||} t| ||||||| d} | ||<Wnty}zd||<td |d||d}~ww||}|durtd|d|sdSqG|d}|d}|dd}|r|dur||}|durtd|d|dkrt||Std|ddd|d dS)ai Evaluate a flag dependency property according to the dependency chain algorithm. Args: property: Flag property with type="flag" and dependency_chain flags_by_key: Dictionary of all flags by their key evaluation_cache: Cache for storing evaluation results distinct_id: The distinct ID being evaluated properties: Person properties for evaluation cohort_properties: Cohort properties for evaluation device_id: The device ID for bucketing (optional) Returns: bool: True if all dependencies in the chain evaluate to True, False otherwise Nz$Cannot evaluate flag dependency on 'r,unknownz+' without flags_by_key and evaluation_cachedependency_chainzFlag dependency property for 'z.' is missing required 'dependency_chain' fieldrz'Circular dependency detected for flag: z'Circular dependency detected for flag ''z!Cannot evaluate flag dependency 'z!' - flag not found in local flagsactiveFrCaggregation_group_type_indexcohort_properties flags_by_keyevaluation_cache device_idr-z': zFlag dependency 'z' was previously inconclusivevalueoperatorr zFlag 'z5' was not evaluated despite being in dependency chainflag_evaluates_toz' has invalid operator 'T)r#rHlenlogdebugresolve_bucketing_valuematch_feature_flag_propertiesmatches_dependency_value)propertyrTrU distinct_id propertiesrSrVrN dep_flag_keydep_flagdep_flag_filters dep_aggregation_group_type_indexdep_bucketing_value dep_resulte cached_resultflag_keyexpected_valuerX actual_valuer'r'r(evaluate_flag_dependency_s             rncCsZt|trt|dkrt|tr|St|tr||kSdSt|tr+t|tr+||kSdS)a Check if the actual flag value matches the expected dependency value. This follows the same logic as the C# MatchesDependencyValue function: - String variant case: check for exact match or boolean true - Boolean case: must match expected boolean value Args: expected_value: The expected value from the property actual_value: The actual value returned by the flag evaluation Returns: bool: True if the values match according to flag dependency rules rF) isinstancestrrZbool)rlrmr'r'r(r_s  r_cCs>|dpi}|dp|d}|dkr|std|S|S)aResolve the bucketing value for a flag based on its bucketing_identifier setting. Returns: The appropriate identifier string to use for hashing/bucketing. Raises: InconclusiveMatchError: If the flag requires device_id but none was provided. rCbucketing_identifierrVz;Flag requires device_id for bucketing but none was provided)rHr#)r@rarV flag_filtersrrr'r'r(r]s r]rRc Cs|durtjdtddt|||}|dpi}|dpg} d} |p%i}|dp,idp1g} d d | D} | D]=} z)t||| ||||||d re| d }|rY|| vrY|}nt||}|pad WSWq;tyntyxd } Yq;w| rtddS)NzCalling match_feature_flag_properties() without bucketing_value is deprecated. Pass bucketing_value explicitly. This fallback will be removed in a future major release.) stacklevelrCgroupsFrDrEcSsg|]}|dqS)r,r').0r<r'r'r( 8z1match_feature_flag_properties..)r-rVr<TzGCan't determine if feature flag is enabled or not with given properties) warningswarnDeprecationWarningr]rHis_condition_matchrBr)r#)r@rarbrSrTrUrVr-rsflag_conditionsis_inconclusive flag_variantsvalid_variant_keys conditionvariant_overrider<r'r'r(r^sT      r^rVc Cs|d} t|dp gdkrM|dD]1} | d} | dkr,t| ||||||d} n| dkr|kSS|d'krpz tt|\}}Wnttfybtd|d(w|| kom|kSStd|))Nr,rXr rWzUnknown operator z5can't match properties without a given property valuer z/can't match properties with operator is_not_setF)r r cSs0t|trt|dd|DvSt||S)NcSsg|]}t|qSr')rpcasefold)rwvalr'r'r(rxs z?match_property..compute_exact_match..)rolistrprr str_iequals)rWoverride_valuer'r'r(compute_exact_matchs  z+match_property..compute_exact_matchr rrrrrcSsN|dkr||kS|dkr||kS|dkr||kS|dkr ||kStd|)NrrrrzInvalid operator: ) ValueError)lhsrhsrXr'r'r(compareszmatch_property..comparerz.The date set on the flag is not a valid formatrz'The date provided is not a valid formatz1The date provided must be a string or date objectzPerson property value 'z' is not a valid semverzFlag semver value 'rrrrrrr z!' is not valid for tilde operatorr!z!' is not valid for caret operatorr"z$' is not valid for wildcard operator)rHPROPERTY_OPERATORSr#NONE_VALUES_ALLOWED_OPERATORSr str_icontainsrrprecompilesearchfloat Exceptionro-relative_date_parse_for_feature_flag_matchingrparserdatetimedateSEMVER_OPERATORS parse_semverr TypeErrorSEMVER_COMPARISON_OPERATORS _tilde_bounds _caret_bounds_wildcard_bounds)r`property_valuesr,rXrWrrr parsed_value parsed_dateri override_dateoverride_parsed flag_parsedlowerupperr'r'r(rs                                          rc CsDt|d}||vrtd|d||}t|||||||dS)NrWzcohort zT not found in local cohorts - likely a static cohort that requires server evaluationr)rprHr)match_property_group) r`rrSrTrUrarV cohort_idproperty_groupr'r'r(rTs rc Cs|sdS|d}|d}|rt|dkrdSd} d|dvrs|D]F} zt| ||||||d} |dkr;| s:WdSn| rAWdSWq"tyJtyh} ztd| d | d} WYd} ~ q"d} ~ ww| rotd |dkS|D]} zX| dd krt| ||||||d} n| dd krt| ||||||d} nt | |} | d d} |dkr| s| sWdS| r| rWdSn| r| sWdS| s| rWdSWqutyty} ztd| d | d} WYd} ~ qud} ~ ww| rtd|dkS)NTrvaluesrFrANDzFailed to compute property z locally: z8Can't match cohort without a given cohort property valuerr@negationz8can't match cohort without a given cohort property value) rHrZrr)r#r[r\rrnr)rrrSrTrUrarVproperty_group_typerberror_matching_locallyrrrirr'r'r(rxs         rrWcCsd}t||}tjtjj}|rgt|d}|dkrdS|d}|dkr1|t|d}|S|dkr>|t|d}|S|d krK|t|d }|S|d krX|t|d }|S|d kre|t|d}|SdSdS)Nz)^-?(?P[0-9]+)(?P[a-z])$numberi'intervalh)hoursd)daysw)weeksm)monthsy)years) rrrnowtimezoneutcr3groupr)rWrmatch parsed_dtrrr'r'r(rs2    rcCst|d}|dddd}|d}|r |ds$tdt|d}t|dkr:|dr:t|dnd}t|dkrL|drLt|dnd}|||fS) a.Parse a semver string into a comparable (major, minor, patch) integer tuple. Matches the behavior of the sortableSemver HogQL function: - Handles v-prefix, whitespace, pre-release suffixes - Defaults missing components to 0 (e.g., 1.2 -> 1.2.0) Raises ValueError if parsing fails. vV-r+r0zInvalid semver formatrt)rpstriplstripsplitrr3rZ)rWtextpartsmajorminorpatchr'r'r(rs   $$ rcCs&t|\}}}|||f||ddffS)z9~1.2.3 means >=1.2.3 <1.3.0 (allows patch-level changes).rrr)rWrrrr'r'r(rsrcCsjt|\}}}|||f}|dkr|dddf}||fS|dkr*d|ddf}||fSdd|df}||fS)zCaret follows semver spec: ^1.2.3 means >=1.2.3 <2.0.0 ^0.2.3 means >=0.2.3 <0.3.0 ^0.0.3 means >=0.0.3 <0.0.4 rrr)rWrrrrrr'r'r(r$s rcCst|dddd}|stddd|dD}|s&tdt|dkr>t|d }|d d f|dd d ffSt|d kr]t|d t|d}}||d f||dd ffSt|d t|dt|d }}}|||f|||dffS) zSWildcard matching: 1.* means >=1.0.0 <2.0.0 1.2.* means >=1.2.0 <1.3.0 r*r+r0zInvalid wildcard patterncSsg|]}|r|qSr'r')rwpr'r'r(rx@ryz$_wildcard_bounds..rrrt) rprrreplacerstriprrrZr3)rWcleanedrrrrr'r'r(r7s    (r)r+)N)NN)NNNN)5rr4loggingrrztypingrdateutilrdateutil.relativedeltarr r posthog.typesr posthog.utilsrrrr8 getLoggerr[rEQUALITY_OPERATORSSTRING_OPERATORSNUMERIC_OPERATORSDATE_OPERATORSrSEMVER_RANGE_OPERATORSrrrr#r)rpr;rBr?rnr_r]r^rqr}rrrrtuplerrrrr'r'r'r(s         " I  4D ( o