mongo-graphql 0.0.2

Dynamic GraphQL schema generation from MongoDB collections, optimized for AWS Lambda
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

#[cfg(feature = "integration")]
mod common;

#[cfg(feature = "integration")]
mod tests {
    use mongodb::bson::{doc, oid::ObjectId};

    use mongo_graphql::executor;

    use crate::common::{get_db, get_schema};

    #[tokio::test]
    async fn test_queries() {
        let db = get_db().await;
        let schema = get_schema().await;

        // ---- introspection ----
        let result = executor::execute(
            schema,
            r#"{ __schema { queryType { name } } }"#,
            async_graphql::Variables::default(),
            None,
        )
        .await
        .unwrap();

        let query_name = &result["data"]["__schema"]["queryType"]["name"];
        assert_eq!(query_name.as_str().unwrap(), "Query");

        // ---- get by id (existing and non-existing) ----
        let hero = db.collection::<mongodb::bson::Document>("hero");

        let oid = ObjectId::new();
        hero.insert_one(doc! {
            "_id": oid,
            "id": oid,
            "alias": "IntTestGetHero",
            "secret_identity": "John Doe",
            "power_level": 9000,
            "active": true,
            "joined_at": mongodb::bson::DateTime::now(),
            "created_at": mongodb::bson::DateTime::now(),
        })
        .await
        .unwrap();

        // Non-existent id returns null.
        let result = executor::execute(
            schema,
            r#"query { hero(where: { id: "000000000000000000000000" }) { id alias } }"#,
            async_graphql::Variables::default(),
            None,
        )
        .await
        .unwrap();
        assert!(result["data"]["hero"].is_null());

        // Existing id returns the hero.
        let result = executor::execute(
            schema,
            &format!(
                r#"query {{ hero(where: {{ id: "{}" }}) {{ id alias }} }}"#,
                oid.to_hex()
            ),
            async_graphql::Variables::default(),
            None,
        )
        .await
        .unwrap();

        let hero_data = &result["data"]["hero"];
        assert_eq!(hero_data["id"].as_str().unwrap(), oid.to_hex());
        assert_eq!(hero_data["alias"].as_str().unwrap(), "IntTestGetHero");
    }
}