o Ah @sddlmZddlmZmZddlmZddlmZddlm Z ddl m Z m Z dZ ded ejd efd d Zd edede ede ed ejd e ef ddZd eded ejd e efddZdS))datetime) CollectionReturnDocument)database)AuditLogCreate)str_to_objectid)OptionalList audit_logs audit_logdbreturncsF|t}|}t|d<||}t|j|d<|d|d<|S)zG Insert a new audit log record into the audit_logs collection. timestamp_idaudit_id)COLLECTION_NAMEdictrutcnow insert_onestr inserted_id)r r audit_collectionlog_dataresultr6/var/www/html/moveengine/app/v1/services/saas/audit.pycreate_audit_log_service s   rskiplimit account_iduser_idc s|t}i}|r ||d<|r||d<||||dd}g}|2z3dHW} t| d| d<| d| d<|| q&6|S)z Retrieve a paginated list of audit logs. If account_id or user_id is provided, filters are applied; otherwise, global logs are returned. rr rNrrrfindrrsortrappend) rrrr r rquerycursorlogsdocrrrlist_audit_logs_services  r*csj|t}|i||dd}g}|2z3dHW}t|d|d<|d|d<||q6|S)zD Retrieve a paginated list of all audit logs (global view). rr!Nrrr")rrr rr'r(r)rrrlist_global_audit_logs_service)s  r+N)rpymongo.collectionrrapp.dbrapp.v1.models.saas.auditmodelrapp.v1.libraries.objectrtypingrr rMongoDBrrintrr*r+rrrrs    0 $