---

filter.h

Go to the documentation of this file.

/* 
 * This file is part of the rfc822 library (C) rebel42@users.sourceforge.net.
 *
 * The rfc822 library is released under the terms of the GNU Library General Public License as
 * published by the Free Software Foundation; either version 2 of the
 * License, or (at your option) any later version. See the file COPYING
 * as included in the distribution for details.
 */
#ifndef RFC822_FILTER_H
#define RFC822_FILTER_H

#include <rfc822/msg.h>

#include <set>

using namespace std;

namespace rfc822
{

namespace filter
{


class filter
{
public:
        filter();
        
        virtual ~filter();
                

        bool no_loop_check();


        virtual void onMsg(const msg&);


        virtual void onCleanup();
        

        virtual void onInit();
        

        void connect(const string& outgoing, filter& dest, bool fConnect = true);

        void connect(filter& dest, bool fConnect = true);

        static void connect(filter& src, filter& dest, bool fConnect = true)
                { src.connect(dest, fConnect); }

        static void connect(filter& src, const string& outgoing, filter& dest, bool fConnect = true)
                { src.connect(outgoing, dest, fConnect); }

        template <class T>
        static void copy(T& in, filter& f);
        
        static void copy(const msg& in, filter& f);
        
protected:

        void redirect(const msg& m, const string& slot);
        
        void redirect(const msg& m);
        
private:
        // checks for loops
        bool no_loop_check(set<filter*>&);
        
        // returns a list of recipients.
        set<filter*> recipients();
        
        typedef multimap<string, filter*> Map;
        Map m_targets;
        
        filter(const filter&);
        
        filter& operator = (const filter&);
};

template <class T>
void copy(T& in, filter& f)
{
        typename T::iterator it;
        for(it = in.begin(); it != in.end(); ++it)
                f.onMsg(*it);
}

inline void copy(const msg& in, filter& f)
{
        f.onMsg(in);
}

/*
 * include filters
 */
#define IN_RFC822_FILTER_H

#include <rfc822/filter/mboxwriter.h>
#include <rfc822/filter/conditional.h>

#undef  IN_RFC822_FILTER_H

};      // namespace rfc822::filter
};      // namespace rfc822


#endif

---