o sDi7@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]events#Optional[ReferenceType[Queue[Any]]]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?X/home/alumno/antzosa8961/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]MongoClient[Any]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|jdzB| r|d}n ||||| }| rt}d}nd}d}|||j|j||d }| r|d}|j||j t!||j"|j#d 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|}| r7|d}n.|j,d krG|rD|dni}n|j|-ddd}|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|j0r| r|j01|2}t3||j|}|4|j s|j5r|6t%|t7r|j} n t8|j5o|j} |jr|j9| t:||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) pool_opts)rHrj durationMSfailurerlrmrnrorprqrJrKrrisServerSideError)rF database_nameexplain)idns)r&okfindr&r(r)) rHrjrvreplyrlrmrnrorprqrJrKrr)datarNrWduration request_id from_commanddocs more_to_come)rrNrrrr)=enabled_for_commandsrnow use_commandconn_mgrrre get_message_split_messagerrOrPrQrrSTARTED_topology_settingsr9nextiterr{server_connection_idrNrFpublish_command_startreceive_message send_message_CURSOR_DOC_FIELDS cursor_idrbr]_process_responsesessionr max_wire_versionrB 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_sizerrtrsrfirstexcrrwres 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>rHrrr?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]rir4r)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