)"SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKr SSK r SSK r SSK r SSK r SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKr"SS\5rSr"SS\5r Sr!Sr"Sr#\RHS"Sj5r%"SS\5r&Sr'Sr(Sr)Sr*\RV"SS94Sjr,S r-S!r.g)#z1Functions for reading the skaffold events stream.)absolute_import)division)print_function)unicode_literalsN) json_stream)config)log) properties) console_attr)update_manager)filesc\rSrSrSrSrg)StopThreadError'z-The thread has been stopped by a ThreadEvent.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r/lib/googlecloudsdk/command_lib/code/skaffold.pyrr's5rrc[5e)zRaise a KeyboardInterrupt.)KeyboardInterrupt) unused_signum unused_stacks r_KeyboardInterruptHandlerr-s rc*\rSrSrSrSrSrSrSrg)_SigInterruptedHandler2z;Context manager to capture SIGINT and send it to a handler.cSUlXlgN) _orig_handler_handler)selfhandlers r__init___SigInterruptedHandler.__init__5sDMrc[R"[R5Ul[R"[RUR5 gr#)signal getsignalSIGINTr$r%r&s r __enter__ _SigInterruptedHandler.__enter__9s/))&--8D MM&--/rcb[R"[RUR5 gr#)r+r-r$)r&exc_type exc_valuetbs r__exit___SigInterruptedHandler.__exit__=s MM&--!3!34r)r%r$N rrrrrr(r/r5rrrrr r 2sC05rr c[R"5R(ac[RR S/5(a>[ RR[R"5RSS5$g)Nskaffoldbin) rPathssdk_rootr UpdateManagerEnsureInstalledAndRestartospathjoinrrr_FindOrInstallSkaffoldComponentrBAsP lln""<Skaffold..~s06$4[T..&u(=>$4s;=PATH)envN)rKr rr?environcopyupdateitemsrr;r<rNrVpathseprPPopenr terminatewaitsysstdoutflushstderr) skaffold_config context_name namespaceenv_varsdebug events_portcmdr]ps rSkaffoldrrXs^( %8HI# , . //C y ( ))C I;C ; . //C78 **// C jj6$,NN$466 ||~NN3v;#;#)<<>#:#:$; 9 9 9    s; C0%CC0BCC0 C-)C0-C00 C=<C=cz[RRRR [ U55$)z4Open a connection to the skaffold events api output.)rNmovesurllibrequesturlopen _GetEventsUrlros rOpenEventsStreamrs(    ! ! ) )- *D EErc#h# [U5Hn[X!5(dMUSSv M! g7f)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)rrevents rrrs1x(ee22 + { ++)s22c## [R"U5H&n[U[5(dMUSSnUv M( g7f)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 6sAAr)secondsc6UR5(d [U5$[5e![RRR R a" URUR55 Of=fUR5(dMNy)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. ) rrrNrrerrorURLErrorre total_secondsr)ro stop_eventretry_intervals rrrs{$     6 k **  99   ! ! * *6oon22456     s ,AB?BcHSR[R"U5S9$)Nz(http://localhost:{events_port}/v1/eventsr)rrN text_typers rrr s& 3 : :-- , ; ..rcJURS05RS5U:H$)Nr resourceName)get)rrs rrrs# ; # ' ' 7< GGr)NNNFN)/r __future__rrrrrdatetimeos.pathr?r+rPrfrygooglecloudsdk.command_lib.codergooglecloudsdk.corerr r googlecloudsdk.core.consoler googlecloudsdk.core.updaterr googlecloudsdk.core.utilr rHrN BaseExceptionrrobjectr rBrKrRcontextmanagerrrrtr}rrr timedeltarrrrrrrs8&%'  7&#*468 6m6  5V 5P   33lF4 BF ,$ $*2););A)F4. Hr