ENPHASE-T1.plugin.txt

/////////             <version>1.2.1</version>
/////////                     ENPHASE-T1                        /////////////
/////////  Plugin to extract Enphase Solar data for Toon  ///////////////
/////////                   By Oepi-Loepi                  /////////////

	function getSolarData(passWord,userName,sessionID,siteid,urlString,totalValue){
		var sessionID = apiKey
		if (debugOutput) console.log("*********SolarPanel Start getSolarData")
		//getEnphaseStep1(urlString,passWord,userName,sessionID, totalValue,siteid);
		parseEnpaseInfo(urlString,passWord,userName,sessionID, totalValue,siteid);
    }

/*
	function getEnphaseStep1(urlString,passWord,userName,sessionID, totalValue,siteid){
		var onetime = true
		if (debugOutput) console.log("*********SolarPanel Start getEnphaseStep1()")
		if (debugOutput) console.log("*********SolarPanel haal de enphase info op via tsc command")
		if (debugOutput) console.log("*********SolarPanel enphase info url " + urlString)
		
		var doc2 = new XMLHttpRequest();
		doc2.open("PUT", "file:///tmp/enphase_info.txt");
		doc2.send(urlString)

		var doc4 = new XMLHttpRequest();
		doc4.open("PUT", "file:///tmp/tsc.command");
		doc4.send("external-solarPanel");

		//wacht op een response vanuit het TSC script
		solarEnphaseDelay(8000, function() {
			if (onetime){
				onetime = false
				parseEnpaseInfo(urlString,passWord,userName,sessionID,totalValue,siteid)
			}
		})
	}
*/

