欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

uniapp 链接openfire

程序员文章站 2022-03-30 10:18:13
import xmldom from './x2j/xmldom/dom-parser.js'var DOMParser = xmldom.DOMParser;let document = new DOMParser().parseFromString("\n", 'text/xml');import X2JS from './x2j/x2js/we-x2js.js'import XML from './ObjTree.js'import {b...

import xmldom from './x2j/xmldom/dom-parser.js'
var DOMParser = xmldom.DOMParser;
let document = new DOMParser().parseFromString("<?xml version='1.0'?>\n", 'text/xml');
import X2JS from './x2j/x2js/we-x2js.js'
import XML from './ObjTree.js'
import {btoa} from './base64.min.js'

//消息服务地址
const XMPPSERVER = "wss://域名地址:7443/ws";
//消息域名
const XMPPDOMAIN = "域名";
const XMPPDOMAINSUFFIX = "@域名";
//房间URL
const ROOMURL = "conference.域名";
const ROOMURLSUFFIX = "@conference.域名";
//查询服务
const SEARCHURL = "search.域名";
let AppIM ={};
function HHJYIM(){
    if (!(this instanceof HHJYIM)) {
        return new HHJYIM();
    }
}
// //构造函数
function HHJYIMConnection(options) {
    if (!(this instanceof HHJYIMConnection)) {
        return new HHJYIMConnection(options);
    }
    options = options || {};
    this.url = XMPPSERVER;
    this.domain = XMPPDOMAIN;
    console.log(11);
};

//socket 连接对象
let socketTask = null; 
//链接ID
let connectionID = null;
//链接用户名
let username=null;
//链接密码
let password=null;
//是否已经登录
let isLogin = false;
//链接成功回调函数
let OnConnectionCallback=null;
//全局消息监听
let GlobalMessageCallBack = null;
 HHJYIMConnection.prototype = {
     handlers:[],
     connected:false,
    //连接方法
    Connection : function (options) {
      console.log('连接方法-1111');
      username = options.UserName;
      password = options.UserPassword;
      //this.service = service;
      this.options = options || {};
      this.jid = "";
      HHJYIMConnection.prototype.handlers = [];
      HHJYIMConnection.prototype.connected = false;
      this.maxRetries = 5;
      socketTask = uni.connectSocket({
        url: XMPPSERVER,
        header: {'content-type': 'application/json'},
        protocols: ['xmpp'],
        method: 'GET',
      })
      uni.onSocketOpen(function (res) {
          console.log('onOpen', res);
          _webSocketOpened(options);
      });
      OnConnectionCallback = options.OnConnection;
      uni.onSocketMessage(function (res) {
          console.log("uni.onSocketMessage",res);
          onMessage(res,options);
      });
    },
    //设置消息链接的回调函数
    AddHandlers :function (options){
        if(HHJYIMConnection.prototype.handlers.length > 0){
            var repeat = HHJYIMConnection.prototype.handlers.filter(item => item.NS ==options.NS && item.Name==options.Name && item.Type==options.Type && item.ID==options.ID && item.From==options.From  && item.IsHasNode==options.IsHasNode)
            if(repeat.length<=0){
                HHJYIMConnection.prototype.handlers.push(options);
            }
        }else{
            HHJYIMConnection.prototype.handlers.push(options);
        }
        console.log("设置消息链接的回调函数",HHJYIMConnection.prototype.handlers)
    },
    //删除对应的回调函数
    RemoveHandlers : function (options){
        if(HHJYIMConnection.prototype.handlers.length > 0){
            for(var index=0 ;index<HHJYIMConnection.prototype.handlers.length;index++){
                var item= HHJYIMConnection.prototype.handlers[index];
                if(item.NS ==options.NS && item.Name==options.Name && item.Type==options.Type && item.ID==options.ID && item.From==options.From  && item.IsHasNode==options.IsHasNode){
                    HHJYIMConnection.prototype.handlers.splice(index,1);
                }
            }
        }
        console.log("删除对应的回调函数",HHJYIMConnection.prototype.handlers)
    },
    //获取我的好友列表
    GetMyFriends : function (options){
      var hhjyim = HHJYIM.Connection.prototype;
      myFriend = hhjyim.$iq({
        from: options.JID,
          type: 'get',
          id: "GetMyFriends"
        }).c('query', { xmlns: HHJYIM.prototype.NS.ROSTER });
      uni.sendSocketMessage({
        data: myFriend.tree().toString(),
        success:function(){
            options.Success();
        },
        fail:function(){
            options.fail();
        },
        complete:function(){
            options.complete()
        }
      });
    },
    //设置在线状态
    SettingOnline : function (options){
      var setOnLine = null;
      var hhjyim = HHJYIM.prototype;
      if (options.Type == "chat"){
        setOnLine = hhjyim.$pres(
          { "id": "OnlineSetting" }
        ).c("status").t("在线")
        .up().c("priority").t("1");
      } 
      if (options.Type == "away"){
        setOnLine = hhjyim.$pres(
          { "id": "OnlineSetting" })
          .c("status").t("离开")
          .up().c("priority").t("0")
          .up().c("show").t("away");
      }
      if (options.Type == "dnd") {
        setOnLine = hhjyim.$pres(
          { "id": "OnlineSetting" })
          .c("status").t("忙碌")
          .up().c("priority").t("0")
          .up().c("show").t("dnd");
      }
      uni.sendSocketMessage({ 
          data: setOnLine.tree().toString(),
          success:function(){
              options.Success();
          },
          fail:function(){
              options.fail();
          },
          complete:function(){
              options.complete()
          }
      });
    },
    //查找好友
    SearchFriends : function (options) {
      var hhjyim = HHJYIM.prototype;
      var searchFriends = hhjyim.$iq({
        to: SEARCHURL,
        type: 'set',
        id: "SearchFriends"
      }).c('query', { xmlns: HHJYIM.prototype.NS.SEARCH })
        .c("x", { "xmlns": HHJYIM.prototype.NS.DATA, "type": "submit" })
        .c("field", { "var": "FORM_TYPE", "type": "hidden" })
        .c("value").t(HHJYIM.prototype.NS.SEARCH)
        .up().up().c("field", { "var": "search", "type": "text-single" })
        .c("value").t(options.FriendsName)
        .up().up().c("field", { "var": "Username", "type": "boolean" })
        .c("value").t("1")
        .up().up().c("field", { "var": "Name", "type": "boolean" })
        .c("value").t("1")
        .up().up().c("field", { "var": "Email", "type": "boolean" })
        .c("value").t("1");
      uni.sendSocketMessage({ 
          data: searchFriends.tree().toString(),
          success:function(){
              options.Success();
          },
          fail:function(){
              options.fail();
          },
          complete:function(){
              options.complete()
          }
          });
    },
    //添加好友
    AddFriend : function (options) {
      var hhjyim = HHJYIM.prototype;
      var addFriend = hhjyim.$iq({
        type: 'set',
        id: "SetFriendToGroup"
      }).c('query', { xmlns: 'jabber:iq:roster' })
        .c("item", { "jid": options.JID, "name": options.FriendName })
        .c("group").t("组名称");
      uni.sendSocketMessage({ 
          data: addFriend.tree().toString(),
          success:function(){
              options.Success();
          },
          fail:function(){
              options.fail();
          },
          complete:function(){
              options.complete()
          }
          });
    },
    //同意好友
    AgreeFriend : function (options){
      var hhjyim = HHJYIM.prototype;
      var agreeFriends = hhjyim.$pres({ to: options.MessageContext, "type": "subscribed" });
      uni.sendSocketMessage({ 
          data: agreeFriends.tree().toString(),
          success:function(){
              options.Success();
          },
          fail:function(){
              options.fail();
          },
          complete:function(){
              options.complete()
          }
           });
    },
    //不同意好友请求
    DisagreeFriend : function (options){
      var hhjyim = HHJYIM.prototype;
      var disAgreeFriends = hhjyim.$pres({ to: options.MessageContext, "type": "unsubscribed" });
      uni.sendSocketMessage({ 
          data: disAgreeFriends.tree().toString(),
          success:function(){
              options.Success();
          },
          fail:function(){
              options.fail();
          },
          complete:function(){
              options.complete()
          }
           });
    },
    //删除好友
    RemoveFriend : function (options){
      var hhjyim = HHJYIM.prototype;
      var removeFriend = hhjyim.$iq({
        from: options.Jid,
        type: 'set',
        id: "RemoveFriend"
      }).c('query', { xmlns: HHJYIM.prototype.NS.ROSTER })
        .c("item", { "jid": options.Jid, "name": options.UserName, "subscription": "remove" });
      uni.sendSocketMessage({ 
          data: removeFriend.tree().toString(),
          success:function(){
              options.Success();
          },
          fail:function(){
              options.fail();
          },
          complete:function(){
              options.complete()
          }
          }); 
    },
    //销毁群组
    DestroyingRoom : function (jsonPar) {
         var hhjyim = HHJYIM.prototype;
        var destoryRoom = $iq({
            "to": jsonPar.RoomJID ,
            "type": "set",
            "id": "DestroyingRoom",
            "from": jsonPar.UserName
        }).c("query", { 'xmlns': 'http://jabber.org/protocol/muc#owner' })
            .c("destroy", { "jid": jsonPar.RoomJID })
            .c("reason").t(jsonPar.Reason);
        uni.sendSocketMessage({ 
            data: destoryRoom.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
             }); 
    },
    //离开房间
    LeaveRoom : function (options){
      var hhjyim = HHJYIM.prototype;
      setOnLine = hhjyim.$pres({ to: options.RoomJID + "/" + options.UserName, "type": "unavailable" });
      uni.sendSocketMessage({ 
          data: setOnLine.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
       });
    },
    //邀请进入房间
    InviteUserToRoom : function (options){
      var hhjyim = HHJYIM.prototype;
      var inviteUser = hhjyim.$msg({
        to: options.RoomJID
      }).c("x", { "xmlns": HHJYIM.prototype.NS.MUC_USER })
        .c("invite", { "to": options.InviteUserJID })
        .c("reason").t(options.Reason);
      uni.sendSocketMessage({ 
          data: inviteUser.tree().toString() ,
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
          });
    },
    //创建房间
    CreateRoom : function (options){
      var hhjyim = HHJYIM.prototype;
      //默认属性
      var defaults = {
        IsPerpetual: "1",
        PublicRoom: "1",
        RoomNumberCount: "500",
        IsInvitation: "1",
        RoomName: "默认房间",
        RoomDescription: "默认房间",
        IsSaveMessage: "1"
      };
      options = Object.assign(defaults, options);
       //发送创建房间请求
      var fromUser = options.FromUser + XMPPDOMAINSUFFIX;
      var toRoom = options.RoomName + ROOMURLSUFFIX + '/' + options.FromUser;
      var roomPresen = hhjyim.$pres({
        from: fromUser,
        to: toRoom
      }).c("x", { "xmlns": HHJYIM.prototype.NS.MUC });
      uni.sendSocketMessage({ data: roomPresen.tree().toString() });
      //查询房间配置
      var queryRoom = hhjyim.$iq({
        from: fromUser,
        id: 'queryRoomInfo',
        to: toRoom,
        type: 'get'
      }).c("query", {
        xmlns: HHJYIM.prototype.NS.MUC_OWNER
      });
      uni.sendSocketMessage({ data: queryRoom.tree().toString()});
      var setRoomIQ = hhjyim.$iq({
        from: fromUser,
        id: 'SetRoomInfo',
        to: toRoom,
        type: 'set'
      }).c("query", {
        xmlns: HHJYIM.prototype.NS.MUC_OWNER
      });
      setRoomIQ.c("x", {
        xmlns: HHJYIM.prototype.NS.DATA,
        type: "submit"
      });
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_persistentroom' }).c('value').t(options.IsPerpetual).up().up();//是否永久
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_publicroom' }).c('value').t(options.PublicRoom).up().up();//是否显示房间
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_maxusers' }).c('value').t(options.RoomNumberCount).up().up();//最大房客数
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_allowinvites' }).c('value').t(options.IsInvitation).up().up();//允许成员邀请其他人
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_roomname' }).c('value').t(options.RoomName).up().up();//设置房间名称
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_roomdesc' }).c('value').t(options.RoomDescription).up().up();//设置房间描述
      setRoomIQ.c('field', { 'var': 'muc#roomconfig_enablelogging' }).c('value').t(options.IsSaveMessage).up().up(); //是否保存消息履历 
      setRoomIQ.c("field", { 'var': 'muc#roomconfig_presencebroadcast' }).c("value").t("participant").up().up();
      uni.sendSocketMessage({ 
        data: setRoomIQ.tree().toString(),
        success:function(){
            options.Success();
        },
        fail:function(){
            options.fail();
        },
        complete:function(){
            options.complete()
        }
          });
    },
    //获取我的群组列表
    GetMyRooms : function (options) {
      var hhjyim = HHJYIM.prototype;
      var getRooms = hhjyim.$iq({
        from: options.JID,
        to: options.RoomUrl,
        type: 'get',
        id: "GetMyRooms"
      }).c("query", { "xmlns": HHJYIM.prototype.NS.DISCO_ITEMS });
      uni.sendSocketMessage({ 
        data: getRooms.tree().toString(),
        success:function(){
            options.Success();
        },
        fail:function(){
            options.fail();
        },
        complete:function(){
            options.complete()
        }
           });
    },
    //加入房间
    JoinRoom : function (options){
      var hhjyim = HHJYIM.prototype;
      // var pres = hhjyim.$pres({
      //   to: options.RoomJID + ROOMURLSUFFIX + '/' + options.UserName
      // }).c("x", { xmlns: HHJYIM.prototype.NS.MUC });
      // uni.sendSocketMessage({ data: pres.tree().toString() });
       //设置权限
        var setRole = hhjyim.$iq({
          to: options.RoomJID+ ROOMURLSUFFIX ,
          type: "set"
        }).c('query', { xmlns: HHJYIM.prototype.NS.MUC + "#admin" })
          .c('item', {
            jid: options.UserName + XMPPDOMAINSUFFIX,
            affiliation: "participant"
          });
        uni.sendSocketMessage({ 
            data: setRole.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
             });
    },
    //群组踢人
    OutCastRoom : function (options){
        var hhjyim = HHJYIM.prototype;
        var outcast  = hhjyim.$iq({
            to: options.RoomJID,
            type: "set",
            }).c('query', {xmlns: HHJYIM.prototype.NS.MUC + "#admin"})
              .c('item', {jid: options.UserName, affiliation: "outcast"});
        uni.sendSocketMessage({ 
            data: outcast.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
             });
    },
    //设置为管理员
    SetUserAdmin:function (options){
        var hhjyim = HHJYIM.prototype;
        var adminUser = hhjyim.$iq({
            to: options.RoomJID,
            type: "set",
            }).c('query', {xmlns: HHJYIM.prototype.NS.MUC + "#admin"})
              .c('item', {jid: options.UserName, affiliation: "admin"});
        uni.sendSocketMessage({ 
            data: adminUser.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            } 
            });
    },
    //ping设置
    SendPingfunction :function (options) {
      var hhjyim = HHJYIM.prototype;
      var ping = hhjyim.$iq({
        to: XMPPDOMAIN,
        type: "get",
        id: "ping"
      }).c("ping", { xmlns: "urn:xmpp:ping" });
      uni.sendSocketMessage({ 
        data: ping.tree().toString(),
        success:function(){
            options.Success();
        },
        fail:function(){
            options.fail();
        },
        complete:function(){
            options.complete()
        }
      });
    },
    //关闭连接
    Disconnecting  : function (options){
      var hhjyim = HHJYIM.prototype;
      var presence = hhjyim.$pres({ "type":"unavailable" });
      console.log(presence.toString());
      uni.sendSocketMessage({ data: presence.tree().toString() });
      //发送stream
      var stream = {
        "stream:stream":{}
      }
      var streamXml = HHJYIM.prototype.JsonToXML(stream);
      uni.sendSocketMessage({ 
        data: streamXml ,
        success:function(){
            options.Success();
        },
        fail:function(){
            options.fail();
        },
        complete:function(){
            options.complete()
        }
          });
    },
    //发送消息
    SendMessage :function(options){
      var hhjyim = HHJYIM.prototype;
      var setOnLine = hhjyim.$pres(
        { "id": "OnlineSetting" }
      ).c("status").t("在线")
      .up().c("priority").t("1");
      uni.sendSocketMessage({ data: setOnLine.tree().toString() });
      if(options.Type == "chat"){
          var toUser = options.ToUser + XMPPDOMAINSUFFIX;
          var fromUser = options.FromUser + XMPPDOMAINSUFFIX;
          var messageInfo = hhjyim.$msg({
            to: toUser,
            from: fromUser,
            type: options.Type,
            file: options.CustomType == null ? "" : options.CustomType
          }).c("body").t(""+options.Message);
          console.log("单人发送消息",messageInfo.tree().toString());
          uni.sendSocketMessage({ 
            data: messageInfo.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
        });
      }else{
          var toUser = options.ToUser  ;
          var fromUser = options.FromUser + XMPPDOMAINSUFFIX;
          var messageInfo = hhjyim.$msg({
            to: toUser +ROOMURLSUFFIX,
            from: fromUser,
            type: options.Type,
            file: options.CustomType == null ? "" : options.CustomType
          }).c("body").t(""+options.Message);
          console.log("群组发送消息",messageInfo.tree().toString());
          uni.sendSocketMessage({ 
            data: messageInfo.tree().toString(),
            success:function(){
                options.Success();
            },
            fail:function(){
                options.fail();
            },
            complete:function(){
                options.complete()
            }
          });
      }
    }
}


