Function test_metadata_store_crud

core/src/memory/store.rs:360–414

()

    #[tokio::test]
    async fn test_metadata_store_crud() {
        let store = MetadataStore::new(":memory:").expect("should create in-memory store");

        // Insert
        let id = MemoryId::new();
        let memory = Memory {
            id: id.clone(),
            content: "User lives in Munich".to_string(),
            scope: MemoryScope {
                user_id: Some("user1".to_string()),
                agent_id: None,
                run_id: None,
            },
            metadata: HashMap::new(),
            created_at: chrono::Utc::now(),
            updated_at: chrono::Utc::now(),
            hash: "abc123".to_string(),
        };
        store
            .insert_memory(&memory)
            .await
            .expect("insert should succeed");

        // Get
        let fetched = store
            .get_memory(&id)
            .await
            .expect("get should succeed")
            .expect("memory should exist");
        assert_eq!(fetched.content, "User lives in Munich");
        assert_eq!(fetched.scope.user_id.as_deref(), Some("user1"));

        // Update
        store
            .update_memory(&id, "User lives in Berlin", "def456")
            .await
            .expect("update should succeed");
        let updated = store
            .get_memory(&id)
            .await
            .expect("get should succeed")
            .expect("memory should exist");
        assert_eq!(updated.content, "User lives in Berlin");

        // Delete
        store
            .delete_memory(&id)
            .await
            .expect("delete should succeed");
        let gone = store
            .get_memory(&id)
            .await
            .expect("get should succeed");
        assert!(gone.is_none());
    }

    #[tokio::test]
    async fn test_metadata_store_scope_filtering() {