// ;
// (function (window, undefined) {
import StropheAll from '../../strophe.js'

var Strophe = StropheAll.Strophe

Strophe.log = function (level, msg) {
    //console.log(ts(), level, msg);
};

var xmldom = require('../../xmldom/dom-parser');
// //console.log('xml',xmldom, typeof xmldom.DOMParser);
var DOMParser = xmldom.DOMParser;


var window = {}
var _version = '1.1.3';
var _code = require('./status').code;
var _utils = require('./utils').utils;
var _msg = require('./message');
var _message = _msg._msg;
var _msgHash = {};
var Queue = require('./queue').Queue;

var PAGELIMIT = 2;
var pageLimitKey = new Date().getTime();

var location = window.location || {protocol: 'https:'}
window.URL = window.URL || window.webkitURL || window.mozURL || window.msURL;

if (window.XDomainRequest) {
    XDomainRequest.prototype.oldsend = XDomainRequest.prototype.send;
    XDomainRequest.prototype.send = function () {
        XDomainRequest.prototype.oldsend.apply(this, arguments);
        this.readyState = 2;
    };
}

Strophe.Request.prototype._newXHR = function () {
    var xhr = _utils.xmlrequest(true);
    if (xhr.overrideMimeType) {
        xhr.overrideMimeType('text/xml');
    }
    // use Function.bind() to prepend ourselves as an argument
    xhr.onreadystatechange = this.func.bind(null, this);
    return xhr;
};

Strophe.Websocket.prototype._closeSocket = function () {
    if (this.socket) {
        var me = this;
        setTimeout(function () {
            try {
                me.socket.close();
            } catch (e) {
            }
        }, 0);
    } else {
        this.socket = null;
    }
};

/**
 *
 * Strophe.Websocket has a bug while logout:
 * 1.send: <presence xmlns='jabber:client' type='unavailable'/> is ok;
 * 2.send: <close xmlns='urn:ietf:params:xml:ns:xmpp-framing'/> will cause a problem,log as follows:
 * WebSocket connection to 'ws://im-api.easemob.com/ws/' failed: Data frame received after close_connect @ strophe.js:5292connect @ strophe.js:2491_login @ websdk-1.1.2.js:278suc @ websdk-1.1.2.js:636xhr.onreadystatechange @ websdk-1.1.2.js:2582
 * 3 "Websocket error [object Event]"
 * _changeConnectStatus
 * onError Object {type: 7, msg: "The WebSocket connection could not be established or was disconnected.", reconnect: true}
 *
 * this will trigger socket.onError, therefore _doDisconnect again.
 * Fix it by overide  _onMessage
 */
Strophe.Websocket.prototype._onMessage = function (message) {
    // WebIM && WebIM.config.isDebug && //console.log(WebIM.utils.ts() + 'recv:', message.data);
    try {
        if (WebIM && WebIM.config.isDebug) {
            console.group('%crecv # ', 'color: green; font-size: large')
            console.log('%c' + message.data, 'color: green');
            console.groupEnd();
        }
    } catch (e) {
        //console.log('%crecv' + message.data, 'color: green');
    }

    var elem, data;
    // check for closing stream
    // var close = '<close xmlns="urn:ietf:params:xml:ns:xmpp-framing" />';
    // if (message.data === close) {
    //     this._conn.rawInput(close);
    //     this._conn.xmlInput(message);
    //     if (!this._conn.disconnecting) {
    //         this._conn._doDisconnect();
    //     }
    //     return;
    //
    // send and receive close xml: <close xmlns='urn:ietf:params:xml:ns:xmpp-framing'/>
    // so we can't judge whether message.data equals close by === simply.
    //console.log('DOMParser connection')
    if (message.data.indexOf("<close ") === 0) {
        elem = new DOMParser().parseFromString(message.data, "text/xml").documentElement;
        var see_uri = elem.getAttribute("see-other-uri");
        if (see_uri) {
            this._conn._changeConnectStatus(Strophe.Status.REDIRECT, "Received see-other-uri, resetting connection");
            this._conn.reset();
            this._conn.service = see_uri;
            this._connect();
        } else {
            // if (!this._conn.disconnecting) {
            this._conn._doDisconnect("receive <close> from server");
            // }
        }
        return;
    } else if (message.data.search("<open ") === 0) {
        // This handles stream restarts
        elem = new DOMParser().parseFromString(message.data, "text/xml").documentElement;
        if (!this._handleStreamStart(elem)) {
            return;
        }
    } else {
        data = this._streamWrap(message.data);
        elem = new DOMParser().parseFromString(data, "text/xml").documentElement;
    }

    //console.log('DOMParser connection ed')
    if (this._check_streamerror(elem, Strophe.Status.ERROR)) {
        return;
    }

    //handle unavailable presence stanza before disconnecting
    if (this._conn.disconnecting &&
        elem.firstChild.nodeName === "presence" &&
        elem.firstChild.getAttribute("type") === "unavailable") {
        this._conn.xmlInput(elem);
        this._conn.rawInput(Strophe.serialize(elem));
        // if we are already disconnecting we will ignore the unavailable stanza and
        // wait for the </stream:stream> tag before we close the connection
        return;
    }
    this._conn._dataRecv(elem, message.data);
};


var _listenNetwork = function (onlineCallback, offlineCallback) {

    if (window.addEventListener) {
        window.addEventListener('online', onlineCallback);
        window.addEventListener('offline', offlineCallback);

    } else if (window.attachEvent) {
        if (document.body) {
            document.body.attachEvent('ononline', onlineCallback);
            document.body.attachEvent('onoffline', offlineCallback);
        } else {
            window.attachEvent('load', function () {
                document.body.attachEvent('ononline', onlineCallback);
                document.body.attachEvent('onoffline', offlineCallback);
            });
        }
    } else {
        /*var onlineTmp = window.ononline;
         var offlineTmp = window.onoffline;

         window.attachEvent('ononline', function () {
         try {
         typeof onlineTmp === 'function' && onlineTmp();
         } catch ( e ) {}
         onlineCallback();
         });
         window.attachEvent('onoffline', function () {
         try {
         typeof offlineTmp === 'function' && offlineTmp();
         } catch ( e ) {}
         offlineCallback();
         });*/
    }
};

var _parseRoom = function (result) {
    var rooms = [];
    var items = result.getElementsByTagName('item');
    if (items) {
        for (var i = 0; i < items.length; i++) {
            var item = items[i];
            var roomJid = item.getAttribute('jid');
            var tmp = roomJid.split('@')[0];
            var room = {
                jid: roomJid,
                name: item.getAttribute('name'),
                roomId: tmp.split('_')[1]
            };
            rooms.push(room);
        }
    }
    return rooms;
};

var _parseRoomOccupants = function (result) {
    var occupants = [];
    var items = result.getElementsByTagName('item');
    if (items) {
        for (var i = 0; i < items.length; i++) {
            var item = items[i];
            var room = {
                jid: item.getAttribute('jid'),
                name: item.getAttribute('name')
            };
            occupants.push(room);
        }
    }
    return occupants;
};

var _parseResponseMessage = function (msginfo) {
    var parseMsgData = {errorMsg: true, data: []};

    ////console.log('msginfo', msginfo)
    var msgBodies = msginfo.getElementsByTagName('body');
    ////console.log('msginfo', msgBodies)
    if (msgBodies) {
        for (var i = 0; i < msgBodies.length; i++) {
            var msgBody = msgBodies[i];
            var childNodes = msgBody.childNodes;
            if (childNodes && childNodes.length > 0) {
                var childNode = msgBody.childNodes[0];
                if (childNode.nodeType == Strophe.ElementType.TEXT) {
                    var jsondata = childNode.wholeText || childNode.nodeValue;
                    jsondata = jsondata.replace('\n', '<br>');
                    //console.log('jsondata', jsondata)

                    try {
                        var data = JSON.parse(jsondata);
                        parseMsgData.errorMsg = false;
                        parseMsgData.data = [data];
                    } catch (e) {
                        //console.log('eval error', e)
                    }
                }
            }
        }

        var delayTags = msginfo.getElementsByTagName('delay');
        if (delayTags && delayTags.length > 0) {
            var delayTag = delayTags[0];
            var delayMsgTime = delayTag.getAttribute('stamp');
            if (delayMsgTime) {
                parseMsgData.delayTimeStamp = delayMsgTime;
            }
        }
    } else {
        var childrens = msginfo.childNodes;
        if (childrens && childrens.length > 0) {
            var child = msginfo.childNodes[0];
            if (child.nodeType == Strophe.ElementType.TEXT) {
                try {
                    var data = eval('(' + child.nodeValue + ')');
                    parseMsgData.errorMsg = false;
                    parseMsgData.data = [data];
                } catch (e) {
                }
            }
        }
    }
    return parseMsgData;
};

var _parseNameFromJidFn = function (jid, domain) {
    domain = domain || '';
    var tempstr = jid;
    var findex = tempstr.indexOf('_');

    if (findex !== -1) {
        tempstr = tempstr.substring(findex + 1);
    }
    var atindex = tempstr.indexOf('@' + domain);
    if (atindex !== -1) {
        tempstr = tempstr.substring(0, atindex);
    }
    return tempstr;
};

var _parseFriend = function (queryTag, conn, from) {
    var rouster = [];
    var items = queryTag.getElementsByTagName('item');
    if (items) {
        for (var i = 0; i < items.length; i++) {
            var item = items[i];
            var jid = item.getAttribute('jid');
            if (!jid) {
                continue;
            }
            var subscription = item.getAttribute('subscription');
            var friend = {
                subscription: subscription,
                jid: jid
            };
            var ask = item.getAttribute('ask');
            if (ask) {
                friend.ask = ask;
            }
            var name = item.getAttribute('name');
            if (name) {
                friend.name = name;
            } else {
                var n = _parseNameFromJidFn(jid);
                friend.name = n;
            }
            var groups = [];
            Strophe.forEachChild(item, 'group', function (group) {
                groups.push(Strophe.getText(group));
            });
            friend.groups = groups;
            rouster.push(friend);
            // B同意之后 -> B订阅A
            if (conn && (subscription == 'from')) {
                conn.subscribe({
                    toJid: jid
                });
            }

            if (conn && (subscription == 'to')) {
                conn.subscribed({
                    toJid: jid
                });
            }
        }
    }
    return rouster;
};