HHJYIM.prototype = {
  _xmlGenerator: null,
  //创建对应的节点
  $build: function (name, attrs) { return new HHJYIM.Builder(name, attrs); },
  //形成msg节点
  $msg: function (attrs) { return new HHJYIM.Builder("message", attrs);},
  //形成iq节点
  $iq: function (attrs) { return new HHJYIM.Builder("iq", attrs);},
  //形成presence 节点
  $pres: function (attrs) { return new HHJYIM.Builder("presence", attrs)},
  //打开
  $open: function (attrs) { return new HHJYIM.Builder("open", attrs)},
  //对应对应的命名空间
  NS:{
    HTTPBIND: "http://jabber.org/protocol/httpbind",
    BOSH: "urn:xmpp:xbosh",
    CLIENT: "jabber:client",
    AUTH: "jabber:iq:auth",
    ROSTER: "jabber:iq:roster",
    PROFILE: "jabber:iq:profile",
    SEARCH: "jabber:iq:search",
    DATA: "jabber:x:data",
    DISCO_INFO: "http://jabber.org/protocol/disco#info",
    DISCO_ITEMS: "http://jabber.org/protocol/disco#items",
    MUC: "http://jabber.org/protocol/muc",
    MUC_OWNER: "http://jabber.org/protocol/muc#owner",
    MUC_USER: "http://jabber.org/protocol/muc#user",
    SASL: "urn:ietf:params:xml:ns:xmpp-sasl",
    STREAM: "http://etherx.jabber.org/streams",
    BIND: "urn:ietf:params:xml:ns:xmpp-bind",
    SESSION: "urn:ietf:params:xml:ns:xmpp-session",
    VERSION: "jabber:iq:version",
    REGISTER: "jabber:iq:register",
    STANZAS: "urn:ietf:params:xml:ns:xmpp-stanzas",
    FRAMING: "urn:ietf:params:xml:ns:xmpp-framing",
    XMLLANG: "zh"
  },
  Status: {
    ERROR: 0,
    CONNECTING: 1,
    CONNFAIL: 2,
    AUTHENTICATING: 3,
    AUTHFAIL: 4,
    CONNECTED: 5,
    DISCONNECTED: 6,
    DISCONNECTING: 7
  },
  ElementType: {
    NORMAL: 1,
    TEXT: 3
  },
  //超时时间
  TIMEOUT: 70, 
  //二次超时
  SECONDARY_TIMEOUT: 7,
  //添加命名空间
  addNamespace: function (name, value) {
    HHJYIM.NS[name] = value;
  },
  //判断节点是否相同
  isTagEqual: function (data, name) {
    return data[name] ;
  },
  //JSON 格式化XML 
   JsonToXML:function (jsonStr) {
      var xotree = new XML.ObjTree();
      var xml = xotree.writeXML(jsonStr);
      return xml;
    },
  //xml 转JSON
   XMLToJson:function(xml){
     var x2js = new X2JS();
     var json = x2js.xml2js(xml);
     return json;
   },
   //xml节点形成
   xmlElement: function (name) {
    if (!name) { return null; }

    var node = null;
    if (!HHJYIM._xmlGenerator) {
      HHJYIM.prototype._xmlGenerator = HHJYIM.prototype._makeGenerator();
    }
     node = HHJYIM.prototype._xmlGenerator.createElement(name);
    var a, i, k;
    for (a = 1; a < arguments.length; a++) {
      if (!arguments[a]) { continue; }
      if (typeof (arguments[a]) == "string" ||
        typeof (arguments[a]) == "number") {
        node.appendChild(HHJYIM.prototype.xmlTextNode(arguments[a]));
      } else if (typeof (arguments[a]) == "object" &&
        typeof (arguments[a]['sort']) == "function") {
        for (i = 0; i < arguments[a].length; i++) {
          if (typeof (arguments[a][i]) == "object" &&
            typeof (arguments[a][i]['sort']) == "function") {
            node.setAttribute(arguments[a][i][0],
              arguments[a][i][1]);
          }
        }
      } else if (typeof (arguments[a]) == "object") {
        for (k in arguments[a]) {
          if (arguments[a].hasOwnProperty(k)) {
            node.setAttribute(k, arguments[a][k]);
          }
        }
      }
    }
    return node;
  },
  //xml形成器
  _makeGenerator: function () {
    var doc;
    if (document.implementation.createDocument === undefined ||
      document.implementation.createDocument && document.documentMode && document.documentMode < 10) {
      doc = this._getIEXmlDom();
      doc.appendChild(doc.createElement('HHJYIM'));
    } else {
      doc = document.implementation.createDocument('jabber:client', 'HHJYIM', null);
    }
    return doc;
  },
  //序列化xml 
  serialize: function (elem) {
    var result;
    if (!elem) return null;
    if (typeof (elem["tree"]) === "function") {
      elem = elem.tree();
    }
    var nodeName = elem.nodeName;
    var i, child;
    if (elem.getAttribute("_realname")) {
      nodeName = elem.getAttribute("_realname");
    }
    result = "<" + nodeName;
    for (i = 0; i < elem.attributes.length; i++) {
      if (elem.attributes[i].nodeName != "_realname") {
        result += " " + elem.attributes[i].nodeName.toLowerCase() +
          "='" + elem.attributes[i].value
            .replace("'", "&#39;").replace("&", "&#x26;") + "'";
      }
    }
    if (elem.childNodes.length > 0) {
      result += ">";
      for (i = 0; i < elem.childNodes.length; i++) {
        child = elem.childNodes[i];
        if (child.nodeType == HHJYIM.prototype.ElementType.NORMAL) {
          result += HHJYIM.serialize(child);
        } else if (child.nodeType == HHJYIM.prototype.ElementType.TEXT) {
          result += child.nodeValue;
        }
      }
      result += "</" + nodeName + ">";
    } else {
      result += "/>";
    }
    return result;
  },
  //创建一个xml text Node
  xmlTextNode: function (text) {
    text = HHJYIM.prototype.xmlescape(text);
    if (!HHJYIM.prototype._xmlGenerator) {
      HHJYIM.prototype._xmlGenerator = HHJYIM.prototype._makeGenerator();
    }
    return HHJYIM.prototype._xmlGenerator.createTextNode(text);
  },
  //取消无效的特殊字符
  xmlescape: function (text) {
    text = text.replace(/\&/g, "&amp;");
    text = text.replace(/</g, "&lt;");
    text = text.replace(/>/g, "&gt;");
    return text;
  },
};
//节点创建类
HHJYIM.Builder = function (name, attrs){
  if (name == "presence" || name == "message" || name == "iq") {
    if (attrs && !attrs.xmlns)
      attrs.xmlns = HHJYIM.prototype.NS.CLIENT;
    else if (!attrs)
      attrs = { xmlns: HHJYIM.prototype.NS.CLIENT };
  }
  this.nodeTree = HHJYIM.prototype.xmlElement(name, attrs);
  this.node = this.nodeTree;
}

