let ts= InDriver.hookTs();

RestApi.sendRequest('shelly');

if (RestApi.isSucceeded()) {

const json = RestApi.getData('shelly');

const jsonObj = JSON.parse(text);

//Extract energy and power values for each phase

let energy1 = Math.abs(jsonObj .data.device_status.emeters[0].total_returned);

let energy2 = Math.abs(jsonObj .data.device_status.emeters[1].total_returned);

let energy3 = Math.abs(jsonObj .data.device_status.emeters[2].total_returned);

let power1 = Math.abs(jsonObj .data.device_status.emeters[0].power);

let power2 = Math.abs(jsonObj .data.device_status.emeters[1].power);

let power3 = Math.abs(jsonObj .data.device_status.emeters[2].power);

//Build smart meter time series data point

let data = {

power1 : power1,

power2 : power2,

power3 : power3,

voltage1 : Math.abs(jsonObj .data.device_status.emeters[0].voltage),

voltage2 : Math.abs(jsonObj .data.device_status.emeters[1].voltage),

voltage3 : Math.abs(jsonObj .data.device_status.emeters[2].voltage),

current1 : Math.abs(jsonObj .data.device_status.emeters[0].current),

current2 : Math.abs(jsonObj .data.device_status.emeters[1].current),

current3 : Math.abs(jsonObj .data.device_status.emeters[2].current),

energy1 : energy1,

energy2 : energy2,

energy3 : energy3,

energy_total: energy1 + energy2 + energy3,

power_total: power1 + power2 + power3

}

let shelly = {Shelly:data};

let list = [];

list.push(shelly);

// Ensure data changes are detected. This smart meter sends updates irregularly, often repeating values in subsequent requests.

let currentJSON = JSON.stringify(list);

if (lastJSON !=currentJSON) {

// Log JSON object with extracted values to database

InDriver.sqlExecute("azureserver", "insert into public.shelly (source, ts, data ) values ('Shelly','"+ts.toISOString()+"',$$"+currentJSON+"$$);");

lastJSON = currentJSON;

InDriver.debug(currentJSON)

}

}

​