UCOMmandIt
/
uci-base
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

0.1.22 bump because of change in uci-socket

master
David Kebler 2019-05-01 15:37:52 -07:00
parent 903d907201
commit c1d35f7c0f
3 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "@uci/base", "name": "@uci/base",
"version": "0.1.21", "version": "0.1.22",
"description": "Multi type and transport JSON packet communication base class. Used in UCI extended classes", "description": "Multi type and transport JSON packet communication base class. Used in UCI extended classes",
"main": "src/base", "main": "src/base",
"scripts": { "scripts": {
@ -39,7 +39,7 @@
"@uci-utils/bind-funcs": "^0.2.3", "@uci-utils/bind-funcs": "^0.2.3",
"@uci-utils/logger": "^0.0.14", "@uci-utils/logger": "^0.0.14",
"@uci/mqtt": "^0.1.11", "@uci/mqtt": "^0.1.11",
"@uci/socket": "^0.2.13", "@uci/socket": "^0.2.14",
"@uci/websocket": "^0.3.7", "@uci/websocket": "^0.3.7",
"await-to-js": "^2.1.1", "await-to-js": "^2.1.1",
"p-settle": "^3.1.0" "p-settle": "^3.1.0"

8
src/base.js
View File

@ -232,6 +232,7 @@ class Base extends EventEmitter {
} }
async push(packet) { async push(packet) {
// TODO set like send to accept a name
let broadcast = [] let broadcast = []
for (let name of Object.keys(this._socket)) { for (let name of Object.keys(this._socket)) {
if (this._socket[name].type === 's') { if (this._socket[name].type === 's') {
@ -248,6 +249,9 @@ class Base extends EventEmitter {
) )
} }
// TODO make push version of all this sends
// TODO accept alt transport string i.e. t or TCP
async sendTransport(packet, transport) { async sendTransport(packet, transport) {
let sends = [] let sends = []
for (let name of Object.keys(this._socket)) { for (let name of Object.keys(this._socket)) {
@ -269,10 +273,14 @@ class Base extends EventEmitter {
async sendTCP(packet) { async sendTCP(packet) {
return this.sendTransport(packet, 't') return this.sendTransport(packet, 't')
} }
// TODO change this to PIPE
async sendIPC(packet) { async sendIPC(packet) {
return this.sendTransport(packet, 'n') return this.sendTransport(packet, 'n')
} }
// TODO add sendMQTT, sendWS
socketsListen(event,fn) { socketsListen(event,fn) {
this._eventListen('s',event,fn) this._eventListen('s',event,fn)

1
src/processing.js
View File

@ -70,6 +70,7 @@ const defaultCmds ={
packet.info = 'default socket echo' packet.info = 'default socket echo'
return packet return packet
}, },
// add sedning along an ack to any consumers and or pushing to other sockets on this device
ack: async packet => { ack: async packet => {
packet.cmd = 'reply' packet.cmd = 'reply'
packet.ack = true packet.ack = true