function TrackerManager(host, username, password, database, server_port)
{
var self = this;
this.host_ = host;
this.username_ = username;
this.password_ = password;
this.database_ = database;
this.tracked_node_ids_ = {};
this.db_resource_ = null;
this.server_port_ = server_port;
this.server_id_ = null;
this._StartServer = function()
{
self.server_id_ = Socket_StartServer(self.server_port_, self._HandleClientDataReceived, self._HandleConnectedTracker);
if (self.server_id_ === false)
{
return false;
}
return true;
}
this._ConnectToDatabase = function()
{
if (self.db_resource_)
{
MySql_Close(self.db_resource_);
self.db_resource_ = null;
}
self.db_resource_ = MySql_Connect(self.host_, self.username_, self.password_);
if (self.db_resource_ === false)
{
return false;
}
MySql_SelectDb(self.db_resource_, self.database_);
MySql_Query(self.db_resource_, "SET time_zone='+0:00';");
return true;
}
/* Function for finding tracked object */
this._IdentifyTracker = function(data)
{
var result = MySql_Query(self.db_resource_, "SELECT `Nodes`.* FROM `Nodes`, `Attributes` WHERE `Nodes`.`type` = 'tracker' AND `Nodes`.`id` = `Attributes`.`node_id` AND `Attributes`.`name` = 'Imei' AND `Attributes`.`value` = '" + data.Imei + "'");
if (result === false || result.length == 0)
{
Log("Unable to find a tracker with IMEI " + data.Imei);
}
else
{
var tracker_node_id = result[0]["id"];
var tracker_node_name = result[0]["name"];
Log("Found tracker \"" + tracker_node_name + "\" (NodeId " + tracker_node_id + ") that corresponds to IMEI " + data.Imei);
result = MySql_Query(self.db_resource_, "SELECT * FROM `Links` WHERE `node_id_down` = " + tracker_node_id + " AND `Role` = 'tracker'");
if (result === false || result.length == 0)
{
Log("Unable to find an object that is being tracked with this tracker, will store positions on the tracker itself!");
return tracker_node_id;
}
else
{
result = MySql_Query(self.db_resource_, "SELECT * FROM `Nodes` WHERE `id` = " + result[0]["node_id_up"]);
if (result === false || result.length == 0)
{
Log("Failed to fetch the name of the tracked object (node_id " + result[0]["node_id_up"] + ")!");
}
else
{
Log("Found \"" + result[0]["name"] + "\" (node_id " + result[0]["id"] + ") which is being tracked by \"" + tracker_node_name + "\".");
return result[0]["id"];
}
}
}
return false;
}
/* Function for inserting new position in database */
this._InsertPosition = function(tracker_node_id, data)
{
if (data.Type != "NO")
{
var query = "INSERT INTO `Positions` (`node_id`, `source`, `type`, `latitude_longitude`, `datetime`, `pdop`, `hdop`, `vdop`, `satellites`, `altitude`, `height_of_geoid`, `speed`, `angle`) VALUES (";
query += tracker_node_id + ",";
query += "'gps',";
query += "'" + data.Type + "',";
query += "GeomFromText('POINT(" + data.Latitude + " " + data.Longitude + ")'),";
query += "'" + data.Datetime + "',";
query += data.Pdop + ",";
query += data.Hdop + ",";
query += data.Vdop + ",";
query += data.Satellites + ",";
query += data.Altitude + ",";
query += data.HeightOfGeoid + ",";
query += data.Speed + ",";
query += data.Angle;
query += ");";
if (!MySql_Query(self.db_resource_, query))
{
if (self._ConnectToDatabase())
{
Log("Reconnected to MySql database!");
MySql_Query(self.db_resource_, query);
}
}
/*query = "SELECT `node_id`, `source`, AsText(latitude_longitude), `created`, `datetime`, `hdop`, `satellites`, `altitude`, `height_of_geoid`, `speed`, `angle` FROM `Positions` WHERE `id` = " + MySql_InsertId(self.db_resource_) + " LIMIT 1";
Log("From DB:" + JSON.stringify(MySql_Query(self.db_resource_, query)));*/
}
Log(JSON.stringify(data));
}
/* Function for handling tracker connected disconnected */
this._HandleClientStatusUpdate = function(client_id, state)
{
switch (state)
{
case SOCKET_STATE_CONNECTED:
{
Log("Client " + client_id + " connected!");
self.tracked_node_ids_[client_id] = true;
break;
}
case SOCKET_STATE_DISCONNECTED:
{
Log("Client " + client_id + " disconnected!");
if (self.tracked_node_ids_[client_id])
{
delete self.tracked_node_ids_[client_id];
}
break;
}
default:
{
Log("Unknown state (" + state + ") for client " + client_id + "!");
break;
}
}
}
/* Functio for handling tracker data */
this._HandleClientDataReceived = function(client_id, data)
{
if (self.tracked_node_ids_[client_id])
{
Log(data);
var json_data = eval("(" + data + ")");
if (json_data.method == "MBB.OnPosition")
{
if (self.tracked_node_ids_[client_id])
{
self._InsertPosition(self.tracked_node_ids_[client_id], json_data);
}
}
else if (json_data.method == "MBB.OnConnected")
{
self.tracked_node_ids_[client_id] = self._IdentifyTracker(json_data);
}
else
{
Log("Got unknown data \"" + data + "\" from client " + client_id);
}
}
}
/* Initialize connection */
self._ConnectToDatabase();
self._StartServer();
}