add compat layer over core library (#85)

* Compat Layer

* rm unused data

* Update README.md

* backupunit

* private cross connect functionality

* s3keeys

* disregard warning

* add pcc to lan

* nodepools update - add parameter lan ids and documentation

* nodepools update

* set useragent as compat sdk

* Create config.yml for issue templates

* Created template for bug

* Created feature request template

* rm print

* set version on user agent

* fix test shares

* add public ips

* change package

* fix loadbalancer

* fix tests

* fix tests

* change package name of the core to ionoscloud

* fix cdrom tests

* fix um

* pylint code cosmetization

* pylint sugestions fix

* fix import

* update code fot flake8

* pylint code cozmetization

* pylint fixes

* fix flake standard

* refactor k8s tests

* k8s nodepools tests refactor

* review pull request: ensure transitive dependencies

* change package version

Co-authored-by: Alexandru Toma <alexandru.toma@ionos.com>
Co-authored-by: Livius <plivius@yahoo.com>

Author: 3 people

.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,54 @@
+---
+name: Bug report
+about: Create a report to help us improve
+title: ''
+labels: bug
+assignees: LiviusP
+
+---
+
+## Descripton
+<!-- A clear and concise description of what the bug is. -->
+
+## Expected behavior
+<!-- A clear and concise description of what you expected to happen. -->
+
+## Environment
+<!-- coud be ansible, python etc.  version, depends on concrete sdk/tool -->
+hello version: <!-- run `hello --version` and paste the output between the ```marks. -->
+```
+```
+world version: <!-- run `grep version /etc/world.cfg` and paste the output between the ```marks. -->
+```
+```
+OS: <!-- use whatever fits and put it between the ```marks. -->
+```
+```
+
+## Configuration Files
+<!-- could also be environment settings, e.g. LANG=de_DE -->
+
+## How to Reproduce
+<!--
+Steps to reproduce the behavior:
+1. Go to '...'
+2. Execute `acme --emca template.xml`
+3. ...
+Might be omitted if there are no choices, eg. the single command is already in the description
+-->
+
+## Error and Debug Output
+<!--
+Add anything, that could help here.
+You can increase the debug level by .. ' hello --whatsover=example`
+-->
+
+## Additional Notes
+<!--
+Add any other content about the problem here.
+-->
+
+## References
+<!--
+Add any other related issues or other links that you think are important for fixing the bug.
+-->

.github/ISSUE_TEMPLATE/config.yml

@@ -0,0 +1,5 @@
+blank_issues_enabled: false
+contact_links:
+  - name: IONOS Cloud API
+    url: https://devops.ionos.com/api/
+    about: View API documentation

.github/ISSUE_TEMPLATE/feature_request.md

@@ -0,0 +1,51 @@
+---
+name: Feature request
+about: Suggest an idea for this project
+title: ''
+labels: enhancement
+assignees: LiviusP
+
+---
+
+### Current SDK Version
+<!---
+If you're not using the latest version, please check to see if something related to your request has already been implemented in a later version.
+-->
+
+```
+...
+```
+
+### Use-cases
+<!---
+In order to properly evaluate a feature request, it is necessary to understand the use-cases for it.
+
+Please describe below the end goal you are trying to achieve that has led you to request this feature.
+
+Please keep this section focused on the problem and not on the suggested solution. We'll get to that in a moment, below!
+-->
+
+### Attempted Solutions
+<!---
+If you've already tried to solve the problem within SDKs existing features and found a limitation that prevented you from succeeding, please describe it below in as much detail as possible.
+
+Ideally, this would include real code snippets that you tried and what results you got in each case.
+
+Please remove any sensitive information such as passwords before sharing configuration snippets and command lines.
+--->
+
+### Proposal
+<!---
+If you have an idea for a way to address the problem, please describe it below.
+
+In this section, it's helpful to include specific examples of how what you are suggesting might look in configuration files, or on the command line, since that allows us to understand the full picture of what you are proposing.
+
+-->
+
+### References
+<!--
+Are there any other GitHub issues, whether open or closed, that are related to the problem you've described above or to the suggested solution? If so, please create a list below that mentions each of them. For example:
+
+- #6017
+
+-->

README.md

@@ -1,7 +1,7 @@
 
 # Python SDK
 
-Version: ionosenterprise-sdk-python **5.4.0**
+Version: ionosenterprise-sdk-python **5.5.0**
 
 ## Table of Contents
 
@@ -2379,6 +2379,7 @@ The following table describes the request arguments:
 | annotations | no | dict | Map of annotations attached to node pool |
 | public_ips | no | list | List of IP addresses to be used by nodes |
 
+
 Method signature:
 
 ```python
@@ -2492,7 +2493,7 @@ Method signature:
 ```python
 def update_k8s_cluster_nodepool(self,
                                     k8s_cluster_id, nodepool_id, node_count,
-                                    maintenance_window=None, auto_scaling=None):
+                                    maintenance_window=None, auto_scaling=None, lan_ids=None):
 ```
 
 Update a nodepool:

coreadaptor/AuthAdaptor.py

@@ -0,0 +1,12 @@
+import ionoscloud
+
+class AuthAdaptor:
+    def __init__(self, username, password):
+        self.username = username
+        self.password = password
+
+    def get_api_client(self):
+        return ionoscloud.ApiClient(ionoscloud.Configuration(
+            username = self.username,
+            password = self.password
+        ))

coreadaptor/IonosCoreProxy.py

@@ -0,0 +1,153 @@
+from ionoscloud.exceptions import ApiException, ApiTimeout, ApiFailedRequest
+from ionosenterprise.errors import (
+    ICNotAuthorizedError,
+    ICNotFoundError,
+    ICValidationError,
+    ICRateLimitExceededError,
+    ICError,
+    ICFailedRequest,
+    ICTimeoutError
+)
+import json
+import functools
+import re
+import inspect
+
+class IonosCoreProxy:
+
+    custom_methods = {
+        'start_server': 'POST-ACTION',
+        'stop_server': 'POST-ACTION',
+        'reboot_server': 'POST-ACTION',
+        'restore_snapshot': 'POST-ACTION',
+        'create_snapshot': 'POST-ACTION-JSON'
+    }
+
+    @staticmethod
+    def get_default_args(func):
+        signature = inspect.signature(func)
+        return {
+            k: v.default
+            for k, v in signature.parameters.items()
+            if v.default is not inspect.Parameter.empty
+        }
+
+    @staticmethod
+    def _request_id(headers):
+        # The request URL has currently the format:
+        # {host_base}/requests/{request ID}/status
+        # Thus search for a UUID.
+        match = re.search('/requests/([-A-Fa-f0-9]+)/', headers['location'])
+        if match:
+            return match.group(1)
+        else:
+            raise Exception("Failed to extract request ID from response "
+                            "header 'location': '{location}'".format(location=headers['location']))
+
+    @staticmethod
+    def process_response(f):
+        @functools.wraps(f)
+        def func(*args, **kwargs):
+            try:
+                response = f(*args, **kwargs)
+                return IonosCoreProxy.handle_response_operations(f, response)
+            except Exception as e:
+                raise IonosCoreProxy.cast_exception(e)
+        return func
+
+    @staticmethod
+    def cast_exceptions(f):
+        @functools.wraps(f)
+        def func(*args, **kwargs):
+            try:
+                return f(*args, **kwargs)
+            except Exception as e:
+                if type(e) == ApiException:
+                    code = e.status
+                    msg = json.loads(e.body)
+                    url = e.url
+                    if code == 401:
+                        raise ICNotAuthorizedError(code, msg, url)
+                    elif code == 404:
+                        raise ICNotFoundError(code, msg, url)
+                    elif code == 422:
+                        raise ICValidationError(code, msg, url)
+                    elif code == 429:
+                        raise ICRateLimitExceededError(code, msg, url)
+                    else:
+                        raise ICError(code, msg, url)
+                elif type(e) == ApiTimeout:
+                    raise ICTimeoutError(e.message, e.request_id)
+                elif type(e) == ApiFailedRequest:
+                    raise ICFailedRequest(e.message, e.request_id)
+                raise e
+        return func
+
+    @staticmethod
+    def _underscore_to_camelcase(f):
+        def underscore_to_camelcase(value):
+            def camelcase():
+                yield str.lower
+                while True:
+                    yield str.capitalize
+            c = camelcase()
+            return "".join(next(c)(x) if x else '_' for x in value.split("_"))
+        def myprint(d):
+            for k in list(d):
+                v = d[k]
+                del d[k]
+                d[underscore_to_camelcase(k)] = v
+                if isinstance(v, dict):
+                    myprint(v)
+
+
+        @functools.wraps(f)
+        def func(*args, **kwargs):
+            x = f(*args, **kwargs)
+            myprint(x)
+            return x
+        return func
+
+    @staticmethod
+    def handle_response_operations(func, response):
+        return_data = response[0]
+        status_code = response[1]
+        response_headers = response[2]
+
+        if func.__name__ in IonosCoreProxy.custom_methods and IonosCoreProxy.custom_methods[func.__name__] in ['POST-ACTION-JSON', 'POST-ACTION']:
+            if status_code == 202 and func.__name__ in IonosCoreProxy.custom_methods and IonosCoreProxy.custom_methods[func.__name__] == 'POST-ACTION':
+                return True
+
+        if 'location' in response_headers:
+            if return_data == '':
+                return_data = {}
+            elif type(return_data) != dict:
+                return_data = return_data.to_dict()
+            return_data['requestId'] = IonosCoreProxy._request_id(response_headers)
+
+        return return_data
+
+
+
+    @staticmethod
+    def cast_exception(e):
+        if type(e).__name__ == ApiException.__name__:
+
+            code = e.status
+            msg = json.loads(e.body)
+            url = e.url
+
+            if 'messages' in msg:
+                msg = msg['messages']
+
+            if code == 401:
+                raise ICNotAuthorizedError(code, msg, url)
+            if code == 404:
+                raise ICNotFoundError(code, msg, url)
+            if code == 422:
+                raise ICValidationError(code, msg, url)
+            if code == 429:
+                raise ICRateLimitExceededError(code, msg, url)
+            else:
+                raise ICError(code, msg, url)
+        raise e

coreadaptor/__init__.py

@@ -77,7 +77,7 @@
 
 print('Waiting for the datacenter to be active!')
 datacenters = client.wait_for(
-  fn_request=lambda: client.list_datacenters(),
+  fn_request=client.list_datacenters(),
   fn_check=lambda r: list(filter(
       lambda e: e['properties']['name'] == datacenter_name,
       r['items']
@@ -97,7 +97,7 @@
 
 print('Waiting for the cluster to be active!')
 clusters = client.wait_for(
-  fn_request=lambda: client.list_k8s_clusters(),
+  fn_request=client.list_k8s_clusters(),
   fn_check=lambda r: list(filter(
       lambda e: e['properties']['name'] == cluster_name,
       r['items']
@@ -162,7 +162,7 @@
 
 print('Waiting for the cluster to be deleted!')
 clusters = client.wait_for(
-  fn_request=lambda: client.list_k8s_clusters(),
+  fn_request=client.list_k8s_clusters(),
   fn_check=lambda r: len(list(filter(
       lambda e: e['properties']['name'] == cluster_name,
       r['items']
@@ -178,7 +178,7 @@
 
 print('Waiting for the datacenter to be deleted!')
 clusters = client.wait_for(
-  fn_request=lambda: client.list_datacenters(),
+  fn_request=client.list_datacenters(),
   fn_check=lambda r: len(list(filter(
       lambda e: e['properties']['name'] == datacenter_name,
       r['items']

examples/k8s.py

@@ -13,7 +13,7 @@
 # limitations under the License.
 
 """Ionos Enterprise API Client Library for Python"""
-__version__ = '5.4.0'
+__version__ = '5.5.0'
 
 API_HOST = 'https://api.ionos.com/cloudapi/v5'
 API_VERSION = '5.0'