var _login = function (options, conn) {
    ////console.log(options, conn, '_login')
    var accessToken = options.access_token || '';
    if (accessToken == '') {
        var loginfo = _utils.stringify(options);
        conn.onError({
            type: _code.WEBIM_CONNCTION_OPEN_USERGRID_ERROR,
            data: options
        });
        return;
    }
    conn.context.accessToken = options.access_token;
    conn.context.accessTokenExpires = options.expires_in;
    var stropheConn = null;
    if (conn.isOpening() && conn.context.stropheConn) {
        stropheConn = conn.context.stropheConn;
    } else if (conn.isOpened() && conn.context.stropheConn) {
        // return;
        stropheConn = new Strophe.Connection(conn.url, {
            inactivity: conn.inactivity,
            maxRetries: conn.maxRetries,
            pollingTime: conn.pollingTime
        });
    } else {
        stropheConn = new Strophe.Connection(conn.url, {
            inactivity: conn.inactivity,
            maxRetries: conn.maxRetries,
            pollingTime: conn.pollingTime
        });
    }
    var callback = function (status, msg) {
        _loginCallback(status, msg, conn);
    };

    conn.context.stropheConn = stropheConn;
    if (conn.route) {
        stropheConn.connect(conn.context.jid, '$t$' + accessToken, callback, conn.wait, conn.hold, conn.route);
    } else {
        stropheConn.connect(conn.context.jid, '$t$' + accessToken, callback, conn.wait, conn.hold);
    }
};

var _parseMessageType = function (msginfo) {
    var msgtype = 'normal';
    var receiveinfo = msginfo.getElementsByTagName('received');
    if (receiveinfo && receiveinfo.length > 0 && receiveinfo[0].namespaceURI === 'urn:xmpp:receipts') {
        msgtype = 'received';
    } else {
        var inviteinfo = msginfo.getElementsByTagName('invite');
        if (inviteinfo && inviteinfo.length > 0) {
            msgtype = 'invite';
        }
    }
    return msgtype;
};

var _handleMessageQueue = function (conn) {
    for (var i in _msgHash) {
        if (_msgHash.hasOwnProperty(i)) {
            _msgHash[i].send(conn);
        }
    }
};

var _loginCallback = function (status, msg, conn) {
    var conflict, error;
    // console.log('_loginCallback 1', Strophe.Status, status, msg)
    if (msg === 'conflict') {
        conflict = true;
    }

    if (status == Strophe.Status.CONNFAIL) {
        //client offline, ping/pong timeout, server quit, server offline
        error = {
            type: _code.WEBIM_CONNCTION_SERVER_CLOSE_ERROR,              //客户端网络离线
            msg: msg,
            reconnect: true
        };

        conflict && (error.conflict = true);
        conn.onError(error);
    } else if (status == Strophe.Status.ATTACHED || status == Strophe.Status.CONNECTED) {
        conn.autoReconnectNumTotal = 0

        // client should limit the speed of sending ack messages  up to 5/s
        //console.log('_loginCallback 2')
        conn.intervalId = setInterval(function () {
            conn.handelSendQueue();
        }, 200);
        var handleMessage = function (msginfo) {
            var type = _parseMessageType(msginfo);
            if ('received' === type) {
                conn.handleReceivedMessage(msginfo);
                return true;
            } else if ('invite' === type) {
                conn.handleInviteMessage(msginfo);
                return true;
            } else {
                conn.handleMessage(msginfo);
                return true;
            }
        };
        var handlePresence = function (msginfo) {
            conn.handlePresence(msginfo);
            return true;
        };
        var handlePing = function (msginfo) {
            conn.handlePing(msginfo);
            return true;
        };
        var handleIqRoster = function (msginfo) {
            conn.handleIqRoster(msginfo);
            return true;
        };
        var handleIqPrivacy = function (msginfo) {
            conn.handleIqPrivacy(msginfo);
            return true;
        };
        var handleIq = function (msginfo) {
            conn.handleIq(msginfo);
            return true;
        };
        conn.addHandler(handleMessage, null, 'message', null, null, null);
        conn.addHandler(handlePresence, null, 'presence', null, null, null);
        conn.addHandler(handlePing, 'urn:xmpp:ping', 'iq', 'get', null, null);
        conn.addHandler(handleIqRoster, 'jabber:iq:roster', 'iq', 'set', null, null);
        conn.addHandler(handleIqPrivacy, 'jabber:iq:privacy', 'iq', 'set', null, null);
        conn.addHandler(handleIq, null, 'iq', null, null, null);

        conn.context.status = _code.STATUS_OPENED;

        var supportRecMessage = [
            _code.WEBIM_MESSAGE_REC_TEXT,
            _code.WEBIM_MESSAGE_REC_EMOJI];

        if (_utils.isCanDownLoadFile) {
            supportRecMessage.push(_code.WEBIM_MESSAGE_REC_PHOTO);
            supportRecMessage.push(_code.WEBIM_MESSAGE_REC_AUDIO_FILE);
        }
        var supportSedMessage = [_code.WEBIM_MESSAGE_SED_TEXT];
        if (_utils.isCanUploadFile) {
            supportSedMessage.push(_code.WEBIM_MESSAGE_REC_PHOTO);
            supportSedMessage.push(_code.WEBIM_MESSAGE_REC_AUDIO_FILE);
        }
        //console.log('_loginCallback 3')
        conn.notifyVersion();
        conn.retry && _handleMessageQueue(conn);
        conn.heartBeat();
        conn.isAutoLogin && conn.setPresence();
        conn.onOpened({
            canReceive: supportRecMessage,
            canSend: supportSedMessage,
            accessToken: conn.context.accessToken
        });
    } else if (status == Strophe.Status.DISCONNECTING) {
        if (conn.isOpened()) {
            if (conn.autoReconnectNumTotal < conn.autoReconnectNumMax) {
                conn.reconnect()
                return
            }

            conn.stopHeartBeat()
            conn.context.status = _code.STATUS_CLOSING

            error = {
                type: _code.WEBIM_CONNCTION_SERVER_CLOSE_ERROR,
                msg: msg,
                reconnect: true
            };

            conflict && (error.conflict = true);
            conn.onError(error);
        }
    } else if (status == Strophe.Status.DISCONNECTED) {
        if (conn.isOpened()) {
            if (conn.autoReconnectNumTotal < conn.autoReconnectNumMax) {
                conn.reconnect();
                return;
            } else {
                error = {
                    type: _code.WEBIM_CONNCTION_DISCONNECTED
                };
                conn.onError(error);
            }
        }
        conn.context.status = _code.STATUS_CLOSED;
        conn.clear();
        conn.onClosed();
    } else if (status == Strophe.Status.AUTHFAIL) {
        error = {
            type: _code.WEBIM_CONNCTION_AUTH_ERROR
        };

        conflict && (error.conflict = true);
        conn.onError(error);
        conn.clear();
    } else if (status == Strophe.Status.ERROR) {
        conn.context.status = _code.STATUS_ERROR;
        error = {
            type: _code.WEBIM_CONNCTION_SERVER_ERROR
        };

        conflict && (error.conflict = true);
        conn.onError(error);
    }
    conn.context.status_now = status;
};

var _getJid = function (options, conn) {
    var jid = options.toJid || '';

    if (jid === '') {
        var appKey = conn.context.appKey || '';
        var toJid = appKey + '_' + options.to + '@' + conn.domain;

        if (options.resource) {
            toJid = toJid + '/' + options.resource;
        }
        jid = toJid;
    }
    return jid;
};

var _getJidByName = function (name, conn) {
    var options = {
        to: name
    };
    return _getJid(options, conn);
};

var _validCheck = function (options, conn) {
    options = options || {};

    if (options.user == '') {
        conn.onError({
            type: _code.WEBIM_CONNCTION_USER_NOT_ASSIGN_ERROR
        });
        return false;
    }

    var user = (options.user + '') || '';
    var appKey = options.appKey || '';
    var devInfos = appKey.split('#');

    if (devInfos.length !== 2) {
        conn.onError({
            type: _code.WEBIM_CONNCTION_APPKEY_NOT_ASSIGN_ERROR
        });
        return false;
    }
    var orgName = devInfos[0];
    var appName = devInfos[1];

    if (!orgName) {
        conn.onError({
            type: _code.WEBIM_CONNCTION_APPKEY_NOT_ASSIGN_ERROR
        });
        return false;
    }
    if (!appName) {
        conn.onError({
            type: _code.WEBIM_CONNCTION_APPKEY_NOT_ASSIGN_ERROR
        });
        return false;
    }

    var jid = appKey + '_' + user.toLowerCase() + '@' + conn.domain,
        resource = options.resource || 'webim';

    if (conn.isMultiLoginSessions) {
        resource += user + new Date().getTime() + Math.floor(Math.random().toFixed(6) * 1000000);
    }
    conn.context.jid = jid + '/' + resource;
    /*jid: {appkey}_{username}@domain/resource*/
    conn.context.userId = user;
    conn.context.appKey = appKey;
    conn.context.appName = appName;
    conn.context.orgName = orgName;

    return true;
};

var _getXmppUrl = function (baseUrl, https) {
    if (/^(ws|http)s?:\/\/?/.test(baseUrl)) {
        return baseUrl;
    }

    var url = {
        prefix: 'http',
        base: '://' + baseUrl,
        suffix: '/http-bind/'
    };

    if (https && _utils.isSupportWss) {
        url.prefix = 'wss';
        url.suffix = '/ws/';
    } else {
        if (https) {
            url.prefix = 'https';
        } else if (window.WebSocket) {
            url.prefix = 'ws';
            url.suffix = '/ws/';
        }
    }

    return url.prefix + url.base + url.suffix;
};


