// Converse.js
// https://conversejs.org
//
// Copyright (c) 2013-2018, the Converse.js developers
// Licensed under the Mozilla Public License (MPLv2)

/* This is a Converse.js plugin which add support for registering
 * an "App Server" as defined in  XEP-0357
 */
(function (root, factory) {
    define(["converse-core"], factory);
}(this, function (converse) {
    "use strict";
    const { Strophe, $iq, _ } = converse.env;


    Strophe.addNamespace('PUSH', 'urn:xmpp:push:0');


    converse.plugins.add('converse-push', {

        initialize () {
            /* The initialize function gets called as soon as the plugin is
             * loaded by converse.js's plugin machinery.
             */
            const { _converse } = this,
                  { __ } = _converse;

            _converse.api.settings.update({
                'push_app_servers': [],
            });

            function disablePushAppServer (push_app_server) {
                if (!push_app_server.jid) {
                    return;
                }
                Promise.all([
                    _converse.api.disco.supports(Strophe.NS.PUSH, _converse.bare_jid)
                ]).then((result) => {
                    if (!result[0].length && !result[1].length) {
                        return _converse.log(
                            `Not disabling push app server "${push_app_server.jid}", no disco support from your server.`,
                            Strophe.LogLevel.WARN
                        );
                    }
                    const stanza = $iq({'type': 'set'})
                        .c('disable', {
                            'xmlns': Strophe.NS.PUSH,
                            'jid': push_app_server.jid,
                        });
                    if (push_app_server.node) {
                        stanza.attrs({'node': push_app_server.node});
                    }

                    _converse.api.sendIQ(stanza)
                        .then(() => _converse.session.set('push_enabled', true))
                        .catch((e) => {
                            _converse.log(`Could not enable push app server for ${push_app_server.jid}`, Strophe.LogLevel.ERROR);
                            _converse.log(e, Strophe.LogLevel.ERROR);
                        });
                }).catch(_.partial(_converse.log, _, Strophe.LogLevel.FATAL));
            }

            function enablePushAppServer (push_app_server) {
                if (!push_app_server.jid || !push_app_server.node) {
                    return;
                }
                _converse.api.disco.getIdentity('pubsub', 'push', push_app_server.jid)
                .then((identity) => {
                    if (!identity) {
                        return _converse.log(
                            `Not enabling push the service "${push_app_server.jid}", it doesn't have the right disco identtiy.`,
                            Strophe.LogLevel.WARN
                        );
                    }
                    return Promise.all([
                        _converse.api.disco.supports(Strophe.NS.PUSH, push_app_server.jid),
                        _converse.api.disco.supports(Strophe.NS.PUSH, _converse.bare_jid)
                    ]).then((result) => {
                        if (!result[0].length && !result[1].length) {
                            return _converse.log(
                                `Not enabling push app server "${push_app_server.jid}", no disco support from your server.`,
                                Strophe.LogLevel.WARN
                            );
                        }
                        const stanza = $iq({'type': 'set'})
                            .c('enable', {
                                'xmlns': Strophe.NS.PUSH,
                                'jid': push_app_server.jid,
                                'node': push_app_server.node
                            });
                        if (push_app_server.secret) {
                            stanza.c('x', {'xmlns': Strophe.NS.XFORM, 'type': 'submit'})
                                .c('field', {'var': 'FORM_TYPE'})
                                    .c('value').t(`${Strophe.NS.PUBSUB}#publish-options`).up().up()
                                .c('field', {'var': 'secret'})
                                    .c('value').t(push_app_server.secret);
                        }
                        _converse.api.sendIQ(stanza)
                            .then(() => _converse.session.save('push_enabled', true))
                            .catch((e) => {
                                _converse.log(`Could not enable push app server for ${push_app_server.jid}`, Strophe.LogLevel.ERROR);
                                _converse.log(e, Strophe.LogLevel.ERROR);
                            });
                    }).catch(_.partial(_converse.log, _, Strophe.LogLevel.FATAL));
                }).catch(_.partial(_converse.log, _, Strophe.LogLevel.FATAL));
            }

            function enablePush () {
                if (_converse.session.get('push_enabled')) {
                    // XXX: this code is still a bit naive. We set push_enabled
                    // to true as soon as the first push app server has been set.
                    //
                    // When enabling or disabling multiple push app servers,
                    // we won't wait until we have confirmation that all have been set.
                    return;
                }
                const enabled_services = _.reject(_converse.push_app_servers, 'disable');
                _.each(enabled_services, enablePushAppServer);

                const disabled_services = _.filter(_converse.push_app_servers, 'disable');
                _.each(disabled_services, disablePushAppServer);
            }
            _converse.api.listen.on('statusInitialized', enablePush);
        }
    });
}));