// $Id: BcastInject.java,v 1.7 2003/10/07 21:46:08 idgay Exp $

/*									tab:4
 * "Copyright (c) 2000-2003 The Regents of the University  of California.  
 * All rights reserved.
 *
 * Permission to use, copy, modify, and distribute this software and its
 * documentation for any purpose, without fee, and without written agreement is
 * hereby granted, provided that the above copyright notice, the following
 * two paragraphs and the author appear in all copies of this software.
 * 
 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
 * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
 * OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
 * CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 * 
 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
 * AND FITNESS FOR A PARTICULAR PURPOSE.  THE SOFTWARE PROVIDED HEREUNDER IS
 * ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
 * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
 *
 * Copyright (c) 2002-2003 Intel Corporation
 * All rights reserved.
 *
 * This file is distributed under the terms in the attached INTEL-LICENSE     
 * file. If you do not find these files, copies can be found by writing to
 * Intel Research Berkeley, 2150 Shattuck Avenue, Suite 1300, Berkeley, CA, 
 * 94704.  Attention:  Intel License Inquiry.
 */


/**
 * 
 *
 * @author <a href="mailto:szewczyk@sourceforge.net">Robert Szewczyk</a>
 */
package net.tinyos.tools;

import net.tinyos.util.*;
import java.io.*;
import java.util.Properties;
import net.tinyos.message.*;

public class BcastInject implements MessageListener {
    static Properties p = new Properties();
    public static final byte LED_ON = 1;
    public static final byte LED_OFF = 2;
    public static final byte RADIO_LOUDER = 3;
    public static final byte RADIO_QUIETER = 4;
    public static final byte START_SENSING = 5;
    public static final byte READ_LOG = 6;

    public boolean read_log_done = false; 
        
    public static final short TOS_BCAST_ADDR = (short) 0xffff;
	
    public static void usage() {
	System.err.println("Usage: java net.tinyos.tools.BcastInject"+
			   " <command> [arguments]");
	System.err.println("\twhere <command> and [arguments] can be one of the following:");
	System.err.println("\t\tled_on");
	System.err.println("\t\tled_off");
	System.err.println("\t\tradio_louder");
	System.err.println("\t\tradio_quieter");
	System.err.println("\t\tstart_sensing [nsamples interval_ms]");
	System.err.println("\t\tread_log [dest_address]");
    }

    public static void startSensingUsage() {
	System.err.println("Usage: java net.tinyos.tools.BcastInject"
			   + " start_sensing [num_samples interval_ms]");
    }
    public static void  readLogUsage() {
	System.err.println("Usage: java net.tinyos.tools.BcastInject" +
			   " read_log [dest_address]");
    } 

    public static byte restoreSequenceNo() {
	try {
	    FileInputStream fis = new FileInputStream("bcast.properties");
	    p.load(fis);
	    byte i = (byte)Integer.parseInt(p.getProperty("sequenceNo", "1"));
	    fis.close();
	    return i;
	} catch (IOException e) {
	    p.setProperty("sequenceNo", "1");
	    return 1;
	}
    }
    public static void saveSequenceNo(int i) {
	try {
	    FileOutputStream fos = new FileOutputStream("bcast.properties");
	    p.setProperty("sequenceNo", Integer.toString(i));
	    p.store(fos, "#Properties for BcastInject\n");
	} catch (IOException e) {
	    System.err.println("Exception while saving sequence number" +
			       e);
	    e.printStackTrace();
	}
    }

    public static void main(String[] argv) throws IOException {
	String cmd;
	byte sequenceNo = 0;
	boolean read_log = false;

	if (argv.length < 1) {
	    usage();
	    System.exit(-1);
	}

	cmd = argv[0];

	if (cmd.equals("start_sensing") && argv.length != 3) {
	    startSensingUsage();
	    System.exit(-1);
	} else if (cmd.equals("read_log") && argv.length != 2) {
	    readLogUsage();
	    System.exit(-1);
	}
	
	SimpleCmdMsg packet = new SimpleCmdMsg(); 

	sequenceNo = restoreSequenceNo();
	packet.set_seqno(sequenceNo);
	packet.set_hop_count((short)0);
	packet.set_source(0);

	if (cmd.equals("led_on")) {
	    packet.set_action(LED_ON);
	} else if (cmd.equals("led_off")) {
	    packet.set_action(LED_OFF);
	} else if (cmd.equals("radio_louder")) {
	    packet.set_action(RADIO_LOUDER);
	} else if (cmd.equals("radio_quieter")) {
	    packet.set_action(RADIO_QUIETER);
	} else if (cmd.equals("start_sensing")) {
	    packet.set_action(START_SENSING);
	    short nsamples = (short)Integer.parseInt(argv[1]);
	    long interval_ms = (long)Integer.parseInt(argv[2]);
	    packet.set_args_ss_args_nsamples(nsamples);
	    packet.set_args_ss_args_interval(interval_ms);
	} else if (cmd.equals("read_log")) {
	    read_log = true;
	    packet.set_action(READ_LOG);
	    short address = (short)Integer.parseInt(argv[1]);
	    packet.set_args_rl_args_destaddr(address);
	} else {
	    usage();
	    System.exit(-1);
	}
        
	try {
	    System.err.print("Sending payload: ");
	  		
	    for (int i = 0; i < packet.dataLength(); i++) {
		System.err.print(Integer.toHexString(packet.dataGet()[i] & 0xff)+ " ");
	    }
	    System.err.println();

	    MoteIF mote = new MoteIF(PrintStreamMessenger.err);

	    // Need to wait for a read_log message to come back
	    BcastInject bc = null;
	    if (read_log) {
		bc = new BcastInject();
		mote.registerListener(new LogMsg(), bc);
	    }
	    
	    mote.send(TOS_BCAST_ADDR, packet);

	    if (read_log) {
		synchronized (bc) {
		    if (bc.read_log_done == false) {
			System.err.println("Waiting for response to read_log...");
			bc.wait(10000);
		    }
		    if (bc.read_log_done == false) {
			System.err.println("Warning: Timed out waiting for response to read_log command!");
		    }
		}
	    }

	    saveSequenceNo(sequenceNo+1);
	    System.exit(0);

	} catch(Exception e) {
	    e.printStackTrace();
	}	

    }

    public void messageReceived(int dest_addr, Message m) {
	LogMsg lm = (LogMsg) m;
	System.err.println("Received log message: "+lm);

	System.err.print("Log values: ");
	for (int i = 0; i < lm.numElements_log(); i++) {
	    short val = lm.getElement_log(i);
	    System.err.print(Integer.toHexString((int)val)+" ");
	}
	System.err.println("");

	synchronized (this) {
	    read_log_done = true;
	    this.notifyAll();
	}
    }

}