+1
-4
| { | ||
| "name": "nodeqim", | ||
| "version": "0.0.8", | ||
| "version": "0.1.0", | ||
| "description": "qcloud im for nodejs", | ||
| "main": "qim/qim.js", | ||
| "files": [ | ||
| "/qim" | ||
| ], | ||
| "author": "xkazer", | ||
@@ -10,0 +7,0 @@ "license": "ISC", |
+44
-0
@@ -271,2 +271,46 @@ 'use strict'; | ||
| }, | ||
| sendC2CTextMessage: function(userId, text) { | ||
| this._info("sendC2CTextMessage->text: "+text+"/"+userId); | ||
| return new Promise((resolve, reject)=>{ | ||
| if (!text || text.length==0){ | ||
| reject({ErrorCode: -1, ErrorInfo: "发送消息不能为空"}); | ||
| this._error("sendC2CTextMessage->fail with empty"); | ||
| } | ||
| var session = new im.Session(im.SESSION_TYPE.C2C, userId, userId, "", Math.round(new Date().getTime() / 1000)); | ||
| var msg = new im.Msg(session, true, -1, -1, -1, this._user_id, 0, ""); | ||
| var textObj = new im.Msg.Elem.Text(text); | ||
| msg.addText(textObj); | ||
| im.sendMsg(msg, (rsp) => { | ||
| if (rsp.ErrorCode == 0){ | ||
| this._info("sendC2CTextMessage->completed"); | ||
| resolve(rsp); | ||
| }else{ | ||
| this._error("sendC2CTextMessage->fail: "+rsp) | ||
| reject(rsp); | ||
| } | ||
| }); | ||
| }) | ||
| }, | ||
| sendC2CCustomMessage: function(userId, data, ext, callback=null) { | ||
| this._info("sendC2CCustomMessage->text: "+text+"/"+userId); | ||
| return new Promise((resolve, reject)=>{ | ||
| if (!data || data.length==0){ | ||
| this._error("sendC2CCustomMessage->fail with empty"); | ||
| reject({ErrorCode: -1, ErrorInfo: "发送消息不能为空"}); | ||
| } | ||
| var session = new im.Session(im.SESSION_TYPE.C2C, userId, userId, "", Math.round(new Date().getTime() / 1000)); | ||
| var msg = new im.Msg(session, true, -1, -1, -1, this._user_id, 0, ""); | ||
| var customObj = new im.Msg.Elem.Custom(data, "", ext); | ||
| msg.addCustom(customObj); | ||
| im.sendMsg(msg, (rsp) => { | ||
| if (rsp.ErrorCode == 0){ | ||
| this._info("sendC2CCustomMessage->completed"); | ||
| resolve(rsp); | ||
| }else{ | ||
| this._error("sendC2CCustomMessage->fail: "+rsp) | ||
| reject(rsp); | ||
| } | ||
| }); | ||
| }) | ||
| }, | ||
| /** 监听回调 */ | ||
@@ -273,0 +317,0 @@ on: function(event, listener){ |
313865
0.61%7101
0.62%