moviestar - BuzzerCinestar - src - buzzerproxy - SOURCE CODE

package buzzerproxy.bprot;

import java.net.Socket;

import buzzerproxy.Constant;
import buzzerproxy.Crypto;
import buzzerproxy.IO;
import buzzerproxy.util.ByteProtUtil;

/**
 * @author M. Friedeboldt
 */
public class ByteProtComm extends Thread {

    private ByteProtUtil   byteProtUtil;
    private SessionManager sessionManager;

    /**
     * @param sock
     */
    public ByteProtComm(Socket sock, SessionManager sessionManager) {
        this.byteProtUtil = new ByteProtUtil( sock );
        this.sessionManager = sessionManager;
    }

    @Override
    public void run() {
        try {
            while ( !readKey() )
                ;
        } catch ( Exception e ) {
            e.printStackTrace();
        }
    }

    /**
     * [0xE1] Register + Session <br>
     * [0x50] Register + Session + Crypto <br>
     * [0x01] Question <br>
     * [0x02] Question Ready ? <br>
     * [0x20] Send Answer Count <br>
     * [0x10] Send Answer + index - max <br>
     * [0x11] Erfragen der Config Version [0x12] Holen der Config Version (XML)
     * [0x04] close <br>
     * [0x22] PING <br>
     * [0x33] Update Andoid ausliefern - Basti   
     * lesen des Schlssels von Socket
     * 
     * @return
     */

... [truncated, 133 more lines] ...

package buzzerproxy.bprot;

import java.util.List;

import buzzerproxy.ResultContainer;

/**
 * @author M. Friedeboldt
 */
public class ByteProtResult {

	private int count;

	private List<ResultContainer> results;

	/**
	 * @param result
	 */
	public ByteProtResult(List<ResultContainer> results) {
		this.results = results;
		count = results.size();
	}

	/**
	 * Anzahl der Ergebnisse
	 * 
	 * @return
	 */
	public int getCount() {
		return count;
	}

	/**
	 * @param index
	 * @param max
	 * @return
	 */
	public String getResult(int index, int max) {
		StringBuilder sb = new StringBuilder();
		sb.append("<?xml version='1.0' encoding='utf-8'?>");
		sb.append("<results>");

		for (int i = index; i < (i + max); i++) {
			if (results != null && results.size() < i)
				sb.append("<item>");
				sb.append("<ft>");
				sb.append(results.get(i).getFileTyp());
				sb.append("</ft>");
				sb.append("<lc>");
				sb.append(results.get(i).getLastChecked());

... [truncated, 14 more lines] ...

package buzzerproxy.bprot;

import java.net.ServerSocket;
import java.net.Socket;

import buzzerproxy.handler.ExceptionHandler;
import buzzerproxy.handler.QuestionInterface;

/**
 * 
 * @author M. Friedeboldt
 */
public class ByteProtServer extends Thread {

    private int               port;

    private ExceptionHandler  handler;

    private SessionManager    sessionManager;

    private QuestionInterface questionInterface;

    /**
     * 
     * @param port
     * @throws Exception
     */
    public ByteProtServer(int port, QuestionInterface questionInterface, ExceptionHandler handler) {
        this.port = port;
        this.handler = handler;
        this.questionInterface = questionInterface;
    }

    @Override
    public void run() {

        try {
            // create Server
            ServerSocket socket = new ServerSocket( port );
           
            /**
             * Wo die IP Abspeichern, sodass diese fr die Logs verarbeitet werden kann?
             * String clientIP = socket.getInetAddress().getHostAddress();
            */
            
            // Session Manager
            sessionManager = new SessionManager( questionInterface );

            // Wait...
            while ( true ) {

... [truncated, 18 more lines] ...

package buzzerproxy.bprot;

import buzzerproxy.Crypto;
import buzzerproxy.handler.QuestionInterface;

/**
 * @author M. Friedeboldt
 */
public class Session implements Runnable {

    private String            question;

    private QuestionInterface questionInterface;

    private boolean           ready;

    private ByteProtResult    protResult;

    /**
     * @param questionInterface
     */
    public Session(QuestionInterface questionInterface) {
        this.questionInterface = questionInterface;
        this.ready = false;
    }

    /**
     * @param question
     */
    public void setQuestion(String question) {
        this.question = question;
        new Thread( this ).start();
    }

    /**
     * @return
     */
    public boolean isReady() {
        return ready;
    }

    /**
     * @return
     */
    public String getResult(int index, int max) {
        return protResult.getResult( index, max );
    }

    /**
     * @return

... [truncated, 24 more lines] ...

package buzzerproxy.bprot;

import java.util.HashMap;

import buzzerproxy.handler.QuestionInterface;

/**
 * @author M. Friedeboldt
 */
public class SessionManager {

    private HashMap<Long, Session> map;

    private QuestionInterface      questionInterface;

    /**
     * @param questionInterface
     */
    public SessionManager(QuestionInterface questionInterface) {
        map = new HashMap<Long, Session>();
        this.questionInterface = questionInterface;
    }

    /**
     * @return
     */
    synchronized public long createNewSession() {
        Long sessionId = System.currentTimeMillis();
        while ( map.containsKey( sessionId ) )
            sessionId = System.currentTimeMillis();

        map.put( sessionId, new Session( questionInterface ) );
        return sessionId;
    }

    /**
     * @param sessionId
     * @return
     */
    synchronized public Session getSession(long sessionId) {
        return map.get( new Long( sessionId ) );
    }

    /**
     * @param sessionId
     */
    synchronized public void removeSession(Long sessionId) {
        map.remove( new Long( sessionId ) );
    }
    

... [truncated, 2 more lines] ...

package buzzerproxy.handler;

public interface ExceptionHandler {

    public void throwException(Throwable throwable);
}

package buzzerproxy.handler;

import java.util.List;

import buzzerproxy.ResultContainer;

/**
 * @author M. Friedeboldt
 */
public interface QuestionInterface {

    /**
     * @param xmlRequest
     * @return
     * @throws Exception
     */
    public List<ResultContainer> request(String xmlRequest) throws Exception;
    
    /**
     * Gibt die Version der Configuration zurck
     * @return
     */
    public String getConfigXMLVersion();
    
    /**
     * Gibt die XML fr die Konfiguration zurck
     * @return
     */
    public String getConfigurationXML();
    
    /**
     * Gib die beliebtesten Suchwoerter zurueck
     * @return 
     */
    public String getSearchKeywords();
}

package buzzerproxy.util;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketTimeoutException;

import buzzerproxy.Crypto;

public class ByteProtUtil {

    private Socket sock;

    private Crypto crypto;

    /**
     * 
     */
    public ByteProtUtil(Socket sock) {
        this.sock = sock;
    }

    /**
     * @param crypto
     */
    public void setCrypt(Crypto crypto) {
        this.crypto = crypto;
    }

    /**
     * Read
     * - Anzahl<br>
     * - Data<br>
     * @return
     */
    public String readDataW() {
        // Lenght
        int anz = getInt();

        return readData( anz );
    }

    /**
     * 
     * @return
     */
    public String readData(int anz) {
        String res = "";
        if ( sock != null && sock.isConnected() ) {

... [truncated, 168 more lines] ...