HHJYIM.Builder.prototype = {
  //制作一个节点树
  tree: function () {
    return this.nodeTree;
  },
  //序列化节点数为一个字符串
  toString: function () {
    return HHJYIM.prototype.serialize(this.nodeTree);
  },
    //当前节点的上级节点
  up: function () {
    this.node = this.node.parentNode;
    return this;
  },
  //添加活这修改节点属性值
  attrs: function (moreattrs) {
    for (var k in moreattrs){
      this.node.setAttribute(k, moreattrs[k]);
    }
    return this;
  },
  //当前节点下添加节点
  c: function (name, attrs) {
    var child = HHJYIM.prototype.xmlElement(name, attrs);
    this.node.appendChild(child);
    this.node = child;
    return this;
  },
  //添加一个子节点,并是他当做现在的新节点
  cnode: function (elem) {
    this.node.appendChild(elem);
    this.node = elem;
    return this;
  },
  //设置节点的对应的值
  t: function (text) {
    var child = HHJYIM.prototype.xmlTextNode(text);
    this.node.appendChild(child);
    return this;
  }
}


//打开连接socket
function _webSocketOpened(options) {
  var hhjyim = HHJYIM.prototype;
  var from = options.UserName + XMPPDOMAINSUFFIX;
  var open = hhjyim.$open({
    "to": XMPPDOMAIN,
    "from": from,
    "xmlns": HHJYIM.prototype.NS.FRAMING,
    "xml:lang":HHJYIM.prototype.NS.XMLLANG,
    "version": "1.0"
  });
  var steam= open.tree().toString();
  console.log(steam);
  uni.sendSocketMessage({
        data: steam,
        success:function(){
            console.log("connwsopen");
        },
        fail:function(){
            console.log("connwsopen");
        }
  });
}

