/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package dashfx.lib.data.endpoints;

import dashfx.lib.data.*;
import dashfx.lib.controls.DesignableData;
import dashfx.lib.data.values.*;

/**
 *
 * @author patrick
 */
@DesignableData(name = "Test Data", types =
{
	DataProcessorType.DataSender,
	DataProcessorType.DataSource,
}, description = "Simple sin/cosine wave generator", protocols = {"testdatasource"})
public class TestDataSource implements DataSource, Runnable, DataSender
{

	private DataProcessor proc;
	private Thread nNeedles;
	private boolean shouldBeRunning = true;

	@Override
	public boolean init(InitInfo info)
	{
		// nothing we need :)
		return true;
	}

	@Override
	public boolean isConnected()
	{
		return true;
	}

	@Override
	public void setProcessor(DataProcessor proc)
	{
		this.proc = proc;
		if (nNeedles == null && proc != null)
		{
			nNeedles = new Thread(this);
			nNeedles.setDaemon(true);
		}
		if (proc == null && nNeedles != null)
		{
			shouldBeRunning = false;
		}
		else
		{
			if (!nNeedles.isAlive())
			{
				nNeedles.start();
			}
		}
	}

	@Override
	public void run()
	{
		try
		{
			double t = 0;
			proc.processData(null, new SimpleTransaction(new SmartValue(new StringSmartValue("Clever Gollumn"), SmartValueTypes.String, "invisible")));
			while (shouldBeRunning)
			{
				final SimpleTransaction trans = new SimpleTransaction();

				trans.addValue(new SmartValue(new DoubleSmartValue(Math.sin(t)), SmartValueTypes.Double, "sin"));
				trans.addValue(new SmartValue(new DoubleSmartValue(Math.cos(t)), SmartValueTypes.Double, "cos"));
				trans.addValue(new SmartValue(new DoubleSmartValue(Math.sin(t) + Math.cos(t * 0.989)), SmartValueTypes.Double, "complex"));
				trans.addValue(new SmartValue(new StringSmartValue(String.valueOf(Math.sin(t))), SmartValueTypes.String, "sins"));

				proc.processData(null, trans);
				try
				{
					Thread.sleep(50);
				}
				catch (InterruptedException ex)
				{
				}
				t += 0.02;
			}
		}
		catch (NullPointerException n)
		{
		}
	}

	@Override
	public void send(SmartValue data)
	{
		System.out.printf("We got an update for '%s' => \t %s (%s)\n", data.getName(), data.getValue().toString(), data.getType().toString());
	}
}