---

AbstractPost.java

Go to the documentation of this file.

package net.threebit.utils.sosc ; 

/*
 * Copyright 2003 Shawn Deleurme
 * Copyright 2003 Kevin O'Donnell
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 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 General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter; 
import java.io.InputStreamReader; 
import java.util.logging.Logger; 
import java.util.logging.FileHandler; 
import java.util.logging.SimpleFormatter; 
import java.net.*;
import java.util.*;
import javax.net.ssl.SSLSocketFactory; 
import javax.net.ssl.SSLSocket;  

public abstract class AbstractPost {

        private int httpversion = 1; 
        private String server = ""; 
        private String script = ""; 
        private boolean debug = false; 

        public AbstractPost (javax.servlet.jsp.JspWriter out, String server, String script ){
                this.server = server; 
                this.script = script;   
        }
        
        public AbstractPost ( String server, String script ) throws Exception {
                this.server = server; 
                this.script = script;   
                debug = true ;
        }

        public AbstractPost ( String server, String script, int httpversion ) throws Exception {
                this.httpversion = httpversion; 
                this.server = server; 
                this.script = script;   
                debug = true ;
        }


        //
        //
        // these methods make up a provider.  They are protected to avoid accidental
        // execution by evil spirits. 
        //
        //

        protected void setServer( String server ) {
                this.server = server ; 
        } 

        protected void setScript( String script ) {
                this.script = script ; 
        } 

        protected Map executeRequest (Map input) throws Exception {
                System.out.println ( "IN THE POST" ) ; 
                System.out.println ( server ) ; 
                Map map = encode ( input ) ; // this call allows processor specific map-munging.
                
                // get a SSL connection to the server
                SSLSocketFactory sf = (SSLSocketFactory)SSLSocketFactory.getDefault();
                SSLSocket s = (SSLSocket)sf.createSocket(server, 443);

                // create a PrintWriter for sending request to the server
                PrintWriter o = new PrintWriter(
                        new BufferedWriter(
                                new OutputStreamWriter(
                                        s.getOutputStream())));

                // send the HTTP header name/value pairs
                o.println("POST "+script+" HTTP/1."+httpversion);
                o.println("Content-Type: application/x-www-form-urlencoded");
                o.println("User-Agent: threebit");
                o.println("Host: "+server);
                o.println("Connection: close"); // o.println("Connection:Keep-Alive"); 

                // build the body by iterating through the specifed HashMap 
                String body = new String();
                for (Iterator i = map.keySet().iterator(); i.hasNext() ; ) {
                        try {
                                String key = (String) i.next();
                                // getParameterMap returns an ARRAY of strings, not strings. 
                                // i always get fucked by this one. 
                                if(debug)System.out.print ( "key = " + key  + "\t\t\t" );  
                                Object obj = map.get(key);  
                                // Fix maps called above fixes this. 
                                if (obj instanceof String) {
                                        String value = (String) obj; 
                                        if(debug)System.out.println ( "value = "+  value );  
                                        body += URLEncoder.encode(key,"UTF-8") 
                                                + "=" + URLEncoder.encode(value,"UTF-8") + "&"; //i want to be a stringbuffer 
                                }
                                // This is for when you call me with the getParameterMap.  Of course, i don't 
                                // deal with *actual* arrays yet. 
                                else if (obj instanceof String[] ){
                                        String[] values = (String[]) obj; 
                                        if(debug) System.out.println ( "value = "+  values[0] );  
                                        body += URLEncoder.encode(key,"UTF-8") 
                                                + "=" + URLEncoder.encode(values[0],"UTF-8") + "&"; //i want to be a stringbuffer 
                                }
                        } 
                        catch ( Exception e ) {
                                // do not die here. 
                                e.printStackTrace(System.out);  
                        }
                }
                // System.out.println ( body ) ; 

                // specify the content length and the blank line following the HTTP heades
                o.println("Content-Length: "+body.length());
                o.println();

                // send the body and flush the output
                o.print(body);
                o.flush();

                // create a buffered reader for reading the server's response
                BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));

                // NOTE: this method is not yet validating the HTTP response codes.
                Map decoded = decode ( in ) ; 

                // This is a fix for any keys that go missing from the input. 
                decoded.putAll ( input ) ; 
                        
                // close the socket, this closes the output stream
                s.close();
                in.close(); 

                // return the response.
                return decoded;
        }

        protected abstract Map encode ( Map unencoded ) throws Exception ;

        protected abstract Map decode ( BufferedReader in ) throws Exception; 

        private void setLogger ( String log ) {
                try { 
                        /*
                        FileHandler handler = new FileHandler(log , true);
                        handler.setFormatter(new net.threebit.utils.sosc.TerseLoggingFormatter());
                        logger.addHandler(handler);
                        */ 
                }       
                catch ( Exception e ) {
                        // so bad. 
                        e.printStackTrace( System.out ) ; 
                } 
        }
}

---