// Copyright (c) 2000 Just Objects B.V. <just@justobjects.nl>
// Distributable under LGPL license. See terms of license at gnu.org.

package nl.justobjects.pushlet.test;

import nl.justobjects.pushlet.core.Event;
import nl.justobjects.pushlet.core.EventPullSource;
import nl.justobjects.pushlet.core.SessionManager;
import nl.justobjects.pushlet.util.Rand;


/**
 * Event sources for testing.
 *
 * @author Just van den Broecke - Just Objects &copy;
 * @version $Id: TestEventPullSources.java,v 1.10 2007/11/09 13:16:57 justb Exp $
 */
public class TestEventPullSources {

	/**
	 * Produces a fake temparature event.
	 */
	public static class RFIDEventPullSource extends EventPullSource {
		public static String EPCCode = null;
		
		public long getSleepTime() {
			return 50;
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/RFID");
//			LinkDll linkDll = new LinkDll();
//			linkDll.XCOpen("aaa", "bbb");
//			linkDll.XCPowerOn(1);
//			linkDll.XCIdentify(1, (byte) 0x01, (byte) 0x02, (byte) 0x00);
//			LinkDllThread thread = new LinkDllThread();
//			Thread t = new Thread(thread);
//			t.start();
//
//			event.setField("epc",  "" + EPCCode);
		
			return event;
		}

	
	}
	
	/**
	 * Produces a fake temparature event.
	 */
	public static class WispyTestEventPullSource extends EventPullSource {
		String[] cities = {"MyTestcity5", null, "MyTestcity6", null,
				"MyTestcity7", null, "MyTestcity8", null, "MyTestcity9", null};

		long time = 1;
		public long getSleepTime() {
			time = Rand.randomLong(0, 500);
			return time;
		}
		public Event pullEvent() {
			int cityNumber = Rand.randomInt(0, (cities.length) / 2 - 1);
			int nextCityIndex = 2 * cityNumber;

			Event event = Event.createDataEvent("/wispycity");

			event.setField("number", "" + cityNumber);
			event.setField("city", cities[nextCityIndex]);
			event.setField("time", time);
			time = 1;
			if (cities[nextCityIndex + 1] == null) {
				cities[nextCityIndex + 1] = "" + Rand.randomInt(5, 10);
			}
			int currentCityValue = new Integer(cities[nextCityIndex + 1]).intValue();
			int newCityValue = currentCityValue + Rand.randomInt(-2, 2);

			event.setField("value", "" + newCityValue);
			return event;
		}
	}
	
	/**
	 * Produces a fake temparature event.
	 */
	static public class TemperatureEventPullSource extends EventPullSource {
		String[] cities = {"Temperatureaaa", null, "Temperaturebbb", null,
				"Temperatureccc", null, "Temperatureddd", null, "Temperatureeee", null};
		long time = 1;
		public long getSleepTime() {
			time = Rand.randomLong(0, 3000);
			return time;
		}

		public Event pullEvent() {
			int cityNumber = Rand.randomInt(0, (cities.length) / 2 - 1);
			int nextCityIndex = 2 * cityNumber;

			Event event = Event.createDataEvent("/temperature");

			event.setField("number", "" + cityNumber);
			event.setField("city", cities[nextCityIndex]);
			event.setField("time", time);
			time = 1;
			if (cities[nextCityIndex + 1] == null) {
				cities[nextCityIndex + 1] = "" + Rand.randomInt(5, 10);
			}
			int currentCityValue = new Integer(cities[nextCityIndex + 1]).intValue();
			int newCityValue = currentCityValue + Rand.randomInt(-2, 2);

			event.setField("value", "" + newCityValue);
			return event;
		}
	}

	/**
	 * Produces a ping event.
	 */
	static public class PingEventPullSource extends EventPullSource {
		public long getSleepTime() {
			return 3000;
		}

		public Event pullEvent() {

			return Event.createDataEvent("/pushlet/ping");
		}
	}

