Sweep: add a new webhook endpoint to receive events from Linear. Users should be allowed to tag a linear ticket with the Sweep label and invoke Sweep.

sweepai/api.py

@@ -56,7 +56,8 @@
     on_check_suite,
 )
 from sweepai.handlers.on_comment import on_comment
-from sweepai.handlers.on_jira_ticket import handle_jira_ticket
+
+from sweepai.handlers.on_linear_ticket import handle_linear_ticket
 from sweepai.handlers.on_ticket import on_ticket
 from sweepai.handlers.stack_pr import stack_pr
 from sweepai.utils.buttons import (
@@ -330,14 +331,14 @@ def webhook(
         logger.info(f"Received event: {x_github_event}, {action}")
         return handle_request(request_dict, event=x_github_event)
 
-@app.post("/jira")
-def jira_webhook(
+@app.post("/linear")  
+def linear_webhook(
     request_dict: dict = Body(...),
 ) -> None:
-    def call_jira_ticket(*args, **kwargs):
-        thread = threading.Thread(target=handle_jira_ticket, args=args, kwargs=kwargs)
+    def call_linear_ticket(*args, **kwargs):
+        thread = threading.Thread(target=handle_linear_ticket, args=args, kwargs=kwargs)
         thread.start()
-    call_jira_ticket(event=request_dict)
+    call_linear_ticket(event=request_dict)
 
 # Set up cronjob for this
 @app.get("/update_sweep_prs_v2")

sweepai/config/server.py

@@ -197,9 +197,12 @@
 DEPLOYMENT_GHA_ENABLED = os.environ.get("DEPLOYMENT_GHA_ENABLED", "true").lower() == "true"
 
 JIRA_USER_NAME = os.environ.get("JIRA_USER_NAME", None)
-JIRA_API_TOKEN = os.environ.get("JIRA_API_TOKEN", None)
+JIRA_API_TOKEN = os.environ.get("JIRA_API_TOKEN", None)  
 JIRA_URL = os.environ.get("JIRA_URL", None)
 
+LINEAR_API_KEY = os.environ.get("LINEAR_API_KEY", None)
+LINEAR_LABEL_NAME = os.environ.get("LINEAR_LABEL_NAME", "sweep")
+
 SLACK_API_KEY = os.environ.get("SLACK_API_KEY", None)
 
 LICENSE_KEY = os.environ.get("LICENSE_KEY", None)

sweepai/handlers/on_linear_ticket.py

@@ -0,0 +1,31 @@
+import os
+from typing import Any, Dict
+
+from loguru import logger
+from sweepai.handlers.on_ticket import on_ticket
+
+LINEAR_LABEL_NAME = os.environ.get("LINEAR_LABEL_NAME", "sweep")
+
+def handle_linear_ticket(event: Dict[str, Any]):
+    try:
+        ticket_data = event["data"]
+        ticket_labels = ticket_data.get("labels", [])
+
+        if any(label["name"].lower() == LINEAR_LABEL_NAME.lower() for label in ticket_labels):
+            logger.info(f"Sweep label detected on Linear ticket {ticket_data['id']}")
+
+            on_ticket(
+                title=ticket_data["title"],
+                summary=ticket_data["description"],
+                issue_number=ticket_data["number"], 
+                issue_url=ticket_data["url"],
+                username=ticket_data["creator"]["name"],
+                repo_full_name="linear_repo", # TODO: Map Linear team to GitHub repo  
+                repo_description="",
+                installation_id=0, # TODO: Get GitHub app installation ID
+            )
+        else:
+            logger.info(f"Sweep label not found on Linear ticket {ticket_data['id']}")
+
+    except Exception as e:
+        logger.exception(f"Error processing Linear webhook event: {e}")