Function create_event_fails

api/src/tests.rs:310–361

()

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

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

    mock_event_store
        .expect_insert_many()
        .with(predicate::eq(args), predicate::eq(node_id))
        .times(1)
        .returning(|input, _| {
            Ok(input
                .iter()
                .map(|i| {
                    EventInsertResult::new_failed(
                        i.key.clone(),
                        "Event is missing prev".to_string(),
                    )
                })
                .collect())
        });
    let server = create_test_server(
        node_id,
        network,
        mock_interest,
        Arc::new(mock_event_store),
        MockP2PService::new(),
        None,
    );
    let resp = server
        .events_post(
            models::EventData {
                data: event_data.to_string(),
            },
            &Context,
        )
        .await
        .unwrap();
    assert!(matches!(resp, EventsPostResponse::BadRequest(_)));
}

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