amundsen-io
diff --git a/‎amundsen_application/__init__.py
+13-1 b/‎amundsen_application/__init__.py
+13-1
diff --git a/‎tests/unit/utils/notification/__init__.py ‎amundsen_application/api/issue/__init__.py b/‎tests/unit/utils/notification/__init__.py ‎amundsen_application/api/issue/__init__.py
diff --git a/‎amundsen_application/api/issue/issue.py
+76 b/‎amundsen_application/api/issue/issue.py
+76
@@ -4,7 +4,8 @@
 import logging.config
 import os
 
-from flask import Flask
+from flask import Flask, Blueprint
+from flask_restful import Api
 
 from amundsen_application.api import init_routes
 from amundsen_application.api.v0 import blueprint
@@ -15,6 +16,8 @@
 from amundsen_application.api.metadata.v0 import metadata_blueprint
 from amundsen_application.api.preview.v0 import preview_blueprint
 from amundsen_application.api.search.v0 import search_blueprint
+from amundsen_application.api.issue.issue import IssueAPI, IssuesAPI
+
 
 app_wrapper_class = Flask
 
@@ -53,6 +56,14 @@ def create_app(config_module_class: str, template_folder: str = None) -> Flask:
     logging.info('Using metadata service at {}'.format(app.config.get('METADATASERVICE_BASE')))
     logging.info('Using search service at {}'.format(app.config.get('SEARCHSERVICE_BASE')))
 
+    api_bp = Blueprint('api', __name__)
+    api = Api(api_bp)
+
+    api.add_resource(IssuesAPI,
+                     '/api/issue/issues', endpoint='issues')
+    api.add_resource(IssueAPI,
+                     '/api/issue/issue', endpoint='issue')
+
     app.register_blueprint(blueprint)
     app.register_blueprint(announcements_blueprint)
     app.register_blueprint(log_blueprint)
@@ -61,6 +72,7 @@ def create_app(config_module_class: str, template_folder: str = None) -> Flask:
     app.register_blueprint(metadata_blueprint)
     app.register_blueprint(preview_blueprint)
     app.register_blueprint(search_blueprint)
+    app.register_blueprint(api_bp)
     init_routes(app)
 
     init_custom_routes = app.config.get('INIT_CUSTOM_ROUTES')
 
@@ -0,0 +1,76 @@
+from flask import current_app as app
+from flask import jsonify, make_response, Response
+from flask_restful import Resource, reqparse
+from http import HTTPStatus
+import logging
+
+from amundsen_application.base.base_issue_tracker_client import BaseIssueTrackerClient
+from amundsen_application.proxy.issue_tracker_clients import get_issue_tracker_client
+from amundsen_application.proxy.issue_tracker_clients.issue_exceptions import IssueConfigurationException
+
+LOGGER = logging.getLogger(__name__)
+
+
+class IssuesAPI(Resource):
+    def __init__(self) -> None:
+        self.reqparse = reqparse.RequestParser()
+        self.client: BaseIssueTrackerClient
+
+    def get(self) -> Response:
+        """
+        Given a table key, returns all tickets containing that key. Returns an empty array if none exist
+        :return: List of tickets
+        """
+        try:
+            if not app.config['ISSUE_TRACKER_CLIENT_ENABLED']:
+                message = 'Issue tracking is not enabled. Request was accepted but no issue will be returned.'
+                logging.exception(message)
+                return make_response(jsonify({'msg': message}), HTTPStatus.ACCEPTED)
+
+            self.client = get_issue_tracker_client()
+            self.reqparse.add_argument('key', 'Request requires a key', location='args')
+            args = self.reqparse.parse_args()
+            response = self.client.get_issues(args['key'])
+            return make_response(jsonify({'issues': response.serialize()}), HTTPStatus.OK)
+
+        except IssueConfigurationException as e:
+            message = 'Encountered exception: ' + str(e)
+            logging.exception(message)
+            return make_response(jsonify({'msg': message}), HTTPStatus.NOT_IMPLEMENTED)
+        except Exception as e:
+            message = 'Encountered exception: ' + str(e)
+            logging.exception(message)
+            return make_response(jsonify({'msg': message}), HTTPStatus.INTERNAL_SERVER_ERROR)
+
+
+class IssueAPI(Resource):
+    def __init__(self) -> None:
+        self.reqparse = reqparse.RequestParser()
+        self.client: BaseIssueTrackerClient
+        super(IssueAPI, self).__init__()
+
+    def post(self) -> Response:
+        try:
+            if not app.config['ISSUE_TRACKER_CLIENT_ENABLED']:
+                message = 'Issue tracking is not enabled. Request was accepted but no issue will be created.'
+                logging.exception(message)
+                return make_response(jsonify({'msg': message}), HTTPStatus.ACCEPTED)
+            self.client = get_issue_tracker_client()
+
+            self.reqparse.add_argument('title', type=str, location='form')
+            self.reqparse.add_argument('key', type=str, location='form')
+            self.reqparse.add_argument('description', type=str, location='form')
+            args = self.reqparse.parse_args()
+            response = self.client.create_issue(description=args['description'],
+                                                table_uri=args['key'],
+                                                title=args['title'])
+            return make_response(jsonify({'issue': response.serialize()}), HTTPStatus.OK)
+
+        except IssueConfigurationException as e:
+            message = 'Encountered exception: ' + str(e)
+            logging.exception(message)
+            return make_response(jsonify({'msg': message}), HTTPStatus.NOT_IMPLEMENTED)
+        except Exception as e:
+            message = 'Encountered exception: ' + str(e)
+            logging.exception(message)
+            return make_response(jsonify({'msg': message}), HTTPStatus.INTERNAL_SERVER_ERROR)