Update app.py

app.py

@@ -1,97 +1,260 @@
 from flask import Flask, request, jsonify
 import requests
 import base64
-import os
 import logging
 
 app = Flask(__name__)
-
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
-# Environment variables (set these in Hugging Face Secrets)
-SLACK_TOKEN ="xoxb-7025747032292-10683671864694-lhUNPKF1KSpYwRvrvZeP7CPy"
-CW_COMPANY_ID = "Intrinsic"
-CW_PUBLIC_KEY = "IkrljDywPCSE4s10"
-CW_PRIVATE_KEY = "kOwo89oUO6SVVSYi"
-CW_CLIENT_ID = "e45cf35f-24a8-4f5f-b47a-19376cafce64"
-
-BASE_URL = "https://api-na.myconnectwise.net/v4_6_release/apis/3.0"
+# ── Credentials ────────────────────────────────────────────────────────────────
+SLACK_TOKEN     = "xoxb-7025747032292-10683671864694-lhUNPKF1KSpYwRvrvZeP7CPy"
+CW_COMPANY_ID   = "Intrinsic"
+CW_PUBLIC_KEY   = "IkrljDywPCSE4s10"
+CW_PRIVATE_KEY  = "kOwo89oUO6SVVSYi"
+CW_CLIENT_ID    = "e45cf35f-24a8-4f5f-b47a-19376cafce64"
+BASE_URL        = "https://api-na.myconnectwise.net/v4_6_release/apis/3.0"
 
-auth = f"{CW_COMPANY_ID}+{CW_PUBLIC_KEY}:{CW_PRIVATE_KEY}"
+auth         = f"{CW_COMPANY_ID}+{CW_PUBLIC_KEY}:{CW_PRIVATE_KEY}"
 encoded_auth = base64.b64encode(auth.encode()).decode()
 
