Quadcap Embeddable Server

com/quadcap/pop3/client/MailSuck.java

Go to the documentation of this file.

package com.quadcap.pop3.client;

/*
 * Copyright 1997 by Stan Bailes and quadcap Software.
 *
 **/

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;

import java.util.List;
import java.util.Map;
import java.util.Properties;

import com.quadcap.io.IO;

import com.quadcap.util.Debug;

/**
 *
 * @author Stan Bailes
 */
public class MailSuck implements MessageHook {
    boolean                             delete = false;
    OutputStream                        os;
    
    /**
     * Suck mail <host> <user> <passwd> <file>
     */
    public static void main(String[] args) {
        MailSuck suck = new MailSuck();
        try {
            if (args.length == 1) {
                suck.runMany(args[0]);
            } else if (args.length == 4) {
                Pop3Agent agent = new Pop3Agent();
                Properties props = new Properties();
                props.put("daysKeep", "0");
                props.put("host", args[0]);
                props.put("user", args[1]);
                props.put("passwd", args[2]);
                props.put("suck.outfile", args[3]);
                props.put("delete",
                          System.getProperty("suck.delete", "false"));

                suck.init(props);
                agent.run(props, suck);
            }
        } catch (Throwable t) {
            Debug.print(t);
        } finally {
            suck.close();
        }
    }

    public void runMany(String accountsFile) throws Exception {
        List agents = Pop3Service.getTuples(new File(accountsFile));
        for (int i = 0; i < agents.size(); i++) {
            try {
                Map ai = (Map)agents.get(i);
                Pop3Agent agent = new Pop3Agent();
                Properties props = new Properties();
                props.putAll(ai);
                props.put("daysKeep", "0");
                props.put("suck.outfile", ai.get("name") + ".log");
                props.put("delete",
                          System.getProperty("suck.delete", "false"));
                init(props);
                Debug.println("Running : " + ai.get("name"));
                agent.run(props, this);
                close();
            } catch (Throwable t) {
                System.err.print(t.toString());
            }
        }
    }
        
    /**
     * Initialize the hook with its property set
     */
    public void init(Properties p) throws Exception {
        os = new FileOutputStream(
            p.getProperty("suck.outfile", "suck.out"),
            true);
        delete = p.getProperty("delete", "false").equals("true");
    }

    void close() {
        try {
            os.close();
        } catch (Throwable t) {
        } finally {
            os = null;
        }
    }

    /**
     * Return <code>true</code> if the call to
     * <code>boolean passHeaders(Map headers)</code> will always return
     * true, so the message receiver can avoid calling it.
     */
    public boolean passAllHeaders() {
        return true;
    }

    /**
     * A hook first gets called with the parsed headers from the message.
     * If the hook returns 'true' to this call, it will be called again
     * to process the body using <code>sendMessage()</code>, below.
     */
    public boolean passHeaders(Map headers) {
        return true;
    }

    /**
     * The hook is called to process the entire message (including headers)
     * as an octet stream.
     *
     * @return <code>false</code> if the message is to be retained in
     * the store, <code>true</code> to delete it.
     */
    public boolean passMessage(InputStream is) throws Exception {
        IO.copyStream(is, os);
        return delete;
    }
}