'use strict'; /* App Controllers */ function ConnectCtl($scope, StropheSrv, $log, $rootScope) { $rootScope.self = {jid: "", status: 'offline' }; $rootScope.is_connected = function () { return $rootScope.status == Strophe.Status.CONNECTED; }; function connect_callback(status){ $rootScope.status = status; switch(status) { case Strophe.Status.CONNECTING: $log.log('Strophe is connecting.'); break; case Strophe.Status.CONNFAIL: $log.log('Strophe failed to connect.'); break; case Strophe.Status.DISCONNECTING: $log.log('Strophe is disconnecting.'); break; case Strophe.Status.DISCONNECTED: $log.log('Strophe is disconnected.'); break; case Strophe.Status.CONNECTED: $log.log('Strophe is connected.'); $rootScope.$broadcast('connected', true); } }; $scope.login = function () { StropheSrv.login($scope.username, $scope.password, connect_callback); $rootScope.self["jid"] = $scope.username; }; $scope.disconnect = function() { StropheSrv.disconnect(); }; } ConnectCtl.$inject = ['$scope', 'StropheSrv', '$log', '$rootScope']; function RosterCtl($scope, StropheSrv, $log, $rootScope) { $scope.contacts = {}; $scope.get_contacts = function() { return _.toArray($scope.contacts); }; function onRoster(iq) { var elems = iq.getElementsByTagName('query'); var query = elems[0]; Strophe.forEachChild(query, 'item', function(item){ var jid = item.getAttribute('jid'); var name = item.getAttribute('name')||''; //contacts are offline by default $scope.contacts[jid] = {jid: jid, name: name, status: 'offline'}; }); //make sure the roster is populated before sending presence request StropheSrv.send($pres()); $rootScope.self["status"] = "chat"; }; function onPresence(presence) { var who = $(presence).attr('from'); var jid = Strophe.getBareJidFromJid(who); var type = $(presence).attr('type'); // if (jid in $scope.contacts) { if(_.has($scope.contacts, jid)){ var contact = $scope.contacts[jid]; if (type !== 'error') { if (type === 'unavailable') { contact['status'] = 'offline'; } else { var show = $(presence).find('show'); if (show.length) { contact['status'] = show.text(); } else { contact['status'] = 'chat'; } } } } } $scope.$on('connected', function() { StropheSrv.addHandler(onPresence, 'presence'); $scope.getRoster(); }); $scope.getRoster = function() { var query = $iq({type : 'get'}).c('query', {xmlns : Strophe.NS.ROSTER}); StropheSrv.sendIQ(query, onRoster); }; $scope.chatWith = function(contact) { $rootScope.$broadcast('msgrequest', contact.name||contact.jid); }; $scope.status = function(status) { var pres = $pres().c("show",{},status); StropheSrv.send(pres); $rootScope.self["status"] = status; }; } RosterCtl.$inject = ['$scope','StropheSrv','$log', '$rootScope']; function MsgCtl($scope, $log) { $scope.conversations = []; $scope.activeConversation = ''; $scope.$on('msgrequest', function(event, contact) { $log.log(contact); if (_.indexOf($scope.conversations, contact)==-1) { $scope.conversations.push(contact); $scope.activeConversation = contact; } }); $scope.delete = function(conversation) { $scope.conversations.splice(_.indexOf($scope.conversations, conversation),1); }; $scope.activate = function(conversation) { $log.log(conversation+' was clicked'); $scope.activeConversation = conversation; }; } MsgCtl.$inject = ['$scope','$log'];