.hG ddlZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z ddl mZmZmZmZmZmZmZmZddlmZddlmZdd ed ed ed dfd ZGddZeZy)N)Path)Thread)Requesturlopen)SETTINGS __version__)ARGV ENVIRONMENTGITIS_PIP_PACKAGEONLINEPYTHON_VERSIONRANK TESTS_RUNNING)GITHUB_ASSETS_NAMES) get_cpu_infourldatatimeoutreturnc tj|dj}t||ddi}t ||j y#t $rYywxYw)z"Send a one-shot JSON POST request.),:) separatorsz Content-Typezapplication/json)rheaders)rN)jsondumpsencoderrclose Exception)rrrbodyreqs V/var/www/html/ai-service/venv/lib/python3.12/site-packages/ultralytics/utils/events.py_postr$sY zz$:6==?c~?Q.RSW%++-    sAA AAc&eZdZdZdZddZdddZy)Eventsa Collect and send anonymous usage analytics with rate-limiting. Event collection and transmission are enabled when sync is enabled in settings, the current process is rank -1 or 0, tests are not running, the environment is online, and the installation source is either pip or the official Ultralytics GitHub repository. Attributes: url (str): Measurement Protocol endpoint for receiving anonymous events. events (list[dict]): In-memory queue of event payloads awaiting transmission. rate_limit (float): Minimum time in seconds between POST requests. t (float): Timestamp of the last transmission in seconds since the epoch. metadata (dict): Static metadata describing runtime, installation source, and environment. enabled (bool): Flag indicating whether analytics collection is active. Methods: __init__: Initialize the event queue, rate limiter, and runtime metadata. __call__: Queue an event and trigger a non-blocking send when the rate limit elapses. zihttps://www.google-analytics.com/mp/collect?measurement_id=G-X8NCJYTQXM&api_secret=QLQrATrNSwGRFRLE-cbHJwNc g|_d|_d|_ttdj dk(t jrdn trdndtjdd dtttttjd zd d |_t"d xr6t$dvxr,t& xr#t(xrtxst j*dk(|_y)zRInitialize the Events instance with queue, rate limiter, and environment metadata.g>@gryologitpipother.g4&k Ci)cliinstallpythonCPUversionenv session_idengagement_time_msecsync>rz.https://github.com/ultralytics/ultralytics.gitN)events rate_limittrr namer is_repor rrsplitrrr roundrandommetadatarrrr originenabled)selfs r#__init__zEvents.__init__1s Q=%%/ # u.g$++C3A6>" $ 67$(    V  c c!! c c a3::1a#a cx|jsyt|jdkri|j|j|j t vr |j ndt|d}|jdk(r|j|d<|jj|j|dtj}||jz |jkryt|j}tt |j"t$d|d fd j'g|_||_ y) a3 Queue an event and flush the queue asynchronously when the rate limit elapses. Args: cfg (IterableSimpleNamespace): The configuration object containing mode and task information. device (torch.device | str, optional): The device type (e.g., 'cpu', 'cuda'). Ncustom)taskmodeldeviceexportformat)r;paramsuuid) client_idr8T)targetargsdaemon)rBlenr8r@rIrJrstrmoderMappendtimer:r9listrr$rrstart)rCcfgrKrNr:payload_eventss r#__call__zEvents.__call__Is||  t{{ b --&)ii3F&FHf+ F xx8##&::x KK  FC D IIK J$// ) dkk*(((6*:nUV  %' rE)rN)N)__name__ __module__ __qualname____doc__rrDr]rEr#r&r&s( vC 0'rEr&)g@) rr?rXpathlibr threadingrurllib.requestrr ultralyticsrrultralytics.utilsr r r r r rrrultralytics.utils.downloadsrultralytics.utils.torch_utilsrrUdictfloatr$r&r8rbrEr#rlsb +-qqq;6 s $   VVr rE