moviestar - BuzzerStar - Buzzer_Android_V1 - src - SOURCE CODE

package de.se.buzzer.conf;

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

    /** Maximale Anzahl an Ergebnissen */
    public static int count_max_answer = 10;
}

package de.se.buzzer.enums;

public enum RequestState {

    START,

    FIRST_BLOCK_IS_READY,

    //***************
    // Fehler
    //***************

    FAIL_F,

    FAIL_SESSION,

    FAIL_SEND_QUSETION,

    FAIL_OFFLINE,

    FAIL_WAIT_FOR_READY,

    FAIL_WAIT_TIMEOUT,

    FAIL_READ_FOR_CONTENT
}

package de.se.buzzer.handler;

import java.util.ArrayList;
import java.util.List;

import de.se.buzzer.LineContainer;

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

    private ContentLoaderInterface loaderInterface;

    private int                    count;

    private List<LineContainer>    contentList;

    /**
     * @param loaderInterface
     */
    public AnswerHandler(ContentLoaderInterface loaderInterface) {
        this.loaderInterface = loaderInterface;
    }

    /**
     * @param count
     */
    public void setCount(int count) {
        this.count = count;
    }

    /**
     * @param lines
     */
    public void putLines(List<LineContainer> lines) {
        if ( this.contentList == null )
            contentList = new ArrayList<LineContainer>();

        contentList.addAll( lines );
    }

    /**
     * @param index
     * @param max
     * @return
     */
    public List<LineContainer> getLines(int index, int max) throws Exception {
        if ( this.contentList == null || this.contentList.size() == 0 || this.contentList.size() <= index ) {
            // nachladen

... [truncated, 13 more lines] ...

package de.se.buzzer.handler;

import java.util.List;

import de.se.buzzer.LineContainer;

public interface ContentLoaderInterface {

    public List<LineContainer> loadLineContainers(int index) throws Exception;
}

package de.se.buzzer.io;

/**
 * 
 * @author Master
 *
 */
public interface Constants {

    public static final byte CMD_HELLO        = (byte) 0xE1; // 225

    public static final byte CMD_QESTION      = (byte) 0x01; // 1

    public static final byte CMD_ANSWER_READY = (byte) 0x02; // 2

    public static final byte CMD_ANSWER       = (byte) 0x03; // 3

    public static final byte CMD_CONTENT      = (byte) 0x10; // 10

    public static final byte CMD_CLOSE        = (byte) 0x04; // 4

    public static final byte CMD_ANSWER_COUNT = (byte) 0x20; // 
}

package de.se.buzzer.io;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketTimeoutException;
import java.net.UnknownHostException;
import java.util.Arrays;

import android.util.Log;

/**
 * 
 * @author M. Friedeboldt
 */
public class MConnection implements Constants {

    /** Port to Buzzer Server */
    private static final int    PORT = 3381;

    /** Host to Buzzer Server */
    private static final String HOST = "192.168.178.20";

    /** Socket to Buzzer Server */
    private Socket              outputLine;

    /**
     * Construktor
     */
    public MConnection() throws UnknownHostException, IOException {
        // Connect
        connect();
    }

    /**
     * @throws IOException 
     * @throws UnknownHostException 
     */
    public void connect() throws UnknownHostException, IOException {
        Log.d( "MConnection", "Create Connect to (" + HOST + ":" + PORT + ")" );
        outputLine = new Socket( HOST, PORT );
        Log.d( "MConnection", "OK Create Connect to (" + PORT + ")" );
    }

    /**
     * Create Session and register on Buzzer Server<br>
     * - CMD_HELLO  >> SEND<br>
     * - Session ID << READ<br>
     * @return

... [truncated, 274 more lines] ...

package de.se.buzzer.io;

import java.io.IOException;
import java.net.UnknownHostException;
import java.util.HashMap;
import java.util.List;

import de.se.buzzer.LineContainer;
import de.se.buzzer.RequestBuilder;
import de.se.buzzer.conf.Context;
import de.se.buzzer.enums.RequestState;
import de.se.buzzer.handler.AnswerHandler;
import de.se.buzzer.handler.ContentLoaderInterface;

/**
 * 
 * @author Master
 */
public class RequestHandler implements ContentLoaderInterface {

    /** Connection Session ID*/
    private long          sessionId;

    /** Connection to server*/
    private MConnection   connection;

    /** State for Advertisement */
    private RequestState  state;

    /** Wait Time*/
    private int           waitRequestTimeout = 30; // 30 Sekunden

    /** Handler for Request */
    private AnswerHandler answerHandler;

    /**
     * Start the request.<br>
     * @param para 
     */
    public void search(HashMap<String, String> para) {
        /*
         * 0. Init
         */
        answerHandler = new AnswerHandler(this);

        /*
         * 1. Connection
         */
        try {
            connection = new MConnection();

... [truncated, 107 more lines] ...