apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-06-08 20:25:19 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat: add Linear write mutations to LinearConnector

Browse source
This commit is contained in:
CREDO23 2026-02-18 16:53:21 +02:00
parent 594379ea69
commit 50868f32d4
1 changed files with 102 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

102
surfsense_backend/app/connectors/linear_connector.py
View file

@ -588,6 +588,108 @@ class LinearConnector:
return formatted
async def create_issue(
self,
team_id: str,
title: str,
description: str | None = None,
state_id: str | None = None,
assignee_id: str | None = None,
priority: int | None = None,
label_ids: list[str] | None = None,
) -> dict[str, Any]:
mutation = """
mutation IssueCreate($input: IssueCreateInput!) {
issueCreate(input: $input) {
success
issue { id identifier title url }
}
}
"""
input_data: dict[str, Any] = {"teamId": team_id, "title": title}
if description is not None:
input_data["description"] = description
if state_id is not None:
input_data["stateId"] = state_id
if assignee_id is not None:
input_data["assigneeId"] = assignee_id
if priority is not None:
input_data["priority"] = priority
if label_ids:
input_data["labelIds"] = label_ids
result = await self.execute_graphql_query(mutation, {"input": input_data})
payload = result.get("data", {}).get("issueCreate", {})
if not payload.get("success"):
errors = result.get("errors", [])
msg = (
errors[0].get("message", "Unknown error") if errors else "Unknown error"
)
raise Exception(f"issueCreate failed: {msg}")
return payload.get("issue", {})
async def update_issue(
self,
issue_id: str,
title: str | None = None,
description: str | None = None,
state_id: str | None = None,
assignee_id: str | None = None,
priority: int | None = None,
label_ids: list[str] | None = None,
) -> dict[str, Any]:
mutation = """
mutation IssueUpdate($id: String!, $input: IssueUpdateInput!) {
issueUpdate(id: $id, input: $input) {
success
issue { id identifier title url }
}
}
"""
input_data: dict[str, Any] = {}
if title is not None:
input_data["title"] = title
if description is not None:
input_data["description"] = description
if state_id is not None:
input_data["stateId"] = state_id
if assignee_id is not None:
input_data["assigneeId"] = assignee_id
if priority is not None:
input_data["priority"] = priority
if label_ids is not None:
input_data["labelIds"] = label_ids
result = await self.execute_graphql_query(
mutation, {"id": issue_id, "input": input_data}
)
payload = result.get("data", {}).get("issueUpdate", {})
if not payload.get("success"):
errors = result.get("errors", [])
msg = (
errors[0].get("message", "Unknown error") if errors else "Unknown error"
)
raise Exception(f"issueUpdate failed: {msg}")
return payload.get("issue", {})
async def archive_issue(self, issue_id: str) -> bool:
mutation = """
mutation IssueArchive($id: String!) {
issueArchive(id: $id) {
success
}
}
"""
result = await self.execute_graphql_query(mutation, {"id": issue_id})
payload = result.get("data", {}).get("issueArchive", {})
if not payload.get("success"):
errors = result.get("errors", [])
msg = (
errors[0].get("message", "Unknown error") if errors else "Unknown error"
)
raise Exception(f"issueArchive failed: {msg}")
return True
def format_issue_to_markdown(self, issue: dict[str, Any]) -> str:
"""
Convert an issue to markdown format.