pub(crate) mod cache;
pub(crate) mod constants;
mod enums;
mod field_optionality;
pub(crate) mod hashing;
pub(crate) mod metadata;
pub(crate) mod operations;
pub(crate) mod path_renderer;
pub(crate) mod responses;
pub(crate) mod status_codes;
mod string_enum_optimizer;
mod structs;
pub(crate) mod type_resolver;
mod type_usage_recorder;
use std::collections::{BTreeSet, HashSet};
pub(crate) use field_optionality::FieldOptionalityPolicy;
use oas3::spec::ObjectSchema;
pub(crate) use type_usage_recorder::TypeUsageRecorder;
use self::{cache::SharedSchemaCache, enums::EnumConverter, structs::StructConverter, type_resolver::TypeResolver};
use super::{
ast::{RustType, StructKind, TypeAliasDef, TypeRef},
schema_graph::SchemaGraph,
};
use crate::naming::identifiers::to_rust_type_name;
pub(crate) type ConversionResult<T> = anyhow::Result<T>;
#[derive(Debug, Clone, Copy)]
pub(crate) struct CodegenConfig {
pub preserve_case_variants: bool,
pub case_insensitive_enums: bool,
pub no_helpers: bool,
}
pub(crate) struct SchemaConverter<'a> {
type_resolver: TypeResolver<'a>,
struct_converter: StructConverter<'a>,
enum_converter: EnumConverter<'a>,
cached_schema_names: HashSet<String>,
}
impl<'a> SchemaConverter<'a> {
pub(crate) fn new(graph: &'a SchemaGraph, optionality_policy: FieldOptionalityPolicy, config: CodegenConfig) -> Self {
let type_resolver = TypeResolver::new(graph, config);
let cached_schema_names = Self::build_schema_name_cache(graph);
Self {
type_resolver: type_resolver.clone(),
struct_converter: StructConverter::new(graph, type_resolver.clone(), None, optionality_policy),
enum_converter: EnumConverter::new(graph, type_resolver, config),
cached_schema_names,
}
}
pub(crate) fn new_with_filter(
graph: &'a SchemaGraph,
reachable_schemas: BTreeSet<String>,
optionality_policy: FieldOptionalityPolicy,
config: CodegenConfig,
) -> Self {
let type_resolver = TypeResolver::new(graph, config);
let cached_schema_names = Self::build_schema_name_cache(graph);
Self {
type_resolver: type_resolver.clone(),
struct_converter: StructConverter::new(
graph,
type_resolver.clone(),
Some(reachable_schemas),
optionality_policy,
),
enum_converter: EnumConverter::new(graph, type_resolver, config),
cached_schema_names,
}
}
pub(crate) fn convert_schema(
&self,
name: &str,
schema: &ObjectSchema,
mut cache: Option<&mut SharedSchemaCache>,
) -> ConversionResult<Vec<RustType>> {
if !schema.all_of.is_empty() {
let cache_reborrow = cache.as_deref_mut();
return self
.struct_converter
.convert_all_of_schema(name, schema, cache_reborrow);
}
if !schema.one_of.is_empty() {
let cache_reborrow = cache.as_deref_mut();
return self
.enum_converter
.convert_union_enum(name, schema, enums::UnionKind::OneOf, cache_reborrow);
}
if !schema.any_of.is_empty() {
let cache_reborrow = cache.as_deref_mut();
return self
.enum_converter
.convert_union_enum(name, schema, enums::UnionKind::AnyOf, cache_reborrow);
}
if !schema.enum_values.is_empty() {
let cache_reborrow = cache.as_deref_mut();
return Ok(
self
.enum_converter
.convert_simple_enum(name, schema, cache_reborrow)
.into_iter()
.collect(),
);
}
if !schema.properties.is_empty() || schema.additional_properties.is_some() {
let cache_reborrow = cache;
let (main_type, inline_types) = self
.struct_converter
.convert_struct(name, schema, None, cache_reborrow)?;
return self
.struct_converter
.finalize_struct_types(name, schema, main_type, inline_types);
}
let type_ref = self.type_resolver.schema_to_type_ref(schema)?;
let alias = RustType::TypeAlias(TypeAliasDef {
name: to_rust_type_name(name),
docs: metadata::extract_docs(schema.description.as_ref()),
target: type_ref,
});
Ok(vec![alias])
}
pub(crate) fn convert_struct(
&self,
name: &str,
schema: &ObjectSchema,
kind: Option<StructKind>,
cache: Option<&mut SharedSchemaCache>,
) -> ConversionResult<(RustType, Vec<RustType>)> {
self.struct_converter.convert_struct(name, schema, kind, cache)
}
pub(crate) fn schema_to_type_ref(&self, schema: &ObjectSchema) -> anyhow::Result<TypeRef> {
self.type_resolver.schema_to_type_ref(schema)
}
fn build_schema_name_cache(graph: &SchemaGraph) -> HashSet<String> {
graph
.schema_names()
.into_iter()
.flat_map(|schema_name| {
let rust_name = to_rust_type_name(schema_name);
[schema_name.clone(), rust_name]
})
.collect()
}
pub(crate) fn is_schema_name(&self, name: &str) -> bool {
self.cached_schema_names.contains(name)
}
}
#[cfg(test)]
mod tests;