)8SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK Jr SSK Jr SSK Jr SS K Jr SS K Jr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKrSSKr\ R<"S5r"SS\R@5r!"SS\R@5r""SS\R@5r#"SS\R@5r$"SS\R@5r%Sr&Sr'Sr(Sr)S r*S!r+S"r,S#r-S$r.S%r/\R`S3S&j5r1S'r2S(r3S)r4S*r5"S+S,\65r7"S-S.\Rp"\Rr55r:"S/S0\R@5r;S1r[[U] S5 g)Nz(Unable to find a Cloud SDK installation.)superr__init__self __class__s 0lib/googlecloudsdk/command_lib/emulators/util.pyrNoCloudSDKError.__init__3s /4)24__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__ __classcell__rs@rrr0s044rrc,^\rSrSrSrU4SjrSrU=r$)NoEnvYamlError8zUnable to find a env.yaml file.cJ>[[U] SRU55 g)NzgUnable to find env.yaml in the data_dir [{0}]. Please ensure you have started the appropriate emulator.)rr(rformat)rdata_dirrs rrNoEnvYamlError.__init__;s! .$( --3VH-=?rrrr&s@rr(r(8s'??rr(c\rSrSrSrg)MissingProxyErrorArNrr r!r"r$rrrr/r/Arr/c\rSrSrSrg)NoEmulatorErrorErNr1rrrr4r4Er2rr4c,^\rSrSrSrU4SjrSrU=r$)InvalidHostErrorIz$The configured host:port is invalid.c,>[[U] S5 g)NzeEmulator host-port must take the form ADDRESS:PORT where ADDRESS is a hostname, IPv4 or IPv6 address.)rr7rrs rrInvalidHostError.__init__Ls D* 01rrrr&s@rr7r7Is,11rr7cSRX5n[RRU/US9 g![R a [ 5ef=f)zEnsures that the specified component is installed. Args: component_id: str, the name of the component for_text: str, the text explaining what the component is necessary for Raises: NoCloudSDKError: If a Cloud SDK installation is not found. z,You need the [{0}] component to use the {1}.)msgN)r+r UpdateManagerEnsureInstalledAndRestartr InvalidSDKRootErrorr) component_idfor_textr<s rEnsureComponentIsInstalledrBRsZ 8 & (  ::L>?B;D  ( (  s 3Ac[R"5RnU(d [5e[R "SU5 U$)zGets the directory of the root of the Cloud SDK, error if it doesn't exist. Raises: NoCloudSDKError: If there is no SDK root. Returns: str, The path to the root of the Cloud SDK. zFound Cloud SDK root: %s)rPathssdk_rootrrdebug)rEs rGetCloudSDKRootrGes5\\^ $ $(   )) &1 /rc[RRUS5n[R"U5n[ R "U/SUS9 SSS5 g!,(df  g=f)zWrites the given environment values into the output_dir/env.yaml file. Args: env: {str: str}, Dictonary of environment values. output_dir: str, Path of directory to which env.yaml file should be written. env.yamlr ) print_formatoutN)ospathjoinr FileWriterr Print)env output_dir env_file_pathenv_files r WriteEnvYamlrUusH'',,z:6-  &(C5v8D'&&s A A&c[RRUS5n[R"U5n[ R "U5sSSS5 $!,(df  g=f![Ra [U5ef=f)zReads and returns the environment values in output_dir/env.yaml file. Args: output_dir: str, Path of directory containing the env.yaml to be read. Returns: env: {str: str} rIN) rLrMrNr FileReaderr loadMissingFileErrorr()rRrSfs r ReadEnvYamlr[sc'',,z:6-%   - (A YYq\ ) ( (   %  $$%s(A)A A) A&"A)&A)) B c 4[RR5nSnU[RRLaSn[R "U5H?up4SU;aSR US9n[R"SR UUUS95 MA g) zPrint OS specific export commands for the given environment values. Args: env: {str: str}, Dictonary of environment values. exportset z "{value}")valuez{export_command} {var}={value})export_commandvarr`N) rOperatingSystemCurrentWINDOWSsix iteritemsr+rrP)rQ current_osrarbr`s rPrintEnvExportris ((002*.9,,444NMM#&jc e|  u -eII.55% 6'rc[RR5nSnU[RRLaSn[R "U5H&n[ R"URUS95 M( g)zPrint OS specific unset commands for the given environment variables. Args: env: {str: str}, Dictionary of environment values, the value is ignored. z unset {var}z set {var}=)rbN) rrcrdrerfiterkeysrrPr+)rQrhrarbs r PrintEnvUnsetrlsc ((002* .9,,444!N \\# cIIn###,-rc[US5nU(aU$[R"5Rn[R R USU5n[R"U5 U$)zIf present, returns the configured data dir, else returns the default. Args: prefix: pubsub, datastore, bigtable, etc. The prefix for the *_data_dir property of the emulators section. Returns: str, The configured or default data_dir path. r, emulators) _GetEmulatorPropertyrrDglobal_config_dirrLrMrNrMakeDir)prefix configured config_rootdefault_data_dirs r GetDataDirrvsS$FJ7* " 00+WW\\+{FC-- ! rc[R(aSOSnSRU[R"SS5S9n[ US5=(d Un[ U5upE[RU5(a[RO[Rn[R"U[R5n[U5nURXE45S:waU$U$![a [5ef=f) aGIf present, returns the configured host port, else returns the default. Args: prefix: str, The prefix for the *-emulator property group to look up. Raises: InvalidHostError: If configured host-port is not of the form ADDRESS:PORT. Returns: str, Configured or default host_port if present, else an unused local port. z[::1] localhostz {host}:{port}i@i'#)hostport host_portr)sockethas_ipv6r+randomrandintro_ParseHostPort_IPV6_REmatchAF_INET6AF_INET SOCK_STREAMint ValueErrorr7 connect_ex)rr default_hostarbitrary_host_portrsryrzprotocolsocks r GetHostPortrs#OO,(.. fnnT48/:#FK8O>( # * * ,, >># rcSnSRX5n[RHLnURU:XdMUR U5(dM-UR U5R 5s $ g)a!Returns the value of the given property in the given emulator group. Args: prefix: str, The prefix for the *_emulator property group to look up. prop_name: str, The name of the property to look up. Returns: str, The the value of the given property in the specified emulator group. emulatorz{}_{}N)r+r VALUESname HasPropertyPropertyGet)rr prop_nameproperty_group full_namesections rrorosb.nnV/)""g||~%'*=*=i*H*H   i ( , , ..# rc#0# U=(d [Rn[RR 5(dD[ R "S5[ R"5:wa[ R"SS5 [R"UU[RS9nUv UR5c!UR5 UR5 gg!UR5c!UR5 UR5 ff=f7f)a/Starts subprocess with given args and ensures its termination upon exit. This starts a subprocess with the given args. The stdout and stderr of the subprocess are piped. Note that this is a context manager, to ensure that processes (and references to them) are not leaked. Args: args: [str], The arguments to execute. The first argument is the command. log_file: optional file argument to reroute process's output. If given, will be closed when the file is terminated. Yields: process, The process handle of the subprocess that has been started. r)stdoutstderrN) subprocessPIPErrc IsWindowsrLgetsidgetpidsetpgidPopenSTDOUTpoll terminatewait)argslog_filereroute_stdoutprocesss rExecrs .z.  " " , , . . yy|ryy{"jjA   T$2$.$5$5 7' M||~  llnw||~  llnsB%D(C,3D4DDc lURR5nU(a[RR SR U[ R"UR5555 [RR5 URR5nU(aMgg)zPrepends the given prefix to each line of the given process's output. Args: process: process, The handle to the process whose output should be prefixed prefix: str, The prefix to be prepended to the process's output. z [{0}] {1}N) rreadlinerstatusrPr+rDecoderstripflush)rrr output_lines r PrefixOutputr sz'')+JJ[''(0 8J8J8L(MOPJJ..))+K  rc/nUR(a[RURR5(a&SR URR5nOURRnURRb UR SR U55 URR b4UR SR URR 55 U$)z8Converts an argparse.Namespace to a list of arg strings.z[{}]z --host={0}z --port={0})r{rrryr+appendrz)r args_listrys r BuildArgsListr/s) ^^~~dnn))** ]]4>>.. /d ^^ d ~~&|**401 ~~&|**4>>+>+>?@ rc[RR[5SSR U55n[RR U5(d[ SR U55eU$)Nplatformz {0}-emulatorzNo {0} directory found.)rLrMrNrGr+isdirr4)r emulator_dirs rGetEmulatorRootr?sZo/(.*?*?*IK, | $ $ 3::8D EE rc[RR[5SS5n[RR U5(d [ S5eU$)z+Returns path to the emulator reverse proxy.rzemulator-reverse-proxyzremulator-reverse-proxy component must be installed. try running `gcloud components install emulator-reverse-proxy`)rLrMrNrGrr/)rMs rGetEmulatorProxyPathrGsJ o'5M N$ t    = >> +rc<^\rSrSrSrSSjrSrU4SjrSrU=r $)AttrDictiUzAllows for a wrapped map to be indexed via attributes instead of keys. Example: m = {'a':'b', 'c':{'d':'e', 'f':'g'}} a = AttrDict(m) m['c']['d'] == a.c.d cU(aN0n[R"U5H+upEUn[U[5(a [ XR5nXcU'M- X0lOXlX lg)zInitializes attributes dictionary. Args: _dict: dict, the map to convert into an attribute dictionary recurse: bool, if True then any nested maps will also be treated as attribute dictionaries N)rfrg isinstancedictr_dict_recurse)rrrecurse dict_copykeyr`tosets rrAttrDict.__init__^sUi e,*# eT " "5*%# - jjMrc URU$N)r)rattrs r __getattr__AttrDict.__getattr__rs ::d rcl>U[SS/5;a[[U]X5 gX RU'g)Nrr)r^rr __setattr__r)rrr`rs rrAttrDict.__setattr__us0 sGZ()) Hd'4jjr)rr)T) rr r!r"r#rrrr$r%r&s@rrrUs(rrc\rSrSrSr\R S5r\\RS55r \\RS55r \\RS55r \\RS55r SrS rg ) Emulatori|z5This organizes the information to expose an emulator.c[5e)zStarts the emulator process on the given port. Args: port: int, port number for emulator to bind to Returns: subprocess.Popen, the emulator process NotImplementedError)rrzs rStartEmulator.Start   rc[5e)zcReturns the grpc route prefixes to route to this service. Returns: list(str), list of prefixes. rrs rprefixesEmulator.prefixes   rc[5e)zReturns the service name this emulator corresponds to. Note that it is assume that the production API this service is emulating exists at .googleapis.com Returns: str, the service name rrs r service_nameEmulator.service_names   rc[5e)zvReturns title of the emulator. This is just for nice rendering in the cloud sdk. Returns: str, the emulator title rrs remulator_titleEmulator.emulator_titlerrc[5e)zRReturns cloud sdk component to install. Returns: str, cloud sdk component name rrs remulator_componentEmulator.emulator_componentrrc[R"5up[RR SR UR U55 U$)aReturns the OS-level handle to log file. This handle is the same as would be returned by os.open(). This is what the subprocess interface expects. Note that the caller needs to make sure to close this to avoid leaking file descriptors. Returns: int, OS-level handle to log file zLogging {0} to: {1})tempfilemkstemprrrPr+r)r log_file_nors r _GetLogNoEmulator._GetLogNosA%,,.KJJ*11$2C2CXNO rrN)rr r!r"r#abcabstractmethodrpropertyabstractpropertyrrrrrr$rrrrr|s=                       rrc\rSrSrSrSrg)EmulatorArgumentsErroriz$Generic error for invalid arguments.rN)rr r!r"r#r$rrrrrs,rriòc[R"[5(a[$[SR [55e)z~Returns default port if available. Raises: EmulatorArgumentsError: if port is not available. Returns: int, default port z,Default emulator port [{}] is already in use) portpicker is_port_free _DEFAULT_PORTrr+rrrDefaultPortIfAvailablers8]++  6==mL NNrr)>r# __future__rrrr contextlibrLr~rer|rrgooglecloudsdk.corerrrr r googlecloudsdk.core.resourcer googlecloudsdk.core.updaterr r googlecloudsdk.core.utilrrrrrfcompilerErrorrr(r/r4r7rBrGrUr[rirlrvrrrocontextmanagerrrrrrobjectrwith_metaclassABCMetarrrrrrrr si>&'  &*#*$936-*.  ::' (4j&&4?Z%%? ((j&&1z''1&  E%"& .&B$ > ,   $v$NMs!!#++.M`Z--   Nr