//class
var connection = function (options) {
    if (!this instanceof connection) {
        return new connection(options);
    }

    var options = options || {};

    this.isMultiLoginSessions = options.isMultiLoginSessions || false;
    this.wait = options.wait || 30;
    this.retry = options.retry || false;
    this.https = options.https || location.protocol === 'https:';
    this.url = _getXmppUrl(options.url, this.https);
    this.hold = options.hold || 1;
    this.route = options.route || null;
    this.domain = options.domain || 'easemob.com';
    this.inactivity = options.inactivity || 30;
    this.heartBeatWait = options.heartBeatWait || 4500;
    this.maxRetries = options.maxRetries || 5;
    this.isAutoLogin = options.isAutoLogin === false ? false : true;
    this.pollingTime = options.pollingTime || 800;
    this.stropheConn = false;
    this.autoReconnectNumMax = options.autoReconnectNumMax || 0;
    this.autoReconnectNumTotal = 0;
    this.autoReconnectInterval = options.autoReconnectInterval || 0;
    this.context = {status: _code.STATUS_INIT};
    //todo 接收的事件，放到数组里的时候，加上g.isInBackground字段。每帧执行一个事件的时候，如果g.isInBackground=true,就pass
    this.sendQueue = new Queue();  //接收到的事件队列
    this.intervalId = null;
};

connection.prototype.handelSendQueue = function () {
    var options = this.sendQueue.pop();
    if (options !== null) {
        this.sendReceiptsMessage(options);
    }
};
connection.prototype.listen = function (options) {
    options.url && (this.url = _getXmppUrl(options.url, this.https));
    this.onOpened = options.onOpened || _utils.emptyfn;
    this.onClosed = options.onClosed || _utils.emptyfn;
    this.onTextMessage = options.onTextMessage || _utils.emptyfn;
    this.onEmojiMessage = options.onEmojiMessage || _utils.emptyfn;
    this.onPictureMessage = options.onPictureMessage || _utils.emptyfn;
    this.onAudioMessage = options.onAudioMessage || _utils.emptyfn;
    this.onVideoMessage = options.onVideoMessage || _utils.emptyfn;
    this.onFileMessage = options.onFileMessage || _utils.emptyfn;
    this.onLocationMessage = options.onLocationMessage || _utils.emptyfn;
    this.onCmdMessage = options.onCmdMessage || _utils.emptyfn;
    this.onPresence = options.onPresence || _utils.emptyfn;
    this.onRoster = options.onRoster || _utils.emptyfn;
    this.onError = options.onError || _utils.emptyfn;
    this.onReceivedMessage = options.onReceivedMessage || _utils.emptyfn;
    this.onInviteMessage = options.onInviteMessage || _utils.emptyfn;
    this.onOffline = options.onOffline || _utils.emptyfn;
    this.onOnline = options.onOnline || _utils.emptyfn;
    this.onConfirmPop = options.onConfirmPop || _utils.emptyfn;
    //for WindowSDK
    this.onUpdateMyGroupList = options.onUpdateMyGroupList || _utils.emptyfn;
    this.onUpdateMyRoster = options.onUpdateMyRoster || _utils.emptyfn;
    //
    this.onBlacklistUpdate = options.onBlacklistUpdate || _utils.emptyfn;

    _listenNetwork(this.onOnline, this.onOffline);
};

connection.prototype.heartBeat = function () {
    var me = this;
    //IE8: strophe auto switch from ws to BOSH, need heartbeat
    var isNeed = !/^ws|wss/.test(me.url);
    // || /mobile/.test(navigator.userAgent)
    if (this.heartBeatID || !isNeed) {
        return;
    }

    var options = {
        toJid: this.domain,
        type: 'normal'
    };
    this.heartBeatID = setInterval(function () {
        me.ping(options);
    }, this.heartBeatWait);
};

connection.prototype.stopHeartBeat = function () {
    if (typeof this.heartBeatID == "number") {
        this.heartBeatID = clearInterval(this.heartBeatID);
    }
};

connection.prototype.sendReceiptsMessage = function (options) {
    var dom = StropheAll.$msg({
        from: this.context.jid || '',
        to: this.domain,
        id: options.id || ''
    }).c('received', {
        xmlns: 'urn:xmpp:receipts',
        id: options.id || ''
    });
    this.sendCommand(dom.tree());
};

connection.prototype.cacheReceiptsMessage = function (options) {
    this.sendQueue.push(options);
};

connection.prototype.open = function (options) {


    var pass = _validCheck(options, this);

    if (!pass) {
        return;
    }
    var conn = this;

    if (conn.isOpening() || conn.isOpened()) {
        return;
    }

    if (options.accessToken) {
        options.access_token = options.accessToken;
        _login(options, conn);
    } else {
        var apiUrl = options.apiUrl;
        var userId = options.user;
        var pwd = options.pwd || '';
        var appkey = options.appKey;
        var str = appkey.split('#');
        var orgName = str[0];
        var appName = str[1];
        var successMethod = options.success;

        var suc = function (data, xhr, myName) {
            // console.log('success',data, xhr, myName)
            conn.context.status = _code.STATUS_DOLOGIN_IM;
            conn.context.restTokenData = data;
            //console.log(options)
            if (data.statusCode != '404' && data.statusCode != '400') {
                wx.showToast({
                    title: '登录成功',
                    icon: 'success',
                    duration: 1000
                });
                
                setTimeout(function () {
                  successMethod(data);

                    // wx.redirectTo({
                    //     url: '../main/main?myName=' + userId
                    // })
                }, 1000);
            }
            
            _login(data.data, conn);
        };
        var error = function (res, xhr, msg) {
            console.log('error', res, xhr, msg)
            conn.clear();
            wx.showModal({
                title: '用户名或密码错误!',
                showCancel: false,
                confirmText: 'OK'
            });
            if (res.error && res.error_description) {
                conn.onError({
                    type: _code.WEBIM_CONNCTION_OPEN_USERGRID_ERROR,
                    data: res,
                    xhr: xhr
                });
            } else {
                conn.onError({
                    type: _code.WEBIM_CONNCTION_OPEN_ERROR,
                    data: res,
                    xhr: xhr
                });
            }
        };

        this.context.status = _code.STATUS_DOLOGIN_USERGRID;

        var loginJson = {
            grant_type: 'password',
            username: userId,
            password: pwd,
            timestamp: +new Date()
        };
        var loginfo = _utils.stringify(loginJson);
        console.log(loginfo)
        var options = {
            url: apiUrl + '/' + orgName + '/' + appName + '/token',
            data: loginfo,
            success: suc || _utils.emptyfn,
            error: error || _utils.emptyfn
        };
        console.log("options", options.success)
        _utils.ajax(options);
    }


};

// attach to xmpp server for BOSH
connection.prototype.attach = function (options) {
    var pass = _validCheck(options, this);

    if (!pass) {
        return;
    }

    options = options || {};

    var accessToken = options.accessToken || '';
    if (accessToken == '') {
        this.onError({
            type: _code.WEBIM_CONNCTION_TOKEN_NOT_ASSIGN_ERROR
        });
        return;
    }

    var sid = options.sid || '';
    if (sid === '') {
        this.onError({
            type: _code.WEBIM_CONNCTION_SESSIONID_NOT_ASSIGN_ERROR
        });
        return;
    }

    var rid = options.rid || '';
    if (rid === '') {
        this.onError({
            type: _code.WEBIM_CONNCTION_RID_NOT_ASSIGN_ERROR
        });
        return;
    }

    var stropheConn = new Strophe.Connection(this.url, {
        inactivity: this.inactivity,
        maxRetries: this.maxRetries,
        pollingTime: this.pollingTime,
        heartBeatWait: this.heartBeatWait
    });

    this.context.accessToken = accessToken;
    this.context.stropheConn = stropheConn;
    this.context.status = _code.STATUS_DOLOGIN_IM;

    var conn = this;
    var callback = function (status, msg) {
        _loginCallback(status, msg, conn);
    };

    var jid = this.context.jid;
    var wait = this.wait;
    var hold = this.hold;
    var wind = this.wind || 5;
    stropheConn.attach(jid, sid, rid, callback, wait, hold, wind);
};

connection.prototype.close = function (reason) {
    this.stopHeartBeat();

    var status = this.context.status;
    if (status == _code.STATUS_INIT) {
        return;
    }

    if (this.isClosed() || this.isClosing()) {
        return;
    }

    this.context.status = _code.STATUS_CLOSING;
    this.context.stropheConn.disconnect(reason);
};

connection.prototype.addHandler = function (handler, ns, name, type, id, from, options) {
    this.context.stropheConn.addHandler(handler, ns, name, type, id, from, options);
};

connection.prototype.notifyVersion = function (suc, fail) {
    var jid = _getJid({}, this);
    var dom = StropheAll.$iq({
        from: this.context.jid || ''
        , to: this.domain
        , type: 'result'
    })
        .c('query', {xmlns: 'jabber:iq:version'})
        .c('name')
        .t('easemob')
        .up()
        .c('version')
        .t(_version)
        .up()
        .c('os')
        .t('webim');

    var suc = suc || _utils.emptyfn;
    var error = fail || this.onError;
    var failFn = function (ele) {
        error({
            type: _code.WEBIM_CONNCTION_NOTIFYVERSION_ERROR
            , data: ele
        });
    };
    this.context.stropheConn.sendIQ(dom.tree(), suc, failFn);
    return;
};

