1.0.9 • Published 6 years ago

clientiotprotcol v1.0.9

Weekly downloads
-
License
ISC
Repository
-
Last release
6 years ago

clientiotprotcol

Use for AWS IOT JavaScript SDK

Install

npm install --save clientiotprotcol

Usage to HTTP API

Choton demo, the default POST request（调用demo，默认为POST请求）
var clientiot = require("clientiotprotcol");
var co = require('co');


//消息发送
 var data = {
    fromId: "111",
    fromType: "user",
    msgType: "text",
    targetId: "2222",
    targetType: "single",
    msgContent: {
        arn: "",
        durationTime: "",
        extras: "",
        fileSize: "",
        format: "",
        height: "",
        mediaCrc32: "",
        mediaId: "",
        text: "",
        width: ""
    }
}
 



co(function* () {
    /*消息发送(私有)*/
    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.deleteSensitiveWord("你最帅");
    console.log(retvalue);

    /*查找敏感词*/
    console.log("===========查找敏感词=============");
    var retvalue = yield clientiot.sensitiveWord.getSensitiveWord("你最帅");
    console.log(retvalue);

    /*增加敏感词*/
    console.log("===========增加敏感词=============");
    var retvalue = yield clientiot.sensitiveWord.addSensitiveWord("你最帅");
    console.log(retvalue);

    /*修改敏感词*/
    console.log("===========修改敏感词=============");
    var retvalue = yield clientiot.sensitiveWord.updateSensitiveWord("你最帅","你超级帅");
    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("111111");
    console.log(retvalue);

    /*获取指定用户的所有群组*/
    console.log("===========获取指定用户的所有群组=============");
    var retvalue = yield clientiot.employees.getEmployeesEidGroups("111111");
    console.log(retvalue);

    /*指定用户是否屏蔽指定群的消息*/
    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.getGroups("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.updateGroups("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(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);
});
clientiot
@everything-registry/sub-chunk-1338@zalastax/nolb-clie
1.0.9

6 years ago

1.0.8

6 years ago

1.0.7

6 years ago

1.0.6

6 years ago

1.0.5

6 years ago

1.0.4

6 years ago

1.0.3

6 years ago

1.0.2

6 years ago

1.0.1

6 years ago