Mussab Abdalla
--- a/ingestor/app.py
+++ b/ingestor/app.py
    try:
        client.lpush(queue_name, queue_content)
        
-        save_Json(filename, 'SUCSSES')
+        save_json(filename, queue_content, True)
--- a/ingestor/Dockerfile
+++ b/ingestor/Dockerfile
 ADD install.sh requirements.txt \
    /
 RUN /install.sh
-RUN mkdir /ingestor
+RUN mkdir /ingestor 
--- a/ingestor/ingestor/util.py
+++ b/ingestor/ingestor/util.py
 def converter(o):
    if isinstance(o, datetime):
        return o.isoformat()
+
+def save_report(filename:str, data, success: bool):
--- a/ingestor/ingestor/util.py
+++ b/ingestor/ingestor/util.py
 def converter(o):
    if isinstance(o, datetime):
        return o.isoformat()
+
+def save_report(filename:str, data, success: bool):
+
+    if success:
+        save_dir = os.environ['INGESTOR_SUCCESS_DIR']
+    else: 
+        save_dir = os.environ['INGESTOR_FAIL_DIR']
+
+    if isinstance(data, str):
+        shutil.move(data, save_dir)
+    else :
--- a/ingestor/ingestor/util.py
+++ b/ingestor/ingestor/util.py
 def converter(o):
    if isinstance(o, datetime):
        return o.isoformat()
+
+def save_report(filename:str, data, success: bool):
+
+    if success:
+        save_dir = os.environ['INGESTOR_SUCCESS_DIR']
+    else: 
+        save_dir = os.environ['INGESTOR_FAIL_DIR']
+
+    if isinstance(data, str):
+        shutil.move(data, save_dir)
+    else :
+        
+        with open(os.path.join(save_dir, '%s.xml' % filename), "w") as outfile: 
--- a/ingestor/filedaemon.py
+++ b/ingestor/filedaemon.py
-                )
+
+        with open(event.pathname) as f:
+            browse_report = parse_browse_report(f)
+        logger.debug(browse_report)
+        if isinstance(browse_report, str):
+            queue_content = browse_report
+
+        else:
+            queue_content = json.dumps(
+                browse_report, default=converter
+            )
+        try:  
            client.lpush(queue_name, queue_content)
+            
+            save_report('', event.pathname, True)