a a*jK@sddlmZddlZddlZddlZddlmZmZddlm Z m Z m Z ddl m Z mZmZmZmZmZddlmZedZedZed d ed d d Gddde e e ZdS)) annotationsN) versionaddedversionchanged)MovingWindowSupportSlidingWindowCounterSupportStorage)Optional ParamSpecTypeTypeVarUnioncast)get_dependencyPRz2.1)versionz3.14.0zEAdded option to select custom collection names for windows & counters)rreasonc s*eZdZdZddgZddgZd8d d d d d d d dfdd ZeddddZeddZ d dddZ ddddZ d d dddZ d ddd d!Z d d"dd#d$Zd9d d"d d"d"d&d'd(Zd dd)d*Zd d"d"d+d,d-d.Zd:d d"d"d"d d/d0d1Zd;d d"d"d"d d/d2d3Zd d"d4d5d6d7ZZS)<MongoDBStoragezS Rate limit storage with MongoDB as backend. Depends on :pypi:`motor` async+mongodbzasync+mongodb+srvmotor.motor_asynciopymongolimitscounterswindowsFstrboolzUnion[float, str, bool]None)uri database_namecounter_collection_namewindow_collection_namewrap_exceptionsoptionsreturnc s|ddd}tj|fd|i||jd|_|jd|_td\|_}|jjj |fi||_ t j |j _ ||_||d|_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 counter_collection_name: The collection name to use for individual counters used in fixed window strategies :param window_collection_name: The collection name to use for sliding & moving window storage :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 rZmongodbr!rrzpymongo.errors)rrFN)replacesuper__init__ dependencies dependencyproxy_dependencyr lib_errorsmoduleZAsyncIOMotorClientstorageasyncioZget_running_loopZ get_io_loop_MongoDBStorage__database_name#_MongoDBStorage__collection_mapping _MongoDBStorage__indices_created)selfrrrr r!r"_ __class__V/var/www/html/assistant/venv/lib/python3.9/site-packages/limits/aio/storage/mongodb.pyr'/s   zMongoDBStorage.__init__z3Union[Type[Exception], tuple[Type[Exception], ...]])r#cCs|jjSN)r+Z PyMongoErrorr2r6r6r7base_exceptions^szMongoDBStorage.base_exceptionscCs|j|jSr8)r-Z get_databaser/r9r6r6r7databasedszMongoDBStorage.databasecsN|jsDt|j|jdjddd|j|jdjdddIdHd|_dS)NrexpireAtr)ZexpireAfterSecondsrT)r1r.gatherr;r0Z create_indexr9r6r6r7create_indiceshs zMongoDBStorage.create_indicesz Optional[int]csvtt|j|jdi|j|jdiIdH}t|j|jd|j|jdIdHtt|S)z^ Delete all rate limit keys in the rate limit collections (counters, windows) rrN) sumr.r=r;r0Zcount_documentsZdropr int)r2Znum_keysr6r6r7resetts zMongoDBStorage.reset)keyr#csBt|j|jdd|i|j|jdd|iIdHdS)z> :param key: the key to clear rate limits for r_idrN)r.r=r;r0Zfind_one_and_delete)r2rBr6r6r7clearszMongoDBStorage.clearfloatcsF|j|jdd|iIdH}|r,|dntjjtjjdS)z; :param key: the key to get the expiry for rrCNr<tzinfo) r;r0find_onedatetimenowr%timezoneutc timestampr2rBcounterr6r6r7 get_expirys zMongoDBStorage.get_expiryr@csH|j|jdj|dtjtjjiddgdIdH}|rD|dpFdS)zB :param key: the key to get the counter value for r$gte)rCr<count) projectionNr)r;r0rHrIrJrKrLrNr6r6r7gets zMongoDBStorage.getr$)rBexpiryelastic_expiryamountr#c s|IdHtjtjjtj|d}|j|jdjd|iddddd gi|d d |gid idddd gi||rv|ndd id igddg|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 NsecondsrrC$set$condz$ltz $expireAt$$NOW$addz$countifZthenelse)rRr<TrR)upsertrSreturn_document)r>rIrJrKrL timedeltar;r0find_one_and_updater*r,ReturnDocumentAFTERr@)r2rBrUrVrWZ expirationresponser6r6r7incrs:      zMongoDBStorage.incrcs*z|jIdHWdSYdS0dS)z{ Check if storage is healthy by calling :meth:`motor.motor_asyncio.AsyncIOMotorClient.server_info` NTF)r-Z server_infor9r6r6r7checks zMongoDBStorage.checkztuple[float, int])rBlimitrUr#c st}|j|jddd|iidddddd d ||gid iiid did dddiddidigjddIdH}r|dd|ddfS|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) rz$matchrCz$projectentriesz$filterz$entriesentryrQz$$entry)inputasZcondz$unwindz$groupz$_idz$minz$sumr$)rCminrR)lengthNrrorR)timer;r0Z aggregateZto_list)r2rBrjrUrMresultr6r6r7get_moving_windows6    z MongoDBStorage.get_moving_window)rBrjrUrWr#cs|IdH||krdSt}z~d|g|d|didtjtjjtj|did}|j|jd j d |d ||d d ||iii|ddIdHWdS|j j j j yYdS0dS)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 NFrkr)z$eachz $positionz$slicer<rX)z$pushrZrrCzentries.z$notrQT)ra)r>rqrIrJrKrLrcr;r0Z update_oner*r,errorsZDuplicateKeyError)r2rBrjrUrWrMZupdatesr6r6r7 acquire_entrys8   zMongoDBStorage.acquire_entrycs|IdH|d}|j|jdjd|idddddd d gi|gid d d gid dd gidiiiddddd d gi|gid d d d gididddd d gi|giddd d gidd |gidd d|gidid dididdddddddd dd dd |gigigi|gigid giiiidddddd|gi|gidd |gid diiiddddd|gi|giiiddgig|jjjjddIdH}tt |dS)NrrCrZ previousCountr[$lte $subtract $expiresAtr\$ifNull $currentCountr$previousCountr^z$gtr]) currentCount expiresAtZcurWeightedCountz$floorz $multiplyz$dividez$maxrz$curWeightedCountZ _acquiredz$unsetT)rbra) r>r;r0rdr*r,rerfr r)r2rBrjrUrW expiry_msrrr6r6r7acquire_sliding_window_entryGs         #&  q  yz+MongoDBStorage.acquire_sliding_window_entryztuple[int, float, int, float])rBrUr#c s4|d}|j|jdjd|idddddd gi|gid d d gid d d gididdddd gi|gid d d d gididdddd gi|gidd|giddidig|jjjjgddIdH}r0|dr|djt j j d nt }td |t }td |dr||nd }|d||d|fSdS)NrvrrCrZr[rxryrzr\r{r|rr}r^r])rwrr)rrwr)rbrSrrFrwr)rrr)r;r0rdr*r,rerfrTr%rIrKrLrMrqmax)r2rBrUrrrZ expires_atZ current_ttlZprev_ttlr6r6r7get_sliding_windowsl         * 3z!MongoDBStorage.get_sliding_window)rrrF)Fr$)r$)r$)__name__ __module__ __qualname____doc__ZSTORAGE_SCHEMEZ DEPENDENCIESr'propertyr:r;r>rArDrPrTrhrirsrurr __classcell__r6r6r4r7rs6 /    1 ,1r) __future__rr.rIrqZdeprecated.sphinxrrZlimits.aio.storage.baserrrZ limits.typingrr r r r r Z limits.utilrrrrr6r6r6r7s