)"dZddlmZddlmZddlmZddlmZddlZddlZddlZ ddl Z ddl Z ddl Z ddl Z ddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlZGddeZdZGddeZ dZ!dZ"dZ#ejH d"dZ%GddeZ&dZ'dZ(dZ)dZ*ejVdfdZ,d Z-d!Z.y)#z1Functions for reading the skaffold events stream.)absolute_import)division)print_function)unicode_literalsN) json_stream)config)log) properties) console_attr)update_manager)filesceZdZdZy)StopThreadErrorz-The thread has been stopped by a ThreadEvent.N)__name__ __module__ __qualname____doc__/lib/googlecloudsdk/command_lib/code/skaffold.pyrr's5rrct)zRaise a KeyboardInterrupt.)KeyboardInterrupt) unused_signum unused_stacks r_KeyboardInterruptHandlerr-s rc"eZdZdZdZdZdZy)_SigInterruptedHandlerz;Context manager to capture SIGINT and send it to a handler.c d|_||_yN) _orig_handler_handler)selfhandlers r__init__z_SigInterruptedHandler.__init__5sDDMrctjtj|_tjtj|jyr)signal getsignalSIGINTr r!r"s r __enter__z _SigInterruptedHandler.__enter__9s/))&--8D MM&--/rc`tjtj|jyr)r&r(r )r"exc_type exc_valuetbs r__exit__z_SigInterruptedHandler.__exit__=s MM&--!3!34rNrrrrr$r*r/rrrrr2sC05rrctjjr]tjj dgr=t jjtjjddSy)Nskaffoldbin) rPathssdk_rootr UpdateManagerEnsureInstalledAndRestartospathjoinrrr_FindOrInstallSkaffoldComponentr;AsM lln""<zSkaffold..~s36$4[T5..&u(=>$4s79PATH)envN)rDrrr8environcopyupdateitemsrr4r5rGrOpathseprIPopenr terminatewaitsysstdoutflushstderr) skaffold_config context_name namespaceenv_varsdebug events_portcmdrUps rSkaffoldrjXsa( %8HI# , . //C y ( ))C I;C ; . //C78 **// C jj6$,NN$466 ||~NN3v;#;#)<<>#:#:$; 9 9 9    s;C-!C!C- B C!C-!C*&C-*C-- C98C9cztjjjj t |S)z4Open a connection to the skaffold events api output.)rGmovesurllibrequesturlopen _GetEventsUrlrgs rOpenEventsStreamrs(    ! ! ) )- *D EErc#ZKt|D]}t||s|ddyw)zGet the local port for a service. This function yields the new local port every time a new port forwarding connection is created. Args: response: urlopen response. service_name: Name of the service. Yields: Local port number. portEvent localPortN)ReadEventStream_IsPortEventForService)rrvevents rrrs1x(ee\2 + { ++)s+ +c#zKtj|D]}t|ts|dd}|!yw)zRead the events from the skaffold event stream. Args: response: urlopen response. Yields: Events from the JSON payloads. resultrN)rReadJsonStream isinstancedict)rpayloadrs rrrs>++H5g gt $ H g &E K 6s9;r)secondsc|js t|St#tjjj j $r"|j|jYnwxYw|js}r)aOpen a connection to the skaffold events api output. This function retries opening the connection until opening is succesful or stop_event is set. Args: events_port: Port of the events api. stop_event: A threading.Event object. retry_interval: Interval for which to sleep between tries. Returns: urlopen response. Raises: StopThreadError: The stop_event was set before a connection was established. ) rrrGrrerrorURLErrorr] total_secondsr)rg stop_eventretry_intervals rrrsv$    6 k **  99   ! ! * *6oon22456    s 'AA:9A:cLdjtj|S)Nz(http://localhost:{events_port}/v1/eventsr)rrG text_typers rrr s& 3 : :-- , ; ..rcJ|jdijd|k(S)Nr resourceName)get)rrvs rrrs# ; # ' ' 7< GGr)NNNFN)/r __future__rrrrrdatetimeos.pathr8r&rIr^rpgooglecloudsdk.command_lib.codergooglecloudsdk.corerr r googlecloudsdk.core.consoler googlecloudsdk.core.updaterr googlecloudsdk.core.utilr rArG BaseExceptionrrobjectrr;rDrKcontextmanagerrjrlrtrrr timedeltarrrrrrrs8&%'  7&#*468 6m6  5V 5P   33lF4 BF ,$ $*<););A)F4. Hr