JamesRemoteManager.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2011 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
package org.turro.elephant.james;
 
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.turro.elephant.context.ElephantContext;
 
public class JamesRemoteManager {
 
  private String mailHost,  user,  password;
  private int port;
 
  public JamesRemoteManager(String mailHost, int port, String user, String password) {
    this.mailHost = mailHost;
    this.port = port;
    this.user = user;
    this.password = password;
  }
 
  public String execute(JamesCommand command) {
    String returnString = "An unknown error has occurred.";
    try {
      Socket socket = new Socket(mailHost, port);
      InputStream is = socket.getInputStream();
      InputStreamReader isr = new InputStreamReader(is);
      BufferedReader br = new BufferedReader(isr);
      OutputStream os = socket.getOutputStream();
      OutputStreamWriter osw = new OutputStreamWriter(os);
      BufferedWriter bw = new BufferedWriter(osw);
 
      String total = "";
      String line = "";
      String infoString = "OK: \r\n\r\n";
 
      while ((line = br.readLine()) != null) {
        total += line;
 
        if (line.indexOf("id") != -1) {
          //It wants a username.
          bw.write(user);
          bw.newLine();//Put in a new line.
          bw.flush();
        } else if (line.indexOf("Password") != -1) {
          //It wants a password.
          bw.write(password);
          bw.newLine();//Put in a new line.
          bw.flush();
        }
        if (line.indexOf("Welcome") != -1) {
          //It wants the command.
          bw.write(command.getCommand());
          bw.newLine();//Put in a new line.
          bw.flush();
 
          //Give James a head start.
          //If James is slow in returning data, br.ready (below) won't be able to collect the status information 
          //from the command. 1.5 seconds should be enough of a delay to let James get a head start in sending back
          //data. If necessary, increase this value. 
          Thread.sleep(3000);
 
          //Acquire resulting data.
          while (br.ready()) {
            infoString += br.readLine() + "\r\n";
          }
 
          //And quit neatly.
          bw.write("quit");
          bw.newLine();//Put in a new line.
          bw.flush();
        }//end if Welcome
 
      }//end while
 
      returnString = (String) infoString;
 
      socket.close();
 
      Logger.getLogger(JamesRemoteManager.class.getName()).log(Level.INFO, returnString);
 
    }//end try
    catch (Exception e) {
      if (command.getCommand().equals("shutdown")) {
        returnString = "OK: Shutdown";
      } else {
        Logger.getLogger(JamesRemoteManager.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(returnString), e);
      }
    }
 
    return returnString;
 
  }
}