1 files changed, 49 insertions, 0 deletions
diff --git a/src/pybind/mgr/feedback/service.py b/src/pybind/mgr/feedback/service.py
new file mode 100644
index 000000000..dc8c6b64a
--- /dev/null
+++ b/src/pybind/mgr/feedback/service.py
@@ -0,0 +1,49 @@
+# -*- coding: utf-8 -*-
+
+import json
+import requests
+from requests.exceptions import RequestException
+
+from .model import Feedback
+
+class config:
+    url = 'tracker.ceph.com'
+    port = 443
+
+class CephTrackerClient():
+
+    def list_issues(self):
+        '''
+        Fetch an issue from the Ceph Issue tracker
+        '''
+        headers = {
+            'Content-Type': 'application/json',
+        }
+        response = requests.get(
+            f'https://{config.url}/issues.json', headers=headers)
+        if not response.ok:
+            if response.status_code == 404:
+                raise FileNotFoundError
+            raise RequestException(response.status_code)
+        return {"message": response.json()}
+
+    def create_issue(self, feedback: Feedback, api_key: str):
+        '''
+        Create an issue in the Ceph Issue tracker
+        '''
+        try:
+            headers = {
+                'Content-Type': 'application/json',
+                'X-Redmine-API-Key': api_key,
+            }
+        except KeyError:
+            raise Exception("Ceph Tracker API Key not set")
+        data = json.dumps(feedback.as_dict())
+        response = requests.post(
+            f'https://{config.url}/projects/{feedback.project_id}/issues.json',
+            headers=headers, data=data)
+        if not response.ok:
+            if response.status_code == 401:
+                raise RequestException("Unauthorized. Invalid issue tracker API key")
+            raise RequestException(response.reason)
+        return {"message": response.json()}