Fix stuff

Author: Monster0506

ticket-backend/app/models/__init__.py

@@ -16,6 +16,7 @@
     DiscordContent,
     GitHubContent,
     FormContent,
+    SMSContent,
     content_from_dict,
 )
 from .ticket import Ticket, InvalidStateTransitionError
@@ -39,6 +40,7 @@
     "DiscordContent",
     "GitHubContent",
     "FormContent",
+    "SMSContent",
     "content_from_dict",
     # Ticket
     "Ticket",

ticket-backend/app/models/content.py

@@ -395,6 +395,87 @@ def from_dict(cls, data: dict[str, Any]) -> "FormContent":
         )
 
 
+class SMSContent(TicketContent):
+    """Content from SMS messages."""
+
+    def __init__(
+        self,
+        sender_phone_number: str,
+        message_body: str,
+        timestamp: datetime,
+        message_sid: Optional[str] = None,
+    ):
+        self._sender_phone_number = sender_phone_number
+        self._recipient_phone_number = recipient_phone_number
+        self._message_body = message_body
+        self._timestamp = timestamp
+        self._message_sid = message_sid
+
+    @property
+    def raw_content(self) -> str:
+        return self._message_body
+
+    @property
+    def sender(self) -> str:
+        return self._sender_phone_number
+
+    @property
+    def timestamp(self) -> datetime:
+        return self._timestamp
+
+    @property
+    def metadata(self) -> dict[str, Any]:
+        return {
+            "recipient_phone_number": self._recipient_phone_number,
+            "message_sid": self._message_sid,
+        }
+
+    @property
+    def sender_phone_number(self) -> str:
+        return self._sender_phone_number
+    
+    @property
+    def recipient_phone_number(self) -> str:
+        return self._recipient_phone_number
+
+    @property
+    def message_body(self) -> str:
+        return self._message_body
+    
+    @property
+    def message_sid(self) -> Optional[str]:
+        return self._message_sid
+
+    def extract_body(self) -> str:
+        return self._message_body
+
+    def extract_attachments(self) -> list[dict[str, Any]]:
+        return []
+
+    def to_dict(self) -> dict[str, Any]:
+        return {
+            "type": "sms",
+            "sender_phone_number": self._sender_phone_number,
+            "recipient_phone_number": self._recipient_phone_number,
+            "message_body": self._message_body,
+            "timestamp": self._timestamp.isoformat(),
+            "message_sid": self._message_sid,
+        }
+
+    @classmethod
+    def from_dict(cls, data: dict[str, Any]) -> "SMSContent":
+        timestamp = data.get("timestamp")
+        if isinstance(timestamp, str):
+            timestamp = datetime.fromisoformat(timestamp.replace("Z", "+00:00"))
+        return cls(
+            sender_phone_number=data["sender_phone_number"],
+            recipient_phone_number=data["recipient_phone_number"],
+            message_body=data["message_body"],
+            timestamp=timestamp,
+            message_sid=data.get("message_sid"),
+        )
+
+
 def content_from_dict(data: dict[str, Any]) -> TicketContent:
     """Factory function to create the appropriate content type from a dictionary."""
     content_type = data.get("type", "").lower()
@@ -407,5 +488,7 @@ def content_from_dict(data: dict[str, Any]) -> TicketContent:
         return GitHubContent.from_dict(data)
     elif content_type == "form":
         return FormContent.from_dict(data)
+    elif content_type == "sms":
+        return SMSContent.from_dict(data)
     else:
         raise ValueError(f"Unknown content type: {content_type}")

ticket-backend/app/models/enums.py

@@ -53,6 +53,7 @@ class TicketSource(str, Enum):
     GITHUB = "GITHUB"
     FORM = "FORM"
     WEBHOOK = "WEBHOOK"
+    SMS = "SMS"
 
 
 class AutoResolveAction(str, Enum):

ticket-backend/app/routes/tickets.py

@@ -19,7 +19,9 @@
     EmailContent,
     DiscordContent,
     GitHubContent,
+    GitHubContent,
     FormContent,
+    SMSContent,
 )
 from app.storage import ticket_repository
 from app.queues import queue_manager
@@ -83,6 +85,19 @@ class Config:
         populate_by_name = True
 
 
+class SMSPayload(BaseModel):
+    """SMS content payload (e.g. from Twilio)."""
+
+    sender: str = Field(..., alias="From")
+    recipient: str = Field(..., alias="To")
+    body: str = Field(..., alias="Body")
+    message_sid: Optional[str] = Field(None, alias="MessageSid")
+    timestamp: Optional[str] = None
+
+    class Config:
+        populate_by_name = True
+
+
 class IngestRequest(BaseModel):
     """Request body for ticket ingestion."""
 
@@ -220,6 +235,20 @@ def create_content_from_payload(content_type: str, payload: dict[str, Any]):
             submitter_email=payload.get("submitter_email"),
             submitter_name=payload.get("submitter_name", payload.get("user")),
         )
+    elif content_type == "sms":
+        return SMSContent(
+            sender_phone_number=payload.get(
+                "From", payload.get("sender", payload.get("subject", ""))
+            ),
+            recipient_phone_number=payload.get(
+                "To", payload.get("recipient", payload.get("user", ""))
+            ),
+            message_body=payload.get("Body", payload.get("body", "")),
+            timestamp=parse_timestamp(payload.get("timestamp")),
+            message_sid=payload.get(
+                "MessageSid", payload.get("message_id", payload.get("id"))
+            ),
+        )
     else:
         raise ValueError(f"Unknown content type: {content_type}")
 

ticket-frontend/src/lib/api/client.ts

@@ -9,7 +9,7 @@ export interface BackendTicket {
   id: string;
   created_at: string;
   updated_at: string;
-  source: 'EMAIL' | 'DISCORD' | 'GITHUB' | 'FORM' | 'WEBHOOK';
+  source: 'EMAIL' | 'DISCORD' | 'GITHUB' | 'FORM' | 'WEBHOOK' | 'SMS';
   priority: 'LOW' | 'MEDIUM' | 'HIGH' | 'CRITICAL';
   category: 'BILLING' | 'TECHNICAL_SUPPORT' | 'FEATURE_REQUEST' | 'BUG_REPORT' | 'ADMIN' | 'OTHER' | null;
   status: 'INBOX' | 'TRIAGE_PENDING' | 'ASSIGNED' | 'IN_PROGRESS' | 'RESOLVED' | 'CLOSED';
@@ -321,7 +321,7 @@ export async function getAgentStats(agentId: string): Promise<{
 }
 
 export async function createTicket(ticketData: {
-  source: 'EMAIL' | 'DISCORD' | 'GITHUB' | 'FORM' | 'WEBHOOK';
+  source: 'EMAIL' | 'DISCORD' | 'GITHUB' | 'FORM' | 'WEBHOOK' | 'SMS';
   content_type: string;
   payload: Record<string, any>;
   metadata?: Record<string, any>;