o 'h.@sdZddlmZddlZddlZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZmZmZddlmZddlmZmZdd lmZmZmZdd lmZdd lm Z dd l!m"Z"m#Z#erdd lm$Z$ddlm%Z%m&Z&m'Z'ddlm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4m5Z5m6Z6m7Z7ddl8m9Z9dZ:              dDdEdBdCZ;dS)Fz&Internal network layer helper methods.) annotationsN) TYPE_CHECKINGAnyMappingMutableMappingOptionalSequenceUnioncast)_decode_all_selective)_csothelpers_sharedmessage)_NO_COMPRESSION)NotPrimaryErrorOperationFailure)_COMMAND_LOGGER_CommandStatusMessage _debug_log)_OpMsg)_is_speculative_authenticate)receive_messagesendall) CodecOptions) SnappyContext ZlibContext ZstdContext)_EventListeners) ReadConcern) _ServerMode) ClientSession) MongoClient) Connection)_Address _CollationIn _DocumentOut _DocumentType) WriteConcernTFconnr"dbnamestrspecMutableMapping[str, Any] is_mongosboolread_preferenceOptional[_ServerMode] codec_optionsCodecOptions[_DocumentType]sessionOptional[ClientSession]clientOptional[MongoClient]checkallowable_errors#Optional[Sequence[Union[str, int]]]addressOptional[_Address] listenersOptional[_EventListeners] max_bson_size Optional[int] read_concernOptional[ReadConcern]parse_write_concern_error collationOptional[_CollationIn]compression_ctx4Union[SnappyContext, ZlibContext, ZstdContext, None] use_op_msgunacknowledged user_fieldsOptional[Mapping[str, Any]]exhaust_allowed write_concernOptional[WriteConcern]returnr&c)Cstt|}|d}d}|}|r|s|dusJt||}| r5|r%|js5| jr-| j|d<|r5||||dur=||d<| duoC| j}t j }|rPt ||}|rZ| t vrZd}|rm|jrm|jjsm|j|||}}|ru|||t|||r|rtjnd}||rtjndO}tj||||||d\}}}} |r| dur| | krt||| ntd|dd|d||\}}}| dur|| tjkrt||| tj|durttjrttt j!|j"j#|tt|||||j$|j%|j&d|j&d |j'd |r| dusJ| dusJ| j(|||| |j%|j'd zOt)|j*j+||r0|r0d}!d d i}"n9t,||}!|!j-|_-|!j.||d }#|#d}"|j/sS|"0d}$|$rS|$|_1|r\|2|"||rit3j4|"|j5| |dWnxt6y}%zkt j |}&t7|%t8t9fr|%j:}'nt;|%}'|durttjrttt j<|j"j#|&|'tt|||||j$|j%|j&d|j&d |j't7|%t9d|r| dusJ| dusJ| j=|&|'||| |j%|j'|dd}%~%wwt j |}&|durttjrttt j>|j"j#|&|"tt|||||j$|j%|j&d|j&d |j'd|vd|r<| dus%J| dus,J| j?|&|"||| |j%|j'||d |rY|jrY|!rY|j@|!A}(tBdtC|(||d}"|"S)aExecute a command over the socket, or raise socket.error. :param conn: a Connection instance :param dbname: name of the database on which to run the command :param spec: a command document as an ordered dict type, eg SON. :param is_mongos: are we connected to a mongos? :param read_preference: a read preference :param codec_options: a CodecOptions instance :param session: optional ClientSession instance. :param client: optional MongoClient instance for updating $clusterTime. :param check: raise OperationFailure if there are errors :param allowable_errors: errors to ignore if `check` is True :param address: the (host, port) of `conn` :param listeners: An instance of :class:`~pymongo.monitoring.EventListeners` :param max_bson_size: The maximum encoded bson size for this server :param read_concern: The read concern for this command. :param parse_write_concern_error: Whether to parse the ``writeConcernError`` field in the command response. :param collation: The collation for this command. :param compression_ctx: optional compression Context. :param use_op_msg: True if we should use OP_MSG. :param unacknowledged: True if this is an unacknowledged command. :param user_fields: Response fields that should be decoded using the TypeDecoders from codec_options, passed to bson._decode_all_selective. :param exhaust_allowed: True if we should enable OP_MSG exhaustAllowed. z.$cmdFN readConcernrCr)ctx) rclientIdcommand commandName databaseName requestId operationIddriverConnectionIdserverConnectionId serverHost serverPort serviceId) service_idok)r1rIz $clusterTime)rB)rrS durationMSfailurerUrVrWrXrYrZr[r\r]isServerSideError)r^ database_namespeculativeAuthenticate)rrSr`replyrUrVrWrXrYrZr[r\r]speculative_authenticate)r^speculative_hellorcr%)Dnextiterr_maybe_add_read_preferencein_transactionleveldocument_update_read_concernenabled_for_commandsdatetimenowrlowerr _encrypter_bypass_auto_encryptionencrypt apply_timeoutr apply_write_concernr MORE_TO_COMEEXHAUST_ALLOWED_op_msg_raise_document_too_large_query_COMMAND_OVERHEADr isEnabledForloggingDEBUGrrSTARTED_topology_settings _topology_ididserver_connection_idr:r^publish_command_startrr(get_connr more_to_comeunpack_responsereadyget _cluster_time_process_responser _check_command_responsemax_wire_version Exception isinstancerrdetails_convert_exceptionFAILEDpublish_command_failure SUCCEEDEDpublish_command_successdecryptraw_command_responser r ))r(r)r+r-r/r1r3r5r7r8r:r<r>r@rBrCrErGrHrIrKrLnamensrgorigpublishstartflags request_idmsgsize max_doc_sizere response_doc unpacked_docs cluster_timeexcdurationra decryptedrW/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/synchronous/network.pyrT=sX 3                      '   rT)TNNNNNFNNFFNFN).r(r"r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r.r8r9r:r;r<r=r>r?r@rArBr.rCrDrErFrGr.rHr.rIrJrKr.rLrMrNr&)<__doc__ __future__rrprtypingrrrrrrr r bsonr pymongor r rpymongo.compression_supportrpymongo.errorsrrpymongo.loggerrrrpymongo.messagerpymongo.monitoringrpymongo.network_layerrrrrrrrpymongo.read_concernrpymongo.read_preferencesr"pymongo.synchronous.client_sessionr pymongo.synchronous.mongo_clientr!pymongo.synchronous.poolr"pymongo.typingsr#r$r%r&pymongo.write_concernr'_IS_SYNCrTrrrrsP (