use proc_macro2::TokenStream;
use pyo3::{Bound, FromPyObject, PyAny, PyResult, prelude::PyAnyMethods};
use quote::quote;
use serde::{Deserialize, Serialize};
use crate::{
CodeGen, CodeGenContext, ExprType, Node, PythonOptions, Statement, SymbolTableScopes,
extract_list,
};
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
pub struct Try {
pub body: Vec<Statement>,
pub handlers: Vec<ExceptHandler>,
pub orelse: Vec<Statement>,
pub finalbody: Vec<Statement>,
pub lineno: Option<usize>,
pub col_offset: Option<usize>,
pub end_lineno: Option<usize>,
pub end_col_offset: Option<usize>,
}
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
pub struct ExceptHandler {
pub exception_type: Option<ExprType>,
pub name: Option<String>,
pub body: Vec<Statement>,
pub lineno: Option<usize>,
pub col_offset: Option<usize>,
pub end_lineno: Option<usize>,
pub end_col_offset: Option<usize>,
}
impl<'a> FromPyObject<'a> for Try {
fn extract_bound(ob: &Bound<'a, PyAny>) -> PyResult<Self> {
let body: Vec<Statement> = extract_list(ob, "body", "try body")?;
let handlers: Vec<ExceptHandler> = extract_list(ob, "handlers", "try handlers")?;
let orelse: Vec<Statement> = extract_list(ob, "orelse", "try orelse").unwrap_or_default();
let finalbody: Vec<Statement> = extract_list(ob, "finalbody", "try finalbody").unwrap_or_default();
Ok(Try {
body,
handlers,
orelse,
finalbody,
lineno: ob.lineno(),
col_offset: ob.col_offset(),
end_lineno: ob.end_lineno(),
end_col_offset: ob.end_col_offset(),
})
}
}
impl<'a> FromPyObject<'a> for ExceptHandler {
fn extract_bound(ob: &Bound<'a, PyAny>) -> PyResult<Self> {
let exception_type: Option<ExprType> = if let Ok(type_attr) = ob.getattr("type") {
if type_attr.is_none() {
None
} else {
Some(type_attr.extract()?)
}
} else {
None
};
let name: Option<String> = if let Ok(name_attr) = ob.getattr("name") {
if name_attr.is_none() {
None
} else {
Some(name_attr.extract()?)
}
} else {
None
};
let body: Vec<Statement> = extract_list(ob, "body", "except handler body")?;
Ok(ExceptHandler {
exception_type,
name,
body,
lineno: ob.lineno(),
col_offset: ob.col_offset(),
end_lineno: ob.end_lineno(),
end_col_offset: ob.end_col_offset(),
})
}
}
impl Node for Try {
fn lineno(&self) -> Option<usize> { self.lineno }
fn col_offset(&self) -> Option<usize> { self.col_offset }
fn end_lineno(&self) -> Option<usize> { self.end_lineno }
fn end_col_offset(&self) -> Option<usize> { self.end_col_offset }
}
impl Node for ExceptHandler {
fn lineno(&self) -> Option<usize> { self.lineno }
fn col_offset(&self) -> Option<usize> { self.col_offset }
fn end_lineno(&self) -> Option<usize> { self.end_lineno }
fn end_col_offset(&self) -> Option<usize> { self.end_col_offset }
}
impl CodeGen for Try {
type Context = CodeGenContext;
type Options = PythonOptions;
type SymbolTable = SymbolTableScopes;
fn find_symbols(self, symbols: Self::SymbolTable) -> Self::SymbolTable {
let symbols = self.body.into_iter().fold(symbols, |acc, stmt| stmt.find_symbols(acc));
let symbols = self.handlers.into_iter().fold(symbols, |acc, handler| {
let symbols = handler.body.into_iter().fold(acc, |acc, stmt| stmt.find_symbols(acc));
if let Some(exception_type) = handler.exception_type {
exception_type.find_symbols(symbols)
} else {
symbols
}
});
let symbols = self.orelse.into_iter().fold(symbols, |acc, stmt| stmt.find_symbols(acc));
self.finalbody.into_iter().fold(symbols, |acc, stmt| stmt.find_symbols(acc))
}
fn to_rust(
self,
ctx: Self::Context,
options: Self::Options,
symbols: Self::SymbolTable,
) -> Result<TokenStream, Box<dyn std::error::Error>> {
let try_body_tokens: Result<Vec<TokenStream>, Box<dyn std::error::Error>> = self.body.into_iter()
.map(|stmt| stmt.to_rust(ctx.clone(), options.clone(), symbols.clone()))
.collect();
let try_body_tokens = try_body_tokens?;
let catch_blocks: Result<Vec<TokenStream>, Box<dyn std::error::Error>> = self.handlers.into_iter()
.map(|handler| {
let handler_body_tokens: Result<Vec<TokenStream>, Box<dyn std::error::Error>> = handler.body.into_iter()
.map(|stmt| stmt.to_rust(ctx.clone(), options.clone(), symbols.clone()))
.collect();
let handler_body_tokens = handler_body_tokens?;
Ok::<TokenStream, Box<dyn std::error::Error>>(quote! {
#(#handler_body_tokens)*
})
})
.collect();
let catch_blocks = catch_blocks?;
let else_tokens = if !self.orelse.is_empty() {
let else_body_tokens: Result<Vec<TokenStream>, Box<dyn std::error::Error>> = self.orelse.into_iter()
.map(|stmt| stmt.to_rust(ctx.clone(), options.clone(), symbols.clone()))
.collect();
let else_body_tokens = else_body_tokens?;
quote! {
#(#else_body_tokens)*
}
} else {
quote!()
};
let finally_tokens = if !self.finalbody.is_empty() {
let finally_body_tokens: Result<Vec<TokenStream>, Box<dyn std::error::Error>> = self.finalbody.into_iter()
.map(|stmt| stmt.to_rust(ctx.clone(), options.clone(), symbols.clone()))
.collect();
let finally_body_tokens = finally_body_tokens?;
quote! {
#(#finally_body_tokens)*
}
} else {
quote!()
};
Ok(quote! {
{
#(#try_body_tokens)*
#(#catch_blocks)*
#else_tokens
#finally_tokens
}
})
}
}
#[cfg(test)]
mod tests {
}