#!/usr/bin/env node
// Concepto TI DSL LIVE
/*
- inicialmente asociado a ti.dsl (hacer agnostico despues)

1. saludar en consola (todo hacer config.json para considerar opciones o usar argumentos)
	1.1 se debe ejecutar en la carpeta del proyecto donde estan los archivos 'live_*.json'  :: OK!
2. se debe conectar (o intentar cada x segundos) a Concepto en modo Live (usando smart.js->bridge)  :: OK!
3. se debe conectar (o intentar cada x segundos) a TiShadow socket (puerto 3000) (usando ts.js)
4. cuando el punto 4 y 5 esten ok:
	4.1 debe leer archivo app/live_properties.json de proyecto actual y dejar en memoria.   :: OK!
	4.2 debe leer archivo app/live_styles.json de proyecto actual y dejar en memoria.
5. leer cada transaccion y llamar funcion procesarTransaccion(nodo)   :: OK!
	5.1 ver si nodeid existe como llave en live_properties de memoria (4.2). :: OK!
	5.2 ve si atributo tiene match en registro identificado de live_properties del punto 5.1 :: OK!
	5.3 reemplazar de contenidos texto 'nodeid' por valor de nuestro nodo (getSpy('nodeid').) y dejar string en temporal. :: OK!
	5.3 si tiene llave 'before_set', asignar valor de atributo a var temp 'setvalue' y asignar a string a enviar.  :: OK!
	5.4 si tiene llave 'set' asignar contenido a string a enviar: ej: getSpy('nodeid').setTitle(setvalue).. :: OK!
*/

var bridge = require('./smart');
var tis = require('./ts.js');

var apple = require('./apple');

var notifier = require('node-notifier');
var watch = require('node-watch');	// watched file changes.

var jsonfile = require('jsonfile')
var fs = require('fs');
var path = require('path');
var cheerio = require('cheerio');
var _colors = require('colors');
var pkginfo = require('pkginfo')(module);

var args = process.argv.slice(2),	cwd = '', lprop = '';
var nodes = {}, nodes_meta = {}, last_cmd = '';
var $;
// define here all files that must be read (key)->live_key.json
var _live = {
	properties : {},
	//style : {} 
};
var _config = {
	title: 'Concepto DSL Live Mode',
	dsl: 'ti.dsl',
	ti_connected: false,
	live_retry_delay: 2000
};

if (args.length>0) {
	// tiene un argumento (directorio del proyecto)
	cwd = args[0];
} else {
	// no tiene un argumento, intentamos usar directorio en donde estamos
	cwd = process.cwd();
}

// SEND WELCOME MESSAGE
consoleTitle('Concepto DSL Live Mode Bridge :: ver '+module.exports.version,'yellow','magenta');

// READ DSL AND JSON FILES
loadLive(cwd, function(){
	// read json files
	loadJSON(cwd);
});

var _startAll = function() {
	if (last_cmd!='_startAll') {
		console.log('bridge:on'.underline.green);
		// if live on, execute update on json properties : 14-1-2016 PSB
		loadJSON(cwd);
		// TI SHADOW SOCKET
		tis.disconnect();
		var socket = tis.connect(
			function(e) {
				//console.log("shadow:connected.\n".green);
				_config.ti_connected = true;
				// try to start Concepto Live Bridge
				bridge.init(function(){});
				//
			},
			function(msg) {
				console.log("shadow:message received:".green,msg);
			},
			function() {
				// on error
				//console.log("shadow:disconnected.\n".red);
				_config.ti_connected = false;
			}
		);
		last_cmd = '_startAll';
	}
};

var _stopAll = function() {
	if (last_cmd!='_stopAll') {
		console.log('bridge:off'.underline.red+'\n\n');
		if (_config.ti_connected==true) {
			// desconectamos ti_shadow
			tis.disconnect();
			//console.log("shadow:disconnected.\n\n".green);
		}
		last_cmd = '_stopAll';
	}
};

