mod cache_control; mod export_sdl; mod stringify_exec_doc; use std::collections::{BTreeMap, BTreeSet, HashMap, HashSet}; use std::sync::Arc; use indexmap::map::IndexMap; use indexmap::set::IndexSet; use crate::parser::types::{ BaseType as ParsedBaseType, Field, Type as ParsedType, VariableDefinition, }; use crate::validators::InputValueValidator; use crate::{model, Any, Context, Positioned, ServerResult, Type, Value, VisitorContext}; pub use cache_control::CacheControl; fn strip_brackets(type_name: &str) -> Option<&str> { type_name .strip_prefix('[') .map(|rest| &rest[..rest.len() - 1]) } #[derive(Clone, Copy, PartialEq, Debug)] pub enum MetaTypeName<'a> { List(&'a str), NonNull(&'a str), Named(&'a str), } impl<'a> std::fmt::Display for MetaTypeName<'a> { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { match self { MetaTypeName::Named(name) => write!(f, "{}", name), MetaTypeName::NonNull(name) => write!(f, "{}!", name), MetaTypeName::List(name) => write!(f, "[{}]", name), } } } impl<'a> MetaTypeName<'a> { #[inline] pub fn create(type_name: &str) -> MetaTypeName { if let Some(type_name) = type_name.strip_suffix('!') { MetaTypeName::NonNull(type_name) } else if let Some(type_name) = strip_brackets(type_name) { MetaTypeName::List(type_name) } else { MetaTypeName::Named(type_name) } } #[inline] pub fn concrete_typename(type_name: &str) -> &str { match MetaTypeName::create(type_name) { MetaTypeName::List(type_name) => Self::concrete_typename(type_name), MetaTypeName::NonNull(type_name) => Self::concrete_typename(type_name), MetaTypeName::Named(type_name) => type_name, } } #[inline] pub fn is_non_null(&self) -> bool { matches!(self, MetaTypeName::NonNull(_)) } #[inline] pub fn unwrap_non_null(&self) -> Self { match self { MetaTypeName::NonNull(ty) => MetaTypeName::create(ty), _ => *self, } } #[inline] pub fn is_subtype(&self, sub: &MetaTypeName<'_>) -> bool { match (self, sub) { (MetaTypeName::NonNull(super_type), MetaTypeName::NonNull(sub_type)) | (MetaTypeName::Named(super_type), MetaTypeName::NonNull(sub_type)) => { MetaTypeName::create(super_type).is_subtype(&MetaTypeName::create(sub_type)) } (MetaTypeName::Named(super_type), MetaTypeName::Named(sub_type)) => { super_type == sub_type } (MetaTypeName::List(super_type), MetaTypeName::List(sub_type)) => { MetaTypeName::create(super_type).is_subtype(&MetaTypeName::create(sub_type)) } _ => false, } } #[inline] pub fn is_list(&self) -> bool { match self { MetaTypeName::List(_) => true, MetaTypeName::NonNull(ty) => MetaTypeName::create(ty).is_list(), MetaTypeName::Named(name) => name.ends_with(']'), } } } #[derive(Clone)] pub struct MetaInputValue { pub name: &'static str, pub description: Option<&'static str>, pub ty: String, pub default_value: Option, pub validator: Option>, pub visible: Option, pub is_secret: bool, } type ComputeComplexityFn = fn( &VisitorContext<'_>, &[Positioned], &Field, usize, ) -> ServerResult; #[derive(Clone)] pub enum ComplexityType { Const(usize), Fn(ComputeComplexityFn), } #[derive(Debug, Clone)] pub enum Deprecation { NoDeprecated, Deprecated { reason: Option<&'static str> }, } impl Default for Deprecation { fn default() -> Self { Deprecation::NoDeprecated } } impl Deprecation { #[inline] pub fn is_deprecated(&self) -> bool { matches!(self, Deprecation::Deprecated { .. }) } #[inline] pub fn reason(&self) -> Option<&str> { match self { Deprecation::NoDeprecated => None, Deprecation::Deprecated { reason } => reason.as_deref(), } } } #[derive(Clone)] pub struct MetaField { pub name: String, pub description: Option<&'static str>, pub args: IndexMap<&'static str, MetaInputValue>, pub ty: String, pub deprecation: Deprecation, pub cache_control: CacheControl, pub external: bool, pub requires: Option<&'static str>, pub provides: Option<&'static str>, pub visible: Option, pub compute_complexity: Option, } #[derive(Clone)] pub struct MetaEnumValue { pub name: &'static str, pub description: Option<&'static str>, pub deprecation: Deprecation, pub visible: Option, } #[derive(Clone)] pub struct MetaUnionValue { pub name: String, pub visible: Option, } type MetaVisibleFn = fn(&Context<'_>) -> bool; #[derive(Clone)] pub enum MetaType { Scalar { name: String, description: Option<&'static str>, is_valid: fn(value: &Value) -> bool, visible: Option, specified_by_url: Option<&'static str>, }, Object { name: String, description: Option<&'static str>, fields: IndexMap, cache_control: CacheControl, extends: bool, keys: Option>, visible: Option, }, Interface { name: String, description: Option<&'static str>, fields: IndexMap, possible_types: IndexSet, extends: bool, keys: Option>, visible: Option, }, Union { name: String, description: Option<&'static str>, union_values: IndexMap, possible_types: IndexSet, visible: Option, }, Enum { name: String, description: Option<&'static str>, enum_values: IndexMap<&'static str, MetaEnumValue>, visible: Option, }, InputObject { name: String, description: Option<&'static str>, input_fields: IndexMap, visible: Option, }, } impl MetaType { #[inline] pub fn field_by_name(&self, name: &str) -> Option<&MetaField> { self.fields().and_then(|fields| fields.get(name)) } #[inline] pub fn fields(&self) -> Option<&IndexMap> { match self { MetaType::Object { fields, .. } => Some(&fields), MetaType::Interface { fields, .. } => Some(&fields), _ => None, } } #[inline] pub fn is_visible(&self, ctx: &Context<'_>) -> bool { let visible = match self { MetaType::Scalar { visible, .. } => visible, MetaType::Object { visible, .. } => visible, MetaType::Interface { visible, .. } => visible, MetaType::Union { visible, .. } => visible, MetaType::Enum { visible, .. } => visible, MetaType::InputObject { visible, .. } => visible, }; match visible { Some(f) => f(ctx), None => true, } } #[inline] pub fn name(&self) -> &str { match self { MetaType::Scalar { name, .. } => &name, MetaType::Object { name, .. } => name, MetaType::Interface { name, .. } => name, MetaType::Union { name, .. } => name, MetaType::Enum { name, .. } => name, MetaType::InputObject { name, .. } => name, } } #[inline] pub fn is_composite(&self) -> bool { matches!( self, MetaType::Object { .. } | MetaType::Interface { .. } | MetaType::Union { .. } ) } #[inline] pub fn is_abstract(&self) -> bool { matches!(self, MetaType::Interface { .. } | MetaType::Union { .. }) } #[inline] pub fn is_leaf(&self) -> bool { matches!(self, MetaType::Enum { .. } | MetaType::Scalar { .. }) } #[inline] pub fn is_input(&self) -> bool { matches!( self, MetaType::Enum { .. } | MetaType::Scalar { .. } | MetaType::InputObject { .. } ) } #[inline] pub fn is_possible_type(&self, type_name: &str) -> bool { match self { MetaType::Interface { possible_types, .. } => possible_types.contains(type_name), MetaType::Union { possible_types, .. } => possible_types.contains(type_name), MetaType::Object { name, .. } => name == type_name, _ => false, } } #[inline] pub fn possible_types(&self) -> Option<&IndexSet> { match self { MetaType::Interface { possible_types, .. } => Some(possible_types), MetaType::Union { possible_types, .. } => Some(possible_types), _ => None, } } pub fn type_overlap(&self, ty: &MetaType) -> bool { if std::ptr::eq(self, ty) { return true; } match (self.is_abstract(), ty.is_abstract()) { (true, true) => self .possible_types() .iter() .copied() .flatten() .any(|type_name| ty.is_possible_type(type_name)), (true, false) => self.is_possible_type(ty.name()), (false, true) => ty.is_possible_type(self.name()), (false, false) => false, } } } pub struct MetaDirective { pub name: &'static str, pub description: Option<&'static str>, pub locations: Vec, pub args: IndexMap<&'static str, MetaInputValue>, } #[derive(Default)] pub struct Registry { pub types: BTreeMap, pub directives: HashMap, pub implements: HashMap>, pub query_type: String, pub mutation_type: Option, pub subscription_type: Option, pub disable_introspection: bool, pub enable_federation: bool, pub federation_subscription: bool, } impl Registry { pub fn create_type MetaType>( &mut self, mut f: F, ) -> String { let name = T::type_name(); if !self.types.contains_key(name.as_ref()) { // Inserting a fake type before calling the function allows recursive types to exist. self.types.insert( name.clone().into_owned(), MetaType::Object { name: "".to_string(), description: None, fields: Default::default(), cache_control: Default::default(), extends: false, keys: None, visible: None, }, ); let ty = f(self); *self.types.get_mut(&*name).unwrap() = ty; } T::qualified_type_name() } pub fn create_dummy_type(&mut self) -> MetaType { T::create_type_info(self); self.types .get(&*T::type_name()) .cloned() .expect("You definitely encountered a bug!") } pub fn add_directive(&mut self, directive: MetaDirective) { self.directives .insert(directive.name.to_string(), directive); } pub fn add_implements(&mut self, ty: &str, interface: &str) { self.implements .entry(ty.to_string()) .and_modify(|interfaces| { interfaces.insert(interface.to_string()); }) .or_insert({ let mut interfaces = HashSet::new(); interfaces.insert(interface.to_string()); interfaces }); } pub fn add_keys(&mut self, ty: &str, keys: &str) { let all_keys = match self.types.get_mut(ty) { Some(MetaType::Object { keys: all_keys, .. }) => all_keys, Some(MetaType::Interface { keys: all_keys, .. }) => all_keys, _ => return, }; if let Some(all_keys) = all_keys { all_keys.push(keys.to_string()); } else { *all_keys = Some(vec![keys.to_string()]); } } pub fn concrete_type_by_name(&self, type_name: &str) -> Option<&MetaType> { self.types.get(MetaTypeName::concrete_typename(type_name)) } pub fn concrete_type_by_parsed_type(&self, query_type: &ParsedType) -> Option<&MetaType> { match &query_type.base { ParsedBaseType::Named(name) => self.types.get(name.as_str()), ParsedBaseType::List(ty) => self.concrete_type_by_parsed_type(ty), } } pub(crate) fn has_entities(&self) -> bool { self.types.values().any(|ty| match ty { MetaType::Object { keys: Some(keys), .. } | MetaType::Interface { keys: Some(keys), .. } => !keys.is_empty(), _ => false, }) } fn create_entity_type(&mut self) { let possible_types = self .types .values() .filter_map(|ty| match ty { MetaType::Object { name, keys: Some(keys), .. } if !keys.is_empty() => Some(name.clone()), MetaType::Interface { name, keys: Some(keys), .. } if !keys.is_empty() => Some(name.clone()), _ => None, }) .collect(); self.types.insert( "_Entity".to_string(), MetaType::Union { name: "_Entity".to_string(), description: None, union_values: Default::default(), possible_types, visible: None, }, ); } pub(crate) fn create_federation_types(&mut self) { Any::create_type_info(self); self.types.insert( "_Service".to_string(), MetaType::Object { name: "_Service".to_string(), description: None, fields: { let mut fields = IndexMap::new(); fields.insert( "sdl".to_string(), MetaField { name: "sdl".to_string(), description: None, args: Default::default(), ty: "String".to_string(), deprecation: Default::default(), cache_control: Default::default(), external: false, requires: None, provides: None, visible: None, compute_complexity: None, }, ); fields }, cache_control: Default::default(), extends: false, keys: None, visible: None, }, ); self.create_entity_type(); let query_root = self.types.get_mut(&self.query_type).unwrap(); if let MetaType::Object { fields, .. } = query_root { fields.insert( "_service".to_string(), MetaField { name: "_service".to_string(), description: None, args: Default::default(), ty: "_Service!".to_string(), deprecation: Default::default(), cache_control: Default::default(), external: false, requires: None, provides: None, visible: None, compute_complexity: None, }, ); fields.insert( "_entities".to_string(), MetaField { name: "_entities".to_string(), description: None, args: { let mut args = IndexMap::new(); args.insert( "representations", MetaInputValue { name: "representations", description: None, ty: "[_Any!]!".to_string(), default_value: None, validator: None, visible: None, is_secret: false, }, ); args }, ty: "[_Entity]!".to_string(), deprecation: Default::default(), cache_control: Default::default(), external: false, requires: None, provides: None, visible: None, compute_complexity: None, }, ); } } pub fn names(&self) -> Vec { let mut names = HashSet::new(); for d in self.directives.values() { names.insert(d.name.to_string()); names.extend(d.args.values().map(|arg| arg.name.to_string())); } for ty in self.types.values() { match ty { MetaType::Scalar { name, .. } | MetaType::Union { name, .. } => { names.insert(name.clone()); } MetaType::Object { name, fields, .. } | MetaType::Interface { name, fields, .. } => { names.insert(name.clone()); names.extend( fields .values() .map(|field| { std::iter::once(field.name.clone()) .chain(field.args.values().map(|arg| arg.name.to_string())) }) .flatten(), ); } MetaType::Enum { name, enum_values, .. } => { names.insert(name.clone()); names.extend(enum_values.values().map(|value| value.name.to_string())); } MetaType::InputObject { name, input_fields, .. } => { names.insert(name.clone()); names.extend(input_fields.values().map(|field| field.name.to_string())); } } } names.into_iter().collect() } pub fn set_description(&mut self, desc: &'static str) { match self.types.get_mut(&*T::type_name()) { Some(MetaType::Scalar { description, .. }) => *description = Some(desc), Some(MetaType::Object { description, .. }) => *description = Some(desc), Some(MetaType::Interface { description, .. }) => *description = Some(desc), Some(MetaType::Union { description, .. }) => *description = Some(desc), Some(MetaType::Enum { description, .. }) => *description = Some(desc), Some(MetaType::InputObject { description, .. }) => *description = Some(desc), None => {} } } pub fn remove_unused_types(&mut self) { let mut used_types = BTreeSet::new(); let mut unused_types = BTreeSet::new(); fn traverse_field<'a>( types: &'a BTreeMap, used_types: &mut BTreeSet<&'a str>, field: &'a MetaField, ) { traverse_type( types, used_types, MetaTypeName::concrete_typename(&field.ty), ); for arg in field.args.values() { traverse_input_value(types, used_types, arg); } } fn traverse_input_value<'a>( types: &'a BTreeMap, used_types: &mut BTreeSet<&'a str>, input_value: &'a MetaInputValue, ) { traverse_type( types, used_types, MetaTypeName::concrete_typename(&input_value.ty), ); } fn traverse_type<'a>( types: &'a BTreeMap, used_types: &mut BTreeSet<&'a str>, type_name: &'a str, ) { if used_types.contains(type_name) { return; } if let Some(ty) = types.get(type_name) { used_types.insert(type_name); match ty { MetaType::Object { fields, .. } => { for field in fields.values() { traverse_field(types, used_types, field); } } MetaType::Interface { fields, possible_types, .. } => { for field in fields.values() { traverse_field(types, used_types, field); } for type_name in possible_types.iter() { traverse_type(types, used_types, type_name); } } MetaType::Union { possible_types, .. } => { for type_name in possible_types.iter() { traverse_type(types, used_types, type_name); } } MetaType::InputObject { input_fields, .. } => { for field in input_fields.values() { traverse_input_value(types, used_types, field); } } _ => {} } } } for type_name in Some(&self.query_type) .into_iter() .chain(self.mutation_type.iter()) .chain(self.subscription_type.iter()) { traverse_type(&self.types, &mut used_types, type_name); } for ty in self.types.values().filter(|ty| match ty { MetaType::Object { keys: Some(keys), .. } | MetaType::Interface { keys: Some(keys), .. } => !keys.is_empty(), _ => false, }) { traverse_type(&self.types, &mut used_types, ty.name()); } fn is_system_type(name: &str) -> bool { if name.starts_with("__") { return true; } name == "Boolean" || name == "Int" || name == "Float" || name == "String" || name == "ID" } for ty in self.types.values() { let name = ty.name(); if !is_system_type(name) && !used_types.contains(name) { unused_types.insert(name.to_string()); } } for type_name in unused_types { self.types.remove(&type_name); } } }