o KDi4K@sddlmZddlZddlZddlZddlmZmZddlm Z m Z m Z ddl m Z mZmZddlmZe dZedZed d ed d d Gddde e e ZdS)) annotationsN) versionaddedversionchanged)MovingWindowSupportSlidingWindowCounterSupportStorage) ParamSpecTypeVarcast)get_dependencyPRz2.1)versionz3.14.0zEAdded option to select custom collection names for windows & counters)rreasoncseZdZdZddgZ ddgZ    d@dAfdd ZedBddZeddZ dCddZ dDdd Z dEd"d#Z dFd%d&Z dGd(d)ZdHdId-d.ZdJd/d0ZdKd3d4Z *dHdLd5d6Z *dHdLd7d8ZdMd:d;ZdNdd?ZZS)OMongoDBStoragezS Rate limit storage with MongoDB as backend. Depends on :pypi:`motor` async+mongodbzasync+mongodb+srvmotor.motor_asynciopymongolimitscounterswindowsFuristr database_namecounter_collection_namewindow_collection_namewrap_exceptionsbooloptionsfloat | str | boolreturnNonec 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 rmongodbrrrzpymongo.errors)rrFN)replacesuper__init__ dependencies dependencyproxy_dependencyr lib_errorsmoduleAsyncIOMotorClientstorageasyncioget_running_loop get_io_loop_MongoDBStorage__database_name#_MongoDBStorage__collection_mapping _MongoDBStorage__indices_created)selfrrrrrr_ __class__S/var/www/Datamplify/venv/lib/python3.10/site-packages/limits/aio/storage/mongodb.pyr&,s    zMongoDBStorage.__init__-type[Exception] | tuple[type[Exception], ...]cCs|jjSN)r* PyMongoErrorr4r8r8r9base_exceptions[szMongoDBStorage.base_exceptionscCs|j|jSr;)r- get_databaser1r=r8r8r9databaseaszMongoDBStorage.databasecsP|js#t|j|jdjddd|j|jdjdddIdHd|_dS)NrexpireAtr)expireAfterSecondsrT)r3r.gatherr@r2 create_indexr=r8r8r9create_indiceses zMongoDBStorage.create_indices int | Nonecsxtt|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.rCr@r2count_documentsdropr int)r4num_keysr8r8r9resetqs zMongoDBStorage.resetkeycsDt|j|jdd|i|j|jdd|iIdHdS)z> :param key: the key to clear rate limits for r_idrN)r.rCr@r2find_one_and_delete)r4rMr8r8r9clearszMongoDBStorage.clearfloatcsH|j|jdd|iIdH}|r|dntjjtjjdS)z; :param key: the key to get the expiry for rrNNrAtzinfo) r@r2find_onedatetimenowr$timezoneutc timestampr4rMcounterr8r8r9 get_expirys zMongoDBStorage.get_expiryrJcsJ|j|jdj|dtjtjjiddgdIdH}|r#|dp$dS)zB :param key: the key to get the counter value for r$gte)rNrAcount) projectionNr)r@r2rTrUrVrWrXrZr8r8r9gets zMongoDBStorage.getr#expiryamountc s|IdHtjtjjtj|d}|j|jdjd|iddddd gi|d d |gid idddd gi|dd id igddg|j j j j dIdH}t |dS)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 NsecondsrrN$set$condz$lt $expireAt$$NOW$addz$countifthenelse)r^rATr^)upsertr_return_document)rErUrVrWrX timedeltar@r2find_one_and_updater)r+ReturnDocumentAFTERrJ)r4rMrarb expirationresponser8r8r9incrs>     zMongoDBStorage.incrcs&z |jIdHWdSYdS)z{ Check if storage is healthy by calling :meth:`motor.motor_asyncio.AsyncIOMotorClient.server_info` NTF)r- server_infor=r8r8r9checks zMongoDBStorage.checklimittuple[float, int]c st}|j|jddd|iidddddd d ||gid iiidd d idd idigjddIdH}rE|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$matchrNz$projectfilteredEntriesz$filterz$entriesentryr]z$$entry)inputascondz$minz$filteredEntriesz$size)minr^r#)lengthNrrr^)timer@r2 aggregateto_list)r4rMryrarYresultr8r8r9get_moving_windows6   z MongoDBStorage.get_moving_windowcs|IdH||krdSt}z?d|g|d|didtjtjjtj|did}|j|jd j d |d ||d d ||iii|ddIdHWdS|j j j j y_YdSw)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 NFentriesr)z$eachz $positionz$slicerArc)z$pushrerrNzentries.z$notr]T)rn)rErrUrVrWrXrpr@r2 update_oner)r+errorsDuplicateKeyError)r4rMryrarbrYupdatesr8r8r9 acquire_entrys<    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)NrrNre previousCountrf$lte $subtractrgrh$ifNull $currentCountr$previousCountrjz$gtri) currentCountrAcurWeightedCountz$floorz $multiplyz$dividez$maxrz$curWeightedCount _acquiredz$unsetT)rorn) rEr@r2rqr)r+rrrsr r)r4rMryrarb expiry_msrr8r8r9acquire_sliding_window_entry?s         #&   q yz+MongoDBStorage.acquire_sliding_window_entrytuple[int, float, int, float]c s2|d}|j|jdjd|idddddd gi|gid d d gid d d gididdddd gi|gid d d d gididdddd gi|gidd|giddidig|jjjjgddIdH}r|drs|djt j j d nt }td |t }td |dr||nd }|d||d|fSdS)NrrrNrerfrrrgrhrrrrrjri)rrrA)rrrA)ror_rArRrr)rrr)r@r2rqr)r+rrrsr`r$rUrWrXrYrmax)r4rMrarr expires_at current_ttlprev_ttlr8r8r9get_sliding_windowsp          *3z!MongoDBStorage.get_sliding_windowcs||IdHSr;)rP)r4rMrar8r8r9clear_sliding_windowsz#MongoDBStorage.clear_sliding_windowcCs|jo |jdSdSr;)r-closer=r8r8r9__del__szMongoDBStorage.__del__)rrrF)rrrrrrrrrrrrr r!)r r:)r r!)r rF)rMrr r!)rMrr rQ)rMrr rJ)r#)rMrrarJrbrJr rJ)r r)rMrryrJrarJr rz) rMrryrJrarJrbrJr r)rMrrarJr r)rMrrarJr r!)__name__ __module__ __qualname____doc__STORAGE_SCHEME DEPENDENCIESr&propertyr>r@rErLrPr\r`rvrxrrrrrr __classcell__r8r8r6r9rs</      - + 1   Er) __future__rr.rUrdeprecated.sphinxrrlimits.aio.storage.baserrr limits.typingrr r limits.utilr r r rr8r8r8r9s