riotpiao-poimen/poimen-memory
2
0
Fork 0
Code Issues 12 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test: production ingest E2E test suite with enhanced logging #55

Open
poimen wants to merge 34 commits from feat/production-ingest-test-logging into main
pull from: feat/production-ingest-test-logging
merge into: :main
Conversation 2 Commits 34 Files Changed 74
+6 -6
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit b36327948d - Show all commits
crates/mem-cli/src/handlers/agent_handler.rs
+3 -3
View File
@@ -390,7 +390,7 @@ pub struct PromptResponse {
pub created_at: String, pub created_at: String,
} }
/// POST /memory/agents/{project_id}/prompts - Create agent prompt /// POST /agents/{id}/prompts - Create agent prompt
pub async fn create_prompt_handler( pub async fn create_prompt_handler(
req: HttpRequest, req: HttpRequest,
path: web::Path<String>, path: web::Path<String>,
@@ -462,7 +462,7 @@ pub struct MapRoleToPromptRequest {
pub priority: Option<i32>, pub priority: Option<i32>,
} }
/// POST /memory/agents/{project_id}/roles - Map role to prompt /// POST /agents/{id}/roles - Map role to prompt
pub async fn map_role_to_prompt_handler( pub async fn map_role_to_prompt_handler(
req: HttpRequest, req: HttpRequest,
path: web::Path<String>, path: web::Path<String>,
@@ -548,7 +548,7 @@ pub struct RolePromptsResponse {
pub prompts: Vec<PromptResponse>, pub prompts: Vec<PromptResponse>,
} }
/// GET /memory/agents/{project_id}/roles/{role_name}/prompts - Get prompts for role /// GET /agents/{id}/roles/{role_name}/prompts - Get prompts for role
pub async fn get_role_prompts_handler( pub async fn get_role_prompts_handler(
req: HttpRequest, req: HttpRequest,
path: web::Path<(String, String)>, path: web::Path<(String, String)>,
crates/mem-cli/src/http_server.rs
+3 -3
View File
@@ -440,9 +440,9 @@ pub async fn start_server(port: u16, api_key: String, database_url: &str) -> Res
.route("/agents/{id}", web::put().to(crate::handlers::agent_handler::update_agent_handler)) .route("/agents/{id}", web::put().to(crate::handlers::agent_handler::update_agent_handler))
.route("/agents/{id}", web::delete().to(crate::handlers::agent_handler::delete_agent_handler)) .route("/agents/{id}", web::delete().to(crate::handlers::agent_handler::delete_agent_handler))
.route("/agents/{id}/metrics", web::get().to(crate::handlers::agent_handler::get_agent_metrics_handler)) .route("/agents/{id}/metrics", web::get().to(crate::handlers::agent_handler::get_agent_metrics_handler))
.route("/memory/agents/{project_id}/prompts", web::post().to(crate::handlers::agent_handler::create_prompt_handler)) .route("/agents/{id}/prompts", web::post().to(crate::handlers::agent_handler::create_prompt_handler))
.route("/memory/agents/{project_id}/roles", web::post().to(crate::handlers::agent_handler::map_role_to_prompt_handler)) .route("/agents/{id}/roles", web::post().to(crate::handlers::agent_handler::map_role_to_prompt_handler))
.route("/memory/agents/{project_id}/roles/{role_name}/prompts", web::get().to(crate::handlers::agent_handler::get_role_prompts_handler)) .route("/agents/{id}/roles/{role_name}/prompts", web::get().to(crate::handlers::agent_handler::get_role_prompts_handler))
}); });
tracing::info!("HttpServer instance created, binding to 0.0.0.0:{}", port); tracing::info!("HttpServer instance created, binding to 0.0.0.0:{}", port);