(db: &SqlitePool, session_id: &str)
| 70 | } |
| 71 | |
| 72 | pub async fn get_messages(db: &SqlitePool, session_id: &str) -> AppResult<Vec<Message>> { |
| 73 | let messages = sqlx::query_as::<_, Message>( |
| 74 | "SELECT id, session_id, role, content, created_at FROM messages \ |
| 75 | WHERE session_id = ?1 ORDER BY created_at ASC", |
| 76 | ) |
| 77 | .bind(session_id) |
| 78 | .fetch_all(db) |
| 79 | .await?; |
| 80 | |
| 81 | Ok(messages) |
| 82 | } |
| 83 | |
| 84 | /// Return a trimmed conversation window suitable for sending to the LLM. |
| 85 | /// |
no outgoing calls
no test coverage detected