Update app.py

app.py

@@ -19,26 +19,22 @@ from human_text_detect import detect_human_text
 app = Flask(__name__)
 CORS(app)
 
+task_results = {}
+
 @app.route('/')
 def index():
     return 'Hello'
 
-@app.route('/detectHumanInAIText/checkText', methods=['POST'])
-def check_text():
+def process_analysis(task_id, text, model_name, topic):
+    print(f"Processing task: {task_id}")
 
-    # Get data
-    print('Get data')
-    data = request.get_json()
-    text = data.get('text')
-    model_name = data.get('model')
-    topic = data.get('topic')
-    
     # Validate data
     print('Validate data')
     answer = validate_data(text, model_name, topic)
     if answer != '':
-        return jsonify({'error': answer}), 400
-    
+        task_results[task_id] = {'error': answer}
+        return
+
     topic = check_topic(topic)
     hcRelativeToThreshold, df_sentences = detect_human_text(model_name, topic, text)
     message = 'Edits found in the text' if hcRelativeToThreshold >= 0 else 'We couldn\'t find edits in the text'
@@ -52,7 +48,40 @@ def check_text():
         }
         for _, row in df_sentences.iterrows()
     ]
-    return jsonify({'message': message, 'hcRelativeToThreshold': hcRelativeToThreshold, 'sentences': sentences})
+    
+    # Store the result
+    task_results[task_id] = {'message': message, 'hcRelativeToThreshold': hcRelativeToThreshold, 'sentences': sentences}
+
+@app.route('/detectHumanInAIText/checkText', methods=['POST'])
+def check_text():
+    # Get data
+    print('Get data')
+    data = request.get_json()
+    text = data.get('text')
+    model_name = data.get('model')
+    topic = data.get('topic')
+
+    # Generate a unique taskId
+    task_id = str(uuid.uuid4())
+
+    # Start processing in a separate thread
+    thread = threading.Thread(target=process_analysis, args=(task_id, text, model_name, topic))
+    thread.start()
+
+    # Return taskId immediately
+    return jsonify({'taskId': task_id}), 202
+
+@app.route('/detectHumanInAIText/getAnalyzeResults', methods=['GET'])
+def get_results():
+    task_id = request.args.get('taskId')
+    
+    if not task_id:
+        return jsonify({'error': 'Missing taskId parameter'}), 400
+    
+    if task_id not in task_results:
+        return jsonify({'status': 'pending'}), 202
+    
+    return jsonify(task_results.pop(task_id)), 200
 
 def validate_data(text, model_name, topic):
     if text is None or text == '':