	/**
	 * Produces an event related to the JVM status.
	 */
	static public class SystemStatusEventPullSource extends EventPullSource {
		Runtime runtime = Runtime.getRuntime();

		public long getSleepTime() {
			return 4000;
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/system/jvm");
			event.setField("totalMemory", "" + runtime.totalMemory());
			event.setField("freeMemory", "" + runtime.freeMemory());
			event.setField("maxMemory", "" + runtime.maxMemory());
			int activeCount = Thread.activeCount();
			event.setField("threads", "" + activeCount);

			return event;
		}
	}

	/**
	 * Produces an event related to the Dispatcher.getInstance(). status.
	 */
	static public class PushletStatusEventPullSource extends EventPullSource {

		public long getSleepTime() {
			return 5000;
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/system/pushlet");
			// p(Dispatcher.getStatus());
			event.setField("publisher", "" + SessionManager.getInstance().getStatus());
			return event;
		}
	}


	/**
	 * Produces events simulating stocks from the AEX.
	 */
	static public class AEXStocksEventPullSource extends EventPullSource {

		String[] stocks = {"abn amro1", "26",
				"aegon1", "38",
				"ahold1", "34",
				"akzo nobel1", "51",
				"asm lith h1", "26",
				"corus plc1", "2",
				"dsm", "40",
				"elsevier", "14",
				"fortis (nl)", "32",
				"getronics", "6",
				"gucci", "94",
				"hagemeyer", "25",
				"heineken", "61",
				"ing c", "78",
				"klm", "66",
				"kon olie", "66",
				"kpn", "13",
				"numico c", "44",
				"philips, kon", "38",
				"tnt", "26",
				"unilever c", "62",
				"vendex kbb", "16",
				"vnu", "49",
				"wolt-kluw c", "25"};

		public long getSleepTime() {
			return Rand.randomLong(0, 1000);
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/stocks/aex");
//			Event event = null;
			int stockNumber = Rand.randomInt(0, (stocks.length) / 2 - 1);
			int nextStockIndex = 2 * stockNumber;

			event.setField("number", "" + stockNumber);
			event.setField("name", stocks[nextStockIndex]);
			if (stocks[nextStockIndex + 1] == null) {
				stocks[nextStockIndex + 1] = "" + Rand.randomInt(50, 150);
			}
			int currentStockValue = new Integer(stocks[nextStockIndex + 1]).intValue();
			int newStockValue = currentStockValue + Rand.randomInt(-2, 2);

			event.setField("rate", "" + newStockValue + "." + Rand.randomInt(0, 99));
			return event;
		}

	}
	
	
	
	static public class AEXStocksEventPullSource2 extends EventPullSource {

		String[] stocks = {"abn amro", "26",
				"aegon", "38",
				"ahold", "34",
				"akzo nobel", "51",
				"asm lith h", "26",
				"corus plc", "2",
				"dsm", "40",
				"elsevier", "14",
				"fortis (nl)", "32",
				"getronics", "6",
				"gucci", "94",
				"hagemeyer", "25",
				"heineken", "61",
				"ing c", "78",
				"klm", "66",
				"kon olie", "66",
				"kpn", "13",
				"numico c", "44",
				"philips, kon", "38",
				"tnt", "26",
				"unilever c", "62",
				"vendex kbb", "16",
				"vnu", "49",
				"wolt-kluw c", "25"};

		public long getSleepTime() {
			return Rand.randomLong(0, 30);
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/stocks/aex2");
//			Event event = null;
			int stockNumber = Rand.randomInt(0, (stocks.length) / 2 - 1);
			int nextStockIndex = 2 * stockNumber;

			event.setField("number", "" + stockNumber);
			event.setField("name", stocks[nextStockIndex]);
			if (stocks[nextStockIndex + 1] == null) {
				stocks[nextStockIndex + 1] = "" + Rand.randomInt(50, 150);
			}
			int currentStockValue = new Integer(stocks[nextStockIndex + 1]).intValue();
			int newStockValue = currentStockValue + Rand.randomInt(-2, 2);

			event.setField("rate", "" + newStockValue + "." + Rand.randomInt(0, 99));
			return event;
		}

	}

