o 'h6@sddZddlmZddlZddlmZddlmZmZmZm Z m Z m Z ddl m Z ddlmZmZddlmZdd lmZmZmZmZmZdd lmZmZmZmZdd lmZm Z dd l!m"Z"erdd l#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0m1Z1ddl2m3Z3ddl4m5Z5m6Z6ddl7m8Z8dZ9ddddiZ:GdddZ;dS)z2Communicate with one MongoDB server in a topology.) annotationsN)datetime) TYPE_CHECKINGAnyCallableContextManagerOptionalUnion)_decode_all_selective)NotPrimaryErrorOperationFailure)_check_command_response)_COMMAND_LOGGER _SDAM_LOGGER_CommandStatusMessage _debug_log_SDAMStatusMessage)_convert_exception_GetMore_OpMsg_Query)PinnedResponseResponse)_handle_reauth)Queue) ReferenceType)ObjectId)_EventListeners) _ServerMode)ServerDescription) MongoClient_MongoClientErrorHandler)Monitor) ConnectionPool) _DocumentOutTcursor) firstBatch nextBatchc@seZdZ   d@dAddZdBddZdCdDddZdBddZdBddZ dEdFd#d$Ze dGd,d-Z dCdHd1d2Z e dId3d4Z e jdJd5d4Z e dKd6d7ZdLd;d<ZdMd>d?ZdS)NServerNserver_descriptionrpoolr$monitorr" topology_idOptional[ObjectId] listenersOptional[_EventListeners]eventsOptional[ReferenceType[Queue]]returnNonecCsJ||_||_||_||_|duo|j|_||_d|_|jr#||_dSdS)zRepresent one MongoDB server.N) _description_pool_monitor _topology_idenabled_for_server_publish _listener_events)selfr+r,r-r.r0r2r?V/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/synchronous/server.py__init__>s  zServer.__init__cCs|jjjs |jdSdS)z[Start monitoring, or restart after a fork. Multiple calls have no effect. N)r7opts load_balancedr8openr>r?r?r@rDRs z Server.open service_idcCs|j|dS)zClear the connection pool.N)r,reset)r>rFr?r?r@rGZsz Server.resetcCs|jr |jdus J|jdusJ|j|jj|jj|jfft t j r9t tt j|j|jjd|jjdd|j|jdS)zXClear the connection pool and stop the monitor. Reconnect with open(). Nrr')message topologyId serverHost serverPort)r;r<r=putpublish_server_closedr6addressr9r isEnabledForloggingDEBUGrr STOP_SERVERr8closer7rEr?r?r@rS^s$     z Server.closecCs|jdS)zCheck the server's state soon.N)r8 request_checkrEr?r?r@rTxszServer.request_checkF operationUnion[_Query, _GetMore]connr# apply_timeoutbooltuple[dict[str, Any], str]cCsJ|||\}}|jjr|jjjs|jj|j||j}||||fSN) as_commandclient _encrypter_bypass_auto_encryptionencryptdb codec_optionsupdate_command)r>rUrWrXcmdrar?r?r@operation_to_command|s  zServer.operation_to_commandread_preferencer unpack_res!Callable[..., list[_DocumentOut]]r]r rcCs|dusJ|j}t}||} |jo|jj} |||| \} } | r'd} n|||| }||\} }}t t j r]t t tj|jj| tt| | | | |j|j|jd|jd|jd |r{d| vrg| | d<|dusmJ|j| | | |j|j|jdz?| r|d}n ||||| }| rt}d}nd}d}|||j|j||d }| r|d}|j||j t!||j"Wnkt#y%}z^t|}t$|t%t&fr|j'}nt(|}t t j rt t tj)|jj||tt| | | | |j|j|jd|jd|jt$|t&d |r |dusJ|j*|||j+| |j|j|j| d d}~wwt|}| r4|d}n.|j+d krD|rA|dni}n|j|,d dd}|j+dkr\||dd<n||dd<t t j rt t tj-|jj||tt| | | | |j|j|jd|jd|jd|r|dusJ|j.|||j+| |j|j|j| d |j}|r|j/r| r|j/0|1}t2||j|}|3|j s|j4r|5t$|t6r|j} n t7|j4o|j} |jr|j8| t9||j:j||| | || d}|St;||j:j|| | |d}|S)a<Run a _Query or _GetMore operation and return a Response object. This method is used only to run _Query/_GetMore operations from cursors. Can raise ConnectionFailure, OperationFailure, etc. :param conn: A Connection instance. :param operation: A _Query or _GetMore object. :param read_preference: The read preference to use. :param listeners: Instance of _EventListeners or None. :param unpack_res: A callable that decodes the wire protocol response. :param client: A MongoClient instance. Nrr') rHclientIdcommand commandName databaseName requestId operationIddriverConnectionIdserverConnectionIdrJrK serviceIdz$db)rFFT)legacy_response user_fields)rHri durationMSfailurerkrlrmrnrorprJrKrqisServerSideError)rF database_nameexplain)idns)r&okfindr&r(r)) rHrirtreplyrkrlrmrnrorprJrKrq)datarNrWduration request_id from_commanddocs more_to_come)r~rNrrrr)<enabled_for_commandsrnow use_commandconn_mgrrre get_message_split_messagerrOrPrQrrSTARTED_topology_settingsr9nextiterryserver_connection_idrNrFpublish_command_startreceive_message send_message_CURSOR_DOC_FIELDS cursor_idrbr]_process_responsesessionr max_wire_version Exception isinstancer r detailsrFAILEDpublish_command_failurename namespace SUCCEEDEDpublish_command_successr^decryptraw_command_responser _should_pin_cursorexhaust pin_cursorrrYupdate_exhaustrr6r)r>rWrUrfr0rgr]publishstartuse_cmdrrddbnrrHr~ max_doc_sizer}rsrrrfirstexcrrures decryptedresponser?r?r@ run_operationsP              %         zServer.run_operationhandler"Optional[_MongoClientErrorHandler]ContextManager[Connection]cCs |j|Sr[)r,checkout)r>rr?r?r@r^s zServer.checkoutcC|jSr[)r6rEr?r?r@ descriptionczServer.descriptioncCs|j|jjks J||_dSr[)rNr6)r>r+r?r?r@rgs cCrr[)r7rEr?r?r@r,lrz Server.poolrH,Union[tuple[int, Any], tuple[int, Any, int]]tuple[int, Any, int]cCs"t|dkr|S|\}}||dfS)zReturn request_id, data, max_doc_size. :param message: (request_id, data, max_doc_size) or (request_id, data) r)len)r>rHrr~r?r?r@rps  zServer._split_messagestrcCsd|jjd|jdS)N< >) __class____name__r6rEr?r?r@__repr__~szServer.__repr__)NNN)r+rr,r$r-r"r.r/r0r1r2r3r4r5)r4r5r[)rFr/r4r5)F)rUrVrWr#rXrYr4rZ)rWr#rUrVrfrr0r1rgrhr]r r4r)rrr4r)r4r)r+rr4r5)r4r$)rHrr4r)r4r)r __module__ __qualname__rArDrGrSrTrerrrpropertyrsetterr,rrr?r?r?r@r*=s0      V     r*)<__doc__ __future__rrPrtypingrrrrrr bsonr pymongo.errorsr r pymongo.helpers_sharedr pymongo.loggerrrrrrpymongo.messagerrrrpymongo.responserrpymongo.synchronous.helpersrqueuerweakrefr bson.objectidrpymongo.monitoringrpymongo.read_preferencesrpymongo.server_descriptionr pymongo.synchronous.mongo_clientr r!pymongo.synchronous.monitorr"pymongo.synchronous.poolr#r$pymongo.typingsr%_IS_SYNCrr*r?r?r?r@s4