// 收到消息的处理函数
function onMessage(event,options) {
  var jsondata = HHJYIM.prototype.XMLToJson(event.data);
  //自定义监听事件
  for (let index = 0; index < HHJYIMConnection.prototype.handlers.length; index++) {
    var hand = HHJYIMConnection.prototype.handlers[index];
    if (customListerMatch(jsondata, hand)) {
      hand.CallBack(jsondata);
    }
  }
  //判断是否是消息节点
  if (undefined != jsondata.message) {
    if (undefined != jsondata.message.body) {
     
    } else if (undefined != jsondata.message.composing) {
      //对方正在输入
    } else if (undefined != jsondata.message.gone) {
      //对方已关闭和您的聊天
    } else if (undefined != jsondata.message.file) {
      //收到的文件:
    } else {
      console.log("其他:", jsondata.message);
    }
  } else if (undefined != jsondata.open) {
    //记录id
    connectionID = jsondata.open["_id"];
  } else if (undefined != jsondata["features"]) {
    if (undefined != jsondata["features"].mechanisms) {
      //获取登录验证方式
      socketAuth(jsondata["features"].mechanisms.mechanism[0]);
    } else if (undefined != jsondata["features"].bind) {
      sockeBind();
    } else {
      //绑定失败
    }
  } else if (undefined != jsondata.failure) {
    //islogin = false; //TODO
    console.log("登录失败,用户名或者密码错误");
  } else if (undefined != jsondata.success) {
    //发起新的流
    newSocket();
  } else if (undefined != jsondata.iq) {
    if (undefined != jsondata.iq.bind) {
      //获取session会话
      setSession();
    } else {
      console.log("登录成功!");
      //islogin = true; //TODO
      setOnline();
     //链接成功回调函数
     OnConnectionCallback();
    }
  } else {
  }
}