// MONITOR OPEN PORTS
var portastic = require('portastic');
var monitor = new portastic.Monitor([3000,9000]);
var _live_running = false, _ts_running = false;

monitor.on('close', function(port) {
	// seems monitos close/open are inverted.
	if (port==9000) {
		_live_running = true;
		//console.log('concepto live seems running');
	} else {
		// tishadow server is online
		_ts_running = true;
		//console.log('tishadow seems running');
	}
	// only run if both ports are opened
	if (_live_running==true && _ts_running==true) {
		//console.log('both servers seems running: calling startAll');
		_startAll();
	}
});
monitor.on('open', function(port) {
	if (port==9000) {
		// concepto mode live is deactivated
		_live_running = false;
		//console.log('concepto live seems stop');
	} else {
		// tishadow server is offline
		_ts_running = false;
		//console.log('tishadow seems stop');
	}
	// 
	_stopAll();
});

// WATCH FILE CHANGES (ti.dsl and live_*.json)
var files_to_watch = [path.join(cwd,'ti.dsl')];
for (var el in _live) {
	files_to_watch.push('live_'+el+'.json');
	var ltmp = path.join(cwd, 'live_'+el+'.json');
}
watch(files_to_watch, function(file) {
	// we should call LoadLive(cwd);
	console.log('watch:file:'.grey+file.yellow+', changed.');
	if (file.indexOf('.json')!=-1) {
		loadJSON(cwd);
		console.log('watch:json reloaded');
	} else {
		loadLive(cwd, function(){}, function(){});
		console.log('watch:dsl reloaded');
	}
});


