' + notification + '
')
else
wkTile=device.currentValue("html").replace('
','
' + notification)
// when msg count exceeds limit, purge last message
if (debugEnable) log.debug "logReceived msgFilled: ${msgFilled} msgLimit: ${settings.msgLimit}"
if (msgFilled < settings.msgLimit.toInteger())
msgFilled++
else
{
int i = wkTile.lastIndexOf('
');
if (i != -1)
wkTile = wkTile.substring(0, i) + '
';
}
// Ensure tile length is less than 1024 and hopefully stop loops
int wkLen=wkTile.length()
while (wkLen > 1024 && msgFilled > 0)
{
if (debugEnable) log.debug "wkTile length ${wkLen}> 1024 truncating msgCount: ${msgFilled}"
int i = wkTile.lastIndexOf('
');
if (i != -1)
{
wkTile = wkTile.substring(0, i) + '
';
msgFilled--
}
else
{
wkTile='
'
msgFilled=0
}
wkLen=wkTile.length()
if (debugEnable) log.debug "Truncated wkTile length ${wkLen}, msgCount: ${msgFilled}"
}
// Update attributes and state
sendEvent(name:"html", value: wkTile)
state.msgCount = msgFilled
}
void logsOff(){
device.updateSetting("debugEnable",[value:"false",type:"bool"])
}
void push() {
configure()
}
// Start of modified InfluxDB Logger code
void parse(String description) {
def descData = new JsonSlurper().parseText(description)
if ("${descData.id}" != "${device.id}") {
String name = escapeStringHTMlforMsg(descData.name)
String message = escapeStringHTMlforMsg(descData.msg)
String timestmp = '"' + descData.time + '"'
String id = descData.id.toString()
switch (descData.level) {
case 'error':
sevCode = 3
break
case 'warn':
sevCode = 4
break
case 'info':
sevCode = 6
break
default :
sevCode = 7
}
switch (descData.level) {
case 'error':
severity = "
err"
break
case 'warn':
severity = "
warn"
break
case 'info':
severity = "
info"
break
default :
severity = "
debug"
}
String level = descData.level.toString()
String type = descData.type.toString()
long timeNow = new Date().time
def dateFormat = "yyyy-MM-dd HH:mm:ss.SSS"
def date = Date.parse(dateFormat, descData.time)
epoch_milis = date.getTime()// * 1000000
//loggerQueueMap += ["syslog,appname=${name},facility=${type},host=${hubName},hostname=${hubName},severity=${severity} facility_code=1,message=${msg},procid=${id},severity_code=${sevCode},timestamp=${timestmp} ${epoch_milis}"]
logMsg = "${type}:${name} ${severity} ${message}"
logReceived(logMsg, epoch_milis)
}
}
void connect() {
if (debugEnable) { log.debug "attempting connection" }
try {
interfaces.webSocket.connect("http://localhost:8080/logsocket")
pauseExecution(1000)
} catch (e) {
log.error "initialize error: ${e.message}"
}
}
void disconnect() {
interfaces.webSocket.close()
}
void webSocketStatus(String message) {
// handle error messages and reconnect
if (debugEnable) { log.debug "Got status ${message}" }
if (message.startsWith("failure")) {
// reconnect in a little bit
runIn(5, connect)
}
}
private String escapeStringForInfluxDB(String str) {
//logger("$str", "info")
if (str) {
str = str.replaceAll(" ", "\\\\ ") // Escape spaces.
str = str.replaceAll(",", "\\\\,") // Escape commas.
str = str.replaceAll("=", "\\\\=") // Escape equal signs.
str = str.replaceAll("\"", "\\\\\"") // Escape double quotes.
//str = str.replaceAll("'", "_") // Replace apostrophes with underscores.
}
else {
str = 'null'
}
return str
}
private String escapeStringHTMlforMsg(String str) {
//logger("$str", "info")
if (str) {
str = str.replaceAll("'", "&") // Escape spaces.
str = str.replaceAll("<", "<") // Escape commas.
str = str.replaceAll(">", ">") // Escape equal signs.
str = str.replaceAll("", "'") // Escape double quotes.
str = str.replaceAll("'", "'") // Replace apostrophes with underscores.
str = str.replaceAll("'", "'")
}
else {
str = 'null'
}
return str
}