clientiot
v1.2.1
Published
use im to aws-oit
Downloads
5
Readme
clientiot
Use for AWS IOT JavaScript SDK
This iotClient module can be used for developing node.js client code for IBM IoT Foundation
Install
npm install --save @hxim/clientiotUpdate log
2018.09.12
取消S3附件回调上传进度消息2018.09.05
调整iot订阅者函数
新增私聊与群聊订阅，取消iot直接订阅
修复接口返回json不统一问题2018.09.04
修正消息发送接口问题，消息发送demo对象调整 2018.09.03
增加S3上传与下载文件，请注意配置文件Usage to HTTP API
Choton demo, the default POST request（调用demo，默认为POST请求）If the interface address and the certificate change, please refer to lib/config.js to modify the corresponding parameters.（如接口地址与证书发生变化，请参考lib/config.js修改相应参数）var clientiot = require("clientiot");
var co = require('co');
//消息发送
var data = {
fromId: 1001,
fromType: "user",
msgType: "text",
targetId: 1002,
targetType: "single",
msgContent: {
arn: "arn",
durationTime: 7,
extras: "extras",
fileSize: 2,
format: "format",
height: 5,
mediaCrc32: "mediaCrc32",
mediaId: "mediaId",
text: "你好",
width: 5
}
}
co(function* () {
/*登陆*/
console.log("===========获取token=============");
var retvalue = yield clientiot.login.getToken();
console.log(retvalue);
var login_obj = JSON.parse(retvalue);
/*提交用户名、密码、token*/
console.log("===========提交用户名、密码、token=============");
var login_obj = yield clientiot.login.login("Hx_test1", "Hx_test1", login_obj.data);//用户名、密码、token
console.log(login_obj);
var userObj = JSON.parse(login_obj);
/*私聊订阅*/
console.log("===========私聊订阅=============");
clientiot.globalinfo.regPrivateThingName(userObj.data.employee_id, function (topic, res) {
console.log(topic);
console.log(res);
});
/*轮询扫码登录是否成功*/
console.log("===========轮询扫码登录是否成功=============");
var retvalue = yield clientiot.login.loginStatus(login_obj.data); //token
console.log(retvalue);
/*上传文件到S3*/
console.log("===========上传文件到S3=============");
clientiot.awss3.UploadFile(keyName, localPath, function (res) {
console.log(res);
});
/*从S3下载文件*/
console.log("===========从S3下载文件=============");
clientiot.awss3.DownloadFile(keyName, localPath, function (res) {
console.log(res);
});
/*消息发送(私有)*/
console.log("===========消息发送（私有）=============");
var retvalue = yield clientiot.messages.messagesPrivate(JSON.stringify(data));
console.log(retvalue);
/*获取指定消息记录（私有）*/
console.log("===========获取指定消息记录（私有）=============");
var retvalue = yield clientiot.messages.getMessagesPrivate("1111","2222","33333","44444");
console.log(retvalue);
/*获取最新一条树的消息（私有）*/
console.log("===========获取最新一条树的消息（私有）=============");
var retvalue = yield clientiot.messages.getMessagesPrivateLatest("1111", "2222");
console.log(retvalue);
/*获取最近指定条数的消息（私有）*/
console.log("===========获取最近指定条数的消息（私有）=============");
var retvalue = yield clientiot.messages.getMessagesPrivateRecently("1111", "2222",10);
console.log(retvalue);
/*获取未读条数（私有）*/
console.log("===========获取未读条数（私有）=============");
var retvalue = yield clientiot.messages.getMessagesPrivateUnRead("1111", "2222", 10);
console.log(retvalue);
/*获取指定消息的已读状态（私有）*/
console.log("===========获取指定消息的已读状态（私有）=============");
var retvalue = yield clientiot.messages.getMessagesPrivateMsgIdStatus("1111", "2222", "3333");
console.log(retvalue);
//消息发送(公有)
console.log("===========消息发送（公有）=============");
var retvalue = yield clientiot.messages.messagesPublic(JSON.stringify(data));
console.log(retvalue);
/*获取指定消息记录（公有）*/
console.log("===========获取指定消息记录（公有）=============");
var retvalue = yield clientiot.messages.getMessagesPublic("1111", "2222", "33333", "44444");
console.log(retvalue);
/*获取最新一条树的消息（公有）*/
console.log("===========获取最新一条树的消息（公有）=============");
var retvalue = yield clientiot.messages.getMessagesPublicLatest("1111", "2222");
console.log(retvalue);
/*获取最近指定条数的消息（公有）*/
console.log("===========获取最近指定条数的消息（公有）=============");
var retvalue = yield clientiot.messages.getMessagesPublicRecently("1111", "2222", 10);
console.log(retvalue);
/*获取未读条数（公有）*/
console.log("===========获取未读条数（公有）=============");
var retvalue = yield clientiot.messages.getMessagesPublicUnRead("1111", "2222", 10);
console.log(retvalue);
/*获取指定消息的已读状态（公有）*/
console.log("===========获取指定消息的已读状态（公有）=============");
var retvalue = yield clientiot.messages.getMessagesPublicMsgIdStatus("1111", "2222", "3333");
console.log(retvalue);
/*查找敏感词*/
console.log("===========查找敏感词=============");
var retvalue = yield clientiot.sensitiveWord.getSensitiveWord("你最帅");
console.log(retvalue);
/*修改敏感词*/
console.log("===========修改敏感词=============");
var retvalue = yield clientiot.sensitiveWord.updateSensitiveWord("你最帅","你超级帅");
console.log(retvalue);
/*删除敏感词*/
console.log("===========删除敏感词=============");
var retvalue = yield clientiot.sensitiveWord.deleteSensitiveWord("你超级帅");
console.log(retvalue);
/*增加敏感词*/
console.log("===========增加敏感词=============");
var retvalue = yield clientiot.sensitiveWord.addSensitiveWord("你最帅");
console.log(retvalue);
/*获取所有员工*/
console.log("===========获取所有员工=============");
var retvalue = yield clientiot.employees.getEmployees();
console.log(retvalue);
/*通过部门ID获取员工列表*/
console.log("===========通过部门ID获取员工列表=============");
var retvalue = yield clientiot.employees.getEmployeesFindByDeptId("111111");
console.log(retvalue);
/*通过工牌号获得指定员工信息*/
console.log("===========通过工牌号获得指定员工信息=============");
var retvalue = yield clientiot.employees.getEmployeesEid("103046");
console.log(retvalue);
/*获取指定用户的所有群组*/
console.log("===========获取指定用户的所有群组=============");
var retvalue = yield clientiot.employees.getEmployeesEidGroups(userObj.data.employee_id);
console.log(retvalue);
/*群聊订阅，请在获取当前用户所有群组之后循环订阅主题*/
console.log("===========群聊订阅=============");
clientiot.globalinfo.regPrivateThingName(userObj.data.employee_id, function (topic, res) {
console.log(topic);
console.log(res);
});
/*指定用户是否屏蔽指定群的消息*/
console.log("===========指定用户是否屏蔽指定群的消息=============");
var retvalue = yield clientiot.employees.getEmployeesEidGroupsGroupShield("111111", "22222", true);
console.log(retvalue);
/*通过工牌号和截止日期获得指定员工消息列表*/
console.log("===========通过工牌号和截止日期获得指定员工消息列表=============");
var retvalue = yield clientiot.employees.getEmployeesEidMessageList("111111", "22222");
console.log(retvalue);
/*免打扰设置*/
console.log("===========免打扰设置=============");
var retvalue = yield clientiot.employees.getEmployeesEidNodistrub("111111", "single","3333333");
console.log(retvalue);
/*获取可用的群组列表*/
console.log("===========获取可用的群组列表=============");
var retvalue = yield clientiot.groups.getGroups();
console.log(retvalue);
/*获取可用的群组列表*/
console.log("===========新增群组=============");
var data = {
"admit_mode": "1", //入群验证(0>需要管理员同意,1>不需要管理员同意,2>不允许加入) ,
"group_name": "群组名称 ",
"group_range": "群组范围",
"group_theme": "群组主题",
"group_type": "conference",//群组类别:organization>按组织架构 flight>按航班沟通 conference>按会议 project>按项目 lives>图文直播 custom>自定义
"invite_mode": "1", //邀请方式(0>群主邀请;1>群员可邀请)
"members": [
0
],
"owner_eid": 0//群主的工牌号
}
var retvalue = yield clientiot.groups.addGroups(data);
console.log(retvalue);
/*按群组类型获取群组列表*/
console.log("===========按群组类型获取群组列表=============");
var retvalue = yield clientiot.groups.getGroupsByType("1111111");
console.log(retvalue);
/*获取指定员工加入的所有群组*/
console.log("===========获取指定员工加入的所有群组=============");
var retvalue = yield clientiot.groups.getGroupsByEid("1111111");
console.log(retvalue);
/*删除群组*/
console.log("===========删除群组=============");
var retvalue = yield clientiot.groups.deleteGroups("1111111");
console.log(retvalue);
/*获取群组信息*/
console.log("===========获取群组信息=============");
var retvalue = yield clientiot.groups.getGroupsByGid("1111111");
console.log(retvalue);
/*修改群组信息*/
console.log("===========修改群组信息=============");
var data = {
"description": "群组描述",
"inviteMode": 0,//邀请方式(0>群主邀请;1>群员可邀请)
"admit_mode": 1,//入群验证(0>需要管理员同意,1>不需要管理员同意,2>不允许加入)
"managerCount": 1,//管理员数量
"proclamation": "群公告"
}
var retvalue = yield clientiot.groups.updateGroupsByGid("1111111", data);
console.log(retvalue);
/*获取指定群组的所有成员*/
console.log("===========获取指定群组的所有成员=============");
var retvalue = yield clientiot.groups.getGroupsGidMembers("1111111");
console.log(retvalue);
/*更新群组成员*/
console.log("===========更新群组成员=============");
var retvalue = yield clientiot.groups.updateGroupsGidMembers("1111111","2222222222");
console.log(retvalue);
/*移交群主*/
console.log("===========移交群主=============");
var retvalue = yield clientiot.groups.groupsGidOwner("1111111", "2222222222","333333");
console.log(retvalue);
});
/*控制台程序自动关闭限制*/
setInterval(() => console.log('Long wait'), 10000);####统一返回json数据demo（Unit returns to the JSON data demo）
{"errorMessage":"","errorCode":"","success":true,"data":{}}####示例
{
"errorMessage": "",
"errorCode": "",
"success": true,
"data": {
"curtime": "1532582226",
"issmarter": "1",
"xmusicnum": "4",
"picurl": [],
"playlist": [{
"xqusic_mid": "002NkERn2LNVI4 ",
"xqusic_id": "105030812",
"xctype": "3",
"xexpire_time": "0",
"xdesc": " ",
"xsong_name": "Faded ",
"xsinger_name": "Alan Walker ",
"xsong_url": "http://stream8.qqmusic.qq.com/117030812.wma ",
"xsong_size": "1834194",
"xsong_playtime": "212",
"xsong_diskname": "Faded ",
"xsong_dissmid": ["002Nt51E0q8Zoo ", "002Nt51E0q8Zoo "],
"xsong_dissid": "1211728",
"xis_word": "0",
"xcopy_right": "0",
"xsinger_id": "944940",
"xsinger_mid": "0020PeOh4ZaCw1 "
}, {
"xqusic_mid": "000aB5HG4dioBi ",
"xqusic_id": "4831024",
"xctype": "3",
"xexpire_time": "0",
"xdesc": " ",
"xsong_name": "海誓山盟亦会分开 ",
"xsinger_name": "本兮 ",
"xsong_url": "http://stream6.qqmusic.qq.com/16831024.wma ",
"xsong_size": "2496570",
"xsong_playtime": "289",
"xsong_diskname": "无底线 ",
"xsong_dissmid": ["004LrhoF44bRf2 ", "004LrhoF44bRf2 "],
"xsong_dissid": "193826",
"xis_word": "0",
"xcopy_right": "0",
"xsinger_id": "4545",
"xsinger_mid": "003LaMHm42u7qS "
}, {
"xqusic_mid": "0019kz9c1QBWNA ",
"xqusic_id": "2633764432",
"xctype": "1",
"xexpire_time": "0",
"xdesc": " ",
"xsinger_name": "文艺范电台 ",
"xsong_name": "文艺范电台 ",
"xsong_url": "http://img.wenyifan.net/20131221/5/1387627094890.mp3 ",
"xsong_size": "0",
"xsong_playtime": "0",
"xsong_diskname": "0",
"xsong_dissmid": "0047airw212ppN ",
"xsong_dissid": "0",
"xis_word": "-999",
"xcopy_right": "-999",
"xsinger_id": "-999"
}, {
"xqusic_mid": "001rVHgt15aRmM ",
"xqusic_id": "699379606",
"xctype": "5",
"xexpire_time": "0",
"xdesc": " ",
"xsinger_name": "soso ",
"xsong_name": "8446666.mp3 ",
"xsong_url": "http://streamrdt.music.qq.com/8138.83a798500d5cb2b63f442ec3ee215a8d/1081067841532582226/8138.83a798500d.html ",
"xsong_size": "0",
"xsong_playtime": "0",
"xsong_diskname": "0",
"xsong_dissmid": "0047airw212ppN ",
"xsong_dissid": "0",
"xis_word": "-999",
"xcopy_right": "-999",
"xsinger_id": "-999"
}],
"systemtime": "1532582226"
}
}接口地址：http://10.152.21.175:5000/ui/#/
Usage to aws iot（aws iot MQTT Demo）
/*AWS IOT订阅者*/
console.log("===========AWS IOT订阅者=============");
clientiot.awsIotSubscriber("im_mnt_foss",function (topic, res) {
console.log(topic);
console.log(res);
});
/*AWS IOT发布者*/
console.log("===========AWS IOT发布者发布消息=============");
clientiot.awsIotPublisher("im_mnt_foss","我是发布者",function (topic, res) {
console.log(res);
});
//发布者接收订阅者的消息
console.log("===========AWS IOT发布者接收订阅者的消息=============");
clientiot.awsIotPublisher.getMessages(function (topic, res) {
console.log(topic);
console.log(res);
});