// CONCEPTO DSL LIVE MODE (bridge) events
var slow_ping = 0;
bridge.on({
	'_error'		:  function(error) {
		// error connecting to concepto - bridge
		//console.log('live:error connecting:retrying in 3 seconds'.grey);
		/*setTimeout(function(){ 
			bridge.destroy();
			bridge.init(function(){}); 
		}, 3000);*/
	},
	'who_are_you'	:  function(data) {
		bridge.send.login('nexo');
		console.log('live:login sent'.yellow);
		// Concepto DSL Bridge Ready
		apple.say('Laiv conectado.');	
		console.log('live:welcome'.green);
		notifier.notify({
		  'title': _config.title,
		  'message': 'Bridge Activated',
		  sound: false
		});
	},
	'user_information' :  function(data) {
		slow_ping++;
		if (slow_ping%5==0) {
			console.log('live:ping ..'.grey);
		}
	},
	'welcome'  :  function(data) {
		//console.log('live:welcome:'.green,data);
	},
	'goodbye'  :  function(data) {
		apple.say('laiv desconectado.');
		console.log('live:goodbye'.yellow);
	},
	'transaction' : function(data) {
		if (bridge.getLastID()!=data['$'].id) {
			// solo ejecutamos transaccion si no fuimos nosotros mismos.
			bridge.parseXml(data['$'].do_action, function(tag, js) {
				var nodeid = '';
				if ('$' in js && 'node' in js['$']) nodeid = js['$'].node;
				if (nodeid!='') {
					var accion = tag.split('_').join(' ');
					switch(tag) {
						case 'insert_attribute_elementary_action':
						case 'set_attribute_name_elementary_action':
							var _row = ('row' in js.$)? eval(js.$.row) : 0;
							//console.log('fila en donde quiero insertar atributo:'+_row);
							if (nodeid in nodes==false) nodes[nodeid] = [];
							if (!nodes[nodeid][_row]) nodes[nodeid][_row]={};
							nodes[nodeid][_row].name 	= 	js.$.name;
							break;
						case 'edit_node_action':
						case 'set_attribute_value_elementary_action':
							if ('text' in js) {
								// se solicito modificar el nodo: text (usamos nodes_meta)
								if (nodeid in nodes_meta==false) nodes_meta[nodeid] = { _text:'', _color:'', _bgcolor:'', _icons:'' };
								if (js.text[0].indexOf('<img')!=-1) {
									// nodo cambio de imagen: done 14-1-2016
									var che_img = cheerio.load(js.text[0], { recognizeSelfClosing:true });
									var just_img = che_img('img[src]').attr('src');
									var full_img = path.join(cwd,just_img);
									if (fileExists(full_img)==true) {
										nodes_meta[nodeid]._image = fs.readFileSync(full_img).toString('base64');
										procesarTransaccion('nodes_meta',nodeid,nodes_meta[nodeid],'_image', nodes_meta[nodeid]._image);
									} else {
										console.log('changed image for nodeid '+nodeid+' was not found on disk ('+full_img+')');
									}

								} else {
									// nodo de texto simple
									nodes_meta[nodeid]._text = js.text[0];
									procesarTransaccion('nodes_meta',nodeid,nodes_meta[nodeid],'_text', js.text[0]);
									//console.log('cambiaron meta datos de nodo: '+nodeid,nodes_meta[nodeid]);
								}
							} else {
								// asigna valor a atributo ya existente: da value
								var _row = ('row' in js.$)? eval(js.$.row) : 0;
								//console.log('fila en donde quiero modificar atributo:'+_row);
								if (nodeid in nodes==false) nodes[nodeid] = [];
								if (!nodes[nodeid][_row]) nodes[nodeid][_row]={};
								nodes[nodeid][_row].value 	=	js.value[0];
								procesarTransaccion('nodes',nodeid,nodes[nodeid][_row],nodes[nodeid][_row].name, js.value[0]);
							}
							break;
						case 'delete_attribute_elementary_action':
							// eliminamos el atributo row indicado
							var _row = ('row' in js.$)? eval(js.$.row) : 0;
							if (nodeid in nodes==false) nodes[nodeid] = [];
							if (nodes[nodeid][_row]) nodes[nodeid].splice(_row,1);
							break;
						case 'node_color_format_action':
							// nodo cambio de color, lo definimos como un nodes_meta atributo _color
							if (nodeid in nodes_meta==false) nodes_meta[nodeid] = { _text:'', _color:'', _bgcolor:'', _icons:'' };
							nodes_meta[nodeid]._color 	=	js.$.color;
							procesarTransaccion('nodes_meta',nodeid,nodes_meta[nodeid],'_color',js.$.color);
							//console.log('cambiaron meta datos de nodo: '+nodeid,nodes_meta[nodeid]);
							break;
						case 'node_background_color_format_action':
							// nodo cambio de bgcolor
							if (nodeid in nodes_meta==false) nodes_meta[nodeid] = { _text:'', _color:'', _bgcolor:'', _icons:'' };
							nodes_meta[nodeid]._bgcolor =	js.$.color;
							procesarTransaccion('nodes_meta',nodeid,nodes_meta[nodeid],'_bgcolor',js.$.color);
							//console.log('cambiaron meta datos de nodo: '+nodeid,nodes_meta[nodeid]);
							break;
						default:
							console.log('switch aun no implementado:' + tag.red);
							logfull('*** ACCION '+tag+' SOLICITADA SOBRE NODE ID: '+nodeid+':',js);
							break;
					}
					//console.log('nodo modificado ('.yellow+nodeid.green+'):'.yellow,nodes[nodeid]);
					//logfull('*** ACCION '+tag+' SOLICITADA SOBRE NODE ID: '+nodeid+':',js);
					//apple.say('Accion '+(tag.split('_').join(' '))+' solicitada en nodo.');
				}
			});
		}
		//console.log('dump de transaction:',data);
	},
	'*'	: function(data, comando) {
		console.log('*** EVENTO GENERICO DETECTADO (cmd:'+comando+'): ***', data);
	}
});

