diff options
| author | Sankar Tanguturi <stanguturi@stanguturi-rhel> | 2016-03-11 11:29:15 -0800 | 
|---|---|---|
| committer | Sankar Tanguturi <stanguturi@stanguturi-rhel> | 2016-03-11 11:29:15 -0800 | 
| commit | a3fd7441f8ea4d25e96b9bc0eca7cbb6164a4691 (patch) | |
| tree | 74a6ebbe7c91c30467577eb231fab8c5f188b93c /cloudinit/sources/DataSourceBigstep.py | |
| parent | a6e0922a4d34ede6df000dd8fc4bb3531218d69f (diff) | |
| parent | 41470d29f5888baf7ec78e170cc0d6d981dcf63e (diff) | |
| download | vyos-cloud-init-a3fd7441f8ea4d25e96b9bc0eca7cbb6164a4691.tar.gz vyos-cloud-init-a3fd7441f8ea4d25e96b9bc0eca7cbb6164a4691.zip | |
- Executed 'bzr merge' and resolved all the conflicts.
- Now my branch is identical to trunk.dist
Diffstat (limited to 'cloudinit/sources/DataSourceBigstep.py')
| -rw-r--r-- | cloudinit/sources/DataSourceBigstep.py | 57 | 
1 files changed, 57 insertions, 0 deletions
| diff --git a/cloudinit/sources/DataSourceBigstep.py b/cloudinit/sources/DataSourceBigstep.py new file mode 100644 index 00000000..b5ee4129 --- /dev/null +++ b/cloudinit/sources/DataSourceBigstep.py @@ -0,0 +1,57 @@ +# +#    Copyright (C) 2015-2016 Bigstep Cloud Ltd. +# +#    Author: Alexandru Sirbu <alexandru.sirbu@bigstep.com> +# + +import json +import errno + +from cloudinit import log as logging +from cloudinit import sources +from cloudinit import util +from cloudinit import url_helper + +LOG = logging.getLogger(__name__) + + +class DataSourceBigstep(sources.DataSource): +    def __init__(self, sys_cfg, distro, paths): +        sources.DataSource.__init__(self, sys_cfg, distro, paths) +        self.metadata = {} +        self.vendordata_raw = "" +        self.userdata_raw = "" + +    def get_data(self, apply_filter=False): +        url = get_url_from_file() +        if url is None: +            return False +        response = url_helper.readurl(url) +        decoded = json.loads(response.contents) +        self.metadata = decoded["metadata"] +        self.vendordata_raw = decoded["vendordata_raw"] +        self.userdata_raw = decoded["userdata_raw"] +        return True + + +def get_url_from_file(): +    try: +        content = util.load_file("/var/lib/cloud/data/seed/bigstep/url") +    except IOError as e: +        # If the file doesn't exist, then the server probably isn't a Bigstep +        # instance; otherwise, another problem exists which needs investigation +        if e.errno == errno.ENOENT: +            return None +        else: +            raise +    return content + +# Used to match classes to dependencies +datasources = [ +    (DataSourceBigstep, (sources.DEP_FILESYSTEM, sources.DEP_NETWORK)), +] + + +# Return a list of data sources that match this set of dependencies +def get_datasource_list(depends): +    return sources.list_from_depends(depends, datasources) | 