// handle all types of presence message
connection.prototype.handlePresence = function (msginfo) {
    if (this.isClosed()) {
        return;
    }
    var from = msginfo.getAttribute('from') || '';
    var to = msginfo.getAttribute('to') || '';
    var type = msginfo.getAttribute('type') || '';
    var presence_type = msginfo.getAttribute('presence_type') || '';
    var fromUser = _parseNameFromJidFn(from);
    var toUser = _parseNameFromJidFn(to);
    var info = {
        from: fromUser,
        to: toUser,
        fromJid: from,
        toJid: to,
        type: type,
        chatroom: msginfo.getElementsByTagName('roomtype').length ? true : false
    };

    var showTags = msginfo.getElementsByTagName('show');
    if (showTags && showTags.length > 0) {
        var showTag = showTags[0];
        info.show = Strophe.getText(showTag);
    }
    var statusTags = msginfo.getElementsByTagName('status');
    if (statusTags && statusTags.length > 0) {
        var statusTag = statusTags[0];
        info.status = Strophe.getText(statusTag);
        info.code = statusTag.getAttribute('code');
    }

    var priorityTags = msginfo.getElementsByTagName('priority');
    if (priorityTags && priorityTags.length > 0) {
        var priorityTag = priorityTags[0];
        info.priority = Strophe.getText(priorityTag);
    }

    var error = msginfo.getElementsByTagName('error');
    if (error && error.length > 0) {
        var error = error[0];
        info.error = {
            code: error.getAttribute('code')
        };
    }

    var destroy = msginfo.getElementsByTagName('destroy');
    if (destroy && destroy.length > 0) {
        var destroy = destroy[0];
        info.destroy = true;

        var reason = destroy.getElementsByTagName('reason');
        if (reason && reason.length > 0) {
            info.reason = Strophe.getText(reason[0]);
        }
    }

    //     <actor nick="liuwz"/>
    // </item>
    // one record once a time
    // kick info: actor / member
    var members = msginfo.getElementsByTagName('item');
    if (members && members.length > 0) {
        var member = members[0];
        var role = member.getAttribute('role');
        var jid = member.getAttribute('jid');
        // dismissed by group
        if (role == 'none' && jid) {
            var kickedMember = _parseNameFromJidFn(jid);
            var actor = member.getElementsByTagName('actor')[0];
            var actorNick = actor.getAttribute('nick');
            info.actor = actorNick;
            info.kicked = kickedMember;
        }
        // Service Acknowledges Room Creation `createGroupACK`
        if (role == 'moderator' && info.code == '201') {
            // info.type = 'createGroupACK';
            info.type = 'joinPublicGroupSuccess';
        }
    }

    // from message : apply to join group
    var apply = msginfo.getElementsByTagName('apply');
    if (apply && apply.length > 0) {
        apply = apply[0];
        var toNick = apply.getAttribute('toNick');
        var groupJid = apply.getAttribute('to');
        var userJid = apply.getAttribute('from');
        var groupName = _parseNameFromJidFn(groupJid);
        var userName = _parseNameFromJidFn(userJid);
        info.toNick = toNick;
        info.groupName = groupName;
        info.type = 'joinGroupNotifications';
        var reason = apply.getElementsByTagName('reason');
        if (reason && reason.length > 0) {
            info.reason = Strophe.getText(reason[0]);
        }
    }


    if (info.chatroom) {
        // diff the
        info.presence_type = presence_type;
        info.original_type = info.type;
        var reflectUser = from.slice(from.lastIndexOf('/') + 1);

        if (reflectUser === this.context.userId) {
            if (info.type === '' && !info.code) {
                info.type = 'joinChatRoomSuccess';
            } else if (presence_type === 'unavailable' || info.type === 'unavailable') {
                if (!info.status) {// logout successfully.
                    info.type = 'leaveChatRoom';
                } else if (info.code == 110) {// logout or dismissied by admin.
                    info.type = 'leaveChatRoom';
                } else if (info.error && info.error.code == 406) {// The chat room is full.
                    info.type = 'reachChatRoomCapacity';
                }
            }
        }
    } else {
        info.presence_type = presence_type;
        info.original_type = type;

        if (info.type) {

        } else if (type == "" && !info.status && !info.error) {
            info.type = 'joinPublicGroupSuccess';
        } else if (presence_type === 'unavailable' || type === 'unavailable') {// There is no roomtype when a chat room is deleted.
            if (info.destroy) {// Group or Chat room Deleted.
                info.type = 'deleteGroupChat';
            } else if (info.code == 307 || info.code == 321) {// Dismissed by group.
                info.type = 'leaveGroup';
            }
        }
    }
    this.onPresence(info, msginfo);
};

connection.prototype.handlePing = function (e) {
    if (this.isClosed()) {
        return;
    }
    var id = e.getAttribute('id');
    var from = e.getAttribute('from');
    var to = e.getAttribute('to');
    var dom = $iq({
        from: to
        , to: from
        , id: id
        , type: 'result'
    });
    this.sendCommand(dom.tree());
};

connection.prototype.handleIq = function (iq) {
    return true;
};

connection.prototype.handleIqPrivacy = function (msginfo) {
    var list = msginfo.getElementsByTagName('list');
    if (list.length == 0) {
        return;
    }
    this.getBlacklist();
};

connection.prototype.handleIqRoster = function (e) {
    var id = e.getAttribute('id');
    var from = e.getAttribute('from') || '';
    var name = _parseNameFromJidFn(from);
    var curJid = this.context.jid;
    var curUser = this.context.userId;

    var iqresult = StropheAll.$iq({type: 'result', id: id, from: curJid});
    this.sendCommand(iqresult.tree());

    var msgBodies = e.getElementsByTagName('query');
    if (msgBodies && msgBodies.length > 0) {
        var queryTag = msgBodies[0];
        var rouster = _parseFriend(queryTag, this, from);
        this.onRoster(rouster);
    }
    return true;
};

connection.prototype.handleMessage = function (msginfo) {
    if (this.isClosed()) {
        return;
    }

    var id = msginfo.getAttribute('id') || '';

    // cache ack into sendQueue first , handelSendQueue will do the send thing with the speed of  5/s
    this.cacheReceiptsMessage({
        id: id
    });
    ////console.log('handlePresence', msginfo)
    var parseMsgData = _parseResponseMessage(msginfo);
    ////console.log('parseMsgData', parseMsgData)
    if (parseMsgData.errorMsg) {
        this.handlePresence(msginfo);
        return;
    }
    // send error
    var error = msginfo.getElementsByTagName('error');
    var errorCode = '';
    var errorText = '';
    var errorBool = false;
    if (error.length > 0) {
        errorBool = true;
        errorCode = error[0].getAttribute('code');
        var textDOM = error[0].getElementsByTagName('text');
        errorText = textDOM[0].textContent || textDOM[0].text;
        log('handle error', errorCode, errorText);
    }

    var msgDatas = parseMsgData.data;
    for (var i in msgDatas) {
        if (!msgDatas.hasOwnProperty(i)) {
            continue;
        }
        var msg = msgDatas[i];
        if (!msg.from || !msg.to) {
            continue;
        }

        var from = (msg.from + '').toLowerCase();
        var too = (msg.to + '').toLowerCase();
        var extmsg = msg.ext || {};
        var chattype = '';
        var typeEl = msginfo.getElementsByTagName('roomtype');
        if (typeEl.length) {
            chattype = typeEl[0].getAttribute('type') || 'chat';
        } else {
            chattype = msginfo.getAttribute('type') || 'chat';
        }

        var msgBodies = msg.bodies;
        if (!msgBodies || msgBodies.length == 0) {
            continue;
        }
        var msgBody = msg.bodies[0];
        var type = msgBody.type;

        //console.log('onmessage1', type, msgBody)

        try {
            switch (type) {
                case 'txt':
                    //console.log("666666666666")
                    var receiveMsg = msgBody.msg;
                    //console.log('receiveMsg', receiveMsg)
                    //console.log('WebIM.Emoji', WebIM.Emoji)
                    var emojibody = _utils.parseTextMessage(receiveMsg, WebIM.Emoji);
                    //console.log('emojibody', emojibody)
                    if (emojibody.isemoji) {
                        var msg = {
                            id: id
                            , type: chattype
                            , from: from
                            , to: too
                            , delay: parseMsgData.delayTimeStamp
                            , data: emojibody.body
                            , ext: extmsg
                        };
                        !msg.delay && delete msg.delay;
                        msg.error = errorBool;
                        msg.errorText = errorText;
                        msg.errorCode = errorCode;
                        //console.log('onmessage', type, msg)

                        this.onEmojiMessage(msg);
                    } else {
                        //console.log('ttxtxtxtxtxtxttxtxtxtxtxtxt')
                        var msg = {
                            id: id
                            , type: chattype
                            , from: from
                            , to: too
                            , delay: parseMsgData.delayTimeStamp
                            , data: receiveMsg
                            , ext: extmsg
                        };
                        !msg.delay && delete msg.delay;
                        msg.error = errorBool;
                        msg.errorText = errorText;
                        msg.errorCode = errorCode;
                        //console.log('onmessage', type, msg)

                        this.onTextMessage(msg);
                    }
                    break;
                case 'img':
                    var rwidth = 0;
                    var rheight = 0;
                    if (msgBody.size) {
                        rwidth = msgBody.size.width;
                        rheight = msgBody.size.height;
                    }
                    var msg = {
                        id: id
                        , type: chattype
                        , from: from
                        , to: too
                        , url: msgBody.url
                        , secret: msgBody.secret
                        , filename: msgBody.filename
                        , thumb: msgBody.thumb
                        , thumb_secret: msgBody.thumb_secret
                        , file_length: msgBody.file_length || ''
                        , width: rwidth
                        , height: rheight
                        , filetype: msgBody.filetype || ''
                        , accessToken: this.context.accessToken || ''
                        , ext: extmsg
                        , delay: parseMsgData.delayTimeStamp
                    };
                    !msg.delay && delete msg.delay;
                    msg.error = errorBool;
                    msg.errorText = errorText;
                    msg.errorCode = errorCode;
                    this.onPictureMessage(msg);
                    break;
                case 'audio':
                    var msg = {
                        id: id
                        , type: chattype
                        , from: from
                        , to: too
                        , url: msgBody.url
                        , secret: msgBody.secret
                        , filename: msgBody.filename
                        , length: msgBody.length || ''
                        , file_length: msgBody.file_length || ''
                        , filetype: msgBody.filetype || ''
                        , accessToken: this.context.accessToken || ''
                        , ext: extmsg
                        , delay: parseMsgData.delayTimeStamp
                    };
                    !msg.delay && delete msg.delay;
                    msg.error = errorBool;
                    msg.errorText = errorText;
                    msg.errorCode = errorCode;
                    this.onAudioMessage(msg);
                    break;
                case 'file':
                    var msg = {
                        id: id
                        , type: chattype
                        , from: from
                        , to: too
                        , url: msgBody.url
                        , secret: msgBody.secret
                        , filename: msgBody.filename
                        , file_length: msgBody.file_length
                        , accessToken: this.context.accessToken || ''
                        , ext: extmsg
                        , delay: parseMsgData.delayTimeStamp
                    };
                    !msg.delay && delete msg.delay;
                    msg.error = errorBool;
                    msg.errorText = errorText;
                    msg.errorCode = errorCode;
                    this.onFileMessage(msg);
                    break;
                case 'loc':
                    var msg = {
                        id: id
                        , type: chattype
                        , from: from
                        , to: too
                        , addr: msgBody.addr
                        , lat: msgBody.lat
                        , lng: msgBody.lng
                        , ext: extmsg
                        , delay: parseMsgData.delayTimeStamp
                    };
                    !msg.delay && delete msg.delay;
                    msg.error = errorBool;
                    msg.errorText = errorText;
                    msg.errorCode = errorCode;
                    this.onLocationMessage(msg);
                    break;
                case 'video':
                    var msg = {
                        id: id
                        , type: chattype
                        , from: from
                        , to: too
                        , url: msgBody.url
                        , secret: msgBody.secret
                        , filename: msgBody.filename
                        , file_length: msgBody.file_length
                        , accessToken: this.context.accessToken || ''
                        , ext: extmsg
                        , delay: parseMsgData.delayTimeStamp
                    };
                    !msg.delay && delete msg.delay;
                    msg.error = errorBool;
                    msg.errorText = errorText;
                    msg.errorCode = errorCode;
                    this.onVideoMessage(msg);
                    break;
                case 'cmd':
                    var msg = {
                        id: id
                        , from: from
                        , to: too
                        , action: msgBody.action
                        , ext: extmsg
                        , delay: parseMsgData.delayTimeStamp
                    };
                    !msg.delay && delete msg.delay;
                    msg.error = errorBool;
                    msg.errorText = errorText;
                    msg.errorCode = errorCode;
                    this.onCmdMessage(msg);
                    break;
            }
            ;
        } catch (e) {
            this.onError({
                type: _code.WEBIM_CONNCTION_CALLBACK_INNER_ERROR
                , data: e
            });
        }
    }
};