// *****************
// helper methods
// *****************
 function procesarTransaccion(type, nodeid, attributes, changed, value) {
	// type: nodes, nodes_meta
	// changed: attributes names that changed
	console.log('process ('.green+_colors.white(nodeid)+'):'.green+_colors.yellow(type)+'('+_colors.red(changed)+'):'.yellow,attributes);
	// traducimos a codigo para shadow
	if (nodeid in _live.properties && changed in _live.properties[nodeid]) {
		var _live_prop = _live.properties[nodeid][changed];
		//logfull('dsl.cfc data for node:'.yellow, _live_prop);
		var _code = '';
		if (!isNaN(value)) {
			_code = "var setvalue = "+value+";\n";
		} else if (value.indexOf("'")!=-1 || value.indexOf('"')!=-1) {
			// value usa comillas (dejamos tal cual)
			_code = "var setvalue = "+value+";\n";
		} else {
			_code = "var setvalue = '"+value+"';\n";
		}
		if (value!='') {
			// solo procesar si valor no esta completamente en blanco.
			if ('BEFORE_SET' in _live_prop) _code += _live_prop['BEFORE_SET'];
			if ('before_set' in _live_prop) _code += _live_prop['before_set'];
			if ('SET' in _live_prop) _code += 'getSpy("' + nodeid + '").' + _live_prop['SET'] + '(setvalue);';
			if ('set' in _live_prop) _code += 'getSpy("' + nodeid + '").' + _live_prop['set'] + '(setvalue);';
			if ('CUSTOMSET' in _live_prop) _code += _live_prop['CUSTOMSET'] + '(setvalue);';
			if ('customset' in _live_prop) _code += _live_prop['customset'] + '(setvalue);';
			_code = _code.split('setvalue').join('_setvalue');
			_code = _code.split('nodeid').join('getSpy("'+nodeid+'")');
			_code = _code.split('\t').join(''); // eliminamos los tabs
			console.log('codigo a enviar a tishadow:',_code);
			_code = _code.split('"').join("'");
			_code = _code.split("'").join("\'");
			_code = _code.split("\n").join(" ");
			var _real = 'Alloy.Globals.live_apply("'+nodeid+'_'+changed+'","'+_code+'");';
			console.log('real enviando:',_real);
			if (_config.ti_connected==true) {
				tis.send(_real);
			}
		}
	} else if (nodeid in _live.properties) {
		console.log('nodo tiene propiedades, pero atributo no esta dentro de capacidades');
	} else {
		//console.log('live properties?',_live.properties);
	}
}

function loadJSON(directory) {
	// loads live_*.json into var '_live.*'
	console.log('loading json.');
	for (var el in _live) {
		var ltmp = path.join(directory, 'live_'+el+'.json');
		_live[el] = null; // clean the obj first to be overwritten :14/1/2016 PSB
		if (fileExists(ltmp)==true) {
			console.log('json file loaded');
			_live[el] = jsonfile.readFileSync(ltmp,'utf-8');
		}
	}
}

