()
| 101 | |
| 102 | #[tokio::test] |
| 103 | async fn test_add_comment() { |
| 104 | run_test(async { |
| 105 | let (context_manager, _recv) = ContextManager::new().await; |
| 106 | let id: String; |
| 107 | |
| 108 | '_preparation_block: { |
| 109 | let mut uow = |
| 110 | UnitOfWork::<Repository<BoardAggregate>>::new(context_manager.clone()) |
| 111 | .await |
| 112 | .unwrap(); |
| 113 | |
| 114 | let mut board_aggregate = board_create_helper(BoardState::Published); |
| 115 | id = uow.repository().add(&mut board_aggregate).await.unwrap(); |
| 116 | assert_eq!(board_aggregate.board.id.to_string(), id); |
| 117 | uow.commit().await.unwrap(); |
| 118 | } |
| 119 | |
| 120 | '_test_block: { |
| 121 | let cmd = AddComment { |
| 122 | board_id: Uuid::from_str(&id).unwrap(), |
| 123 | author: Uuid::new_v4(), |
| 124 | content: "What a beautiful day!".to_string(), |
| 125 | }; |
| 126 | ServiceHandler::add_comment(cmd, context_manager.clone()) |
| 127 | .await |
| 128 | .unwrap(); |
| 129 | let mut uow = |
| 130 | UnitOfWork::<Repository<BoardAggregate>>::new(context_manager.clone()) |
| 131 | .await |
| 132 | .unwrap(); |
| 133 | if let Ok(board_aggregate) = uow.repository().get(&id).await { |
| 134 | assert_eq!(board_aggregate.comments.len(), 1); |
| 135 | }; |
| 136 | } |
| 137 | }) |
| 138 | .await; |
| 139 | } |
| 140 | } |
nothing calls this directly
no test coverage detected