U ]g$@sddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z ddlmZmZmZmZmZmZmZddlmZedZed Ze d d Gd d d e e ZdS)) annotationsN)Anycast) versionadded)MovingWindowSupportStorage)DictOptional ParamSpecTupleTypeTypeVarUnion)get_dependencyPRz2.1)versioncseZdZdZddgZddgZd/ddd d d d fd d ZeddddZeddZ d dddZ ddddZ dd dddZ dddddZ dddd d!Zd0ddd ddd#d$d%Zd dd&d'Zdddd(d)d*d+Zd1ddddd d,d-d.ZZS)2MongoDBStoragezS Rate limit storage with MongoDB as backend. Depends on :pypi:`motor` async+mongodbzasync+mongodb+srvmotor.motor_asynciopymongolimitsFstrboolzUnion[float, str, bool]None)uri database_namewrap_exceptionsoptionsreturnc sz|ddd}tj|fd|i||jd|_|jd|_td\|_}|jjj |f||_ t j |j _ ||_d|_d S) a :param uri: uri of the form ``async+mongodb://[user:password]@host:port?...``, This uri is passed directly to :class:`~motor.motor_asyncio.AsyncIOMotorClient` :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:`~motor.motor_asyncio.AsyncIOMotorClient` :raise ConfigurationError: when the :pypi:`motor` or :pypi:`pymongo` are not available rZmongodbrrrzpymongo.errorsFN)replacesuper__init__Z dependencies dependencyproxy_dependencyr lib_errorsmoduleZAsyncIOMotorClientstorageasyncioZget_running_loopZ get_io_loop_MongoDBStorage__database_name _MongoDBStorage__indices_created)selfrrrr_ __class__>/tmp/pip-unpacked-wheel-kizsipjx/limits/aio/storage/mongodb.pyr#"s   zMongoDBStorage.__init__z3Union[Type[Exception], Tuple[Type[Exception], ...]])rcCs|jjSN)r&Z PyMongoErrorr,r0r0r1base_exceptionsGszMongoDBStorage.base_exceptionscCs|j|jSr2)r(Z get_databaser*r3r0r0r1databaseMszMongoDBStorage.databasecs>|js4t|jjjddd|jjjdddIdHd|_dS)NexpireAtr)ZexpireAfterSecondsT)r+r)gatherr5countersZ create_indexwindowsr3r0r0r1create_indicesQs  zMongoDBStorage.create_indicesz Optional[int]csVtt|jji|jjiIdH}t|jj|jjIdHtt |S)z^ Delete all rate limit keys in the rate limit collections (counters, windows) N) sumr)r7r5r8Zcount_documentsr9Zdroprint)r,Znum_keysr0r0r1resetYs   zMongoDBStorage.reset)keyrcs2t|jjd|i|jjd|iIdHdS)z> :param key: the key to clear rate limits for _idN)r)r7r5r8Zfind_one_and_deleter9)r,r>r0r0r1cleariszMongoDBStorage.clearr<csB|jjd|iIdH}|r$|dntjtjj}t| S)z; :param key: the key to get the expiry for r?Nr6) r5r8find_onedatetimenowtimezoneutccalendartimegm timetuple)r,r>counterexpiryr0r0r1 get_expiryrs  zMongoDBStorage.get_expirycs@|jjj|dtjtjjiddgdIdH}|r<|dp>dS)zB :param key: the key to get the counter value for $gte)r?r6count) projectionNr)r5r8rArBrCrDrE)r,r>rIr0r0r1gets zMongoDBStorage.getr )r>rJelastic_expiryamountrc s|IdHtjtjjtj|d}|jjjd|idddddgi|d d |gid iddddgi||rn|ndd id igd dg|j j j j dIdH}t |dS)aD 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 elastic_expiry: whether to keep extending the rate limit window every hit. :param amount: the number to increment by Nsecondsr?$setz$condz$ltz $expireAtz$$NOWz$addz$count)ifZthenelse)rMr6TrM)upsertrNZreturn_document)r:rBrCrDrE timedeltar5r8Zfind_one_and_updater%r'ZReturnDocumentZAFTERr<)r,r>rJrPrQZ expirationresponser0r0r1incrs6      zMongoDBStorage.incrcs*z|jIdHWdSYdSXdS)z{ Check if storage is healthy by calling :meth:`motor.motor_asyncio.AsyncIOMotorClient.server_info` NTF)r(Z server_infor3r0r0r1checks zMongoDBStorage.checkzTuple[int, int])r>limitrJrc st}|jjdd|iiddddddd ||gid iiid did d ddiddidigjddIdH}|rt|dd|ddfSt|dfS)z returns the starting point and the number of entries in the moving window :param str key: rate limit key :param int expiry: expiry of entry :return: (start of window, number of acquired entries) z$matchr?z$projectentriesz$filterz$entriesentryrLz$$entry)inputasZcondz$unwindz$groupz$_idz$minz$sumr )r?minrM)lengthNrrarM)timer5r9Z aggregateZto_listr<)r,r>r\rJ timestampresultr0r0r1get_moving_windows6    z MongoDBStorage.get_moving_window)r>r\rJrQrcs|IdH||krdSt}zddgd|dii}dtjtjjtj|di|d <|g||ddd <|jjj d |d ||d d||iii|ddIdHWdS|j j j 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 NFz$pushr]r)$eachz $positionz$slicer6rRrTrgr?z entries.%dz$notrLT)rW)r:rcrBrCrDrErXr5r9Z update_oner%r'errorsZDuplicateKeyError)r,r>r\rJrQrdZupdatesr0r0r1 acquire_entrys8     zMongoDBStorage.acquire_entry)rF)Fr )r )__name__ __module__ __qualname____doc__ZSTORAGE_SCHEMEZ DEPENDENCIESr#propertyr4r5r:r=r@rKrOrZr[rfri __classcell__r0r0r.r1rs,%   / +r) __future__rr)rFrBrctypingrrZdeprecated.sphinxrZlimits.aio.storage.baserrZ limits.typingrr r r r r rZ limits.utilrrrrr0r0r0r1s  $