o @Bi~=@sddlmZddlZddlZddlZddlmZddlmZddlmZddZ dd Z d d Z d d Z e ej dGdddejZGdddejZdS))absolute_importN)message)role) serializercCs|r |jdr tjr dSdS)NjsonTF) SERIALIZER_ID startswithsixPY2)sercontains_binaryr b/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/wamp/test/test_serializer.py must_skip(src Csgtddtittdtjdgdddddtjddgd tjdd d tdtjdtjjd tdd tjdd gdddddtjdd ddt dtj dgdddddtj dd d t dtj dtj jd t ddtj ddgdddddtj ddddt dt dd tdd tddtjddddtjddddtdd tjdd gdddddtjdd ddtdd tddtjddgdddddtjddddggddtdtdd tdd tddtjddtjjdttj jddtjtj jddgdddddtj ddgdd tj dgddddd}d d!|DS)"z List of WAMP test message used for serializers. Expand this if you add more options or messages. This list of WAMP message does not contain any binary app payloads! realm1 subscriber@hellofoobarargskwargsrT)progress)mode i')timeoutzcom.myapp.procedure1prefix)match roundrobin)invoke,) publisherzcom.myapp.topic1F)dr() exclude_meexcludeeligiblezcom.myapp.error1ucom.myapp.你好世界z Hello Worlduこんにちは世界)enjpcSg|]}d|fqS)Fr .0msgr r r az*generate_test_messages..)rHellorRoleSubscriberFeaturesGoodbyeYield InterruptKILL InvocationResultCancelCall Unregistered Unregister RegisteredRegisterEvent PublishedPublish Unsubscribed Unsubscribe Subscribed Subscribe MATCH_PREFIXError MESSAGE_TYPE)msgsr r rgenerate_test_messages/s               ! " # $%& '()+rPc Csg}dddtdtdtdtdtdtd f D]}|tjd d |gd |tjd d |gd |idqdd|DS)a! Generate WAMP test messages which contain binary app payloads. With the JSON serializer, this currently only works on Python 3 (both CPython3 and PyPy3), because even on Python 3, we need to patch the stdlib JSON, and on Python 2, the patching would be even hackier. iirr"rrrcSr1)Tr r2r r rr5xr6z1generate_test_messages_binary..)osurandomappendrrE)rObinaryr r rgenerate_test_messages_binaryds r\cCsg}|t|tjdd|t|tjdd|t|tjdd|t|tjddtjrF |S)NT)batched)rZrJsonSerializerMsgPackSerializerCBORSerializerUBJSONSerializerr PY3) _serializersr r rcreate_serializers{srdz1WAMP-FlatBuffers currently only supports Python 3c@seZdZddZdS)TestFlatBuffersSerializercCs~tjddgddddddd tjdd gdddddd g}t}|D]}||\}}|||d }|||q%dS) Nrr"rrrriT)rrr)retainedzcom.example.topic1)rrretainr)rrErGrFlatBuffersSerializer serialize unserialize assertEqual)selfmessagesr r4payloadr[msg2r r r test_basics(z$TestFlatBuffersSerializer.test_basicN)__name__ __module__ __qualname__rpr r r rres rec@s\eZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ dS)TestSerializercCstt|_t|_dS)N)rPr\_test_messagesrd_test_serializersrlr r rsetUps zTestSerializer.setUpcCs^td}ddd|gddgdid|g}dddgdi|gddd |g}|||d S) zK Test deep object equality assert (because I am paranoid). rrr) rrmoor)rrbazgoo)r}rr|rN)rXrYrk)rlvo1o2r r rtest_deep_equal_msgs ""z"TestSerializer.test_deep_equal_msgcCsR|jD]#}|jD]\}}t||s%||\}}|||}||g|qqdS)z; Test round-tripping over each serializer. Nrvrurrirjrk)rlr r r4rnr[ror r rtest_roundtrip_msgs   z!TestSerializer.test_roundtrip_msgc Cs|jD]?}|jD]9\}}t||sA||\}}|||}|d}|jD]}t||s@||\}}|||}||g|q%qqdS)zV Test cross-tripping over 2 serializers (as is done by WAMP routers). rNr) rlser1r r4rnr[msg1ser2ror r rtest_crosstrip_msgs      z!TestSerializer.test_crosstrip_msgcCs|jD]F\}}||ji|jD]7}t||sH||j|jv||\}}||j|jv||j|j|| ||j|jvqqdS)z5 Test message serialization caching. N) rurk _serializedrvr assertFalse _serializerri assertTrueuncache)rlr r4r rnr[r r rtest_cache_msgs  zTestSerializer.test_cache_msgcCs|jD]D}|jdd}||ddd||ddd||ddd||ddd||ddd||dddqd S) zA Test initial serializer stats are indeed empty. Tdetails serializedbytesrrmrated_messages unserializedN)rvstatsrk)rlr rr r rtest_initial_statss  z!TestSerializer.test_initial_statscCs|jD]=}|jD]\}}t||s||\}}|||q|jdd}||ddk||ddk||ddkqdS)_ Test serializer stats are non-empty after serializing/unserializing messages. FrrrrmrN)rvrurrirjrrrlr r r4rnr[rr r rtest_serialize_stats$s    z#TestSerializer.test_serialize_statscCs(|jD]}|jD]\}}t||s||\}}|||q|jdd}||dddk||dddk||dddk||dddk||dddk||dddk||dd|dd||dd|dd||dd|ddqd S) zp Test serializer stats - with details - are non-empty after serializing/unserializing messages. TrrrrrmrrN)rvrurrirjrrrkrr r r!test_serialize_stats_with_details9s"    z0TestSerializer.test_serialize_stats_with_detailscCs|jD]b}|jD]\}}t||s||\}}|||q||jdd}||ddd||ddd||ddd||ddd||ddd||dddqd S) z] Test serializer stats are reset after fetching stats - depending on option. TrrrrrmrrN)rvrurrirjrrkrr r rtest_reset_statsYs    zTestSerializer.test_reset_statscs^jD])}fdd}|dd|jD]\}}t||s+||\}}|||qqdS)rcs:|ddk|ddk|ddkdS)Nrrrmr)r)rrwr ron_statsysz0TestSerializer.test_auto_stats..on_statsryrN)rvset_stats_autoresetrurrirj)rlr rr r4rnr[r rwrtest_auto_statsss    zTestSerializer.test_auto_statsN) rqrrrsrxrrrrrrrrrr r r rrts  rt) __future__rrXunittestr autobahn.wamprrrrrPr\rdskipIfrbTestCaserertr r r rs    5&