smsreceiver.java

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

package net.frog_parrot.net;

import java.io.*;
import javax.microedition.io.*;
import javax.wireless.messaging.*;

/**
 * This class handles listening for the SMS messages 
 * from the remote player.
 *
 * @author Carol Hamer
 */
public class SMSReceiver implements Runnable, MessageListener {

  //--------------------------------------------------------
  //  game instance fields

  /**
   * The class to report back to.
   */
  private SMSManager mySMSManager;

  /**
   * The connection to listen for messages on.
   */
  private MessageConnection myConnection;

  /**
   * whether it's time to clean up.
   */
  private boolean myShouldStop;

  //--------------------------------------------------------
  //  lifecycle

  /**
   * Find connections and start up the listener thread.
   */
  boolean init(SMSManager manager) throws IOException {
    myShouldStop = false;
    mySMSManager = manager;
    boolean retVal = false;
    // We start by checking for a connection with data to read
    // to see if the application was launched because of 
    // receiving an invitation.
    String[] connections = PushRegistry.listConnections(true);
    if (connections != null && connections.length > 0) {
      retVal = true;
    }
    // Here we get the name of all connections that are open 
    // to this application, whether they have data or not.
    connections = PushRegistry.listConnections(false);
    if (connections == null || connections.length == 0) {
      throw(new IOException("No push-port registered"));
    }
    myConnection = (MessageConnection)Connector.open(connections[0]);
    myConnection.setMessageListener(this);
    // Since listening for messages is a blocking operation, 
    // we need to start a new thread to do it:
    Thread thread = new Thread(this);
    thread.start();
    return(retVal);
  }

  /**
   * Find connections and start up the listener thread.
   */
  void shutDown() {
    myShouldStop = true;
    try {
      myConnection.close();
    } catch (Exception e) {}
  }

  //--------------------------------------------------------
  //  listen for messages

  /**
   * Implementation of MessageListener.
   *
   * This does nothing since the receiving loop is set 
   * to treat each message as it arrives..
   *
   * @param conn the connection with messages available.
   */
  public void notifyIncomingMessage(MessageConnection conn) {
  }

  /**
   * Start the listener thread.
   */
  public void run() {
    try {
      while(true) {
	//System.out.println("about to receive");
	Message msg = myConnection.receive();
	//System.out.println("received: " + msg);
	if (msg != null) {
	  String senderAddress = msg.getAddress();
	  //System.out.println("address: " + senderAddress);
	  // accept only binary messages from the player
	  // we're currently playing with -- ignore 
	  // messages from other players.
	  if((mySMSManager.checkPhoneNum(senderAddress))
	     && (msg instanceof BinaryMessage)) {
	    System.out.println("received binary message");
	    byte[] data = ((BinaryMessage)msg).getPayloadData();
	    System.out.println("data.length: " + data.length);
	    int index = 0;
	    String taunt = null;
	    while(index < data.length) {
	      //System.out.println("data " + index + ": " + data[index]);
	      switch(data[index]) {
		// if we've just received an invitation to 
		// start the game, then we set the phone 
		// number of the other player
	      case SMSManager.START_GAME_FLAG:
		System.out.println("start game-->taunt: " + taunt);
		index++;
		if(index != data.length) {
		  taunt = new String(data, index, data.length - index);
		}
		index = data.length;
		mySMSManager.receiveInvitation(taunt);
		break;
	      case SMSManager.END_GAME_FLAG:
		System.out.println("end game");
		index++;
		System.out.println("index: " + index);
		System.out.println("data.length: " + data.length);
		if(index != data.length) {
		  taunt = new String(data, index, data.length - index);
		}
		System.out.println("taunt: " + taunt);
		index = data.length;
		mySMSManager.receiveGameOver(taunt);
		break;
	      case SMSManager.END_TURN_FLAG:
		//System.out.println("ending turn");
		index++;
		if(index != data.length) {
		  taunt = new String(data, index, data.length - index);
		}
		index = data.length;
		mySMSManager.endTurn(taunt);
		break;
	      default:
		//System.out.println("setting move");
		// the default case is that we've received
		// some move data to pass along to the 
		// game logic.
		byte[] move = new byte[4];
		System.arraycopy(data, index, move, 0, 4);
		mySMSManager.setMove(move);
		index += 4;
		break;
	      }
	    }
	  }
	} // if (msg != null) {
      }
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
	myConnection.close();
      } catch (Exception e) {}
    }
  }

}