vxmppb
/
vxmppb
Archived
1
0
Fork 1
Code Issues 6 Pull Requests 1 Packages Projects 3 Releases 3 Wiki Activity

Adding Tuya for lights (Uses Tuya API) #6

Merged
stephen merged 2 commits from stephen/vxmppb:tuya into main 2022-01-27 20:33:29 -05:00
Conversation 0 Commits 2 Files Changed 3 +96 -56
3 changed files with 96 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
config.ini.dist
View File

@ -1,7 +1,6 @@
api_pass = api_pass =
api_url = api_url =
api_user = api_user =
app_port =
asterisk_callfrom = asterisk_callfrom =
asterisk_callto = asterisk_callto =
asterisk_callerID = asterisk_callerID =
@ -28,9 +27,10 @@ mqtt_password =
mqtt_server = mqtt_server =
mqtt_topic = mqtt_topic =
mqtt_user = mqtt_user =
rss_url = tuya_name =
tuya_status_url =
tuya_toggle_url =
user_jid = user_jid =
user_name = user_name =
vfc_url =
weather_api_key = weather_api_key =
weather_units = weather_units =

142
index.js
View File

@ -3,8 +3,6 @@ const ini = require('ini');
const mastodon = require('mastodon'); const mastodon = require('mastodon');
const mqtt = require('mqtt'); const mqtt = require('mqtt');
const request = require('request'); const request = require('request');
let Parser = require('rss-parser');
let parser = new Parser();
const xmpp = require('simple-xmpp'); const xmpp = require('simple-xmpp');
try { try {
@ -42,11 +40,11 @@ const mqtt_password = config.mqtt_password;
const mqtt_server = config.mqtt_server; const mqtt_server = config.mqtt_server;
const mqtt_topic = config.mqtt_topic; const mqtt_topic = config.mqtt_topic;
const mqtt_user = config.mqtt_user; const mqtt_user = config.mqtt_user;
const rpc_url = config.rpc_url; const tuya_name = config.tuya_name;
const rss_url = config.rss_url; const tuya_status_url = config.tuya_status_url;
const tuya_toggle_url = config.tuya_toggle_url;
const user_jid = config.user_jid; const user_jid = config.user_jid;
const user_name = config.user_name; const user_name = config.user_name;
const vfc_url = config.vfc_url;
const weather_api_key = config.weather_api_key; const weather_api_key = config.weather_api_key;
const weather_units = config.weather_units; const weather_units = config.weather_units;
@ -121,42 +119,93 @@ xmpp.on('chat', function(from, message) {
}); });
console.log('unlocks'); console.log('unlocks');
} }
// Tuya light control
else if (message === 'lights' || message === 'Lights') {
request(tuya_status_url,(error, res, body) => {
if (error) {
return console.log(error)
};
// Check VFC balance if (!error && res.statusCode == 200) {
else if (message === "vfc" || message === "Vfc") { if (res.body === "true"){
ami.action({ const stat = tuya_name + ": On";
'action':'originate', xmpp.send(from, stat);
'channel':'SIP/' + asterisk_callfrom, console.log(stat);
'context': asterisk_context, } else if (res.body === "false") {
'callerID' : asterisk_callerID, const stat = tuya_name + ": Off";
'exten' : asterisk_callto, xmpp.send(from, stat);
'priority' : '1', console.log(stat);
}); } else {
request(vfc_url, (error, res, body) => { xmpp.send(from, "Unknown reply. Please reply ping to reach an admin.");
if (error) { console.log("Tuya API: Unknown reply!");
return console.log(error)
};
if (!error && res.statusCode == 200) {
const balance = user_name + " has " + res.body + " VFC";
xmpp.send(from, balance);
console.log(balance);
} }
}); }
console.log('vfc'); if (!error && res.statusCode == 401) {
console.log('Invalid credentials');
xmpp.send(from, 'Invalid credentials');
}
if (!error && res.statusCode == 404) {
console.log('Record not found');
xmpp.send(from, 'Record not found');
}
if (!error && res.statusCode == 500) {
console.log('Server error.');
xmpp.send(from, 'Server error. Please ping admin');
}
});
console.log('lights status');
} }
else if (message === tuya_name + ' on') {
request(tuya_toggle_url + "?stat=true&devname=" + tuya_name,(error, res, body) => {
if (error) {
return console.log(error)
};
// Get latest RSS item from feed if (!error && res.statusCode == 200) {
else if (message === "rss" || message === "Rss") { const stat = tuya_name + " has been turned on";
(async () => { xmpp.send(from, stat);
let feed = await parser.parseURL(rss_url); console.log(stat);
// console.log(feed.title); }
feed.items.forEach(item => { if (!error && res.statusCode == 401) {
console.log(item.title + ':' + item.link) console.log('Invalid credentials');
xmpp.send(from, item.title) xmpp.send(from, 'Invalid credentials');
}); }
xmpp.send(from, 'See https://vanderwarker.social/@stephen for full entries.') if (!error && res.statusCode == 404) {
})(); console.log('Record not found');
xmpp.send(from, 'Record not found');
}
if (!error && res.statusCode == 500) {
console.log('Server error.');
xmpp.send(from, 'Server error. Please ping admin');
}
});
console.log('lights on');
}
else if (message === tuya_name + ' off') {
request(tuya_toggle_url + "?stat=false&devname=" + tuya_name,(error, res, body) => {
if (error) {
return console.log(error)
};
if (!error && res.statusCode == 200) {
const stat = tuya_name + " has been turned off";
xmpp.send(from, stat);
console.log(stat);
}
if (!error && res.statusCode == 401) {
console.log('Invalid credentials');
xmpp.send(from, 'Invalid credentials');
}
if (!error && res.statusCode == 404) {
console.log('Record not found');
xmpp.send(from, 'Record not found');
}
if (!error && res.statusCode == 500) {
console.log('Server error.');
xmpp.send(from, 'Server error. Please ping admin');
}
});
console.log('lights on');
} }
// Ping a user to let them know you would like to communitcate // Ping a user to let them know you would like to communitcate
@ -236,10 +285,11 @@ xmpp.on('chat', function(from, message) {
console.log(vcard) console.log(vcard)
}) })
} }
// If the user sends something we don't have logic for, send them info about the project // If the user sends something we don't have logic for, send them info about the project
else { xmpp.send(from, "This is an auto replying bot. Reply \"help\" for more info, or https://wiki.vanderwarker.family/doku.php?id=code:vxmppb:start"); else {
console.log('autoreply'); xmpp.send(from, "This is an auto replying bot. Reply \"help\" for more info, or https://wiki.vanderwarker.family/doku.php?id=code:vxmppb:start");
console.log('autoreply');
} }
}); });
@ -248,16 +298,8 @@ xmpp.on('error', function(err) {
console.error(err); console.error(err);
}); });
// EXTENDING XEPS (WIP) // Set XMPP status
/* xmpp.setPresence('chat', 'Asterisk,Mastodon, and MQTT. Oh my!');
xmpp.on('chatstate', function(from, state) {
console.log(state);
});
xmpp.on('buddy', function(jid, state, statusText, resource) {
console.log(state + statusText + resource);
});
*/
// Alas, we connect to XMPP! // Alas, we connect to XMPP!
xmpp.connect({ xmpp.connect({

2
package.json
View File

@ -8,7 +8,6 @@
"sms", "sms",
"autoreply", "autoreply",
"asterisk", "asterisk",
"rss",
"mqtt", "mqtt",
"gotify", "gotify",
"push notifications" "push notifications"
@ -26,7 +25,6 @@
"mastodon": "1.2.2", "mastodon": "1.2.2",
"mqtt": "4.2.6", "mqtt": "4.2.6",
"request": "2.88.0", "request": "2.88.0",
"rss-parser": "3.12.0",
"simple-xmpp": "2.3.1" "simple-xmpp": "2.3.1"
}, },
"bugs": { "bugs": {