apollo-federation 2.13.1

Apollo Federation
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

use apollo_compiler::Name;
use apollo_compiler::Schema;
use apollo_compiler::executable::FieldSet;
use apollo_compiler::validation::Valid;
use apollo_compiler::validation::WithErrors;
use itertools::Itertools;

use super::VariableReference;
use crate::connectors::Namespace;
use crate::connectors::json_selection::SelectionTrie;

/// Given the variables relevant to entity fetching, synthesize a FieldSet
/// appropriate for use in a @key directive.
pub(crate) fn make_key_field_set_from_variables(
    schema: &Schema,
    object_type_name: &Name,
    variables: impl Iterator<Item = VariableReference<Namespace>>,
    namespace: Namespace,
) -> Result<Option<Valid<FieldSet>>, WithErrors<FieldSet>> {
    let params = variables
        .filter(|var| var.namespace.namespace == namespace)
        .unique()
        .collect_vec();

    if params.is_empty() {
        return Ok(None);
    }

    // let mut merged = TrieNode::default();
    let mut merged = SelectionTrie::new();
    for param in params {
        merged.extend(&param.selection);
    }

    FieldSet::parse_and_validate(
        Valid::assume_valid_ref(schema),
        object_type_name.clone(),
        merged.to_string(),
        "",
    )
    .map(Some)
}

#[cfg(test)]
mod tests {
    use apollo_compiler::Schema;
    use apollo_compiler::name;

    use super::make_key_field_set_from_variables;
    use crate::connectors::Namespace;
    use crate::connectors::PathSelection;
    use crate::connectors::json_selection::location::new_span;

    #[test]
    fn test_make_args_field_set_from_variables() {
        let result = make_key_field_set_from_variables(
            &Schema::parse_and_validate("type Query { t: T } type T { a: A b: ID } type A { b: B c: ID d: ID } type B { c: ID d: ID e: ID }", "").unwrap(),
            &name!("T"),
            vec![
                PathSelection::parse(new_span("$args.a.b.c")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$args.a.b { d e }")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$args.a.c")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$args.a.d")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$args { b }")).unwrap().1.variable_reference().unwrap(),
            ].into_iter(),
            Namespace::Args,
        )
        .unwrap()
        .unwrap();

        assert_eq!(
            result.serialize().no_indent().to_string(),
            "a { b { c d e } c d } b"
        );
    }

    #[test]
    fn test_make_batch_field_set_from_variables() {
        let result = make_key_field_set_from_variables(
            &Schema::parse_and_validate("type Query { t: T } type T { a: A b: ID } type A { b: B c: ID d: ID } type B { c: ID d: ID e: ID }", "").unwrap(),
            &name!("T"),
            vec![
                PathSelection::parse(new_span("$batch.a.b.c")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$batch.a.b { d e }")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$batch.a.c")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$batch.a.d")).unwrap().1.variable_reference().unwrap(),
                PathSelection::parse(new_span("$batch { b }")).unwrap().1.variable_reference().unwrap(),
            ].into_iter(),
            Namespace::Batch,
        )
        .unwrap()
        .unwrap();

        assert_eq!(
            result.serialize().no_indent().to_string(),
            "a { b { c d e } c d } b"
        );
    }
}