| from db import supabase | |
| from engine.states import HANDOFF_DONE | |
| def create_support_handoff(customer_phone: str, bot_number: str, summary: str, metadata=None): | |
| payload = { | |
| "customer_phone": customer_phone, | |
| "bot_number": bot_number, | |
| "department": "support", | |
| "summary": summary, | |
| "status": "pending", | |
| "metadata": metadata or {}, | |
| } | |
| res = supabase.table("handoff_requests").insert(payload).execute() | |
| rows = res.data or [] | |
| return rows[0] if rows else None | |
| def create_support_handoff_result(flow_data: dict, summary: str): | |
| flow_data = flow_data or {} | |
| flow_data["handoff_department"] = "support" | |
| flow_data["handoff_summary"] = summary | |
| return { | |
| "next_state": HANDOFF_DONE, | |
| "flow_data": flow_data, | |
| "reply": ( | |
| "تمام، تم رفع استفسارك لفريق خدمة العملاء.\n" | |
| "هيتم التواصل معاك قريب." | |
| ), | |
| "action": { | |
| "type": "handoff", | |
| "department": "support", | |
| "summary": summary, | |
| } | |
| } |