//
// Copyright (C) 2007 - Cogent Real-Time Systems Inc.  All rights reserved.
//

var DataHub_iframe;
var DataHub_points = [];
var DataHub_url;

function DataHubStream (iframeid, sourceurl)
{
	this.iframeid = iframeid;
	this.url = sourceurl;
	this.wasloaded = false;
	this.activity = false;
	this.request_children = false;
	this.parent_point = null;
	this.recursive = false;
	this.points = {};

	this.qualities = [];
	this.qualities[0x00] = "Bad";
	this.qualities[0x40] = "Uncertain";
	this.qualities[0x04] = "Config error";
	this.qualities[0x08] = "Not connected";
	this.qualities[0x0c] = "Device failure";
	this.qualities[0x10] = "Sensor failure";
	this.qualities[0x14] = "Last known";
	this.qualities[0x18] = "Comm failure";
	this.qualities[0x1c] = "Out of service";
	this.qualities[0x20] = "Waiting for data";
	this.qualities[0x44] = "Last usable";
	this.qualities[0x50] = "Sensor calibration";
	this.qualities[0x54] = "EGU exceeded";
	this.qualities[0x58] = "Sub normal";
	this.qualities[0xc0] = "Good";
	this.qualities[0xd8] = "Local override";
}

DataHubStream.prototype.Attach = function ()
{
	this.iframe = document.getElementById(this.iframeid);
}

DataHubStream.prototype.GetUrl = function ()
{
    var		str, i;

    if (this.parent_point)
    {
	str = this.url + "&name=" + this.parent_point + "&children=true";
	if (this.recursive)
	    str = str + "&recursive=true";
    }
    else
    {
	str = this.url + "&name=";
	for (i in this.points)
	{
	    str = str + this.points[i].name + "|";
	}
    }
    return str;
}

DataHubStream.prototype.RegisterChildren = function (parentname, recursive)
{
    this.parent_point = parentname;
    this.recursive = recursive;
}
    
DataHubStream.prototype.RegisterEvent = function (ptname, expression)
{
    this.Register(ptname, expression);
}
    
DataHubStream.prototype.Register = function (ptname, expression)
{
	var		pt = this.points[ptname];
	var		idx, i;
	
	if (!pt)
	{
		pt = { name: ptname,
			   quality: 0,
			   timestamp: 0,
			   previous: null,
			   value: null,
			   callbacks: [],
			   ncallbacks: 0,
			   maxcallbacks: 0 };
		this.points[ptname] = pt;
	}
	if (pt.ncallbacks == pt.maxcallbacks)
	{
		idx = pt.maxcallbacks;
		pt.maxcallbacks++;
	}
	else
	{
		for (i=0; i<pt.maxcallbacks; i++)
		{
			if (pt.callbacks[i] == null)
			{
				idx = i;
				break;
			}
		}
	}
	
	pt.ncallbacks++;
	pt.callbacks[idx] = expression;
	return idx;
}

DataHubStream.prototype.Unregister = function (ptname, idx)
{
	var		success = false;
	var		pt = this.points[ptname];
	if (pt && pt.callbacks[idx])
	{
		pt.callbacks[idx] = null;
		pt.ncallbacks--;
		success = true;
	}
	return success;
}

DataHubStream.prototype.Reconnect = function ()
{
	// We want to issue reload to stop IE from clicking whenever we
	// reconnect, but IE cannot reliably handle a reload.  It simply
	// sometimes fails to run.  So, live with the click by never
	// setting this.wasreloaded to true.
	if (!this.wasloaded)
	{
		var		str = this.GetUrl();
		this.iframe.src = str;
		//this.wasloaded = true;
	}
	else
	{
		this.iframe.contentWindow.location.reload(false);
	}
	this.activity = false;
}

DataHubStream.prototype.NewData = function (data)
{
	var	values = eval (data);
	var str = "";
	var point, i;

	this.activity = true;
	
	for (i=0; i<values.length; i++)
	{
		point = this.points[values[i].n];
		if (point)
		{
			point.quality = values[i].q;
			point.previous = (point.value != null) ? point.value : values[i].v;
			point.value = values[i].v;
			point.timestamp = values[i].t;
			for (j in point.callbacks)
			{
				eval (point.callbacks[j]);
			}
		}
	}
}

// As a user, you need so supply these functions in your mainline
// with a reference to the appropriate DataHubStream object.
//function onNewData (data)
//{
//	myDataHubStream.NewData(data);
//}
//
//function onReconnect ()
//{
//	myDataHubStream.Reconnect();
//}

DataHubStream.prototype.QualityName = function (quality)
{
	var 	x = this.qualities[quality];
	if (!x)
		x = "Other";
	return x;
}

