U ;hDi@sdZddlZddlZddlmZmZddlmZmZmZm Z m Z ddl m Z m Z mZddlmZmZddlmZmZddlmZdd lmZdd lmZdd lmZdd lmZdd lm Z ddl!m"Z"m#Z#m$Z$ddl%m&Z&m'Z'm(Z(eZ)e*e+Z,eZ-eZ.eZ/ee ddZ0ee ddZ1eeddZ2eeddZ3eeddZ4eeddZ5ee-ddZ6ee.dd Z7d!d"Z8d#d$Z9d%d&Z:d'd(Z;ee/d)d*ZdS)/a Adtlas Activities Signals This module contains Django signal handlers for the activities app, providing automatic activity logging, model change tracking, and event-driven functionality. Features: - Automatic activity logging for model changes - User authentication activity tracking - System event monitoring - Custom signal handlers - Activity cleanup and maintenance - Real-time notifications Author: Adtlas Development Team Version: 1.0.0 Last Updated: 2025-01-27 N)datetime timedelta) post_save post_deletepre_save pre_delete m2m_changed)user_logged_inuser_logged_outuser_login_failed)request_startedrequest_finished)receiverSignal)get_user_model) ContentType)timezone)settings)cache) transaction)ActivityActivityCategoryActivitySummary) get_client_ipget_user_agentshould_log_activityc Ksztjjddddddd\}}tj|dd |jd ||d t|d d t|ddt ddt d|j tdt d|jWn>tk r}z t d|jdt|W5d}~XYnXdS)aU Log user login activity. This signal handler automatically creates an activity record when a user successfully logs in to the system. Args: sender: The sender of the signal request: Django request object user: User instance that logged in **kwargs: Additional keyword arguments authAuthenticationUser authentication activities#007bfffas fa-sign-in-altname descriptioncoloriconcodedefaultsloginUser z logged in successfullyT login_methodstandard remember_meF)r,r.login_timestamp)useractionr$categoryrequest is_successfulmetadatauser_last_login_zLogin activity logged for user z&Failed to log login activity for user : N)robjects get_or_creater log_activityemailgetattrrnow isoformatrsetidloggerinfo Exceptionerrorstr)senderr3r0kwargs auth_category_erL2/var/www/html/Focus/src/apps/activities/signals.pylog_user_login9s2     rNc Ksz|s WdStjjdd}|s(WdStd|j}d}|rVt| d}t j |dd|j d||d |t |d d |td d td|jtd|j Wn6tk r}ztdt|W5d}~XYnXdS)aY Log user logout activity. This signal handler automatically creates an activity record when a user logs out of the system. Args: sender: The sender of the signal request: Django request object user: User instance that logged out (may be None) **kwargs: Additional keyword arguments Nr)r(r6ilogoutr+z logged outT logout_methodr-)rPZsession_duration_msZlogout_timestamp)r0r1r$r2r3r4 duration_msr5z Logout activity logged for user zFailed to log logout activity: )rr9filterfirstrgetrArr> total_secondsrr;r<r=r?deleterBrCrDrErF)rGr3r0rHrI last_loginZsession_durationrKrLrLrMlog_user_logoutks:    rXc Ksztjjddddddd\}}|dd }tjd d d |||d d|dtddt |}d|}t |dd} t || dt d|d|Wn6tk r} zt dt| W5d } ~ XYnXd S)aD Log failed login attempts. This signal handler automatically creates an activity record when a login attempt fails. Args: sender: The sender of the signal credentials: Login credentials used request: Django request object **kwargs: Additional keyword arguments rrrr r!r"r'usernameUnknownN login_failedz#Failed login attempt for username: FzInvalid credentials providedZinvalid_credentials)Zattempted_usernameZfailure_reasonZattempt_timestamp)r0r1r$r2r3r4 error_messager5Zfailed_login_attempts_rrr7z"Failed login attempt for username z from IP z%Failed to log failed login activity: )rr9r:rTrr;rr>r?rrr@rBwarningrDrErF) rG credentialsr3rHrIrJrY ip_address cache_keyZattemptsrKrLrLrMlog_failed_logins<   rac Ks|r |tkrdSt|sdSzt|dd}|s4WdS|jj}t|}tj|dd|jjdt||t j ||j d|jj t|t|ddtd |jj d|j Wn@tk r}z"td |jj dt|W5d}~XYnXdS) aq Log model creation activities. This signal handler automatically creates activity records when new model instances are created. Args: sender: Model class that sent the signal instance: Model instance that was saved created: Boolean indicating if instance was created **kwargs: Additional keyword arguments N _current_usercreatezCreated r8T)model object_reprZcreated_fieldsr0r1r$r2 content_type object_idr4r5zCreation activity logged for z$Failed to log creation activity for rrr=_meta app_labelget_or_create_category_for_appr; verbose_namerFrr9 get_for_modelpklabelget_model_fieldsrBdebugrDrE)rGinstancecreatedrHr0rkr2rKrLrLrMlog_model_creations4    ruc Ks|s |tkrdSt|sdSzt|dd}|s4WdSt|di}|sJWdS|jj}t|}tj|dd|jjdt||t j ||j d|jj t||t|dd td |jj d|j WnBtk r}z"td |jj dt|W5d}~XYnXdS) ak Log model update activities. This signal handler automatically creates activity records when model instances are updated. Args: sender: Model class that sent the signal instance: Model instance that was saved created: Boolean indicating if instance was created **kwargs: Additional keyword arguments NrbZ_changed_fieldsupdatezUpdated r8T)rdrechanged_fieldsZ field_countrfzUpdate activity logged for z"Failed to log update activity for )rrr=rjrkrlr;rmrFrr9rnrorplenrBrrrDrE) rGrsrtrHr0rwrkr2rKrLrLrMlog_model_updates<     ryc Ks|tkr dSt|sdSzt|dd}|s0WdS|jj}t|}tj|dd|jjdt||t j ||j d|jj t|t|ddtd |jj d|j Wn@tk r}z"td |jj dt|W5d}~XYnXdS) a3 Log model deletion activities. This signal handler automatically creates activity records when model instances are deleted. Args: sender: Model class that sent the signal instance: Model instance that was deleted **kwargs: Additional keyword arguments NrbrVzDeleted r8T)rdreZdeleted_fieldsrfzDeletion activity logged for z$Failed to log deletion activity for ri)rGrsrHr0rkr2rKrLrLrMlog_model_deletionXs4   rzc KszttdrLtjsLddlm}||j|jr6|j nd|j rD|j ndn*t |j|jrb|j nd|j rp|j ndt tddrt|td|jWn6tk r}ztdt|W5d}~XYnXdS) a\ Handle activity logged signal. This signal handler performs additional processing when an activity is logged, such as updating summaries and triggering notifications. Args: sender: The sender of the signal activity: Activity instance that was logged **kwargs: Additional keyword arguments CELERY_TASK_ALWAYS_EAGERr)update_activity_summaryNZACTIVITIES_REALTIME_ENABLEDFz,Activity logged signal handled for activity z)Failed to handle activity logged signal: )hasattrrr{tasksr|delay created_atdater0user_idr2 category_idupdate_activity_summary_syncr=send_realtime_notificationrBrrrArDrErF)rGactivityrHr|rKrLrLrMhandle_activity_loggeds$  rc Kszt}|D]6}|j|jr$|jnd|jr2|jndf}||q tt drpt j spddl m }| t|n|D]\}}} t||| qttdt|dWn6tk r} ztdt| W5d} ~ XYnXdS)a< Handle bulk activity logged signal. This signal handler performs batch processing when multiple activities are logged at once. Args: sender: The sender of the signal activities: List of Activity instances that were logged **kwargs: Additional keyword arguments Nr{r)update_activity_summaries_bulkz(Bulk activity logged signal handled for z activitiesz.Failed to handle bulk activity logged signal: )r@rrr0rr2raddr}rr{r~rrlistrrBrCrxrDrErF) rG activitiesrHZ summary_keysrZ summary_keyrrrrrKrLrLrMhandle_bulk_activity_loggeds   rc Csddddddddd dd d d d dddddddddddd}|||d|dddd}tjj|d|d\}}|S)z Get or create an activity category for a Django app. Args: app_label: Django app label Returns: ActivityCategory: Category instance for the app zUser ManagementZuser_managementr z fas fa-users)r#r(r%r&Campaign ManagementZcampaign_management#28a745fas fa-bullhornzChannel ManagementZchannel_management#ffc107z fas fa-tvAnalytics & Reporting analyticsz#17a2b8fas fa-chart-barzVAST Ad ServingZ vast_serving#6f42c1zfas fa-play-circle)accounts campaignschannelsrvastz ManagementZ _managementz#6c757dz fas fa-cogr(r')rTtitlerr9r:)rkZcategory_mapping category_datar2rtrLrLrMrlsJ !  rlc Csi}|jjD]|}zXt||j}t|dr2|}n*t|dr\t|ttt t t dfs\t|}|||j<Wq t k rd||j<Yq Xq |S)z Get model fields and their values for logging. Args: instance: Model instance Returns: dict: Dictionary of field names and values r?__str__Nz) rjfieldsr=r#r}r? isinstancerFintfloatbooltyperD)rsrfieldvaluerLrLrMrqs     "rqc Cszttjj|||d\}}tjj|d}|r@|j|d}|rP|j|d}||_|jdd|_ |jdd|_ |jddj d dd }|rt |t ||_|d |_|W5QRXWn8tk r }ztd t|W5d }~XYnXd S)z Update activity summary synchronously. Args: date: Date for the summary user_id: User ID (optional) category_id: Category ID (optional) )rrr)Zcreated_at__date)r)rT)r4F)Zduration_ms__isnullrQ)flatr_z#Failed to update activity summary: N)ratomicrr9r:rrRcounttotal_activitiessuccessful_activitiesfailed_activities values_listsumrxavg_duration_msvaluesdistinct unique_ipssaverDrBrErF)rrrsummaryrtrZ durationsrKrLrLrMr:s:      rc Cszjd}t|g}|dt|j|jr.|jjnd||j|j |j d|dd}t ||dWn6t k r}ztdt|W5d}~XYnXdS) zf Send real-time notification for activity. Args: activity: Activity instance Zlatest_activitiesrSystem)rAr0r1r$ timestampr4N2r7z'Failed to send real-time notification: )rrTinsertrFrAr0r<get_action_displayr$rr?r4r@rDrBrE)rr`latestrKrLrLrMrms  rc Kstd|dz4tjddd|dtdd|td d Wn6tk r|}zt d t |W5d}~XYnXdS) z Handle activity cleanup completion. Args: sender: The sender of the signal deleted_count: Number of activities deleted **kwargs: Additional keyword arguments zActivity cleanup completed: z activities deletedNZsystem_cleanupzAutomatic cleanup completed: z old activities removedrT) deleted_countZcleanup_timestamp)r0r1r$r2r4r5z Failed to log cleanup activity: ) rBrCrr;rlrr>r?rDrErF)rGrrHrKrLrLrMhandle_cleanup_completeds    rc Kszddlm}ddddddd d d d d ddddd dddddddd dddddddd dddd d!dd"d d#d$d%d&d'ddd g}|D]0}|jj|d(|d)\}}|rtd*|jqWn0tk r}ztd+|W5d,}~XYnXd,S)-a+ Create default activity categories if they don't exist. This method creates the basic activity categories needed for proper activity classification and filtering. Categories created: - Authentication (login, logout, password changes) - Content Management (create, update, delete content) - Campaign Management (campaign operations) - System Administration (user management, settings) - Analytics (report generation, data export) - Security (failed logins, permission changes) r)rrrz@User authentication activities (login, logout, password changes)r r!TZ)r#r(r$r%r& is_systemretention_dayszContent Managementcontentz7Content creation, modification, and deletion activitiesrzfas fa-file-altimrcampaignz:Campaign creation, modification, and management activitiesrrizSystem AdministrationadminzsX        1 : 9 7 ? 7 ( (:3" [