mtan93/SmartThingsPublic
1
0
Fork 0
mirror of https://github.com/mtan93/SmartThingsPublic.git synced 2026-04-01 06:13:06 +01:00
Code Issues Packages Projects Releases Wiki Activity

removed all simicolons as per the groovy-lang.org style guide and better consistency

Browse Source
This commit is contained in:
David Sulpy
2015-09-14 16:19:30 -05:00
parent 80b4d6a665
commit bad978afbd
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
smartapps/initialstate-events/initial-state-event-streamer.src/initial-state-event-streamer.groovy
View File

@@ -229,7 +229,7 @@ def installed() {
atomicState.isBucketCreated = false atomicState.isBucketCreated = false
atomicState.grokerSubdomain = "groker" atomicState.grokerSubdomain = "groker"
atomicState.eventBuffer = []; atomicState.eventBuffer = []
runEvery15Minutes(flushBuffer) runEvery15Minutes(flushBuffer)
@@ -243,7 +243,7 @@ def updated() {
atomicState.isBucketCreated = false atomicState.isBucketCreated = false
} }
if (atomicState.eventBuffer == null) { if (atomicState.eventBuffer == null) {
atomicState.eventBuffer = []; atomicState.eventBuffer = []
} }
subscribeToEvents() subscribeToEvents()
@@ -258,10 +258,10 @@ def uninstalled() {
def createBucket() { def createBucket() {
if (!atomicState.bucketName) { if (!atomicState.bucketName) {
atomicState.bucketName = atomicState.bucketKey; atomicState.bucketName = atomicState.bucketKey
} }
if (!atomicState.accessKey) { if (!atomicState.accessKey) {
return; return
} }
def bucketName = "${atomicState.bucketName}" def bucketName = "${atomicState.bucketName}"
def bucketKey = "${atomicState.bucketKey}" def bucketKey = "${atomicState.bucketKey}"
@@ -321,23 +321,23 @@ def genericHandler(evt) {
def flushBuffer() { def flushBuffer() {
log.trace "About to flush the buffer on schedule" log.trace "About to flush the buffer on schedule"
if (atomicState.eventBuffer != null && atomicState.eventBuffer.size() > 0) { if (atomicState.eventBuffer != null && atomicState.eventBuffer.size() > 0) {
shipEvents(); shipEvents()
} }
} }
def eventHandler(name, value) { def eventHandler(name, value) {
log.debug atomicState.eventBuffer; log.debug atomicState.eventBuffer
def eventBuffer = atomicState.eventBuffer; def eventBuffer = atomicState.eventBuffer
def epoch = now() / 1000; def epoch = now() / 1000
eventBuffer << [key: "$name", value: "$value", epoch: "$epoch"] eventBuffer << [key: "$name", value: "$value", epoch: "$epoch"]
log.debug eventBuffer; log.debug eventBuffer
atomicState.eventBuffer = eventBuffer; atomicState.eventBuffer = eventBuffer
if (eventBuffer.size() >= 10) { if (eventBuffer.size() >= 10) {
shipEvents(); shipEvents()
} }
} }
@@ -352,7 +352,7 @@ def shipEvents() {
"Accept-Version": "0.0.2" "Accept-Version": "0.0.2"
], ],
body: atomicState.eventBuffer body: atomicState.eventBuffer
]; ]
try { try {
// post the events to initial state // post the events to initial state
@@ -362,7 +362,7 @@ def shipEvents() {
log.error "shipping failed... ${resp.data}" log.error "shipping failed... ${resp.data}"
} else { } else {
// clear the buffer // clear the buffer
atomicState.eventBuffer = []; atomicState.eventBuffer = []
} }
} }
} catch (e) { } catch (e) {