σ O'—^c@@sσdZddlmZddlZddlmZmZddlmZddl m Z ddl m Z dd l mZyddlZWnek r‘dZnXd Zd Zd Zd „Zdejfd„ƒYZdejfd„ƒYZdS(s‘ kombu.transport.couchdb ======================= CouchDB transport. :copyright: (c) 2010 - 2013 by David Clymer. :license: BSD, see LICENSE for more details. i(tabsolute_importN(tloadstdumps(tEmpty(tuuid4(t bytes_to_stri(tvirtuali`t kombu_defaults#David Clymer cC@sHddlm}|jdddƒ}|j|ƒsD|j|ƒndS(Ni(tdesigntkombutmessagessv function (doc) { if (doc.queue && doc.payload) emit(doc.queue, doc); } (tcouchdbRtViewDefinitiontget_doctsync(tdbRtview((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pytcreate_message_view"s   tChannelcB@sYeZdZeZd„Zd„Zd„Zd„Z d„Z d„Z e d„ƒZ RS(cK@s5|jjitƒjd6|d6t|ƒd6ƒdS(Nt_idtqueuetpayload(tclienttsaveRthexR(tselfRtmessagetkwargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyt_put4scC@s[|j|ddƒ}|s'tƒ‚n|jdj}|jj|ƒtt|dƒƒS(NtlimitiiR(t_queryRtrowstvalueRtdeleteRR(RRtresulttitem((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyt_get9s  cC@s=|j|ƒ}x!|D]}|jj|jƒqWt|ƒS(N(RRR!R tlen(RRR"R#((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyt_purgeBs cC@st|j|ƒƒS(N(R%R(RR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyt_sizeHscC@sδ|jj}|j}|jr$dp'd}| s=|dkrFt}n|jpRt}tjd||j |fƒ}y(|j r›|j |j f|j _ nWntk r―nXy ||SWn!tjjk rί|j|ƒSXdS(Nthttpsthttpt/s %s://%s:%s/(t connectionRt virtual_hosttssltDEFAULT_DATABASEtportt DEFAULT_PORTR tServerthostnametuseridtpasswordtresourcet credentialstAttributeErrorR)tResourceNotFoundtcreate(RtconninfotdbnametprotoR/tserver((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyt_openKs&        cK@s;|js"t|jƒt|_n|jjdd||S(Nskombu/messagestkey(t view_createdRRtTrueR(RRR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyRas   cC@s(|jdkr!|jƒ|_n|jS(N(t_clienttNoneR>(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyRhsN(t__name__t __module__RCRBtFalseR@RR$R&R'R>RtpropertyR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyR/s     t Transportc B@sΦeZeZdZeZejje j e e dd ƒe e dd ƒe e dd ƒfZejje e dd ƒe e dd ƒe e dd ƒe e dd ƒe e dd ƒfZdZdZd„Zd „ZRS( it HTTPErrort ServerErrort UnauthorizedtPreconditionFailedtResourceConflictR8R cO@s8tdkrtdƒ‚ntt|ƒj||ŽdS(Ns-Missing couchdb library (pip install couchdb)(R RCt ImportErrortsuperRHt__init__(RtargsR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyRPˆs cC@stjS(N(R t __version__(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pytdriver_versionsN(RDRERtpolling_intervalR0t default_portRRHtconnection_errorstsocketterrortgetattrR RCtchannel_errorst driver_typet driver_nameRPRS(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyRHos$   (t__doc__t __future__RRWtanyjsonRRt kombu.fiveRt kombu.utilsRtkombu.utils.encodingRtRR RNRCR0R.t __author__RRRH(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/couchdb.pyt s"    @