cordova-both.js

Cordova = {};

if (Meteor.isCordova) {

    NotificationClient = function(options) {

        if (!options || !options.senderId) {
            throw new Meteor.Error('required_options', 'senderId must be supplied as an option as a minimum');
        }

        var instance = {};

        var successHandler = options.successHandler || function(data) {
            console.log("Success: " + JSON.stringify(data));
        };

        var errorHandler = options.errorHandler || function(e) {
            console.log("Error " + e);
        };

        var messageHandler = options.messageHandler || function(payload, foreground, coldstart) {
            if (!payload) return null;
            if (foreground && !coldstart) {
                navigator.notification.alert(
                    payload.message,
                    options.alertCallback,
                    payload.title
                );
            } else {
                window.plugin.notification.local.add(
                    _.extend({}, options.notificationOptions, {
                        message: payload.message,
                        title: payload.title,
                        autoCancel: true
                    })
                );
            }
        };

        Cordova.onNotificationGCM = options.onNotificationGCM || function(res) {
            if (res.event === 'registered') {
                if (res.regid) {
                    Meteor.call('cordova-notifications/updateRegid', res.regid, options.registeredCallback && options.registeredCallback.bind(res));
                }
            } else if (res.event === 'message') {
                messageHandler(res.payload, res.foreground, res.coldstart);
            }
        }

        Tracker.autorun(function(c) {

            if (Meteor.user()) {
                if (device.platform.toLowerCase() === 'android') {
                    window.plugins.pushNotification.register(successHandler, errorHandler, {
                        "senderID": options.senderId.toString(),
                        "ecb": "Cordova.onNotificationGCM"
                    });
                } else {
                    // TODO: APN HANDLER REGISTRATION HERE
                }
            }
        });

        return instance

    }

} else if (Meteor.isServer) {

    NotificationClient = function(options) {

        if (!options || !options.gcmAuthorization || !options.senderId) {
            return false;
        }

        var Future = Npm.require('fibers/future'),
            instance = {};

        instance.sendNotification = function(users, data) {

            if (typeof users === 'string')
                users = Meteor.users.find(users).fetch();
            else if (typeof users === "object" && users._id)
                users = [users];
            else if (users instanceof Mongo.Cursor)
                users = users.fetch()
            else if (!users instanceof Array)
                throw new Meteor.Error('bad_users_argument', 'Supplied user(s) data is not one of: user id, user object, cursor, array of user objects.');

            var regids = _.without(
                    _.pluck(users, 'regid'),
                    undefined),
                payload = {
                    registration_ids: regids,
                    data: data
                },
                headers = {
                    'Content-Type': 'application/json',
                    'Authorization': 'key=' + options.gcmAuthorization
                },
                url = "https://android.googleapis.com/gcm/send",
                fut = new Future();

            if (regids.length) {
                HTTP.post(url, {
                        headers: headers,
                        data: payload
                    },
                    function(err, res) {
                        if (err) {
                            fut.throw(err);
                        } else {
                            fut.return({
                                response: res,
                                userCount: regids.length
                            });
                        }
                    }
                );
            } else {
                fut.return(null);
            }

            return fut.wait();

        };

        Meteor.methods({
            'cordova-notifications/updateRegid': function(regid) {
                check && check(regid, String);
                Meteor.users.update(this.userId, {
                    $set: {
                        regid: regid
                    }
                });
            }
        });

        if (options.removeOnLogout) {

            Meteor.users.find({
                "status.online": true
            }).observe({
                removed: function(user) {
                    Meteor.users.update(user._id, {
                        $unset: {
                            regid: true
                        }
                    });
                }
            });

        }

        return instance;

    }

} else {

    NotificationClient = function() {};

}