iddlZddlZddlmZmZmZmZmZmZddl m Z ddl m Z m Z ddlmZddlmZmZmZmZddlmZmZmZmZddlmZmZmZmZmZm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z( Gd d Z)y) N)AnyOptionalUnionListDictSequence)warn)payloadSelfDescribingJson)Subject)non_empty_stringone_of non_empty form_element)VERSIONDEFAULT_ENCODE_BASE64BASE_SCHEMA_PATH SCHEMA_TAG)EventPagePingPageViewSelfDescribingStructuredEvent ScreenView)JsonEncoderFunctionEmitterProtocolFORM_NODE_NAMES FORM_TYPES FormNodeNameElementClasses FormClassescXeZdZddedfdedeeeefdee deede dee ddfd Z e defd Ze dWd eedefd Z d edeefdZd edej*fdZ dXdedeedeedeeed eedee ddfdZ dYdedeedeedeedeedeedeedeeed eedee ddfdZ dZdedeedeedeedeedeeed eedee ddfd Z dZd!ed"ed#eed$eed%eed&eedeeed eedee ddfd'Z dZd!ed"ed#eed$eed%eed&eedeeed eedee ddfd(Z dXd)edeed*ed+eed,eedeedeeed eedee ddfd-Z dXd)ed.ee d/eee!ee"fdeeed eedee ddfd0Z# d[d1e$ed2ee!eeee ffd3eed4eedeeed eedee ddfd5Z% d[d6ed!ed7ed"ed#eed$eed&eedeeed eedee ddfd8Z& d\d6ed9ed:eed;eedeed?eed&eed@eee!ee"fdeeed eedee ddfdAZ' dXd#eedBeedeeed eedee ddf dCZ( dYd#edBeedDeedEeedFeedGeedHeedeeed eedee ddfdIZ) d[d$edJedKeedLeed+eeeefdeeed eedee ddfdMZ* d]dNedeeed eedee ddf dOZ+ d]dNedeeed eedee ddf dPZ,d^dQe ddfdRZ-dee ddfdSZ.dTeddfdUZ/defdVZ0y)_TrackerN namespaceemitterssubjectapp_id encode_base64 json_encoderreturnc| t}t|trt|||_n|g|_||_||_||_t||d|_ d|_ y)a :param namespace: Identifier for the Tracker instance :type namespace: string :param emitters: Emitters to which events will be sent :type emitters: list[>0](emitter) | emitter :param subject: Subject to be tracked :type subject: subject | None :param app_id: Application ID :type app_id: string_or_none :param encode_base64: Whether JSONs in the payload should be base-64 encoded :type encode_base64: bool :param json_encoder: Custom JSON serializer that gets called on non-serializable object :type json_encoder: function | None N)tvtnaaid) r isinstancelistrr%r&r(r)rstandard_nv_pairstimer)selfr$r%r&r'r(r)s Y/var/www/html/strategist-ai/venv/lib/python3.12/site-packages/snowplow_tracker/tracker.py__init__zTracker.__init__9s_. ?iG h % h $DM%JDM*1 *((/ &!Q c<ttjS)z Set transaction ID for the payload once during the lifetime of the event. :rtype: string )struuiduuid4r6r4get_uuidzTracker.get_uuid`s4::<  r6tstampct|ttfr t|SttjdzS)z :param tstamp: User-input timestamp or None :type tstamp: int | float | None :rtype: int i)r/intfloattime)r=s r4 get_timestampzTracker.get_timestampjs<    v; 499;%&&r6eventc|j|}|jD]}|j|jd|jj vr|jdSy)z Send the event payload to a emitter. Returns the tracked event ID. :param event: Event :type event: events.Event :rtype: String rCeidN)complete_payloadr%inputnv_pairskeys)r3rCr emitters r4trackz Tracker.tracksp''( }} ,G MM'** + , G$$))+ +##E* *r6c6|j|j|j|j}|jdt j |jdt j|j|j|S)N)r(r)r&rFdtm) build_payloadr(r)r&addr#r<rBadd_dictr1)r3rCr s r4rGzTracker.complete_payloads%%,,**LL&   E7++-. E70023//0r6page_url page_titlereferrercontext event_subjectcptdtdt||||||}|j||S)a :param page_url: URL of the viewed page :type page_url: non_empty_string :param page_title: Title of the viewed page :type page_title: string_or_none :param referrer: Referrer of the page :type referrer: string_or_none :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zitrack_page_view will be removed in future versions. Please use the new PageView class to track the event. stacklevel)rRrSrTrVrUtrue_timestamprE)r DeprecationWarningrrL)r3rRrSrTrUr=rVpvs r4track_page_viewzTracker.track_page_viewsH0 w  !'!     r6min_xmax_xmin_ymax_yc xtdtdt||||||||| |  } |j| |S)a :param page_url: URL of the viewed page :type page_url: non_empty_string :param page_title: Title of the viewed page :type page_title: string_or_none :param referrer: Referrer of the page :type referrer: string_or_none :param min_x: Minimum page x offset seen in the last ping period :type min_x: int | None :param max_x: Maximum page x offset seen in the last ping period :type max_x: int | None :param min_y: Minimum page y offset seen in the last ping period :type min_y: int | None :param max_y: Maximum page y offset seen in the last ping period :type max_y: int | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zitrack_page_ping will be removed in future versions. Please use the new PagePing class to track the event.rXrY) rRrSrTr_r`rarbrUr[rVrE)r r\rrL) r3rRrSrTr_r`rarbrUr=rVpps r4track_page_pingzTracker.track_page_pingsUH w  !!'     r6 target_url element_idelement_classeselement_targetelement_contentc tdtdt|i} || d<||| d<||| d<||| d<||| d<ttd t d | } |j | ||| |S) a :param target_url: Target URL of the link :type target_url: non_empty_string :param element_id: ID attribute of the HTML element :type element_id: string_or_none :param element_classes: Classes of the HTML element :type element_classes: list(str) | tuple(str,\*) | None :param element_target: ID attribute of the HTML element :type element_target: string_or_none :param element_content: The content of the HTML element :type element_content: string_or_none :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zptrack_link_click will be removed in future versions. Please use the new SelfDescribing class to track the event.rXrY targetUrl elementIdelementClasses elementTargetelementContentz /link_click/z/1-0-1 event_jsonrUr=rVr r\r r rrtrack_self_describing_event) r3rfrgrhrirjrUr=rV propertiesrrs r4track_link_clickzTracker.track_link_click s< ~  $<> ", ;  !&0J{ #  &+:J' (  %*8J '  &+:J' ('(8* Ez  ((!' )  r6skuquantitynamecategory unit_pricecurrencyc tdtdt|i} || d<|| d<||| d<||| d<||| d<||| d <ttd t d | } |j | ||| |S)  :param sku: Item SKU or ID :type sku: non_empty_string :param quantity: Number added to cart :type quantity: int :param name: Item's name :type name: string_or_none :param category: Item's category :type category: string_or_none :param unit_price: Item's price :type unit_price: int | float | None :param currency: Type of currency the price is in :type currency: string_or_none :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker z8track_add_to_cart will be deprecated in future versions.rXrYrwrxryrz unitPricer|z /add_to_cart//1-0-0rqrs r3rwrxryrzr{r|rUr=rVrurrs r4track_add_to_cartzTracker.track_add_to_cartFsB F  ?A  5!) :  !%Jv   %-Jz "  !&0J{ #  %-Jz "')9: F   ((!' )  r6c tdtdt|i} || d<|| d<||| d<||| d<||| d<||| d <ttd t d | } |j | ||| |S) r~z=track_remove_from_cart will be deprecated in future versions.rXrYrwrxryrzrr|z/remove_from_cart/rrqrsrs r4track_remove_from_cartzTracker.track_remove_from_cartsB K  8:  5!) :  !%Jv   %-Jz "  !&0J{ #  %-Jz "'.> KZ  ((!' )  r6form_id node_namevaluetype_c Vtdtdt|t|t|t|j t t} || d<|| d<|| d<|| d<||| d<||| d <ttd td | } |j| ||| |S) a :param form_id: ID attribute of the HTML form :type form_id: non_empty_string :param element_id: ID attribute of the HTML element :type element_id: string_or_none :param node_name: Type of input element :type node_name: form_node_name :param value: Value of the input element :type value: string_or_none :param type_: Type of data the element represents :type type_: non_empty_string, form_type :param element_classes: Classes of the HTML element :type element_classes: list(str) | tuple(str,\*) | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zqtrack_form_change will be removed in future versions. Please use the new SelfDescribing class to track the event.rXrYformIdrmnodeNamertypernz /change_form/rrq) r r\r rrlowerrdictr rrrt) r3rrgrrrrhrUr=rVrurrs r4track_form_changezTracker.track_form_changesB   !y/*   5;;=* -FJf & 8", ;!* :# 7  !&Jv   &+:J' (')9: F   ((!' )  r6 form_classeselementsc tdtdt||xsgD] }t|t }||d<|||d<|t |dkDr||d<t tdtd |} |j| ||| |S) a :param form_id: ID attribute of the HTML form :type form_id: non_empty_string :param form_classes: Classes of the HTML form :type form_classes: list(str) | tuple(str,\*) | None :param elements: Classes of the HTML form :type elements: list(form_element) | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zqtrack_form_submit will be removed in future versions. Please use the new SelfDescribing class to track the event.rXrYr formClassesrrz /submit_form/rrq) r r\r rrlenr rrrt) r3rrrrUr=rVelementrurrs r4track_form_submitzTracker.track_form_submits0   !~2 "G  ! " F  ' 8  #(4J} %  CMA$5%-Jz "')9: F   ((!' )  r6termsfilters total_results page_resultsctdtdt|i}||d<|||d<|||d<|||d<ttdt d |} |j | ||| |S) a4 :param terms: Search terms :type terms: seq[>=1](str) :param filters: Filters applied to the search :type filters: dict(str:str|bool) | None :param total_results: Total number of results returned :type total_results: int | None :param page_results: Total number of pages of results :type page_results: int | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zqtrack_site_search will be removed in future versions. Please use the new SelfDescribing class to track the event.rXrYrr totalResults pageResultsz /site_search/rrq)r r\rr rrrt) r3rrrrrUr=rVrurrs r4track_site_searchzTracker.track_site_search?s6   %  $ 7  $+Jy !  $)6J~ &  #(4J} %')9: F   ((!' )  r6order_idpricec Vtdtdt|t|t| || } | jj dd| jj d|| jj d|| jj d || jj d || jj d || jj d || jj d ||j | |S)a This is an internal method called by track_ecommerce_transaction. It is not for public use. :param order_id: Order ID :type order_id: non_empty_string :param sku: Item SKU :type sku: non_empty_string :param price: Item price :type price: int | float :param quantity: Item quantity :type quantity: int :param name: Item name :type name: string_or_none :param category: Item category :type category: string_or_none :param currency: The currency the price is expressed in :type currency: string_or_none :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zGtrack_ecommerce_transaction_item will be deprecated in future versions.rXrYrVrUr[etiti_idti_skti_nmti_cati_prti_quti_curE)r r\r rr rPrL) r3rrwrrxryrzr|rUr=rVrCs r4 track_ecommerce_transaction_itemz(Tracker.track_ecommerce_transaction_itemxsN U  "'   #t$ '8, '3' '4( '8, '5) '8, '8,   r6 total_value affiliation tax_valueshippingcitystatecountryitemscFtdtdt|t| | | }|jj dd|jj d||jj d||jj d ||jj d ||jj d ||jj d ||jj d ||jj d||jj d| t j| } |j|| g} | D]-}||d<| |d<| |d<| |d<| |d<|jdi|/|S)a :param order_id: ID of the eCommerce transaction :type order_id: non_empty_string :param total_value: Total transaction value :type total_value: int | float :param affiliation: Transaction affiliation :type affiliation: string_or_none :param tax_value: Transaction tax value :type tax_value: int | float | None :param shipping: Delivery cost charged :type shipping: int | float | None :param city: Delivery address city :type city: string_or_none :param state: Delivery address state :type state: string_or_none :param country: Delivery address country :type country: string_or_none :param currency: The currency the price is expressed in :type currency: string_or_none :param items: The items in the transaction :type items: list(dict(str:\*)) | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zBtrack_ecommerce_transaction will be deprecated in future versions.rXrYrrtrtr_idtr_tttr_aftr_txtr_shtr_citr_sttr_cotr_curErr|r=rVrUr;) r r\r rr rPr#rBrLr)r3rrrrrrrrr|rrUr=rVrCitems r4track_ecommerce_transactionz#Tracker.track_ecommerce_transactions|Z P  "'   #t$ '8, ';/ ';/ '9- '8, '4( '5) '7+ '8,&&v.   =E :D'D 'D #DN$1D !%DO 1D 1 1 9D 9  : r6id_ctdtdi}|||d<|||d<ttdtd|}|j |||||S) aX :param name: The name of the screen view event :type name: string_or_none :param id_: Screen view ID :type id_: string_or_none :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zmtrack_screen_view will be removed in future versions. Please use the new ScreenView class to track the event.rXrYryidz /screen_view/rrq)r r\r rrrt)r3ryrrUr=rVscreen_view_propertiesrrs r4track_screen_viewzTracker.track_screen_views{* {  "$  -1 "6 * ?+. "4 (')9: F " ((!' )  r6r previous_name previous_id previous_typetransition_typec tdtd||j}t|||||||| ||  } |j | |S)a :param name: The name of the screen view event :type name: string_or_none :param id_: Screen view ID. This must be of type UUID. :type id_: string | None :param type: The type of screen that was viewed e.g feed / carousel. :type type: string | None :param previous_name: The name of the previous screen. :type previous_name: string | None :param previous_id: The screenview ID of the previous screenview. :type previous_id: string | None :param previous_type The screen type of the previous screenview :type previous_type string | None :param transition_type The type of transition that led to the screen being viewed. :type transition_type string | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zttrack_mobile_screen_view will be removed in future versions. Please use the new ScreenView class to track the event.rXrY) ryrrrrrrrVrUr[rE)r r\r<rrL) r3ryrrrrrrrUr=rVsvs r4track_mobile_screen_viewz Tracker.track_mobile_screen_view5shH  C  ;--/C '#'+'!     r6actionlabel property_c ttdtdt||||||||} |j| |S)a :param category: Category of the event :type category: non_empty_string :param action: The event itself :type action: non_empty_string :param label: Refer to the object the action is performed on :type label: string_or_none :param property_: Property associated with either the action or the object :type property_: string_or_none :param value: A value associated with the user action :type value: int | float | None :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker zntrack_struct_event will be removed in future versions. Please use the new Structured class to track the event.rXrY)rzrrrrrUr[rVrE)r r\rrL) r3rzrrrrrUr=rVses r4track_struct_eventzTracker.track_struct_eventqsW@ |  !'      r6rrcltdtdt||||}|j||S) :param event_json: The properties of the event. Has two field: A "data" field containing the event properties and A "schema" field identifying the schema against which the data is validated :type event_json: self_describing_json :param context: Custom context for the event :type context: context_array | None :param tstamp: Optional event timestamp in milliseconds :type tstamp: int | float | None :param event_subject: Optional per event subject :type event_subject: subject | None :rtype: Tracker z{track_self_describing_event will be removed in future versions. Please use the new SelfDescribing class to track the event.rXrY)rrrUr[rVrE)r r\rrL)r3rrrUr=rVsds r4rtz#Tracker.track_self_describing_eventsM(  J  !!'      r6cTtdtd|j|||||S)rzctrack_unstruct_event will be deprecated in future versions. Please use track_self_describing_event.rXrYrq)r r\rt)r3rrrUr=rVs r4track_unstruct_eventzTracker.track_unstruct_events=( q  ((!' )  r6is_asyncc|jD]?}|rt|ds|j#t|ds0|jA|S)z Flush the emitter :param is_async: Whether the flush is done asynchronously. Default is False :type is_async: bool :rtype: tracker flush sync_flush)r%hasattrrr)r3rrKs r4rz Tracker.flushsJ}} )G7G,MMO7L1&&(  ) r6c||_|S)z Set the subject of the events fired by the tracker :param subject: Subject to be tracked :type subject: subject | None :rtype: tracker )r&)r3r&s r4 set_subjectzTracker.set_subjects  r6rKc<|jj||S)z Add a new emitter to which events should be passed :param emitter: New emitter :type emitter: emitter :rtype: tracker )r%append)r3rKs r4 add_emitterzTracker.add_emitter s W% r6c |jdS)Nr-)r1)r3s r4 get_namespacezTracker.get_namespaces %%e,,r6)N)NNNNN) NNNNNNNNN)NNNNNNN)NNNNNN) NNNNNNNNNNN)NNN)F)1__name__ __module__ __qualname__rr8rrrrr boolrr5 staticmethodr<r@r?rBrrLr PayloadrGr r^rer rvrrrrr!rrrrrrrrrrrtrrrrrr;r6r4r#r#8s7 &* $36:%%_->?%'" %  %  %23% %N!c!!'huo'''  #. &%)"&6:"&+/((SM(3- ( $123 (  ( (( (Z%)"&####6:"&+/88SM83- 8 } 8 } 8}8}8$12388 (8 8z%)48(,)-6:"&+/::SM:".1 : ! : "# :$123:: (: :@#"&&*"&6:"&+/> >>sm > 3- > UO >3->$123>> (> >H#"&&*"&6:"&+/> >>sm > 3- > UO >3->$123>> (> >L $486:"&+/@@SM@ @ } @ } @".1@$123@@ (@ @J/3376:"&+/55{+54S#X/0 5 $123 5  5 (5 5t:>'+&*6:"&+/7}7$sE#t)$44567 } 7 sm 7 $123 77 (7 7~#"&"&6:"&+/<<< <  < sm <3-<3-<$123<< (< <D&*%)$("#!%"&046:"&+/PPPc] P E? P 5/ PsmP}P#P3-PT#s(^,-P$123PP (P Ph#!6:"&+/ +sm+c]+$123 +  +  ( + +`""'+%)'+)-6:"&+/::c]:sm :  } : c] : }:"#:$123:: (: :@ $#'-16:"&+/333} 3 C= 3 c5j)* 3$12333 (3 3p7;"&+/ #&#$123# #  ( #  #R7;"&+/ & $123    (   Ddy" 8G#4   ? y -s-r6r#)*rAr9typingrrrrrrwarningsr snowplow_trackerr r snowplow_tracker.subjectr snowplow_tracker.contractsr rrrsnowplow_tracker.constantsrrrrsnowplow_tracker.eventsrrrrrrsnowplow_tracker.typingrrrrrr r!r#r;r6r4rsV$ ==8,XX c-c-r6