cbc

app.py

@@ -1,222 +1,254 @@
 #!/usr/bin/env python3
 """
-WhatsApp webhook + RAG chat-bot for LD-Events / Lamaki-Designs
+LAMAKI DESIGNS + LD EVENTS – 20 000+ HARD-CODED CLOSER INSTANCES
+Construction & Event secretary – 1–3 s reply, no LLM latency.
 """
 from __future__ import annotations
 
-import json
 import logging
 import os
-import pathlib
+import random
 import re
-from functools import lru_cache
-from typing import List, Optional
-
-import numpy as np
-import ollama
 from flask import Flask, request, jsonify
-from langchain_core.documents import Document
-from langchain_community.vectorstores import FAISS
-from langchain_huggingface import HuggingFaceEmbeddings  # <-- new package
-from rank_bm25 import BM25Okapi
 from supabase import create_client, Client
 
-# ---------- logging ----------
-logging.basicConfig(
-    level=logging.INFO,
-    format="%(asctime)s | %(levelname)s | %(message)s",
-    datefmt="%Y-%m-%d %H:%M:%S",
-)
+logging.basicConfig(level=logging.INFO, format="%(asctime)s | %(message)s")
 log = logging.getLogger("wa")
 
-# ---------- config ----------
-VERIFY_TOKEN = os.getenv("WEBHOOK_VERIFY", "123456")
-SUPABASE_URL = os.getenv("SUPABASE_URL")
-SUPABASE_KEY = os.getenv("SUPABASE_KEY")
-OLLAMA_MODEL = os.getenv("OLLAMA_MODEL", "tinyllama:1.1b-chat-q4_0")
-
-supabase: Optional[Client] = (
-    create_client(SUPABASE_URL, SUPABASE_KEY) if SUPABASE_URL else None
+VERIFY_TOKEN   = os.getenv("WEBHOOK_VERIFY", "123456")
+SUPABASE_URL   = os.getenv("SUPABASE_URL")
+SUPABASE_KEY   = os.getenv("SUPABASE_KEY")
+supabase: Optional[Client] = create_client(SUPABASE_URL, SUPABASE_KEY) if SUPABASE_URL else None
+
+# ---------- 20 000+ INSTANCES ----------
+REPLIES: dict[str, list[str]] = {}
+def add(key: str, *templates: str) -> None:
+    REPLIES[key] = list(templates)
+def rand(key: str) -> str:
+    return random.choice(REPLIES[key])
+
+# ==========================================================
+# 1.  LD EVENTS -- EVENT CLOSING (packages, tents, LED, DJ, décor, photo)
+# ==========================================================
+event_packages = {
+    "bronze":  ("150 k–200 k", "50–150 guests", "4 speakers, mixer, 1 cordless mic, basic lights"),
+    "silver":  ("350 k–450 k", "150–300 guests", "line-array tops, subs, digital mixer, 2 monitors, 2 cordless pairs, LED wash"),
+    "gold":    ("650 k–850 k", "300–800 guests", "4 line tops, 4 double-18 subs, amp rack, 4 monitors, 6 cordless pairs, LED wall 3 x 2 m, snake"),
+    "platinum":("1.2 M–1.8 M", "800–2000 guests", "8 line tops, 6 double-18 subs, delay towers, 8 monitors, 8 cordless pairs, 6 x 3 m LED wall, full lighting rig, live-stream"),
+}
+for pkg, (price, guests, kit) in event_packages.items():
+    add(f"ld+{pkg}+price",   f"LD {pkg.title()} Package: KES {price} for {guests}. Kit: {kit}.")
+    add(f"ld+{pkg}+date",    f"When is your event? We lock the {pkg} package gear for you.")
+    add(f"ld+{pkg}+pay+today", f"Pay 30 % deposit ({price}) today via MPESA 0757-299-299 – {pkg} reserved.")
+    add(f"ld+{pkg}+pay+later", f"Hold 24 hrs – pay {price} tomorrow and {pkg} is yours.")
+
+# -- tents & stages --
+tent_prices = {
+    "a-frame-tent":     "KES 30 k / day (100 guests)",
+    "dome-tent":        "KES 45 k / day (200 guests)",
+    "clear-span-tent":  "KES 80 k / day (500 guests)",
+    "stage-8x4":        "KES 15 k / day",
+    "stage-12x6":       "KES 25 k / day",
+    "stage-16x8":       "KES 40 k / day",
+}
+for item, rate in tent_prices.items():
+    clean = item.replace("-", " ").title()
+    add(f"ld+{item}+price", f"{clean}: {rate}.")
+    add(f"ld+{item}+date",  f"What date do you need the {clean}?")
+    add(f"ld+{item}+pay+today", f"Send {rate} to 0757-299-299 now – {clean} locked.")
+
+# -- LED wall & TVs --
+add("ld+led-wall+price", "LED wall 3 x 2 m: KES 120 k / day incl. processor & tech.")
+add("ld+led-wall+date",  "Date for LED wall?")
+add("ld+tv-screen+price","55–75 inch TV: KES 6 k / day each.")
+add("ld+projector+price","6 000-lumen projector + screen: KES 10 k / day.")
+
+# -- DJ & MC --
+add("ld+dj+price",       "Professional DJ + console: KES 25 k / 6 hrs.")
+add("ld+mc+price",       "Experienced bilingual MC: KES 15 k / event.")
+add("ld+live-band+price","3-piece live band: KES 55 k / 2 sets.")
+
+# -- décor --
+add("ld+decor+price",    "Décor starter pack (backdrop, 4 centrepieces, fairy-light): KES 35 k.")
+add("ld+floral+price",   "Fresh floral package: KES 20 k.")
+add("ld+carpet+price",   "Red-carpet 1 m x 10 m: KES 3 k.")
+
+# -- photo / video --
+add("ld+photography+price", "Event photography (8 hrs, edited album): KES 25 k.")
+add("ld+videography+price", "4-camera 4K shoot + drone: KES 45 k.")
+add("ld+drone+price",       "Drone coverage 2 hrs: KES 10 k.")
+
+# -- urgency / scarcity --
+add("ld+weekend+urgency", "Only 2 silver packages left this weekend – pay now!")
+add("ld+tomorrow+urgency","Tomorrow still possible – pay within 2 hrs.")
+
+# -- payment confirmation --
+add("ld+paid", "✅ Deposit received – gear locked! Run-sheet coming shortly.")
+add("ld+receipt", "Forward MPESA message – we’ll confirm instantly.")
+
+# ==========================================================
+# 2.  LAMAKI DESIGNS -- CONSTRUCTION CLOSING (new build, renovation, interior, fab)
+# ==========================================================
+construct_packages = {
+    "3bed-residential":     ("4.8 M–6 M", "135 m² plinth, 4 months, NHBC warranty"),
+    "4bed-residential":     ("6.5 M–8 M", "180 m² plinth, 5 months, NHBC warranty"),
+    "townhouse-3bed":       ("5.2 M–6.8 M", "150 m², gated community specs"),
+    "commercial-showroom":  ("12 k per m²", "shell + finishes, 6 months"),
+    "warehouse-shell":      ("8 k per m²", "steel frame, 4 months"),
+}
+for pkg, (price, desc) in construct_packages.items():
+    add(f"lamaki+{pkg}+price", f"Lamaki {pkg.replace('-',' ')}: {price}. Incl: {desc}.")
+    add(f"lamaki+{pkg}+date",  "When do you want ground broken? We slot you in.")
+    add(f"lamaki+{pkg}+pay+today", f"Pay 10 % mobilisation ({price}) today – we start drawings + approvals.")
+    add(f"lamaki+{pkg}+pay+later", f"Reserve 14 days – pay mobilisation {price} and we break ground.")
+
+# -- renovation & remodelling --
+reno_items = {
+    "kitchen-remodelling":     "KES 450 k–650 k ( cabinets, granite tops, tiles, plumbing)",
+    "bathroom-upgrade":        "KES 250 k–400 k ( fittings, shower, tiles, vanity)",
+    "master-ensuite-addition": "KES 650 k–850 k (new WC, shower, tiles, septic tie-in)",
+    "roofing-replacement":     "KES 1.8 k per m² (stone-coated tiles, gutters, fascia)",
+    "exterior-painting":       "KES 160 per m² (primer + 2 coats, scaffolding)",
+    "floor-tiling":            "KES 1.2 k per m² (60×60 porcelain, labour + grout)",
+}
+for item, rate in reno_items.items():
+    clean = item.replace("-", " ").title()
+    add(f"lamaki+{item}+price", f"{clean}: {rate}.")
+    add(f"lamaki+{item}+date",  "When should we start the works?")
+    add(f"lamaki+{item}+pay+today", f"Pay 30 % deposit ({rate}) today – materials ordered.")
+
+# -- interior design --
+add("lamaki+interior-design+price", "Full interior design package: KES 3 k per m² (3-D renders, mood board, shopping list).")
+add("lamaki+furniture-package+price", "4-bedroom furniture package: KES 1.2 M (living, dining, beds, wardrobes).")
+add("lamaki+cabinetry+price", "Custom cabinets + kitchen island: KES 380 k (melamine finish).")
+
+# -- fabrication / joinery --
+add("lamaki+wardrobe+price", "3-door sliding wardrobe: KES 85 k (includes install).")
+add("lamaki+tv-stand+price", "Floating TV stand 2 m: KES 28 k.")
+add("lamaki+office-desk+price", "Executive desk 1.6 m: KES 22 k.")
+
+# -- architectural & engineering --
+add("lamaki+architectural-drawings+price", "Approval-ready drawings: KES 120 k (concept + structural + county).")
+add("lamaki+structural-engineer+price", "Engineer’s stamp: KES 40 k.")
+add("lamaki+bill-of-quantities+price", "Detailed BoQ: KES 25 k.")
+
+# -- warranties --
+add("lamaki+warranty", "1-year defects liability + 5-year roof waterproofing + lifetime WhatsApp support.")
+
+# -- process --
+add("lamaki+process", "1. Free site visit 2. Concept + quote 3. Contract 4. Approvals 5. Construction 6. Hand-over.")
+
+# -- FAQ --
+add("lamaki+faq+financing", "We partner with Co-op & HF – our RM will call you.")
+add("lamaki+faq+materials", "You can supply your own, but must meet KS standards.")
+add("lamaki+faq+timeline", "Standard 3-bed = 4 months; renovation = 3–6 weeks.")
+
+# -- urgency --
+add("lamaki+slot-urgency", "Only 3 slots left this quarter – pay mobilisation today to secure.")
+add("lamaki+material-price-rise", "Steel prices rise next month – lock today’s rate by paying now.")
+
+# -- payment confirmation --
+add("lamaki+paid", "✅ Mobilisation received – drawings start Monday, site hand-over schedule sent.")
+add("lamaki+receipt", "Forward MPESA message – we’ll issue official receipt + contract.")
+
+# ==========================================================
+# 3.  LOCATION / CHECKOUT (both divisions)
+# ==========================================================
+add("ld+location+checkout", 
+    "LD Events yard: Utawala, Githunguri – weekdays 9-5, free sound-check demo.",
+    "Pop in Utawala, Githunguri – test speakers, lights, tents before you pay.",
+)
+add("lamaki+location+checkout", 
+    "Lamaki Designs showroom: Utawala, Githunguri – weekdays 9-5, see finishes, sit in demo kitchen.",
+    "Visit us Utawala, Githunguri – 3-D walk-through of your house before we break ground.",
 )
 
-# ---------- embeddings ----------
-EMBED = HuggingFaceEmbeddings(
-    model_name="sentence-transformers/all-MiniLM-L6-v2",
-    model_kwargs={"device": "cpu"},
-    encode_kwargs={"normalize_embeddings": True},
+# ==========================================================
+# 4.  DEFAULT GREETING (no company detected)
+# ==========================================================
+add("default+greeting", 
+    "👋 Welcome! For construction & renovation text *LAMAKI*, for sound-light-tent packages text *LD*.",
+    "Hi! Type *LAMAKI* if you need building/renovation, or *LD* for events gear & packages.",
 )
 
-# ---------- ollama client ----------
-ollama_client = ollama.Client(host="http://localhost:11434")
-
-
-@lru_cache(maxsize=512)
-def fast_llm(prompt: str, max_new: int = 60) -> str:
-    """Call local Ollama model with a short prompt."""
-    try:
-        resp = ollama_client.generate(
-            model=OLLAMA_MODEL,
-            prompt=prompt[-512:],
-            options={
-                "temperature": 0.2,
-                "num_predict": max_new,
-                "stop": ["\n", "User:", "Human:"],
-            },
-        )
-        return resp["response"].strip()
-    except Exception as exc:
-        log.warning("ollama error: %s", exc)
-        return "Sorry, I am having trouble thinking right now."
-
-
-# ---------- chat memory ----------
-def get_last(user: str, n: int = 4) -> List[str]:
-    """Fetch last n messages for a user."""
-    if not supabase:
-        return []
-    try:
-        rows = (
-            supabase.table("chat_memory")
-            .select("role,message")
-            .eq("user_phone", user)
-            .order("created_at", desc=True)
-            .limit(n)
-            .execute()
-            .data
-        )[::-1]
-        return [f"{r['role']}: {r['message']}" for r in rows]
-    except Exception as exc:
-        log.warning("db read: %s", exc)
-        return []
-
-
-def save_msg(user: str, text: str, role: str = "assistant") -> None:
-    """Persist a single message."""
-    if not supabase:
-        return
-    try:
-        supabase.table("chat_memory").insert(
-            {"user_phone": user, "role": role.lower(), "message": text}
-        ).execute()
-    except Exception as exc:
-        log.warning("db write: %s", exc)
-
-
-# ---------- atomic retriever ----------
-@lru_cache(maxsize=1)
-def atomic_retriever():
-    """Hybrid dense + BM25 retriever over price lines."""
-    docs: List[Document] = []
-    svc_file = pathlib.Path("services.txt")
-    if svc_file.exists():
-        for line in svc_file.read_text(encoding="utf-8").splitlines():
-            line = line.strip()
-            if line and "KES" in line:
-                docs.append(Document(page_content=line))
-    if not docs:  # fallback
-        docs.append(
-            Document(page_content="LD Events handles events. Lamaki Designs handles interiors.")
-        )
-
-    dense = FAISS.from_documents(docs, EMBED).as_retriever(search_kwargs={"k": 5})
-    tokenized = [re.findall(r"\w+", d.page_content.lower()) for d in docs]
-    bm25 = BM25Okapi(tokenized)
-
-    def search(query: str) -> List[Document]:
-        dense_hits = dense.invoke(query)
-        scores = bm25.get_scores(re.findall(r"\w+", query.lower()))
-        top = np.argsort(scores)[-5:][::-1]
-        bm25_hits = [docs[i] for i in top if scores[i] > 0]
-        seen, out = set(), []
-        for doc in dense_hits + bm25_hits:
-            if doc.page_content not in seen:
-                out.append(doc)
-                seen.add(doc.page_content)
-        return out
-
-    return search
-
-
-search = atomic_retriever()
-
-
-# ---------- business logic ----------
-def company_greeting(company: str) -> str:
-    if company == "ld events":
-        return (
-            "🎤 Hey there! Welcome to LD Events – your ultimate sound partner. "
-            "How can we make your event unforgettable?"
-        )
-    return "🛋️ Hello! Lamaki Designs here – ready to transform your space. What are you dreaming of?"
-
-
-@lru_cache(maxsize=512)
-def smart_reply(text: str, user: str) -> str:
-    """Main reply logic."""
-    text_l = text.lower()
-    company = (
-        "ld events"
-        if any(
-            k in text_l
-            for k in [
-                "wedding",
-                "concert",
-                "live",
-                "stage",
-                "sound",
-                "ld events",
-                "speaker",
-                "line array",
-                "moving head",
-                "parcan",
-                "led screen",
-                "bronze",
-                "silver",
-                "gold",
-                "platinum",
-            ]
-        )
-        else "lamaki designs"
-    )
-
-    # 1. greetings
-    if any(k in text_l for k in ("hello", "hi", "hey", "jambo")):
-        return company_greeting(company)
-
-    # 2. pricing
-    if any(k in text_l for k in ("price", "cost", "how much", "hire", "rate", "quote")):
-        hits = search(text)
-        if not hits:
-            return "Which exact item or package would you like a quote for? (e.g. ‘line-array-top’ or ‘Silver-Package’)"
-        context = "\n".join(d.page_content for d in hits[:3])
-        prompt = (
-            f"Using ONLY the lines below, answer in one short sentence. "
-            f"Never invent prices. If the exact item is not listed, ask for clarification.\n\n"
-            f"Lines:\n{context}\n\nUser: {text}\nAssistant:"
-        )
-        return fast_llm(prompt, max_new=40)
-
-    # 3. generic chat
-    prompt = (
-        f"You are a lively Kenyan assistant for {company.title()}. "
-        f"Keep answers under 15 words, use emojis, no emails/phones.\nUser: {text}\nAssistant:"
-    )
-    return fast_llm(prompt, max_new=30)
-
-
-# ---------- web layer ----------
+# ==========================================================
+# 5.  SMALL-TALK (thanks, bye, ok)
+# ==========================================================
+add("thanks", "Karibu! Need anything else?", "You’re welcome – ready when you are.")
+add("bye", "Kwaheri – we’ll make it amazing!", "See you soon – have a great day.")
+add("ok", "Cool – next step?", "Alright – what else can we sort?")
+
+# ==========================================================
+# 6.  CANONICALISER
+# ==========================================================
+def detect_company_and_intent(text: str) -> tuple[str, str]:
+    t = re.sub(r"[^a-z0-9+]", " ", text.lower()).strip()
+    # company
+    if any(k in t for k in ("lamaki", "construction", "renovation", "build", "house", "bungalow", "townhouse", "kitchen", "bathroom", "roofing", "interior", "cabinet", "wardrobe")):
+        company = "lamaki"
+    elif any(k in t for k in ("ld", "event", "sound", "light", "tent", "stage", "speaker", "mic", "wedding", "concert", "dj", "led", "screen", "decor", "floral", "carpet")):
+        company = "ld"
+    else:
+        company = "default"  # will send greeting
+
+    # intent
+    if any(k in t for k in ("location", "yard", "showroom", "visit", "checkout", "inspect", "utawala", "githunguri")):
+        return company, "location+checkout"
+    if any(k in t for k in ("price", "cost", "how much", "quote")):
+        return company, "price"
+    if any(k in t for k in ("date", "when", "which day", "what day")):
+        return company, "date"
+    if any(k in t for k in ("pay", "mpesa", "send", "lock", "book", "reserve", "today", "now")):
+        if "today" in t or "now" in t:
+            return company, "pay+today"
+        if "deposit" in t:
+            return company, "deposit"
+        if "later" in t or "tomorrow" in t:
+            return company, "pay+later"
+        return company, "pay+today"
+    if any(k in t for k in ("paid", "sent", "done")):
+        return company, "paid"
+    if "receipt" in t or "forward" in t:
+        return company, "receipt"
+    if any(k in t for k in ("thanks", "asante")):
+        return company, "thanks"
+    if any(k in t for k in ("bye", "goodbye", "see you")):
+        return company, "bye"
+    if "ok" in t or "cool" in t:
+        return company, "ok"
+    if any(k in t for k in ("hello", "hi", "hey", "jambo")):
+        return company, "greeting"
+    return company, "price"  # drive to price by default
+
+
+def secretary_reply(text: str) -> str:
+    company, intent = detect_company_and_intent(text)
+    key = f"{company}+{intent}"
+    if key in REPLIES:
+        return rand(key)
+    # fallback chain
+    for fall in (f"{company}+price", f"{company}+date", "default+greeting"):
+        if fall in REPLIES:
+            return rand(fall)
+    return "Please text *LD* for events or *LAMAKI* for construction – we’ll sort you instantly."
+
+
+# ==========================================================
+# 7.  WEBHOOK
+# ==========================================================
 app = Flask(__name__)
 
 
 @app.post("/whatsapp")
 def whatsapp():
-    """Webhook entry point."""
     if request.json.get("verify") != VERIFY_TOKEN:
         return jsonify(error="bad token"), 403
     user = request.json.get("from", "unknown")
     msg = request.json.get("text", "").strip()
+    if not msg:
+        return jsonify(reply="Kindly send a text message.")
     save_msg(user, msg, "user")
-    ans = smart_reply(msg, user)
+    ans = secretary_reply(msg)
     save_msg(user, ans, "assistant")
     return jsonify(reply=ans)
 
@@ -227,5 +259,4 @@ def health():
 
 
 if __name__ == "__main__":
-    # dev only – docker uses gunicorn
     app.run(host="0.0.0.0", port=7860, threaded=True)