APR-81_1: Check Duplicates

python/common/vips_api.py

@@ -65,6 +65,12 @@ def status_get(prohibition_id: str, config, correlation_id='abcd') -> tuple:
         return True, data
     return False, dict({})
 
+def duplicate_get(prohibition_id: str, config, correlation_id='abcd'): 
+    endpoint = build_endpoint(config.VIPS_API_ROOT_URL, 'application', 'notice', prohibition_id, correlation_id)
+    is_response_successful, data = get(endpoint, config.VIPS_API_USERNAME, config.VIPS_API_PASSWORD, correlation_id)
+    if 'resp' in data:
+        return True, data
+    return False, dict({})
 
 def disclosure_get(document_id: str, config, correlation_id='abcd'):
     endpoint = build_endpoint(config.VIPS_API_ROOT_URL, document_id, 'disclosure', correlation_id)

python/ingestor/routes.py

@@ -1,4 +1,5 @@
 import python.common.helper as helper
+import python.common.vips_api as vips
 from python.ingestor.config import Config
 from python.common.rabbitmq import RabbitMQ
 from python.common.message import encode_message
@@ -124,7 +125,6 @@ def evidence():
             }
         }))
 
-
 @application.route('/check', methods=['GET'])
 def check():
     """
@@ -159,6 +159,22 @@ def check_templates():
             templates=rsi_email.content_data()
         )
 
+@application.route('/duplicate', methods=['GET'])
+@basic_auth_required
+def check_duplicate():
+
+    prohibition_number = request.args.get('prohibition_number')
+
+    is_api_callout_successful, vips_duplicate_data = vips.duplicate_get(
+        prohibition_id=prohibition_number, 
+        config=Config)
+    if is_api_callout_successful:
+        return vips_duplicate_data
+    error = 'the VIPS get_duplicate operation returned an invalid response'
+    args['error_string'] = "The system is down, please try again later."
+    logging.info(error)
+    return False, args
+
 
 if __name__ == "__main__":
     application.run(host='0.0.0.0')