/*
 * Analyseur de log Postfix
 * Arnaud Grandville
 * V1.0  15/04/07
 *
 * Parcours de la log Postfix, renseignement d'une structure temporaire
 * affichage lorsque les informations sont toutes disponibles et vidage
 * de la structure lors que les informations ne sont plus utiles.
 * Les spams et autres erreurs de protocole ne nécessitent
 * pas de stockage temporaire.
 *
 */

#include <string>
#include <iostream>
#include <fstream>
#include <boost/regex.hpp>
#include <vector>

using namespace std;

typedef struct {
        string strDate;
        string strFrom;
        string strDeny;
        string strID;
} mailStruct;


typedef vector<mailStruct> mailVector;

const string DateTime("(\\w{3})  (\\d{1,2}) (\\d{2}:\\d{2}:\\d{2}) ");
const string Hostname("\\w* ");
const string smtpd("postfix\\/smtpd\\[(\\w+)\\]: ");
const string smtp("postfix\\/smtp\\[(\\w+)\\]: ");
const string qmgr("postfix\\/qmgr\\[(\\w+)\\]: (\\w{10}): from=<(.*)>,.*");
const string removed("postfix\\/qmgr\\[(\\w+)\\]: (\\w{10}): removed");
const string accept("(\\w{10}): to=<(.*)>, orig_to=<.*>,.*");
const string noqueue("NOQUEUE: .*blocked using ([\\w.]*).*from=<(.*)> to=<(.*)> .*");
const string BlackList("NOQUEUE: .*Sender address rejected\\: Access denied.*from=<(.*)> to=<(.*)> .*");


boost::regex acceptFrom(DateTime+Hostname+qmgr);
boost::regex acceptTo(DateTime+Hostname+smtp+accept);
boost::regex RBLrefused(DateTime+Hostname+smtpd+noqueue);
boost::regex senderRefused(DateTime+Hostname+smtpd+BlackList);
boost::regex endReceived(DateTime+Hostname+removed);



int GetMailPos(string strMailID,mailVector* List){
    for(unsigned int i=List->size()-1;i>=0;i--){
        if((List->at(i)).strID == strMailID)
            return i;
    }
    return -1;
}

bool isAcceptFrom(string& strLine,mailVector* List){
        boost::match_results<std::string::const_iterator> what;
        if(boost::regex_search(strLine,what,acceptFrom,boost::match_default)){
                List->resize(List->size() + 1);
                List->at(List->size() - 1).strID = what[5];
                List->at(List->size() - 1).strFrom = what[6];
                List->at(List->size() - 1).strDate = what[1]+" "+what[2]+" "+what[3];
                return true;
        }
        return false;
}

bool isAcceptTo(string& strLine,mailVector* List){
        boost::match_results<std::string::const_iterator> what;
        if(boost::regex_search(strLine,what,acceptTo,boost::match_default)){
                int iPos = GetMailPos(what[5],List);
                if(iPos>-1){
                        cout << List->at(iPos).strDate << ";" << List->at(iPos).strFrom << ";"<< what[6] << ";OK" << endl;
                }
                return true;
        }
        return false;
}


bool isBlackListed(string& strLine){
        boost::match_results<std::string::const_iterator> what;
        if(boost::regex_search(strLine,what,senderRefused,boost::match_default)){
                cout <<what[1]<< " " <<what[2]<<" " <<what[3]<<";"<<what[5]<<";"<<what[6]<<";"<<what[7]<< ";BL" << endl;
                return true;
        }
        return false;
}

bool isRefused(string& strLine){
        boost::match_results<std::string::const_iterator> what;
        if(boost::regex_search(strLine,what,RBLrefused,boost::match_default)){
                cout<<what[1]<< " " <<what[2]<<" " <<what[3]<<";"<<what[6]<<";" <<what[7]<<";"<<what[5]<< endl;

                return true;
        }
        return false;
}

bool isEndReceive(string& strLine,mailVector* List){
        boost::match_results<std::string::const_iterator> what;
        if(boost::regex_search(strLine,what,endReceived,boost::match_default)){
                mailVector::iterator i;
                int iPos = GetMailPos(what[5],List);
                if(iPos>=0){
                        i=List->begin();
                        List->erase(i+iPos);
                }

                return true;
        }
        return false;
}



int main(int argc, char* argv[])
{
        ifstream in("c://logs//posfix//maillog");
        string line;
        mailVector MailsList(0);
        int iCount=0;

        while(getline(in,line) && iCount++<5000) {
                if(not isAcceptFrom(line,&MailsList))
                        if(not isAcceptTo(line,&MailsList))
                                if(not isEndReceive(line,&MailsList))
                                        if(not isRefused(line))
                                                isBlackListed(line);
        }

        return 0;
}