function loadLive(directory, onSuccess, onError) {
	var dsl_map, padre_id = '', tmp_color = '', tmp_bgcolor = '', tmp_link = '', e_ok = true, _app_name = '';
	// loads the dsl file, process it into 'nodes' struct var
	if (fileExists(path.join(directory,_config.dsl))) {
		_app_name = directory.split(path.sep)[directory.split(path.sep).length-1].toUpperCase();
		console.log('Processing file '.yellow+_config.dsl.toUpperCase().green + ' ('.white+_app_name.cyan+')'.white);
		dsl_map = fs.readFileSync(path.join(cwd,_config.dsl),{ encoding:'utf-8' });
		nodes = {}; // reset nodes file
		nodes_meta = {}; // reset nodes_meta file
		// process dsl file into 'nodes'
		$ = cheerio.load(dsl_map, { recognizeSelfClosing:true });
		$('node').each(function(index_a,element_a) {
			padre_id = $(this).attr('id');
			if (padre_id in nodes==false) nodes[padre_id] = [];
			if (padre_id in nodes_meta==false) nodes_meta[padre_id] = { _text:'', _color:'', _bgcolor:'', _icons:'' };
			// assign node metadata (_color, _bgcolor, _link, _text, _icons)
			if ($(this).attr('text')) nodes_meta[padre_id]._text = $(this).attr('text');
			if ($(this).attr('color')) nodes_meta[padre_id]._color = $(this).attr('color');
			if ($(this).attr('background_color')) nodes_meta[padre_id]._bgcolor = $(this).attr('background_color');
			var _icons = [];
			$(this).find('icon').each(function(i,e){
				if ($(e).parent('node').attr('id')==padre_id) {
					_icons.push($(e).attr('builtin'));
				}
			});
			_icons = _icons.join(',');
			nodes_meta[padre_id]._icons = _icons;
			// assign node attributes
			$(this).find('attribute').each(function(index,element) {
				if ($(element).parent('node').attr('id')==padre_id) {	
					nodes[padre_id][nodes[padre_id].length] = { name: $(element).attr('name'), value: $(element).attr('value') };
				}
			});
		});
		if (onSuccess && typeof onSuccess === 'function') {
			onSuccess();
		}
	} else {
		console.log(_colors.red('FATAL ERROR:\n')+_colors.cyan('NO APP DSL found on ')+_colors.yellow(directory)+'\n\n');
		process.exit(2);
		e_ok = false;
		if (onError && typeof onError === 'function') {
			onError('file '+_config.dsl+' does not exist on directory '+directory);
		}
	}
}

var searchAttributesOf = function($, nodeid) {
	var attrs = [], count = 0, node = {};
	if ($) {
		$('node[ID='+nodeid+'] attribute').each(function(index,element) {
			node[index] = { name: $(this).attr('NAME'), value: $(this).attr('VALUE') };
		});
	}
	return node;
};

var logfull = function(msg, data) {
	console.log(msg, JSON.stringify(data));
};

function consoleTitle(message, color, bordercolor) {
	var max_len = 0, to_show = '', to_show_open = '', to_show_close = '', 
		left_right_chars = '**', 
		left_right_space = 2, 
		left_right_margin = left_right_chars.length+left_right_space;
	if (message.indexOf('\n')!=-1) {
		// multiple lines message
		for (var lines in message.split('\n')) {
			if (message.split('\n')[lines].length > max_len) {
				max_len = message.split('\n')[lines].length;
			}
		}
	} else {
		// single line message
		max_len = message.length;
		to_show_open = Array(max_len+(left_right_margin*2)).join('*') + '\n';
		to_show_open += left_right_chars + Array(left_right_space).join(' ');
		if (bordercolor) to_show_open = _colors[bordercolor](to_show_open); 
		if (color) {
			to_show = _colors[color](message);
		} else {
			to_show = message;
		}
		to_show_close += Array(left_right_space).join(' ') + left_right_chars + '\n';
		to_show_close += Array(max_len+(left_right_margin*2)).join('*') + '\n';
		if (bordercolor) to_show_close = _colors[bordercolor](to_show_close); 
		// glue message
		to_show = to_show_open + to_show + to_show_close;
	}
	console.log(to_show);
}

function fileExists(filePath)
{
    try
    {
        return fs.statSync(filePath).isFile();
    }
    catch (err)
    {
        return false;
    }
}

function getHash(str) {
  var hash = 5381,
      i    = str.length

  while(i)
    hash = (hash * 33) ^ str.charCodeAt(--i)

  /* JavaScript does bitwise operations (like XOR, above) on 32-bit signed
   * integers. Since we want the results to be always positive, convert the
   * signed int to an unsigned by doing an unsigned bitshift. */
  return hash >>> 0;
}