feat: implement chatbot engine for project validation, classification, and management

src/recommendation_engine/chatbot_engine.py

@@ -506,6 +506,8 @@ def chatbot(user_id: str, user_input: str):
     domain = analysis.get("domain")
     project_title = analysis.get("project_title")
     number = analysis.get("number")
+    abstract = analysis.get("abstract")
+    description = analysis.get("description")
 
     if action == "reply_directly":
         if project_title and not state.get("project_title"):
@@ -513,11 +515,25 @@ def chatbot(user_id: str, user_input: str):
         if domain and not state.get("domain"):
             state["domain"] = domain
             
+        custom_saved = False
+        if abstract:
+            state["abstract"] = abstract
+            state["custom_abstract"] = True
+            custom_saved = True
+        if description:
+            state["description"] = description
+            state["custom_description"] = True
+            custom_saved = True
+            
         save_user_memory(user_id, {"history": history, "state": state})
         
+        final_reply = reply_text or "I didn't quite catch that. Can you clarify?"
+        if custom_saved:
+            final_reply = "✅ I have saved your custom project details!\n\n" + final_reply
+            
         return finalize_response(
             user_input,
-            reply_text or "I didn't quite catch that. Can you clarify?",
+            final_reply,
             history,
             state,
             user_id
@@ -529,6 +545,8 @@ def chatbot(user_id: str, user_input: str):
             if domain_lower in ["other", "others", "general", "any"]:
                 state["domain"] = "general"
                 state["waiting_for_domain"] = False
+            elif domain_lower in ["domain", "domains", "list", "options", "help"]:
+                state["domain"] = None
             else:
                 state["domain"] = domain
                 state["waiting_for_domain"] = False
@@ -629,11 +647,16 @@ def chatbot(user_id: str, user_input: str):
             )
             state["features"] = feature_result.get("recommended_features", [])
 
+        custom_desc = state.get("custom_description", False)
+        custom_abs = state.get("custom_abstract", False)
+
         result = generate_full_project(
             title=state.get("project_title"),
             features=state.get("features", []),
-            description=state.get("description", ""),
-            abstract=state.get("abstract", "")
+            description=state.get("description", "") if custom_desc else "",
+            abstract=state.get("abstract", "") if custom_abs else "",
+            custom_description=custom_desc,
+            custom_abstract=custom_abs
         )
 
         state = update_state(state, result, mode="merge")
@@ -684,5 +707,16 @@ def chatbot(user_id: str, user_input: str):
         save_user_memory(user_id, {"history": history, "state": state})
         return finalize_response(user_input, "No problem! Let's try something else.", history, state, user_id)
         
+    elif action == "clear_session":
+        state = default_state()
+        save_user_memory(user_id, {"history": history, "state": state})
+        return finalize_response(
+            user_input,
+            "✅ Session cleared! We are starting fresh. How can I help you today?",
+            history,
+            state,
+            user_id
+        )
+
     else:
         return finalize_response(user_input, "I am not sure how to handle that.", history, state, user_id)

src/recommendation_engine/full_project_generator.py

@@ -72,7 +72,9 @@ def generate_full_project(
     title,
     features,
     description="",
-    abstract=""
+    abstract="",
+    custom_description=False,
+    custom_abstract=False
 ):
 
     context = {
@@ -100,10 +102,10 @@ def generate_full_project(
             extract_section(raw, "CATEGORY"),
 
         "abstract":
-            extract_section(raw, "ABSTRACT"),
+            abstract if custom_abstract else extract_section(raw, "ABSTRACT"),
 
         "description":
-            extract_section(raw, "DESCRIPTION"),
+            description if custom_description else extract_section(raw, "DESCRIPTION"),
 
         
         

src/recommendation_engine/llm_router.py

@@ -16,7 +16,7 @@ def word_to_number(text: str):
     text = text.lower()
 
     for word, num in mapping.items():
-        if word in text:
+        if re.search(rf"\b{word}\b", text):
             return num
 
     nums = re.findall(r'\d+', text)
@@ -63,12 +63,16 @@ Evaluate the input and choose exactly ONE action from the following list:
 4. "trigger_full_project_generation": Choose this if the user wants to generate the complete project specification.
     - Example: "generate full project", "fill all fields", or "2" (if selecting option 2 to generate the full project).
 
+5. "clear_session": Choose this if the user explicitly asks to start over, clear the chat, start a new project, reset the memory, or forget the current project.
+    - Example: "restart", "start over", "clear memory", "let's do a different project".
+
 5. "confirmation_yes": Choose this if the user is saying yes/confirming a prompt.
 6. "confirmation_no": Choose this if the user is saying no/declining.
 
 CRITICAL INSTRUCTIONS:
 - You are the orchestrator. If a request is invalid, missing context, or vague, use "reply_directly" to ask the user to clarify. Do NOT trigger a generation task if the input is bad.
 - NEVER choose "trigger_feature_generation" if the project title is just a single word, a brand name, or lacks technical description (e.g. "Fixy", "My Project", "Test"). You MUST choose "reply_directly" and ask the user to provide a descriptive technical title that explains what the system actually does.
+- If the user provides a summary or context about their project, extract it into "extracted_abstract". If they provide a detailed breakdown or scope, extract it into "extracted_description".
 - Return ONLY a valid JSON object. Do NOT include markdown blocks.
 
 JSON Format:
@@ -76,7 +80,9 @@ JSON Format:
     "action": "exact_action_name",
     "reply_text": "text to reply to the user (ONLY if action is reply_directly, otherwise null)",
     "extracted_domain": "extract_domain_if_mentioned_else_null",
-    "extracted_title": "extract_project_title_if_mentioned_else_null"
+    "extracted_title": "extract_project_title_if_mentioned_else_null",
+    "extracted_abstract": "extract_abstract_if_user_provides_one_else_null",
+    "extracted_description": "extract_description_if_user_provides_one_else_null"
 }}
 """
     try:
@@ -99,12 +105,16 @@ JSON Format:
         reply_text = parsed.get("reply_text")
         domain = parsed.get("extracted_domain") or extract_domain(text)
         project_title = parsed.get("extracted_title")
+        abstract = parsed.get("extracted_abstract")
+        description = parsed.get("extracted_description")
         
         return {
             "action": action,
             "reply_text": reply_text,
             "domain": domain,
             "project_title": project_title,
+            "abstract": abstract,
+            "description": description,
             "number": number
         }
     except Exception as e:
@@ -115,11 +125,15 @@ JSON Format:
         action = "reply_directly"
         reply_text = None
         project_title = None
+        abstract = None
+        description = None
             
         return {
             "action": action,
             "reply_text": reply_text,
             "domain": domain,
             "project_title": project_title,
+            "abstract": abstract,
+            "description": description,
             "number": number
         }