}fE bdZddlZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z mZmZmZmZmZddlZddlmZddlmZddlmZdd lmZmZmZmZmZdd l m!Z!ejDe#Z$d Z%d Z&d Z'dddddddZ(de)fdZ* d2deee)de e)e ffdZ+GddeZ,GddeZ-GddeZ.de)de/fdZ0GddejbZ2de3fd Z4 d3d!ejjd"e)d#e3fd$Z6 d3d!ejjd"e)d#e3dejnfd%Z8Gd&d'eZ9Gd(d)Z:e&e9jvfd*e)d+e9de/fd,Zd-Z?e#d.k(rSddl@Z@d/ZAe@jeA0ZCeCjeEejevJ    .. vm>vJ  sA B  'BB c&eZdZUdZej Zeee fe d<ej Z e eee fe d<ejjdzZee dfe d<dZded d ffd Zed efd Zd efd Zd e fdZd e fdZed efdZxZS) DataSourceLXDLXD_network_config_crawled_metadata)user.meta-datarrrr.sensitive_metadata_keysTci_pkl_versionrNc2t||d|_y)NT)rJ _unpickleskip_hotplug_detect)rOrrPs r4rzDataSourceLXD._unpickles .)#' rDctS)z@Check platform environment to report if this datasource may run.)is_platform_viablernrDr4 ds_detectzDataSourceLXD.ds_detects "##rDctjtjdt|_t d|j jd|_|j jdi}|jdi}|r t d|}d|j vr|j d|_ d|j vrt d|j d|_ d|j vr|j d|_ y ) z=Crawl LXD socket API instance data and return True on successzCrawl of metadata service)logfuncmsgfunc meta-datar@rrrrT) rlog_timer+rA read_metadatarr|getmetadata userdata_rawrvendordata_raw)rOr@ user_metadatas r4 _get_datazDataSourceLXD._get_datas!%II+"  3 //33K@  ''++Hb9 #3R8 6 -M $00 0 $ 6 6{ CD  t55 5#= $"8"89I"J$D  D22 2"&"8"8"GD rDc8djttS)z.Return subplatform details for this datasourcez"LXD socket API v. {ver} ({socket}))verrS)rxLXD_SOCKET_API_VERSIONrerWs r4_get_subplatformzDataSourceLXD._get_subplatforms3::&;  rDcttj}|jdi}t |t st j|}|jd|jjdk(S)z%Return True if instance_id unchanged. metadata_keysrz instance-id) r MetaDataKeys META_DATArrsrtrrur)rOsys_cfgresponsemds r4check_instance_idzDataSourceLXD.check_instance_ids] |/E/EF \\+r *"d##Bvvm$ (9(9-(HHHrDc|jtjk(r|jtjk(r|j t |jt r|jjdr*tjd|jd|_nb|jjdrG|jdjDcgc]\}}|ddk(r|}}}t||_|jtjk(r$tjdt|_tt |jScc}}w)zNetwork config read from LXD socket config/user.network-config. If none is present, then we generate fallback configuration. rz,LXD datasource using provided network configdevicesr;nicz8LXD datasource generating network config using fallback.) rrUNSETrrrsrtrr+rAitemsrCr )rOkvrs r4network_configzDataSourceLXD.network_configs)   7== 0%%6 $00$7))--.>?IILM+/+A+A(,D(++// : %)$:$:9$E$K$K$M* AqV9-*G* ,C7+KD(   7== 0 IIJ $;#>?? rDsessionrfdo_raisec rt|||}|js=tjd||j|j j diS |jS#t$rE}tjdj||j j d|d}~wwxYw)NSkipping %s on [HTTP:%d]:%sutf-8zFUnable to process LXD config at {url}. Expected JSON but found: {resp})rfresp) _do_requestokr+rA status_codecontentdecodejsonrrrwrx)rrfr url_responser{s r4_get_json_responserswX6L ?? )   $ $  ' ' 0     "" .. //5vl2299'B060   sA(( B61AB11B6c tdddD][}|j|}d|jk(r8tjdt j d|j||[nt jdj||rV|jsJtjdj|j||jjd  |S) Nrig?z,[GET] [HTTP:%d] %s, retrying %d more time(s)z[GET] [HTTP:%d] %sz3Invalid HTTP response [{code}] from {route}: {resp}r)coderouter)rangerrtimesleepr+r,rArrrwrxrr)rrfrretriesrs r4rr0sQ# ;;s# (&& & JJsO KK>$$    II"H$8$8#> .. A H H))%%,,W5 I    OrDcTeZdZeZeZeZeZeezezZy)rN) rXrYrZrNONECONFIGDEVICESrALLrnrDr4rrMs- 6D VFfGI 7 Y &CrDrcPeZdZefdefdZdejdefdZ de defdZ y) _MetaDataReader api_versioncd||_tjt|j|_yrR)rr combine_urlLXD_URL _version_url)rOrs r4rKz_MetaDataReader.__init__Vs%&&227D-> J,WcEJ$+ByM%   s DD&&D/N) rXrYrZrrrKrrrtrrrrnrDr4rrUs@*@NCN4x'7'74D4l$rDrrrc(t||S)a8Fetch metadata from the /dev/lxd/socket routes. Perform a number of HTTP GETs on known routes on the devlxd socket API. Minimally all containers must respond to /meta-data when the LXD configuration setting `security.devlxd` is true. When `security.devlxd` is false, no /dev/lxd/socket file exists. This datasource will return False from `is_platform_viable` in that case. Perform a GET of /config` and walk all `user.*` configuration keys, storing all keys and values under a dict key LXD_SOCKET_API_VERSION: config {...}. In the presence of the following optional user config keys, create top level aliases: - user.user-data -> user-data - user.vendor-data -> vendor-data - user.network-config -> network-config :param api_version: LXD API version to operated with. :param metadata_keys: Instance of `MetaDataKeys` indicating what keys to fetch. :return: A dict with the following optional keys: meta-data, user-data, vendor-data, network-config, network_mode, devices. Below is a dict representation of all raw configuration keys and values provided to the container surfaced by the socket under the /1.0/config/ route. )rr)r)rrs r4rrsF 4?{ 3# rDc6tj|tSrR)rlist_from_depends datasources)dependss r4get_datasource_listrs  $ $Wk ::rD__main__z*Query LXD metadata and emit a JSON object.) descriptionrrR)T)G__doc__loggingrrSrrenumrr json.decoderrtypingrrrr r r r rrequests.adaptersr urllib3.connectionrurllib3.connectionpoolr cloudinitrrrrr cloudinit.netr getLoggerrXr+rerrrrr5rCrFr^rcrtr|rr~rrrrResponserrrrrDEP_FILESYSTEMrrargparserArgumentParserparser parse_argsprint json_dumpsrnrDr4rs, (@@@).5DD+g!! (!1+!+% c6!%# 49 # #s(^#L,>,6-6 9{ 9cd:c0G&&c0LD;?   $'370;?   $'37 :'4'NNd."."2"2%%% %TW++-. ; zBK $X $ $ =F     \=M=M!NO rD