//设置在线状态
function setOnline(){
  var hhjyim = HHJYIM.prototype;
  var temp = hhjyim.$pres().c("priority").t("1");
  //转化为xml
  uni.sendSocketMessage({ data: temp.tree().toString() })
}

//设置Session
function setSession(){
  var temp = {
    "iq": {
      "-xmlns": "jabber:client",
      "-id": connectionID,
      "-type": "set",
      "session": { "-xmlns": HHJYIM.prototype.NS.SESSION }
    }
  };
  var steam = HHJYIM.prototype.JsonToXML(temp);
  uni.sendSocketMessage({ data: steam })
}

//再次握手
function newSocket(){
  var hhjyim = HHJYIM.prototype;
  var fromUser = username + XMPPDOMAINSUFFIX 
  var open = hhjyim.$open({
    "xmlns": HHJYIM.prototype.NS.CLIENT,
    "to": XMPPDOMAIN,
    "version": "1.0",
    "from": fromUser,
    "xml:lang": HHJYIM.prototype.NS.XMLLANG
  });
  uni.sendSocketMessage({ data: open.tree().toString() });
}

//状态更改事件
function _changeConnectStatus (status, condition) {
  for (var k in Strophe._connectionPlugins) {
    var plugin = this[k];
    if (plugin.statusChanged) {
      try {
        plugin.statusChanged(status, condition);
      } catch (err) {
        Strophe.error("" + k + " plugin caused an exception " +
          "changing status: " + err);
      }
    }
  }
  if (this.connect_callback) {
    try {
      this.connect_callback(status, condition);
    } catch (err) {
      Strophe.error("User connection callback caused an " +
        "exception: " + err);
    }
  }
}

