(row: SqliteRow)
| 249 | } |
| 250 | |
| 251 | fn map_agent(row: SqliteRow) -> Result<Agent> { |
| 252 | Ok(Agent { |
| 253 | id: row.try_get("id")?, |
| 254 | name: row.try_get("name")?, |
| 255 | description: row.try_get("description")?, |
| 256 | executor_type: row.try_get("executor_type")?, |
| 257 | model: row.try_get("model")?, |
| 258 | reasoning_effort: row.try_get("reasoning_effort")?, |
| 259 | permission_policy: row.try_get("permission_policy")?, |
| 260 | prompt_template: row.try_get("prompt_template")?, |
| 261 | capabilities_json: row.try_get("capabilities_json")?, |
| 262 | config_json: row.try_get("config_json")?, |
| 263 | daemon_id: row.try_get("daemon_id")?, |
| 264 | max_concurrent_tasks: row.try_get("max_concurrent_tasks")?, |
| 265 | heartbeat_interval_seconds: row.try_get("heartbeat_interval_seconds")?, |
| 266 | max_missed_heartbeats: row.try_get("max_missed_heartbeats")?, |
| 267 | status: parse_enum(row.try_get::<String, _>("status")?)?, |
| 268 | last_heartbeat_at: row.try_get("last_heartbeat_at")?, |
| 269 | is_default: row.try_get::<i64, _>("is_default")? != 0, |
| 270 | paused: row.try_get::<i64, _>("paused")? != 0, |
| 271 | owner_id: row.try_get("owner_id")?, |
| 272 | visibility: row.try_get::<String, _>("visibility")?, |
| 273 | version: row.try_get("version")?, |
| 274 | created_at: row.try_get("created_at")?, |
| 275 | updated_at: row.try_get("updated_at")?, |
| 276 | }) |
| 277 | } |
| 278 | |
| 279 | fn map_workspace(row: SqliteRow) -> Result<Workspace> { |
| 280 | Ok(Workspace { |
nothing calls this directly
no test coverage detected