source: sandbox/expresso-solr/imapCrawler/SRC/JCrawlerForIMAP/src/pkg/crawler/data/conn/Crawler.java @ 8056

package pkg.crawler.data.conn;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Properties;

import javax.mail.Folder;
import javax.mail.MessagingException;
import javax.mail.Session;

import com.sun.mail.imap.ACL;
import com.sun.mail.imap.IMAPFolder;
import com.sun.mail.imap.IMAPStore;
import com.sun.mail.imap.Rights;
import com.sun.mail.imap.Rights.Right;

public class Crawler{

        private String host;
        private String user;
        private String password;
        private String mbox;
        private String hostSolr;
        private ACL acl;

        public Crawler(String host, String password, String hostSolr)
        {
                this.host = host;
                this.user = "expresso-admin";
                this.password = password;
                this.mbox = "user";
                this.hostSolr = hostSolr;

                //Cria a ACL a ser configurada
                acl = new ACL("expresso-admin");

                //Define direito de leitura
                Rights rights = new Rights();
                rights.add(Right.READ);

                //Configura direito de leitura para a ACL
                acl.setRights(rights);
        }

        public void run()
        {

                int iAux0 = 0;
                while (iAux0 == 0)
                {
                        iAux0 = 1;

                        //Inicializando as propriedades default da máquina para conexão
                        //com o servidor IMAP
                        Properties props = System.getProperties();
                        Session session = Session.getInstance(props, null);

                        IMAPStore store = new IMAPStore(session, null);

                        try {

                                //Conectando com o servidor IMAP
                                store.connect(host, user, password);
                                //Definindo a pasta base a ser usada
                                IMAPFolder imapFolder = (IMAPFolder)store.getFolder(mbox);
                                //Faz a iteração entre os usuários/pastas do usuário

                                ArrayList<String> userMailBoxes = new ArrayList<String>();

                                for (Folder fINBOXAux : imapFolder.list())
                                {

                                        System.out.println(fINBOXAux.getFullName());
                                        userMailBoxes.add(fINBOXAux.getFullName());

                                }
                                ServerSocket server = null;
                                ObjectInputStream ois = null;
                                Socket connection = null;

                                try {
                                        server = new ServerSocket(8090);

                                        while (userMailBoxes.size() > 0 )
                                        {
                                                ProcessBuilder proc = new ProcessBuilder("java", "-jar", 
                                                                "-Xms2048m", "client.jar", this.host, 
                                                                userMailBoxes.get(0), this.password, this.hostSolr);

                                                try 
                                                {
                                                        proc.start();
                                                        System.out.println("Iniciou processo: "+
                                                                        "java -jar client.jar "+
                                                                        "\""+this.host+"\" \""+userMailBoxes.get(0)+"\" "+ 
                                                                        "\""+this.password+"\" \""+this.hostSolr+"\"");
                                                }
                                                catch (IOException e) {
                                                        // TODO Auto-generated catch block
                                                        e.printStackTrace();
                                                }
                                                catch (Exception e) {
                                                        // TODO Auto-generated catch block
                                                        e.printStackTrace();
                                                }
                                                
                                                connection = server.accept();

                                                ois = new ObjectInputStream(connection.getInputStream());
                                                try {
                                                        String socketMessage = (String)ois.readObject();
                                                        if(socketMessage.equals(userMailBoxes.get(0)))
                                                        {
                                                                System.out.println(userMailBoxes.get(0));
                                                                userMailBoxes.remove(0);
                                                        }
                                                } catch (ClassNotFoundException e) {
                                                        // TODO Auto-generated catch block
                                                        e.printStackTrace();
                                                }
                                        }

                                }
                                catch (IOException e) 
                                {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }

                                imapFolder.close(true);
                                imapFolder = null;
                                store.close();
                                store = null;

                        } catch (MessagingException e) {
                                System.out.println(e.getMessage());
                                e.printStackTrace();
                        }
                        catch (Exception e)
                        {
                                System.out.println(e.getMessage());
                                e.printStackTrace();
                        }

                }

        }

}