Newer
Older
import Scenari from "../scenari.js";
import Antifurto from "../antifurto.js";
import { mqtt_tree, sendMessage } from "./mqtthat.js";
static isConnected = false;
/**
* gets the luci of the user from the server
* @returns {*} all the lights of the user
*/
static getLuci = () => { console.log('ciao');
const topic = "to/all";
const message = "{request:status}";
sendMessage(topic, message);
static sendLuciWeb = luci => { console.log('ciao');
Luci.luciFromMqtt(luci);
// static callbackGetAllLuci = null;
static getAllLuci = () => { console.log('ciao');
const topic = `rpc/${mqtt_tree}luci`;
const message = "{request:description}";
sendMessage(topic, message);
static sendDataLuciWeb = luci => { console.log('ciao');
Luci.luciFromMqtt(luci);
}
static luceMakeNewLuci = null;
static callbackMakeNewLuci = null;
/**
* adds a new luce to the server
* @param {luceTemplate} luce the luce to add to the server
* @returns {*} null if the light was added
*/
static makeNewLuci = luce => { console.log('ciao');
const luceSent = {nome: luce.luogo, stato: luce.stato, input: luce["sensore-in"], output: luce["luce-out"]};
const topic = `to/${mqtt_tree}luci/new`;
const message = JSON.stringify(luceSent);
sendMessage(topic, message);
static sendWebNewLuci = luce => { console.log('ciao');
const luceReceived = {luogo: luce.nome, stato: luce.stato, "sensore-in": luce.input, "luce-out": luce.output, id : oldLuce.id};
if (oldLuce != luce) {
console.log('le luci non corrispondono', { oldLuce, luceReceived });
Luci.showCreatedLight(luceReceived);
static sensoreMakeNewSensore = null;
/**
* invia il sensore al microservizio per aggiornarlo (YET TO BE USED)
* @param {*} sensore l'oggetto sensore che dev'essere inviato al microservizio
*/
static makeNewSensoreLuci = sensore => { console.log('ciao');
if (sensore == null || sensore.nome == null)
throw new Error("sensore must be defined");
Api.sensoreMakeNewSensore = sensore;
const newSensore = {sensM: sensore.nome};
const topic = `to/${mqtt_tree}luci/sensore`;
const message = JSON.stringify(newSensore);
sendMessage(topic, message);
}
static sendWebNewSensore = sensore => { console.log('ciao');
const oldSensore = Api.sensoreMakeNewSensore;
if(oldSensore != null && oldSensore.nome !== sensore.sensM) {
console.log('i sensori non corrispondono', { oldSensore, sensore });
}
Luci.showCreatedSensore(sensore);//TODO
static callbackLuciStatoToBeStatic = null;
static fixedCallbackLuciStato = null;
/**
* changes the status of a luce on the server
* @param {luceTemplate} luce the luce to change the status of
* @returns {*} null if the light's status was changed
*/
static setLuciStato = (luce, toggle, callback) => { console.log('ciao');
throw new Error("toggle must be defined");
throw new Error("callback must be defined");
if(Api.callbackLuciStatoToBeStatic == null)
Api.callbackLuciStatoToBeStatic = callback;
const topic = `from/${mqtt_tree}gpio/${luce["sensore-in"].toUpperCase()}`;
const message = `{"event":1}`;
// Api.outForToggleLuciStato = luce;
static sendLuciStatoWeb = response => { console.log('ciao');
//response == {"output":outVal,stato};
const toggle = Api.toggleForLuciStato;
Api.toggleForLuciStato = null;
Api.callbackLuciStatoToBeStatic(toggle);
} else {
Api.fixedCallbackLuciStato(response);
}
/*static outForToggleLuciStato = null;
static triggerLuce = (outVal, stato) => {
if (Api.outForToggleLuciStato == null)
return;
// send to luci to figure out what is the connection
if (Api.outForToggleLuciStato["luce-out"] === outVal && Api.outForToggleLuciStato.stato === stato) {
Api.sendLuciStatoWeb();
Api.outForToggleLuciStato = null;
} else {
Api.sendLuciStatoWeb({"sensore-out":outVal,stato});
}
/**
* gets the scenari of the user from the server
* @returns {*} all the scenarios of the user
*/
static getScenari = () => { console.log('ciao');
const topic = `rpc/${mqtt_tree}scenari`;
const message = "{request:status}";
sendMessage(topic, message);
static sendScenariWeb = scenari => { console.log('ciao');
Scenari.mostraScenariServer(scenari);
static setAntifurtoINbtnFromScenari = newINbtn => { console.log('ciao');
console.log(newINbtn)
if(newINbtn == null || newINbtn?.nome == null)
const btn = newINbtn.nome;
if(btn == null)
return;
const topic = `to/${mqtt_tree}scenari/sensoreAntifurto`;
const message = `{"attiva-scenari":"${btn}"}`;
sendMessage(topic, message);
static scenarioSetScenarioStatus = null;
static activatingSetScenarioStatus = null;
/**
* activates or deactivates a scenario on the server
* @param {scenarioTemplate} scenario the scenario to activate or deactivate
* @returns {*} null if the scenario was activated or deactivated
*/
static setScenarioStatus = (scenario, activating) => { console.log('ciao');
throw new Error("scenario must be defined");
throw new Error("activating must be defined");
Api.scenarioSetScenarioStatus = scenario;
Api.activatingSetScenarioStatus = activating;
const topic = `to/${mqtt_tree}scenari`;
const message = `{"evento":${scenario.stato === false ? '0' : '1'},"nome":"${scenario.nome}"}`;
sendMessage(topic, message);
static sendWebNewScenarioStatus = scenarioNome => { console.log('ciao');
const scenario = Api.scenarioSetScenarioStatus;
const activating = Api.activatingSetScenarioStatus;
Api.scenarioSetScenarioStatus = null;
Api.activatingSetScenarioStatus = null;
if(scenario == null || activating == null)
return;
// FIXME forse dovrei controllare scenarioNome
console.log(scenario)
if (scenarioNome.startsWith(scenario.nome))
Scenari.showScenarioAfterToggling(scenario, activating,true);
static sendWebScenarioAttivoAutomatico = scenarioNome => { console.log('ciao');
Scenari.showScenarioAfterToggling(scenarioNome, true,true);
}
static overlayScenariAntifurto = stato => {
Scenari.correctlySetAntifurto(stato,false,true);
}
static recordingRecordScenario = null;
static learnINBtnRecordScenario = null;
/**
* starts/stop the recording of a scenario
* @param {Boolean} recording true to start the recording, false to stop it
* @returns {*} null if the recording was started or stopped
*/
Alfredo Chissotti
committed
static recordScenario = (recording, learnINBtn) => { console.log('ciao');
throw new Error("recording must be defined");
throw new Error("learnINBtn must be defined");
Api.recordingRecordScenario = recording;//true se voglio registrare
Api.learnINBtnRecordScenario = learnINBtn;
const INBtn = learnINBtn.nome;
const topic = `from/${mqtt_tree}gpio/${INBtn.toUpperCase()}`;
const message = `{"event":1}`;
sendMessage(topic, message);
}
static retriesRecordScenario = 0;
static sendWebScenarioAutoma = stato => { console.log('ciao');
if(isNaN(stato))
return;
const recording = Api.recordingRecordScenario;
// const statoAspettato = recording ? 1 : 0;
if (recording != null && stato !== recording && Api.retriesRecordScenario < 3) {
Api.retriesRecordScenario++;
const INBtn = Api.learnINBtnRecordScenario.nome;
const topic = `from/${mqtt_tree}gpio/${INBtn.toUpperCase()}`;
const message = `{"event":1}`;
sendMessage(topic, message);
}
Api.recordingRecordScenario = null;
Api.learnINBtnRecordScenario = null;
Api.retriesRecordScenario = 0;
Alfredo Chissotti
committed
Scenari.apiCallbackRecordScenario(recording);
/**
* tells the server to save the currently recorded scenario
* @returns {*} the scenario if it was saved
*/
static saveScenario = nome => { console.log('ciao');
const topic = `to/${mqtt_tree}scenari/salva`;
const message = JSON.stringify({nome});
sendMessage(topic, message);
static sendWebSavedScenario = scenario => { console.log('ciao');
Scenari.saveScenarioCallback(scenario);
// /api/scenari/conf
static sendScenariConfiguration = conf => { console.log('ciao');
const topic = `to/${mqtt_tree}scenari/conf`;
const message = JSON.stringify(conf);
sendMessage(topic, message);
}
static sendWebConfiguration = conf => { console.log('ciao');
Scenari.updateConfiguration(conf);
}
* gets everything about the antifurto (stato, allarme, attenzione (valore progress bar), soglia, sensori)
static getAntifurto = () => { console.log('ciao');
const topic = `rpc/${mqtt_tree}antifurto`;
const message = `{"request":"description"}`;
sendMessage(topic, message);
static sendWebGetAntifurto = antifurto => { console.log('ciao');
Antifurto.mostraAntifurtoServer(antifurto);
static payloadSetAntifurtoStatus = null;
* @param {Boolean} payload {previousStatus, fromScenari, fromServer}
static setAntifurtoStatus = payload => { console.log('ciao');
throw new Error("payload must be defined");
// Api.newStatusSetAntifurtoStatus = newStatus;
// Api.antifurtoINbtnSetAntifurtoStatus = antifurtoINbtn;
Api.payloadSetAntifurtoStatus = payload;
console.log(Antifurto.attivaAntifurtoINbtn)
const INBtn = Antifurto.attivaAntifurtoINbtn != null ? Antifurto.attivaAntifurtoINbtn.nome : Scenari.antifurtoINbtn.nome;
const topic = `from/${mqtt_tree}gpio/${INBtn.toUpperCase()}`;
const message = `{"event":1}`;
sendMessage(topic, message);
static retriesSetAntifurtoStatus = 0;
static sendWebSetAntifurtoStatus = stato => { console.log('ciao');
if(stato === NaN)
const newStatus = Antifurto?.status != null ? !Antifurto.status : !Scenari.antifurtoStatus;
const expectedStatus = newStatus ? 2 : 0;
console.log(Antifurto.attivaAntifurtoINbtn)
const nomeIN = Antifurto.attivaAntifurtoINbtn != null ? Antifurto.attivaAntifurtoINbtn.nome : Scenari.antifurtoINbtn.nome;
if (stato !== expectedStatus && Api.retriesSetAntifurtoStatus < 3) {
Api.retriesSetAntifurtoStatus++;
const topic = `from/${mqtt_tree}gpio/${nomeIN.toUpperCase()}`;
const message = `{"event":1}`;
sendMessage(topic, message);
}
const payload = Api.payloadSetAntifurtoStatus;
// Api.newStatusSetAntifurtoStatus = null;
// Api.antifurtoINbtnSetAntifurtoStatus = null;
Api.payloadSetAntifurtoStatus = null;
Api.retriesSetAntifurtoStatus = 0;
try{
Antifurto.showChangeAntifurtoStatus(payload?.previousStatus ? payload?.previousStatus : Antifurto.status, newStatus, payload?.fromScenari ? payload?.fromScenari : false, payload?.fromServer ? payload?.fromServer : true);
} catch (error) {
if(error.message !== "Antifurto.showChangeAntifurtoStatus is not a function")
throw error;
else Scenari.showChangeAntifurtoStatus(newStatus, payload?.fromServer ? payload?.fromServer : true);
}
static overlayAntifurtoAntifurto = stato => {
Antifurto.activate(stato,false,true);
}
static fixedCallbackStatoAllarme = null;
/**
* sets the status of the antifurto's alarm
* @param {Boolean} allarme the new status of the antifurto's alarm
* @returns {*} null if the status was changed
*/
static setAntifurtoAllarme = allarme => { console.log('ciao');
// const booleanAlarm = allarme == 'true';
if (allarme == null || Api.fixedCallbackStatoAllarme == null)
return;
Api.fixedCallbackStatoAllarme(allarme);
static fixedCallbackValoreAttenzione = null;
/**
* sets the status for the progress bar of the antifurto's alarm
* @param {Number} attenzione the new value of the antifurto's attention
static setAntifurtoAttenzione = attenzione => { console.log('ciao');
if (attenzione == null || isNaN(parseInt(attenzione)) || Api.fixedCallbackValoreAttenzione == null)
return;
Api.fixedCallbackValoreAttenzione(val);
static sogliaSetAntifurtoSoglia = null;
static fromServerSetAntifurtoSoglia = null;
static callbackSetAntifurtoSoglia = null;
/**
* sets the value of the antifurto's threshold
* @param {Number} soglia the user's value of the antifurto's threshold
* @returns {*} null if the value was changed
*/
static setAntifurtoSoglia = (soglia, fromServer) => { console.log('ciao');
if (soglia == null || isNaN(parseInt(soglia)))
throw new Error("soglia must be a set integer");
const val = parseInt(soglia);
if (fromServer == null)
throw new Error("fromServer must be defined");
Api.sogliaSetAntifurtoSoglia = val;
Api.fromServerSetAntifurtoSoglia = fromServer;
const topic = `to/${mqtt_tree}antifurto/soglia`;
const message = `{"soglia":${val}}`;
sendMessage(topic, message);
static sendWebSoglia = soglia => { console.log('ciao');
const expectedSoglia = Api.sogliaSetAntifurtoSoglia;
if (expectedSoglia !== soglia) {
console.log('soglie differenti', { expectedSoglia, soglia });
}
const fromServer = Api.fromServerSetAntifurtoSoglia;
Api.sogliaSetAntifurtoSoglia = null;
Api.fromServerSetAntifurtoSoglia = null;
Antifurto.showEditsSoglia(soglia, fromServer);
static testSensore = sensore => {//usato da sensori.js
const topic = `from/${mqtt_tree}gpio/${sensore.toUpperCase()}`;
const message = `{"event":1}`;
sendMessage(topic, message);
}