connection.prototype.handleReceivedMessage = function (message) {
    try {
        this.onReceivedMessage(message);
    } catch (e) {
        this.onError({
            type: _code.WEBIM_CONNCTION_CALLBACK_INNER_ERROR
            , data: e
        });
    }

    var rcv = message.getElementsByTagName('received'),
        id,
        mid;

    if (rcv.length > 0) {
        if (rcv[0].childNodes && rcv[0].childNodes.length > 0) {
            id = rcv[0].childNodes[0].nodeValue;
        } else {
            id = rcv[0].innerHTML || rcv[0].innerText;
        }
        mid = rcv[0].getAttribute('mid');
    }

    if (_msgHash[id]) {
        try {
            _msgHash[id].msg.success instanceof Function && _msgHash[id].msg.success(id, mid);
        } catch (e) {
            this.onError({
                type: _code.WEBIM_CONNCTION_CALLBACK_INNER_ERROR
                , data: e
            });
        }
        delete _msgHash[id];
    }
};

connection.prototype.handleInviteMessage = function (message) {
    var form = null;
    var invitemsg = message.getElementsByTagName('invite');
    var reasonDom = message.getElementsByTagName('reason')[0];
    var reasonMsg = reasonDom.textContent;
    var id = message.getAttribute('id') || '';
    this.sendReceiptsMessage({
        id: id
    });

    if (invitemsg && invitemsg.length > 0) {
        var fromJid = invitemsg[0].getAttribute('from');
        form = _parseNameFromJidFn(fromJid);
    }
    var xmsg = message.getElementsByTagName('x');
    var roomid = null;
    if (xmsg && xmsg.length > 0) {
        for (var i = 0; i < xmsg.length; i++) {
            if ('jabber:x:conference' === xmsg[i].namespaceURI) {
                var roomjid = xmsg[i].getAttribute('jid');
                roomid = _parseNameFromJidFn(roomjid);
            }
        }
    }
    this.onInviteMessage({
        type: 'invite',
        from: form,
        roomid: roomid,
        reason: reasonMsg
    });
};

connection.prototype.sendCommand = function (dom, id) {
    if (this.isOpened()) {
        //console.log("wadawdwdwadwa", dom)
        this.context.stropheConn.send(dom);
    } else {
        this.onError({
            type: _code.WEBIM_CONNCTION_DISCONNECTED,
            reconnect: true
        });
    }
};

connection.prototype.getUniqueId = function (prefix) {
    var cdate = new Date();
    var offdate = new Date(2010, 1, 1);
    var offset = cdate.getTime() - offdate.getTime();
    var hexd = parseInt(offset).toString(16);

    if (typeof prefix === 'string' || typeof prefix === 'number') {
        return prefix + '_' + hexd;
    } else {
        return 'WEBIM_' + hexd;
    }
};

connection.prototype.send = function (message) {
    //console.log(message)
    if (WebIM.config.isWindowSDK) {
        WebIM.doQuery('{"type":"sendMessage","to":"' + message.to + '","message_type":"' + message.type + '","msg":"' + encodeURI(message.msg) + '","chatType":"' + message.chatType + '"}',
            function (response) {
            },
            function (code, msg) {

            });
    } else {
        if (Object.prototype.toString.call(message) === '[object Object]') {
            var appKey = this.context.appKey || '';
            var toJid = appKey + '_' + message.to + '@' + this.domain;

            if (message.group) {
                toJid = appKey + '_' + message.to + '@conference.' + this.domain;
            }
            if (message.resource) {
                toJid = toJid + '/' + message.resource;
            }
            //console.log(toJid);
            //console.log("adwadwdawdaw", message)
            message.toJid = toJid;
            message.id = message.id || this.getUniqueId();
            _msgHash[message.id] = new _message(message);
            // //console.log(new _message(message))
            _msgHash[message.id].send(this);
        } else if (typeof message === 'string') {
            _msgHash[message] && _msgHash[message].send(this);
        }
    }
};

connection.prototype.addRoster = function (options) {
    var jid = _getJid(options, this);
    var name = options.name || '';
    var groups = options.groups || '';

    var iq = StropheAll.$iq({type: 'set'});
    iq.c('query', {xmlns: 'jabber:iq:roster'});
    iq.c('item', {jid: jid, name: name});

    if (groups) {
        for (var i = 0; i < groups.length; i++) {
            iq.c('group').t(groups[i]).up();
        }
    }
    var suc = options.success || _utils.emptyfn;
    var error = options.error || _utils.emptyfn;
    this.context.stropheConn.sendIQ(iq.tree(), suc, error);
};

connection.prototype.removeRoster = function (options) {
    var jid = _getJid(options, this);
    var iq = StropheAll.$iq({type: 'set'}).c('query', {xmlns: 'jabber:iq:roster'}).c('item', {
        jid: jid,
        subscription: 'remove'
    });

    var suc = options.success || _utils.emptyfn;
    var error = options.error || _utils.emptyfn;
    this.context.stropheConn.sendIQ(iq, suc, error);
};

connection.prototype.getRoster = function (options) {
    var conn = this;
    var dom = StropheAll.$iq({
        type: 'get'
    }).c('query', {xmlns: 'jabber:iq:roster'});
    var options = options || {};
    var suc = options.success || this.onRoster;
    var completeFn = function (ele) {
        var rouster = [];
        var msgBodies = ele.getElementsByTagName('query');
        if (msgBodies && msgBodies.length > 0) {
            var queryTag = msgBodies[0];
            rouster = _parseFriend(queryTag);
        }
        suc(rouster, ele);
    };
    var error = options.error || this.onError;
    var failFn = function (ele) {
        error({
            type: _code.WEBIM_CONNCTION_GETROSTER_ERROR
            , data: ele
        });
    };
    if (this.isOpened()) {
        this.context.stropheConn.sendIQ(dom.tree(), completeFn, failFn);
    } else {
        error({
            type: _code.WEBIM_CONNCTION_DISCONNECTED
        });
    }
};

connection.prototype.subscribe = function (options) {
    var jid = _getJid(options, this);
    var pres = StropheAll.$pres({to: jid, type: 'subscribe'});
    if (options.message) {
        console.log('ggggggggg', pres, options.message)
        pres.c('status').t(options.message).up();
    }
    if (options.nick) {
        pres.c('nick', {'xmlns': 'http://jabber.org/protocol/nick'}).t(options.nick);
    }
    this.sendCommand(pres.tree());
};

connection.prototype.subscribed = function (options) {
    var jid = _getJid(options, this);
    var pres = StropheAll.$pres({to: jid, type: 'subscribed'});
    //console.log("options.message", options.message)
    if (options.message) {
        pres.c('status').t(options.message).up();
    }
    this.sendCommand(pres.tree());
};

connection.prototype.unsubscribe = function (options) {
    var jid = _getJid(options, this);
    var pres = StropheAll.$pres({to: jid, type: 'unsubscribe'});

    if (options.message) {
        pres.c('status').t(options.message);
    }
    this.sendCommand(pres.tree());
};

connection.prototype.unsubscribed = function (options) {
    var jid = _getJid(options, this);
    var pres = StropheAll.$pres({to: jid, type: 'unsubscribed'});

    if (options.message) {
        pres.c('status').t(options.message).up();
    }
    this.sendCommand(pres.tree());
};

