wip

kbcstorage/client.py

@@ -3,6 +3,8 @@
 """
 
 from kbcstorage.buckets import Buckets
+from kbcstorage.components import Components
+from kbcstorage.configurations import Configurations
 from kbcstorage.workspaces import Workspaces
 from kbcstorage.jobs import Jobs
 from kbcstorage.tables import Tables
@@ -31,6 +33,8 @@ def __init__(self, api_domain, token):
         self.jobs = Jobs(self.root_url, self.token)
         self.tables = Tables(self.root_url, self.token)
         self.workspaces = Workspaces(self.root_url, self.token)
+        self.components = Components(self.root_url, self.token)
+        self.configurations = Configurations(self.root_url, self.token)
 
     @property
     def token(self):

kbcstorage/components.py

@@ -0,0 +1,46 @@
+"""
+Manages calls to the Storage API relating to configurations
+
+Full documentation `here`.
+
+.. _here:
+    http://docs.keboola.apiary.io/#reference/tables/
+"""
+import tempfile
+import os
+from kbcstorage.base import Endpoint
+from kbcstorage.files import Files
+from kbcstorage.jobs import Jobs
+
+
+class Components(Endpoint):
+    """
+    Components Endpoint
+    """
+    def __init__(self, root_url, token):
+        """
+        Create a Component endpoint.
+
+        Args:
+            root_url (:obj:`str`): The base url for the API.
+            token (:obj:`str`): A storage API key.
+        """
+        super().__init__(root_url, 'branch/default/components', token)
+
+    def detail(self, component_id, configuration_id):
+        """
+        Retrieves information about a given configuration.
+
+        Args:
+            component_id (str): The id of the component.
+            configuration_id (str): The id of the configuration.
+
+        Raises:
+            requests.HTTPError: If the API request fails.
+        """
+        if not isinstance(component_id, str) or component_id == '':
+            raise ValueError("Invalid component_id '{}'.".format(component_id))
+        if not isinstance(configuration_id, str) or configuration_id == '':
+            raise ValueError("Invalid component_id '{}'.".format(configuration_id))
+        url = '{}/{}/configs/{}'.format(self.base_url, component_id, configuration_id)
+        return self._get(url)

kbcstorage/configurations.py

@@ -0,0 +1,43 @@
+"""
+Manages calls to the Storage API relating to configurations
+
+Full documentation `here`.
+
+.. _here:
+    http://docs.keboola.apiary.io/#reference/tables/
+"""
+import tempfile
+import os
+from kbcstorage.base import Endpoint
+from kbcstorage.files import Files
+from kbcstorage.jobs import Jobs
+
+
+class Configurations(Endpoint):
+    """
+    Configurations Endpoint
+    """
+    def __init__(self, root_url, token):
+        """
+        Create a Configuration endpoint.
+
+        Args:
+            root_url (:obj:`str`): The base url for the API.
+            token (:obj:`str`): A storage API key.
+        """
+        super().__init__(root_url, 'branch/default/components', token)
+
+    def list(self, include=None):
+        """
+        List all components (and optionally configurations) in a project.
+
+        Args:
+            include (list): Properties to list (configuration, rows, state)
+        Returns:
+            response_body: The parsed json from the HTTP response.
+
+        Raises:
+            requests.HTTPError: If the API request fails.
+        """
+        params = {'include': ','.join(include)} if include else {}
+        return self._get(self.base_url, params=params)

kbcstorage/tables.py

@@ -15,7 +15,7 @@
 
 class Tables(Endpoint):
     """
-    Buckets Endpoint
+    Tables Endpoint
     """
     def __init__(self, root_url, token):
         """