// Variablen
let ConnectionCounter = 3;
let DebugOut = false;
var Url1 = 'http://mobile.bahn.de/bin/query.exe/dox?S=Lindau&Z=Friedrichshafen&timeSel=depart&start=1&journeyOptions=1';
var Url2 = 'http://mobile.bahn.de/bin/query.exe/dox?S=Friedrichshafen&Z=Lindau&timeSel=depart&start=1&journeyOptions=1';

function HoleBahn(ConnectionUrl, ConnectionName){
        request(ConnectionUrl, function (err, state, body){
            if (body) {
                //log('Request - alles ok');
                // log(body);
                if (DebugOut == true) { log(body); };
                let iConnectionCounter = ConnectionCounter - 1;
                let RgxBahnVerbindung = /\<script type\=\"text\/javascript\"\>var verbindung \= (.*?)\sdigitalData\.verbindung\.push\(verbindung\)\;\s<\/script\>/g;
                let CurrConn = RgxBahnVerbindung.exec(body);
                let iCounter = 0;
                while (CurrConn != null) {
                    if (iCounter <= iConnectionCounter)
                    {
                        let sCurrConn = String(CurrConn[1]);
                        if (DebugOut == true) { log(sCurrConn); };
                        let sBhfAbfahrt = sCurrConn.match(/bhfUtf8\[verbindung\.start\.name\] \= \"(.*?)\"\;/)[1];
                        let sBhfAnkunft = sCurrConn.match(/bhfUtf8\[verbindung\.ziel\.name\] \= \"(.*?)\"\;/)[1];
                        let tAbfahrt = sCurrConn.match(/verbindung\.abfahrt \= \"(.*?)\"\;/)[1].split("T")[1];
                        let tAnkunft = sCurrConn.match(/verbindung\.ankunft \= \"(.*?)\"\;/)[1].split("T")[1];
                        let tDauer = sCurrConn.match(/verbindung\.reisedauer \= \"(.*?)\"\;/)[1];
                        let sInfo = sCurrConn.match(/verbindung\.info \= \"(.*?)\"\;/)[1];
                        if (sInfo == "keine") {
                            sInfo = "";
                        }
                        let tAbfahrtDelay = "";
                        let tAnkunftDelay = "";
                        let bLate = false;
                        let bAusfall = false;
                        let bOnTime = false;
                        if (sInfo.match(/^Versp.tung$/)) {
                            sInfo = "Versp&auml;tung"
                            bLate = true;
                        } else if (sInfo.match(/Ausfall/)) {
                            sInfo = "Ausfall"
                            bAusfall = true;
                        }
                        // Verspaetung
                        let RgxBahnLate = /\<span class\=\"delay.*?\">(\d{2}:\d{2})\<\/span\>/g;
                        let CurrConLate = RgxBahnLate.exec(sCurrConn);
                        let iCounterLate = 0;
                        while (CurrConLate != null) {
                            if (iCounterLate == 0) {
                                if (CurrConLate[1] != tAbfahrt) {
                                    tAbfahrtDelay = CurrConLate[1];
                                    bLate = true;
                                } else {
                                    bOnTime = true;
                                };
                            } else {
                                if (CurrConLate[1] != tAnkunft) {
                                    tAnkunftDelay = CurrConLate[1];
                                    bLate = true;
                                } else {
                                    bOnTime = true;
                                }
                            }
                            CurrConLate = RgxBahnLate.exec(sCurrConn);
                            iCounterLate++;
                        }
                        if (DebugOut) { 
                            //log('CurrCon: ' + sCurrConn);
                            log ('BhfAbfahrt: ' + sBhfAbfahrt);
                            log ('BhfAnkunft: ' + sBhfAnkunft);
                            log ('Abfahrt: ' + tAbfahrt);
                            log ('AbfahrtDelay: ' + tAbfahrtDelay);
                            log ('Ankunft: ' + tAnkunft);
                            log ('AnkunftDelay: ' + tAnkunftDelay);
                            log ('Verspaetung: ' + bLate);
                            log ('Ausfall: ' + bAusfall);
                            log ('Info: ' + sInfo);
                        };
                        createState('bahn.' + ConnectionName + '.BhfAbfahrt', "");
                        setState('bahn.' + ConnectionName + '.BhfAbfahrt', sBhfAbfahrt, true);
                        createState('bahn.' + ConnectionName + '.BhfAnkunft', "");
                        setState('bahn.' + ConnectionName + '.BhfAnkunft', sBhfAnkunft, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Abfahrt', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Abfahrt', tAbfahrt, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.AbfahrtDelay', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.AbfahrtDelay', tAbfahrtDelay, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Ankunft', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Ankunft', tAnkunft, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.AnkunftDelay', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.AnkunftDelay', tAnkunftDelay, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Dauer', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Dauer', tDauer, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Verspaetung', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Verspaetung', bLate, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Ausfall', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Ausfall', bAusfall, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Puenktlich', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Puenktlich', bOnTime, true);
                        createState('bahn.' + ConnectionName + '.' + iCounter + '.Info', "");
                        setState('bahn.' + ConnectionName + '.' + iCounter + '.Info', sInfo, true);
                    }
                    CurrConn = RgxBahnVerbindung.exec(body);
                    iCounter++;
                }
                // Update HTML
                let sHTML = ""
                sHTML = '<table><tr><th align="left" colspan="3">' + getState('bahn.' + ConnectionName + '.BhfAbfahrt').val + ' - ' + getState('bahn.' + ConnectionName + '.BhfAnkunft').val + '</th></tr>'
                for (var i = 0; i <= iConnectionCounter; i++) {
                    let bDelay = getState('bahn.' + ConnectionName + '.' + i + '.Verspaetung').val;
                    let bAusfall = getState('bahn.' + ConnectionName + '.' + i + '.Ausfall').val;
                    let bOnTime = getState('bahn.' + ConnectionName + '.' + i + '.Puenktlich').val;
                    let sConnInfo = getState('bahn.' + ConnectionName + '.' + i + '.Info').val;
                    sHTML = sHTML + '<tr><td>'
                    if (bDelay == true) {
                        let sAbfahrtDelay = getState('bahn.' + ConnectionName + '.' + i + '.AbfahrtDelay').val;
                        if (sAbfahrtDelay != "") {
                            sHTML = sHTML + '<font color="red">' + sAbfahrtDelay + '</font><br/><small>(' + getState('bahn.' + ConnectionName + '.' + i + '.Abfahrt').val + ')</small>';
                        } else {
                            sHTML = sHTML + '<font color="red">' + getState('bahn.' + ConnectionName + '.' + i + '.Abfahrt').val + '</font>';
                        };
                        sHTML = sHTML + '</td><td>';
                        let sAnkunftDelay = getState('bahn.' + ConnectionName + '.' + i + '.AnkunftDelay').val;
                        if (sAnkunftDelay != "") {
                            sHTML = sHTML + '<font color="red">' + sAnkunftDelay + '</font><br/><small>(' + getState('bahn.' + ConnectionName + '.' + i + '.Ankunft').val + ')</small>';
                        } else {
                            sHTML = sHTML + '<font color="red">' + getState('bahn.' + ConnectionName + '.' + i + '.Ankunft').val + '</font>';
                        };
                        sHTML = sHTML + '</td><td>';
                    } else if (bAusfall == true) {
                        sHTML = sHTML + '<font color="red"><s>' + getState('bahn.' + ConnectionName + '.' + i + '.Abfahrt').val + '</s></font>';
                        sHTML = sHTML + '</td><td>';
                        sHTML = sHTML + '<font color="red"><s>' + getState('bahn.' + ConnectionName + '.' + i + '.Ankunft').val + '</s></font>';
                        sHTML = sHTML + '</td><td>';
                    } else if (bOnTime == true) {
                        sHTML = sHTML + '<font color="green">' + getState('bahn.' + ConnectionName + '.' + i + '.Abfahrt').val + '</font></td><td><font color="green">' + getState('bahn.' + ConnectionName + '.' + i + '.Ankunft').val + '</font></td><td>';
                    } else if (sConnInfo != "") {
                        sHTML = sHTML + '<font color="yellow">' + getState('bahn.' + ConnectionName + '.' + i + '.Abfahrt').val + '</font></td><td><font color="yellow">' + getState('bahn.' + ConnectionName + '.' + i + '.Ankunft').val + '</font></td><td>';
                    } else {
                        sHTML = sHTML + getState('bahn.' + ConnectionName + '.' + i + '.Abfahrt').val + '</td><td>' + getState('bahn.' + ConnectionName + '.' + i + '.Ankunft').val + '</td><td>';
                    };
                    sHTML = sHTML + getState('bahn.' + ConnectionName + '.' + i + '.Dauer').val + '</td></tr>';
                }
                sHTML = sHTML + "</table>";
                if (DebugOut == true) { log(sHTML); };
                createState('bahn.' + ConnectionName + '.HTML', "");
                setState('bahn.' + ConnectionName + '.HTML', sHTML, true);
            } else {
                log('Request meldet Fehler: ' + err, 'error');  
            }
 
        });
}
 
schedule("*/3 * * * *" , function(){ 
    HoleBahn(Url1, 'LiFr');
    HoleBahn(Url1, 'FrLi');
});