apollo-router 2.13.1

A configurable, high-performance routing runtime for 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
100
101
102
103
104
105
106

use apollo_compiler::Name;
use apollo_compiler::Node;
use apollo_compiler::ast;
use apollo_compiler::schema::Directive;
use url::Url;

use crate::spec::LINK_AS_ARGUMENT;
use crate::spec::LINK_URL_ARGUMENT;

#[derive(Debug)]
pub(super) struct ParsedLinkSpec {
    pub(super) spec_name: String,
    pub(super) version: semver::Version,
    pub(super) spec_url: String,
    pub(super) imported_as: Option<String>,
    pub(super) url: String,
}

impl ParsedLinkSpec {
    pub(super) fn from_link_directive(
        link_directive: &Directive,
    ) -> Option<Result<ParsedLinkSpec, url::ParseError>> {
        link_directive
            .specified_argument_by_name(LINK_URL_ARGUMENT)
            .and_then(|value| {
                let url_string = value.as_str();

                let parsed_url = Url::parse(url_string.unwrap_or_default()).ok()?;

                let mut segments = parsed_url.path_segments()?;
                let spec_name = segments.next()?.to_string();
                let spec_url = format!(
                    "{}://{}/{}",
                    parsed_url.scheme(),
                    parsed_url.host()?,
                    spec_name
                );
                let version_string = segments.next()?.strip_prefix('v')?;
                let parsed_version =
                    semver::Version::parse(format!("{}.0", &version_string).as_str()).ok()?;

                let imported_as = link_directive
                    .specified_argument_by_name(LINK_AS_ARGUMENT)
                    .map(|as_arg| as_arg.as_str().unwrap_or_default().to_string());

                Some(Ok(ParsedLinkSpec {
                    spec_name,
                    spec_url,
                    version: parsed_version,
                    imported_as,
                    url: url_string?.to_string(),
                }))
            })
    }

    pub(super) fn from_join_directive_args(
        args: &[(Name, Node<ast::Value>)],
    ) -> Option<Result<Self, url::ParseError>> {
        let url_string = args
            .iter()
            .find(|(name, _)| name == &Name::new_unchecked(LINK_URL_ARGUMENT))
            .and_then(|(_, value)| value.as_str());

        let parsed_url = Url::parse(url_string.unwrap_or_default()).ok()?;

        let mut segments = parsed_url.path_segments()?;
        let spec_name = segments.next()?.to_string();
        let spec_url = format!(
            "{}://{}/{}",
            parsed_url.scheme(),
            parsed_url.host()?,
            spec_name
        );
        let version_string = segments.next()?.strip_prefix('v')?;
        let parsed_version =
            semver::Version::parse(format!("{}.0", &version_string).as_str()).ok()?;

        let imported_as = args
            .iter()
            .find(|(name, _)| name == &Name::new_unchecked(LINK_AS_ARGUMENT))
            .and_then(|(_, value)| value.as_str())
            .map(|s| s.to_string());

        Some(Ok(ParsedLinkSpec {
            spec_name,
            spec_url,
            version: parsed_version,
            imported_as,
            url: url_string?.to_string(),
        }))
    }

    // Implements directive name construction logic for link directives.
    // 1. If the link directive has an `as` argument, use that as the prefix.
    // 2. If the link directive's spec name is the same as the default name, use the default name with no prefix.
    // 3. Otherwise, use the spec name as the prefix.
    pub(super) fn directive_name(&self, default_name: &str) -> String {
        if let Some(imported_as) = &self.imported_as {
            format!("{imported_as}__{default_name}")
        } else if self.spec_name == default_name {
            default_name.to_string()
        } else {
            format!("{}__{}", self.spec_name, default_name)
        }
    }
}