ej_$xdZddlZddlZddlZddlZddlmZmZddl m Z dZ dZ dZ dZGd d ZdS) zServe GridFS files with Motor and aiohttp. Requires Python 3.5 or later and aiohttp 3.0 or later. See the :doc:`/examples/aiohttp_gridfs_example`. N)AsyncIOMotorDatabaseAsyncIOMotorGridFSBucket) _hash_gridoutc,||S)a&Override to choose a GridFS file to serve at a URL. By default, if a URL pattern like ``/fs/{filename}`` is mapped to this :class:`AIOHTTPGridFS`, then the filename portion of the URL is used as the filename, so a request for "/fs/image.png" results in a call to :meth:`.AsyncIOMotorGridFSBucket.open_download_stream_by_name` with "image.png" as the ``filename`` argument. To customize the mapping of path to GridFS file, override ``get_gridfs_file`` and return a :class:`asyncio.Future` that resolves to a :class:`~motor.motor_asyncio.AsyncIOMotorGridOut`. For example, to retrieve the file by ``_id`` instead of filename:: def get_gridfile_by_id(bucket, filename, request): # "filename" is interpreted as _id instead of name. # Return a Future AsyncIOMotorGridOut. return bucket.open_download_stream(file_id=filename) client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database, get_gridfs_file=get_gridfile_by_id) :Parameters: - `bucket`: An :class:`~motor.motor_asyncio.AsyncIOMotorGridFSBucket` - `filename`: A string, the URL portion matching {filename} in the URL pattern - `request`: An :class:`aiohttp.web.Request` )open_download_stream_by_name)bucketfilenamerequests Z/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/motor/aiohttp/__init__.pyget_gridfs_filer s<  . .x 8 88cdS)a5Override to customize cache control behavior. Return a positive number of seconds to trigger aggressive caching or 0 to mark resource as cacheable, only. 0 is the default. For example, to allow image caching:: def image_cache_time(filename, modified, mime_type): if mime_type.startswith('image/'): return 3600 return 0 client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database, get_cache_time=image_cache_time) :Parameters: - `filename`: A string, the URL portion matching {filename} in the URL pattern - `modified`: A datetime, when the matching GridFS file was created - `mime_type`: The file's type, a string like "application/octet-stream" r)r modified mime_types r get_cache_timerAs 0 1r cdS)a,Override to modify the response before sending to client. For example, to allow image caching:: def gzip_header(response, gridout): response.headers['Content-Encoding'] = 'gzip' client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database, set_extra_headers=gzip_header) :Parameters: - `response`: An :class:`aiohttp.web.Response` - `gridout`: The :class:`~motor.motor_asyncio.AsyncIOMotorGridOut` we will serve to the client Nr)responsegridouts r set_extra_headersr\s " Dr c |jjjd}d|z}n#tt f$rd|z}YnwxYwt j|d)N formatterz>@@M LyX n %BBB7'AB + - -3 - 7 7TAs.1A  A c.eZdZdZdeeefdZdZdZ dS) AIOHTTPGridFSa.Serve files from `GridFS`_. This class is a :ref:`request handler ` that serves GridFS files, similar to aiohttp's built-in static file server. .. code-block:: python client = AsyncIOMotorClient() gridfs_handler = AIOHTTPGridFS(client.my_database) app = aiohttp.web.Application() # The GridFS URL pattern must have a "{filename}" variable. resource = app.router.add_resource('/fs/{filename}') resource.add_route('GET', gridfs_handler) resource.add_route('HEAD', gridfs_handler) app_handler = app.make_handler() server = loop.create_server(app_handler, port=80) By default, requests' If-Modified-Since headers are honored, but no specific cache-control timeout is sent to clients. Thus each request for a GridFS file requires a quick check of the file's ``uploadDate`` in MongoDB. Pass a custom :func:`get_cache_time` to customize this. :Parameters: - `database`: An :class:`AsyncIOMotorDatabase` - `get_gridfs_file`: Optional override for :func:`get_gridfs_file` - `get_cache_time`: Optional override for :func:`get_cache_time` - `set_extra_headers`: Optional override for :func:`set_extra_headers` .. _GridFS: https://www.mongodb.com/docs/manual/core/gridfs/ fsct|tstd|z||_t |j||_||_||_||_dS)NzDFirst argument to AIOHTTPGridFS must be AsyncIOMotorDatabase, not %r) isinstancer TypeError _databaser_bucket_get_gridfs_file_get_cache_time_set_extra_headers)selfdatabaseroot_collectionr rrs r __init__zAIOHTTPGridFS.__init__sl($899 VYaa "/PP /-"3r cK |jd}n#t$rt|YnwxYw|jdvr(tj|jddh ||j||d{V}n8#tj $r&tj |j wxYwtj }t|}||j |||||||j}|X||jj}|jd }||kr|d |S|jd } | 0| d |kr|d |S|j|_||d{V|jdkred } | |jkrX||jd{V} || d{V| t?| z } | |jkX|S)z&Send filepath to client using request.r )GETHEADr6r7)methodallowed_methodsNr)tzinfor) microsecondi0z If-None-Match") rrr%r8r!r"HTTPMethodNotAllowedr.r-gridfsNoFile HTTPNotFoundpathStreamResponser_set_standard_headersr0if_modified_sincereplace upload_dater: set_statusheadersgetstriplengthcontent_lengthprepareread chunk_sizewritelen) r1r r rrespchecksum ims_valueif_sinceretagwrittenchunks r __call__zAIOHTTPGridFS.__call__s #)*5HH # # # ' " " " " " # > 0 0+22~v3  > 11$,'RRRRRRRRGG} > > >+** *== = >{))++!)) ""7<wIII g...-  !((0C0J(KKH*22q2AAH8##$$$ ""?33   38 ; ; OOC K%nll7######### >U " "GGN**%ll7+=>>>>>>>>jj'''''''''3u::% GN**  s ..#"B5B;c|j|_|j}|tj|\}}|r||_d|z|jd<|||j|j}|dkrktjtj |z d|jd<dt|z|jd<dSd |jd<dS) Nz"%s"Etagr)secondsz%a, %d %b %Y %H:%M:%S GMTExpireszmax-age=z Cache-Controlpublic) rF last_modified content_type mimetypes guess_typerHr/datetimeutcnow timedeltastrftimestr)r1rArRrrSr`encoding cache_times r rCz#AIOHTTPGridFS._set_standard_headerss$0+  %.%9$%?%? "L(  - ,D %0 V))$0CWEYZZ >>!((**X-? -S-S-SSh233 L #-7Z,HDL ) ) ),4DL ) ) )r N) __name__ __module__ __qualname____doc__r rrr4rYrCrr r r'r'{s`  J'%+ 4444&777r55555r r')rmrcra aiohttp.webr!r>motor.motor_asynciorrmotor.motor_gridfsrr rrr%r'rr r rqs NNNNNNNN,,,,,,999B   6   (BBBD5D5D5D5D5D5D5D5D5D5r