)`i.ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z Gdd ZGd d Zd e d edzfdZd edzfdZd edzfdZe jZeeadS)N)RLock)Optional)logger)SageMakerConfigcbeZdZdZ d dededeefdZdefdZd defd Z d Z defd Z dS) SessionzRepresents a single stateful session with file-based storage. Each session has a unique directory where it stores key-value data as JSON files. Sessions have an expiration timestamp and are automatically cleaned up when expired. N session_id session_root expiration_tsc||_tj|||_||_|j|d|_dSdS)a*Initialize a session instance. Args: session_id: Unique identifier for this session (typically UUID) session_root: Root directory where session directories are stored expiration_ts: Unix timestamp when session expires, or None to load from disk N.expiration_ts)r ospathjoin files_pathr get)selfr r r s /home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/model_hosting_container_standards/sagemaker/sessions/manager.py__init__zSession.__init__sV%',,|Z@@*   %!%*:!;!;D    & %keyct||d5}tj||ddddS#1swxYwYdS)aStore a JSON-serializable value in the session. Args: key: The key to store the value under value: Must be JSON-serializable (str, int, float, bool, list, dict, None) Raises: TypeError: If value is not JSON-serializable wN)open_pathjsondump)rrvaluefs rputz Session.put*s$**S//3 ' ' 1 IeQ                     sAA A c||}tj|s|St |d5}t j|cdddS#1swxYwYdS)zRetrieve a value from the session. Args: key: The key to retrieve d: Default value if key doesn't exist Returns: The stored value or default if key not found rN)rrrisfilerrload)rrdrr!s rrz Session.get7szz#w~~d## H $__ 9Q<<                  sA((A,/A,ctj|jst d|jt jd|jtj |jdS)zDelete the session and all its stored data from disk. Returns: bool: True if deletion successful Raises: ValueError: If session directory doesn't exist z"session directory does not exist: zclosing session: T) rrexistsr ValueErrorr rinfoshutilrmtree)rs rremovezSession.removeHshw~~do.. US$/SSTT T 999::: do&&&trcd|vrtd|dtj|rtd|d|dd}tj|j|}tj|}|tj|jtj zstd|d|S)a-Generate a safe file path within the session directory. Args: key: The key name for the session data file Returns: Absolute path to the file within the session directory Raises: ValueError: If key contains path traversal attempts z..z&Invalid key: '..' not allowed in key ''z)Invalid key: absolute paths not allowed '/-z&Invalid key: path traversal detected ') r*rrisabsreplacerrabspath startswithsep)rr sanitized_key file_path resolved_paths rrz Session._pathWs 3;;LcLLLMM M 7==   QOOOOPP P C-- GLL-@@  22 ''(H(H26(QRR NLcLLLMM Mr)N) __name__ __module__ __qualname____doc__strrfloatrr"rr.rrrr r sTX<<<-0Create a new session with a unique ID and expiration timestamp. Also triggers cleanup of any expired sessions before creating the new one. Returns: Session: The newly created session instance with UUID and expiration Thread-safe: Uses internal lock for concurrent access rN)rR_clean_expired_sessionr?uuiduuid4timerKr rGrQrrSrr")rr r sessions rcreate_sessionzSessionManager.create_sessionsZ    ' ' ) ) )TZ\\**J IKK$/9Mj$* ddddS#1swxYwYdS)aInternal method to remove all expired sessions. Iterates through all sessions and closes any that have expired. Called automatically during session creation to prevent stale session buildup. Thread-safe: Uses internal lock for concurrent access N)rRlistrQitemsr r`rfrgs rr]z%SessionManager._clean_expired_session sZ 3 3'+DM,?,?,A,A'B'B 3 3# G(0DIKK'BW4W4W&&z222 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3sA%A;;A?A?N) r;r<r=r>dictrr rbr?rrhrfr]rArrrCrCus747777r8 c hw.?    D***. 3 3 3 3 3rrCconfigr[cj|jr+t|j|jd}t |SdS)zInitialize a SessionManager if stateful sessions are enabled. Args: config: SagemakerConfig instance with session settings Returns: SessionManager instance if enabled, None otherwise )rFrGN)enable_stateful_sessionsr?rFrGrC)rn config_dicts r_init_session_managerrrsF&+$'v'A#B#B#1  k*** 4rctS)zGet the global session manager instance. Returns: The global SessionManager instance, or None if not initialized )session_managerrArrget_session_managerru,s rcTtj}t|atS)aInitialize the global session manager from environment variables. This can be called to reinitialize the session manager after environment variables have been set. Returns: The initialized SessionManager instance, or None if disabled )rfrom_envrrrt)rns rinit_session_manager_from_envrx5s% % ' 'F+F33O r)rrr,rLr`r^ threadingrtypingrlogging_configrrnrr rCrrrurxrw_configrtrArrr}st  $$$$$$$$$$$$aaaaaaaaHa3a3a3a3a3a3a3a3H/nt6K&^d2 ~'<     #/ " $ $''00r