5 eventAppList = [] # This list maps App1 or App2 to a specific event
7 eventVarCounterMap = {}
15 # Mapping for event type and number of events
16 # e.g., switch has 2 events: on and off
17 eventTypeCounterMap = {'lock': 2,
31 'thermostatFanMode' : 5,
32 'thermostatOperatingState' : 5,
45 'colorTemperature' : 1,
56 'trackDescription' : 1,
60 'heatingSetpoint' : 1,
61 'coolingSetpoint' : 1,
62 'thermostatSetpoint' : 1,
65 'consumableStatus' : 1,
73 'soundPressureLevel' : 1,
75 'ultravioletIndex': 1,
80 # Mapping for specific event types
81 eventTypesMap = {'alarm.both': 'alarm',
82 'alarm.siren' : 'alarm',
83 'alarm.strobe' : 'alarm',
84 'alarm.off' : 'alarm',
85 'contact.open' : 'contact',
86 'contact.closed' : 'contact',
87 'tamper.tampered' : 'contact',
88 'doorState.open' : 'doorState',
89 'doorState.closed' : 'doorState',
90 'position' : 'location',
92 'mode.away' : 'location',
93 'mode.home' : 'location',
94 'mode.night' : 'location',
95 'lock.locked' : 'lock',
96 'lock.unlocked' : 'lock',
97 'motion.active' : 'motion',
98 'motion.inactive' : 'motion',
99 'status.playing' : 'status',
100 'status.stopped' : 'status',
101 'status.paused' : 'status',
102 'mute.muted' : 'mute',
103 'mute.unmuted' : 'mute',
104 'presence.present' : 'presence',
105 'presence.not present' : 'presence',
106 'presence.not' : 'presence',
107 'smoke.detected' : 'smoke',
108 'smoke.clear' : 'smoke',
109 'smoke.tested' : 'smoke',
110 'carbonMonoxide.detected' : 'carbonMonoxide',
111 'carbonMonoxide.clear' : 'carbonMonoxide',
112 'carbonMonoxide.tested' : 'carbonMonoxide',
113 'thermostatMode.cool' : 'thermostatMode',
114 'thermostatMode.auto' : 'thermostatMode',
115 'thermostatMode.emergencyHeat' : 'thermostatMode',
116 'thermostatMode.heat' : 'thermostatMode',
117 'thermostatMode.off' : 'thermostatMode',
118 'thermostatFanMode.auto' : 'thermostatFanMode',
119 'thermostatFanMode.fanCirculate' : 'thermostatFanMode',
120 'thermostatFanMode.circulate' : 'thermostatFanMode',
121 'thermostatFanMode.fanOn' : 'thermostatFanMode',
122 'thermostatFanMode.on' : 'thermostatFanMode',
123 'fanMode' : 'thermostatFanMode',
124 'fanMode.auto' : 'thermostatFanMode',
125 'fanMode.fanCirculate' : 'thermostatFanMode',
126 'fanMode.circulate' : 'thermostatFanMode',
127 'fanMode.fanOn' : 'thermostatFanMode',
128 'fanMode.on' : 'thermostatFanMode',
129 'switch.on' : 'switch',
130 'switch.off' : 'switch',
131 'button.pushed' : 'button',
132 'button.held' : 'button',
133 'acceleration.active' : 'acceleration',
134 'acceleration.inactive' : 'acceleration',
135 'sleeping.sleeping' : 'sleeping',
136 'sleeping.not sleeping' : 'sleeping',
137 'water.dry' : 'water',
138 'water.wet' : 'water'}
143 Skip = ['\n', '\t', ' ']
144 Special = ["(", "\"", ":", ",", "{", "}", ")", "/", "*"]
170 def ExtractFunctions(F, appName):
177 while (Temp != "EOF"):
178 if (Temp == "def" or Temp == "private"):
180 if (Temp == "def" or Temp == "private"):
183 if (GetToken(F) == "("): #We have a function to create object for
184 if (appName == "App1"):
185 extractedFunctionsApp1.write("//Global Object for functions in subscribe method!\n")
186 extractedFunctionsApp1.write("def %s = this.&" % NameofFunc)
187 extractedFunctionsApp1.write("%s\n" % NameofFunc)
189 extractedFunctionsApp2.write("//Global Object for functions in subscribe method!\n")
190 extractedFunctionsApp2.write("def %s = this.&" % NameofFunc)
191 extractedFunctionsApp2.write("%s\n" % NameofFunc)
193 #Check subscribed events
194 if (Temp == "initialize" or Temp == "installed"):
198 # If it is a schedule function, then extract the scheduled method and put it as one of the events
199 if (Temp == "schedule"):
200 eventList.append("schedule")
201 if (appName == "App1"):
202 eventAppList.append("App1")
204 eventAppList.append("App2")
208 # If this is a " then get the next one still---we are interested in the scheduled function name
211 # Insert function name into the map
212 if "schedule" in eventVarMap.keys():
213 listOfEvents = eventVarMap["schedule"]
214 listOfEvents.append(Temp)
216 eventVarMap["schedule"] = [Temp]
218 #Check input capability
219 if (Temp == "input"):
222 variable = GetToken(F)
223 Temp = GetToken(F) #Get '"'
224 Temp = GetToken(F) #Get ','
227 capability = GetToken(F)
228 capabilityMap[variable] = capability
230 #Check subscribed events
231 if (Temp == "subscribe"):
232 if (appName == "App1"):
240 while (Temp != "\"" and Temp != "app" and Temp != "location"):
242 if Temp == "location":
243 # See if we have another case for location
244 Temp = GetToken(F) # Get ','
245 Temp = GetToken(F) # Get '"'
249 # This is the special case where we will see, e.g., sunset, sunrise, etc.
254 #print "DEBUG: %s - %s" % (variable, Temp)
256 #print "DEBUG: location variable: %s" % Temp
258 #This is a bogus event, just skip it...
261 #Translate and reduce through mapping
262 if Temp in eventTypesMap.keys():
263 Temp = eventTypesMap[Temp]
264 if Temp == "app" or Temp == "location" or Temp == "mode" or Temp == "sunset" or Temp == "sunrise" or Temp == "sunsetTime" or Temp == "sunriseTime":
265 if Temp not in eventList:
266 eventList.append(Temp)
267 if (appName == "App1"):
268 eventAppList.append("App1")
270 eventAppList.append("App2")
271 elif Temp not in eventList or (variable in capabilityMap.keys() and capabilityMap[variable] not in capabilityList):
272 # We do not repeat the same capability twice
273 capability = capabilityMap[variable]
274 capabilityList.append(capability)
275 eventList.append(Temp)
276 if (appName == "App1"):
277 eventAppList.append("App1")
279 eventAppList.append("App2")
280 if Temp in eventVarMap.keys():
281 listOfEvents = eventVarMap[Temp]
282 listOfEvents.append(variable)
284 eventVarMap[Temp] = [variable]
285 #print "DEBUG: %s - %s" % (variable, Temp)
289 #Check and analyze capabilities for physical interaction
290 AnalyzeCapabilities(Temp, appName, F)
294 #Warn if there is a potential for physical interaction
295 AnalyzePhysicalInteraction(app1Capabilities, app2Capabilities)
296 AnalyzePhysicalInteraction(app2Capabilities, app1Capabilities)
298 def AnalyzeCapabilities(Temp, appName, F):
300 if (Temp == "capability.switch" or
301 Temp == "capability.switchLevel" or
302 Temp == "capability.illuminanceMeasurement" or
303 Temp == "capability.colorControl" or
304 Temp == "capability.colorTemperature" or
306 Temp == "capability.motionSensor" or
307 Temp == "capability.accelerationSensor" or
309 Temp == "capability.valve" or
310 Temp == "capability.waterSensor" or
312 Temp == "capability.musicPlayer" or
313 Temp == "capability.alarm" or
314 Temp == "capability.speechSynthesis" or
315 Temp == "capability.soundSensor"):
316 if (appName == "App1"):
317 app1Capabilities.append(Temp)
319 app2Capabilities.append(Temp)
320 if (Temp == "capability"):
321 Temp = GetToken(F) #Get '"'
322 Temp = GetToken(F) #Get 'Music'
323 Temp = Temp + GetToken(F) #Get 'Player'
324 if (Temp == "MusicPlayer"):
325 if (appName == "App1"):
326 app1Capabilities.append("capability.musicPlayer")
328 app2Capabilities.append("capability.musicPlayer")
330 def AnalyzePhysicalInteraction(app1Capab, app2Capab):
332 if ("capability.illuminanceMeasurement" in app1Capab) and ("capability.switch" in app2Capab or
333 "capability.switchLevel" in app2Capab or "capability.colorControl" or "capability.colorTemperature" in app2Capab):
334 print ("\nWARNING: Potential PHYSICAL CONFLICT (light) detected between App1 and App2!\n")
336 # TODO: Technically this is not entirely precise since we need to be able to detect that the other app creates motion
337 if ("capability.motionSensor" in app1Capab) or ("capability.accelerationSensor" in app1Capab):
338 print ("\nWARNING: Potential PHYSICAL CONFLICT (motion) detected between App1 and App2!\n")
340 if ("capability.waterSensor" in app1Capab) and ("capability.valve" in app2Capab or
341 "capability.switch" in app2Capab):
342 print ("\nWARNING: Potential PHYSICAL CONFLICT (water) detected between App1 and App2!\n")
344 if ("capability.soundSensor" in app1Capab) and ("capability.musicPlayer" in app2Capab or
345 "capability.alarm" in app2Capab or "capability.speechSynthesis" in app2Capab):
346 print ("\nWARNING: Potential PHYSICAL CONFLICT (sound) detected between App1 and App2!\n")
350 numOfActualEvents = 0
351 #print "DEBUG: eventlist: %d" % len(eventList)
352 #print "DEBUG: eventlist: %s" % eventList
353 for event in eventList:
354 print("DEBUG: Event: %s %d" % (event, eventTypeCounterMap[event]))
355 numOfActualEvents = numOfActualEvents + eventTypeCounterMap[event]
356 return numOfActualEvents
358 def ExtractEvents(extractedEvents):
363 global eventVarCounterMap
364 # Count the number of events
365 numOfActualEvents = CountEvents()
366 extractedEvents.write("while(true) {\n")
367 # We use Verify.getIntFromList() instead of Verify.getInt() since we want to manipulate the
368 # choices in the list/set to implement POR
369 #extractedEvents.write("\tdef eventNumber = Verify.getInt(0,%d)\n" % (numOfActualEvents - 1))
370 extractedEvents.write("\tdef eventNumber = Verify.getIntFromList(0,")
371 for x in range (1, numOfActualEvents - 1):
372 extractedEvents.write("%d," % x)
373 extractedEvents.write("%d)\n" % (numOfActualEvents - 1))
374 extractedEvents.write("\tswitch(eventNumber) {\n")
377 if "App2" in eventAppList:
378 indexApp2 = eventAppList.index("App2")
380 indexApp2 = len(eventList)
381 indexApp2Start = indexApp2
382 #print "DEBUG: App1: %d" % indexApp1
383 #print "DEBUG: App2: %d" % indexApp2
384 #print "DEBUG: eventList: %d" % len(eventList)
389 if indexApp2Start > 0:
393 while counter < numOfActualEvents:
394 # Interleave events from App1 and App2
397 indexApp1 = indexApp1 + 1
398 if indexApp2 < len(eventList):
402 indexApp2 = indexApp2 + 1
403 if indexApp1 < indexApp2Start:
405 #print "DEBUG: i: %d" % i
406 extractedEvents.write("\t\tcase %d:\n" % counter)
407 if eventList[i] == "schedule":
408 variable = eventVarMap[eventList[i]]
409 if eventList[i] not in eventVarCounterMap.keys():
410 eventVarCounterMap[eventList[i]] = 1
413 eventVarCount = eventVarCounterMap[eventList[i]]
414 eventVarCounterMap[eventList[i]] = eventVarCount + 1
415 currentMethod = variable[eventVarCount]
416 extractedEvents.write("\t\t\t// Scheduled method in installed() or intialize()\n")
417 extractedEvents.write("\t\t\t%s.%s()" % (eventAppList[i].lower(), currentMethod))
418 elif eventList[i] == "lock":
419 #Write two events subsequently
420 event = open("eventSimulator/lockLockedEvent.groovy", "r")
422 extractedEvents.write(line)
424 extractedEvents.write("\n\t\t\tbreak\n")
425 counter = counter + 1
426 extractedEvents.write("\t\tcase %d:\n" % counter)
427 event = open("eventSimulator/lockUnlockedEvent.groovy", "r")
429 extractedEvents.write(line)
431 elif eventList[i] == "nfcTouch":
432 event = open("eventSimulator/nfcTouchEvent.groovy", "r")
434 extractedEvents.write(line)
436 elif eventList[i] == "app": #Case for Touched event
437 event = open("eventSimulator/appTouchEvent.groovy", "r")
439 extractedEvents.write(line)
441 elif eventList[i] == "button":
442 #Check which capability
443 variable = eventVarMap[eventList[i]]
444 if eventList[i] not in eventVarCounterMap.keys():
445 eventVarCounterMap[eventList[i]] = 1
448 eventVarCount = eventVarCounterMap[eventList[i]]
449 eventVarCounterMap[eventList[i]] = eventVarCount + 1
450 capability = capabilityMap[variable[eventVarCount]]
451 #Write two events subsequently
452 if capability == "capability.button":
453 event = open("eventSimulator/buttonHeldEvent.groovy", "r")
454 elif capability == "device.aeonKeyFob":
455 event = open("eventSimulator/aeonKeyFobHeldEvent.groovy", "r")
457 extractedEvents.write(line)
459 extractedEvents.write("\n\t\t\tbreak\n")
460 counter = counter + 1
461 extractedEvents.write("\t\tcase %d:\n" % counter)
462 if capability == "capability.button":
463 event = open("eventSimulator/buttonPushedEvent.groovy", "r")
464 elif capability == "device.aeonKeyFob":
465 event = open("eventSimulator/aeonKeyFobPushedEvent.groovy", "r")
467 extractedEvents.write(line)
469 elif eventList[i] == "water":
470 #Write two events subsequently
471 event = open("eventSimulator/waterDryEvent.groovy", "r")
473 extractedEvents.write(line)
475 extractedEvents.write("\n\t\t\tbreak\n")
476 counter = counter + 1
477 extractedEvents.write("\t\tcase %d:\n" % counter)
478 event = open("eventSimulator/waterWetEvent.groovy", "r")
480 extractedEvents.write(line)
482 elif eventList[i] == "presence":
483 #Check which capability
484 variable = eventVarMap[eventList[i]]
485 if eventList[i] not in eventVarCounterMap.keys():
486 eventVarCounterMap[eventList[i]] = 1
489 eventVarCount = eventVarCounterMap[eventList[i]]
490 eventVarCounterMap[eventList[i]] = eventVarCount + 1
491 capability = capabilityMap[variable[eventVarCount]]
492 #Write two events subsequently
493 if capability == "capability.presenceSensor":
494 event = open("eventSimulator/presencePresentEvent.groovy", "r")
495 elif capability == "capability.beacon":
496 event = open("eventSimulator/beaconPresentEvent.groovy", "r")
498 extractedEvents.write(line)
500 extractedEvents.write("\n\t\t\tbreak\n")
501 counter = counter + 1
502 extractedEvents.write("\t\tcase %d:\n" % counter)
503 if capability == "capability.presenceSensor":
504 event = open("eventSimulator/presenceLeftEvent.groovy", "r")
505 elif capability == "capability.beacon":
506 event = open("eventSimulator/beaconLeftEvent.groovy", "r")
508 extractedEvents.write(line)
510 elif eventList[i] == "doorState":
511 #Write two events subsequently
512 event = open("eventSimulator/doorOpenEvent.groovy", "r")
514 extractedEvents.write(line)
516 extractedEvents.write("\n\t\t\tbreak\n")
517 counter = counter + 1
518 extractedEvents.write("\t\tcase %d:\n" % counter)
519 event = open("eventSimulator/doorClosedEvent.groovy", "r")
521 extractedEvents.write(line)
523 elif eventList[i] == "motion":
524 #Write two events subsequently
525 event = open("eventSimulator/motionActiveEvent.groovy", "r")
527 extractedEvents.write(line)
529 extractedEvents.write("\n\t\t\tbreak\n")
530 counter = counter + 1
531 extractedEvents.write("\t\tcase %d:\n" % counter)
532 event = open("eventSimulator/motionInactiveEvent.groovy", "r")
534 extractedEvents.write(line)
536 elif eventList[i] == "smoke":
537 #Write three events subsequently
538 event = open("eventSimulator/smokeClearEvent.groovy", "r")
540 extractedEvents.write(line)
542 extractedEvents.write("\n\t\t\tbreak\n")
543 counter = counter + 1
544 extractedEvents.write("\t\tcase %d:\n" % counter)
545 event = open("eventSimulator/smokeDetectedEvent.groovy", "r")
547 extractedEvents.write(line)
549 extractedEvents.write("\n\t\t\tbreak\n")
550 counter = counter + 1
551 extractedEvents.write("\t\tcase %d:\n" % counter)
552 event = open("eventSimulator/smokeTestedEvent.groovy", "r")
554 extractedEvents.write(line)
556 elif eventList[i] == "carbonMonoxide":
557 #Check which capability
558 variable = eventVarMap[eventList[i]]
559 if eventList[i] not in eventVarCounterMap.keys():
560 eventVarCounterMap[eventList[i]] = 1
563 eventVarCount = eventVarCounterMap[eventList[i]]
564 eventVarCounterMap[eventList[i]] = eventVarCount + 1
565 capability = capabilityMap[variable[eventVarCount]]
566 #Write three events subsequently
567 if capability == "capability.smokeDetector":
568 event = open("eventSimulator/smokeCarbonMonoxideClearEvent.groovy", "r")
569 elif capability == "capability.carbonMonoxideDetector":
570 event = open("eventSimulator/carbonMonoxideClearEvent.groovy", "r")
572 extractedEvents.write(line)
574 extractedEvents.write("\n\t\t\tbreak\n")
575 counter = counter + 1
576 extractedEvents.write("\t\tcase %d:\n" % counter)
577 if capability == "capability.smokeDetector":
578 event = open("eventSimulator/smokeCarbonMonoxideDetectedEvent.groovy", "r")
579 elif capability == "capability.carbonMonoxideDetector":
580 event = open("eventSimulator/carbonMonoxideDetectedEvent.groovy", "r")
582 extractedEvents.write(line)
584 extractedEvents.write("\n\t\t\tbreak\n")
585 counter = counter + 1
586 extractedEvents.write("\t\tcase %d:\n" % counter)
587 if capability == "capability.smokeDetector":
588 event = open("eventSimulator/smokeCarbonMonoxideTestedEvent.groovy", "r")
589 elif capability == "capability.carbonMonoxideDetector":
590 event = open("eventSimulator/carbonMonoxideTestedEvent.groovy", "r")
592 extractedEvents.write(line)
594 elif eventList[i] == "battery":
595 #Check which capability
596 variable = eventVarMap[eventList[i]]
597 if eventList[i] not in eventVarCounterMap.keys():
598 eventVarCounterMap[eventList[i]] = 1
601 eventVarCount = eventVarCounterMap[eventList[i]]
602 eventVarCounterMap[eventList[i]] = eventVarCount + 1
603 capability = capabilityMap[variable[eventVarCount]]
604 if capability == "capability.smokeDetector":
605 event = open("eventSimulator/smokeDetectorBatteryEvent.groovy", "r")
606 elif capability == "capability.battery":
607 event = open("eventSimulator/batteryBatteryEvent.groovy", "r")
609 extractedEvents.write(line)
611 elif eventList[i] == "thermostatMode":
612 #Write five events subsequently
613 event = open("eventSimulator/thermostatAutoModeEvent.groovy", "r")
615 extractedEvents.write(line)
617 extractedEvents.write("\n\t\t\tbreak\n")
618 counter = counter + 1
619 extractedEvents.write("\t\tcase %d:\n" % counter)
620 event = open("eventSimulator/thermostatCoolModeEvent.groovy", "r")
622 extractedEvents.write(line)
624 extractedEvents.write("\n\t\t\tbreak\n")
625 counter = counter + 1
626 extractedEvents.write("\t\tcase %d:\n" % counter)
627 event = open("eventSimulator/thermostatEmergencyHeatModeEvent.groovy", "r")
629 extractedEvents.write(line)
631 extractedEvents.write("\n\t\t\tbreak\n")
632 counter = counter + 1
633 extractedEvents.write("\t\tcase %d:\n" % counter)
634 event = open("eventSimulator/thermostatHeatModeEvent.groovy", "r")
636 extractedEvents.write(line)
638 extractedEvents.write("\n\t\t\tbreak\n")
639 counter = counter + 1
640 extractedEvents.write("\t\tcase %d:\n" % counter)
641 event = open("eventSimulator/thermostatOffModeEvent.groovy", "r")
643 extractedEvents.write(line)
645 elif eventList[i] == "thermostatFanMode":
646 #Write five events subsequently
647 event = open("eventSimulator/thermostatAutoFanModeEvent.groovy", "r")
649 extractedEvents.write(line)
651 extractedEvents.write("\n\t\t\tbreak\n")
652 counter = counter + 1
653 extractedEvents.write("\t\tcase %d:\n" % counter)
654 event = open("eventSimulator/thermostatFanCirculateFanModeEvent.groovy", "r")
656 extractedEvents.write(line)
658 extractedEvents.write("\n\t\t\tbreak\n")
659 counter = counter + 1
660 extractedEvents.write("\t\tcase %d:\n" % counter)
661 event = open("eventSimulator/thermostatCirculateFanModeEvent.groovy", "r")
663 extractedEvents.write(line)
665 extractedEvents.write("\n\t\t\tbreak\n")
666 counter = counter + 1
667 extractedEvents.write("\t\tcase %d:\n" % counter)
668 event = open("eventSimulator/thermostatFanOnFanModeEvent.groovy", "r")
670 extractedEvents.write(line)
672 extractedEvents.write("\n\t\t\tbreak\n")
673 counter = counter + 1
674 extractedEvents.write("\t\tcase %d:\n" % counter)
675 event = open("eventSimulator/thermostatOnFanModeEvent.groovy", "r")
677 extractedEvents.write(line)
679 elif eventList[i] == "thermostatOperatingState":
680 #Write five events subsequently
681 event = open("eventSimulator/thermostatOperatingStateAutoEvent.groovy", "r")
683 extractedEvents.write(line)
685 extractedEvents.write("\n\t\t\tbreak\n")
686 counter = counter + 1
687 extractedEvents.write("\t\tcase %d:\n" % counter)
688 event = open("eventSimulator/thermostatOperatingStateCoolEvent.groovy", "r")
690 extractedEvents.write(line)
692 extractedEvents.write("\n\t\t\tbreak\n")
693 counter = counter + 1
694 extractedEvents.write("\t\tcase %d:\n" % counter)
695 event = open("eventSimulator/thermostatOperatingStateOffEvent.groovy", "r")
697 extractedEvents.write(line)
699 extractedEvents.write("\n\t\t\tbreak\n")
700 counter = counter + 1
701 extractedEvents.write("\t\tcase %d:\n" % counter)
702 event = open("eventSimulator/thermostatOperatingStateEmergencyHeatEvent.groovy", "r")
704 extractedEvents.write(line)
706 extractedEvents.write("\n\t\t\tbreak\n")
707 counter = counter + 1
708 extractedEvents.write("\t\tcase %d:\n" % counter)
709 event = open("eventSimulator/thermostatOperatingStateHeatEvent.groovy", "r")
711 extractedEvents.write(line)
713 elif eventList[i] == "switch":
714 #Check which capability
715 variable = eventVarMap[eventList[i]]
716 if eventList[i] not in eventVarCounterMap.keys():
717 eventVarCounterMap[eventList[i]] = 1
720 eventVarCount = eventVarCounterMap[eventList[i]]
721 eventVarCounterMap[eventList[i]] = eventVarCount + 1
722 capability = capabilityMap[variable[eventVarCount]]
723 #Write two events subsequently
724 if capability == "capability.switch":
725 event = open("eventSimulator/switchOnEvent.groovy", "r")
726 elif capability == "capability.switchLevel":
727 event = open("eventSimulator/switchLevelOnEvent.groovy", "r")
728 elif capability == "capability.relaySwitch":
729 event = open("eventSimulator/relaySwitchOnEvent.groovy", "r")
730 elif capability == "capability.colorControl":
731 event = open("eventSimulator/colorControlSwitchOnEvent.groovy", "r")
732 elif capability == "capability.colorTemperature":
733 event = open("eventSimulator/colorTemperatureSwitchOnEvent.groovy", "r")
735 extractedEvents.write(line)
737 extractedEvents.write("\n\t\t\tbreak\n")
738 counter = counter + 1
739 extractedEvents.write("\t\tcase %d:\n" % counter)
740 if capability == "capability.switch":
741 event = open("eventSimulator/switchOffEvent.groovy", "r")
742 elif capability == "capability.switchLevel":
743 event = open("eventSimulator/switchLevelOffEvent.groovy", "r")
744 elif capability == "capability.relaySwitch":
745 event = open("eventSimulator/relaySwitchOffEvent.groovy", "r")
746 elif capability == "capability.colorControl":
747 event = open("eventSimulator/colorControlSwitchOffEvent.groovy", "r")
748 elif capability == "capability.colorTemperature":
749 event = open("eventSimulator/colorTemperatureSwitchOffEvent.groovy", "r")
751 extractedEvents.write(line)
753 elif eventList[i] == "location": #Case for Location event
754 #Write three events subsequently
755 event = open("eventSimulator/locationHomeEvent.groovy", "r")
757 extractedEvents.write(line)
759 extractedEvents.write("\n\t\t\tbreak\n")
760 counter = counter + 1
761 extractedEvents.write("\t\tcase %d:\n" % counter)
762 event = open("eventSimulator/locationAwayEvent.groovy", "r")
764 extractedEvents.write(line)
766 extractedEvents.write("\n\t\t\tbreak\n")
767 counter = counter + 1
768 extractedEvents.write("\t\tcase %d:\n" % counter)
769 event = open("eventSimulator/locationNightEvent.groovy", "r")
771 extractedEvents.write(line)
773 elif eventList[i] == "sunrise":
774 event = open("eventSimulator/locationSunriseEvent.groovy", "r")
776 extractedEvents.write(line)
778 elif eventList[i] == "sunset":
779 event = open("eventSimulator/locationSunsetEvent.groovy", "r")
781 extractedEvents.write(line)
783 elif eventList[i] == "sunsetTime":
784 event = open("eventSimulator/locationSunsetTimeEvent.groovy", "r")
786 extractedEvents.write(line)
788 elif eventList[i] == "sunriseTime":
789 event = open("eventSimulator/locationSunriseTimeEvent.groovy", "r")
791 extractedEvents.write(line)
793 elif eventList[i] == "acceleration":
794 #Write two events subsequently
795 event = open("eventSimulator/accelerationActiveEvent.groovy", "r")
797 extractedEvents.write(line)
799 extractedEvents.write("\n\t\t\tbreak\n")
800 counter = counter + 1
801 extractedEvents.write("\t\tcase %d:\n" % counter)
802 event = open("eventSimulator/accelerationInactiveEvent.groovy", "r")
804 extractedEvents.write(line)
806 elif eventList[i] == "sleeping":
807 #Write two events subsequently
808 event = open("eventSimulator/sleepSleepingEvent.groovy", "r")
810 extractedEvents.write(line)
812 extractedEvents.write("\n\t\t\tbreak\n")
813 counter = counter + 1
814 extractedEvents.write("\t\tcase %d:\n" % counter)
815 event = open("eventSimulator/sleepNotSleepingEvent.groovy", "r")
817 extractedEvents.write(line)
819 elif eventList[i] == "goal":
820 #Write two events subsequently
821 event = open("eventSimulator/stepGoalHighEvent.groovy", "r")
823 extractedEvents.write(line)
825 extractedEvents.write("\n\t\t\tbreak\n")
826 counter = counter + 1
827 extractedEvents.write("\t\tcase %d:\n" % counter)
828 event = open("eventSimulator/stepGoalLowEvent.groovy", "r")
830 extractedEvents.write(line)
832 elif eventList[i] == "steps":
833 #Write two events subsequently
834 event = open("eventSimulator/stepStepsHighEvent.groovy", "r")
836 extractedEvents.write(line)
838 extractedEvents.write("\n\t\t\tbreak\n")
839 counter = counter + 1
840 extractedEvents.write("\t\tcase %d:\n" % counter)
841 event = open("eventSimulator/stepStepsLowEvent.groovy", "r")
843 extractedEvents.write(line)
845 elif eventList[i] == "color":
846 event = open("eventSimulator/colorChangeEvent.groovy", "r")
848 extractedEvents.write(line)
850 elif eventList[i] == "colorTemperature":
851 event = open("eventSimulator/colorTemperatureEvent.groovy", "r")
853 extractedEvents.write(line)
855 elif eventList[i] == "hue":
856 event = open("eventSimulator/hueChangeEvent.groovy", "r")
858 extractedEvents.write(line)
860 elif eventList[i] == "saturation":
861 event = open("eventSimulator/saturationChangeEvent.groovy", "r")
863 extractedEvents.write(line)
865 elif eventList[i] == "energy":
866 event = open("eventSimulator/energyMeterEvent.groovy", "r")
868 extractedEvents.write(line)
870 elif eventList[i] == "power":
871 #Write two events subsequently
872 event = open("eventSimulator/powerMeterHighPowerEvent.groovy", "r")
874 extractedEvents.write(line)
876 extractedEvents.write("\n\t\t\tbreak\n")
877 counter = counter + 1
878 extractedEvents.write("\t\tcase %d:\n" % counter)
879 event = open("eventSimulator/powerMeterLowPowerEvent.groovy", "r")
881 extractedEvents.write(line)
883 elif eventList[i] == "illuminance":
884 event = open("eventSimulator/illuminanceMeasurementLowEvent.groovy", "r")
886 extractedEvents.write(line)
888 extractedEvents.write("\n\t\t\tbreak\n")
889 counter = counter + 1
890 extractedEvents.write("\t\tcase %d:\n" % counter)
891 event = open("eventSimulator/illuminanceMeasurementHighEvent.groovy", "r")
893 extractedEvents.write(line)
895 elif eventList[i] == "humidity":
896 event = open("eventSimulator/humidityHighMeasurementEvent.groovy", "r")
898 extractedEvents.write(line)
900 extractedEvents.write("\n\t\t\tbreak\n")
901 counter = counter + 1
902 extractedEvents.write("\t\tcase %d:\n" % counter)
903 event = open("eventSimulator/humidityLowMeasurementEvent.groovy", "r")
905 extractedEvents.write(line)
907 elif eventList[i] == "alarm":
908 #Write four events subsequently
909 event = open("eventSimulator/alarmBothEvent.groovy", "r")
911 extractedEvents.write(line)
913 extractedEvents.write("\n\t\t\tbreak\n")
914 counter = counter + 1
915 extractedEvents.write("\t\tcase %d:\n" % counter)
916 event = open("eventSimulator/alarmSirenEvent.groovy", "r")
918 extractedEvents.write(line)
920 extractedEvents.write("\n\t\t\tbreak\n")
921 counter = counter + 1
922 extractedEvents.write("\t\tcase %d:\n" % counter)
923 event = open("eventSimulator/alarmStrobeEvent.groovy", "r")
925 extractedEvents.write(line)
927 extractedEvents.write("\n\t\t\tbreak\n")
928 counter = counter + 1
929 extractedEvents.write("\t\tcase %d:\n" % counter)
930 event = open("eventSimulator/alarmOffEvent.groovy", "r")
932 extractedEvents.write(line)
934 elif eventList[i] == "contact":
935 #Check which capability
936 variable = eventVarMap[eventList[i]]
937 if eventList[i] not in eventVarCounterMap.keys():
938 eventVarCounterMap[eventList[i]] = 1
941 eventVarCount = eventVarCounterMap[eventList[i]]
942 eventVarCounterMap[eventList[i]] = eventVarCount + 1
943 capability = capabilityMap[variable[eventVarCount]]
944 #Write two events subsequently
945 if capability == "capability.contactSensor":
946 event = open("eventSimulator/contactDefaultClosedEvent.groovy", "r")
947 elif capability == "capability.valve":
948 event = open("eventSimulator/valveClosedEvent.groovy", "r")
950 extractedEvents.write(line)
952 extractedEvents.write("\n\t\t\tbreak\n")
953 counter = counter + 1
954 extractedEvents.write("\t\tcase %d:\n" % counter)
955 if capability == "capability.contactSensor":
956 event = open("eventSimulator/contactDefaultOpenEvent.groovy", "r")
957 elif capability == "capability.valve":
958 event = open("eventSimulator/valveOpenEvent.groovy", "r")
960 extractedEvents.write(line)
962 elif eventList[i] == "status":
963 #Write three events subsequently
964 event = open("eventSimulator/musicPlayerPlayingEvent.groovy", "r")
966 extractedEvents.write(line)
968 extractedEvents.write("\n\t\t\tbreak\n")
969 counter = counter + 1
970 extractedEvents.write("\t\tcase %d:\n" % counter)
971 event = open("eventSimulator/musicPlayerStoppedEvent.groovy", "r")
973 extractedEvents.write(line)
975 extractedEvents.write("\n\t\t\tbreak\n")
976 counter = counter + 1
977 extractedEvents.write("\t\tcase %d:\n" % counter)
978 event = open("eventSimulator/musicPlayerPausedEvent.groovy", "r")
980 extractedEvents.write(line)
982 elif eventList[i] == "level":
983 #Check which capability
984 variable = eventVarMap[eventList[i]]
985 if eventList[i] not in eventVarCounterMap.keys():
986 eventVarCounterMap[eventList[i]] = 1
989 eventVarCount = eventVarCounterMap[eventList[i]]
990 eventVarCounterMap[eventList[i]] = eventVarCount + 1
991 capability = capabilityMap[variable[eventVarCount]]
992 if capability == "capability.musicPlayer":
993 event = open("eventSimulator/musicPlayerLevelEvent.groovy", "r")
994 elif capability == "capability.switchLevel":
995 event = open("eventSimulator/switchLevelEvent.groovy", "r")
996 elif capability == "capability.colorControl":
997 event = open("eventSimulator/colorLevelChangeEvent.groovy", "r")
998 elif capability == "capability.switch":
999 event = open("eventSimulator/switchLevelChangeEvent.groovy", "r")
1001 extractedEvents.write(line)
1003 elif eventList[i] == "trackDescription":
1004 event = open("eventSimulator/musicPlayerTrackDescriptionEvent.groovy", "r")
1006 extractedEvents.write(line)
1008 elif eventList[i] == "trackData":
1009 event = open("eventSimulator/musicPlayerTrackDataEvent.groovy", "r")
1011 extractedEvents.write(line)
1013 elif eventList[i] == "mute":
1014 #Write two events subsequently
1015 event = open("eventSimulator/musicPlayerUnmutedEvent.groovy", "r")
1017 extractedEvents.write(line)
1019 extractedEvents.write("\n\t\t\tbreak\n")
1020 counter = counter + 1
1021 extractedEvents.write("\t\tcase %d:\n" % counter)
1022 event = open("eventSimulator/musicPlayerMutedEvent.groovy", "r")
1024 extractedEvents.write(line)
1026 elif eventList[i] == "temperature":
1027 #Check which capability
1028 variable = eventVarMap[eventList[i]]
1029 if eventList[i] not in eventVarCounterMap.keys():
1030 eventVarCounterMap[eventList[i]] = 1
1033 eventVarCount = eventVarCounterMap[eventList[i]]
1034 eventVarCounterMap[eventList[i]] = eventVarCount + 1
1035 capability = capabilityMap[variable[eventVarCount]]
1036 #Write two events subsequently
1037 if capability == "capability.thermostat":
1038 event = open("eventSimulator/temperatureHighEvent.groovy", "r")
1039 elif capability == "capability.temperatureMeasurement":
1040 event = open("eventSimulator/temperatureHighMeasurementEvent.groovy", "r")
1042 extractedEvents.write(line)
1044 extractedEvents.write("\n\t\t\tbreak\n")
1045 counter = counter + 1
1046 extractedEvents.write("\t\tcase %d:\n" % counter)
1047 if capability == "capability.thermostat":
1048 event = open("eventSimulator/temperatureLowEvent.groovy", "r")
1049 elif capability == "capability.temperatureMeasurement":
1050 event = open("eventSimulator/temperatureLowMeasurementEvent.groovy", "r")
1052 extractedEvents.write(line)
1054 elif eventList[i] == "heatingSetpoint":
1055 event = open("eventSimulator/heatingSetpointEvent.groovy", "r")
1057 extractedEvents.write(line)
1059 elif eventList[i] == "coolingSetpoint":
1060 event = open("eventSimulator/coolingSetpointEvent.groovy", "r")
1062 extractedEvents.write(line)
1064 elif eventList[i] == "thermostatSetpoint":
1065 event = open("eventSimulator/thermostatSetpointEvent.groovy", "r")
1067 extractedEvents.write(line)
1069 elif eventList[i] == "threeAxis":
1070 event = open("eventSimulator/threeAxisChangeEvent.groovy", "r")
1072 extractedEvents.write(line)
1074 elif eventList[i] == "carbonDioxide":
1075 event = open("eventSimulator/carbonDioxideEvent.groovy", "r")
1077 extractedEvents.write(line)
1079 elif eventList[i] == "consumableStatus":
1080 event = open("eventSimulator/consumableStatusEvent.groovy", "r")
1082 extractedEvents.write(line)
1084 elif eventList[i] == "pH":
1085 event = open("eventSimulator/pHEvent.groovy", "r")
1087 extractedEvents.write(line)
1089 elif eventList[i] == "pressure":
1090 event = open("eventSimulator/pressureEvent.groovy", "r")
1092 extractedEvents.write(line)
1094 elif eventList[i] == "shock":
1095 event = open("eventSimulator/shockEvent.groovy", "r")
1097 extractedEvents.write(line)
1099 elif eventList[i] == "lqi":
1100 event = open("eventSimulator/lqiEvent.groovy", "r")
1102 extractedEvents.write(line)
1104 elif eventList[i] == "rssi":
1105 event = open("eventSimulator/rssiEvent.groovy", "r")
1107 extractedEvents.write(line)
1109 elif eventList[i] == "sound":
1110 event = open("eventSimulator/soundEvent.groovy", "r")
1112 extractedEvents.write(line)
1114 elif eventList[i] == "soundPressureLevel":
1115 event = open("eventSimulator/soundPressureLevelEvent.groovy", "r")
1117 extractedEvents.write(line)
1119 elif eventList[i] == "tamper":
1120 event = open("eventSimulator/tamperEvent.groovy", "r")
1122 extractedEvents.write(line)
1124 elif eventList[i] == "voltage":
1125 event = open("eventSimulator/voltageEvent.groovy", "r")
1127 extractedEvents.write(line)
1129 elif eventList[i] == "ultravioletIndex":
1130 event = open("eventSimulator/ultravioletIndexEvent.groovy", "r")
1132 extractedEvents.write(line)
1134 elif eventList[i] == "windowShade":
1135 event = open("eventSimulator/windowShadeEvent.groovy", "r")
1137 extractedEvents.write(line)
1140 ###TODO: Add more events later
1141 extractedEvents.write("\n\t\t\tbreak\n")
1142 counter = counter + 1
1143 extractedEvents.write("\t}\n")
1144 extractedEvents.write("\tprintln(\"\\nEVENT NUMBER: \" + eventNumber)\n");
1145 extractedEvents.write("}\n")
1147 def CheckIfOnlyTouchEvents():
1148 #Check and throw an error if it is all touch events
1149 #This is called Direct-Direct interaction and we do not model-check for this case
1150 onlyTouchEvents = True
1151 for item in eventList:
1152 if item != "nfcTouch" and item != "app" and item != "button":
1153 onlyTouchEvents = False
1154 if onlyTouchEvents is True and app1Subscribe is True and app2Subscribe is True:
1155 # Write error log file
1156 extractError = open("appCreationError.log", "w+")
1157 extractError.write("Direct-Direct Interaction detected: we are skipping this pair...\n")
1158 extractError.close()
1159 raise Exception("\n\nDirect-Direct Interaction detected: we are skipping this pair...\n\n")
1162 #Extract objects to call functions from App1
1163 F1 = open("Extractor/App1/App1.groovy", "r")
1164 extractedFunctionsApp1 = open("Extractor/App1/extractedFunctionsApp1.groovy", "w+")
1165 ExtractFunctions(F1, "App1")
1168 #Extract objects to call functions from App2
1169 F2 = open("Extractor/App2/App2.groovy", "r")
1170 extractedFunctionsApp2 = open("Extractor/App2/extractedFunctionsApp2.groovy", "w+")
1171 ExtractFunctions(F2, "App2")
1174 #Prepare eventSimulator file while parsing the App1 and App2 files
1175 extractedEvents = open("eventSimulator/eventSimulator.groovy", "w+")
1176 CheckIfOnlyTouchEvents()
1177 ExtractEvents(extractedEvents)
1178 extractedEvents.close()
1180 #Save the extracted methods and app1 in a same file to extract information
1181 extractorFile = open("Extractor/extractorFile.groovy", "w+")
1182 Extractor = open("Extractor/Extractor.groovy", "r")
1183 F1 = open("Extractor/App1/App1.groovy", "r")
1185 extractorFile.write("////////////////////\n")
1186 extractorFile.write("@Field App\n")
1187 extractorFile.write("App = \"App1\"")
1188 extractorFile.write("\n")
1189 for line in Extractor:
1190 extractorFile.write(line)
1191 extractorFile.write("\n\n")
1193 extractorFile.write(line)
1194 extractorFile.close()
1197 #Run the file to extract the objects
1198 os.system("groovy -classpath lib/jpf.jar Extractor/extractorFile.groovy")
1201 #Save the extracted methods and app2 in a same file to extract information
1202 extractorFile = open("Extractor/extractorFile.groovy", "w+")
1203 Extractor = open("Extractor/Extractor.groovy", "r")
1204 F2 = open("Extractor/App2/App2.groovy", "r")
1206 extractorFile.write("////////////////////\n")
1207 extractorFile.write("@Field App\n")
1208 extractorFile.write("App = \"App2\"")
1209 extractorFile.write("\n")
1210 for line in Extractor:
1211 extractorFile.write(line)
1212 extractorFile.write("\n\n")
1214 extractorFile.write(line)
1215 #Run the file to extract the objects
1216 extractorFile.close()
1219 os.system("groovy -classpath lib/jpf.jar Extractor/extractorFile.groovy")