/**
 * PiHole 2.0
 * Schaltet PiHole (ab Version 6) für eine vorgegebene Zeit (120 min) aus und dann wieder ein.
 * Das Ein- und Aussachalten erfolgt über den State '0_userdata.0.PiHole', 
 * dem über den iot-Adapter ein Alexa-Befehl zugewiesen werden kann - 
 * z. B. "Alexa, schalt den Werbeblocker an/aus"
 * Die Ausschaltzeit kann über den State '0_userdata.0.PiHoleOffTime' eingestellt werden.
 * 
 * log:     PH006
 */

const fetch = require('node-fetch');


/**
 * Einstellungen                                                //Defaults
 */

// IP-Adresse des PiHole Servers ['IP']
// hier eigene PiHole-Adresse eintragen
const piHoleIP='192.168.1.199';                                 //'192.168.1.199'

// API-Token [string]
// hier eigenes API-Token eintragen - wird generiert unter
// "PiHole - Settings - Web interface / API - Advanced Settings - Configure app password"
const apiToken='XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX';

// Nutzung mit Alexa-Adapter [true|false]
const useAlexa=true;					        //true

// Verzögerung der Echoansage bis History-State geschrieben ist
const EchoDelay=500;                                            //500


/**
 * States
 */

createState('0_userdata.0.PiHole', {name: 'PiHole', type: 'boolean'});
createState('0_userdata.0.PiHoleOffTime', 120, {name: 'Ausschaltzeit', type: 'number', unit: 'min'});


/**
 * Main
 */

on({id: Trigger+'PiHole', change: 'any'}, (obj) => {
    if(obj.state.val) {
        disablePiHole(0, piHoleIP, apiToken); 
		if(useAlexa) {
			setTimeout(() => {
				setState(getEcho()+'.Commands.speak', 'Der Werbeblocker ist wieder aktiviert.');
			}, EchoDelay);
		}
    } else {
        disablePiHole(getState(Verwaltung+'PiHoleOffTime').val, piHoleIP, apiToken); 
		if(useAlexa) {
			setTimeout(() => {
				setState(getEcho()+'.Commands.speak', 'Der Werbeblocker wird für '+getState(Verwaltung+'PiHoleOffTime').val+' Minuten abgeschaltet.');
			}, EchoDelay);
		}
    }
});


/**
 * Funktionen
 */

/**
 * Generiert eine Session ID
 * @param   {string}            ip  IP-Adresse des PiHole-Servers
 * @param   {string}            password    API-Token
 * @returns {Promise<string>}   SID
 */
async function getSessionID(ip, password) {
    const url=`http://${ip}/api/auth`;
    const data={password};

    try {
        const response=await fetch(url, {
            method: 'POST',
            headers: {'Content-Type': 'application/json'},
            body: JSON.stringify(data)
        });

        if(response.ok) {
            const result=await response.json();
            return result.session.sid; // Session ID zurückgeben
        } else {
            console.error('PH005 Fehler beim Abrufen der Session ID: '+await response.json());
            return null;
        }
    } catch(error) {
        console.error('PH006 Netzwerkfehler: ', error);
        return null;
    }
}


/**
 * Schaltet PiHole für duration min ab, bei duration == 0 wieder an.
 * @param   {number}    duration    Dauer [min]
 * @param   {string}    ip          IP-Adresse des PiHole-Servers
 * @param   {string}    password    API-Token
 */
async function disablePiHole(duration, ip, password) {
    const sid=await getSessionID(ip, password);
    if (!sid) {
        console.error(' PH004 Authentifizierung fehlgeschlagen');
        return;
    }

    const url=`http://${ip}/api/dns/blocking`;
    const headers={
        'Content-Type': 'application/json',
        'X-FTL-SID': sid
    };
    const data={blocking: duration != 0 ? false: true, timer: duration*60};

    try {
        const response=await fetch(url, {
            method: 'POST',
            headers,
            body: JSON.stringify(data)
        });

        if(response.ok) {
            console.log(`PH001 Pi-hole wurde für ${duration} Minuten deaktiviert.`);
        } else {
            console.error('PH002 Fehler beim Deaktivieren von Pi-hole');
        }
    } catch(error) {
        console.error('PH003 Netzwerkfehler:', error);
    }
}


/**
 * Gibt die ID des Echos EchoName zurück
 * Bei mehreren Übereinstimmungen wird nur die erste berücksichtigt
 * @param   {string}    EchoName        Name des Echos - wenn leer, dann letzter Echo
 * @returns {string}    ID des Echos; undefined, wenn nicht gefunden
 */
function getEcho(EchoName)
{
    if(EchoName === undefined) {
        EchoName=getState('alexa2.0.History.name'/*Echo Device name*/).val;
    }
    let EchoID;
    let IDs=(getIdByName(EchoName, true));
    if(IDs == undefined) {
        log('getEcho: '+EchoName+' not registered!');
        return;
    }
    for (let i=0; i < IDs.length; i++) {
        if (IDs[i].search('Echo-Devices') != -1) {
            EchoID=IDs[i];
            i=IDs.length;       // Abbruch nach erstem gefundenen Echo
        }
    }
    return EchoID;
}


// ___|\/|
//  |

