/* @(#) BIPclient.java	Client program for Brother Internet Print protocol
 *			<www.brother.com>, with compression enhancement.
 *
 *			Copyright (c) 2003 Graham Jenkins <grahjenk@au1.ibm.com>
 *			All rights reserved. Version 1.07, 2003-06-23.
 */
import java.io.*;
import java.util.*;
import java.util.zip.*;
import javax.mail.*;
import javax.mail.internet.*;
import javax.activation.*;
public class BIPclient {
					// Configuration files.
  public static final String[] Conf={"C:\\Windows\\BIPclien.ini",
                                     "/usr/local/etc/BIPclient.cf"};
  public static void main(String[] args) {
    String params[]={"-P","-n"}, paramArgs[]={"",""}, prev="";		
    for (int i=0;i<args.length;i++) {	// Collect "-P" and "-n" parameters.
      for (int j=0;j<params.length;j++) {
        String c=args[i]; if (prev.equals(params[j])) c=prev+c;
        if (c.startsWith(params[j])) paramArgs[j]=c.substring(2);
      }
      prev=args[i];
    }
    if ((paramArgs[0].equals("")) || (paramArgs[1].equals(""))) 
      userMessage(2,"Usage: java BIPclient -P printer -n user");

    Vector pRec=new Vector(), uRec=new Vector(), sRec=new Vector();
    for (int i=0;i<Conf.length;i++) {	// Read configuration file(s).
      try {
        BufferedReader in=new BufferedReader(new FileReader(Conf[i]));
        userMessage(-1,"Seeking printer/user/smtp-host records in "+Conf[i]);
        String line=in.readLine();
        while (line != null) {
          StringTokenizer t=new StringTokenizer(line); int k=t.countTokens();
          Vector iRec=new Vector();
          for (int j=0;j<k;j++) {
            iRec.add(t.nextToken());
            switch( line.charAt(0) ) {
              case 'P':if((j>=1)&&((String)iRec.get(1)).equals(paramArgs[0])){
                         if (j==1) pRec.clear(); else pRec.add(iRec.get(j));
                       }
                       break;
              case 'U':if((j>=1)&&((String)iRec.get(1)).equals(paramArgs[1])){
                         if (j==1) uRec.clear(); else uRec.add(iRec.get(j));
                       }
                       break;
              case 'S':if (j==0) sRec.clear(); else sRec.add(iRec.get(j));
            }
          }
          line=in.readLine();
        }
        in.close();
      }
      catch (IOException e) {}
    } 

    int partSize=0;			// Validate configuration-file details.
    if ((pRec.size()<2) || (uRec.size()<1) || (sRec.size()<1))
      userMessage(1,"Valid printer/user/smtp-host records not found");
    try {partSize=Integer.parseInt((String)pRec.get(0));}
    catch (NumberFormatException e)      {userMessage(1,"Illegal part-size");}
    if ((partSize>-16) && (partSize<16))  userMessage(1,"Illegal part-size");
    if (uRec.size()<3) {uRec.add(""); uRec.add(""); uRec.set(1,"Never");}

    File tmp1=null, tmp2=null; FileOutputStream fos1=null, fos2=null;
    try {				// Create temporary files.
      tmp1=File.createTempFile("BIP",".TMP"); tmp1.deleteOnExit();
      tmp2=File.createTempFile("BIP",".PRN"); tmp2.deleteOnExit();
      fos1=new FileOutputStream(tmp1.getPath());
    }
    catch (IOException e) {userMessage(1,"Temporary file problem");}

    byte[] buffer=new byte[1024]; int bytesRead; String mark="0";
    if (partSize>0) {
      DataOutputStream out=new DataOutputStream(fos1);
      try {
        while ( (bytesRead=System.in.read(buffer)) != -1 ) { 
          out.write(buffer,0,bytesRead);
        }				// Read and store raw or
      } 				// compressed input stream.
      catch (IOException e) {userMessage(1,"Temporary file problem");}
    } else {
      partSize=-partSize; mark="Z";
      Deflater def=new Deflater(); def.setLevel(Deflater.BEST_COMPRESSION);
      DeflaterOutputStream out=new DeflaterOutputStream(fos1,def);
      try {
        while ( (bytesRead=System.in.read(buffer)) != -1 ) { 
          out.write(buffer,0,bytesRead);
        }
        out.finish();
      } 
      catch (IOException e) {userMessage(1,"Temporary file problem");}
    }

    long id=(new Date()).getTime();	// Generate unique identifier.
    long totalParts=1+(tmp1.length()-1)/partSize/1024;

    FileInputStream fis1=null; 		// Extract, encode and send each part.
    try {fis1=new FileInputStream(tmp1);} catch (IOException e) {}
    for (int partNo=1;partNo<=totalParts;partNo++) {
      try {
        fos2=new FileOutputStream(tmp2.getPath()); int k=0;
        while ( (k++<partSize) && ((bytesRead=fis1.read(buffer))!=-1) ) { 
          fos2.write(buffer,0,bytesRead);
        }
        fos2.close();
      }
      catch (IOException e) {userMessage(1,"Temporary file problem");}
      sendPart:
      for (int smtpTry=1;smtpTry<=3;smtpTry++) {
        for (int hostNo=0;hostNo<sRec.size();hostNo++) {
          userMessage(-1,"Trying SMTP-host: "+(String)sRec.get(hostNo));
          Properties prop=new Properties();
          prop.put("mail.transport.default","smtp");
          prop.put("mail.smtp.host",(String)sRec.get(hostNo));
          try {
            String toString=(String)pRec.get(1);
            for (int j=1;j<pRec.size()-1;j++) {
              toString=toString+", "+(String)pRec.get(j+1);
            }
            InternetAddress frAddr=new InternetAddress((String)uRec.get(0));
            Session mySession=Session.getInstance(prop,null);
            Message message=new MimeMessage(mySession);
            message.setFrom(frAddr);
            message.setSubject("Job for Printer "+paramArgs[0]);
            message.setRecipients(Message.RecipientType.TO,
              InternetAddress.parse(toString, false));
            MimeBodyPart  b1=new MimeBodyPart();
            b1.setContent("START-BROBROBRO-START\nBRO-SERVICE=ZYXWVUTSRQ980\n"+
                          "BRO-NOTIFY=" +(String)uRec.get(1)+"\n"+
                          "BRO-REPLY="  +(String)uRec.get(2)+"\n"+
                          "BRO-PARTIAL="+partNo+"/"+totalParts+"\n"+
                          "BRO-UID="    +(String)uRec.get(0)+id+"\n"+
                          "BRO-LANG="   +mark+"x09\nSTOP-BROBROBRO-STOP\n",
                          "text/plain");
            MimeBodyPart  b2=new MimeBodyPart();
            FileDataSource fds=new FileDataSource(tmp2.getPath());
            b2.setDataHandler(new DataHandler(fds));
            b2.setFileName("PrintJob.PRN");
            MimeMultipart mp=new MimeMultipart();
            mp.addBodyPart(b1);
            mp.addBodyPart(b2);
            message.setContent(mp);	// Next 2 lines enforce base64 encode.
            message.saveChanges();
            b2.setHeader("Content-Transfer-Encoding", "base64");
            b2.removeHeader("Content-Disposition");
            Transport.send(message);
            userMessage(-1,"Sent Part "+partNo+"/"+totalParts+" to "+toString);
            if (partNo==totalParts) System.exit(0); else break sendPart;
          }
          catch (MessagingException me) {}
          catch (Exception ex) {} 
        }
      }
    }
    userMessage(1,"Failed");
  }

  private static void userMessage(int p1, String p2) {
    System.err.println(p2);		// Writes message in second parameter to
    if(p1>=0) System.exit(p1);		// STDERR, exits if first parameter is
  }					// non-negative.
}