	/**
	 * Produces an URL event for automatic webpresentation.
	 */
	static public class WebPresentationEventPullSource extends EventPullSource {
		String slideRootDir = "http://www.justobjects.org/cowcatcher/browse/j2ee/slides/";
		String[] slideURLs = {
				"ejb/j2ee/ejbover/slide.0.0.html",
				"ejb/j2ee/ejbover/slide.0.1.html",
				"ejb/j2ee/ejbover/slide.0.2.html",
				"ejb/j2ee/ejbover/slide.0.3.html",
				"ejb/j2ee/ejbover/slide.0.4.html"
		};

		int nextSlideNumber = 0;

		public long getSleepTime() {
			return 5000;
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/webpres/auto");
			event.setField("url", slideRootDir + slideURLs[nextSlideNumber++]);
			if (nextSlideNumber == slideURLs.length) {
				nextSlideNumber = 0;
			}
			// Log.debug("Sending next slide url=" + event.getField("url"));
			return event;
		}
	}

	/**
	 * Produces an event related to the Dispatcher.getInstance(). status.
	 */
	static public class TestEventPullSource extends EventPullSource {
		private int number = 0;

		public long getSleepTime() {
			return 2000;
		}

		public Event pullEvent() {
			Event event = Event.createDataEvent("/system/test");
			// p(Dispatcher.getInstance()..getStatus());
			event.setField("nr", "" + (number++));
			event.setField("time", "" + System.currentTimeMillis());
			return event;
		}

	}

	/**
	 * Util: stderr print method.
	 */
	public static void e(String s) {
		System.out.println(s);
	}

	/**
	 * Util: stdout print method.
	 */
	public static void p(String s) {
		// System.out.println(s);
	}
}

/*
 * $Log: TestEventPullSources.java,v $
 * Revision 1.10  2007/11/09 13:16:57  justb
 * use Rand from util package (and and Rand.java to pushlet client jar
 *
 * Revision 1.9  2005/02/28 09:14:56  justb
 * sessmgr/dispatcher factory/singleton support
 *
 * Revision 1.8  2005/02/21 16:59:17  justb
 * SessionManager and session lease introduced
 *
 * Revision 1.7  2005/02/18 10:07:23  justb
 * many renamings of classes (make names compact)
 *
 * Revision 1.6  2005/02/18 09:54:15  justb
 * refactor: rename Publisher Dispatcher.getInstance(). and single Subscriber class
 *
 * Revision 1.5  2004/09/03 22:35:37  justb
 * Almost complete rewrite, just checking in now
 *
 * Revision 1.4  2003/12/03 21:16:58  justb
 * *** empty log message ***
 *
 * Revision 1.3  2003/08/15 08:37:41  justb
 * fix/add Copyright+LGPL file headers and footers
 *
 * Revision 1.2  2003/05/18 16:15:08  justb
 * support for XML encoded Events
 *
 * Revision 1.1.1.1  2002/09/24 21:02:33  justb
 * import to sourceforge
 *
 * Revision 1.1.1.1  2002/09/20 22:48:19  justb
 * import to SF
 *
 * Revision 1.1.1.1  2002/09/20 14:19:01  justb
 * first import into SF
 *
 * Revision 1.6  2002/07/29 10:17:22  just
 * no message
 *
 * Revision 1.5  2001/02/18 23:45:13  just
 * fixes for AEX
 *
 * Revision 1.4  2000/10/30 14:16:09  just
 * no message
 *
 * Revision 1.3  2000/08/31 12:49:50  just
 * added CVS comment tags for log and copyright
 *
 *
 */