o {g>@sdZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z m Z mZmZmZddlmZddlmZmZmZddlmZddlmZmZdd lmZmZmZm Z dd l!m"Z"m#Z#m$Z$dd l%m&Z&m'Z'm(Z(dd l)m*Z*dd l+m,Z,m-Z-m.Z.m/Z/m0Z0ddl1m2Z2e rddlm3Z3ddlm4Z4m5Z5m6Z6ddl)m7Z7ddl8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAddlBmCZCmDZDmEZEmFZFddlGmHZHdZI              dUdVdDdEZJefdWdJdKZKdXdOdPZLdYdSdTZMdS)Zz&Internal network layer helper methods.) annotationsN) TYPE_CHECKINGAnyMappingMutableMappingOptionalSequenceUnioncast)_decode_all_selective)_csothelpers_sharedmessage)MAX_MESSAGE_SIZE)_NO_COMPRESSION decompress)NotPrimaryErrorOperationFailure ProtocolError_OperationCancelled)_COMMAND_LOGGER_CommandStatusMessage _debug_log) _UNPACK_REPLY_OpMsg_OpReply)_is_speculative_authenticate) _POLL_TIMEOUT_UNPACK_COMPRESSION_HEADER_UNPACK_HEADERBLOCKING_IO_ERRORSsendall)_errno_from_exception) 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]returnr0c(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|durttjrtt|j j!t"j#|tt|||||j$|j%|j&d|j&d |j'd |r| dusJ| dusJ| j(|||| |j%|j'd z?t)|j*||r/|r/d}!d d i}"n*t+||}!|!j,|_,|!j-||d }#|#d}"|rL|.|"||rYt/j0|"|j1| |dWnxt2y}$zkt j |}%t3|$t4t5frv|$j6}&nt7|$}&|durttjrtt|j j!t"j8|%|&tt|||||j$|j%|j&d|j&d |j't3|$t5d|r| dusJ| dusJ| j9|%|&||| |j%|j'|dd}$~$wwt j |}%|dur ttjr tt|j j!t"j:|%|"tt|||||j$|j%|j&d|j&d |j'd|vd|r,| dusJ| dusJ| j;|%|"||| |j%|j'||d |rI|jrI|!rI|j<|!=}'t>dt?|'||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 readConcernrMr)ctx) clientIdrcommand commandName databaseName requestId operationIddriverConnectionIdserverConnectionId serverHost serverPort serviceId) service_idok)r;rS)rL)r]r durationMSfailurer_r`rarbrcrdrerfrgisServerSideError)rh database_namespeculativeAuthenticate)r]rrjreplyr_r`rarbrcrdrerfrgspeculative_authenticate)rhspeculative_hellormr/)@nextiterr_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 isEnabledForloggingDEBUGr_topology_settings _topology_idrSTARTEDidserver_connection_idrDrhpublish_command_startr!r2receive_message more_to_comeunpack_response_process_responser _check_command_responsemax_wire_version Exception isinstancerrdetails_convert_exceptionFAILEDpublish_command_failure SUCCEEDEDpublish_command_successdecryptraw_command_responser r )(r2r3r5r7r9r;r=r?rArBrDrFrHrJrLrMrOrQrRrSrUrVnamensrqorigpublishstartflags request_idmsgsize max_doc_sizero response_doc unpacked_docsexcdurationrk decryptedrx/var/www/bot.gig.net.ua/public_html/telegram/P1/HellBot/venv/lib/python3.10/site-packages/pymongo/synchronous/network.pyr^GsP 3                     '   r^rmax_message_sizeintUnion[_OpReply, _OpMsg]c Cs&tr t}n|j}|rt|}nd}tt|d|\}}}}|dur7||kr7t d|d||dkrCt d|d||krRt d|d|d|d krmt t|d |\}}} t t||d || } nt||d|} z t |} W| | St yt d |dt dw) z1Receive a raw BSON message or raise socket.error.NzGot response id z but expected zMessage length (z3) not longer than standard message header size (16)z*) is larger than server max message size ()i z Got opcode )r get_timeout get_deadliner2 gettimeouttime monotonicr_receive_data_on_socketrrrrKeyErrorkeys) r2rrdeadlinetimeoutlength_ response_toop_code compressor_iddata unpack_replyrrrr3sH       rrOptional[float]NonecCs|j}d}|dkr dS t|dr|dkrd}n"|r3|t}|dkr*d}tt|td}nt}|j j |d|d}|j j rFt d|rJdS|rQtd q) zABlock until at least one byte is read, or a timeout, or a cancel.Fr[NTpendingr)readrzoperation cancelled timed out)r2filenohasattrrrrmaxminrsocket_checkerselectcancel_context cancelledrsocketr)r2rsock timed_outreadable remainingrrrr wait_for_read_s*   rr memoryviewc Cst|}t|}d}||krjz%t||tr(|dur(|t|td|j ||d}Wn&t y@t ddtyY}zt|tjkrTWYd}~q d}~ww|dkrbtd||7}||ks|S)Nrrzconnection closed) bytearrayrrr rset_conn_timeoutrrrr2 recv_intor rrOSErrorr"errnoEINTR)r2rrbufmv bytes_read chunk_lengthrrrrrs,    r)TNNNNNFNNFFNFN).r2r,r3r4r5r6r7r8r9r:r;r<r=r>r?r@rAr8rBrCrDrErFrGrHrIrJrKrLr8rMrNrOrPrQr8rRr8rSrTrUr8rVrWrXr0)r2r,rrIrrrXr)r2r,rrrXr)r2r,rrrrrXr)N__doc__ __future__rrzrrrrtypingrrrrrrr r bsonr pymongor r rpymongo.commonrpymongo.compression_supportrrpymongo.errorsrrrrpymongo.loggerrrrpymongo.messagerrrpymongo.monitoringrpymongo.network_layerrrrr r!pymongo.socket_checkerr"r#r$r%r&r'pymongo.read_concernr(pymongo.read_preferencesr)"pymongo.synchronous.client_sessionr* pymongo.synchronous.mongo_clientr+pymongo.synchronous.poolr,pymongo.typingsr-r.r/r0pymongo.write_concernr1_IS_SYNCr^rrrrrrrsd (              n ,!