boardreader.java

Creat mobile game Creat mobile game Creat mobile game Creat mobile game

package net.frog_parrot.dungeon;

import java.io.*;
import javax.microedition.io.*;
import javax.microedition.io.HttpConnection;
import javax.microedition.lcdui.*;
import javax.microedition.rms.*;

import net.frog_parrot.util.DataConverter;

/**
 * This class contacts a remote server in order to 
 * downolad data for new game boards and stores 
 * them locally..
 *
 * @author Carol Hamer
 */
public class BoardReader extends Thread {

  //--------------------------------------------------------
  //  fields

  /**
   * This is the name of the local datastore on the CLDC device.
   */
  public static final String LOCAL_DATASTORE = "BoardData";

  /**
   * This is the URL to contact.
   * IMPORTANT: before compiling, the following URL
   * must be changed to the correct URL of the 
   * machine running the DungeonDownload servlet.
   */
  public static final String SERVER_URL 
          = "http://testserver.com/games/DungeonDownload2";

  /**
   * This is the size of the byte array containing 
   * all the info for one board..
   */
  public static final int DATA_LENGTH = 48;

  //--------------------------------------------------------
  //  instance fields
  //   these are used by the thread when downloading 
  //   boards to display a possible error message.

  /**
   * The MIDlet subclass, used to set the Display 
   * in the case where an error message needs to be sent..
   */
  private Dungeon myDungeon;

  /**
   * The Canvas subclass, used to set the Display 
   * in the case where an error message needs to be sent..
   */
  private DungeonCanvas myCanvas;

  //--------------------------------------------------------
  //  initialization

  /**
   * Constructor is used only when the program wants 
   * to spawn a data-fetching thread, not for merely 
   * reading local data with static methods.
   */
  BoardReader(Dungeon dungeon, DungeonCanvas canvas) {
    myDungeon = dungeon;
    myCanvas = canvas;
  }

  //--------------------------------------------------------
  //  local data methods
  //   note that these methods are static and do 
  //   not run on a separate thread even though this 
  //   class is a subclass of Thread

  /**
   * @return the number of boards currently stored in the 
   * device memory. (this does not include the hard-coded boards)
   */
  static int getNumBoards() {
    RecordStore store = null;
    int retVal = 0;
    try {
      // if the record store does not yet exist, don't 
      // create it
      store = RecordStore.openRecordStore(LOCAL_DATASTORE, false);
      if(store != null) {
	retVal = store.getNumRecords();
      }
    } catch(Exception e) {
    } finally {
      try {
	if(store != null) {
	  store.closeRecordStore();
	}
      } catch(Exception e) {
	// if the record store is open this shouldn't throw.
      }
    }
    //System.out.println("getNumBoards-->returning: " + retVal);
    return(retVal);
  }

  /**
   * @return the byte array that gives the board that 
   * has the number boardNum (if it is found). returns null
   * if there is no board in memory that has the given number.
   */
  static byte[] getBoardData(int boardNum) {
    RecordStore store = null;
    byte[] retArray = null;
    try {
      // if the record store does not yet exist, don't 
      // create it
      store = RecordStore.openRecordStore(LOCAL_DATASTORE, false);
      if((store != null) && (store.getNumRecords() >= boardNum)) {
	retArray = store.getRecord(boardNum);
      }
    } catch(Exception e) {
    } finally {
      try {
	if(store != null) {
	  store.closeRecordStore();
	}
      } catch(Exception e) {
	// if the record store is open this shouldn't throw.
      }
    }
    return(retArray);
  }

  /**
   * Saves the data of a board being downloaded from the internet
   */
  static void saveBoardData(byte[] data) throws Exception {
    RecordStore store = null;
    try {
      // if the record store does not yet exist, 
      // create it
      store = RecordStore.openRecordStore(LOCAL_DATASTORE, true);
      store.addRecord(data, 0, data.length);
    } finally {
      try {
	if(store != null) {
	  store.closeRecordStore();
	}
      } catch(Exception e) {
	// if the record store is open this shouldn't throw.
      }
    }
  }

