Allow the use of custom context

The main goal of events/reports is to update a context object, which
will be used in filters to generate a response. It is now possible to
use any object implementing both Clone and Default as a context object.
It is also possible to define no context at all.

opensmtpd-derive/src/lib.rs

@@ -4,21 +4,61 @@ use proc_macro::TokenStream;
 use syn::{parse_macro_input, ItemFn};
 use quote::quote;
 
+fn get_type(
+    params: &syn::punctuated::Punctuated<syn::FnArg, syn::token::Comma>,
+) -> Result<(Box<syn::Type>, syn::Type), ()> {
+    match params.iter().count() {
+        1 => {
+            let ctx = Box::new(syn::Type::Verbatim(syn::TypeVerbatim {
+                tts: quote! {
+                    opensmtpd::NoContext
+                },
+            }));
+            let cb = syn::Type::Verbatim(syn::TypeVerbatim {
+                tts: quote!{ opensmtpd::Callback::NoCtx },
+            });
+            Ok((ctx, cb))
+        }
+        2 => match params.iter().next().unwrap() {
+            syn::FnArg::Captured(ref a) => match &a.ty {
+                syn::Type::Reference(r) => {
+                    let cb = match r.mutability {
+                        Some(_) => syn::Type::Verbatim(syn::TypeVerbatim {
+                            tts: quote!{ opensmtpd::Callback::CtxMut },
+                        }),
+                        None => syn::Type::Verbatim(syn::TypeVerbatim {
+                            tts: quote!{ opensmtpd::Callback::Ctx },
+                        }),
+                    };
+                    Ok((r.elem.clone(), cb))
+                }
+                _ => Err(()),
+            },
+            _ => Err(()),
+        },
+        _ => Err(()),
+    }
+}
+
 #[proc_macro_attribute]
 pub fn event(attr: TokenStream, input: TokenStream) -> TokenStream {
     let attr = attr.to_string();
     let item = parse_macro_input!(input as ItemFn);
     let fn_name = &item.ident;
     let fn_params = &item.decl.inputs;
+    let (ctx_type, callback_type) = match get_type(fn_params) {
+        Ok(t) => t,
+        Err(_) => {
+            panic!();
+        }
+    };
     let fn_body = &item.block;
     let fn_output = &item.decl.output;
     let output = quote! {
-        // TODO: set the correct EventHandler type
+        fn #fn_name() -> opensmtpd::EventHandler<#ctx_type> {
-        fn #fn_name() -> opensmtpd::EventHandler<opensmtpd::NoContext> {
-            // TODO: set the correct Callback type
             opensmtpd::EventHandler::new(
                 #attr,
-                opensmtpd::Callback::CtxMut(|#fn_params| #fn_output #fn_body)
+                #callback_type(|#fn_params| #fn_output #fn_body)
             )
         }
     };

opensmtpd/Cargo.toml

@@ -20,5 +20,9 @@ opensmtpd_derive = { path = "../opensmtpd-derive", version="0.1" }
 name = "dummy"
 path = "examples/dummy.rs"
 
+[[example]]
+name = "counter"
+path = "examples/session_event_counter.rs"
+
 [dev-dependencies]
 env_logger = "0.6"

opensmtpd/examples/dummy.rs

@@ -1,14 +1,14 @@
 use env_logger::{Builder, Env};
 use log::{debug, info};
-use opensmtpd::{event, handlers, Entry, NoContext, SmtpIn};
+use opensmtpd::{event, handlers, Entry, SmtpIn};
 
 #[event(Any)]
-fn on_event(_context: &mut NoContext, entry: &Entry) {
+fn on_event(entry: &Entry) {
     debug!("Event received: {:?}", entry);
 }
 
 #[event(LinkConnect)]
-fn on_connect(_context: &mut NoContext, entry: &Entry) {
+fn on_connect(entry: &Entry) {
     info!("New client on session {:x}.", entry.session_id);
 }
 

opensmtpd/examples/session_event_counter.rs

@@ -0,0 +1,19 @@
+use env_logger::{Builder, Env};
+use log::info;
+use opensmtpd::{event, handlers, Entry, SmtpIn};
+
+#[derive(Clone, Default)]
+struct MyContext {
+    nb: usize,
+}
+
+#[event(Any)]
+fn on_event(ctx: &mut MyContext, entry: &Entry) {
+    ctx.nb += 1;
+    info!("Event received: {}, {}", entry.session_id, ctx.nb);
+}
+
+fn main() {
+    Builder::from_env(Env::default().default_filter_or("debug")).init();
+    SmtpIn::new().event_handlers(handlers!(on_event)).run();
+}

opensmtpd/src/event_handlers.rs

@@ -65,11 +65,7 @@ mod test {
 
     #[test]
     fn test_eventhandler_build_noctx() {
-        // TODO: Remove the ::<NoContext>
+        EventHandler::new("Any", Callback::NoCtx::<NoContext>(|_entry: &Entry| {}));
-        EventHandler::new(
-            "Any",
-            Callback::NoCtx::<NoContext>(|_entry: &Entry| {}),
-        );
     }
 
     #[test]

opensmtpd/src/lib.rs

@@ -79,16 +79,14 @@ impl<T: Clone + Default + 'static> SmtpIn<T> {
         let mut evts = Vec::new();
         for eh in self.event_handlers.iter() {
             match eh.event {
-                MatchEvent::Evt(ref v) => {
+                MatchEvent::Evt(ref v) => for e in v.iter() {
-                    for e in v.iter() {
                     evts.push(e);
-                    }
                 },
                 MatchEvent::All => {
                     println!("register|report|smtp-in|*");
                     evts.clear();
                     break;
-                },
+                }
             }
         }
         evts.dedup();