DataHubStream.prototype.StampTime = function (timestamp)
{
	var	d = new Date(timestamp * 1000);
	return d.ISOlocaltimeStr() + "." + LZZ(Math.floor(timestamp * 1000) % 1000);
}

// Prepend a zero to a single-digit number
function LZ(x) {
    return (x >= 10 || x < 0 ? "" : "0") + x;
}

// Prepend enough zeros to make a number 3 digits long
function LZZ(x) {
    return x < 0 || x >= 100 ? "" + x : "0" + LZ(x);
}

Date.prototype.ISOlocaltimeStr =
  new Function("  /* Date.ISOlocaltimeStr hh:mm:ss */\n" +
    "  with (this)\n    return" +
    " LZ(getHours())+':'+LZ(getMinutes())+':'+LZ(getSeconds())")

Date.prototype.ISOlocaldateStr =
  new Function("  /* Date.ISOlocaldateStr YYYY-MM-DD */\n" +
    "  with (this)\n    return " +
    "getFullYear()+'-'+LZ(getMonth()+1)+'-'+LZ(getDate())")

Date.prototype.ISOlocalDTstr =
  new Function("  /* Date.ISOlocalDTstr YYYY-MM-DD hh:mm:ss */\n" +
    "   with (this)\n    return " +
    "ISOlocaldateStr()+' '+ISOlocaltimeStr()")

// Override the default line plotter for Dojo graphs.  We do not want
// a little ball at the end of each line segment.
	
if(typeof(dojo) != "undefined" && dojo.render.svg.capable){
	dojo.require("dojo.svg");

	//	Mixin the SVG-specific plotter object.
	dojo.mixin(dojo.charting.Plotters, {
		Line: function(
			/* array */data, 
			/* dojo.charting.PlotArea */plotarea,
			/* dojo.charting.Plot */plot,
			/* function? */applyTo
		){
			//	summary
			//	Plots the series as a line.
			//	Bindings: x/y
			var area = plotarea.getArea();
			var line = document.createElementNS(dojo.svg.xmlns.svg, "g");
			if(data.length == 0){
				return line;
			}
			
			var path = document.createElementNS(dojo.svg.xmlns.svg, "path");
			line.appendChild(path);

			path.setAttribute("fill", "none");
			path.setAttribute("stroke", data[0].series.color);
			path.setAttribute("stroke-width" , "2");
			path.setAttribute("stroke-opacity", "0.85");
			if(data[0].series.label != null){
				path.setAttribute("title", data[0].series.label);
			}

			var cmd=[];
			for(var i=0; i<data.length; i++){
				var x = plot.axisX.getCoord(data[i].x, plotarea, plot);
				var y = plot.axisY.getCoord(data[i].y, plotarea, plot);
				if(i==0){ cmd.push("M"); }
				else { cmd.push("L"); }
				cmd.push(x+","+y);
			}
			path.setAttribute("d", cmd.join(" "));
			return line;	//	SVGGElement
		}
	});
	dojo.charting.Plotters["Default"] = dojo.charting.Plotters.Line;
}

if(typeof(dojo) != "undefined" && dojo.render.vml.capable){
	dojo.mixin(dojo.charting.Plotters, {
		Line: function(
			/* array */data, 
			/* dojo.charting.PlotArea */plotarea,
			/* dojo.charting.Plot */plot,
			/* function? */applyTo
		){
			//	summary
			//	Plots the series as a line.
			//	Bindings: x/y
			var area = plotarea.getArea();
			var group = dojo.charting.Plotters._group(plotarea);
			if(data.length==0){
				return group;
			}

			var path=document.createElement("v:shape");
			path.setAttribute("strokeweight", "2px");
			path.setAttribute("strokecolor", data[0].series.color);
			path.setAttribute("fillcolor", "none");
			path.setAttribute("filled", "false");
			path.setAttribute("coordsize", (area.right-area.left) + "," + (area.bottom-area.top));
			path.style.position="absolute";
			path.style.top="0px";
			path.style.left="0px";
			path.style.width=area.right-area.left+"px";
			path.style.height=area.bottom-area.top+"px";
			var stroke=document.createElement("v:stroke");
			stroke.setAttribute("opacity", "0.8");
			path.appendChild(stroke);

			var cmd = [];
			var r=3;
			for(var i=0; i<data.length; i++){
				var x = Math.round(plot.axisX.getCoord(data[i].x, plotarea, plot));
				var y = Math.round(plot.axisY.getCoord(data[i].y, plotarea, plot));

				if (i==0){
					cmd.push("m");
				}else if (i==1) {
					cmd.push("l");
				}
				cmd.push(x+","+y);
			}
			path.setAttribute("path", cmd.join(" ")+" e");
			group.appendChild(path);
			return group;	//	HTMLDivElement
		}
	});
	dojo.charting.Plotters["Default"] = dojo.charting.Plotters.Line;
}