use std::fmt;
use failure::Error;
use proc_macro2::Span;
use quote::{self, Tokens};
use syn::{
FloatSuffix,
Ident,
IntSuffix,
Lit,
LitByteStr,
Meta,
MetaList,
MetaNameValue,
NestedMeta,
Path,
parse_str,
self,
};
use field::{
Label,
bool_attr,
set_option,
tag_attr,
};
#[derive(Clone)]
pub struct Field {
pub ty: Ty,
pub kind: Kind,
pub tag: u32,
}
impl Field {
pub fn new(attrs: &[Meta]) -> Result<Option<Field>, Error> {
let mut ty = None;
let mut label = None;
let mut packed = None;
let mut default = None;
let mut tag = None;
let mut unknown_attrs = Vec::new();
for attr in attrs {
if let Some(t) = Ty::from_attr(attr)? {
set_option(&mut ty, t, "duplicate type attributes")?;
} else if let Some(p) = bool_attr("packed", attr)? {
set_option(&mut packed, p, "duplicate packed attributes")?;
} else if let Some(t) = tag_attr(attr)? {
set_option(&mut tag, t, "duplicate tag attributes")?;
} else if let Some(l) = Label::from_attr(attr) {
set_option(&mut label, l, "duplicate label attributes")?;
} else if let Some(d) = DefaultValue::from_attr(attr)? {
set_option(&mut default, d, "duplicate default attributes")?;
} else {
unknown_attrs.push(attr);
}
}
let ty = match ty {
Some(ty) => ty,
None => return Ok(None),
};
match unknown_attrs.len() {
0 => (),
1 => bail!("unknown attribute: {:?}", unknown_attrs[0]),
_ => bail!("unknown attributes: {:?}", unknown_attrs),
}
let tag = match tag {
Some(tag) => tag,
None => bail!("missing tag attribute"),
};
let has_default = default.is_some();
let default = default.map_or_else(|| Ok(DefaultValue::new(&ty)),
|lit| DefaultValue::from_lit(&ty, lit))?;
let kind = match (label, packed, has_default) {
(None, Some(true), _) |
(Some(Label::Optional), Some(true), _) |
(Some(Label::Required), Some(true), _) => {
bail!("packed attribute may only be applied to repeated fields");
},
(Some(Label::Repeated), Some(true), _) if !ty.is_numeric() => {
bail!("packed attribute may only be applied to numeric types");
},
(Some(Label::Repeated), _, true) => {
bail!("repeated fields may not have a default value");
},
(None, _, _) => Kind::Plain(default),
(Some(Label::Optional), _, _) => Kind::Optional(default),
(Some(Label::Required), _, _) => Kind::Required(default),
(Some(Label::Repeated), packed, false) if packed.unwrap_or(ty.is_numeric()) => Kind::Packed,
(Some(Label::Repeated), _, false) => Kind::Repeated,
};
Ok(Some(Field {
ty: ty,
kind: kind,
tag: tag,
}))
}
pub fn new_oneof(attrs: &[Meta]) -> Result<Option<Field>, Error> {
if let Some(mut field) = Field::new(attrs)? {
match field.kind {
Kind::Plain(default) => {
field.kind = Kind::Required(default);
Ok(Some(field))
},
Kind::Optional(..) => bail!("invalid optional attribute on oneof field"),
Kind::Required(..) => bail!("invalid required attribute on oneof field"),
Kind::Packed | Kind::Repeated => bail!("invalid repeated attribute on oneof field"),
}
} else {
Ok(None)
}
}
pub fn encode(&self, ident: Tokens) -> Tokens {
let module = self.ty.module();
let encode_fn = match self.kind {
Kind::Plain(..) | Kind::Optional(..) | Kind::Required(..) => quote!(encode),
Kind::Repeated => quote!(encode_repeated),
Kind::Packed => quote!(encode_packed),
};
let encode_fn = quote!(_prost::encoding::#module::#encode_fn);
let tag = self.tag;
match self.kind {
Kind::Plain(ref default) => {
let default = default.typed();
quote! {
if #ident != #default {
#encode_fn(#tag, &#ident, buf);
}
}
},
Kind::Optional(..) => quote! {
if let ::std::option::Option::Some(ref value) = #ident {
#encode_fn(#tag, value, buf);
}
},
Kind::Required(..) | Kind::Repeated | Kind::Packed => quote!{
#encode_fn(#tag, &#ident, buf);
},
}
}
pub fn merge(&self, ident: Tokens) -> Tokens {
let module = self.ty.module();
let merge_fn = match self.kind {
Kind::Plain(..) | Kind::Optional(..) | Kind::Required(..) => quote!(merge),
Kind::Repeated | Kind::Packed => quote!(merge_repeated),
};
let merge_fn = quote!(_prost::encoding::#module::#merge_fn);
match self.kind {
Kind::Plain(..) | Kind::Required(..) | Kind::Repeated | Kind::Packed => quote! {
#merge_fn(wire_type, &mut #ident, buf)
},
Kind::Optional(..) => quote! {
#merge_fn(wire_type,
#ident.get_or_insert_with(Default::default),
buf)
},
}
}
pub fn encoded_len(&self, ident: Tokens) -> Tokens {
let module = self.ty.module();
let encoded_len_fn = match self.kind {
Kind::Plain(..) | Kind::Optional(..) | Kind::Required(..) => quote!(encoded_len),
Kind::Repeated => quote!(encoded_len_repeated),
Kind::Packed => quote!(encoded_len_packed),
};
let encoded_len_fn = quote!(_prost::encoding::#module::#encoded_len_fn);
let tag = self.tag;
match self.kind {
Kind::Plain(ref default) => {
let default = default.typed();
quote! {
if #ident != #default {
#encoded_len_fn(#tag, &#ident)
} else {
0
}
}
},
Kind::Optional(..) => quote! {
#ident.as_ref().map_or(0, |value| #encoded_len_fn(#tag, value))
},
Kind::Required(..) | Kind::Repeated | Kind::Packed => quote!{
#encoded_len_fn(#tag, &#ident)
},
}
}
pub fn clear(&self, ident: Tokens) -> Tokens {
match self.kind {
Kind::Plain(ref default) | Kind::Required(ref default) => {
let default = default.typed();
match self.ty {
Ty::String | Ty::Bytes => quote!(#ident.clear()),
_ => quote!(#ident = #default),
}
},
Kind::Optional(_) => quote!(#ident = ::std::option::Option::None),
Kind::Repeated | Kind::Packed => quote!(#ident.clear()),
}
}
pub fn default(&self) -> Tokens {
match self.kind {
Kind::Plain(ref value) | Kind::Required(ref value) => value.owned(),
Kind::Optional(_) => quote!(::std::option::Option::None),
Kind::Repeated | Kind::Packed => quote!(::std::vec::Vec::new()),
}
}
fn debug_inner(&self, wrap_name: Tokens) -> Tokens {
if let Ty::Enumeration(ref ty) = self.ty {
quote! {
struct #wrap_name<'a>(&'a i32);
impl<'a> ::std::fmt::Debug for #wrap_name<'a> {
fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
match super::#ty::from_i32(*self.0) {
None => ::std::fmt::Debug::fmt(&self.0, f),
Some(en) => ::std::fmt::Debug::fmt(&en, f),
}
}
}
}
} else {
quote! {
fn #wrap_name<T>(v: T) -> T { v }
}
}
}
pub fn debug(&self, wrapper_name: Tokens) -> Tokens {
let wrapper = self.debug_inner(quote!(Inner));
let inner_ty = self.ty.rust_type();
match self.kind {
Kind::Plain(_) |
Kind::Required(_) => self.debug_inner(wrapper_name),
Kind::Optional(_) => quote! {
struct #wrapper_name<'a>(&'a ::std::option::Option<#inner_ty>);
impl<'a> ::std::fmt::Debug for #wrapper_name<'a> {
fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
#wrapper
::std::fmt::Debug::fmt(&self.0.as_ref().map(Inner), f)
}
}
},
Kind::Repeated |
Kind::Packed => {
quote! {
struct #wrapper_name<'a>(&'a ::std::vec::Vec<#inner_ty>);
impl<'a> ::std::fmt::Debug for #wrapper_name<'a> {
fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
let mut vec_builder = f.debug_list();
for v in self.0 {
#wrapper
vec_builder.entry(&Inner(v));
}
vec_builder.finish()
}
}
}
}
}
}
pub fn methods(&self, ident: &Ident) -> Option<Tokens> {
let set = Ident::from(format!("set_{}", ident));
let push = Ident::from(format!("push_{}", ident));
if let Ty::Enumeration(ref ty) = self.ty {
Some(match self.kind {
Kind::Plain(ref default) | Kind::Required(ref default) => {
quote! {
pub fn #ident(&self) -> super::#ty {
super::#ty::from_i32(self.#ident).unwrap_or(super::#default)
}
pub fn #set(&mut self, value: super::#ty) {
self.#ident = value as i32;
}
}
},
Kind::Optional(ref default) => {
quote! {
pub fn #ident(&self) -> super::#ty {
self.#ident.and_then(super::#ty::from_i32).unwrap_or(super::#default)
}
pub fn #set(&mut self, value: super::#ty) {
self.#ident = ::std::option::Option::Some(value as i32);
}
}
},
Kind::Repeated | Kind::Packed => {
quote! {
pub fn #ident(&self) -> ::std::iter::FilterMap<::std::iter::Cloned<::std::slice::Iter<i32>>,
fn(i32) -> Option<super::#ty>> {
self.#ident.iter().cloned().filter_map(super::#ty::from_i32)
}
pub fn #push(&mut self, value: super::#ty) {
self.#ident.push(value as i32);
}
}
},
})
} else if let Kind::Optional(ref default) = self.kind {
let ty = self.ty.rust_ref_type();
let match_some = if self.ty.is_numeric() {
quote!(::std::option::Option::Some(val) => val,)
} else {
quote!(::std::option::Option::Some(ref val) => &val[..],)
};
Some(quote! {
pub fn #ident(&self) -> #ty {
match self.#ident {
#match_some
::std::option::Option::None => #default,
}
}
})
} else {
None
}
}
}
#[derive(Clone, PartialEq, Eq)]
pub enum Ty {
Double,
Float,
Int32,
Int64,
Uint32,
Uint64,
Sint32,
Sint64,
Fixed32,
Fixed64,
Sfixed32,
Sfixed64,
Bool,
String,
Bytes,
Enumeration(Path),
}
impl Ty {
pub fn from_attr(attr: &Meta) -> Result<Option<Ty>, Error> {
let ty = match *attr {
Meta::Word(ref name) if name == "float" => Ty::Float,
Meta::Word(ref name) if name == "double" => Ty::Double,
Meta::Word(ref name) if name == "int32" => Ty::Int32,
Meta::Word(ref name) if name == "int64" => Ty::Int64,
Meta::Word(ref name) if name == "uint32" => Ty::Uint32,
Meta::Word(ref name) if name == "uint64" => Ty::Uint64,
Meta::Word(ref name) if name == "sint32" => Ty::Sint32,
Meta::Word(ref name) if name == "sint64" => Ty::Sint64,
Meta::Word(ref name) if name == "fixed32" => Ty::Fixed32,
Meta::Word(ref name) if name == "fixed64" => Ty::Fixed64,
Meta::Word(ref name) if name == "sfixed32" => Ty::Sfixed32,
Meta::Word(ref name) if name == "sfixed64" => Ty::Sfixed64,
Meta::Word(ref name) if name == "bool" => Ty::Bool,
Meta::Word(ref name) if name == "string" => Ty::String,
Meta::Word(ref name) if name == "bytes" => Ty::Bytes,
Meta::NameValue(MetaNameValue { ref ident, lit: Lit::Str(ref l), .. }) if ident == "enumeration" => {
Ty::Enumeration(parse_str::<Path>(&l.value())?)
},
Meta::List(MetaList { ref ident, ref nested, .. }) if ident == "enumeration" => {
if nested.len() == 1 {
if let NestedMeta::Meta(Meta::Word(ref ident)) = nested[0] {
Ty::Enumeration(Path::from(ident.clone()))
} else {
bail!("invalid enumeration attribute: item must be an identifier");
}
} else {
bail!("invalid enumeration attribute: only a single identifier is supported");
}
},
_ => return Ok(None),
};
Ok(Some(ty))
}
pub fn from_str(s: &str) -> Result<Ty, Error> {
let enumeration_len = "enumeration".len();
let error = Err(format_err!("invalid type: {}", s));
let ty = match s.trim() {
"float" => Ty::Float,
"double" => Ty::Double,
"int32" => Ty::Int32,
"int64" => Ty::Int64,
"uint32" => Ty::Uint32,
"uint64" => Ty::Uint64,
"sint32" => Ty::Sint32,
"sint64" => Ty::Sint64,
"fixed32" => Ty::Fixed32,
"fixed64" => Ty::Fixed64,
"sfixed32" => Ty::Sfixed32,
"sfixed64" => Ty::Sfixed64,
"bool" => Ty::Bool,
"string" => Ty::String,
"bytes" => Ty::Bytes,
s if s.len() > enumeration_len && &s[..enumeration_len] == "enumeration" => {
let s = &s[enumeration_len..].trim();
match s.chars().next() {
Some('<') | Some('(') => (),
_ => return error,
}
match s.chars().next_back() {
Some('>') | Some(')') => (),
_ => return error,
}
Ty::Enumeration(parse_str::<Path>(s[1..s.len() - 1].trim())?)
},
_ => return error,
};
Ok(ty)
}
pub fn as_str(&self) -> &'static str {
match *self {
Ty::Double => "double",
Ty::Float => "float",
Ty::Int32 => "int32",
Ty::Int64 => "int64",
Ty::Uint32 => "uint32",
Ty::Uint64 => "uint64",
Ty::Sint32 => "sint32",
Ty::Sint64 => "sint64",
Ty::Fixed32 => "fixed32",
Ty::Fixed64 => "fixed64",
Ty::Sfixed32 => "sfixed32",
Ty::Sfixed64 => "sfixed64",
Ty::Bool => "bool",
Ty::String => "string",
Ty::Bytes => "bytes",
Ty::Enumeration(..) => "enum",
}
}
pub fn rust_type(&self) -> Tokens {
match *self {
Ty::String => quote!(::std::string::String),
Ty::Bytes => quote!(::std::vec::Vec<u8>),
_ => self.rust_ref_type(),
}
}
pub fn rust_ref_type(&self) -> Tokens {
match *self {
Ty::Double => quote!(f64),
Ty::Float => quote!(f32),
Ty::Int32 => quote!(i32),
Ty::Int64 => quote!(i64),
Ty::Uint32 => quote!(u32),
Ty::Uint64 => quote!(u64),
Ty::Sint32 => quote!(i32),
Ty::Sint64 => quote!(i64),
Ty::Fixed32 => quote!(u32),
Ty::Fixed64 => quote!(u64),
Ty::Sfixed32 => quote!(i32),
Ty::Sfixed64 => quote!(i64),
Ty::Bool => quote!(bool),
Ty::String => quote!(&str),
Ty::Bytes => quote!(&[u8]),
Ty::Enumeration(..) => quote!(i32),
}
}
pub fn module(&self) -> Ident {
match *self {
Ty::Enumeration(..) => Ident::from("int32"),
_ => Ident::from(self.as_str()),
}
}
pub fn is_numeric(&self) -> bool {
*self != Ty::String && *self != Ty::Bytes
}
}
impl fmt::Debug for Ty {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
f.write_str(self.as_str())
}
}
impl fmt::Display for Ty {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
f.write_str(self.as_str())
}
}
#[derive(Clone)]
pub enum Kind {
Plain(DefaultValue),
Optional(DefaultValue),
Required(DefaultValue),
Repeated,
Packed,
}
#[derive(Clone, Debug)]
pub enum DefaultValue {
F64(f64),
F32(f32),
I32(i32),
I64(i64),
U32(u32),
U64(u64),
Bool(bool),
String(String),
Bytes(Vec<u8>),
Enumeration(Tokens),
Path(Path),
}
impl DefaultValue {
pub fn from_attr(attr: &Meta) -> Result<Option<Lit>, Error> {
if attr.name() != "default" {
return Ok(None);
} else if let Meta::NameValue(ref name_value) = *attr {
Ok(Some(name_value.lit.clone()))
} else {
bail!("invalid default value attribute: {:?}", attr)
}
}
pub fn from_lit(ty: &Ty, lit: Lit) -> Result<DefaultValue, Error> {
let is_i32 = *ty == Ty::Int32 || *ty == Ty::Sint32 || *ty == Ty::Sfixed32;
let is_i64 = *ty == Ty::Int64 || *ty == Ty::Sint64 || *ty == Ty::Sfixed64;
let is_u32 = *ty == Ty::Uint32 || *ty == Ty::Fixed32;
let is_u64 = *ty == Ty::Uint64 || *ty == Ty::Fixed64;
let default = match lit {
Lit::Int(ref lit) if is_i32
&& (lit.suffix() == IntSuffix::I32
|| lit.suffix() == IntSuffix::None) => DefaultValue::I32(lit.value() as _),
Lit::Int(ref lit) if is_i64
&& (lit.suffix() == IntSuffix::I64
|| lit.suffix() == IntSuffix::None) => DefaultValue::I64(lit.value() as _),
Lit::Int(ref lit) if is_u32
&& (lit.suffix() == IntSuffix::U32
|| lit.suffix() == IntSuffix::None) => DefaultValue::U32(lit.value() as _),
Lit::Int(ref lit) if is_u64
&& (lit.suffix() == IntSuffix::U64
|| lit.suffix() == IntSuffix::None) => DefaultValue::U64(lit.value()),
Lit::Float(ref lit) if *ty == Ty::Float
&& (lit.suffix() == FloatSuffix::F32
|| lit.suffix() == FloatSuffix::None) => DefaultValue::F32(lit.value() as _),
Lit::Int(ref lit) if *ty == Ty::Float => DefaultValue::F32(lit.value() as _),
Lit::Float(ref lit) if *ty == Ty::Double
&& (lit.suffix() == FloatSuffix::F64
|| lit.suffix() == FloatSuffix::None) => DefaultValue::F64(lit.value()),
Lit::Int(ref lit) if *ty == Ty::Double => DefaultValue::F64(lit.value() as _),
Lit::Bool(ref lit) if *ty == Ty::Bool => DefaultValue::Bool(lit.value),
Lit::Str(ref lit) if *ty == Ty::String => DefaultValue::String(lit.value().clone()),
Lit::ByteStr(ref lit) if *ty == Ty::Bytes => DefaultValue::Bytes(lit.value().clone()),
Lit::Str(ref lit) => {
let value = lit.value();
let value = value.trim();
if let Ty::Enumeration(ref path) = *ty {
let variant = Ident::from(value);
return Ok(DefaultValue::Enumeration(quote!(#path::#variant)))
}
if *ty == Ty::Float {
match value {
"inf" => return Ok(DefaultValue::Path(parse_str::<Path>("::std::f32::INFINITY")?)),
"-inf" => return Ok(DefaultValue::Path(parse_str::<Path>("::std::f32::NEG_INFINITY")?)),
"nan" => return Ok(DefaultValue::Path(parse_str::<Path>("::std::f32::NAN")?)),
_ => (),
}
}
if *ty == Ty::Double {
match value {
"inf" => return Ok(DefaultValue::Path(parse_str::<Path>("::std::f64::INFINITY")?)),
"-inf" => return Ok(DefaultValue::Path(parse_str::<Path>("::std::f64::NEG_INFINITY")?)),
"nan" => return Ok(DefaultValue::Path(parse_str::<Path>("::std::f64::NAN")?)),
_ => (),
}
}
if value.chars().next() == Some('-') {
if let Ok(lit) = syn::parse_str::<Lit>(&value[1..]) {
match lit {
Lit::Int(ref lit) if is_i32 && (lit.suffix() == IntSuffix::I32 || lit.suffix() == IntSuffix::None) => {
return Ok(DefaultValue::I32((!lit.value() + 1) as i32));
},
Lit::Int(ref lit) if is_i64 && (lit.suffix() == IntSuffix::I64 || lit.suffix() == IntSuffix::None) => {
return Ok(DefaultValue::I64((!lit.value() + 1) as i64));
},
Lit::Float(ref lit) if *ty == Ty::Float && (lit.suffix() == FloatSuffix::F32 || lit.suffix() == FloatSuffix::None) => {
return Ok(DefaultValue::F32(-lit.value() as f32));
},
Lit::Float(ref lit) if *ty == Ty::Double && (lit.suffix() == FloatSuffix::F64 || lit.suffix() == FloatSuffix::None) => {
return Ok(DefaultValue::F64(-lit.value()));
},
Lit::Int(ref lit) if *ty == Ty::Float && lit.suffix() == IntSuffix::None => {
return Ok(DefaultValue::F32(-(lit.value() as f32)));
},
Lit::Int(ref lit) if *ty == Ty::Double && lit.suffix() == IntSuffix::None => {
return Ok(DefaultValue::F64(-(lit.value() as f64)));
},
_ => (),
}
}
}
match syn::parse_str::<Lit>(&value) {
Ok(Lit::Str(_)) => (),
Ok(lit) => return DefaultValue::from_lit(ty, lit),
_ => (),
}
bail!("invalid default value: {}", quote!(#value));
},
_ => bail!("invalid default value: {}", quote!(#lit)),
};
Ok(default)
}
pub fn new(ty: &Ty) -> DefaultValue {
match *ty {
Ty::Float => DefaultValue::F32(0.0),
Ty::Double => DefaultValue::F64(0.0),
Ty::Int32 | Ty::Sint32 | Ty::Sfixed32 => DefaultValue::I32(0),
Ty::Int64 | Ty::Sint64 | Ty::Sfixed64 => DefaultValue::I64(0),
Ty::Uint32 | Ty::Fixed32 => DefaultValue::U32(0),
Ty::Uint64 | Ty::Fixed64 => DefaultValue::U64(0),
Ty::Bool => DefaultValue::Bool(false),
Ty::String => DefaultValue::String(String::new()),
Ty::Bytes => DefaultValue::Bytes(Vec::new()),
Ty::Enumeration(ref path) => return DefaultValue::Enumeration(quote!(#path::default())),
}
}
pub fn owned(&self) -> Tokens {
match *self {
DefaultValue::String(ref value) if value.is_empty() => quote!(::std::string::String::new()),
DefaultValue::String(ref value) => quote!(#value.to_owned()),
DefaultValue::Bytes(ref value) if value.is_empty() => quote!(::std::vec::Vec::new()),
DefaultValue::Bytes(ref value) => {
let lit = LitByteStr::new(value, Span::def_site());
quote!(#lit.to_owned())
},
ref other => other.typed(),
}
}
pub fn typed(&self) -> Tokens {
if let DefaultValue::Enumeration(_) = *self {
quote!(super::#self as i32)
} else {
quote!(#self)
}
}
}
impl quote::ToTokens for DefaultValue {
fn to_tokens(&self, tokens: &mut Tokens) {
match *self {
DefaultValue::F64(value) => value.to_tokens(tokens),
DefaultValue::F32(value) => value.to_tokens(tokens),
DefaultValue::I32(value) => value.to_tokens(tokens),
DefaultValue::I64(value) => value.to_tokens(tokens),
DefaultValue::U32(value) => value.to_tokens(tokens),
DefaultValue::U64(value) => value.to_tokens(tokens),
DefaultValue::Bool(value) => value.to_tokens(tokens),
DefaultValue::String(ref value) => value.to_tokens(tokens),
DefaultValue::Bytes(ref value) => LitByteStr::new(value, Span::def_site()).to_tokens(tokens),
DefaultValue::Enumeration(ref value) => {
value.to_tokens(tokens)
},
DefaultValue::Path(ref value) => value.to_tokens(tokens),
}
}
}