connection.prototype.createRoom = function (options) {
    var suc = options.success || _utils.emptyfn;
    var err = options.error || _utils.emptyfn;
    var roomiq;

    roomiq = StropheAll.$iq({
        to: options.roomName,
        type: 'set'
    })
        .c('query', {xmlns: Strophe.NS.MUC_OWNER})
        .c('x', {xmlns: 'jabber:x:data', type: 'submit'});

    return this.context.stropheConn.sendIQ(roomiq.tree(), suc, err);
};

connection.prototype.joinPublicGroup = function (options) {
    var roomJid = this.context.appKey + '_' + options.roomId + '@conference.' + this.domain;
    var room_nick = roomJid + '/' + this.context.userId;
    var suc = options.success || _utils.emptyfn;
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_JOINROOM_ERROR,
            data: ele
        });
    };
    var iq = $pres({
        from: this.context.jid,
        to: room_nick
    })
        .c('x', {xmlns: Strophe.NS.MUC});

    this.context.stropheConn.sendIQ(iq.tree(), suc, errorFn);
};

connection.prototype.listRooms = function (options) {
    var iq = StropheAll.$iq({
        to: options.server || 'conference.' + this.domain,
        from: this.context.jid,
        type: 'get'
    })
        .c('query', {xmlns: Strophe.NS.DISCO_ITEMS});

    var suc = options.success || _utils.emptyfn;
    var error = options.error || this.onError;
    var completeFn = function (result) {
        var rooms = [];
        rooms = _parseRoom(result);
        try {
            suc(rooms);
        } catch (e) {
            error({
                type: _code.WEBIM_CONNCTION_GETROOM_ERROR,
                data: e
            });
        }
    };
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_GETROOM_ERROR
            , data: ele
        });
    };
    this.context.stropheConn.sendIQ(iq.tree(), completeFn, errorFn);
};

connection.prototype.queryRoomMember = function (options) {
    var domain = this.domain;
    var members = [];
    var iq = StropheAll.$iq({
        to: this.context.appKey + '_' + options.roomId + '@conference.' + this.domain
        , type: 'get'
    })
        .c('query', {xmlns: Strophe.NS.MUC + '#admin'})
        .c('item', {affiliation: 'member'});

    var suc = options.success || _utils.emptyfn;
    var completeFn = function (result) {
        var items = result.getElementsByTagName('item');

        if (items) {
            for (var i = 0; i < items.length; i++) {
                var item = items[i];
                var mem = {
                    jid: item.getAttribute('jid')
                    , affiliation: 'member'
                };
                members.push(mem);
            }
        }
        suc(members);
    };
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_GETROOMMEMBER_ERROR
            , data: ele
        });
    };
    this.context.stropheConn.sendIQ(iq.tree(), completeFn, errorFn);
};

connection.prototype.queryRoomInfo = function (options) {
    var domain = this.domain;
    var iq = StropheAll.$iq({
        to: this.context.appKey + '_' + options.roomId + '@conference.' + domain,
        type: 'get'
    }).c('query', {xmlns: Strophe.NS.DISCO_INFO});

    var suc = options.success || _utils.emptyfn;
    var members = [];

    var completeFn = function (result) {
        var settings = '';
        var features = result.getElementsByTagName('feature');
        if (features) {
            settings = features[1].getAttribute('var') + '|' + features[3].getAttribute('var') + '|' + features[4].getAttribute('var');
        }
        switch (settings) {
            case 'muc_public|muc_membersonly|muc_notallowinvites':
                settings = 'PUBLIC_JOIN_APPROVAL';
                break;
            case 'muc_public|muc_open|muc_notallowinvites':
                settings = 'PUBLIC_JOIN_OPEN';
                break;
            case 'muc_hidden|muc_membersonly|muc_allowinvites':
                settings = 'PRIVATE_MEMBER_INVITE';
                break;
            case 'muc_hidden|muc_membersonly|muc_notallowinvites':
                settings = 'PRIVATE_OWNER_INVITE';
                break;
        }
        var owner = '';
        var fields = result.getElementsByTagName('field');
        var fieldValues = {};
        if (fields) {
            for (var i = 0; i < fields.length; i++) {
                var field = fields[i];
                var fieldVar = field.getAttribute('var');
                var fieldSimplify = fieldVar.split('_')[1];
                switch (fieldVar) {
                    case 'muc#roominfo_occupants':
                    case 'muc#roominfo_maxusers':
                    case 'muc#roominfo_affiliations':
                    case 'muc#roominfo_description':
                        fieldValues[fieldSimplify] = (field.textContent || field.text || '');
                        break;
                    case 'muc#roominfo_owner':
                        var mem = {
                            jid: (field.textContent || field.text) + '@' + domain
                            , affiliation: 'owner'
                        };
                        members.push(mem);
                        fieldValues[fieldSimplify] = (field.textContent || field.text);
                        break;
                }

                // if (field.getAttribute('label') === 'owner') {
                //     var mem = {
                //         jid: (field.textContent || field.text) + '@' + domain
                //         , affiliation: 'owner'
                //     };
                //     members.push(mem);
                //     break;
                // }
            }
            fieldValues['name'] = (result.getElementsByTagName('identity')[0]).getAttribute('name');
        }
        log(settings, members, fieldValues);
        suc(settings, members, fieldValues);
    };
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_GETROOMINFO_ERROR
            , data: ele
        });
    };
    this.context.stropheConn.sendIQ(iq.tree(), completeFn, errorFn);
};

connection.prototype.queryRoomOccupants = function (options) {
    var suc = options.success || _utils.emptyfn;
    var completeFn = function (result) {
        var occupants = [];
        occupants = _parseRoomOccupants(result);
        suc(occupants);
    }
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_GETROOMOCCUPANTS_ERROR
            , data: ele
        });
    };
    var attrs = {
        xmlns: Strophe.NS.DISCO_ITEMS
    };
    var info = StropheAll.$iq({
        from: this.context.jid
        , to: this.context.appKey + '_' + options.roomId + '@conference.' + this.domain
        , type: 'get'
    }).c('query', attrs);
    this.context.stropheConn.sendIQ(info.tree(), completeFn, errorFn);
};

connection.prototype.setUserSig = function (desc) {
    var dom = StropheAll.$pres({xmlns: 'jabber:client'});
    desc = desc || '';
    dom.c('status').t(desc);
    this.sendCommand(dom.tree());
};

connection.prototype.setPresence = function (type, status) {
    var dom = StropheAll.$pres({xmlns: 'jabber:client'});
    if (type) {
        if (status) {
            dom.c('show').t(type);
            dom.up().c('status').t(status);
        } else {
            dom.c('show').t(type);
        }
    }
    this.sendCommand(dom.tree());
};

connection.prototype.getPresence = function () {
    var dom = StropheAll.$pres({xmlns: 'jabber:client'});
    var conn = this;
    this.sendCommand(dom.tree());
};

connection.prototype.ping = function (options) {
    var options = options || {};
    var jid = _getJid(options, this);

    var dom = StropheAll.$iq({
        from: this.context.jid || ''
        , to: jid
        , type: 'get'
    }).c('ping', {xmlns: 'urn:xmpp:ping'});

    var suc = options.success || _utils.emptyfn;
    var error = options.error || this.onError;
    var failFn = function (ele) {
        error({
            type: _code.WEBIM_CONNCTION_PING_ERROR
            , data: ele
        });
    };
    if (this.isOpened()) {
        this.context.stropheConn.sendIQ(dom.tree(), suc, failFn);
    } else {
        error({
            type: _code.WEBIM_CONNCTION_DISCONNECTED
        });
    }
    return;
};

connection.prototype.isOpened = function () {
    return this.context.status == _code.STATUS_OPENED;
};

connection.prototype.isOpening = function () {
    var status = this.context.status;
    return status == _code.STATUS_DOLOGIN_USERGRID || status == _code.STATUS_DOLOGIN_IM;
};

connection.prototype.isClosing = function () {
    return this.context.status == _code.STATUS_CLOSING;
};

connection.prototype.isClosed = function () {
    return this.context.status == _code.STATUS_CLOSED;
};

connection.prototype.clear = function () {
    var key = this.context.appKey;
    if (this.errorType != WebIM.statusCode.WEBIM_CONNCTION_DISCONNECTED) {
        this.context = {
            status: _code.STATUS_INIT,
            appKey: key
        };
    }
    if (this.intervalId) {
        clearInterval(this.intervalId);
    }
    if (this.errorType == WebIM.statusCode.WEBIM_CONNCTION_CLIENT_LOGOUT || this.errorType == -1) {

    }
};

connection.prototype.getChatRooms = function (options) {

    if (!_utils.isCanSetRequestHeader) {
        conn.onError({
            type: _code.WEBIM_CONNCTION_NOT_SUPPORT_CHATROOM_ERROR
        });
        return;
    }

    var conn = this,
        token = options.accessToken || this.context.accessToken;

    if (token) {
        var apiUrl = options.apiUrl;
        var appName = this.context.appName;
        var orgName = this.context.orgName;

        if (!appName || !orgName) {
            conn.onError({
                type: _code.WEBIM_CONNCTION_AUTH_ERROR
            });
            return;
        }

        var suc = function (data, xhr) {
            typeof options.success === 'function' && options.success(data);
        };

        var error = function (res, xhr, msg) {
            if (res.error && res.error_description) {
                conn.onError({
                    type: _code.WEBIM_CONNCTION_LOAD_CHATROOM_ERROR,
                    msg: res.error_description,
                    data: res,
                    xhr: xhr
                });
            }
        };

        var pageInfo = {
            pagenum: parseInt(options.pagenum) || 1,
            pagesize: parseInt(options.pagesize) || 20
        };

        var opts = {
            url: apiUrl + '/' + orgName + '/' + appName + '/chatrooms',
            dataType: 'json',
            type: 'GET',
            headers: {'Authorization': 'Bearer ' + token},
            data: pageInfo,
            success: suc || _utils.emptyfn,
            error: error || _utils.emptyfn
        };
        _utils.ajax(opts);
    } else {
        conn.onError({
            type: _code.WEBIM_CONNCTION_TOKEN_NOT_ASSIGN_ERROR
        });
    }

};

