package push;import java.net.URL;import java.net.HttpURLConnection;import java.io.*;/** * <code>PushInitiator</code> class implements a simple push initiator. It can be used to create and  * send messages to push proxy gateway (ppg) * */public final class PushInitiator {    /* xml version */    private final static String XML_VERSION = "<?xml version=\"1.0\"?>";     /* Push Access Protocol (PAP) document type */    private final static String PAP_DOCTYPE = 	"<!DOCTYPE pap PUBLIC \"-//WAPFORUM//DTD PAP 1.0//EN\" \"http://www.wapforum.org/DTD/pap_1.0.dtd\" >";    /* content type of the push request multipart body */    private final static String CONTENT_TYPE = 	"multipart/related; boundary=multipart-boundary; type=\"application/xml\"";    /* Service Indication (SI) document type */    private static final String SI_DOCTYPE = "<!DOCTYPE si PUBLIC \"-//WAPFORUM//DTD SI 1.0//EN\" " +	"\"http://www.wapforum.org/DTD/si.dtd\">";    private static int pushId = 0;    /* PPG url where the pap message is to be sent  */    private final URL ppgUrl;    /* Some push proxy gateways may also require the authentication of the push initiator.        For instance, the push initiator imay be required to send an HTTP "authorization" header        in each request */    private final String authorization;    /**     * Creates a new <code>PushInitiator</code> instance.     *     * @param ppgUrl an <code>URL</code> value     */    public PushInitiator(URL ppgUrl) {	this.ppgUrl = ppgUrl;	authorization = null;    }    /**     * Creates a new <code>PushInitiator</code> instance.     *     * @param ppgUrl an <code>URL</code> value     * @param authorization a <code>String</code> value     */    public PushInitiator(URL ppgUrl, String authorization) {	this.ppgUrl = ppgUrl;	this.authorization = authorization;	System.out.println("Push Initiator created: ppgUrl = " + ppgUrl);    }    /**     * <code>sendPushMessage</code> sends push message to ppg     *     * @param clientAddress a <code>String</code> value     * @param addressType a <code>String</code> value     * @param message a <code>String</code> value     * @param mimeType a <code>String</code> value     * @exception Exception if an error occurs     */    public void sendPushMessage(String clientAddress, String addressType, 				String message, String mimeType) throws Exception {	HttpURLConnection http = (HttpURLConnection)ppgUrl.openConnection();	String ppgServer = ppgUrl.getHost();	http.setDoInput(true);	http.setRequestProperty("Content-Type", CONTENT_TYPE);	if(authorization != null) {	    if(!authorization.trim().equals(""))		http.setRequestProperty("Authorization", authorization);	}	http.setDoOutput(true);	PrintWriter out = new PrintWriter(new BufferedOutputStream(http.getOutputStream()));	out.println("--multipart-boundary");	out.println("Content-type: application/xml");	out.println();	out.println(createPapMessage(clientAddress, addressType, ppgServer, genPushId(), null));	out.println();        out.println("--multipart-boundary");        out.println("Content-type: " + mimeType);        out.println();	out.println(message);	out.println();	out.println("--multipart-boundary--");	out.flush();	out.close();	http.connect();	/* finally, read and debug the response received from PPG */	try {	    debugResponse(http);	}	catch (Exception e) { 	    System.err.println("Error in receiving the response!"); 	}    }    /**     * <code>createPapMessage</code> creates a Push Access Protocol type message     *     * @param address a <code>String</code> value     * @param addressType a <code>String</code> value     * @param ppgServer a <code>String</code> value     * @param pushId a <code>String</code> value     * @param notificationTo a <code>String</code> value     * @return a <code>String</code> value     */    public static String createPapMessage(String address, String addressType, 					  String ppgServer, String pushId, String notificationTo) {	return XML_VERSION + "\n" + PAP_DOCTYPE + "\n" +	    "<pap product-name=\"Mobile Zoo Push Initiator\">\n" +	    "<push-message push-id=\"" + pushId + 	    (notificationTo != null ? " request-notification-to=\"" + notificationTo : "") + "\">\n" +	    "<address address-value=\"WAPPUSH=" + address + "/TYPE=" + addressType + 		 "@" + ppgServer + "\"/>\n"  + 	    "</push-message>\n</pap>";    }    /**     * <code>createSiMessage</code> creates a service indication type message     *     * @param url a <code>String</code> value     * @param created a <code>String</code> value     * @param expires a <code>String</code> value     * @param message a <code>String</code> value     * @return a <code>String</code> value     */    public static String createSiMessage(String url, String sid, String created, String expires, 					 String action, String message) {	return XML_VERSION + SI_DOCTYPE +	    "<si>\n" +	    "<indication href=\"" + url + "\"" +	    (sid != null ? " si-id=\"" + sid + "\"" : "") +	    (created != null ? " created=\"" + created + "\"" : "") +	    (action != null ? " action=\"" + action + "\"" : "") + 	    (expires != null ? " expires=\"" + expires + "\"" : "") + ">" + 	    message + 	    "</indication>\n</si>";    }    /**     * Debug response     *     * @param http a <code>HttpURLConnection</code> value     * @exception Exception if an error occurs     */    private void debugResponse(HttpURLConnection http) throws Exception {	System.out.println(http.getResponseMessage());	String headerName;	int i=0;	while((headerName = http.getHeaderFieldKey(i++)) != null) {	    System.out.println("headerName" + ": " + http.getHeaderField(headerName));	}	System.out.println();	InputStreamReader in = new InputStreamReader(new BufferedInputStream(http.getInputStream()));	int c;	while((c = in.read()) != -1) System.out.print((char)c);	System.out.println();    }    /**     * <code>genPushId</code> generates an unique push id     *     * @return a <code>String</code> value     */    private String genPushId() {	pushId %= 100000;	return System.currentTimeMillis() + ":" +  pushId++;    }}