Function create_event

api/src/tests.rs:206–252

()

#[test(tokio::test)]
async fn create_event() {
    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,
        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
                .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 resp = server
        .events_post(
            models::EventData {
                data: event_data.to_string(),
            },
            &Context,
        )
        .await
        .unwrap();
    assert!(matches!(resp, EventsPostResponse::Success));
}

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