Geamtanzahl Vouchers:"+respv.data.length+"
"));}
if (writeFile) setState(dpPrefix + "WLANUnifi.Wifi_Vouchers", "Geamtanzahl Vouchers:"+respv.data.length+"
"));
if (writeFile) {setState(dpPrefix + "WLANUnifi.Wifi_Vouchers_Anzahl", respv.data.length);
mylog(listCode +" -- " +list)
setState(dpPrefix + "WLANUnifi.Wifi_Vouchers_List", list ); // für VIS anzeige - löschen
setState(dpPrefix + "WLANUnifi.Wifi_Vouchers_CodeList", listCode ); } // für VIS anzeige - löschen
//mylog("BIN RAUS AUS workvouchers");
}
//-----------------------------------------GET--Health---------------------------------------------------------------
async function getHealth() {
if (health) {
mylog("BIN IN gethealth");
return new Promise(async (resolve, reject) => {
dlog("nur mal so");
if(!loggedIn) await login().catch((e) => reject(e));
resph = await request.get({
url: unifi_controller + "/api/s/"+siteName+"/stat/health",
headers: { Cookie: cookies.join("; ") }
}).catch((e) => { log("getStatus reject " + e); /*reject(e)*/ return testerrh=true; });
if (!testerrh) {
dlog("got response " + JSON.stringify(resph));
dlog(typeof resph);
mylog("--------------------- " + resph);
resolve("done");
} else {log("reject weil resph ist 00"); reject();}
mylog("bin raus a GET health");
});
}}
//-----------------------------------------WORK--HEALTH---------------------------------------------------------------
function workHealth() {
mylog("BIN IN workhealth");
dlog("got response " + JSON.stringify(resph));
dlog(typeof resph);
mylog("--------------------- " + resph);
resph=resph.replace(/-r/g, "_r")
resph = JSON.parse(resph);
mylog(resph.data[0].rx_bytes_r);
setState(dpPrefix + "WLANUnifi.Health.WLAN.Status",resph.data[0].status );
setState(dpPrefix + "WLANUnifi.Health.WLAN.Users",resph.data[0].num_user);
setState(dpPrefix + "WLANUnifi.Health.WLAN.Guests",resph.data[0].num_guest );
setState(dpPrefix + "WLANUnifi.Health.WLAN.TXBytes",resph.data[0].tx_bytes_r );
setState(dpPrefix + "WLANUnifi.Health.WLAN.RXBytes",resph.data[0].rx_bytes_r );
setState(dpPrefix + "WLANUnifi.Health.WLAN.Adopted",resph.data[0].num_adopted );
setState(dpPrefix + "WLANUnifi.Health.WLAN.Disabled",resph.data[0].num_disabled );
setState(dpPrefix + "WLANUnifi.Health.WLAN.Disconnected",resph.data[0].num_disconnected );
// if (apInfo) healthListe = apHead;
healthListe = "";
healthListeTable="";
//healthListe = apHead + apTable +"| Health-Daten: | |
"
healthListeTable = "| Status | "+resph.data[0].status+
" |
| Users | "+resph.data[0].num_user +
" |
| Gäste | " +resph.data[0].num_guest +
" |
| TxBytes | "+resph.data[0].tx_bytes_r +
" |
| RxBytes | "+resph.data[0].rx_bytes_r+
" |
| Disabled | "+resph.data[0].num_disabled+
" |
| Adopted | "+resph.data[0].num_adopted+
" |
| Disconnected | "+resph.data[0].num_disconnected+
" |
"
healthListe = apHead + apTable +"| Health-Daten: | |
" + healthListeTable;
healthListeTable="| Health Daten: | |
" + healthListeTable;
mylog(healthListe);
mylog("bin raus a work health");
}
//-----------------------------------------SET WIFIS - WIFI EIN-AUSSCHALTEN----------------------------------------------
//Wifi an-/ausschalten
//enabled: true = anschalten; false = ausschalten
//wifi: wifi object aus der konstanten wifis
async function setWifi(enabled, wifi) {
if (!clientPause) {
return new Promise(async (resolve, reject) => {
dlog("setWifi: start set Wifi_haupt");
if (!loggedIn) { dlog("need to login"); await login().catch((e) => reject(e)); }
dlog("setWifi: now setting Wifi_haupt");
let resp = request.post({
url: unifi_controller + "/api/s/"+siteName+"/upd/wlanconf/" + wifi.id,
body: JSON.stringify({ enabled }),
headers: { 'Content-Type': 'application/json', Cookie: cookies.join("; ") }
}).catch((e) => { dlog("setWifi: rejected: " + e); /*reject(e)*/ return testerrws=true; });
dlog("setWifi: got response")
if (resp != null) {
dlog("setWifi: Wifi wurde erfolgreich " + (enabled ? "eingeschaltet" : "ausgeschaltet"));
dlog(resp);
// getclient() Pause für umschalten
if (firstTime>=wifiLength) {
// if (true) {
clientPause = true;
clientPauseVal=parseInt((new Date().getTime()));
}
setState(dpPrefix + "WLANUnifi." + wifi.name, enabled, enabled);
resolve();
} else {
dlog("setWifi: rejetced")
dlog("resp: " + JSON.stringify(resp));
reject("msg: " + JSON.parse(resp.body).meta.msg);}
});
} else { log("WLAN wird gerade umgeschaltet"); }
}
//-----------------------------------------CREATE VOUCHERS----------------------------------------------
async function createVoucher (mybody) {
mylog(JSON.stringify( mybody ));
return new Promise(async (resolve, reject) => {
log("createVoucher in aktion");
if (!loggedIn) { mylog("need to login"); await login().catch((e) => reject(e)); }
mylog("do it !");
let respcv = request.post({
url: unifi_controller + "/api/s/"+siteName+"/cmd/hotspot/" ,
body: JSON.stringify( mybody ),
// body: mybody,
headers: { 'Content-Type': 'application/json', Cookie: cookies.join("; ") }
}).catch((e) => { log("setWifi: rejected: " + e); /*reject(e)*/ return testerrcv=true; });
dlog("setWifi: got response")
dlog("------------: "+respcv);
dlog("resp: " + JSON.stringify(respcv));
});
}
//-----------------------------------------DELETE VOUCHERS----------------------------------------------
async function deleteVoucher (mybody) {
mylog(JSON.stringify( mybody ));
return new Promise(async (resolve, reject) => {
dlog("deleteVoucher in aktion");
if (!loggedIn) { mylog("need to login"); await login().catch((e) => reject(e)); }
mylog("do it !");
let respdv = request.post({
url: unifi_controller + "/api/s/"+siteName+"/cmd/hotspot/" ,
body: JSON.stringify( mybody ),
// body: mybody,
headers: { 'Content-Type': 'application/json', Cookie: cookies.join("; ") }
}).catch((e) => { log("setWifi: rejected: " + e); /*reject(e)*/ return testerrdv=true; });
dlog("setWifi: got response")
//log("------------: "+respdv.toString());
dlog("------------: "+respdv);
dlog("resp: " + JSON.stringify(respdv));
dlog("resp: " + JSON.parse(respdv));
});
}
//-----------------------------------------GET--APs---------------------------------------------------------------
async function getAp(id) {
if (apInfo) {
mylog("BIN IN getap mit Wert" + id);
return new Promise(async (resolve, reject) => {
dlog("nur mal so");
if(!loggedIn) await login().catch((e) => reject(e));
respa = await request.get({
url: unifi_controller + "/api/s/"+siteName+"/stat/device/"+id,
headers: { Cookie: cookies.join("; ") }
}).catch((e) => { dlog("getStatus reject " + e); /*reject(e)*/ return testerrap=true; });
if (!testerrv) {
dlog("got response " + JSON.stringify(respv));
dlog(typeof respa);
dlog("--------------------- " + respa);
resolve("done");
} else {log("reject weil respv ist 00"); reject();}
mylog("bin raus a GETap");
});
}}
//const a111 ="| | |
"
//-----------------------------------------WORK--APs---------------------------------------------------------------
function workAP (aliasAPname) {
mylog("BIN IN work ap");
dlog("got response " + JSON.stringify(respa));
dlog(typeof respa);
dlog("--------------------- " + respa);
respa = JSON.parse(respa);
mylog(respa.data[0].model)
setState(dpPrefix + "WLANUnifi.APInfo."+ aliasAPname+".Model",respa.data[0].model );
setState(dpPrefix + "WLANUnifi.APInfo."+ aliasAPname+".IP_Adresse",respa.data[0].connect_request_ip );
setState(dpPrefix + "WLANUnifi.APInfo."+ aliasAPname+".Satisfaction",respa.data[0].satisfaction );
setState(dpPrefix + "WLANUnifi.APInfo."+ aliasAPname+".Adopted",respa.data[0].adopted );
setState(dpPrefix + "WLANUnifi.APInfo."+ aliasAPname+".ToController",respa.data[0].inform_ip );
var apListeHelfer= /*apListeTable +*/ "
| Model | "+respa.data[0].model+
" |
| IP-Adresse | "+respa.data[0].connect_request_ip +
" |
| Satisfaction | " +respa.data[0].satisfaction +
" |
| Adopted | "+respa.data[0].adopted +
" |
| ToController | "+respa.data[0].inform_ip+" |
";
apListeTable= apListeTable + apListeHelfer ;
apListe = apListe + "| | |
"+"| AP-Daten: | "+aliasAPname+" |
"+apListeHelfer;
mylog (apListe)
mylog("bin raus a work ap");
}
//-----------------------------------------------SCHALTER------------------------------------------------
on({id: wifiDPs, ack: false, change: "ne"}, function (obj) {
var value = obj.state.val;
var dp2 = obj.name
setWifi(value, wifis[dp2]);
dlog(wifis[dp2])
if (firstTime {
if (firstTime<3){ //für clientPAuse
for (let suche in wifis) {
if ( getState(dpPrefix + "WLANUnifi."+suche).val !== null ) {firstTime=15;mylog("datanpunkt vorhanden")
} else {mylog("datanpunkt inicht geschrieben");}}}
scriptCounter++
mylog("-----------------------SCRIPTCOUNTER------------------ ist : " + scriptCounter );
mylog(loggedIn.toString())
await login().catch(alarm1)
// log("------------------------------------------------Werte Alarme: " + testerrl + " - " + testerrc+ " - " +testerrv + " - "+testerrs + " - "+testerrh);
if (loggedIn) {
if (alarmCounter > 5) {log("Unifi Sript funktioniert wieder - Verbindung wieder hergestellt","error");}
if (alarmCounter > 0) {alarmCounter=0; }
await getClients().catch(alarm3) ;
if (vouchers) await getVouchers().catch(alarm4);
if (health) await getHealth().catch(alarm7);
if ( !testerrl && !testerrc && !testerrv && !testerrs && !testerrh ) {
workVouchers();
if (!clientPause) workClients();
if ( scriptCounter==3) {
mylog("health und APs")
if (health) {workHealth();}
if (apInfo) { mylog(" APs");
apListe = "";
apListeTable="";
for(let ap_name in apName) {
await getAp(ap_name).catch(alarm8);
apListeTable=apListeTable+"| | |
| AP-Daten: | "+apName[ap_name].aname+" |
";
workAP(apName[ap_name].aname); }
fs.writeFileSync(datei3,healthListe + apListe + tableAus+""); //schreibe Health mitAPs
setState(dpPrefix + "WLANUnifi.Wifi_Info", ""+healthListeTable +apListeTable + tableAus);
} else { fs.writeFileSync(datei3,apHead+healthListe+tableAus+""); //Schreibe Health ohne APs
setState(dpPrefix + "WLANUnifi.Wifi_Info", ""+ healthListeTable + tableAus);
}
scriptCounter=0}
}
for(let wifi_name in wifis) {
if ( firstTime == 3 && getState(dpPrefix + "WLANUnifi."+wifi_name).val !== null ) firstTime = 3;
await getStatus(wifis[wifi_name]).catch(alarm6)}
} else { alarmCounter++;
if (alarmCounter > 5) {log("Unifi Sript hat 'Problem mit Einloggen - Prüfe Unifi Controller, Port, Einlog-Daten","error");
if (!testerrv) log("evtl. Vouchers deaktivieren","warn");}}
if (clientPause) {
var interim=parseInt(new Date().getTime());
log("Unifi Script ist in Pause wegen WLAN Umschalteung- bis: " + formatDate(clientPauseVal + clientPauseConst, "SS:mm:ss"),"warn");
if (interim - clientPauseVal > clientPauseConst) {clientPause=false;log("Unifi Script hat Pause beendet" );} }
testerrc=false;
testerrv=false;
testerrs=false;
testerrl=false;
testerrc=false;
testerrh=false;
testerrap=false;
}, abfragezyklus); // wird oben definiert
function alarm12() {log("Im Unifi Script stimmte etwas nicht - Alarm13 - Delete Voucher","warn"); loggedIn=false; testerrdv=false;cookies=[];}
function alarm12() {log("Im Unifi Script stimmte etwas nicht - Alarm12 - Create Voucher","warn"); loggedIn=false; testerrcv=false;cookies=[];}
function alarm11() {log("Im Unifi Script stimmte etwas nicht - Alarm11 - WLAN schalten","warn"); loggedIn=false; testerrws=false;cookies=[];}
function alarm8() {log("Im Unifi Script stimmte etwas nicht - Alarm8 - APs","warn"); loggedIn=false; testerrap=false;cookies=[];}
function alarm7() {log("Im Unifi Script stimmte etwas nicht - Alarm7 - Health","warn"); loggedIn=false; testerrh=false;cookies=[];}
function alarm6() {log("Im Unifi Script stimmte etwas nicht - Alarm6 - Statusabfrage","warn"); loggedIn=false; testerrs=false;cookies=[];}
function alarm5() {log("Im Unifi Script stimmte etwas nicht - Alarm5 - logout","warn"); loggedIn=false; testerrl=false;cookies=[];}
function alarm4() {log("Im Unifi Script stimmte etwas nicht - Alarm4 - getVouchers-Login","warn"); loggedIn=false; testerrv=false;cookies=[];}
function alarm3() {log("Im Unifi Script stimmte etwas nicht - Alarm3 - getClient-Login","warn"); loggedIn=false; testerrc=false;cookies=[];}
function alarm1() {log("Im Unifi Script stimmte etwas nicht - Alarm1 - Login fehlgeschlagen","warn"); loggedIn=false; ;alarmSwitch=true }
// Beispiel für
//setWifi(true, wifis.WLAN_DragonGuest);