U ]g#@sddlmZddlZddlZddlZddlmZmZddlm Z m Z ddl m Z ddl mZmZmZmZmZmZmZmZddlmZd d lmZmZGd d d eeeZe d dGdddeZdS)) annotationsN)ABCabstractmethod)Anycast) versionadded)Dict MongoClientMongoCollection MongoDatabaseOptionalTupleTypeUnion)get_dependency)MovingWindowSupportStoragecsDeZdZdZdgZd9dddddd fd d Zed d ddZedd ddZedd ddZ edd ddZ e ddd dddZ edd ddZ dd dd Zd!d d"d#Zddd$d%d&Zdd'd$d(d)Zdd'd$d*d+Zd:dd'dd'd'd-d.d/Zdd d0d1Zdd'd'd2d3d4d5Zd;dd'd'd'dd6d7d8ZZS)<MongoDBStorageBasezV Rate limit storage with MongoDB as backend. Depends on :pypi:`pymongo`. pymongolimitsFstrboolUnion[int, str, bool]None)uri database_namewrap_exceptionsoptionsreturnc sPtj|fd|i|||_|jdj|_td\|_}||_||_ d|_ dS)av :param uri: uri of the form ``mongodb://[user:password]@host:port?...``, This uri is passed directly to :class:`~pymongo.mongo_client.MongoClient` :param database_name: The database to use for storing the rate limit collections. :param wrap_exceptions: Whether to wrap storage exceptions in :exc:`limits.errors.StorageError` before raising it. :param options: all remaining keyword arguments are passed to the constructor of :class:`~pymongo.mongo_client.MongoClient` :raise ConfigurationError: when the :pypi:`pymongo` library is not available rrzpymongo.errorsN) super__init___database_nameZ dependenciesmodulelibr lib_errors _storage_uri_storage_options_storage)selfrrrr_ __class__:/tmp/pip-unpacked-wheel-kizsipjx/limits/storage/mongodb.pyr"#szMongoDBStorageBase.__init__r )r cCs,|jdkr&|j|jf|j|_||jSN)r)_init_mongo_clientr'r((_MongoDBStorageBase__initialize_databaser*r.r.r/storage>s zMongoDBStorageBase.storager cCs |j|jSr0)r4r#r3r.r.r/ _databaseGszMongoDBStorageBase._databaser cCs |jdS)Ncountersr5r3r.r.r/r6KszMongoDBStorageBase.counterscCs |jdS)Nwindowsr7r3r.r.r/r8OszMongoDBStorageBase.windows Optional[str]rrr cKs tdSr0)NotImplementedErrorr*rrr.r.r/r1Ssz%MongoDBStorageBase._init_mongo_clientz3Union[Type[Exception], Tuple[Type[Exception], ...]]cCs|jjSr0)r&Z PyMongoErrorr3r.r.r/base_exceptionsYsz"MongoDBStorageBase.base_exceptionscCs$|jjddd|jjddddS)NexpireAtr)ZexpireAfterSeconds)r6Z create_indexr8r3r.r.r/Z__initialize_database_sz(MongoDBStorageBase.__initialize_databasez Optional[int]cCs4|ji|ji}|j|jt|S)z^ Delete all rate limit keys in the rate limit collections (counters, windows) )r6Zcount_documentsr8Zdropint)r*Znum_keysr.r.r/resetcs  zMongoDBStorageBase.reset)keyr cCs$|jd|i|jd|idS)z> :param key: the key to clear rate limits for _idN)r6Zfind_one_and_deleter8)r*rAr.r.r/clearmszMongoDBStorageBase.clearr?cCs:|jd|i}|r|dntjtjj}t|S)z; :param key: the key to get the expiry for rBr>) r6find_onedatetimenowtimezoneutccalendartimegm timetuple)r*rAcounterexpiryr.r.r/ get_expiryts  zMongoDBStorageBase.get_expirycCs8|jj|dtjtjjiddgd}|r4|dp6dS)zB :param key: the key to get the counter value for $gte)rBr>count) projectionr)r6rDrErFrGrH)r*rArLr.r.r/getszMongoDBStorageBase.getr)rArMelastic_expiryamountr c Cstjtjjtj|d}t|jjd|idddddgi|dd |gid iddddgi||r`|ndd id igd d g|jj j dd S)z increments the counter for a given rate limit key :param key: the key to increment :param expiry: amount in seconds for the key to expire in :param amount: the number to increment by secondsrB$setz$condz$ltz $expireAtz$$NOWz$addz$count)ifZthenelse)rPr>TrP)upsertrQZreturn_document) rErFrGrH timedeltar?r6Zfind_one_and_updater%ZReturnDocumentZAFTER)r*rArMrSrTZ expirationr.r.r/incrs:     zMongoDBStorageBase.incrcCs$z|jWdSYdSXdS)zm Check if storage is healthy by calling :meth:`pymongo.mongo_client.MongoClient.server_info` TFN)r4Z server_infor3r.r.r/checks  zMongoDBStorageBase.checkzTuple[int, int])rAlimitrMr c Cst}t|jdd|iiddddddd ||gid iiid did d ddiddidig}|rt|dd|ddfSt|dfS)z returns the starting point and the number of entries in the moving window :param key: rate limit key :param expiry: expiry of entry :return: (start of window, number of acquired entries) z$matchrBz$projectentriesz$filterz$entriesentryrOz$$entry)inputasZcondz$unwindz$groupz$_idz$minz$sumr)rBminrPrrcrP)timelistr8Z aggregater?)r*rAr^rM timestampresultr.r.r/get_moving_windows6   z$MongoDBStorageBase.get_moving_window)rAr^rMrTr cCs||kr dSt}zddgd|dii}dtjtjjtj|di|d<|g||ddd <|jjd |d ||d d ||iii|ddWdS|jj j k rYdSXdS)z :param key: rate limit key to acquire an entry in :param limit: amount of entries allowed :param expiry: expiry of the entry :param amount: the number of entries to acquire Fz$pushr_r)$eachz $positionz$slicer>rUrWrirBz entries.%dz$notrOT)rZN) rdrErFrGrHr[r8Z update_oner%errorsZDuplicateKeyError)r*rAr^rMrTrfZupdatesr.r.r/ acquire_entrys6    z MongoDBStorageBase.acquire_entry)rF)Fr)r)__name__ __module__ __qualname____doc__Z DEPENDENCIESr"propertyr4r5r6r8rr1r=r2r@rCrNrRr\r]rhrk __classcell__r.r.r,r/rs8  - *rz2.1)versionc@s&eZdZddgZddddddZd S) MongoDBStorageZmongodbz mongodb+srvr9rr r:cKstt|jj|f|Sr0)rr r%r<r.r.r/r1sz!MongoDBStorage._init_mongo_clientN)rlrmrnZSTORAGE_SCHEMEr1r.r.r.r/rssrs) __future__rrIrErdabcrrtypingrrZdeprecated.sphinxrZ limits.typingrr r r r r rrutilrbaserrrrsr.r.r.r/s  (