(&self, session_id: &str)
| 567 | } |
| 568 | |
| 569 | pub async fn delete_for_session(&self, session_id: &str) -> Result<(), DatabaseError> { |
| 570 | sqlx::query("DELETE FROM messages WHERE session_id = ?") |
| 571 | .bind(session_id) |
| 572 | .execute(&self.pool) |
| 573 | .await |
| 574 | .map_err(|e| DatabaseError::QueryError(e.to_string()))?; |
| 575 | |
| 576 | Ok(()) |
| 577 | } |
| 578 | } |
| 579 | |
| 580 | #[derive(Debug, Clone, Serialize, Deserialize)] |
no test coverage detected