vnclagoon/vnctalk-muc-rest
14
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: add error handling

Browse Source
This commit is contained in:
Stefan-Sanger
2023-02-23 12:40:17 +01:00
parent 2d83665571
commit 6a004fff4d
1 changed files with 39 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/routes/index.js
+39 -31
View File
@@ -35,7 +35,7 @@ async function doesMucExist(jid) {
query = "select prosody.value from prosody where prosody.host=$2 and prosody.user=$1 and prosody.key=$3";
dbpool.query(query, queryparams, async function (derr, dres) {
if (derr == null) {
// console.log("dres.rows: ", dres.rows);
console.log("doesMucExist dres.rows: ", dres.rows);
if (dres.rowCount > 0) {
resolve(1);
} else {
@@ -508,41 +508,49 @@ router.post('/creategroup', async function (req, res) {
} else {
if (connection.socket.writable) {
console.log("creating room...");
let cmd = 'muc:create("' + req.body.jid + '");';
let cmd = 'muc:create("' + req.body.jid.toLowerCase() + '");';
let response = await connection.send(cmd);
console.log(response);
console.log("setting subject to " + req.body.subject);
cmd = 'muc:room("' + req.body.jid + '"):set_subject("' + req.body.jid + '/' + req.body.owner + '", "' + req.body.subject + '");';
response = await connection.send(cmd);
console.log(response);
console.log("setting historylength");
cmd = 'muc:room("' + req.body.jid + '"):set_historylength(5);';
response = await connection.send(cmd);
console.log(response);
console.log("setting persistent");
cmd = 'muc:room("' + req.body.jid + '"):set_persistent(true);';
response = await connection.send(cmd);
console.log(response);
console.log("setting owner to " + req.body.owner);
cmd = 'muc:room("' + req.body.jid + '"):set_affiliation(true, "' + req.body.owner + '", "owner");';
response = await connection.send(cmd);
console.log(response);
if (req.body.members && req.body.members.length > 0) {
for (var i = 0; i < req.body.members.length; i++) {
console.log("adding member " + req.body.members[i]);
cmd = 'muc:room("' + req.body.jid + '"):set_affiliation(true, "' + req.body.members[i] + '", "member");';
if (response.indexOf("Result: MUC room (" + req.body.jid.toLowerCase()) > -1 ) {
// all good
console.log("setting subject to " + req.body.subject);
cmd = 'muc:room("' + req.body.jid + '"):set_subject("' + req.body.jid + '/' + req.body.owner + '", "' + req.body.subject + '");';
response = await connection.send(cmd);
console.log(response);
if (response.indexOf("Result: true") > -1) {
console.log("setting historylength");
cmd = 'muc:room("' + req.body.jid + '"):set_historylength(5);';
response = await connection.send(cmd);
console.log(response);
}
}
//muc:room("testingtelnetcreate1_meeting@conference.microlab.zimbra-vnc.de"):set_affiliation(true, "richard.watson@microlab.zimbra-vnc.de", "member");
res.json({status: "ok"});
console.log("setting persistent");
cmd = 'muc:room("' + req.body.jid + '"):set_persistent(true);';
response = await connection.send(cmd);
console.log(response);
console.log("setting owner to " + req.body.owner);
cmd = 'muc:room("' + req.body.jid + '"):set_affiliation(true, "' + req.body.owner + '", "owner");';
response = await connection.send(cmd);
console.log(response);
if (req.body.members && req.body.members.length > 0) {
for (var i = 0; i < req.body.members.length; i++) {
console.log("adding member " + req.body.members[i]);
cmd = 'muc:room("' + req.body.jid + '"):set_affiliation(true, "' + req.body.members[i] + '", "member");';
response = await connection.send(cmd);
console.log(response);
}
}
//muc:room("testingtelnetcreate1_meeting@conference.microlab.zimbra-vnc.de"):set_affiliation(true, "richard.watson@microlab.zimbra-vnc.de", "member");
res.json({status: "ok"});
} else {
res.status(500).json({error: response});
}
} else {
res.status(500).json({error: response});
}
} else {
console.log("connection not writable");
res.status(500).json({message: "connection not writable"});