forked from DaveGut/HubitatActive
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Samsung_Refrig.groovy
587 lines (535 loc) · 28.7 KB
/
Samsung_Refrig.groovy
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
/* Samsung Refrigerator using SmartThings Interface
Copyright Dave Gutheinz
License Information:
https://github.com/DaveGut/HubitatActive/blob/master/KasaDevices/License.md
===== Description
This driver is for SmartThings-installed Samsung Refrigerators for import of control
and status of defined functions into Hubitat Environment.
===== Library Use
This driver uses libraries for the functions common to SmartThings devices.
Library code is at the bottom of the distributed single-file driver.
===== Installation Instructions Link =====
https://github.com/DaveGut/HubitatActive/blob/master/SamsungAppliances/Install_Samsung_Appliance.pdf
===== Version 1.1 ==============================================================================*/
//def driverVer() { return "1.1" }
def driverVer() { return "T1.1" }
def nameSpace() { return "davegut" }
metadata {
definition (name: "Samsung Refrig",
namespace: nameSpace(),
author: "David Gutheinz",
importUrl: "https://raw.githubusercontent.com/DaveGut/HubitatActive/master/SamsungAppliances/Samsung_Refrig.groovy"
){
capability "Refresh"
capability "Contact Sensor"
capability "Temperature Measurement"
capability "Thermostat Cooling Setpoint"
capability "Filter Status"
command "setRapidCooling", [[
name: "Rapid Cooling",
constraints: ["on", "off"],
type: "ENUM"]]
attribute "rapidCooling", "string"
command "setRapidFreezing", [[
name: "Rapid Freezing",
constraints: ["on", "off"],
type: "ENUM"]]
attribute "rapidFreezing", "string"
command "defrost", [[
name: "Defrost",
constraints: ["on", "off"],
type: "ENUM"]]
attribute "defrost", "string"
// Sabbath Mode
command "toggleSabbathMode"
attribute "SabbathMode", "string"
}
preferences {
input ("stApiKey", "string", title: "SmartThings API Key", defaultValue: "")
if (stApiKey) {
input ("stDeviceId", "string", title: "SmartThings Device ID", defaultValue: "")
}
if (stDeviceId) {
input ("pollInterval", "enum", title: "Poll Interval (minutes)",
options: ["10sec", "20sec", "30sec", "1", "5", "10", "30"], defaultValue: "10")
input ("debugLog", "bool",
title: "Enable debug logging for 30 minutes", defaultValue: false)
}
}
}
def installed() { }
def updated() {
def commonStatus = commonUpdate()
if (commonStatus.status == "FAILED") {
logWarn("updated: ${commonStatus}")
} else {
logInfo("updated: ${commonStatus}")
deviceSetup()
}
}
def setCoolingSetpoint(setpoint) {
def cmdData = [
component: getDataValue("component"),
capability: "thermostatCoolingSetpoint",
command: "setCoolingSetpoint",
arguments: [setpoint]]
def cmdStatus = deviceCommand(cmdData)
logInfo("setCoolingSetpoint: [cmd: ${setpoint}, ${cmdStatus}]")
}
def setRapidCooling(onOff) {
setRefrigeration("setRapidCooling", onOff)
}
def setRapidFreezing(onOff) {
setRefrigeration("setRapidFreezing", onOff)
}
def defrost(onOff) {
setRefrigeration("setDefrost", onOff)
}
def setRefrigeration(command, onOff) {
def cmdData = [
component: getDataValue("component"),
capability: "refrigeration",
command: command,
arguments: [onOff]]
def cmdStatus = deviceCommand(cmdData)
logInfo("setRefrigeration: [cmd ${command}, onOff: ${onOff}, status: ${cmdStatus}]")
}
def toggleSabbathMode() {
def currMode = device.currentValue("sabbathMode")
def newMode = "Off"
if (currMode == newMode) {
newMode = "On"
}
def arguments = [["x.com.samsung.da.sabbathMode":newMode]]
def cmdData = [
component: "main",
capability: "execute",
command: "execute",
arguments: arguments]
def cmdStatus = deviceCommand(cmdData)
logInfo("toggleSabbathMode: [cmd: ${setpoint}, ${cmdStatus}]")
}
def distResp(resp, data) {
def respLog = [:]
if (resp.status == 200) {
try {
def respData = new JsonSlurper().parseText(resp.data)
if (data.reason == "deviceSetup") {
deviceSetupParse(respData)
} else {
def children = getChildDevices()
children.each {
it.statusParse(respData)
}
statusParse(respData)
}
} catch (err) {
respLog << [status: "ERROR",
errorMsg: err,
respData: resp.data]
}
} else {
respLog << [status: "ERROR",
httpCode: resp.status,
errorMsg: resp.errorMessage]
}
if (respLog != [:]) {
logWarn("distResp: ${respLog}")
}
}
def deviceSetupParse(respData) {
def respLog = []
if (!getDataValue("dongle")) {
def dongle = "false"
def mnmo = respData.components.main.ocf.mnmo
if (mnmo != null && mnmo.value.contains("DONGLE")) {
dongle = "true"
}
updateDataValue("dongle", dongle)
respLog << [dongle: dongle]
}
// Install Children
def compData = respData.components
compData.each {
if (it.key != "main") {
def childDni = dni + "-${it.key}"
def isChild = getChildDevice(childDni)
if (!isChild) {
def disabledComponents = []
if (disabledComponents == null) {
disabledComponents = compData.main["custom.disabledComponents"].disabledComponents.value
}
if(!disabledComponents.contains(it.key)) {
respLog << [component: it.key, status: "Installing"]
addChild(it.key, childDni)
}
}
} else {
updateDataValue("component", "main")
}
}
if (respLog != []) {
logInfo("deviceSetupParse: ${respLog}")
}
}
def addChild(component, childDni) {
def type
switch(component) {
case "freezer":
case "cooler":
case "onedoor":
type = "Samsung Refrig cavity"
break
case "icemaker":
case "icemaker-02":
type = "Samsung Refrig icemaker"
break
case "cvroom":
type = "Samsung Refrig cvroom"
break
default:
logWarn("addChild: [component: ${component}, error: not on components list.")
}
try {
addChildDevice("davegut", "${type}", "${childDni}", [
"name": type, "label": component, component: component])
logInfo("addChild: [status: ADDED, label: ${component}, type: ${type}]")
} catch (error) {
logWarn("addChild: [status: FAILED, type: ${type}, dni: ${childDni}, component: ${component}, error: ${error}]")
}
}
def statusParse(respData) {
def parseData
try {
parseData = respData.components.main
} catch (error) {
logWarn("statusParse: [respData: ${respData}, error: ${error}]")
return
}
def contact = parseData.contactSensor.contact.value
sendEvent(name: "contact", value: contact)
def tempUnit = parseData.thermostatCoolingSetpoint.coolingSetpoint.unit
def coolingSetpoint = parseData.thermostatCoolingSetpoint.coolingSetpoint.value
sendEvent(name: "coolingSetpoint", value: coolingSetpoint, unit: tempUnit)
if (getDataValue("dongle") == "false") {
def temperature = parseData.temperatureMeasurement.temperature.value
sendEvent(name: "temperature", value: temperature, unit: tempUnit)
def SabbathMode = parseData.execute.data.value.payload["x.com.samsung.da.sabbathMode"]
sendEvent(name: "SabbathMode", value: SabbathMode)
}
def defrost = parseData.refrigeration.defrost.value
sendEvent(name: "defrost", value: defrost)
def rapidCooling = parseData.refrigeration.rapidCooling.value
sendEvent(name: "rapidCooling", value: rapidCooling)
def rapidFreezing = parseData.refrigeration.rapidFreezing.value
sendEvent(name: "rapidFreezing", value: rapidFreezing)
def filterStatus = parseData["custom.waterFilter"].waterFilterStatus.value
sendEvent(name: "filterStatus", value: filterStatus)
if (simulate() == true) {
runIn(1, listAttributes, [data: true])
} else {
runIn(1, listAttributes)
}
}
// ===== Library Integration =====
def simulate() { return false }
//#include davegut.Samsung-Refrig-Sim
//#include davegut.Samsung-Refrig-Sim-DONGLE
// ~~~~~ start include (1072) davegut.Logging ~~~~~
library ( // library marker davegut.Logging, line 1
name: "Logging", // library marker davegut.Logging, line 2
namespace: "davegut", // library marker davegut.Logging, line 3
author: "Dave Gutheinz", // library marker davegut.Logging, line 4
description: "Common Logging Methods", // library marker davegut.Logging, line 5
category: "utilities", // library marker davegut.Logging, line 6
documentationLink: "" // library marker davegut.Logging, line 7
) // library marker davegut.Logging, line 8
// Logging during development // library marker davegut.Logging, line 10
def listAttributes(trace = false) { // library marker davegut.Logging, line 11
def attrs = device.getSupportedAttributes() // library marker davegut.Logging, line 12
def attrList = [:] // library marker davegut.Logging, line 13
attrs.each { // library marker davegut.Logging, line 14
def val = device.currentValue("${it}") // library marker davegut.Logging, line 15
attrList << ["${it}": val] // library marker davegut.Logging, line 16
} // library marker davegut.Logging, line 17
if (trace == true) { // library marker davegut.Logging, line 18
logTrace("Attributes: ${attrList}") // library marker davegut.Logging, line 19
} else { // library marker davegut.Logging, line 20
logDebug("Attributes: ${attrList}") // library marker davegut.Logging, line 21
} // library marker davegut.Logging, line 22
} // library marker davegut.Logging, line 23
def logTrace(msg){ // library marker davegut.Logging, line 25
log.trace "${device.displayName} ${driverVer()}: ${msg}" // library marker davegut.Logging, line 26
} // library marker davegut.Logging, line 27
def logInfo(msg) { // library marker davegut.Logging, line 29
if (infoLog == true) { // library marker davegut.Logging, line 30
log.info "${device.displayName} ${driverVer()}: ${msg}" // library marker davegut.Logging, line 31
} // library marker davegut.Logging, line 32
} // library marker davegut.Logging, line 33
def debugLogOff() { // library marker davegut.Logging, line 35
if (debug == true) { // library marker davegut.Logging, line 36
device.updateSetting("debug", [type:"bool", value: false]) // library marker davegut.Logging, line 37
} else if (debugLog == true) { // library marker davegut.Logging, line 38
device.updateSetting("debugLog", [type:"bool", value: false]) // library marker davegut.Logging, line 39
} // library marker davegut.Logging, line 40
logInfo("Debug logging is false.") // library marker davegut.Logging, line 41
} // library marker davegut.Logging, line 42
def logDebug(msg) { // library marker davegut.Logging, line 44
if (debug == true || debugLog == true) { // library marker davegut.Logging, line 45
log.debug "${device.displayName} ${driverVer()}: ${msg}" // library marker davegut.Logging, line 46
} // library marker davegut.Logging, line 47
} // library marker davegut.Logging, line 48
def logWarn(msg) { log.warn "${device.displayName} ${driverVer()}: ${msg}" } // library marker davegut.Logging, line 50
// ~~~~~ end include (1072) davegut.Logging ~~~~~
// ~~~~~ start include (1091) davegut.ST-Communications ~~~~~
library ( // library marker davegut.ST-Communications, line 1
name: "ST-Communications", // library marker davegut.ST-Communications, line 2
namespace: "davegut", // library marker davegut.ST-Communications, line 3
author: "Dave Gutheinz", // library marker davegut.ST-Communications, line 4
description: "ST Communications Methods", // library marker davegut.ST-Communications, line 5
category: "utilities", // library marker davegut.ST-Communications, line 6
documentationLink: "" // library marker davegut.ST-Communications, line 7
) // library marker davegut.ST-Communications, line 8
import groovy.json.JsonSlurper // library marker davegut.ST-Communications, line 9
private asyncGet(sendData, passData = "none") { // library marker davegut.ST-Communications, line 11
if (!stApiKey || stApiKey.trim() == "") { // library marker davegut.ST-Communications, line 12
logWarn("asyncGet: [status: ERROR, errorMsg: no stApiKey]") // library marker davegut.ST-Communications, line 13
} else { // library marker davegut.ST-Communications, line 14
logDebug("asyncGet: ${sendData}, ${passData}") // library marker davegut.ST-Communications, line 15
def sendCmdParams = [ // library marker davegut.ST-Communications, line 16
uri: "https://api.smartthings.com/v1", // library marker davegut.ST-Communications, line 17
path: sendData.path, // library marker davegut.ST-Communications, line 18
headers: ['Authorization': 'Bearer ' + stApiKey.trim()]] // library marker davegut.ST-Communications, line 19
try { // library marker davegut.ST-Communications, line 20
asynchttpGet(sendData.parse, sendCmdParams, [reason: passData]) // library marker davegut.ST-Communications, line 21
} catch (error) { // library marker davegut.ST-Communications, line 22
logWarn("asyncGet: [status: FAILED, errorMsg: ${error}]") // library marker davegut.ST-Communications, line 23
} // library marker davegut.ST-Communications, line 24
} // library marker davegut.ST-Communications, line 25
} // library marker davegut.ST-Communications, line 26
private syncGet(path){ // library marker davegut.ST-Communications, line 28
def respData = [:] // library marker davegut.ST-Communications, line 29
if (!stApiKey || stApiKey.trim() == "") { // library marker davegut.ST-Communications, line 30
respData << [status: "FAILED", // library marker davegut.ST-Communications, line 31
errorMsg: "No stApiKey"] // library marker davegut.ST-Communications, line 32
} else { // library marker davegut.ST-Communications, line 33
logDebug("syncGet: ${sendData}") // library marker davegut.ST-Communications, line 34
def sendCmdParams = [ // library marker davegut.ST-Communications, line 35
uri: "https://api.smartthings.com/v1", // library marker davegut.ST-Communications, line 36
path: path, // library marker davegut.ST-Communications, line 37
headers: ['Authorization': 'Bearer ' + stApiKey.trim()] // library marker davegut.ST-Communications, line 38
] // library marker davegut.ST-Communications, line 39
try { // library marker davegut.ST-Communications, line 40
httpGet(sendCmdParams) {resp -> // library marker davegut.ST-Communications, line 41
if (resp.status == 200 && resp.data != null) { // library marker davegut.ST-Communications, line 42
respData << [status: "OK", results: resp.data] // library marker davegut.ST-Communications, line 43
} else { // library marker davegut.ST-Communications, line 44
respData << [status: "FAILED", // library marker davegut.ST-Communications, line 45
httpCode: resp.status, // library marker davegut.ST-Communications, line 46
errorMsg: resp.errorMessage] // library marker davegut.ST-Communications, line 47
} // library marker davegut.ST-Communications, line 48
} // library marker davegut.ST-Communications, line 49
} catch (error) { // library marker davegut.ST-Communications, line 50
respData << [status: "FAILED", // library marker davegut.ST-Communications, line 51
httpCode: "Timeout", // library marker davegut.ST-Communications, line 52
errorMsg: error] // library marker davegut.ST-Communications, line 53
} // library marker davegut.ST-Communications, line 54
} // library marker davegut.ST-Communications, line 55
return respData // library marker davegut.ST-Communications, line 56
} // library marker davegut.ST-Communications, line 57
private syncPost(sendData){ // library marker davegut.ST-Communications, line 59
def respData = [:] // library marker davegut.ST-Communications, line 60
if (!stApiKey || stApiKey.trim() == "") { // library marker davegut.ST-Communications, line 61
respData << [status: "FAILED", // library marker davegut.ST-Communications, line 62
errorMsg: "No stApiKey"] // library marker davegut.ST-Communications, line 63
} else { // library marker davegut.ST-Communications, line 64
logDebug("syncPost: ${sendData}") // library marker davegut.ST-Communications, line 65
def cmdBody = [commands: [sendData.cmdData]] // library marker davegut.ST-Communications, line 67
def sendCmdParams = [ // library marker davegut.ST-Communications, line 68
uri: "https://api.smartthings.com/v1", // library marker davegut.ST-Communications, line 69
path: sendData.path, // library marker davegut.ST-Communications, line 70
headers: ['Authorization': 'Bearer ' + stApiKey.trim()], // library marker davegut.ST-Communications, line 71
body : new groovy.json.JsonBuilder(cmdBody).toString() // library marker davegut.ST-Communications, line 72
] // library marker davegut.ST-Communications, line 73
try { // library marker davegut.ST-Communications, line 74
httpPost(sendCmdParams) {resp -> // library marker davegut.ST-Communications, line 75
if (resp.status == 200 && resp.data != null) { // library marker davegut.ST-Communications, line 76
respData << [status: "OK", results: resp.data.results] // library marker davegut.ST-Communications, line 77
} else { // library marker davegut.ST-Communications, line 78
respData << [status: "FAILED", // library marker davegut.ST-Communications, line 79
httpCode: resp.status, // library marker davegut.ST-Communications, line 80
errorMsg: resp.errorMessage] // library marker davegut.ST-Communications, line 81
} // library marker davegut.ST-Communications, line 82
} // library marker davegut.ST-Communications, line 83
} catch (error) { // library marker davegut.ST-Communications, line 84
respData << [status: "FAILED", // library marker davegut.ST-Communications, line 85
httpCode: "Timeout", // library marker davegut.ST-Communications, line 86
errorMsg: error] // library marker davegut.ST-Communications, line 87
} // library marker davegut.ST-Communications, line 88
} // library marker davegut.ST-Communications, line 89
return respData // library marker davegut.ST-Communications, line 90
} // library marker davegut.ST-Communications, line 91
// ~~~~~ end include (1091) davegut.ST-Communications ~~~~~
// ~~~~~ start include (1090) davegut.ST-Common ~~~~~
library ( // library marker davegut.ST-Common, line 1
name: "ST-Common", // library marker davegut.ST-Common, line 2
namespace: "davegut", // library marker davegut.ST-Common, line 3
author: "Dave Gutheinz", // library marker davegut.ST-Common, line 4
description: "ST Wash/Dryer Common Methods", // library marker davegut.ST-Common, line 5
category: "utilities", // library marker davegut.ST-Common, line 6
documentationLink: "" // library marker davegut.ST-Common, line 7
) // library marker davegut.ST-Common, line 8
def commonUpdate() { // library marker davegut.ST-Common, line 10
if (!stApiKey || stApiKey == "") { // library marker davegut.ST-Common, line 11
return [status: "FAILED", reason: "No stApiKey"] // library marker davegut.ST-Common, line 12
} // library marker davegut.ST-Common, line 13
if (!stDeviceId || stDeviceId == "") { // library marker davegut.ST-Common, line 14
getDeviceList() // library marker davegut.ST-Common, line 15
return [status: "FAILED", reason: "No stDeviceId"] // library marker davegut.ST-Common, line 16
} // library marker davegut.ST-Common, line 17
unschedule() // library marker davegut.ST-Common, line 19
def updateData = [:] // library marker davegut.ST-Common, line 20
updateData << [status: "OK"] // library marker davegut.ST-Common, line 21
if (debugLog) { runIn(1800, debugLogOff) } // library marker davegut.ST-Common, line 22
updateData << [stDeviceId: stDeviceId] // library marker davegut.ST-Common, line 23
updateData << [debugLog: debugLog, infoLog: infoLog] // library marker davegut.ST-Common, line 24
if (!getDataValue("driverVersion") || // library marker davegut.ST-Common, line 25
getDataValue("driverVersion") != driverVer()) { // library marker davegut.ST-Common, line 26
updateDataValue("driverVersion", driverVer()) // library marker davegut.ST-Common, line 27
updateData << [driverVer: driverVer()] // library marker davegut.ST-Common, line 28
} // library marker davegut.ST-Common, line 29
setPollInterval(pollInterval) // library marker davegut.ST-Common, line 30
updateData << [pollInterval: pollInterval] // library marker davegut.ST-Common, line 31
runIn(5, refresh) // library marker davegut.ST-Common, line 33
return updateData // library marker davegut.ST-Common, line 34
} // library marker davegut.ST-Common, line 35
def setPollInterval(pollInterval) { // library marker davegut.ST-Common, line 37
logDebug("setPollInterval: ${pollInterval}") // library marker davegut.ST-Common, line 38
state.pollInterval = pollInterval // library marker davegut.ST-Common, line 39
switch(pollInterval) { // library marker davegut.ST-Common, line 40
case "10sec": // library marker davegut.ST-Common, line 41
schedule("*/10 * * * * ?", "poll") // library marker davegut.ST-Common, line 42
break // library marker davegut.ST-Common, line 43
case "20sec": // library marker davegut.ST-Common, line 44
schedule("*/20 * * * * ?", "poll") // library marker davegut.ST-Common, line 45
break // library marker davegut.ST-Common, line 46
case "30sec": // library marker davegut.ST-Common, line 47
schedule("*/30 * * * * ?", "poll") // library marker davegut.ST-Common, line 48
break // library marker davegut.ST-Common, line 49
case "1" : runEvery1Minute(poll); break // library marker davegut.ST-Common, line 50
case "5" : runEvery5Minutes(poll); break // library marker davegut.ST-Common, line 51
case "10" : runEvery10Minutes(poll); break // library marker davegut.ST-Common, line 52
case "30" : runEvery30Minutes(poll); break // library marker davegut.ST-Common, line 53
default: runEvery10Minutes(poll) // library marker davegut.ST-Common, line 54
} // library marker davegut.ST-Common, line 55
} // library marker davegut.ST-Common, line 56
def deviceCommand(cmdData) { // library marker davegut.ST-Common, line 58
def respData = [:] // library marker davegut.ST-Common, line 59
if (simulate() == true) { // library marker davegut.ST-Common, line 60
respData = testResp(cmdData) // library marker davegut.ST-Common, line 61
} else if (!stDeviceId || stDeviceId.trim() == "") { // library marker davegut.ST-Common, line 62
respData << [status: "FAILED", data: "no stDeviceId"] // library marker davegut.ST-Common, line 63
} else { // library marker davegut.ST-Common, line 64
def sendData = [ // library marker davegut.ST-Common, line 65
path: "/devices/${stDeviceId.trim()}/commands", // library marker davegut.ST-Common, line 66
cmdData: cmdData // library marker davegut.ST-Common, line 67
] // library marker davegut.ST-Common, line 68
respData = syncPost(sendData) // library marker davegut.ST-Common, line 69
} // library marker davegut.ST-Common, line 70
if (cmdData.capability && cmdData.capability != "refresh") { // library marker davegut.ST-Common, line 71
refresh() // library marker davegut.ST-Common, line 72
} else { // library marker davegut.ST-Common, line 73
poll() // library marker davegut.ST-Common, line 74
} // library marker davegut.ST-Common, line 75
return respData // library marker davegut.ST-Common, line 76
} // library marker davegut.ST-Common, line 77
def refresh() { // library marker davegut.ST-Common, line 79
if (stApiKey!= null) { // library marker davegut.ST-Common, line 80
def cmdData = [ // library marker davegut.ST-Common, line 81
component: "main", // library marker davegut.ST-Common, line 82
capability: "refresh", // library marker davegut.ST-Common, line 83
command: "refresh", // library marker davegut.ST-Common, line 84
arguments: []] // library marker davegut.ST-Common, line 85
deviceCommand(cmdData) // library marker davegut.ST-Common, line 86
} // library marker davegut.ST-Common, line 87
} // library marker davegut.ST-Common, line 88
def poll() { // library marker davegut.ST-Common, line 90
if (simulate() == true) { // library marker davegut.ST-Common, line 91
def children = getChildDevices() // library marker davegut.ST-Common, line 92
if (children) { // library marker davegut.ST-Common, line 93
children.each { // library marker davegut.ST-Common, line 94
it.statusParse(testData()) // library marker davegut.ST-Common, line 95
} // library marker davegut.ST-Common, line 96
} // library marker davegut.ST-Common, line 97
statusParse(testData()) // library marker davegut.ST-Common, line 98
} else if (!stDeviceId || stDeviceId.trim() == "") { // library marker davegut.ST-Common, line 99
respData = "[status: FAILED, data: no stDeviceId]" // library marker davegut.ST-Common, line 100
logWarn("poll: [status: ERROR, errorMsg: no stDeviceId]") // library marker davegut.ST-Common, line 101
} else { // library marker davegut.ST-Common, line 102
def sendData = [ // library marker davegut.ST-Common, line 103
path: "/devices/${stDeviceId.trim()}/status", // library marker davegut.ST-Common, line 104
parse: "distResp" // library marker davegut.ST-Common, line 105
] // library marker davegut.ST-Common, line 106
asyncGet(sendData, "statusParse") // library marker davegut.ST-Common, line 107
} // library marker davegut.ST-Common, line 108
} // library marker davegut.ST-Common, line 109
def deviceSetup() { // library marker davegut.ST-Common, line 111
if (simulate() == true) { // library marker davegut.ST-Common, line 112
def children = getChildDevices() // library marker davegut.ST-Common, line 113
deviceSetupParse(testData()) // library marker davegut.ST-Common, line 114
} else if (!stDeviceId || stDeviceId.trim() == "") { // library marker davegut.ST-Common, line 115
respData = "[status: FAILED, data: no stDeviceId]" // library marker davegut.ST-Common, line 116
logWarn("poll: [status: ERROR, errorMsg: no stDeviceId]") // library marker davegut.ST-Common, line 117
} else { // library marker davegut.ST-Common, line 118
def sendData = [ // library marker davegut.ST-Common, line 119
path: "/devices/${stDeviceId.trim()}/status", // library marker davegut.ST-Common, line 120
parse: "distResp" // library marker davegut.ST-Common, line 121
] // library marker davegut.ST-Common, line 122
asyncGet(sendData, "deviceSetup") // library marker davegut.ST-Common, line 123
} // library marker davegut.ST-Common, line 124
} // library marker davegut.ST-Common, line 125
def getDeviceList() { // library marker davegut.ST-Common, line 127
def sendData = [ // library marker davegut.ST-Common, line 128
path: "/devices", // library marker davegut.ST-Common, line 129
parse: "getDeviceListParse" // library marker davegut.ST-Common, line 130
] // library marker davegut.ST-Common, line 131
asyncGet(sendData) // library marker davegut.ST-Common, line 132
} // library marker davegut.ST-Common, line 133
def getDeviceListParse(resp, data) { // library marker davegut.ST-Common, line 135
def respData // library marker davegut.ST-Common, line 136
if (resp.status != 200) { // library marker davegut.ST-Common, line 137
respData = [status: "ERROR", // library marker davegut.ST-Common, line 138
httpCode: resp.status, // library marker davegut.ST-Common, line 139
errorMsg: resp.errorMessage] // library marker davegut.ST-Common, line 140
} else { // library marker davegut.ST-Common, line 141
try { // library marker davegut.ST-Common, line 142
respData = new JsonSlurper().parseText(resp.data) // library marker davegut.ST-Common, line 143
} catch (err) { // library marker davegut.ST-Common, line 144
respData = [status: "ERROR", // library marker davegut.ST-Common, line 145
errorMsg: err, // library marker davegut.ST-Common, line 146
respData: resp.data] // library marker davegut.ST-Common, line 147
} // library marker davegut.ST-Common, line 148
} // library marker davegut.ST-Common, line 149
if (respData.status == "ERROR") { // library marker davegut.ST-Common, line 150
logWarn("getDeviceListParse: ${respData}") // library marker davegut.ST-Common, line 151
} else { // library marker davegut.ST-Common, line 152
log.info "" // library marker davegut.ST-Common, line 153
respData.items.each { // library marker davegut.ST-Common, line 154
log.trace "${it.label}: ${it.deviceId}" // library marker davegut.ST-Common, line 155
} // library marker davegut.ST-Common, line 156
log.trace "<b>Copy your device's deviceId value and enter into the device Preferences.</b>" // library marker davegut.ST-Common, line 157
} // library marker davegut.ST-Common, line 158
} // library marker davegut.ST-Common, line 159
def calcTimeRemaining(completionTime) { // library marker davegut.ST-Common, line 161
Integer currTime = now() // library marker davegut.ST-Common, line 162
Integer compTime // library marker davegut.ST-Common, line 163
try { // library marker davegut.ST-Common, line 164
compTime = Date.parse("yyyy-MM-dd'T'HH:mm:ss'Z'", completionTime,TimeZone.getTimeZone('UTC')).getTime() // library marker davegut.ST-Common, line 165
} catch (e) { // library marker davegut.ST-Common, line 166
compTime = Date.parse("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'", completionTime,TimeZone.getTimeZone('UTC')).getTime() // library marker davegut.ST-Common, line 167
} // library marker davegut.ST-Common, line 168
Integer timeRemaining = ((compTime-currTime) /1000).toInteger() // library marker davegut.ST-Common, line 169
if (timeRemaining < 0) { timeRemaining = 0 } // library marker davegut.ST-Common, line 170
return timeRemaining // library marker davegut.ST-Common, line 171
} // library marker davegut.ST-Common, line 172
// ~~~~~ end include (1090) davegut.ST-Common ~~~~~