Function create_event_twice

api/src/tests.rs:255–308

()

#[test(tokio::test)]
async fn create_event_twice() {
    let node_id = NodeKey::random().id();
    let network = Network::Mainnet;
    let expected_event_id =
        EventId::try_from(hex::decode(UNSIGNED_INIT_EVENT_ID).unwrap()).unwrap();

    // Remove whitespace from event CAR file
    let event_data = UNSIGNED_INIT_EVENT_CAR
        .chars()
        .filter(|c| !c.is_whitespace())
        .collect::<String>();
    let mock_interest = MockAccessInterestStoreTest::new();
    let mut mock_event_store = MockEventStoreTest::new();
    let item = ApiItem::new(
        expected_event_id,
        decode_multibase_data(&event_data).unwrap(),
    );
    let args = vec![item.clone(), item];

    mock_event_store
        .expect_insert_many()
        .with(predicate::eq(args), predicate::eq(node_id))
        .times(1)
        .returning(|input, _| {
            Ok(input
                .into_iter()
                .map(|v| EventInsertResult::new_ok(v.key.clone()))
                .collect())
        });
    let server = create_test_server(
        node_id,
        network,
        mock_interest,
        Arc::new(mock_event_store),
        MockP2PService::new(),
        None,
    );
    let (resp1, resp2) = join!(
        server.events_post(
            models::EventData {
                data: event_data.to_string(),
            },
            &Context,
        ),
        server.events_post(
            models::EventData {
                data: event_data.to_string(),
            },
            &Context,
        ),
    );
    assert_eq!(resp1.unwrap(), EventsPostResponse::Success);
    assert_eq!(resp2.unwrap(), EventsPostResponse::Success);
}
#[test(tokio::test)]
async fn create_event_fails() {
    let node_id = NodeKey::random().id();