o d6i+@sdZddlZddlmZddlmZmZddlmZddlm Z ddl m Z ddl m Z eeZd ed efd d Zd eded dfddZd eded efddZ  dded ededededed efddZdS)z Main LLM module for Karishye AI chat functionality. This module contains the main chat_with_karishye function that orchestrates the conversation flow with natural AI-driven booking (no rigid question flow). N)datetime)karishye_agent ChatContext)karishye_agent_tools)load_chat_history)get_user_puja_state) PUJA_PATTERNStextreturncCsddl}|sdS|jdd||jd}|dd|}|jdd ||jd}|d d |}|d d |}|d d|}|dd|}|jdd||jd}|jdd||jd}|dd|}|dd|}|S)u Convert markdown to WhatsApp format with proper spacing and readability. Converts: - Headers (# text) → text with spacing (plain text, no bold) - Bold (**text**) → *text* - Italic (_text_) → _text_ (preserved) - Links [text](url) → text: url - Lists → • item (bullets) or numbered - Code blocks → preserved with backticks - Removes HTML tags rNz```[\w]*\n?(.*?)```z\1)flagsz<[^>]+>z^#{1,6}\s+(.+)$z\1\nz \*\*(.+?)\*\*z*\1*z __(.+?)__z ~~(.+?)~~z~\1~z\[([^\]]+)\]\(([^\)]+)\)z\1: \2z ^[\*\-]\s+u• z ^(\d+)\.\s+z\1. z\n{3,}z u(\*[^\*]+\*)\n([•\d])z\1\n\n\2)resubDOTALL MULTILINEstrip)r r r+/var/www/html/karishye-ai-python/app/llm.py_format_for_whatsapps ruser_id session_idcCs|s tdtddS)zValidate required chat inputs.z'[chat_with_karishye] Missing session_idz*session_id is required for chat operationsN)loggererror ValueError)rrrrr_validate_chat_inputsWs rcCsRtD]"\}}|d|}t|||}|r&|dr&|ds&||fSqdS)z Find any active puja session for the user. Returns: tuple: (active_puja_state, active_puja_key) or (None, None) questions_key puja_name completed)NN)ritemsgetr)rr pattern_key pattern_inforstaterrr_find_active_puja_session^s    r#defaultF user_message phone_number user_nameformat_for_whatsappc szt||tdg}|rt|ddIdH}d}|r@t|dkr@d}|D]}|dd kr1d nd } || d |d d7}q't||\} } d} | ry| dsy| dd} | di}| ryd| d} |rud|}| d|d7} | d7} d}|rd|d}|| |d|}t ||||}ddl }| }t j ||dIdH}| }||}t |dr|jnt|}td|dd|rt|}|WSty}ztdt|jd t|}|WYd}~Sd}~ww)!a Main chat function with natural AI-driven booking flow. The AI agent now handles everything naturally: - Detects puja interest - Collects information conversationally (no rigid questions) - Name and phone are auto-provided from WhatsApp - Determines when enough info is gathered - Handles urgency and empathy naturally Args: user_message: The user's message user_id: User's unique identifier (required) session_id: Session identifier (required for proper session isolation) phone_number: Pre-collected phone number from WhatsApp user_name: Pre-collected user name from WhatsApp format_for_whatsapp: If True, format response for WhatsApp (plain text), else use markdown for web z,[chat_with_karishye] Processing chat request )limitNr rz Recent conversation context: type assistant AssistantUserz: message rrcollected_infoz& [Context: User is currently booking z. z, zAlready collected: z2Continue gathering missing information naturally.]z [User's name: zr. Use naturally with 'garu' in appropriate contexts - confirmations, empathy, important questions. Don't overuse.]z Current message: )depsoutputz![chat_with_karishye] Response in z.2fsz[chat_with_karishye] Error: zGI apologize, but I encountered an error while processing your request: )rrdebugrlenr#rjoinkeysrtimerrunhasattrr3rstrinfor Exceptionrr+__name__)r%rrr&r'r( chat_historyhistory_contextentryroleactive_puja_stateactive_puja_keybooking_contextrr1collected_fields name_contextenhanced_message chat_contextr9 start_timeresultend_time response_timeresponseeerror_responserrrchat_with_karishyeusZ      rR)r$NNNF)__doc__loggingrapp.agents.agentsrr app.agentsrapp.utils.conversation_utilsrapp.utils.utilsr app.constantsr getLoggerr?rr<rrtupler#boolrRrrrrs.      ;