// ;
// (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();
}