/**
 * PiHole 2.0
 * Schaltet PiHole (ab Version 6) für eine vorgegebene Zeit (120 min) aus und dann wieder ein.
 * Das Ein- und Aussachalten erfolgt über den State '0_userdata.0.PiHole', 
 * dem über den iot-Adapter ein Alexa-Befehl zugewiesen werden kann - 
 * z. B. "Alexa, schalt den Werbeblocker an/aus"
 * Die Ausschaltzeit kann über den State '0_userdata.0.PiHoleOffTime' eingestellt werden.
 * 
 * log:     PH006
 */

const fetch = require('node-fetch');


/**
 * Einstellungen                                                //Defaults
 */

// IP-Adresse des PiHole Servers ['IP']
// hier eigene PiHole-Adresse eintragen
const piHoleIP='192.168.1.199';                                 //'192.168.1.199'

// API-Token [string]
// hier eigenes API-Token eintragen - wird generiert unter
// "PiHole - Settings - Web interface / API - Advanced Settings - Configure app password"
const apiToken='XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX';

// Nutzung mit Alexa-Adapter [true|false]
const useAlexa=true;					        //true

// Verzögerung der Echoansage bis History-State geschrieben ist
const EchoDelay=500;                                            //500


/**
 * States
 */

createState('0_userdata.0.PiHole', {name: 'PiHole', type: 'boolean'});
createState('0_userdata.0.PiHoleOffTime', 120, {name: 'Ausschaltzeit', type: 'number', unit: 'min'});


/**
 * Main
 */

on({id: Trigger+'PiHole', change: 'any'}, (obj) => {
    if(obj.state.val) {
        disablePiHole(0, piHoleIP, apiToken); 
		if(useAlexa) {
			setTimeout(() => {
				setState(getEcho()+'.Commands.speak', 'Der Werbeblocker ist wieder aktiviert.');
			}, EchoDelay);
		}
    } else {
        disablePiHole(getState(Verwaltung+'PiHoleOffTime').val, piHoleIP, apiToken); 
		if(useAlexa) {
			setTimeout(() => {
				setState(getEcho()+'.Commands.speak', 'Der Werbeblocker wird für '+getState(Verwaltung+'PiHoleOffTime').val+' Minuten abgeschaltet.');
			}, EchoDelay);
		}
    }
});


/**
 * Funktionen
 */

/**
 * Generiert eine Session ID
 * @param   {string}            ip  IP-Adresse des PiHole-Servers
 * @param   {string}            password    API-Token
 * @returns {Promise<string>}   SID
 */
async function getSessionID(ip, password) {
    const url=`http://${ip}/api/auth`;
    const data={password};

    try {
        const response=await fetch(url, {
            method: 'POST',
            headers: {'Content-Type': 'application/json'},
            body: JSON.stringify(data)
        });

        if(response.ok) {
            const result=await response.json();
            return result.session.sid; // Session ID zurückgeben
        } else {
            console.error('PH005 Fehler beim Abrufen der Session ID: '+await response.json());
            return null;
        }
    } catch(error) {
        console.error('PH006 Netzwerkfehler: ', error);
        return null;
    }
}


/**
 * Schaltet PiHole für duration min ab, bei duration == 0 wieder an.
 * @param   {number}    duration    Dauer [min]
 * @param   {string}    ip          IP-Adresse des PiHole-Servers
 * @param   {string}    password    API-Token
 */
async function disablePiHole(duration, ip, password) {
    const sid=await getSessionID(ip, password);
    if (!sid) {
        console.error(' PH004 Authentifizierung fehlgeschlagen');
        return;
    }

    const url=`http://${ip}/api/dns/blocking`;
    const headers={
        'Content-Type': 'application/json',
        'X-FTL-SID': sid
    };
    const data={blocking: duration != 0 ? false: true, timer: duration*60};

    try {
        const response=await fetch(url, {
            method: 'POST',
            headers,
            body: JSON.stringify(data)
        });

        if(response.ok) {
            console.log(`PH001 Pi-hole wurde für ${duration} Minuten deaktiviert.`);
        } else {
            console.error('PH002 Fehler beim Deaktivieren von Pi-hole');
        }
    } catch(error) {
        console.error('PH003 Netzwerkfehler:', error);
    }
}


/**
 * Gibt die ID des Echos EchoName zurück
 * Bei mehreren Übereinstimmungen wird nur die erste berücksichtigt
 * @param   {string}    EchoName        Name des Echos - wenn leer, dann letzter Echo
 * @returns {string}    ID des Echos; undefined, wenn nicht gefunden
 */
function getEcho(EchoName)
{
    if(EchoName === undefined) {
        EchoName=getState('alexa2.0.History.name'/*Echo Device name*/).val;
    }
    let EchoID;
    let IDs=(getIdByName(EchoName, true));
    if(IDs == undefined) {
        log('getEcho: '+EchoName+' not registered!');
        return;
    }
    for (let i=0; i < IDs.length; i++) {
        if (IDs[i].search('Echo-Devices') != -1) {
            EchoID=IDs[i];
            i=IDs.length;       // Abbruch nach erstem gefundenen Echo
        }
    }
    return EchoID;
}


// ___|\/|
//  |