// bind操作
function sockeBind(){
  var temp = {
    "iq": {
      "-id": connectionID,
      "-type": "set",
      "bind": {
        "-xmlns": HHJYIM.prototype.NS.BIND,
        "resource": "MiNiProgram"
      }
    }
  };
  //转化为xml
  var steam = HHJYIM.prototype.JsonToXML(temp);
  uni.sendSocketMessage({ data: steam })
}
//auth 登录验证
function socketAuth(authentication){
  //字符串格式是:jid+password,以\0作为分隔符
  var temp = username + XMPPDOMAINSUFFIX + "\0" + password;
  //Base64编码
  var token = btoa(temp);
  var message = {
    "auth": {
      "-xmlns": HHJYIM.prototype.NS.SASL,
      "-mechanism": authentication,
      "#text": token
    }
  };
  uni.sendSocketMessage({
    data: HHJYIM.prototype.JsonToXML(message)
  })
}

//自定义监听事件匹配方法
function customListerMatch(messageJson,handler){
  var nsMatch, i;
  nsMatch = false;
  if (!handler.Name){
    return false;
  }
  //循环对应的消息内容匹配对应监听事件
  if (!handler.NS){
    nsMatch = true;
  }else{
    for (let key in messageJson){
      if (key == handler.NS){
        nsMatch = true;
      }
    }
    if (messageJson[handler.Name]){
      nsMatch = nsMatch || messageJson[handler.Name]._xmlns == handler.NS;
    }
  }
  if (nsMatch &&
    (!handler.Name || HHJYIM.prototype.isTagEqual(messageJson, handler.Name)) &&
    (!handler.Type || messageJson[handler.Name]._type== handler.Type) &&
    (!handler.ID || messageJson[handler.Name]._id == handler.ID) &&
    (!handler.From || messageJson[handler.Name]._from == handler.From) &&
    (!handler.IsHasNode || messageJson[handler.Name].hasOwnProperty(handler.IsHasNode))
    ) {
    return true;
  }
  return false;
}

AppIM.HHJYIM = HHJYIM;
AppIM.HHJYIMConnection = HHJYIMConnection;

module.exports = AppIM;

 

 

以上有不懂的,或者需要指导调用的请联系我
uniapp 链接openfire

你的支持是给我最大的动力

uniapp 链接openfire

本文地址:https://blog.csdn.net/affordlove/article/details/107167668