-cw_headers = {
+CW_HEADERS = {
     "Authorization": f"Basic {encoded_auth}",
-    "ClientID": CW_CLIENT_ID,
-    "Content-Type": "application/json"
+    "ClientID":      CW_CLIENT_ID,
+    "Content-Type":  "application/json",
 }
 
+# ── Fallback name lists (tried in order) ───────────────────────────────────────
+BOARD_FALLBACKS    = ["Service Desk", "Help Desk", "Support", "Technical Support",
+                      "IT Support", "Service Board", "Default", "General"]
+COMPANY_FALLBACKS  = ["Intrinsic", "intrinsic", "INTRINSIC", "IntrinsicIT",
+                      "intrinsicit", "Intrinsic IT"]
+PRIORITY_FALLBACKS = ["Priority 1", "P1", "High", "Critical", "Urgent",
+                      "Medium", "Normal", "Low", "Priority 2", "Priority 3"]
 
-@app.route("/")
-def home():
-    return "Slack → ConnectWise Bot Running"
 
+# ── Discovery helpers ──────────────────────────────────────────────────────────
 
-def create_ticket(issue):
+def discover_boards():
+    """Return list of active service board names from ConnectWise."""
+    try:
+        r = requests.get(
+            f"{BASE_URL}/service/boards",
+            headers=CW_HEADERS,
+            params={"conditions": "inactive=false", "pageSize": 50},
+            timeout=10,
+        )
+        if r.status_code == 200:
+            names = [b.get("name") for b in r.json() if b.get("name")]
+            logger.info("Discovered boards: %s", names)
+            return names
+    except Exception as e:
+        logger.warning("Board discovery failed: %s", e)
+    return []
 
-    ticket = {
-    "summary": issue[:100],
-    "initialDescription": issue,
-    "board": {"name": "Service Desk"},
-    "company": {"identifier": "Intrinsic"},
-    "priority": {"name": "Priority 1"}
-}
 
+def discover_companies():
+    """Return list of company identifiers from ConnectWise."""
+    try:
+        r = requests.get(
+            f"{BASE_URL}/company/companies",
+            headers=CW_HEADERS,
+            params={"pageSize": 50},
+            timeout=10,
+        )
+        if r.status_code == 200:
+            ids = [c.get("identifier") for c in r.json() if c.get("identifier")]
+            logger.info("Discovered companies: %s", ids)
+            return ids
+    except Exception as e:
+        logger.warning("Company discovery failed: %s", e)
+    return []
+
+
+def discover_priorities():
+    """Return list of priority names from ConnectWise."""
+    try:
+        r = requests.get(
+            f"{BASE_URL}/service/priorities",
+            headers=CW_HEADERS,
+            params={"pageSize": 50},
+            timeout=10,
+        )
+        if r.status_code == 200:
+            names = [p.get("name") for p in r.json() if p.get("name")]
+            logger.info("Discovered priorities: %s", names)
+            return names
+    except Exception as e:
+        logger.warning("Priority discovery failed: %s", e)
+    return []
+
+
+def best_match(discovered, fallbacks):
+    """
+    Return the first discovered value that appears in fallbacks (case-insensitive),
+    then the first discovered value, then the first fallback.
+    """
+    lower_disc = {d.lower(): d for d in discovered}
+    for f in fallbacks:
+        if f.lower() in lower_disc:
+            return lower_disc[f.lower()]
+    if discovered:
+        return discovered[0]
+    return fallbacks[0]   # last resort: just try the first hardcoded name
+
+
+# ── Ticket creation with progressive fallbacks ─────────────────────────────────
+
+def try_create(payload):
     r = requests.post(
         f"{BASE_URL}/service/tickets",
-        headers=cw_headers,
-        json=ticket
+        headers=CW_HEADERS,
+        json=payload,
+        timeout=10,
+    )
+    logger.info("CW status=%s body=%s", r.status_code, r.text[:300])
+    return r
+
+
+def create_ticket(issue):
+    # ── Step 1: discover real values ─────────────────────────────────────────
+    boards     = discover_boards()
+    companies  = discover_companies()
+    priorities = discover_priorities()
+
+    board_name    = best_match(boards,     BOARD_FALLBACKS)
+    company_id    = best_match(companies,  COMPANY_FALLBACKS)
+    priority_name = best_match(priorities, PRIORITY_FALLBACKS)
+
+    logger.info("Using board=%s company=%s priority=%s",
+                board_name, company_id, priority_name)
+
+    # ── Step 2: full payload ──────────────────────────────────────────────────
+    full_payload = {
+        "summary":            issue[:100],
+        "initialDescription": issue,
+        "board":    {"name":       board_name},
+        "company":  {"identifier": company_id},
+        "priority": {"name":       priority_name},
+    }
+    r = try_create(full_payload)
+    if r.status_code in (200, 201):
+        return r.json().get("id"), board_name
+
+    # ── Step 3: try every discovered board one-by-one ────────────────────────
+    for b in boards:
+        if b == board_name:
+            continue
+        payload = {**full_payload, "board": {"name": b}}
+        r = try_create(payload)
+        if r.status_code in (200, 201):
+            return r.json().get("id"), b
+
+    # ── Step 4: drop priority (might be wrong) ────────────────────────────────
+    logger.warning("Retrying without priority field")
+    no_priority = {k: v for k, v in full_payload.items() if k != "priority"}
+    r = try_create(no_priority)
+    if r.status_code in (200, 201):
+        return r.json().get("id"), board_name
+
+    # ── Step 5: drop company too ──────────────────────────────────────────────
+    logger.warning("Retrying without company or priority")
+    minimal_board = {
+        "summary":            issue[:100],
+        "initialDescription": issue,
+        "board":              {"name": board_name},
+    }
+    r = try_create(minimal_board)
+    if r.status_code in (200, 201):
+        return r.json().get("id"), board_name
+
+    # ── Step 6: bare minimum — just summary ───────────────────────────────────
+    logger.warning("Retrying with bare minimum payload")
+    bare = {"summary": issue[:100], "initialDescription": issue}
+    r = try_create(bare)
+    if r.status_code in (200, 201):
+        return r.json().get("id"), "default"
+
+    logger.error("All ticket creation attempts failed")
+    return None, None
+
+
+# ── Slack helpers ──────────────────────────────────────────────────────────────
+
+def send_slack(channel, text):
+    requests.post(
+        "https://slack.com/api/chat.postMessage",
+        headers={
+            "Authorization": f"Bearer {SLACK_TOKEN}",
+            "Content-Type":  "application/json",
+        },
+        json={"channel": channel, "text": text},
+        timeout=10,
     )
 
-    logger.info("ConnectWise status: %s", r.status_code)
-    logger.info("ConnectWise response: %s", r.text)
 
-    if r.status_code in [200, 201]:
-        return r.json().get("id")
+# ── Routes ─────────────────────────────────────────────────────────────────────
+
+@app.route("/")
+def home():
+    return "Slack → ConnectWise Bot Running ✅"
+
+
+@app.route("/debug/cw", methods=["GET"])
+def debug_cw():
+    """
+    Hit /debug/cw in your browser to see exactly what boards / companies /
+    priorities exist in your ConnectWise instance.
+    """
+    return jsonify({
+        "boards":     discover_boards(),
+        "companies":  discover_companies(),
+        "priorities": discover_priorities(),
+    })
+
 
-    return "error"
 @app.route("/slack/events", methods=["POST"])
 def slack_events():
-
     data = request.get_json()
-    logger.info("Slack payload: %s", data)
+    logger.info("Slack payload type=%s", data.get("type"))
 
+    # URL verification handshake
     if data.get("type") == "url_verification":
         return jsonify({"challenge": data.get("challenge")})
 
     event = data.get("event", {})
 
-    # Ignore bot messages
-    if event.get("bot_id"):
+    # Ignore bot messages to prevent loops
+    if event.get("bot_id") or event.get("subtype") == "bot_message":
         return "", 200
 
     if event.get("type") == "message":
-
-        text = event.get("text")
+        text    = event.get("text", "")
         channel = event.get("channel")
 
-        # Remove bot mention
+        # Strip bot mention
         text = text.replace("<@U0AL3KRRELE>", "").strip()
+        if not text:
+            return "", 200
+
+        ticket_id, board_used = create_ticket(text)
+
+        if ticket_id:
+            reply = (
+                f"✅ Support ticket created!\n"
+                f"🎫 Ticket ID: `{ticket_id}`\n"
+                f"📋 Board: {board_used}"
+            )
+        else:
+            reply = (
+                "⚠️ Could not create a ConnectWise ticket right now.\n"
+                "Please contact support directly or try again shortly."
+            )
+
+        send_slack(channel, reply)
+
+    return "", 200
 
-        ticket_id = create_ticket(text)
-
-        # Send reply to Slack
-        requests.post(
-            "https://slack.com/api/chat.postMessage",
-            headers={
-                "Authorization": f"Bearer {SLACK_TOKEN}",
-                "Content-Type": "application/json"
-            },
-            json={
-                "channel": channel,
-                "text": f"🎫 Support ticket created\nTicket ID: {ticket_id}"
-            }
-        )
 
-    return "", 200
+if __name__ == "__main__":
+    app.run(host="0.0.0.0", port=7860)