connection.prototype.joinChatRoom = function (options) {
    var roomJid = this.context.appKey + '_' + options.roomId + '@conference.' + this.domain;
    var room_nick = roomJid + '/' + this.context.userId;
    var suc = options.success || _utils.emptyfn;
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_JOINCHATROOM_ERROR
            , data: ele
        });
    };

    var iq = $pres({
        from: this.context.jid,
        to: room_nick
    })
        .c('x', {xmlns: Strophe.NS.MUC + '#user'})
        .c('item', {affiliation: 'member', role: 'participant'})
        .up().up()
        .c('roomtype', {xmlns: 'easemob:x:roomtype', type: 'chatroom'});

    this.context.stropheConn.sendIQ(iq.tree(), suc, errorFn);
};

connection.prototype.quitChatRoom = function (options) {
    var roomJid = this.context.appKey + '_' + options.roomId + '@conference.' + this.domain;
    var room_nick = roomJid + '/' + this.context.userId;
    var suc = options.success || _utils.emptyfn;
    var err = options.error || _utils.emptyfn;
    var errorFn = function (ele) {
        err({
            type: _code.WEBIM_CONNCTION_QUITCHATROOM_ERROR
            , data: ele
        });
    };
    var iq = $pres({
        from: this.context.jid,
        to: room_nick,
        type: 'unavailable'
    })
        .c('x', {xmlns: Strophe.NS.MUC + '#user'})
        .c('item', {affiliation: 'none', role: 'none'})
        .up().up()
        .c('roomtype', {xmlns: 'easemob:x:roomtype', type: 'chatroom'});

    this.context.stropheConn.sendIQ(iq.tree(), suc, errorFn);
};

