X-Git-Url: http://plrg.eecs.uci.edu/git/?p=smartthings-infrastructure.git;a=blobdiff_plain;f=Extractor%2FExtractorScript.py;h=e3947bcea00246461b50bb5e39ce58c72eafc579;hp=5d92fc4dd1e315263098affa8265f16f695e4bd1;hb=c02e3b520b797a7e31b25f4a27ec08050912112f;hpb=24689b7c0c3eb6e7405ae89768d8e710b79bcfcf diff --git a/Extractor/ExtractorScript.py b/Extractor/ExtractorScript.py index 5d92fc4..e3947bc 100644 --- a/Extractor/ExtractorScript.py +++ b/Extractor/ExtractorScript.py @@ -15,7 +15,6 @@ app2Subscribe = False # Mapping for event type and number of events # e.g., switch has 2 events: on and off eventTypeCounterMap = {'lock': 2, - 'unlock' : 1, 'nfcTouch' : 1, 'app' : 1, 'button' : 2, @@ -40,16 +39,16 @@ eventTypeCounterMap = {'lock': 2, 'sunriseTime' : 1, 'acceleration' : 2, 'sleeping' : 2, - 'goal' : 1, - 'steps' : 1, + 'goal' : 2, + 'steps' : 2, 'color' : 1, 'colorTemperature' : 1, 'hue' : 1, 'saturation' : 1, 'energy' : 1, - 'power' : 1, - 'illuminance' : 1, - 'humidity' : 1, + 'power' : 2, + 'illuminance' : 2, + 'humidity' : 2, 'alarm' : 4, 'contact' : 2, 'status' : 3, @@ -57,10 +56,26 @@ eventTypeCounterMap = {'lock': 2, 'trackDescription' : 1, 'trackData' : 1, 'mute' : 2, - 'temperature' : 1, + 'temperature' : 2, 'heatingSetpoint' : 1, 'coolingSetpoint' : 1, - 'thermostatSetpoint' : 1} + 'thermostatSetpoint' : 1, + 'threeAxis' : 1, + 'carbonDioxide' : 1, + 'consumableStatus' : 1, + 'pH' : 1, + 'pressure': 1, + 'shock': 1, + 'lqi': 1, + 'rssi': 1, + 'schedule': 1, + 'sound': 1, + 'soundPressureLevel' : 1, + 'tamper' : 1, + 'ultravioletIndex': 1, + 'voltage': 1, + 'windowShade': 1, + 'touched': 1} # Mapping for specific event types eventTypesMap = {'alarm.both': 'alarm', @@ -72,6 +87,7 @@ eventTypesMap = {'alarm.both': 'alarm', 'tamper.tampered' : 'contact', 'doorState.open' : 'doorState', 'doorState.closed' : 'doorState', + 'position' : 'location', 'mode' : 'location', 'mode.away' : 'location', 'mode.home' : 'location', @@ -174,6 +190,31 @@ def ExtractFunctions(F, appName): extractedFunctionsApp2.write("def %s = this.&" % NameofFunc) extractedFunctionsApp2.write("%s\n" % NameofFunc) + #Check subscribed events + if (Temp == "initialize" or Temp == "installed"): + Temp = GetToken(F) + Temp = GetToken(F) + Temp = GetToken(F) + # If it is a schedule function, then extract the scheduled method and put it as one of the events + if (Temp == "schedule"): + eventList.append("schedule") + if (appName == "App1"): + eventAppList.append("App1") + else: + eventAppList.append("App2") + while Temp != ",": + Temp = GetToken(F) + Temp = GetToken(F) + # If this is a " then get the next one still---we are interested in the scheduled function name + if (Temp == "\""): + Temp = GetToken(F) + # Insert function name into the map + if "schedule" in eventVarMap.keys(): + listOfEvents = eventVarMap["schedule"] + listOfEvents.append(Temp) + else: + eventVarMap["schedule"] = [Temp] + #Check input capability if (Temp == "input"): while Temp != "\"": @@ -213,7 +254,10 @@ def ExtractFunctions(F, appName): #print "DEBUG: %s - %s" % (variable, Temp) #print capabilityMap #print "DEBUG: location variable: %s" % Temp - + + #This is a bogus event, just skip it... + if Temp == "unlock": + continue #Translate and reduce through mapping if Temp in eventTypesMap.keys(): Temp = eventTypesMap[Temp] @@ -257,6 +301,7 @@ def AnalyzeCapabilities(Temp, appName, F): Temp == "capability.switchLevel" or Temp == "capability.illuminanceMeasurement" or Temp == "capability.colorControl" or + Temp == "capability.colorTemperature" or #Motion related Temp == "capability.motionSensor" or Temp == "capability.accelerationSensor" or @@ -285,7 +330,7 @@ def AnalyzeCapabilities(Temp, appName, F): def AnalyzePhysicalInteraction(app1Capab, app2Capab): #Light if ("capability.illuminanceMeasurement" in app1Capab) and ("capability.switch" in app2Capab or - "capability.switchLevel" in app2Capab or "capability.colorControl" in app2Capab): + "capability.switchLevel" in app2Capab or "capability.colorControl" or "capability.colorTemperature" in app2Capab): print ("\nWARNING: Potential PHYSICAL CONFLICT (light) detected between App1 and App2!\n") #Motion # TODO: Technically this is not entirely precise since we need to be able to detect that the other app creates motion @@ -306,7 +351,7 @@ def CountEvents(): #print "DEBUG: eventlist: %d" % len(eventList) #print "DEBUG: eventlist: %s" % eventList for event in eventList: - #print "DEBUG: Event: %s %d" % (event, eventTypeCounterMap[event]) + print "DEBUG: Event: %s %d" % (event, eventTypeCounterMap[event]) numOfActualEvents = numOfActualEvents + eventTypeCounterMap[event] return numOfActualEvents @@ -319,7 +364,13 @@ def ExtractEvents(extractedEvents): # Count the number of events numOfActualEvents = CountEvents() extractedEvents.write("while(true) {\n") - extractedEvents.write("\tdef eventNumber = Verify.getInt(0,%d)\n" % (numOfActualEvents - 1)) + # We use Verify.getIntFromList() instead of Verify.getInt() since we want to manipulate the + # choices in the list/set to implement POR + #extractedEvents.write("\tdef eventNumber = Verify.getInt(0,%d)\n" % (numOfActualEvents - 1)) + extractedEvents.write("\tdef eventNumber = Verify.getIntFromList(0,") + for x in range (1, numOfActualEvents - 1): + extractedEvents.write("%d," % x) + extractedEvents.write("%d)\n" % (numOfActualEvents - 1)) extractedEvents.write("\tswitch(eventNumber) {\n") counter = 0 indexApp1 = 0 @@ -331,7 +382,14 @@ def ExtractEvents(extractedEvents): #print "DEBUG: App1: %d" % indexApp1 #print "DEBUG: App2: %d" % indexApp2 #print "DEBUG: eventList: %d" % len(eventList) - isApp1 = True + #print capabilityMap + #print eventVarMap + #print eventAppList + #print eventList + if indexApp2Start > 0: + isApp1 = True + else: + isApp1 = False while counter < numOfActualEvents: # Interleave events from App1 and App2 if isApp1 is True: @@ -346,7 +404,18 @@ def ExtractEvents(extractedEvents): isApp1 = True #print "DEBUG: i: %d" % i extractedEvents.write("\t\tcase %d:\n" % counter) - if eventList[i] == "lock": + if eventList[i] == "schedule": + variable = eventVarMap[eventList[i]] + if eventList[i] not in eventVarCounterMap.keys(): + eventVarCounterMap[eventList[i]] = 1 + eventVarCount = 0 + else: + eventVarCount = eventVarCounterMap[eventList[i]] + eventVarCounterMap[eventList[i]] = eventVarCount + 1 + currentMethod = variable[eventVarCount] + extractedEvents.write("\t\t\t// Scheduled method in installed() or intialize()\n") + extractedEvents.write("\t\t\t%s.%s()" % (eventAppList[i].lower(), currentMethod)) + elif eventList[i] == "lock": #Write two events subsequently event = open("eventSimulator/lockLockedEvent.groovy", "r") for line in event: @@ -359,9 +428,6 @@ def ExtractEvents(extractedEvents): for line in event: extractedEvents.write(line) event.close() - elif eventList[i] == "unlock": - #Don't do anything for this case - counter = counter - 1 elif eventList[i] == "nfcTouch": event = open("eventSimulator/nfcTouchEvent.groovy", "r") for line in event: @@ -455,6 +521,7 @@ def ExtractEvents(extractedEvents): extractedEvents.write(line) event.close() elif eventList[i] == "motion": + print("HERE????") #Write two events subsequently event = open("eventSimulator/motionActiveEvent.groovy", "r") for line in event: @@ -655,6 +722,8 @@ def ExtractEvents(extractedEvents): eventVarCounterMap[eventList[i]] = eventVarCount + 1 capability = capabilityMap[variable[eventVarCount]] #Write two events subsequently + print("//////////////////////") + print(capability) if capability == "capability.switch": event = open("eventSimulator/switchOnEvent.groovy", "r") elif capability == "capability.switchLevel": @@ -737,36 +806,42 @@ def ExtractEvents(extractedEvents): for line in event: extractedEvents.write(line) event.close() - elif eventList[i] == "acceleration.active": - event = open("eventSimulator/accelerationDefaultActiveEvent.groovy", "r") + elif eventList[i] == "sleeping": + #Write two events subsequently + event = open("eventSimulator/sleepSleepingEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() - elif eventList[i] == "acceleration.inactive": - event = open("eventSimulator/accelerationDefaultInactiveEvent.groovy", "r") + extractedEvents.write("\n\t\t\tbreak\n") + counter = counter + 1 + extractedEvents.write("\t\tcase %d:\n" % counter) + event = open("eventSimulator/sleepNotSleepingEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() - elif eventList[i] == "sleeping": + elif eventList[i] == "goal": #Write two events subsequently - event = open("eventSimulator/sleepSleepingEvent.groovy", "r") + event = open("eventSimulator/stepGoalHighEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() extractedEvents.write("\n\t\t\tbreak\n") counter = counter + 1 extractedEvents.write("\t\tcase %d:\n" % counter) - event = open("eventSimulator/sleepNotSleepingEvent.groovy", "r") + event = open("eventSimulator/stepGoalLowEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() - elif eventList[i] == "goal": - event = open("eventSimulator/stepGoalEvent.groovy", "r") + elif eventList[i] == "steps": + #Write two events subsequently + event = open("eventSimulator/stepStepsHighEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() - elif eventList[i] == "steps": - event = open("eventSimulator/stepStepsEvent.groovy", "r") + extractedEvents.write("\n\t\t\tbreak\n") + counter = counter + 1 + extractedEvents.write("\t\tcase %d:\n" % counter) + event = open("eventSimulator/stepStepsLowEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() @@ -796,17 +871,39 @@ def ExtractEvents(extractedEvents): extractedEvents.write(line) event.close() elif eventList[i] == "power": - event = open("eventSimulator/powerMeterEvent.groovy", "r") + #Write two events subsequently + event = open("eventSimulator/powerMeterHighPowerEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + extractedEvents.write("\n\t\t\tbreak\n") + counter = counter + 1 + extractedEvents.write("\t\tcase %d:\n" % counter) + event = open("eventSimulator/powerMeterLowPowerEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() elif eventList[i] == "illuminance": - event = open("eventSimulator/illuminanceMeasurementEvent.groovy", "r") + event = open("eventSimulator/illuminanceMeasurementLowEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + extractedEvents.write("\n\t\t\tbreak\n") + counter = counter + 1 + extractedEvents.write("\t\tcase %d:\n" % counter) + event = open("eventSimulator/illuminanceMeasurementHighEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() elif eventList[i] == "humidity": - event = open("eventSimulator/humidityMeasurementEvent.groovy", "r") + event = open("eventSimulator/humidityHighMeasurementEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + extractedEvents.write("\n\t\t\tbreak\n") + counter = counter + 1 + extractedEvents.write("\t\tcase %d:\n" % counter) + event = open("eventSimulator/humidityLowMeasurementEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() @@ -901,6 +998,8 @@ def ExtractEvents(extractedEvents): event = open("eventSimulator/switchLevelEvent.groovy", "r") elif capability == "capability.colorControl": event = open("eventSimulator/colorLevelChangeEvent.groovy", "r") + elif capability == "capability.switch": + event = open("eventSimulator/switchLevelChangeEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() @@ -937,10 +1036,21 @@ def ExtractEvents(extractedEvents): eventVarCount = eventVarCounterMap[eventList[i]] eventVarCounterMap[eventList[i]] = eventVarCount + 1 capability = capabilityMap[variable[eventVarCount]] + #Write two events subsequently + if capability == "capability.thermostat": + event = open("eventSimulator/temperatureHighEvent.groovy", "r") + elif capability == "capability.temperatureMeasurement": + event = open("eventSimulator/temperatureHighMeasurementEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + extractedEvents.write("\n\t\t\tbreak\n") + counter = counter + 1 + extractedEvents.write("\t\tcase %d:\n" % counter) if capability == "capability.thermostat": - event = open("eventSimulator/temperatureEvent.groovy", "r") + event = open("eventSimulator/temperatureLowEvent.groovy", "r") elif capability == "capability.temperatureMeasurement": - event = open("eventSimulator/temperatureMeasurementEvent.groovy", "r") + event = open("eventSimulator/temperatureLowMeasurementEvent.groovy", "r") for line in event: extractedEvents.write(line) event.close() @@ -959,11 +1069,82 @@ def ExtractEvents(extractedEvents): for line in event: extractedEvents.write(line) event.close() + elif eventList[i] == "threeAxis": + event = open("eventSimulator/threeAxisChangeEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "carbonDioxide": + event = open("eventSimulator/carbonDioxideEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "consumableStatus": + event = open("eventSimulator/consumableStatusEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "pH": + event = open("eventSimulator/pHEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "pressure": + event = open("eventSimulator/pressureEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "shock": + event = open("eventSimulator/shockEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "lqi": + event = open("eventSimulator/lqiEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "rssi": + event = open("eventSimulator/rssiEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "sound": + event = open("eventSimulator/soundEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "soundPressureLevel": + event = open("eventSimulator/soundPressureLevelEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "tamper": + event = open("eventSimulator/tamperEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "voltage": + event = open("eventSimulator/voltageEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "ultravioletIndex": + event = open("eventSimulator/ultravioletIndexEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() + elif eventList[i] == "windowShade": + event = open("eventSimulator/windowShadeEvent.groovy", "r") + for line in event: + extractedEvents.write(line) + event.close() ###TODO: Add more events later extractedEvents.write("\n\t\t\tbreak\n") counter = counter + 1 extractedEvents.write("\t}\n") + extractedEvents.write("\tprintln(\"\\nEVENT NUMBER: \" + eventNumber)\n"); extractedEvents.write("}\n") def CheckIfOnlyTouchEvents(): @@ -971,7 +1152,7 @@ def CheckIfOnlyTouchEvents(): #This is called Direct-Direct interaction and we do not model-check for this case onlyTouchEvents = True for item in eventList: - if item != "nfcTouch" and item != "app": + if item != "nfcTouch" and item != "app" and item != "button": onlyTouchEvents = False if onlyTouchEvents is True and app1Subscribe is True and app2Subscribe is True: # Write error log file