"j d Z ddlmZ ddlmZ ddlZddlmZ ddlm Z ddl
m Z m Z m
Z
ddlmZ d Z e j" e Z G d
d e Z G d d
e Z G d de Z G d de Z G d de
Zy)a7
Implementation of a WebDAV provider that provides a very basic, read-only
resource layer emulation of a MongoDB database.
Usage: add the following entries to wsgidav.conf::
from wsgidav.samples.mongo_dav_provider import MongoResourceProvider
mongo_dav_opts = {}
addShare("mongo", MongoResourceProvider(mongo_dav_opts))
Valid options are (sample shows defaults)::
opts = {"host": "localhost", # MongoDB server
"port": 27017, # MongoDB port
# This options are used with `mongod --auth`
# The user must be created in the admin db with
# > use admin
# > db.addUser(user_name, password)
"user": None, # Authenticate with this user
"pwd": None, # ... and password
}
)StringIO)pformatN)ObjectId)util)
DAVCollectionDAVNonCollection DAVProvider)join_urireStructuredTextc . e Zd ZdZ fdZd Zd Z xZS )ConnectionCollectionz+Root collection, lists all mongo databases.c \ t | || | j j | _ y N)super__init__providerconnselfpathenviron __class__s Q/srv/dav/.venv/lib/python3.12/site-packages/wsgidav/samples/mongo_dav_provider.pyr z ConnectionCollection.__init__0 s#
w'MM&& c z | j j D cg c] }|j d c}S c c}w Nutf8)r database_namesencoder names r get_member_namesz%ConnectionCollection.get_member_names4 s, 04 0H0H0JK F#KKK 8c V t t | j | | j S r ) DbCollectionr
r r r s r
get_memberz ConnectionCollection.get_member7 s HTYY 5t||DDr )__name__
__module__ __qualname____doc__r r" r&
__classcell__r s @r r
r
- s 5'LEr r
c 4 e Zd ZdZ fdZd Zd Zd Z xZS )r% z+Mongo database, contains mongo collections.c t | || | j j | _ | j | j | _ y r )r r r r r! dbr s r r zDbCollection.__init__> s7
w'MM&& ))DII&r c
ddiS )NtypezMongo database r s r get_display_infoz DbCollection.get_display_infoC ())r c z | j j D cg c] }|j d c}S c c}w r )r/ collection_namesr r s r r" z DbCollection.get_member_namesF s, 040H0H0JK F#KKKr# c v | j | }t t | j | | j | S r )r/ CollCollectionr
r r )r r! colls r r& zDbCollection.get_memberI s- wwt} htyy$ 7 tLLr r' r( r) r* r r4 r" r& r+ r, s @r r% r% ; s 5'
*LMr r% c 4 e Zd ZdZ fdZd Zd Zd Z xZS )r9 z,Mongo collections, contains mongo documents.c j t | || | j j | _ || _ y r )r r r r r: )r r r r: r s r r zCollCollection.__init__Q s*
w'MM&& r c
ddiS )Nr1 zMongo collectionr2 r3 s r r4 z CollCollection.get_display_infoV s *++r c g }| j j D ]) }|j t j |d + |S )N_id)r: findappendr to_str)r resdocs r r" z CollCollection.get_member_namesY s? 99>># 0C JJt{{3u:. / 0
r c | j j t | }t t | j
| | j | S r )r: find_oner DocResourcer
r r )r r! rE s r r& zCollCollection.get_member_ s8 ii $ 08DIIt4dllCHHr r; r, s @r r9 r9 N s 6
, Ir r9 c @ e Zd ZdZ fdZd Zd Zd Zd Zd Z xZ
S )rH z2Mongo document, returned as virtual text resource.c 4 t | || || _ y r )r r rE )r r r rE r s r r zDocResource.__init__g s
w'r c l dt | j z dz }t |j d S )Nzz
r )r rE r r )r htmls r get_contentzDocResource.get_contentk s. **X5 F+,,r c P t | j j S r )lenrM readr3 s r get_content_lengthz DocResource.get_content_lengtho s 4##%**,--r c y)Nz text/htmlr2 r3 s r get_content_typez DocResource.get_content_typer s r c 0 | j }|j d r|d j d S |j d r|d j d S |j d rt j |d S t j |d S )N_titler titler@ key)rE getr r rC )r rE s r get_display_namez DocResource.get_display_nameu s~ hh 778 x=''/ /
WWW
w<&&v. .
WWU^;;s5z* *{{3u:&&r c
ddiS )Nr1 zMongo documentr2 r3 s r r4 z DocResource.get_display_info r5 r ) r' r( r) r* r rM rQ rS rY r4 r+ r, s @r rH rH d s$ <-.'*r rH c ( e Zd ZdZ fdZd Z xZS )MongoResourceProviderz-DAV provider that serves a MongoDB structure.c H t | || _ t j |j d |j d | _ |j d r| j d }|j |j d |j d }|s*t d|j d|j d t j d|j d |j d d
t j d | j z y ) NhostportuseradminpwdzFailed to logon to db z as user zLogged on to mongo db 'z ' as user ''z%MongoResourceProvider connected to %s) r r optionspymongo
ConnectionrX r authenticate RuntimeErrorr! _loggerinfo)r rd r/ rD r s r r z MongoResourceProvider.__init__ s
&&w{{6':GKKrz s 0 " M M !"
$
* E= E M= M&I] I, *" *D 'K 'r