ToReturn = ""
eventList = []
eventVarMap = {}
+eventVarCounterMap = {}
capabilityMap = {}
+capabilityList = []
app1Capabilities = []
app2Capabilities = []
app1Subscribe = False
while (Temp != "EOF"):
if (Temp == "def" or Temp == "private"):
Temp = GetToken(F)
+ if (Temp == "def" or Temp == "private"):
+ Temp = GetToken(F)
NameofFunc = Temp
- if (GetToken(F) != "="): #We have a function to create object for
+ if (GetToken(F) == "("): #We have a function to create object for
if (appName == "App1"):
extractedFunctionsApp1.write("//Global Object for functions in subscribe method!\n")
extractedFunctionsApp1.write("def %s = this.&" % NameofFunc)
#Check input capability
if (Temp == "input"):
- Temp = GetToken(F) #Get '"'
+ while Temp != "\"":
+ Temp = GetToken(F)
variable = GetToken(F)
Temp = GetToken(F) #Get '"'
Temp = GetToken(F) #Get ','
- Temp = GetToken(F) #Get '"'
- Temp = GetToken(F) #Get capability...
- capability = Temp
+ while Temp != "\"":
+ Temp = GetToken(F)
+ capability = GetToken(F)
capabilityMap[variable] = capability
#Check subscribed events
else:
app2Subscribe = True
Temp = GetToken(F)
+ if (Temp == "("):
+ Temp = GetToken(F)
variable = Temp
while (Temp != "\"" and Temp != "app" and Temp != "location"):
Temp = GetToken(F)
if Temp == "\"":
Temp = GetToken(F)
- if Temp not in eventList:
+ #print "DEBUG: %s" % variable
+ #print capabilityMap
+ #print eventList
+ #if variable == "app" or variable == "location":
+
+ if Temp == "app" or Temp == "location":
+ if Temp not in eventList:
+ eventList.append(Temp)
+ elif variable in capabilityMap.keys() and capabilityMap[variable] not in capabilityList:
+ # We do not repeat the same capability twice
+ capability = capabilityMap[variable]
+ capabilityList.append(capability)
eventList.append(Temp)
- eventVarMap[Temp] = variable
-
+ if Temp in eventVarMap.keys():
+ listOfEvents = eventVarMap[Temp]
+ listOfEvents.append(variable)
+ else:
+ eventVarMap[Temp] = [variable]
+
#Check and analyze capabilities for physical interaction
AnalyzeCapabilities(Temp, appName, F)
AnalyzePhysicalInteraction(app1Capabilities, app2Capabilities)
AnalyzePhysicalInteraction(app2Capabilities, app1Capabilities)
-
def AnalyzeCapabilities(Temp, appName, F):
#Illuminance related
if (Temp == "capability.switch" or
Temp == "capability.switchLevel" or
Temp == "capability.illuminanceMeasurement" or
+ Temp == "capability.colorControl" or
#Motion related
Temp == "capability.motionSensor" or
Temp == "capability.accelerationSensor" or
def AnalyzePhysicalInteraction(app1Capab, app2Capab):
#Light
if ("capability.illuminanceMeasurement" in app1Capab) and ("capability.switch" in app2Capab or
- "capability.switchLevel" in app2Capab):
+ "capability.switchLevel" in app2Capab or "capability.colorControl" 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
global eventList
global eventVarMap
global capabilityMap
+ global eventVarCounterMap
extractedEvents.write("while(true) {\n")
extractedEvents.write("\tdef eventNumber = Verify.getInt(0,%d)\n" % (len(eventList) - 1))
extractedEvents.write("\tswitch(eventNumber) {\n")
for i in range(len(eventList)):
extractedEvents.write("\t\tcase %d:\n" % i)
if eventList[i] == "lock":
- event = open("eventSimulator/lockEvent.groovy", "r")
+ #Write two events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ event = open("eventSimulator/lockLockedEvent.groovy", "r")
for line in event:
- extractedEvents.write(line)
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/lockUnlockedEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
event.close()
+ extractedEvents.write("\t\t\t}\n")
elif eventList[i] == "unlock":
event = open("eventSimulator/unlockEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t}\n")
- elif eventList[i] == "presence":
+ elif eventList[i] == "water":
#Write two events subsequently
extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
extractedEvents.write("\t\t\tif (event == 0) {\n")
- event = open("eventSimulator/presencePresentEvent.groovy", "r")
+ event = open("eventSimulator/waterDryEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t} else {\n")
- event = open("eventSimulator/presenceLeftEvent.groovy", "r")
+ event = open("eventSimulator/waterWetEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "presence":
+ #Check which capability
+ 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
+ capability = capabilityMap[variable[eventVarCount]]
+ #Write three events subsequently
+ if capability == "capability.presenceSensor":
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,2)\n")
+ elif capability == "capability.beacon":
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ if capability == "capability.presenceSensor":
+ event = open("eventSimulator/presencePresentEvent.groovy", "r")
+ elif capability == "capability.beacon":
+ event = open("eventSimulator/beaconPresentEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
+ extractedEvents.write("\t\t\t} else if (event == 1) {\n")
+ if capability == "capability.presenceSensor":
+ event = open("eventSimulator/presenceLeftEvent.groovy", "r")
+ elif capability == "capability.beacon":
+ event = open("eventSimulator/beaconLeftEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ if capability == "capability.presenceSensor":
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/presencePresencePresentEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
extractedEvents.write("\t\t\t}\n")
elif eventList[i] == "doorState":
#Write two events subsequently
elif eventList[i] == "carbonMonoxide":
#Check which capability
variable = eventVarMap[eventList[i]]
- capability = capabilityMap[variable]
-
+ if eventList[i] not in eventVarCounterMap.keys():
+ eventVarCounterMap[eventList[i]] = 1
+ eventVarCount = 0
+ else:
+ eventVarCount = eventVarCounterMap[eventList[i]]
+ eventVarCounterMap[eventList[i]] = eventVarCount + 1
+ capability = capabilityMap[variable[eventVarCount]]
#Write three events subsequently
extractedEvents.write("\t\t\tdef event = Verify.getInt(0,2)\n")
extractedEvents.write("\t\t\tif (event == 0) {\n")
event.close()
extractedEvents.write("\t\t\t}\n")
elif eventList[i] == "battery":
- event = open("eventSimulator/batteryChargeEvent.groovy", "r")
+ #Check which capability
+ 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
+ capability = capabilityMap[variable[eventVarCount]]
+ if capability == "capability.smokeDetector":
+ event = open("eventSimulator/smokeDetectorBatteryEvent.groovy", "r")
+ elif capability == "capability.battery":
+ event = open("eventSimulator/batteryBatteryEvent.groovy", "r")
for line in event:
extractedEvents.write(line)
event.close()
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "thermostatFanMode":
+ #Write five events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,4)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ event = open("eventSimulator/thermostatAutoFanModeEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 1) {\n")
+ event = open("eventSimulator/thermostatFanCirculateFanModeEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 2) {\n")
+ event = open("eventSimulator/thermostatCirculateFanModeEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 3) {\n")
+ event = open("eventSimulator/thermostatFanOnFanModeEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/thermostatOnFanModeEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "thermostatOperatingState":
+ #Write five events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,4)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ event = open("eventSimulator/thermostatOperatingStateAutoEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 1) {\n")
+ event = open("eventSimulator/thermostatOperatingStateCoolEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 2) {\n")
+ event = open("eventSimulator/thermostatOperatingStateOffEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 3) {\n")
+ event = open("eventSimulator/thermostatOperatingStateEmergencyHeatEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/thermostatOperatingStateHeatEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
elif eventList[i] == "switch":
+ #Check which capability
+ 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
+ capability = capabilityMap[variable[eventVarCount]]
#Write two events subsequently
extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
extractedEvents.write("\t\t\tif (event == 0) {\n")
- event = open("eventSimulator/switchOnEvent.groovy", "r")
+ if capability == "capability.switch":
+ event = open("eventSimulator/switchOnEvent.groovy", "r")
+ elif capability == "capability.switchLevel":
+ event = open("eventSimulator/switchLevelOnEvent.groovy", "r")
+ elif capability == "capability.relaySwitch":
+ event = open("eventSimulator/relaySwitchOnEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t} else {\n")
- event = open("eventSimulator/switchOffEvent.groovy", "r")
+ if capability == "capability.switch":
+ event = open("eventSimulator/switchOffEvent.groovy", "r")
+ elif capability == "capability.switchLevel":
+ event = open("eventSimulator/switchLevelOffEvent.groovy", "r")
+ elif capability == "capability.relaySwitch":
+ event = open("eventSimulator/relaySwitchOffEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t}\n")
- elif eventList[i] == "beacon":
+ elif eventList[i] == "sleeping":
#Write two events subsequently
extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
extractedEvents.write("\t\t\tif (event == 0) {\n")
- event = open("eventSimulator/beaconPresenceEvent.groovy", "r")
+ event = open("eventSimulator/sleepSleepingEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t} else {\n")
- event = open("eventSimulator/beaconLeftEvent.groovy", "r")
+ event = open("eventSimulator/sleepNotSleepingEvent.groovy", "r")
for line in event:
extractedEvents.write("\t\t" + line)
event.close()
extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "goal":
+ event = open("eventSimulator/stepGoalEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "steps":
+ event = open("eventSimulator/stepStepsEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
elif eventList[i] == "color":
- event = open("eventSimulator/colorChangeEvent.groovy", "r")
+ event = open("eventSimulator/colorChangedEvent.groovy", "r")
for line in event:
extractedEvents.write(line)
event.close()
elif eventList[i] == "hue":
- event = open("eventSimulator/hueChangeEvent.groovy", "r")
+ event = open("eventSimulator/hueChangedEvent.groovy", "r")
for line in event:
extractedEvents.write(line)
event.close()
elif eventList[i] == "saturation":
- event = open("eventSimulator/saturationChangeEvent.groovy", "r")
+ event = open("eventSimulator/saturationChangedEvent.groovy", "r")
for line in event:
extractedEvents.write(line)
event.close()
-
+ elif eventList[i] == "energy":
+ event = open("eventSimulator/energyMeterEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "power":
+ event = open("eventSimulator/powerMeterEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "illuminance":
+ event = open("eventSimulator/illuminanceMeasurementEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "humidity":
+ event = open("eventSimulator/humidityMeasurementEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "alarm":
+ #Write four events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,3)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ event = open("eventSimulator/alarmBothEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 1) {\n")
+ event = open("eventSimulator/alarmSirenEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 2) {\n")
+ event = open("eventSimulator/alarmStrobeEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/alarmOffEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "contact":
+ #Check which capability
+ 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
+ capability = capabilityMap[variable[eventVarCount]]
+ #Write two events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ if capability == "capability.contactSensor":
+ event = open("eventSimulator/contactDefaultClosedEvent.groovy", "r")
+ elif capability == "capability.valve":
+ event = open("eventSimulator/valveClosedEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ if capability == "capability.contactSensor":
+ event = open("eventSimulator/contactDefaultOpenEvent.groovy", "r")
+ elif capability == "capability.valve":
+ event = open("eventSimulator/valveOpenEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "status":
+ #Write three events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,2)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ event = open("eventSimulator/musicPlayerPlayingEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else if (event == 1) {\n")
+ event = open("eventSimulator/musicPlayerStoppedEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/musicPlayerPausedEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "level":
+ #Check which capability
+ 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
+ capability = capabilityMap[variable[eventVarCount]]
+ if capability == "capability.musicPlayer":
+ event = open("eventSimulator/musicPlayerLevelEvent.groovy", "r")
+ elif capability == "capability.switchLevel":
+ event = open("eventSimulator/switchLevelEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "trackDescription":
+ event = open("eventSimulator/musicPlayerTrackDescriptionEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "trackData":
+ event = open("eventSimulator/musicPlayerTrackDataEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "mute":
+ #Write two events subsequently
+ extractedEvents.write("\t\t\tdef event = Verify.getInt(0,1)\n")
+ extractedEvents.write("\t\t\tif (event == 0) {\n")
+ event = open("eventSimulator/musicPlayerUnmutedEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t} else {\n")
+ event = open("eventSimulator/musicPlayerMutedEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write("\t\t" + line)
+ event.close()
+ extractedEvents.write("\t\t\t}\n")
+ elif eventList[i] == "temperature":
+ #Check which capability
+ 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
+ capability = capabilityMap[variable[eventVarCount]]
+ if capability == "capability.thermostat":
+ event = open("eventSimulator/temperatureEvent.groovy", "r")
+ elif capability == "capability.temperatureMeasurement":
+ event = open("eventSimulator/temperatureMeasurementEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "heatingSetpoint":
+ event = open("eventSimulator/heatingSetpointEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "coolingSetpoint":
+ event = open("eventSimulator/coolingSetpointEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+ elif eventList[i] == "thermostatSetpoint":
+ event = open("eventSimulator/thermostatSetpointEvent.groovy", "r")
+ for line in event:
+ extractedEvents.write(line)
+ event.close()
+
###TODO: Add more events later
extractedEvents.write("\t\t\tbreak\n")
extractedEvents.write("\t}\n")
if item != "nfcTouch" and item != "app":
onlyTouchEvents = False
if onlyTouchEvents is True and app1Subscribe is True and app2Subscribe is True:
+ # Write error log file
+ extractError = open("appCreationError.log", "w+")
+ extractError.write("Direct-Direct Interaction detected: we are skipping this pair...\n")
+ extractError.close()
raise Exception("\n\nDirect-Direct Interaction detected: we are skipping this pair...\n\n")
-
+
+
#Extract objects to call functions from App1
F1 = open("Extractor/App1/App1.groovy", "r")
extractedFunctionsApp1 = open("Extractor/App1/extractedFunctionsApp1.groovy", "w+")
os.system("groovy -classpath lib/jpf.jar Extractor/extractorFile.groovy")
-
-
projects / smartthings-infrastructure.git / blobdiff