mixerLib.js

var logger = new (require("./logger"))(__filename);
var myLib = require("./myLib");
var s = require("./localStorage");
var wss = require("./websocket");


exports.channelUpdateEvent = function (channel_ids) {
	var updatedChannels = {};
	for(var i in channel_ids) {
		updatedChannels[channel_ids[i]] = s.ui.mixer.channels[channel_ids[i]];
	}
	wss.broadcastEvent("channelUpdate", updatedChannels);
};

exports.channelMode = function (channel_id, channel) {
	if (!s.ui.mixer.channels[channel_id]) {
		throw Error ('unknown channel_id');
	} else if (!channel.mode || s.ui.mixer.channels[channel_id].mode === channel.mode) {
		return false;
	} else {
			if (!channel.timestamp && s.ui.mixer.channels[channel_id].mode !== channel.mode) {
				channel.timestamp = Date.now();
			}
			switch(channel.mode) {
				case 'free':
				case 'defunct':
					if (s.ui.mixer.channels[channel_id].direction !== 'operator') {
						channel.direction = null;
					}
					//temp: do not clear channel contact info to let editing contact info after hangup
					//channel.contact = null;

					if (s.ui.mixer.channels[channel_id].contact && s.ui.mixer.channels[channel_id].contact.modified) {
						//pbxProvider.setPhoneBookEntry(s.ui.mixer.channels[channel_id].contact.number, s.ui.mixer.channels[channel_id].contact.name);
						//addressBook.setContactInfo(s.ui.mixer.channels[channel_id].contact);
					}
				case 'master':
				case 'on_hold':
				case 'ivr':
				case 'dial':
				case 'ring':
					return exports.channelUpdateProperties(channel_id, channel);
				default:
					if (s.ui.mixer.channels[channel.mode]) {
						return exports.channelUpdateProperties(channel_id, channel);
					} else {
						myLib.consoleLog('panic', 'unknown channelMode:', channel.mode);
						throw Error ('unknown channelMode:' + channel.mode);
					}
			}
	}
};

exports.channelUpdateProperties = function (channel_id, data) {
	var changed = false;
	if (!s.ui.mixer.channels[channel_id]) {
		if (data) {
			s.ui.mixer.channels[channel_id] = data;
			changed = true;
		}
	} else if (!data) {
		s.ui.mixer.channels[channel_id] = null;
		changed = true;
	} else {
		for (var key in data) {
			//if (key == 'mode' || s.ui.mixer.channels[channel_id][key] !== data[key]) { // temp. solution to a bug
			if (s.ui.mixer.channels[channel_id][key] !== null && typeof s.ui.mixer.channels[channel_id][key] === 'object') {
				var data2 = data[key];
				for(var key2 in data2) {
					if (s.ui.mixer.channels[channel_id][key][key2] !== data2[key2]) {
						s.ui.mixer.channels[channel_id][key][key2] = data2[key2];
						changed = true;
					}
				}
			} else if (s.ui.mixer.channels[channel_id][key] !== data[key]) {
				s.ui.mixer.channels[channel_id][key] = data[key];
				changed = true;
			} else {
				//myLib.consoleLog('debug', "mixerLib::channelUpdateProperties", "value already set for " + [channel_id, key].join('.'), data[key]);
			}
		}
	}
	if (!changed) {
		logger.debug("channelUpdateProperties", "all values already set for", channel_id, data);
	}
	return changed;
};

exports.channelCreate = function (channel_id, defaults) {
	if (s.ui.mixer.channels[channel_id]) {
		return false;
	} else if (!myLib.checkObjectProperties(defaults, ["type"])) {
		throw Error('invalid input');
	} else {
		var channel = {
			type       : null,
			level      : 67,
			direction  : null,
			label      : channel_id,
			mode       : 'defunct',
			muted      : false,
			timestamp  : Date.now(),
			autoanswer : null,
			contact    : null,
			recording  : false
		};
		for(var key in defaults) {
			channel[key] = defaults[key];
		}
		s.ui.mixer.channels[channel_id] = channel;
		return true;
	}
};

/*
function masterUpdate(data) {
	var changed = false;
	for (key in data) {
		if (s.ui.mixer.master[key] !== null) {
			if (s.ui.mixer.master[key] !== data[key]) {
				s.ui.mixer.master[key] = data[key];
				changed = true;
			} else {
				myLib.consoleLog('warning', "masterUpdate:  value already set", [key,  data[key]]);
			}
		} else {
			myLib.consoleLog('error', "masterUpdate: field not found", [key,  data[key]]);
		}
	}
	if (changed) {
		wss.broadcastEvent("masterUpdate", s.ui.mixer.master);
	}
}

function hostUpdate(data) {
	var changed = false;
	for (key in data) {
		if (s.ui.mixer.host[key] !== null) {
			if (s.ui.mixer.host[key] !== data[key]) {
				s.ui.mixer.host[key] = data[key];
				changed = true;
			} else {
				myLib.consoleLog('warning', "hostUpdate:  value already set", [key,  data[key]]);
			}
		} else {
			myLib.consoleLog('error', "hostUpdate: field not found", [key,  data[key]]);
		}
	}
	if (changed) {
		wss.broadcastEvent("hostUpdate", s.ui.mixer.host);
	}
}
*/