angular-chat.js

'use strict';

angular.module('chat', []);

// Common JS
if (typeof(exports) !== 'undefined') exports.chat = angular.module('chat');

// define Angular Message module
angular.module('chat').service( 'Messages', [ 'ChatCore', function(ChatCore) {

    var self = this;

    // Send Messages
    self.send = function(message) {

        if (!message.data) return;

        ChatCore.publish({
            to: message.to || 'global',
            message: message.data,   
            user: ChatCore.user()
        });

    };

    // Receive Messages
    self.receive = function(fn) {
        self.subscription = ChatCore.subscribe(fn);
    };

    // Set/Get User
    self.user = function(data) {
        return ChatCore.user(data);
    };

    return self;

}]);

// AngularJS Chat Core Service
angular.module('chat').service('ChatCore',
    ['$rootScope', '$http', 'config',
    function($rootScope, $http, config) {

    var user = { 
        id: uuid(),
        name: 'Anonymous'
    };

    var self = this;

    self.rltm = rltm(config.rltm);
    
    // the global room everyone is in
    self.roomGlobal;

    // my own private rooms
    self.roomPrivate;

    // everyone elses private rooms
    self.rooms = {};

    // Set User Data
    self.user = function(data) {

        if (data) {
            angular.extend(user, data);
        }

        return user;

    };

    // Publish over network
    self.publish = function(setup) {

        var user = setup.user || self.user();

        var data = setup.data;

        if(setup.to) {

            if(!self.rooms[setup.to]) {
                self.rooms[setup.to] = self.rltm.join(setup.to);   
            }

            return self.rooms[setup.to].publish({
                data: setup.message,
                user: user
            });

        } else {

            return self.roomGlobal.publish({
                data: setup.message,
                user: user
            });

        }

    };

    // Subscribe to new messages
    self.subscribe = function(fn) {

        self.roomGlobal = self.rltm.join('global');
        self.roomPrivate = self.rltm.join(self.user().id);

        self.roomGlobal.on('message', function(uuid, data) {
            fn(data, false);  
            $rootScope.$apply();
        });

        self.roomPrivate.on('message', function(uuid, data) {

            fn(data, true);  
            $rootScope.$apply();

        });

        return self.room;

    };

}]);

// UUID utility
function uuid() {
    return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g,
    function(c) {
        var r = Math.random()*16|0, v = c == 'x' ? r : (r&0x3|0x8);
        return v.toString(16);
    });
}