:vjw>&ddlmZmZmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlZ ddlZ ddlZ ddlZddlZddlmZddlmZmZmZdZdZdZdgfd Zd Zeej<j?ej<jAe!d d d Z"dZ#dZ$dZ%dZ&dZ'gdZ(e%fdZ)Gdde jTjVZ+dZ,Gdde jZj\Z/Gdde0Z1dZ2e3dk(re2yy))absolute_importdivisionprint_functionN) ZMQStream) SceneTreewalk find_nodectj||}|stdj|||j dS)Nz&Could not match {:s} with pattern {:s}r)rematch ValueErrorformatgroups)patternsr s j/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/meshcat/servers/zmqserver.pycapturers? HHWa E AHHGTUU||~a  ctd|S)Nz^zmq_url=(.*)$rlines r match_zmq_urlr $d ++rctd|S)Nz^web_url=(.*)$rrs r match_web_urlr"rrc@tjdddg}|"|jd|j||r|j|ttj }tj jtj jtj jt|d<tj|tjtj|d}d}d |vr|jjjjd }|j!l|j#\}}t%|jd t%|jd t'd t)|j!zd |vrt+|}t-|jjjjd }d } t/j0| ||||fS) z} Starts the ZMQ server as a subprocess, passing *args through popen. Optional Keyword Arguments: zmq_url z-uz-mzmeshcat.servers.zmqserver --zmq-url PYTHONPATHT)stdoutstderrenvstart_new_sessionzmq_urlutf-8z=the meshcat server process exited prematurely with exit code cD|j|jyN)killwait) server_procs rcleanupz/start_zmq_server_as_subprocess..cleanupJsr)sys executableappenddictosenvironpathdirname__file__ subprocessPopenPIPEr!readlinestripdecodepoll communicateprint RuntimeErrorstrrratexitregister) r& server_argsargsr#r,routserrsweb_urlr-s rstart_zmq_server_as_subprocessrI%s NND$(C DD K  G [! rzz C8Q(RSC ""4   K D 4 !!**,224;;GD     )$002JD$ $++g& ' $++g& '^adepeueuewaxxy y 4 D!GK..779??AHHQRG OOG[)  ((rc ttjjdd}|dkr)tj j jyy#t$rYywxYw)N.r)intzmq __version__splitr eventloopioloopinstall) pyzmq_majors r_zmq_install_iolooprURs^#////4Q78 R $$& s+A A('A(z..viewerdistz index.htmliXitcpip) set_transform set_objectdelete set_property set_animationc jt|D]}||z} ||fi||fcStdj |||z#ttjjf$r-t dj |tjYt$r}t t|d}~wwxYw)Nz$Port: {:d} in use, trying another...filez;Could not find an available port in the range: [{:d}, {:d})) rangeOSErrorrNerrorZMQErrorr?rr.r" Exceptiontype)func default_port max_attemptskwargsiportes rfind_available_portrnks < a ''- -!U\\]ikw{GlGHI J ++, X 8??ECJJ W  $q'N  s AA B2B2B--B2c0eZdZfdZdZdZdZxZS)WebSocketHandlercX|jd|_tt||i|y)Nbridge)poprrsuperrp__init__)selfrErj __class__s rruzWebSocketHandler.__init__zs(jj*  .??rc|jjj|td|tj |jj |y)Nzopened:r_)rrwebsocket_pooladdr?r.r" send_scenervs ropenzWebSocketHandler.open~s< ""&&t, iCJJ/ t$rc tj|}|jj|dy#t$r}t |d}~wwxYw)Ndata)jsonloadsrr send_imagerer?)rvmessageerrs r on_messagezWebSocketHandler.on_messagesH jj)G KK " "76? 3   #J  s36 A A  Ac|jjj|td|tj y)Nzclosed:r_)rrryremover?r.r"r|s ron_closezWebSocketHandler.on_closes* ""))$/ iCJJ/r)__name__ __module__ __qualname__rur}rr __classcell__)rws@rrprpys@% 0rrpchdjtj|jdS)zIEncode the drawing command into a Javascript fetch() command for display.z fetch("data:application/octet-binary;base64,{}") .then(res => res.arrayBuffer()) .then(buffer => viewer.handle_command_bytearray(new Uint8Array(buffer))); r')rbase64 b64encoder<)rs rcreate_commandrs.  v%,,W56 7rceZdZdZdZy)StaticFileHandlerNoCachezjEnsures static files do not get cached. Taken from: https://stackoverflow.com/a/18879658/7829525 c(|jddy)Nz Cache-Controlz.no-store, no-cache, must-revalidate, max-age=0) set_header)rvr4s rset_extra_headersz*StaticFileHandlerNoCache.set_extra_headerss )YZrN)rrr__doc__rrrrrs [rrcjeZdZejZ d dZdZdZdZ dZ dZ dZ d Z d Zy) ZMQWebSocketBridgeNc|_t_j_t j jj_|,fd}t|t\\_ _ _ }n$j|\_ _ _ d} i} ||$| td| td||d| d<d} |.tjj t"fi| \}_n$jj |fi| |_dj'| jj$ _|r| dk(r td  d dld dlj.j1d } j2j5j$d| _t7j(t8sj(j:_xj(dz c_t=dfd} t?j@| tI_%y#tB$r-} d| jDjFvr tdYd} ~ Ad} ~ wwxYw)Ncdjdjtj|S)Nz{:s}://{:s}:{:d}) setup_zmqrDEFAULT_ZMQ_METHODhost)rlrvs rfz&ZMQWebSocketBridge.__init__..fs+~~&8&?&?@RTXT]T]_c&deerzhttp:z2You must supply a certfile if you supply a keyfilez2You must supply a keyfile if you supply a certfile)certfilekeyfile ssl_optionszhttps:z!{protocol}//{host}:{port}/static/)protocolrrlz0The free version of ngrok does not support httpsrT)r$http)pyngrok_configz/static/ c:jjyr))ngrokr*)pyngroksrr-z,ZMQWebSocketBridge.__init__..cleanupsMM&&(rrz:You must install pyngrok (e.g. via `pip install pyngrok`).)&rsetrymake_appapptornadorRIOLoopcurrentrnDEFAULT_ZMQ_PORT zmq_socket zmq_streamr&rrelistenDEFAULT_FILESERVER_PORTfileserver_portrrH pyngrok.conf pyngrok.ngrokconf PyngrokConfigrconnect isinstancerA public_urlr?rBrC ImportErrorrwrrtree)rvr&rrlrrngrok_http_tunnelr_r listen_kwargsconfigr-rmrs` @rruzZMQWebSocketBridge.__init__s1 !e==?nn++335 ? fBUVWYiBj ? z/ZMQWebSocketBridge.handle_zmq.. sDOOF4Krserror: expected 3 framesct|dkDS)Nr)r)xs rrz/ZMQWebSocketBridge.handle_zmq..s Q!rrrrZrYr\r]r[r get_scener%z main.min.jsra MeshCat
) mainminjscommandsserror: unrecognized comand)!r<rrrHencoderR add_callbackrrryforward_to_websocketsrMESHCAT_COMMANDSlistfilterrPr robject transform propertiesr0 animationrr rr2r4joinrr} readlinesr)rvrcmdr4r cache_hitparentchilddrawing_commandsnodepmainminjs_path mainminjs_srcrhtmls`` rrzZMQWebSocketBridge.handle_zmqsoQiw' %< OO !4!4W!= > F] KK $ $T%=%= > O #4&&'!+**62 &&s,KL $ $6{a$$%@A3VAY5E5Eg5N5T5TUX5YZ[D!9D ,C"499d3::C"499d3::dB **62o%7; $))T*4 $48 $))T*18: $))T*5&$))T*55<>-$t~~(FF$>>-$t~~(FF$( WW\\+}ENMnc*a ! +GGM2M29IJ3 4 OO W!5 6 OO !> ?A+*s PPcX|\}}}|jD]}|j|dyNT)binary)ry write_message)rvrrr4r websockets rrz(ZMQWebSocketBridge.forward_to_websockets]s0 T4,,I  # #D # 6-rc|jjtj}|j |t |}|j |j|||fSr))contextsocketrNREPbindron_recvr)rvrrrs rrzZMQWebSocketBridge.setup_zmqbsO\\((1 z* 4??+:s**rcxt|jD]}|j|j|jd|jD]}|j|d|j |j|j d|j |j|j dyr)r rrrrrr)rvrrrs rr{zZMQWebSocketBridge.send_sceneisOD{{&'' D'A__''$'7%~~)''t'D~~)''t'D$rc8|jjyr))rRstartr|s rrunzZMQWebSocketBridge.runts r)Nz 127.0.0.1NNNF)rrrrNContextrrurrrrrrr{r rrrrrsIckkmG<@@EE N B ( [@z7 + Errcfddl}ddl}ddl}ddl}ddl}|j dk\r2|j dk(r|j|j|jd}|jddtdd |jd d d |jdtd|jdtd|jdd d|j}t|j|j|j |j"}t%dj'|jt%dj'|j(|j*r|j+|j(d |j-y#t.$rYywxYw)Nr)rWindowsz;Serve the MeshCat HTML files and listen for ZeroMQ commands) descriptionrz-z?)rfnargsdefaultz--openz-o store_true)actionz --certfile)rfrz --keyfilez--ngrok_http_tunnelz ngrok is a service for creating a public URL from your local machine, which is very useful if you would like to make your meshcat server public.)rhelp)r&rrrz zmq_url={:s}z web_url={:s}r)new)argparser. webbrowserplatformasyncio version_infosystemset_event_loop_policyWindowsSelectorEventLoopPolicyArgumentParser add_argumentrA parse_argsrr&rrrr?rrHr}r KeyboardInterrupt)rr.rrrparserresultsrrs rmainr%xsu 6!hoo&79&D%%g&L&L&NO  $ $1n $ oF  T3M $|<  3=  #t< -lJHI!G )0)9)9(/292K2KMF .   /0 .   /0||A.     sF$$ F0/F0__main__)4 __future__rrrrBrr2r r.r7multiprocessingr tornado.webrtornado.iolooptornado.websocket tornado.genrNzmq.eventloop.ioloopzmq.eventloop.zmqstreamrrrr r rrrrIrUr4rr5r6rrr MAX_ATTEMPTSrrrrnrrprrStaticFileHandlerrrrr%rrrrr1s@@   -,,!,,,0R*)Z 'ggll277??84dHfM   ]:F J0w((99007[w{{<<[QQh! F zFr