function parseEnpaseInfo(urlString,passWord,userName,sessionID,totalValue,siteid){
    if (debugOutput) console.log("*********SolarPanel parsing Info data after TSC command")
    var http = new XMLHttpRequest()
    //var url = "file:///tmp/enphase_info_return.txt"
	var url = "http://" + urlString + "/info.xml"
    http.open("GET", url, true);
    http.onreadystatechange = function() {
        if (debugOutput) console.log("http.readyState: " +http.readyState)
        if (http.readyState === XMLHttpRequest.DONE) {
            if (debugOutput) console.log("http.status: " + http.status)
            if (http.status === 200 || http.status === 300  || http.status === 302) {
                try {
                    if (debugOutput) console.log("*********SolarPanel http.status: " + http.status)
                    if (debugOutput) console.log("*********SolarPanel http.responseText: " + http.responseText)
                    var envoyserial
                    var envoyfirmware
					
                    if (http.responseText.indexOf("<sn>")){
                       envoyserial= http.responseText.split("<sn>")[1].split("</sn>")[0]
                    }
                    if (http.responseText.indexOf("<software>")){
                       envoyfirmware= http.responseText.split("<software>")[1].split("</software>")[0].split(".")[0]
                    }
                    if (debugOutput) console.log("*********SolarPanel envoyserial: " + envoyserial)
                    if (debugOutput) console.log("*********SolarPanel envoyfirmware: " + envoyfirmware)

                    if (envoyfirmware === 'D7' & sessionID  === ''){
                        startLoginD7(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue)
                    }
					
					if (envoyfirmware === 'D8' & sessionID  === ''){
                        startLoginD8(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid)
                    }
					
					if (envoyfirmware === 'D8' & sessionID !== ''){
                        getD7data(urlString, sessionID,totalValue,"D8")
                    }

                    if (envoyfirmware === 'D7' & sessionID !== ''){
                        getD7data(urlString, sessionID,totalValue,"D7")
                    }

                    if (envoyfirmware === 'D5'){
                        getD5data(urlString,totalValue)
                    }

                }
                catch (e){
                    currentPower = 0
                    parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            } else {
                if (debugOutput) console.log("*********SolarPanel error: " + http.status)
                parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
            }
        }
    }
    http.send();
}


function startLoginD7(passWord,userName,urlString,envoyserial,envoyfirmware, totalValue){
    if (debugOutput) console.log("*********SolarPanel Start startLoginD7")
    var http = new XMLHttpRequest()
    var url = "https://enlighten.enphaseenergy.com/login/login.json?&user[password]=" + passWord + "&user[email]=" + userName
    if (debugOutput) console.log("*********SolarPanel url: " + url)
    http.open("POST", url, true);
    http.onreadystatechange = function() { // Call a function when the state changes.
        if (debugOutput) console.log("http.readyState: " +http.readyState)
        if (http.readyState === XMLHttpRequest.DONE) {
            if (debugOutput) console.log("http.status: " + http.status)
            if (http.status === 200 || http.status === 300  || http.status === 302) {
                try {
                    if (debugOutput) console.log("http.status: " + http.status)
                    if (debugOutput) console.log(http.responseText)
                    var JsonString = http.responseText
                    var JsonObject= JSON.parse(JsonString)
                    var tempSession =  JsonObject.session_id
                    getTokenD7(tempSession, passWord,userName,urlString,envoyserial,envoyfirmware,totalValue)
                }
                catch (e){
                    currentPower = 0
                    parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            } else {
                parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
            }
        }
    }
    http.send();
}

   function  getTokenD7(tempSession, passWord,userName,urlString,envoyserial,envoyfirmware,totalValue){
        if (debugOutput) console.log("*********SolarPanel Start getTokenD7")
        var http = new XMLHttpRequest()
        var url = "https://entrez.enphaseenergy.com/tokens"
        if (debugOutput) console.log("*********SolarPanel url: " + url)
        http.open("POST", url, true);
        http.withCredentials = true;
        http.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
        http.onreadystatechange = function() { // Call a function when the state changes.
            if (debugOutput) console.log("http.readyState: " + http.readyState)
            if (http.readyState === XMLHttpRequest.DONE) {
                if (debugOutput) console.log("http.status: " + http.status)
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("http.status: " + http.status)
                        if (debugOutput) console.log(http.responseText)
                        if (http.responseText != ""){
                           checkToken(tempSession, urlString,http.responseText,totalValue,"D7")
                        }else{
                            if (getDataCount == 0){apiKey = ""}
                            if (getDataCount == 1){apiKey2 = ""}
                        }
                    }
                    catch (e){
                        currentPower = 0
                        parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
                     parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
       http.send(JSON.stringify({ "session_id":  tempSession  , "serial_num": envoyserial , "username" : userName}));
    }



	function startLoginD8(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid){
        if (debugOutput) console.log("*********SolarPanel Start startLoginD8")
        var http = new XMLHttpRequest()
        var url = "https://entrez.enphaseenergy.com/login_main_page"
        http.open("GET", url, true);
        http.setRequestHeader("Connection", "keep-alive")
        http.onreadystatechange = function() {
            if (http.readyState === XMLHttpRequest.DONE) {
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("*********SolarPanel Start startLoginD8 http.status: " + http.status)
						if (debugOutput) console.log("*********SolarPanel Start startLoginD8 http.responseText: " + http.responseText)
                        var csrf= http.responseText.split("<input type=\"hidden\" name=\"_csrf\" value=\"")[1].split("\"/>")[0].trim()
                        if (debugOutput) console.log("*********SolarPanel csrf: " + csrf)
                        startLoginD82(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid,csrf)
                    }
                    catch (e){
                        currentPower = 0
						parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
                    parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
        http.send();
    }


    function startLoginD82(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid, csrf){
        if (debugOutput) console.log("*********SolarPanel Start startLoginD82")
        var data = "_csrf=" + csrf + "&username=" + encodeURIComponent(userName) + "&password=" + encodeURIComponent(passWord) + "&codeChallenge=&redirectUri=&client=&clientId=&authFlow=entrezSession&serialNum=&grantType=&state=&invalidSerialNum=";
        var http = new XMLHttpRequest()
        var url = "https://entrez.enphaseenergy.com/login"
        if (debugOutput) console.log("*********SolarPanel url: " + url)
        http.open("POST", url, true);
        http.setRequestHeader("content-type", "application/x-www-form-urlencoded")
        http.onreadystatechange = function() {
            if (http.readyState === XMLHttpRequest.DONE) {
                if (debugOutput) console.log("*********SolarPanel http.status: " + http.status)
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("*********SolarPanel Start startLoginD8-2 http.status: " + http.status)
						if (debugOutput) console.log("*********SolarPanel Start startLoginD8-2 http.responseText: " + http.responseText)
                        var csrf2= http.responseText.split("<input type=\"hidden\" name=\"_csrf\" value=\"")[1].split("\"/>")[0].trim()
                        if (debugOutput) console.log("*********SolarPanel csrf2: " + csrf2)
                        getTokenD8(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid,csrf2)
                    }
                    catch (e){
                        currentPower = 0
                        parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
                    parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
        http.send(data);
    }
	
	

    function getTokenD8(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid,csrf){
        if (debugOutput) console.log("*********SolarPanel Start getTokenD8")
		var siteName = siteid
		if (debugOutput) console.log("*********SolarPanel getTokenD8 siteName: " + siteName)
		if (debugOutput) console.log("*********SolarPanel getTokenD8 siteSerial: " + envoyserial)
        var data = "_csrf=" + csrf + "&Site=" + siteName + "&serialNum=" + envoyserial;
        var http = new XMLHttpRequest()
        var url = "https://entrez.enphaseenergy.com/entrez_tokens"
        if (debugOutput) console.log("*********SolarPanel url: " + url)
        http.open("POST", url, true);
        http.setRequestHeader("content-type", "application/x-www-form-urlencoded")
        http.onreadystatechange = function() {
            if (http.readyState === XMLHttpRequest.DONE) {
                if (debugOutput) console.log("*********SolarPanel http.status: " + http.status)
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("*********SolarPanel getTokenD8 http.status: " + http.status)
						if (debugOutput) console.log("*********SolarPanel getTokenD8 http.responseText: " + http.responseText)
                        var newtoken= http.responseText.split("<textarea name=\"accessToken\" id=\"JWTToken\" cols=\"30\" rows=\"10\" >")[1].split("</textarea>")[0].trim()
                        if (debugOutput) console.log("*********SolarPanel newtokenD8:: " + newtoken)
                        if (newtoken !== ""){
						   if (debugOutput) console.log("*********SolarPanel checking token: " + newtoken)
                           checkToken(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid,newtoken, "D8")
                        }else{
                            if (getDataCount == 0){apiKey = ""}
                            if (getDataCount == 1){apiKey2 = ""}
                        }
                    }
                    catch (e){
                        currentPower = 0
                        parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
                    parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
        http.send(data);
    }


    function checkToken(passWord,userName,urlString,envoyserial,envoyfirmware,totalValue,siteid,newtoken,invtype){
		console.log("*********SolarPanel Start checkToken()*******************************************************************************")
        if (debugOutput) console.log("*********SolarPanel Start checkToken()")
		if (debugOutput) console.log("*********SolarPanel haal de enphase info op via tsc command")
		if (debugOutput) console.log("*********SolarPanel enphase checktoken url " + urlString)
		if (debugOutput) console.log("*********SolarPanel enphase checktoken newtoken " + newtoken)
			
		var onetime = true
		
		var doc2 = new XMLHttpRequest();
		doc2.open("PUT", "file:///tmp/enphase_token.txt");
		doc2.send(urlString + ";" + newtoken);

		var doc4 = new XMLHttpRequest();
		doc4.open("PUT", "file:///tmp/tsc.command");
		doc4.send("external-solarPanel");

		//wacht op een response vanuit het TSC script
		solarEnphaseDelay(8000, function() {
			if (onetime){
				onetime = false
				parseEnpaseToken(urlString,passWord,userName,newtoken,totalValue,invtype)
			}
		})
	}
		
	function parseEnpaseToken(urlString,passWord,userName,newtoken,totalValue,invtype){
		if (debugOutput) console.log("*********SolarPanel Start parseEnpaseToken()")
		if (debugOutput) console.log("*********SolarPanel newtoken: " + newtoken)
        var http = new XMLHttpRequest()
        var url = "file:///tmp/enphase_token_return.txt"
        if (debugOutput) console.log("*********SolarPanel url: " + url)
        http.open("GET", url, true);
        http.onreadystatechange = function() { // Call a function when the state changes.
            if (debugOutput) console.log("http.readyState: " + http.readyState)
            if (http.readyState === XMLHttpRequest.DONE) {
                if (debugOutput) console.log("http.status: " + http.status)
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("http.status: " + http.status)
                        if (debugOutput) console.log("*********SolarPanel http.responseText: " + http.responseText)
                        if (http.responseText.indexOf("Valid token")>0){
                           if (debugOutput) console.log("valid token")
						   //get cookie data from response
						   var locsessionID= http.responseText.split("sessionId=")[1].split(";")[0]
						   if (debugOutput) console.log("apiKeyPlugin: " + locsessionID)   
                           if (getDataCount == 0){apiKey = locsessionID}
                           if (getDataCount == 1){apiKey2 = locsessionID}
                           getD7data(urlString,locsessionID,totalValue,invtype)
                        }else{
                            if (getDataCount == 0){apiKey = ""}
                            if (getDataCount == 1){apiKey2 = ""}
                        }
                    }
                    catch (e){
                        currentPower = 0
                        parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
                     parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
       http.send();
    }
	
	
	function getD7data(urlString,sessionID,totalValue,invtype){
		var onetime = true
		if (debugOutput) console.log("*********SolarPanel Start getD7data")
		if (debugOutput) console.log("*********SolarPanel haal de enphase info op via tsc command")
		if (debugOutput) console.log("*********SolarPanel enphase getD7data url " + urlString)
		if (debugOutput) console.log("*********SolarPanel enphase getD7data sessionID " + sessionID)
		
		var doc2 = new XMLHttpRequest();
		doc2.open("PUT", "file:///tmp/enphase_D7.txt");
		doc2.send(urlString + ";" + sessionID);

		var doc4 = new XMLHttpRequest();
		doc4.open("PUT", "file:///tmp/tsc.command");
		doc4.send("external-solarPanel");

		//wacht op een response vanuit het TSC script
		solarEnphaseDelay(8000, function() {
			if (onetime){
				onetime = false
				parseEnphaseD7(totalValue,invtype)
			}
		})
	}



    function parseEnphaseD7(totalValue,invtype){
        if (debugOutput) console.log("*********SolarPanel Start parseEnphaseD7")
        var http = new XMLHttpRequest()
        var url = "file:///tmp/enphase_D7_return.txt"
        if (debugOutput) console.log("*********SolarPanel url: " + url)
        http.open("GET", url, true);
        http.onreadystatechange = function() { // Call a function when the state changes.
            if (debugOutput) console.log("http.readyState: " + http.readyState)
            if (http.readyState === XMLHttpRequest.DONE) {
                if (debugOutput) console.log("http.status: " + http.status)
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("*********SolarPanel http.status: " + http.status)
                        if (debugOutput) console.log("*********SolarPanel http.responseText: " + http.responseText)
						if (http.responseText.indexOf("401 Authorization Required")>0){
							if (getDataCount == 0){apiKey = ""}
							if (getDataCount == 1){apiKey2 = ""}
						}else{
							if(invtype == "D7"){
								if (debugOutput) console.log("*********SolarPanel parsing D7 responseText")
								var JsonObject= JSON.parse(http.responseText)
								var today2
								currentPower = parseInt(JsonObject.production[0].wNow)
								today2=parseInt(JsonObject.production[1].whToday)
								totalValue= parseInt(JsonObject.production[0].whLifetime)
								if (debugOutput) console.log("*********SolarPanel currentPower: " + currentPower)
								if (debugOutput) console.log("*********SolarPanel today2: " + today2)
								if (debugOutput) console.log("*********SolarPanel totalValue: " + totalValue)
								parseReturnData(currentPower,totalValue,today2,0,0,0,0,http.status,"succes")
							}
							if(invtype == "D8"){
								if (debugOutput) console.log("*********SolarPanel yesterdayTotal: " + yesterdayTotal)
								if (yesterdayTotal == 0||yesterdayTotal == null){
									if (debugOutput) console.log("*********SolarPanel yesterdayTotal is 0")
									getLastNonNullValueFromURL()
									if (debugOutput) console.log("*********SolarPanel return yesterdayTotal: " + yesterdayTotal)
								}
								if (debugOutput) console.log("*********SolarPanel parsing D8 responseText")
								var JsonObject= JSON.parse(http.responseText)
								var today2
								currentPower = parseInt(JsonObject.production[0].wNow)
								totalValue= parseInt(JsonObject.production[0].whLifetime)
								today2= totalValue - yesterdayTotal
								if (debugOutput) console.log("*********SolarPanel currentPower: " + currentPower)
								if (debugOutput) console.log("*********SolarPanel today2: " + today2)
								if (debugOutput) console.log("*********SolarPanel totalValue: " + totalValue)
								parseReturnData(currentPower,totalValue,today2,0,0,0,0,http.status,"succes")
							}
						}
						
                    }
                    catch (e){
                        currentPower = 0
                        parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
					if (http.status === 401){
						if (getDataCount == 0){apiKey = ""}
                        if (getDataCount == 1){apiKey2 = ""}
					}
                     parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
       http.send();
    }

	
    function  getD5data(urlString,totalValue){
        if (debugOutput) console.log("*********SolarPanel Start getD5data")
        var http = new XMLHttpRequest()
        var url = "http://" + urlString + "/production.json"
        if (debugOutput) console.log("*********SolarPanel url: " + url)
        http.open("GET", url, true);
        http.onreadystatechange = function() { // Call a function when the state changes.
            if (debugOutput) console.log("http.readyState: " + http.readyState)
            if (http.readyState === XMLHttpRequest.DONE) {
                if (debugOutput) console.log("http.status: " + http.status)
                if (http.status === 200 || http.status === 300  || http.status === 302) {
                    try {
                        if (debugOutput) console.log("http.status: " + http.status)
                        if (debugOutput) console.log(http.responseText)
                        var JsonObject= JSON.parse(http.responseText)
                        var today2
                        currentPower = parseInt(JsonObject.production[0].wNow)
                        today2=parseInt(JsonObject.production[1].whToday)
                        totalValue= parseInt(JsonObject.production[0].whLifetime)
                        parseReturnData(currentPower,totalValue,today2,0,0,0,0,http.status,"succes")
                    }
                    catch (e){
                        currentPower = 0
                        parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                    }
                } else {
                     parseReturnData(currentPower,totalValue,todayValue,0,0,0,0, http.status,"error")
                }
            }
        }
       http.send();
    }
   
function getLastNonNullValueFromURL() {
	if (debugOutput) console.log("*********SolarPanel getLastNonNullValueFromURL")
	var $date = new Date()
	$date.setDate($date.getDate()-1)
	var yesterdayDate =  $date.getDate() + '-' + ($date.getMonth()+1) + '-' + $date.getFullYear()
	var url = "http://localhost/hcb_rrd?action=getRrdData&loggerName=elec_solar_quantity&rra=10yrdays&readableTime=1&nullForNaN=1&to=" + yesterdayDate;
    const xhr = new XMLHttpRequest()
    xhr.open('GET', url, true)
    xhr.onreadystatechange = function () {
        if (xhr.readyState === 4 && xhr.status === 200) {
            try {
                const data = JSON.parse(xhr.responseText)
                const keys = Object.keys(data).reverse()
                let lastNonNullValue = null
                for (var key in keys) {
                    if (data[key] !== null) {
                        lastNonNullValue = data[key]
                        yesterdayTotal =  lastNonNullValue
                    }
                }
               if (debugOutput) console.log("*********SolarPanel yesterdayTotal: " + yesterdayTotal)
			   return yesterdayTotal
            } catch (error) {
                if (debugOutput) console.error("*********SolarPanel getLastNonNullValueFromURL error: ", error)
            }
        } else if (xhr.readyState === 4) {
             if (debugOutput) console.error("*********SolarPanel getLastNonNullValueFromURL error: ", xhr.status)
        }
    }
    xhr.send();
}