hdZddlZddlZddlZddlZddlmZmZmZmZm Z m Z ddl m Z ddl mZddlmZmZddlmZmZmZddlmZ dd lmZd Zdd lmZmZmZm Z m!Z!m"Z"m#Z#m$Z$dd l%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9e0de1de2diZ:d d!d"d#Z;d$Z<ed%&Z=d'Z>d(Z?d)Z@d*ZAegd+ZBegd,ZC dvd-ZDd.ZEGd/d0eFZGGd1d2eFZHGd3d4eGZIGd5d6eHZJGd7d8eKZLejd9jZOd:ZPd;ZQd<ZRejd=jZSd>ZTejd?jZUd@ZVdAZWdBZXer ejZX dwdCZZdDZ[dEZ\dFZ]er ejZ] dwdGZ_ejdHjZ`ejdIjZadJZbdKZcdLZder ejZddwdMZedNZf dxdOZg dydPZher ejZh dxdQZjejdRjZkdSZldTZmdUZner ejZndwdVZpdWZqdXZrdzdYZsd{dZZtd[ZuGd\d]eFZvd^ZwGd_d`evZxdaZydbZzer ejZze0dce1dde2deiZ{dfZ|dgZ}er ejZ}dhZ~diZer ejZdjZdkZdlZer ejZdmZer ejZdnZdoZdpZGdqdreFZGdsdteFZejejejejiZduZy#e$rd ZYwxYw)|a>**DEPRECATED** Tools for creating `messages `_ to be sent to MongoDB. .. note:: This module is for internal use and is generally not needed by application developers. .. versionchanged:: 3.12 This module is deprecated and will be removed in PyMongo 4.0. N) CodecOptions_decode_selective _dict_to_bson_make_c_stringdecodeencode)DEFAULT_CODEC_OPTIONS)Int64)StringIOb)DEFAULT_RAW_BSON_OPTIONSRawBSONDocument _inflate_bsonSON) _cmessageTF)ConfigurationErrorCursorNotFoundDocumentTooLargeExecutionTimeoutInvalidOperationNotPrimaryErrorOperationFailure ProtocolError) HelloCompat)DEFAULT_READ_CONCERN)ReadPreference) WriteConcerniii?ssssdocumentss updatess deletes documentsupdatesdeletes)insertupdatedeletez%s.%sreplace)unicode_decode_error_handlerc>tjttS)z(Generate a pseudo random 32 bit integer.)randomrandint MIN_INT32 MAX_INT32r!M/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/pymongo/message.py_randintr4_s >>)Y //r!c|j}|j}|rB|tjjk7st |dkDrd|vrt d|fg}||d<|S)z-Add $readPreference to spec when appropriate.r$query$readPreference)modedocumentrSECONDARY_PREFERREDlenr)specread_preferencer8r9s r3_maybe_add_read_preferencer>dsf   D''H  ;;@@@CMTUDU 4 4()*D"*  Kr!cFt||jjdS)z&QEF"#))#4i "'C JHw{+,C J h   )*6*3EFGC O J ZZ) *e 3A Y'*F+//%)?@C)*378C O Jr!))tailabler ) oplogReplayrQ)noCursorTimeout) awaitData )allowPartialResults) )r6filter)z$orderbysort)z$hinthint)z$commentcomment)z$maxScanmaxScan)z $maxTimeMS maxTimeMS)z$maxmax)z$minmin)z $returnKey returnKey)z $showRecordId showRecordId)z $showDiskLocrr)z $snapshotsnapshotc |td|fg} d|vrr| j|jD cgc]\} } | tvr t| | fn| | fc} } d| vr| j dd| vr| j dn|| d<|r|| d<|r|| d<|rt || d<|d krd | d <|r|| d <|j r| r | js|j| d <|r|| d<| | | d<|r>| jtjD cgc]\}} || zs |d fc} }| Scc} } wcc} }w)z!Generate a find command document.findr6$explainr7ri projectionskiplimitrT singleBatch batchSize readConcern collation allowDiskUse) rr)items _MODIFIERSpopabslevelin_transactionr9_OPTIONS)collr<rwrxry batch_sizeoptions read_concernr}sessionallow_disk_usecmdkeyvalopts r3_gen_find_commandrs^ ~ C4 !%  C+.*;C#&#sK    GGJ   # GG% &H &L F  5zG 19!%C %K7w/E/E)22M$K!,N 0@RHCGcMS$KRS J? :Ss!D2  D8 "D8 cDtd|fd|fg}|r||d<|||d<|S)z$Generate a getMore command document.getMore collectionr{rnr) cursor_idrrmax_await_time_msrs r3_gen_get_more_commandrs= 9% d';< =C%K$,K Jr!c<eZdZdZdZdZdZdZdZdZ dZ d dZ y) _QueryzA query operation.)flagsdbrntoskipr<fields codec_optionsr=ryrnamerr}rclientr _as_commandexhaustNc||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ ||_d|_d|_||_y)Nru)rrrrr<rrr=rryrr}rrrrrr)selfrrrrr<rrr=ryrrr}rrrrs r3__init__z_Query.__init__s&     *.( $"  ,  r!c@t|j|jfzSN_UJOINrrrs r3 namespacez_Query.namespace8$)),,,r!cd}|jdk\r|jsd}nV|jdk\rd}nD|jjs.t d|jj |jfz|jdkr%|j t d|jfz|jdkr%|jt d|jfz|j|j|j|S) NFTrQzDread concern level of %s is not valid with a max wire version of %d.zDSpecifying a collation is unsupported with a max wire version of %d.zESpecifying allowDiskUse is unsupported with a max wire version of %d.) max_wire_versionrr ok_for_legacyrrr}rvalidate_sessionrr)r sock_info use_find_cmds r3 use_commandz_Query.use_command;s  % % *4<<L  ' '1 ,L""00$1$$**I,F,FGH   % % )dnn.H$!$-$>$>#@A   % % )d.A.A.M$!$-$>$>#@A  ""4;; =r!c t|j |jSd|jv}t|j|j|j|j |j |j|j|j|j|j|j }|rd|_ td|fg}|j}|j||r>|j!|d|j"||s|j$s|j'|||j)|||j*|j*}|j,rH|j,j.s2|j,j1|j2|d|j4}||j2f|_|jS)z.Return a find command document for this query.rvexplainF)rr<rrrrryrrrr}rrrradd_server_api _apply_tor=r_update_read_concernsend_cluster_timer _encrypter_bypass_auto_encryptionencryptrr)rrrrrrs r3 as_commandz_Query.as_commandYsj    '## # ) II II KK LL JJ OO JJ    NN LL      !DI 3'()C,,  %    c5$*>*> J7#9#9,,S)<##C$++>   V%6%6%N%N##++DGGS%ASASTC<r!c |r|jdz}n |j}|j}|j}|r}|j|d}|jrEt d||j |j|d|j|j\}}} } ||| fSt|j dfz}d} nR|jdk(xrdxs |j} |jr%| rt|j| } n |j} |jrt||j}t!|||j"| ||rd n |j$|j|jS) z:Get a query message, possibly setting the secondaryOk bit.rrFctx$cmdrr N)rrr<rop_msg_enabled_op_msgrr=rcompression_contextrrryrp is_mongosr>queryrr) rset_secondary_okruse_cmdrnsr< request_idmsgsize_ ntoreturns r3 get_messagez_Query.get_messagesP JJNEJJE ^^ yy ??9-a0D''+2GG(($&&!55 ,( Cq"3,,477F++BI 1,2EdooIzz #DJJ :I $ I   -dD4H4HID   LL  D   --  r!F) rD __module__ __qualname____doc__ __slots__sock_mgrrrrrrrr2r!r3rrs3I,HI$L-<% N2 r!rc8eZdZdZdZdZdZdZdZdZ d dZ y ) _GetMorezA getmore operation.) rrrrrrr=rrrrrrc ||_||_||_||_||_||_||_||_| |_| |_ d|_ | |_ yr) rrrrrr=rrrrrr) rrrrrrr=rrrrrs r3rz_GetMore.__init__s\ ""*.  !2   r!c@t|j|jfzSrrrs r3rz_GetMore.namespacerr!cd}|jdk\r|jsd}n|jdk\rd}|j|j|j|S)NFrTrQ)rrrrr)rrrs r3rz_GetMore.use_commandsP  % % *4<<G  ' '1 ,G""4;; =r!ct|j |jSt|j|j|j|j }|j r(|j j|d|j||j||j||j |j|j}|jrH|jjs2|jj|j|d|j }||jf|_|jS)z1Return a getMore command document for this query.F)rrrrrrrrr=rrrrrrrr)rrrrs r3rz_GetMore.as_commands    '## ## NNDIIt~~t7M7M  << LL " "3t/C/CY O  %##Ct{{C   V%6%6%N%N##++DGGS%ASASTC<r!c |j}|j}|r|j|d}|jrZ|jrt j }nd}t|||jddd|j|j\}} } } || | fSt|jdfz}td|dd|d|j|St||j|j|S)zGet a getmore message.rNFrrr)rrrrr_OpMsgEXHAUST_ALLOWEDrrrrrget_morerr) rdummy0rrrrr<rrrrrs r3rz_GetMore.get_messages^^ ++ ??9-a0D''=="22EE+2GG&&!55 ,( Cq"3,,477F++BB2tT43E3E3O ODNNDNNC@@r!Nr) rDrrrrrrrrrrr2r!r3rrs- I D6-  *Ar!rceZdZfdZxZS)_RawBatchQueryc~tt| ||jdk\ry|jr |j syyNrQTF)superrrrrrrrrCs r3rz_RawBatchQuery.use_command&s8 nd/ :  % % *  % %dllr!rDrrr __classcell__rCs@r3rr% r!rceZdZfdZxZS)_RawBatchGetMorec~tt| ||jdk\ry|jr |j syyr)rrrrrrrs r3rz_RawBatchGetMore.use_command2s9 1)<  % % *  % %dllr!rrs@r3rr1rr!rc8eZdZdZdZedZdZdZdZ y)_CursorAddresszEThe server address (host, port) of a cursor, with namespace property.c@tj||}||_|Sr)tuple__new___CursorAddress__namespace)clsaddressrrs r3rz_CursorAddress.__new__@s}}S'*$ r!c|jS)zThe namespace this cursor.)rrs r3rz_CursorAddress.namespaceEsr!c>||jfzjSr)r__hash__rs r3rz_CursorAddress.__hash__Js!((**4466r!ct|tr2t|t|k(xr|j|jk(StSr) isinstancerrrNotImplementedrothers r3__eq__z_CursorAddress.__eq__Os7 e^ ,;%,.T4>>U__3T Tr!c||k( Srr2rs r3__ne__z_CursorAddress.__ne__Ts5=  r!N) rDrrrrpropertyrrrrr2r!r3rr=s-O   7  !r!rz39=G $ r!sB<cPt|||||\}}td||\}} || |fS)z9Internal compressed unacknowledged insert message helper.)r'r ) r!r"r#continue_on_errorr$r op_insert max_bson_sizerrs r3_insert_compressedr-s:&jJ[]abI}y#.HC ] ""r!ct|||||\}}td|\} } |rt||\} } } | | | z|fS| | |fS)zInternal insert message helper.r))r'rr) r!r"r#safelast_error_argsr*r$r+r,rrglers r3_insert_uncompressedr2s` 'jJ[]abI}dI.HC "?OD S!C#I},, ] ""r!c H|rt||||||St|||||||S)z**DEPRECATED** Get an **insert** message. .. versionchanged:: 3.12 This function is deprecated and will be removed in PyMongo 4.0. )r-r2)r!r"r#r/r0r*r$rs r3r(r(s= !/4EVX\^abb z4BSUY r!c d}|r|dz }|r|dz }t}||||} djtt|t |||d|| gt | fS)zGet an OP_UPDATE message.rrr r!Frr_ZERO_32rrr;) r!upsertmultir<r&r#r$rrencoded_updates r3_updater:sy E       FCT2N 88  ? + e  4 %     > r!c Tt|||||||\}} td||\} } | | | fS)z9Internal compressed unacknowledged update message helper.)r:r ) r!r7r8r<r&r#r$r op_updater,rrs r3_update_compressedr>s>&tSR\^bcI}y#.HC ] ""r!c t|||||||\} } td| \} } |rt||\} } }| | | z| fS| | | fS)zInternal update message helper.r<)r:rr)r!r7r8r<r&r/r0r#r$r=r,rrr1rs r3_update_uncompressedr@sd 'tSR\^bcI}dI.HC "?OD S!C#I},, ] ""r!c P| rt|||||||| St||||||||| S)z**DEPRECATED** Get an **update** message. .. versionchanged:: 3.12 This function is deprecated and will be removed in PyMongo 4.0. )r>r@) r!r7r8r<r&r/r0r#r$rs r3r)r)sC !/65$ZY]_bcc c4*VZ r!zz$_op_msg_no_header..s!Cs#c(!Crc32K|]}t|ywrrDrEs r3rGz$_op_msg_no_header..s<3s8:| 33NsB?cVt||||||\}}} td||\} }| ||| fS)zInternal OP_MSG message helper.)rUr ) rr[rMr"r#r$rrrOr,rs r3_op_msg_compressedrXsC%6 w D*d&"C]sC(HC Z ..r!cTt||||||\}}}td|\} } | | ||fS)z*Internal compressed OP_MSG message helper.rW)rUr) rr[rMr"r#r$r rOr,r op_messages r3_op_msg_uncompressedr[!sB&7 w D*d'#D*m,D$7J z:} < %@PRYZ []`^ r!cNt||||\}}td||\}}|||fS)z9Internal compressed unacknowledged delete message helper.)r~r ) r!r<r$rr op_deleter,rrs r3_delete_compressedrs6&dEJI}y#.HC ] ""r!ct||||\}}td|\}} |rt||\}} } || | z|fS|| |fS)zInternal delete message helper.r)r~rr) r!r<r/r0r$rrr,rrr1rs r3_delete_uncompressedrsZ&dEJI}dI.HC "?OD S!C#I},, ] ""r!cD|rt|||||St||||||S)aS**DEPRECATED** Get a **delete** message. `opts` is a CodecOptions. `flags` is a bit vector that may contain the SingleRemove flag or not: http://docs.mongodb.org/meta-driver/latest/legacy/mongodb-wire-protocol/#op-delete .. versionchanged:: 3.12 This function is deprecated and will be removed in PyMongo 4.0. )rr)r!r<r/r0r$rrs r3r*r*s0 !/4ucJJ t_dTY ZZr!ct|}tjdd|zzj}|d|g|}t d|S)z**DEPRECATED** Get a **killCursors** message. .. versionchanged:: 3.12 This function is deprecated and will be removed in PyMongo 4.0. z>22R7 7~~...r!c.|jjS)z*A proxy for SockInfo.max_write_batch_size.)rmax_write_batch_sizers r3rz&_BulkWriteContext.max_write_batch_sizeus~~222r!c|jS)z:The maximum size of a BSON command before batch splitting.)r,rs r3max_split_sizez _BulkWriteContext.max_split_sizezs!!!r!c|r$td||jj\}}|j|jj |||||S)Nr))r rrrrcopy)rrrrP acknowledgedr"rs r3legacy_bulk_insertz$_BulkWriteContext.legacy_bulk_insertsO 'c4>>3U3UVOJ  OO "J\._insert_message(s?$24$H! M +7+Y (J q ] *M=((r!NrFTrr(r)r writerrintrtellrrr;r,rappendgetvaluerrrseektruncater)r!r"r#r/r0r*r$rrr last_errorr message_length begin_lochas_docsrrrr&r%encoded_length too_largerrrrs` ` r3_do_batched_insertr#s )---IJ :DJJv{{4%6!789JJ~o./!%,NYHG F||7T%6Y 7H)j$/W"S%6%66 .( C00 0 JJw  NN3 H   #T]]_C.t}} JHC&&sCIwQ  %h@Q@Q R"^3 )  7%S)V ?@@ C )$--/4@ C:sAtWhG?$ $!$J  s7 ""r!c |t|||||||\}}td||jj\} } | | |fS)z]Create the next batched insert, update, or delete operation with OP_MSG, compressed. rW)rr rr) rZr[r"r#rr$rr rrrs r3_batched_op_msg_compressedr sJ+9gtZQTVZ\_`MD'dCMM,M,MNOJ sG ##r!c rt}|jt|jdt||||||||\}} |j dt } |jt | |j d|jt | | |j|fS)z"OP_MSG implementation entry point.srr)r r_ZERO_64rrr4rr) rZr[r"r#rr$rrrrrs r3_batched_op_msgr s *CIIhII12*7D*c4cOGV HHQKJIIi #$HHQKIIi s||~w ..r!c |jddd|d<d|vrt|djdd}nd}|jjrt |||||||St |||||||S)zRCreate the next batched insert, update, or delete operation using OP_MSG. rrrr] writeConcernrT)rboolrYrrr r )rrZr[r"r#r$rrs r3_do_batched_op_msgrs__S!,Q/GEN 7>*..sA67 }}(())WdJPSUY[^__ 9gtZdC PPr!c |t|||||||\}}td||jj\} } | | |fS)zFCreate the next batched insert, update, or delete command, compressed.rl)rr rr) rrZr[r"r#r$rr rrrs r3!_batched_write_command_compressedrsJ19gtZsMD' dCMM,M,MNOJ sG ##r!c dt}t||||||||\}} |j|fS)z:Encode the next batched insert, update, or delete command.)r _batched_write_command_implr) rrZr[r"r#r$rrrrs r3rr s; *C,9gtZsCJGQ <<>7 ""r!c rt}|jt|jdt||||||||\}} |j dt } |jt | |j d|jt | | |j|fS)z:Create the next batched insert, update, or delete command.srr)r rr rrr4rr) rrZr[r"r#r$rrrrrs r3_batched_write_commandrs *CIIhII1229gtZsCOGV HHQKJIIi #$HHQKIIi s||~w ..r!c r|jjrt|||||||St|||||||S)z#Batched write commands entry point.)rrrrrrZr[r"r#r$rs r3_do_batched_write_commandr7sF }}((0 y'4T3   ")YzSWY\ ]]r!c x|jjdkDrt|||||||St|||||||S)z Bulk write commands entry point.r)rrrrrs r3rr@sF }}%%)!)YzSWY\]] $Y 7D*VZ\_ ``r!c|j}|j} |tz} |j} |j t |j t ||j t|j t|j} |j t||jdd|j |j t||t t"fvrd}|jdz } g}d}|D] }t t%|}t|||}t'|| kD}|r6t)t*j-|}t/|t'|||dk\xr+|jt'|zt'|z| k\}|| k\}|s|rne|j t0|j ||j t|j ||j3||dz } |j t4|j}|j| |j t7|| z dz |j| |j t7|| z ||fS#t$r tdwxYw)z(Create a batched OP_QUERY write command.rr rFrrr)r,r_COMMAND_OVERHEADrrr6r _ZERO_8_SKIPLIMrrrr_OP_MAPrbrrrrBr;rrarr_BSONOBJr_ZERO_16r)rrZr[r"r#r$rrr,r max_cmd_sizer command_start list_startrrr&rrrr enough_dataenough_documentsrs r3rrGsT%%M33!#44L''NIIhIIa lIIgIIhHHJMIIfWoHHROLLN2 ')$%Wg&& aJG CCksJ-E \1 JOO-.y9H %hE M JQhYCHHJS$9CJ$F>#Y "66 *  ( # ' %s q'.IIhXXZFHHZIIi+a/01HH]IIi./0 F?U 20112s J**J?ceZdZdZdZej djZdZ dZ ddZ de ddfd Z d Zd Zed Zed Zy)_OpReplyz$A MongoDB OP_REPLY response message.)rrnumber_returnedr%z #$HII4ylBCb9F b&1 1 ZZ!^99T^^4;;=L  # #D! ,F#..{/G/GH%l6&:LII!!&)R/& $$V,l.>.>v.F #$|'7'7'??  (  >>NN# # r!Fc|j||r tj|j|Stj|j||S)aeUnpack a response from the database and decode the BSON document(s). Check the response for errors and unpack, returning a dictionary containing the response data. Can raise CursorNotFound, NotPrimaryError, ExecutionTimeout, or OperationFailure. :Parameters: - `cursor_id` (optional): cursor_id we sent to get this response - used for raising an informative exception when we get cursor id not valid at server response - `codec_options` (optional): an instance of :class:`~bson.codec_options.CodecOptions` )r7r/ decode_allr%_decode_all_selectiverrrr4legacy_responses r3unpack_responsez_OpReply.unpack_responsesC, )$ ??4>>=A A))$..-UUr!cR|j|}|jdk(sJ|dS)Unpack a command response.rrr)r=r*)rrr"s r3command_responsez_OpReply.command_responses2##-#@##q(((Awr!ctz)Return the bytes of the command response.)NotImplementedErrorrs r3raw_command_responsez_OpReply.raw_command_responses "!r!cy)+Is the moreToCome bit set on this response?Fr2rs r3 more_to_comez_OpReply.more_to_comerr!c`|j|\}}}}t|dd}|||||S)z%Construct an _OpReply from raw bytes.N) UNPACK_FROMbytes)rrrrrr*r%s r3unpackz_OpReply.unpacks=03s/C,y!_#bc(O 5)_i@@r!)NN)rDrrrrrr unpack_fromrKOP_CODErr7_UNICODE_REPLACE_CODEC_OPTIONSr=rArErrH classmethodrMr2r!r3r)r)sx.FI&--(44KG# (X4 V6 " AAr!r)ceZdZdZdZej djZdZ dZ dZ dZ dZ d ifd Zd ed d fd Zd ZdZedZedZy )rz"A MongoDB OP_MSG response message.)rrr*payload_documentz1 sectionN)rKCHECKSUM_PRESENTrr[r;rL)rrrfirst_payload_typefirst_payload_sizerSs r3rMz _OpMsg.unpack8s9<8L5!#5 A:s+++#$VZ_Ya$abbs'''#$Dx$OPP  " JN`Mb bc c s8)A- - FG G!QR>5*++r!)rDrrrrrrrNrKrOr]r[rrr7rPr=rArErrHrQrMr2r!r3rrs,MI&--'33KGLO1&*r#4 ]$D%..,,r!rc Jtd||d|d|||dtddddd}tt|} | j} | rt j j } |j||\} }}| rit j j  z }| j||| |j|jt j j } |j|||j| } |jd|}d|vr||j*|d|ddd }n|r|dni}d|d <| rOt j j  z z}| j-||| | |j|j|S#t$r}| r}t j j  z z}t|t t"fr |j$}n t'|}| j)||| | |j|jd}~wwxYw) zESimple query helper for retrieving a first (and possibly only) batch.rNF)rcursorr) firstBatchidrg?)rarIrI)rrr_r`rrrrrrr send_messagereceive_messager=rrrrrrFrrr)rrrrrrdrr=rrrrrrrrPencoding_durationrr"rrrr\s r3 _first_batchrgTs?             ! E& S ?D,,G!!%%'$)$5$5lI$N!J\$--113e;'' Z!2!2y?S?S ( !!%%' 3 -  % %j 1E$$T=9$3'+EOOXZ\`Lab  !abu %%))+e37HH)) fdJ 0A0AiNbNb *  MA   ))--/%7;LLH#1ABC++,S1  - -!!$// .  sF H"BHH")NNNr)FNr)r)rN)rrr.rr/rrrrrrbson.codec_optionsr bson.int64r bson.py3compatr r bson.raw_bsonr rrbson.sonrpymongor_use_c ImportErrorpymongo.errorsrrrrrrrrpymongo.hello_compatrpymongo.read_concernrpymongo.read_preferencesrpymongo.write_concernrr1r0r_INSERTrr_EMPTYr!rr"r6r rr rarrPr4r>rFr`rrrrobjectrrrrrrrrrrr rrrrr'r-r2rr(r:r>r@_update_messager)rJrKrUrXr[rrjrnrp_query_messagerrsruryr{_get_more_messagerr~rrr*rrrrrrrrrr r rrrrrrrr)rrOrM _UNPACK_REPLYrgr2r!r3r|sM  5&RR! F   -53.            . . 1 / /  $yI N !-9!U0  O F    6 0f| V| ~mAvmA` V  x !U!6)6==499+"Sv}}W%**  FMM$  $ $ *# # $44\` (# # $44]a (&--.33 V]]4 % % 44/= $,,'4B #D#2 #22 %P &--%** V V  &88M## [ 1E E X%#!2%#P OM` "55   ^ ^ <~# &==$/. //O Q"$# $-$K$K!/0 &==^aEPlAvlA^M,VM,b hoo NNFMM RG9 FsL??M  M