summaryrefslogtreecommitdiff
path: root/cloudinit/sources/DataSourceBigstep.py
diff options
context:
space:
mode:
authorroot <root@instance-16199.bigstep.io>2016-03-02 08:51:16 +0000
committerroot <root@instance-16199.bigstep.io>2016-03-02 08:51:16 +0000
commitab6f166da7290928d56ff3c62a5280536e1d241f (patch)
tree74305a9c08e6d8d5a3a40df84da0b9ac21fcce63 /cloudinit/sources/DataSourceBigstep.py
parent97efb9d48197d7098f1abe2ee519418afbe6aec5 (diff)
downloadvyos-cloud-init-ab6f166da7290928d56ff3c62a5280536e1d241f.tar.gz
vyos-cloud-init-ab6f166da7290928d56ff3c62a5280536e1d241f.zip
Added Bigstep datasource.
Diffstat (limited to 'cloudinit/sources/DataSourceBigstep.py')
-rw-r--r--cloudinit/sources/DataSourceBigstep.py48
1 files changed, 48 insertions, 0 deletions
diff --git a/cloudinit/sources/DataSourceBigstep.py b/cloudinit/sources/DataSourceBigstep.py
new file mode 100644
index 00000000..67d43eb3
--- /dev/null
+++ b/cloudinit/sources/DataSourceBigstep.py
@@ -0,0 +1,48 @@
+#
+# Copyright (C) 2015-2016 Bigstep Cloud Ltd.
+#
+# Author: Alexandru Sirbu <alexandru.sirbu@bigstep.com>
+#
+
+import json
+
+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()
+ 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():
+ content = util.load_file("/var/lib/cloud/data/seed/bigstep/url")
+ 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)
+