providers/bundles/org.eclipse.ecf.provider.rss/src/org/eclipse/ecf/internal/provider/rss/http/HttpClient.java

/**
 * Copyright (c) 2006 Parity Communications, Inc. 
 * All rights reserved. This program and the accompanying materials 
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * Contributors:
 *     Sergey Yakovlev - initial API and implementation
 */
package org.eclipse.ecf.internal.provider.rss.http;

import java.io.IOException;
import java.net.MalformedURLException;
import java.net.Socket;
import java.net.URL;
import java.util.Map;

import org.eclipse.ecf.core.identity.ID;
import org.eclipse.ecf.core.identity.IDFactory;
import org.eclipse.ecf.core.util.ECFException;
import org.eclipse.ecf.core.util.Trace;
import org.eclipse.ecf.internal.provider.rss.RssDebugOptions;
import org.eclipse.ecf.internal.provider.rss.RssPlugin;
import org.eclipse.ecf.provider.comm.IConnectionListener;
import org.eclipse.ecf.provider.comm.ISynchAsynchConnection;
import org.eclipse.ecf.provider.comm.ISynchAsynchEventHandler;

/**
 * A ISynchAsynchConnection with support for HTTP-specific features. See the <a
 * href='http://www.w3.org/pub/WWW/Protocols/'>spec</a> for details.
 * 
 * 
 */
public class HttpClient implements ISynchAsynchConnection {

	private static final String PRODUCT_NAME = "ECF RSS Client/0.0.1";
	protected static final int DEFAULT_PORT = 80;

	protected Socket socket;
	protected ISynchAsynchEventHandler handler;
	protected boolean started = false;

	/**
	 * The constructors
	 * @param handler 
	 */
	public HttpClient(ISynchAsynchEventHandler handler) {
		if (handler == null) {
			throw new NullPointerException("Event handler cannot be null");
		}
		this.handler = handler;
	}

	protected void trace(String msg) {
		Trace.trace(RssPlugin.PLUGIN_ID, RssDebugOptions.DEBUG, msg);
	}

	protected void dumpStack(String msg, Throwable e) {
		Trace.catching(RssPlugin.PLUGIN_ID, RssDebugOptions.EXCEPTIONS_CATCHING, this.getClass(), "", e);
	}

	private URL getURL(String path) throws MalformedURLException {
		if (socket != null) {
			return new URL("http", socket.getInetAddress().getHostName(), socket.getPort(), path);
		}
		return null;
	}

	public Object connect(ID remote, Object data, int timeout) throws ECFException {
		try {
			trace("connect(" + remote + "," + data + "," + timeout + ")");
			if (socket != null) {
				throw new ECFException("Already connected to " + getURL(null));
			}

			final URL url = new URL(remote.getName());
			/*
			 * // Get socket factory and create/connect socket SocketFactory fact =
			 * SocketFactory.getSocketFactory(); if(fact == null) { fact =
			 * SocketFactory.getDefaultSocketFactory(); }
			 */

			final int port = url.getPort() != -1 ? url.getPort() : DEFAULT_PORT;
			// socket = fact.createSocket(url.getHost(), port, timeout);
			socket = new Socket(url.getHost(), port);
		} catch (final IOException e) {
			throw new ECFException(e);
		}

		return null;
	}

	public void disconnect() {
		trace("disconnect()");
		if (socket != null) {
			try {
				socket.close();
			} catch (final IOException e) {
				// ignored as we are releasing it anyway
			}
			socket = null;
		}
	}

	public boolean isConnected() {
		if (socket != null) {
			return socket.isConnected();
		}
		return false;
	}

	public ID getLocalID() {
		if (handler != null) {
			return handler.getEventHandlerID();
		}

		if (socket == null) {
			return null;
		}

		ID retID = null;
		try {
			retID = IDFactory.getDefault().createStringID(getURL(null).toString());
		} catch (final Exception e) {
			dumpStack("Exception in getLocalID()", e);
			return null;
		}
		return retID;
	}

	public void start() {
		trace("start()");
		started = true;

	}

	public void stop() {
		trace("stop()");
		started = false;
	}

	public boolean isStarted() {
		return started;
	}

	public Map getProperties() {
		return null;
	}

	public void addListener(IConnectionListener listener) {
		// TODO Auto-generated method stub

	}

	public void removeListener(IConnectionListener listener) {
		// TODO Auto-generated method stub

	}

	public Object getAdapter(Class clazz) {
		return null;
	}

	public void sendAsynch(ID receiver, byte[] data) throws IOException {
		// TODO Auto-generated method stub
	}

	public Object sendSynch(ID receiver, byte[] data) throws IOException {
		trace("sendSynch(" + receiver + ", " + data + ")");
		// data should be a string
		final HttpRequest request = new HttpRequest("GET", getURL(new String(data)));
		request.setHeader("User-Agent", PRODUCT_NAME);
		request.setHeader("Accept", "text/html, image/gif, image/jpeg, *; q=.2, */*; q=.2");
		request.setHeader("Connection", "keep-alive");
		request.writeToStream(request.getStartLine(), socket.getOutputStream());
		final HttpResponse response = new HttpResponse(socket.getInputStream());
		return response.getBody();
	}
}