U bZ@s8dZddlZddlZddlZddlmZmZddlmZddlm Z ddl m Z m Z m Z ddlmZdd lmZmZmZdd lmZmZd d lmZmZeeZd dZeedddZee dddZ e dddZ!e"e"e e edddZ#ee ddddZ$e e eddddZ%e e ee e"dd d!Z&dS)"z Handles all caching logic including: - Retrieving from cache - Saving to cache - Determining whether not certain items have expired and need to be refreshed N)datetimetimezone)wraps)Path)OptionalSequenceSet)user_cache_dir)APP_NAMENOTICES_CACHE_SUBDIRNOTICES_CACHE_FN)ensure_dir_exists safe_open)ChannelNoticeResponse ChannelNoticecs tttdfdd }|S)N)urlnamecs:t}t|||}|r|S||}|dk r6t|||SN)get_notices_cache_dirget_notice_response_from_cachewrite_notice_response_to_cache)rr cache_dirZ cache_valZ return_valuefunc2lib/python3.8/site-packages/conda/notices/cache.pywrappers   z cached_response..wrapper)rstr)rrrrrcached_responses r )channel_notice_responsereturncs<ttjtttdfdd tfdd|jDS)z This checks the contents of the cache response to see if it is expired. If for whatever reason we encounter an exception while parsing the individual messages, we assume an invalid cache and return true. ) expired_atr"cs|dkr dS|kS)zP If there is no "expired_at" field present assume it is expired NTrr#)nowrris_channel_notice_expired7szCis_notice_response_cache_expired..is_channel_notice_expiredc3s|]}|jVqdSrr$.0Zchn)r&rr @sz3is_notice_response_cache_expired..)rr%rZutcrboolanyZnotices)r!r)r&r%r is_notice_response_cache_expired.s  r,)r"cCstttd}t|tS)zDReturns the location of the notices cache directory as a Path object)Z appauthor)r r rjoinpathr )rrrrrDs rc Cs<t}|t}|s8t|d}|dW5QRX|S)z?Returns the location of the notices cache file as a Path objectw)rr-r is_filerwrite)r cache_filefprrrget_notices_cache_fileLs   r4)rrrr"c CsTt||}tj|rPt|d}t|}W5QRXt|||}t|sP|SdS)zE Retrieves a notice response object from cache if it exists. rN) r get_cache_keyospathisfilerjsonloadr,)rrr cache_keyr3dataZ chn_ntc_resprrrrXs    r)r!rr"c Cs6t|j|}t|d}t|j|W5QRXdS)z< Writes our notice data to our local cache location r.N)rr6rrr:dumpZ json_data)r!rr<r3rrrris r)r2channel_noticesr"c Csztdd|D}t|d}|}W5QRXttdt|}||}t|d}|d|W5QRXdS)zE Insert channel notice into our database marking it as read. css|] }|jVqdSridr'rrrr){sz1mark_channel_notices_as_viewed..r5Nr. )setrreadfilter splitlinesunionr1join)r2r? notice_idsr3contentscontents_uniqueZ contents_newrrrmark_channel_notices_as_viewedus   rLc CsPtdd|D}t|d}|}W5QRXttdt|}||S)zM Return the ids of the channel notices which have already been seen. css|] }|jVqdSrr@r'rrrr)sz0get_viewed_channel_notice_ids..r5N)rCrrDrErF intersection)r2r?rIr3rJrKrrrget_viewed_channel_notice_idss  rN)'__doc__r:Zloggingr7rr functoolsrpathlibrtypingrrrZ_vendor.appdirsr Zbase.constantsr r r ZutilsrrtypesrrZ getLogger__name__Zloggerr r*r,rr4rrrrLrNrrrrsD