Function test_http

chirpstack/src/integration/http.rs:212–330

()

    #[tokio::test]
    async fn test_http() {
        let server = MockServer::start();

        let i = Integration {
            endpoints: vec![server.url("/")],
            headers: [("Foo".to_string(), "Bar".to_string())]
                .iter()
                .cloned()
                .collect(),
            json: true,
        };

        // uplink event
        let pl: integration::UplinkEvent = Default::default();
        let mut mock = server.mock(|when, then| {
            when.method(POST)
                .path("/")
                .query_param("event", "up")
                .header("Foo", "Bar")
                .body(serde_json::to_string(&pl).unwrap());

            then.status(200);
        });

        i.uplink_event(&HashMap::new(), &pl).await.unwrap();
        mock.assert();
        mock.delete();

        // join event
        let pl: integration::JoinEvent = Default::default();
        let mut mock = server.mock(|when, then| {
            when.method(POST)
                .path("/")
                .query_param("event", "join")
                .header("Foo", "Bar")
                .body(serde_json::to_string(&pl).unwrap());

            then.status(200);
        });

        i.join_event(&HashMap::new(), &pl).await.unwrap();
        mock.assert();
        mock.delete();

        // ack event
        let pl: integration::AckEvent = Default::default();
        let mut mock = server.mock(|when, then| {
            when.method(POST)
                .path("/")
                .query_param("event", "ack")
                .header("Foo", "Bar")
                .body(serde_json::to_string(&pl).unwrap());

            then.status(200);
        });
        i.ack_event(&HashMap::new(), &pl).await.unwrap();
        mock.assert();
        mock.delete();