  //--------------------------------------------------------
  //  download methods

  /**
   * Makes a HTTP connection to the server and gets data
   * for more boards.
   */
  public void run() {
    // we sync on the class because we don't want multiple 
    // instances simultaneously attempting to download
    synchronized(this.getClass()) {
      HttpConnection connection = null;
      DataInputStream dis = null;
      DataOutputStream dos = null;
      StringBuffer buff = new StringBuffer();
      try {
	System.out.println("BoardReader.run-->about to open: " + SERVER_URL);
	connection = (HttpConnection)Connector.open(SERVER_URL);
	buff.append("opened:");
	connection.setRequestMethod(HttpConnection.POST);
	System.out.println("BoardReader.run-->conn: " + connection);
	// send the number of local boards to the server 
	// so the server will know which boards to send:
	int numBoards = getNumBoards();
	buff.append("localBoards:" + numBoards + ":");
	dos = connection.openDataOutputStream();
	// munBoards is an int but it is transferred as a 
	// byte.  It should therefore not be more than 15.
	dos.write(numBoards);
	// flush to send the message:
	dos.flush();
	// Getting the response code will open the connection,
	// send the request, and read the HTTP response headers.
	// The headers are stored until requested.
	int rc = connection.getResponseCode();
	if (rc != HttpConnection.HTTP_OK) {
	  throw new IOException("HTTP response code: " + rc);
	}

	// connection.getLength() returns the value of the 
	// content-length header, not the number of bytes 
	// available to read.  The server must set this header
	// if the client wants to use it.
	// Here numBoards is the number 
	// of boards that will be read from the downloaded data.
	int dataLength = (int)connection.getLength();
	buff.append("dataLength:" + dataLength + ":");
	numBoards = (dataLength)/DATA_LENGTH;
	buff.append("remoteBoards:" + numBoards + ":");
	dis = connection.openDataInputStream();
	readStamp(dis, buff);
	buff.append("stamp:");
	for(int i = 0; i < numBoards; i++) {
	  byte[] data = new byte[DATA_LENGTH];
	  dis.readFully(data);
	  saveBoardData(data);
	  buff.append("done:" + i + ":");
	}
	System.out.println(buff.toString());
      } catch(Exception e) {
	e.printStackTrace();
	// if this fails, it is almost undoubtedly 
	// a communication problem (server down, etc.)
	// we need to give the right message to the user:
	//Alert alert = new Alert("download failed", 
	//	    "please try again later", null, AlertType.INFO);
	Alert alert = new Alert("download failed", buff.toString()
	    + e.getClass() + "" + e.getMessage(), null, AlertType.INFO);
	// We set the timeout to forever so this Alert will 
	// have a default dismiss command. When the user 
	// presses the Alert.DISMISS_COMMAND, the displayable
	// myCanvas will become current (see setCurrent() below):
	alert.setTimeout(Alert.FOREVER);
	//myCanvas.setNeedsRepaint();
	// the second arg tells the Display to go to 
	// myCanvas when the user dismisses the alert
	Display.getDisplay(myDungeon).setCurrent(alert, myCanvas);
      } finally {
	try {
	  if(dis != null) {
	    dis.close();
	  }
	  if(dos != null) {
	    dos.close();
	  }
	  if(connection != null) {
	    connection.close();
	  }
	} catch(Exception e) {
	  // if this throws, at least we made our best effort 
	  // to close everything up....
	}
      }
    }
  }

  /**
   * Advanced the stream past a stamp.
   */
  private void readStamp(InputStream dis, StringBuffer buff) 
        throws IOException {
    int curr = dis.read();
    while((curr != 3) && (curr != -1)) {
      buff.append(curr + ".");
      curr = dis.read();
    }
    if(curr == -1) {
      throw new IOException("failed to find stamp 3");
    }
    while(curr == 3) {
      buff.append(curr + ".");
      curr = dis.read();
    }
    buff.append(curr + ".");
    if(curr != 5) {
      throw new IOException("failed to find stamp 5");
    }
    System.out.print("readStamp-->done");
  }

}