connection.prototype._onReceiveInviteFromGroup = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group invitation",
        msg: info.user + " invites you to join into group:" + info.group_id,
        agree: function agree() {
            WebIM.doQuery('{"type":"acceptInvitationFromGroup","id":"' + info.group_id + '","user":"' + info.user + '"}', function (response) {
            }, function (code, msg) {
                IM.api.NotifyError("acceptInvitationFromGroup error:" + msg);
            });

        },
        reject: function reject() {
            WebIM.doQuery('{"type":"declineInvitationFromGroup","id":"' + info.group_id + '","user":"' + info.user + '"}', function (response) {
            }, function (code, msg) {
                IM.api.NotifyError("declineInvitationFromGroup error:" + msg);
            });
        }
    };

    this.onConfirmPop(options);
};
connection.prototype._onReceiveInviteAcceptionFromGroup = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group invitation response",
        msg: info.user + " agreed to join into group:" + info.group_id,
        agree: function agree() {
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onReceiveInviteDeclineFromGroup = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group invitation response",
        msg: info.user + " rejected to join into group:" + info.group_id,
        agree: function agree() {
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onAutoAcceptInvitationFromGroup = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group invitation",
        msg: "You had joined into the group:" + info.group_name + " automatically.Inviter:" + info.user,
        agree: function agree() {
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onLeaveGroup = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group notification",
        msg: "You have been out of the group:" + info.group_id + ".Reason:" + info.msg,
        agree: function agree() {
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onReceiveJoinGroupApplication = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group join application",
        msg: info.user + " applys to join into group:" + info.group_id,
        agree: function agree() {
            WebIM.doQuery('{"type":"acceptJoinGroupApplication","id":"' + info.group_id + '","user":"' + info.user + '"}', function (response) {
            }, function (code, msg) {
                IM.api.NotifyError("acceptJoinGroupApplication error:" + msg);
            });
        },
        reject: function reject() {
            WebIM.doQuery('{"type":"declineJoinGroupApplication","id":"' + info.group_id + '","user":"' + info.user + '"}', function (response) {
            }, function (code, msg) {
                IM.api.NotifyError("declineJoinGroupApplication error:" + msg);
            });
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onReceiveAcceptionFromGroup = function (info) {
    info = eval('(' + info + ')');
    var options = {
        title: "Group notification",
        msg: "You had joined into the group:" + info.group_name + ".",
        agree: function agree() {
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onReceiveRejectionFromGroup = function () {
    info = eval('(' + info + ')');
    var options = {
        title: "Group notification",
        msg: "You have been rejected to join into the group:" + info.group_name + ".",
        agree: function agree() {
        }
    };
    this.onConfirmPop(options);
};
connection.prototype._onUpdateMyGroupList = function (options) {
    this.onUpdateMyGroupList(options);
};
connection.prototype._onUpdateMyRoster = function (options) {
    this.onUpdateMyRoster(options);
};
connection.prototype.reconnect = function () {
    var that = this;
    setTimeout(function () {
        _login(that.context.restTokenData, that);
    }, (this.autoReconnectNumTotal == 0 ? 0 : this.autoReconnectInterval) * 1000);
    this.autoReconnectNumTotal++;
};
connection.prototype.closed = function () {
    IM.api.init();
};

// used for blacklist
function _parsePrivacy(iq) {
    var list = [];
    var items = iq.getElementsByTagName('item');

    if (items) {
        for (var i = 0; i < items.length; i++) {
            var item = items[i];
            var jid = item.getAttribute('value');
            var order = item.getAttribute('order');
            var type = item.getAttribute('type');
            if (!jid) {
                continue;
            }
            var n = _parseNameFromJidFn(jid);
            list[n] = {
                type: type,
                order: order,
                jid: jid,
                name: n
            };
        }
    }
    return list;
};

// used for blacklist
connection.prototype.getBlacklist = function (options) {
    options = (options || {});
    var iq = StropheAll.$iq({type: 'get'});
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;
    var me = this;

    iq.c('query', {xmlns: 'jabber:iq:privacy'})
        .c('list', {name: 'special'});

    this.context.stropheConn.sendIQ(iq.tree(), function (iq) {
        me.onBlacklistUpdate(_parsePrivacy(iq));
        sucFn();
    }, function () {
        me.onBlacklistUpdate([]);
        errFn();
    });
};

// used for blacklist
connection.prototype.addToBlackList = function (options) {
    var iq = StropheAll.$iq({type: 'set'});
    var blacklist = options.list || {};
    var type = options.type || 'jid';
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;
    var piece = iq.c('query', {xmlns: 'jabber:iq:privacy'})
        .c('list', {name: 'special'});

    var keys = Object.keys(blacklist);
    var len = keys.length;
    var order = 2;

    for (var i = 0; i < len; i++) {
        var item = blacklist[keys[i]];
        var type = item.type || 'jid';
        var jid = item.jid;

        piece = piece.c('item', {action: 'deny', order: order++, type: type, value: jid})
            .c('message');
        if (i !== len - 1) {
            piece = piece.up().up();
        }
    }

    // log('addToBlackList', blacklist, piece.tree());
    this.context.stropheConn.sendIQ(piece.tree(), sucFn, errFn);
};

// used for blacklist
connection.prototype.removeFromBlackList = function (options) {

    var iq = StropheAll.$iq({type: 'set'});
    var blacklist = options.list || {};
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;
    var piece = iq.c('query', {xmlns: 'jabber:iq:privacy'})
        .c('list', {name: 'special'});

    var keys = Object.keys(blacklist);
    var len = keys.length;

    for (var i = 0; i < len; i++) {
        var item = blacklist[keys[i]];
        var type = item.type || 'jid';
        var jid = item.jid;
        var order = item.order;

        piece = piece.c('item', {action: 'deny', order: order, type: type, value: jid})
            .c('message');
        if (i !== len - 1) {
            piece = piece.up().up();
        }
    }

    // log('removeFromBlackList', blacklist, piece.tree());
    this.context.stropheConn.sendIQ(piece.tree(), sucFn, errFn);
};

connection.prototype._getGroupJid = function (to) {
    var appKey = this.context.appKey || '';
    return appKey + '_' + to + '@conference.' + this.domain;
}
;

// used for blacklist
connection.prototype.addToGroupBlackList = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;
    var jid = _getJid(options, this);
    var affiliation = 'admin';//options.affiliation || 'admin';
    var to = this._getGroupJid(options.roomId);
    var iq = StropheAll.$iq({type: 'set', to: to});

    iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
        .c('item', {
            affiliation: 'outcast',
            jid: jid
        });

    this.context.stropheConn.sendIQ(iq.tree(), sucFn, errFn);
};

function _parseGroupBlacklist(iq) {
    var list = {};
    var items = iq.getElementsByTagName('item');

    if (items) {
        for (var i = 0; i < items.length; i++) {
            var item = items[i];
            var jid = item.getAttribute('jid');
            var affiliation = item.getAttribute('affiliation');
            var nick = item.getAttribute('nick');
            if (!jid) {
                continue;
            }
            var n = _parseNameFromJidFn(jid);
            list[n] = {
                jid: jid,
                affiliation: affiliation,
                nick: nick,
                name: n
            };
        }
    }
    return list;
}

// used for blacklist
connection.prototype.getGroupBlacklist = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;

    // var jid = _getJid(options, this);
    var affiliation = 'admin';//options.affiliation || 'admin';
    var to = this._getGroupJid(options.roomId);
    var iq = StropheAll.$iq({type: 'get', to: to});

    iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
        .c('item', {
            affiliation: 'outcast',
        });

    this.context.stropheConn.sendIQ(iq.tree(), function (msginfo) {
        log('getGroupBlackList');
        sucFn(_parseGroupBlacklist(msginfo));
    }, function () {
        errFn();
    });
};

// used for blacklist
connection.prototype.removeGroupMemberFromBlacklist = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;

    var jid = _getJid(options, this);
    var affiliation = 'admin';//options.affiliation || 'admin';
    var to = this._getGroupJid(options.roomId);
    var iq = StropheAll.$iq({type: 'set', to: to});

    iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
        .c('item', {
            affiliation: 'member',
            jid: jid
        });

    this.context.stropheConn.sendIQ(iq.tree(), function (msginfo) {
        sucFn();
    }, function () {
        errFn();
    });
};

/**
 * changeGroupSubject 修改群名称
 *
 * @param options
 */

connection.prototype.changeGroupSubject = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;

    // must be `owner`
    var affiliation = 'owner';
    var to = this._getGroupJid(options.roomId);
    var iq = StropheAll.$iq({type: 'set', to: to});

    iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
        .c('x', {type: 'submit', xmlns: 'jabber:x:data'})
        .c('field', {var: 'FORM_TYPE'})
        .c('value')
        .t('http://jabber.org/protocol/muc#roomconfig')
        .up().up()
        .c('field', {var: 'muc#roomconfig_roomname'})
        .c('value')
        .t(options.subject)
        .up().up()
        .c('field', {var: 'muc#roomconfig_roomdesc'})
        .c('value')
        .t(options.description);


    this.context.stropheConn.sendIQ(iq.tree(), function (msginfo) {
        sucFn();
    }, function () {
        errFn();
    });
};

/**
 * destroyGroup 删除群组
 *
 * @param options
 */

connection.prototype.destroyGroup = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;

    // must be `owner`
    var affiliation = 'owner';
    var to = this._getGroupJid(options.roomId);
    var iq = StropheAll.$iq({type: 'set', to: to});

    iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
        .c('destroy');

    this.context.stropheConn.sendIQ(iq.tree(), function (msginfo) {
        sucFn();
    }, function () {
        errFn();
    });
};

/**
 * leaveGroupBySelf 主动离开群组
 *
 * @param options
 */

connection.prototype.leaveGroupBySelf = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;

    // must be `owner`
    var jid = _getJid(options, this);
    var affiliation = 'admin';
    var to = this._getGroupJid(options.roomId);
    var iq = $iq({type: 'set', to: to});

    iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
        .c('item', {
            affiliation: 'none',
            jid: jid
        });

    this.context.stropheConn.sendIQ(iq.tree(), function (msgInfo) {
        sucFn(msgInfo);
    }, function (errInfo) {
        errFn(errInfo);
    });
};

/**
 * leaveGroup 被踢出群组
 *
 * @param options
 */

connection.prototype.leaveGroup = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;
    var list = options.list || [];
    var affiliation = 'admin';
    var to = this._getGroupJid(options.roomId);
    var iq = $iq({type: 'set', to: to});
    var piece = iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
    var keys = Object.keys(list);
    var len = keys.length;

    for (var i = 0; i < len; i++) {
        var name = list[keys[i]];
        var jid = _getJidByName(name, this);

        piece = piece.c('item', {
            affiliation: 'none',
            jid: jid
        }).up().c('item', {
            role: 'none',
            jid: jid,
        }).up();
    }

    this.context.stropheConn.sendIQ(iq.tree(), function (msgInfo) {
        sucFn(msgInfo);
    }, function (errInfo) {
        errFn(errInfo);
    });
};

/**
 * addGroupMembers 添加群组成员
 *
 * @param options
 */

connection.prototype.addGroupMembers = function (options) {
    var sucFn = options.success || _utils.emptyfn;
    var errFn = options.error || _utils.emptyfn;
    var list = options.list || [];
    var affiliation = 'admin';
    var to = this._getGroupJid(options.roomId);
    var iq = $iq({type: 'set', to: to});
    var piece = iq.c('query', {xmlns: 'http://jabber.org/protocol/muc#' + affiliation})
    var keys = Object.keys(list);
    var len = keys.length;

    for (var i = 0; i < len; i++) {
        var name = list[keys[i]];
        var jid = _getJidByName(name, this);

        piece = piece.c('item', {
            affiliation: 'member',
            jid: jid
        }).up();
    }

    this.context.stropheConn.sendIQ(iq.tree(), function (msgInfo) {
        sucFn(msgInfo);
    }, function (errInfo) {
        errFn(errInfo);
    });
};

/**
 * acceptInviteFromGroup 接受加入申请
 *
 * @param options
 */
connection.prototype.acceptInviteFromGroup = function (options) {
    options.success = function () {
        // then send sendAcceptInviteMessage
        // connection.prototype.sendAcceptInviteMessage(optoins);
    };
    this.addGroupMembers(options);
};

/**
 * rejectInviteFromGroup 拒绝加入申请
 *
 * throw request for now 暂时不处理，直接丢弃
 *
 * @param options
 */
connection.prototype.rejectInviteFromGroup = function (options) {
};

/**
 * createGroup 创建群组
 *
 * 1. 创建申请 -> 得到房主身份
 * 2. 获取房主信息 -> 得到房间form
 * 3. 完善房间form -> 创建成功
 * 4. 添加房间成员
 * 5. 消息通知成员
 * @param options
 */
connection.prototype.createGroup = function (options) {
    var roomId = +new Date();
    var toRoom = this._getGroupJid(roomId);
    var to = toRoom + '/' + this.context.userId;

    var pres = StropheAll.$pres({to: to})
        .c('x', {xmlns: 'http://jabber.org/protocol/muc'}).up()
        .c('create', {xmlns: 'http://jabber.org/protocol/muc'}).up();
    // .c('c', {
    //     hash: 'sha-1',
    //     node: 'https://github.com/robbiehanson/XMPPFramework',
    //     ver: 'k6gP4Ua5m4uu9YorAG0LRXM+kZY=',
    //     xmlns: 'http://jabber.org/protocol/caps'
    // }).up();

    // createGroupACK
    this.sendCommand(pres.tree());

    var me = this;
    // timeout hack for create group async
    setTimeout(function () {
        // Creating a Reserved Room
        var iq = $iq({type: 'get', to: toRoom})
            .c('query', {xmlns: 'http://jabber.org/protocol/muc#owner'});

        // Strophe.info('step 1 ----------');
        // Strophe.info(options);
        me.context.stropheConn.sendIQ(iq.tree(), function (msgInfo) {
            // log(msgInfo);

            // for ie hack
            if ('setAttribute' in msgInfo) {
                // Strophe.info('step 3 ----------');
                var x = msgInfo.getElementsByTagName('x')[0];
                x.setAttribute('type', 'submit');
            } else {
                // Strophe.info('step 4 ----------');
                Strophe.forEachChild(msgInfo, 'x', function (field) {
                    field.setAttribute('type', 'submit');
                });
            }

            // var rcv = msgInfo.getElementsByTagName('x');
            // var v;
            // if (rcv.length > 0) {
            //     if (rcv[0].childNodes && rcv[0].childNodes.length > 0) {
            //         v = rcv[0].childNodes[0].nodeValue;
            //     } else {
            //         v = rcv[0].innerHTML || rcv[0].innerText
            //     }
            //     mid = rcv[0].getAttribute('mid');
            // }
            Strophe.info('step 5 ----------');
            Strophe.forEachChild(x, 'field', function (field) {
                var fieldVar = field.getAttribute('var');
                var valueDom = field.getElementsByTagName('value')[0];
                Strophe.info(fieldVar);
                switch (fieldVar) {
                    case 'muc#roomconfig_roomname':
                        _setText(valueDom, options.subject || '');
                        break;
                    case 'muc#roomconfig_roomdesc':
                        _setText(valueDom, options.description || '');
                        break;
                    case 'muc#roomconfig_publicroom': // public 1
                        _setText(valueDom, +options.optionsPublic);
                        break;
                    case 'muc#roomconfig_membersonly':
                        _setText(valueDom, +options.optionsMembersOnly);
                        break;
                    case 'muc#roomconfig_moderatedroom':
                        _setText(valueDom, +options.optionsModerate);
                        break;
                    case 'muc#roomconfig_persistentroom':
                        _setText(valueDom, 1);
                        break;
                    case 'muc#roomconfig_allowinvites':
                        _setText(valueDom, +options.optionsAllowInvites);
                        break;
                    case 'muc#roomconfig_allowvisitornickchange':
                        _setText(valueDom, 0);
                        break;
                    case 'muc#roomconfig_allowvisitorstatus':
                        _setText(valueDom, 0);
                        break;
                    case 'allow_private_messages':
                        _setText(valueDom, 0);
                        break;
                    case 'allow_private_messages_from_visitors':
                        _setText(valueDom, 'nobody');
                        break;
                    default:
                        break;
                }
                // log(valueDom);
            });

            var iq = $iq({to: toRoom, type: 'set'})
                .c('query', {xmlns: 'http://jabber.org/protocol/muc#owner'})
                .cnode(x);

            // log(iq.tree());

            me.context.stropheConn.sendIQ(iq.tree(), function (msgInfo) {
                // sucFn(msgInfo);

                me.addGroupMembers({
                    list: options.members,
                    roomId: roomId
                });
            }, function (errInfo) {
                // errFn(errInfo);
            });
            // sucFn(msgInfo);
        }, function (errInfo) {
            // errFn(errInfo);
        });
    }, 1000);
};

function _setText(valueDom, v) {
    if ('textContent' in valueDom) {
        valueDom.textContent = v;
    } else if ('text' in valueDom) {
        valueDom.text = v;
    } else {
        // Strophe.info('_setText 4 ----------');
        // valueDom.innerHTML = v;
    }
}
// connection.prototype.onError = function () {
//     return false;
// };
// window.WebIM = typeof WebIM !== 'undefined' ? WebIM : {};
var WebIM = window.WebIM || {};
WebIM.connection = connection;
WebIM.utils = _utils;
WebIM.statusCode = _code;
WebIM.message = _msg.message;
WebIM.doQuery = function (str, suc, fail) {
    if (typeof window.cefQuery === 'undefined') {
        return;
    }
    window.cefQuery({
            request: str,
            persistent: false,
            onSuccess: suc,
            onFailure: fail
        }
    );
};

module.exports = WebIM;

if (module.hot) {
    module.hot.accept();
}