1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300 |
- """
- Generated by Statechart compiler by Glenn De Jonghe, Joeri Exelmans, Simon Van Mierlo, and Yentl Van Tendeloo (for the inspiration) and Sam Pieters (DEVS)
- Model author: Simon Van Mierlo+Raphael Mannadiar
- Model name: Bouncing_Balls_Python_Version
- Model description:
- Tkinter frame with bouncing balls in it.
- """
- from sccd.runtime.DEVS_statecharts_core import *
- from pypdevs.DEVS import *
- from pypdevs.infinity import *
- from pypdevs.simulator import *
- from sccd.runtime.libs import ui_v2 as ui
- from sccd.runtime.libs.utils import utils
- import random
- CANVAS_WIDTH = 800
- CANVAS_HEIGHT = 550
- # package "Bouncing_Balls_Python_Version"
- class MainAppInstance(RuntimeClassBase):
- def __init__(self, atomdevs):
- RuntimeClassBase.__init__(self, atomdevs)
- self.associations = {}
- self.associations["fields"] = Association("Field", 0, -1)
-
- self.semantics.big_step_maximality = StatechartSemantics.TakeMany
- self.semantics.internal_event_lifeline = StatechartSemantics.Queue
- self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
- self.semantics.priority = StatechartSemantics.SourceParent
- self.semantics.concurrency = StatechartSemantics.Single
-
- # build Statechart structure
- self.build_statechart_structure()
-
- # call user defined constructor
- MainAppInstance.user_defined_constructor(self)
-
- def user_defined_constructor(self):
- self.nr_of_fields = 0
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, "", self)
-
- # state /running
- self.states["/running"] = State(1, "/running", self)
-
- # state /running/root
- self.states["/running/root"] = ParallelState(2, "/running/root", self)
-
- # state /running/root/main_behaviour
- self.states["/running/root/main_behaviour"] = State(3, "/running/root/main_behaviour", self)
-
- # state /running/root/main_behaviour/initializing
- self.states["/running/root/main_behaviour/initializing"] = State(4, "/running/root/main_behaviour/initializing", self)
-
- # state /running/root/main_behaviour/running
- self.states["/running/root/main_behaviour/running"] = State(5, "/running/root/main_behaviour/running", self)
-
- # state /running/root/cd_behaviour
- self.states["/running/root/cd_behaviour"] = State(6, "/running/root/cd_behaviour", self)
-
- # state /running/root/cd_behaviour/waiting
- self.states["/running/root/cd_behaviour/waiting"] = State(7, "/running/root/cd_behaviour/waiting", self)
-
- # state /running/root/cd_behaviour/creating
- self.states["/running/root/cd_behaviour/creating"] = State(8, "/running/root/cd_behaviour/creating", self)
-
- # state /running/root/cd_behaviour/check_nr_of_fields
- self.states["/running/root/cd_behaviour/check_nr_of_fields"] = State(9, "/running/root/cd_behaviour/check_nr_of_fields", self)
- self.states["/running/root/cd_behaviour/check_nr_of_fields"].setEnter(self._running_root_cd_behaviour_check_nr_of_fields_enter)
- self.states["/running/root/cd_behaviour/check_nr_of_fields"].setExit(self._running_root_cd_behaviour_check_nr_of_fields_exit)
-
- # state /running/root/cd_behaviour/stopped
- self.states["/running/root/cd_behaviour/stopped"] = State(10, "/running/root/cd_behaviour/stopped", self)
-
- # state /running/stopped
- self.states["/running/stopped"] = State(11, "/running/stopped", self)
-
- # add children
- self.states[""].addChild(self.states["/running"])
- self.states["/running"].addChild(self.states["/running/root"])
- self.states["/running"].addChild(self.states["/running/stopped"])
- self.states["/running/root"].addChild(self.states["/running/root/main_behaviour"])
- self.states["/running/root"].addChild(self.states["/running/root/cd_behaviour"])
- self.states["/running/root/main_behaviour"].addChild(self.states["/running/root/main_behaviour/initializing"])
- self.states["/running/root/main_behaviour"].addChild(self.states["/running/root/main_behaviour/running"])
- self.states["/running/root/cd_behaviour"].addChild(self.states["/running/root/cd_behaviour/waiting"])
- self.states["/running/root/cd_behaviour"].addChild(self.states["/running/root/cd_behaviour/creating"])
- self.states["/running/root/cd_behaviour"].addChild(self.states["/running/root/cd_behaviour/check_nr_of_fields"])
- self.states["/running/root/cd_behaviour"].addChild(self.states["/running/root/cd_behaviour/stopped"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/running"]
- self.states["/running"].default_state = self.states["/running/root"]
- self.states["/running/root/main_behaviour"].default_state = self.states["/running/root/main_behaviour/initializing"]
- self.states["/running/root/cd_behaviour"].default_state = self.states["/running/root/cd_behaviour/waiting"]
-
- # transition /running/root/main_behaviour/initializing
- _running_root_main_behaviour_initializing_0 = Transition(self, self.states["/running/root/main_behaviour/initializing"], [self.states["/running/root/main_behaviour/running"]])
- _running_root_main_behaviour_initializing_0.setAction(self._running_root_main_behaviour_initializing_0_exec)
- _running_root_main_behaviour_initializing_0.setTrigger(None)
- self.states["/running/root/main_behaviour/initializing"].addTransition(_running_root_main_behaviour_initializing_0)
-
- # transition /running/root/main_behaviour/running
- _running_root_main_behaviour_running_0 = Transition(self, self.states["/running/root/main_behaviour/running"], [self.states["/running/root/main_behaviour/running"]])
- _running_root_main_behaviour_running_0.setAction(self._running_root_main_behaviour_running_0_exec)
- _running_root_main_behaviour_running_0.setTrigger(Event("button_pressed", None))
- _running_root_main_behaviour_running_0.setGuard(self._running_root_main_behaviour_running_0_guard)
- self.states["/running/root/main_behaviour/running"].addTransition(_running_root_main_behaviour_running_0)
-
- # transition /running/root/cd_behaviour/waiting
- _running_root_cd_behaviour_waiting_0 = Transition(self, self.states["/running/root/cd_behaviour/waiting"], [self.states["/running/root/cd_behaviour/creating"]])
- _running_root_cd_behaviour_waiting_0.setAction(self._running_root_cd_behaviour_waiting_0_exec)
- _running_root_cd_behaviour_waiting_0.setTrigger(Event("create_field", None))
- self.states["/running/root/cd_behaviour/waiting"].addTransition(_running_root_cd_behaviour_waiting_0)
- _running_root_cd_behaviour_waiting_1 = Transition(self, self.states["/running/root/cd_behaviour/waiting"], [self.states["/running/root/cd_behaviour/check_nr_of_fields"]])
- _running_root_cd_behaviour_waiting_1.setAction(self._running_root_cd_behaviour_waiting_1_exec)
- _running_root_cd_behaviour_waiting_1.setTrigger(Event("delete_field", None))
- self.states["/running/root/cd_behaviour/waiting"].addTransition(_running_root_cd_behaviour_waiting_1)
-
- # transition /running/root/cd_behaviour/creating
- _running_root_cd_behaviour_creating_0 = Transition(self, self.states["/running/root/cd_behaviour/creating"], [self.states["/running/root/cd_behaviour/waiting"]])
- _running_root_cd_behaviour_creating_0.setAction(self._running_root_cd_behaviour_creating_0_exec)
- _running_root_cd_behaviour_creating_0.setTrigger(Event("instance_created", None))
- self.states["/running/root/cd_behaviour/creating"].addTransition(_running_root_cd_behaviour_creating_0)
-
- # transition /running/root/cd_behaviour/check_nr_of_fields
- _running_root_cd_behaviour_check_nr_of_fields_0 = Transition(self, self.states["/running/root/cd_behaviour/check_nr_of_fields"], [self.states["/running/root/cd_behaviour/stopped"]])
- _running_root_cd_behaviour_check_nr_of_fields_0.setAction(self._running_root_cd_behaviour_check_nr_of_fields_0_exec)
- _running_root_cd_behaviour_check_nr_of_fields_0.setTrigger(Event("_0after"))
- _running_root_cd_behaviour_check_nr_of_fields_0.setGuard(self._running_root_cd_behaviour_check_nr_of_fields_0_guard)
- self.states["/running/root/cd_behaviour/check_nr_of_fields"].addTransition(_running_root_cd_behaviour_check_nr_of_fields_0)
- _running_root_cd_behaviour_check_nr_of_fields_1 = Transition(self, self.states["/running/root/cd_behaviour/check_nr_of_fields"], [self.states["/running/root/cd_behaviour/waiting"]])
- _running_root_cd_behaviour_check_nr_of_fields_1.setTrigger(None)
- _running_root_cd_behaviour_check_nr_of_fields_1.setGuard(self._running_root_cd_behaviour_check_nr_of_fields_1_guard)
- self.states["/running/root/cd_behaviour/check_nr_of_fields"].addTransition(_running_root_cd_behaviour_check_nr_of_fields_1)
-
- # transition /running/root
- _running_root_0 = Transition(self, self.states["/running/root"], [self.states["/running/stopped"]])
- _running_root_0.setAction(self._running_root_0_exec)
- _running_root_0.setTrigger(Event("stop", None))
- self.states["/running/root"].addTransition(_running_root_0)
-
- def _running_root_cd_behaviour_check_nr_of_fields_enter(self):
- self.addTimer(0, 0.05)
-
- def _running_root_cd_behaviour_check_nr_of_fields_exit(self):
- self.removeTimer(0)
-
- def _running_root_0_exec(self, parameters):
- self.big_step.outputEvent(Event("destroy_all", self.getOutPortName("ui"), []))
-
- def _running_root_main_behaviour_initializing_0_exec(self, parameters):
- self.raiseInternalEvent(Event("create_field", None, []))
-
- def _running_root_main_behaviour_running_0_exec(self, parameters):
- event_name = parameters[0]
- self.raiseInternalEvent(Event("create_field", None, []))
-
- def _running_root_main_behaviour_running_0_guard(self, parameters):
- event_name = parameters[0]
- return event_name == "create_new_field"
-
- def _running_root_cd_behaviour_waiting_0_exec(self, parameters):
- self.big_step.outputEventOM(Event("create_instance", None, [self, "fields"]))
-
- def _running_root_cd_behaviour_waiting_1_exec(self, parameters):
- association_name = parameters[0]
- self.big_step.outputEventOM(Event("delete_instance", None, [self, association_name]))
- self.nr_of_fields -= 1
-
- def _running_root_cd_behaviour_creating_0_exec(self, parameters):
- association_name = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, association_name]))
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, association_name, Event("set_association_name", None, [association_name])]))
- self.nr_of_fields += 1
-
- def _running_root_cd_behaviour_check_nr_of_fields_0_exec(self, parameters):
- self.raiseInternalEvent(Event("stop", None, []))
-
- def _running_root_cd_behaviour_check_nr_of_fields_0_guard(self, parameters):
- return self.nr_of_fields == 0
-
- def _running_root_cd_behaviour_check_nr_of_fields_1_guard(self, parameters):
- return self.nr_of_fields != 0
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/running"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class MainApp(AtomicDEVS, ObjectManagerBase):
- def __init__(self, name):
- AtomicDEVS.__init__(self, name)
- ObjectManagerBase.__init__(self)
- self.elapsed = 0
- self.name = "MainApp"
- self.obj_manager_out = self.addOutPort("obj_manager_out")
- self.outputs = {}
- self.outputs["fields"] = self.addOutPort("fields")
- self.obj_manager_in = self.addInPort("obj_manager_in")
- self.input = self.addInPort("input")
- self.instances.add(MainAppInstance(self))
- self.next_time = INFINITY
-
- def extTransition(self, inputs):
- self.next_time = 0
- all_inputs = []
- if self.obj_manager_in in inputs:
- all_inputs.extend(inputs[self.obj_manager_in])
- if self.input in inputs:
- all_inputs.extend(inputs[self.input])
- for input in all_inputs:
- if isinstance(input, str):
- tem = eval(input)
- self.addInput(tem)
- elif input[3].name == "create_instance":
- self.instances.add(MainAppInstance(self))
- ev = Event("instance_created", None, parameters=[f"{input[3].parameters[0]}[{len(self.instances)-1}]"])
- self.to_send.append((input[1], input[0], input[2], ev))
- elif input[3].name == "start_instance":
- instance = list(self.instances)[input[2]]
- instance.start()
- ev = Event("instance_started", None, parameters=[f"{input[0]}[{input[2]}]"])
- self.to_send.append((input[0], input[1], input[2], ev))
- elif input[3].name == "delete_instance":
- ev = Event("instance_deleted", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "associate_instance":
- ev = Event("instance_associated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "disassociate_instance":
- ev = Event("instance_disassociated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "instance_created":
- association = self.processAssociationReference(input[3].parameters[0])[0]
- instance = list(self.instances)[input[2]]
- p = instance.associations.get(association[0])
- if p:
- p.addInstance(input[3].parameters[0])
- instance.addEvent(input[3])
- #instance.associations['fields'].instances[0] = input[3].parameters[0]
- #association = self.processAssociationReference(input[3].parameters[0])[0]
- #instance = list(self.instances)[input[2]]
- #p = instance.associations.get(association[0])
- #if p:
- # p.addInstance(input[3].parameters[0])
- #instance.addEvent(input[3])
-
- elif input[3].name == "instance_started":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_deleted":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_associated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_disassociated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "set_association_name":
- ev = input[3]
- self.addInput(ev, force_internal=True)
- else:
- ev = input[3]
- self.addInput(ev)
- return self.instances
-
- def intTransition(self):
- earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (earliest == INFINITY):
- self.simulated_time = earliest
- self.to_send = []
- self.handleInput()
- self.stepAll()
- next_earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (len(self.to_send) == 0):
- self.next_time = 0
- elif next_earliest == INFINITY:
- self.next_time = INFINITY
- else:
- self.next_time = next_earliest - earliest
- return self.instances
-
- def outputFnc(self):
- to_dict = {}
- for sending in self.to_send:
- if sending[3].port == None:
- if self.obj_manager_out in to_dict:
- to_dict[self.obj_manager_out].append(sending)
- else:
- to_dict[self.obj_manager_out] = [sending]
- else:
- the_port = None
- for port in self.OPorts:
- if port.name == sending[0]:
- the_port = port
- if the_port in to_dict:
- to_dict[the_port].append(sending)
- else:
- to_dict[the_port] = [sending]
- return to_dict
-
- def timeAdvance(self):
- return self.next_time
- class FieldInstance(RuntimeClassBase):
- num_instances = 0
- def __init__(self, atomdevs):
- RuntimeClassBase.__init__(self, atomdevs)
- self.associations = {}
- self.associations["balls"] = Association("Ball", 0, -1)
- self.associations["buttons"] = Association("Button", 0, -1)
- self.associations["parent"] = Association("MainApp", 1, 1)
-
- self.semantics.big_step_maximality = StatechartSemantics.TakeMany
- self.semantics.internal_event_lifeline = StatechartSemantics.Queue
- self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
- self.semantics.priority = StatechartSemantics.SourceParent
- self.semantics.concurrency = StatechartSemantics.Single
-
- # build Statechart structure
- self.build_statechart_structure()
-
- # user defined attributes
- self.window_id = None
- self.canvas_id = None
-
- # call user defined constructor
- FieldInstance.user_defined_constructor(self)
- self.inports['field_ui'] = ('field_ui', FieldInstance.num_instances)
- FieldInstance.num_instances += 1
-
- def user_defined_constructor(self):
- pass
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, "", self)
-
- # state /root
- self.states["/root"] = State(1, "/root", self)
-
- # state /root/waiting
- self.states["/root/waiting"] = State(2, "/root/waiting", self)
-
- # state /root/creating_window
- self.states["/root/creating_window"] = State(3, "/root/creating_window", self)
- self.states["/root/creating_window"].setEnter(self._root_creating_window_enter)
-
- # state /root/creating_canvas
- self.states["/root/creating_canvas"] = State(4, "/root/creating_canvas", self)
- self.states["/root/creating_canvas"].setEnter(self._root_creating_canvas_enter)
-
- # state /root/creating_button
- self.states["/root/creating_button"] = State(5, "/root/creating_button", self)
- self.states["/root/creating_button"].setEnter(self._root_creating_button_enter)
-
- # state /root/running
- self.states["/root/running"] = ParallelState(6, "/root/running", self)
-
- # state /root/running/main_behaviour
- self.states["/root/running/main_behaviour"] = State(7, "/root/running/main_behaviour", self)
-
- # state /root/running/main_behaviour/running
- self.states["/root/running/main_behaviour/running"] = State(8, "/root/running/main_behaviour/running", self)
-
- # state /root/running/main_behaviour/creating_ball
- self.states["/root/running/main_behaviour/creating_ball"] = State(9, "/root/running/main_behaviour/creating_ball", self)
-
- # state /root/running/deleting_behaviour
- self.states["/root/running/deleting_behaviour"] = State(10, "/root/running/deleting_behaviour", self)
-
- # state /root/running/deleting_behaviour/running
- self.states["/root/running/deleting_behaviour/running"] = State(11, "/root/running/deleting_behaviour/running", self)
-
- # state /root/running/child_behaviour
- self.states["/root/running/child_behaviour"] = State(12, "/root/running/child_behaviour", self)
-
- # state /root/running/child_behaviour/listening
- self.states["/root/running/child_behaviour/listening"] = State(13, "/root/running/child_behaviour/listening", self)
-
- # state /root/running/deleting_balls_behaviour
- self.states["/root/running/deleting_balls_behaviour"] = State(14, "/root/running/deleting_balls_behaviour", self)
-
- # state /root/running/deleting_balls_behaviour/listening
- self.states["/root/running/deleting_balls_behaviour/listening"] = State(15, "/root/running/deleting_balls_behaviour/listening", self)
-
- # state /root/deleting
- self.states["/root/deleting"] = State(16, "/root/deleting", self)
-
- # state /root/deleted
- self.states["/root/deleted"] = State(17, "/root/deleted", self)
-
- # add children
- self.states[""].addChild(self.states["/root"])
- self.states["/root"].addChild(self.states["/root/waiting"])
- self.states["/root"].addChild(self.states["/root/creating_window"])
- self.states["/root"].addChild(self.states["/root/creating_canvas"])
- self.states["/root"].addChild(self.states["/root/creating_button"])
- self.states["/root"].addChild(self.states["/root/running"])
- self.states["/root"].addChild(self.states["/root/deleting"])
- self.states["/root"].addChild(self.states["/root/deleted"])
- self.states["/root/running"].addChild(self.states["/root/running/main_behaviour"])
- self.states["/root/running"].addChild(self.states["/root/running/deleting_behaviour"])
- self.states["/root/running"].addChild(self.states["/root/running/child_behaviour"])
- self.states["/root/running"].addChild(self.states["/root/running/deleting_balls_behaviour"])
- self.states["/root/running/main_behaviour"].addChild(self.states["/root/running/main_behaviour/running"])
- self.states["/root/running/main_behaviour"].addChild(self.states["/root/running/main_behaviour/creating_ball"])
- self.states["/root/running/deleting_behaviour"].addChild(self.states["/root/running/deleting_behaviour/running"])
- self.states["/root/running/child_behaviour"].addChild(self.states["/root/running/child_behaviour/listening"])
- self.states["/root/running/deleting_balls_behaviour"].addChild(self.states["/root/running/deleting_balls_behaviour/listening"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/root"]
- self.states["/root"].default_state = self.states["/root/waiting"]
- self.states["/root/running/main_behaviour"].default_state = self.states["/root/running/main_behaviour/running"]
- self.states["/root/running/deleting_behaviour"].default_state = self.states["/root/running/deleting_behaviour/running"]
- self.states["/root/running/child_behaviour"].default_state = self.states["/root/running/child_behaviour/listening"]
- self.states["/root/running/deleting_balls_behaviour"].default_state = self.states["/root/running/deleting_balls_behaviour/listening"]
-
- # transition /root/waiting
- _root_waiting_0 = Transition(self, self.states["/root/waiting"], [self.states["/root/creating_window"]])
- _root_waiting_0.setAction(self._root_waiting_0_exec)
- _root_waiting_0.setTrigger(Event("set_association_name", None))
- self.states["/root/waiting"].addTransition(_root_waiting_0)
-
- # transition /root/creating_window
- _root_creating_window_0 = Transition(self, self.states["/root/creating_window"], [self.states["/root/creating_canvas"]])
- _root_creating_window_0.setAction(self._root_creating_window_0_exec)
- _root_creating_window_0.setTrigger(Event("window_created", None))
- self.states["/root/creating_window"].addTransition(_root_creating_window_0)
-
- # transition /root/creating_canvas
- _root_creating_canvas_0 = Transition(self, self.states["/root/creating_canvas"], [self.states["/root/creating_button"]])
- _root_creating_canvas_0.setAction(self._root_creating_canvas_0_exec)
- _root_creating_canvas_0.setTrigger(Event("canvas_created", None))
- self.states["/root/creating_canvas"].addTransition(_root_creating_canvas_0)
-
- # transition /root/creating_button
- _root_creating_button_0 = Transition(self, self.states["/root/creating_button"], [self.states["/root/running"]])
- _root_creating_button_0.setAction(self._root_creating_button_0_exec)
- _root_creating_button_0.setTrigger(Event("instance_created", None))
- self.states["/root/creating_button"].addTransition(_root_creating_button_0)
-
- # transition /root/running/main_behaviour/running
- _root_running_main_behaviour_running_0 = Transition(self, self.states["/root/running/main_behaviour/running"], [self.states["/root/running/main_behaviour/creating_ball"]])
- _root_running_main_behaviour_running_0.setAction(self._root_running_main_behaviour_running_0_exec)
- _root_running_main_behaviour_running_0.setTrigger(Event("right_click", self.getInPortName("field_ui")))
- self.states["/root/running/main_behaviour/running"].addTransition(_root_running_main_behaviour_running_0)
-
- # transition /root/running/main_behaviour/creating_ball
- _root_running_main_behaviour_creating_ball_0 = Transition(self, self.states["/root/running/main_behaviour/creating_ball"], [self.states["/root/running/main_behaviour/running"]])
- _root_running_main_behaviour_creating_ball_0.setAction(self._root_running_main_behaviour_creating_ball_0_exec)
- _root_running_main_behaviour_creating_ball_0.setTrigger(Event("instance_created", None))
- self.states["/root/running/main_behaviour/creating_ball"].addTransition(_root_running_main_behaviour_creating_ball_0)
-
- # transition /root/running/deleting_behaviour/running
- _root_running_deleting_behaviour_running_0 = Transition(self, self.states["/root/running/deleting_behaviour/running"], [self.states["/root/running/deleting_behaviour/running"]])
- _root_running_deleting_behaviour_running_0.setAction(self._root_running_deleting_behaviour_running_0_exec)
- _root_running_deleting_behaviour_running_0.setTrigger(Event("delete_ball", None))
- self.states["/root/running/deleting_behaviour/running"].addTransition(_root_running_deleting_behaviour_running_0)
-
- # transition /root/running/child_behaviour/listening
- _root_running_child_behaviour_listening_0 = Transition(self, self.states["/root/running/child_behaviour/listening"], [self.states["/root/running/child_behaviour/listening"]])
- _root_running_child_behaviour_listening_0.setAction(self._root_running_child_behaviour_listening_0_exec)
- _root_running_child_behaviour_listening_0.setTrigger(Event("button_pressed", None))
- self.states["/root/running/child_behaviour/listening"].addTransition(_root_running_child_behaviour_listening_0)
-
- # transition /root/running/deleting_balls_behaviour/listening
- _root_running_deleting_balls_behaviour_listening_0 = Transition(self, self.states["/root/running/deleting_balls_behaviour/listening"], [self.states["/root/running/deleting_balls_behaviour/listening"]])
- _root_running_deleting_balls_behaviour_listening_0.setAction(self._root_running_deleting_balls_behaviour_listening_0_exec)
- _root_running_deleting_balls_behaviour_listening_0.setTrigger(Event("key_press", self.getInPortName("field_ui")))
- _root_running_deleting_balls_behaviour_listening_0.setGuard(self._root_running_deleting_balls_behaviour_listening_0_guard)
- self.states["/root/running/deleting_balls_behaviour/listening"].addTransition(_root_running_deleting_balls_behaviour_listening_0)
-
- # transition /root/deleting
- _root_deleting_0 = Transition(self, self.states["/root/deleting"], [self.states["/root/deleted"]])
- _root_deleting_0.setAction(self._root_deleting_0_exec)
- _root_deleting_0.setTrigger(None)
- self.states["/root/deleting"].addTransition(_root_deleting_0)
-
- # transition /root/running
- _root_running_0 = Transition(self, self.states["/root/running"], [self.states["/root/deleting"]])
- _root_running_0.setAction(self._root_running_0_exec)
- _root_running_0.setTrigger(Event("window_close", self.getInPortName("field_ui")))
- self.states["/root/running"].addTransition(_root_running_0)
-
- def _root_creating_window_enter(self):
- self.big_step.outputEvent(Event("create_window", self.getOutPortName("ui"), [800, 600, "BouncingBalls", self.inports['field_ui']]))
-
- def _root_creating_canvas_enter(self):
- self.big_step.outputEvent(Event("create_canvas", self.getOutPortName("ui"), [self.window_id, CANVAS_WIDTH, CANVAS_HEIGHT, {'background':'#eee'}, self.inports['field_ui']]))
-
- def _root_creating_button_enter(self):
- self.big_step.outputEventOM(Event("create_instance", None, [self, "buttons", "Button", self.window_id, 'create_new_field', 'Spawn New Window']))
-
- def _root_running_0_exec(self, parameters):
- self.big_step.outputEventOM(Event("delete_instance", None, [self, "buttons"]))
- self.big_step.outputEventOM(Event("delete_instance", None, [self, "balls"]))
-
- def _root_waiting_0_exec(self, parameters):
- association_name = parameters[0]
- self.association_name = association_name
-
- def _root_creating_window_0_exec(self, parameters):
- window_id = parameters[0]
- self.window_id = window_id
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [window_id, ui.EVENTS.WINDOW_CLOSE, 'window_close', self.inports['field_ui']]))
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [window_id, ui.EVENTS.KEY_PRESS, 'key_press', self.inports['field_ui']]))
-
- def _root_creating_canvas_0_exec(self, parameters):
- canvas_id = parameters[0]
- self.canvas_id = canvas_id
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [canvas_id, ui.EVENTS.MOUSE_RIGHT_CLICK, 'right_click', self.inports['field_ui']]))
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [canvas_id, ui.EVENTS.MOUSE_MOVE, 'mouse_move', self.inports['field_ui']]))
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [canvas_id, ui.EVENTS.MOUSE_RELEASE, 'mouse_release', self.inports['field_ui']]))
-
- def _root_creating_button_0_exec(self, parameters):
- association_name = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, association_name]))
-
- def _root_running_main_behaviour_running_0_exec(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- self.big_step.outputEventOM(Event("create_instance", None, [self, "balls", "Ball", self.canvas_id, x, y]))
-
- def _root_running_main_behaviour_creating_ball_0_exec(self, parameters):
- association_name = parameters[0]
- self.big_step.outputEventOM(Event("start_instance", None, [self, association_name]))
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, association_name, Event("set_association_name", None, [association_name])]))
-
- def _root_running_deleting_behaviour_running_0_exec(self, parameters):
- association_name = parameters[0]
- self.big_step.outputEventOM(Event("delete_instance", None, [self, association_name]))
-
- def _root_running_child_behaviour_listening_0_exec(self, parameters):
- event_name = parameters[0]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("button_pressed", None, [event_name])]))
-
- def _root_running_deleting_balls_behaviour_listening_0_exec(self, parameters):
- key = parameters[0]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'balls', Event("delete_self", None, [])]))
-
- def _root_running_deleting_balls_behaviour_listening_0_guard(self, parameters):
- key = parameters[0]
- return key == ui.KEYCODES.DELETE
-
- def _root_deleting_0_exec(self, parameters):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("delete_field", None, [self.association_name])]))
- self.big_step.outputEvent(Event("destroy_window", self.getOutPortName("ui"), [self.window_id]))
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/root"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class Field(AtomicDEVS, ObjectManagerBase):
- def __init__(self, name):
- AtomicDEVS.__init__(self, name)
- ObjectManagerBase.__init__(self)
- self.elapsed = 0
- self.name = "Field"
- self.obj_manager_out = self.addOutPort("obj_manager_out")
- self.outputs = {}
- self.outputs["balls"] = self.addOutPort("balls")
- self.outputs["buttons"] = self.addOutPort("buttons")
- self.outputs["parent"] = self.addOutPort("parent")
- self.field_ui = self.addInPort("field_ui")
- self.obj_manager_in = self.addInPort("obj_manager_in")
- self.input = self.addInPort("input")
- self.next_time = INFINITY
-
- def extTransition(self, inputs):
- self.next_time = 0
- all_inputs = []
- if self.field_ui in inputs:
- all_inputs.extend(inputs[self.field_ui])
- if self.obj_manager_in in inputs:
- all_inputs.extend(inputs[self.obj_manager_in])
- if self.input in inputs:
- all_inputs.extend(inputs[self.input])
- for input in all_inputs:
- if isinstance(input, str):
- tem = eval(input)
- self.addInput(tem)
- elif input[3].name == "create_instance":
- new_instance = FieldInstance(self)
- self.instances.add(new_instance)
- #TODO: hardcoded but needs to be fixed
- p = new_instance.associations.get("parent")
- if p:
- p.addInstance(f"mainapp[0]")
- ev = Event("instance_created", None, parameters=[f"{input[3].parameters[0]}[{len(self.instances)-1}]"])
- self.to_send.append((input[1], input[0], input[2], ev))
- elif input[3].name == "start_instance":
- instance = list(self.instances)[input[2]]
- instance.start()
- ev = Event("instance_started", None, parameters=[f"{input[0]}[{input[2]}]"])
- self.to_send.append((input[0], input[1], input[2], ev))
- elif input[3].name == "delete_instance":
- ev = Event("instance_deleted", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "associate_instance":
- ev = Event("instance_associated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "disassociate_instance":
- ev = Event("instance_disassociated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "instance_created":
- association = self.processAssociationReference(input[3].parameters[0])[0]
- instance = list(self.instances)[input[2]]
- p = instance.associations.get(association[0])
- if p:
- p.addInstance(input[3].parameters[0])
- instance.addEvent(input[3])
- elif input[3].name == "instance_started":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_deleted":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_associated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_disassociated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "set_association_name":
- ev = input[3]
- self.addInput(ev, force_internal=True)
- else:
- ev = input[3]
- self.addInput(ev)
- return self.instances
-
- def intTransition(self):
- earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (earliest == INFINITY):
- self.simulated_time = earliest
- self.to_send = []
- self.handleInput()
- self.stepAll()
- next_earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (len(self.to_send) == 0):
- self.next_time = 0
- elif next_earliest == INFINITY:
- self.next_time = INFINITY
- else:
- self.next_time = next_earliest - earliest
- return self.instances
-
- def outputFnc(self):
- to_dict = {}
- for sending in self.to_send:
- if sending[3].port == None:
- if self.obj_manager_out in to_dict:
- to_dict[self.obj_manager_out].append(sending)
- else:
- to_dict[self.obj_manager_out] = [sending]
- else:
- the_port = None
- for port in self.OPorts:
- if port.name == sending[0]:
- the_port = port
- if the_port in to_dict:
- to_dict[the_port].append(sending)
- else:
- to_dict[the_port] = [sending]
- return to_dict
-
- def timeAdvance(self):
- return self.next_time
- class ButtonInstance(RuntimeClassBase):
- num_instances = 0
- def __init__(self, atomdevs, window_id, event_name, button_text):
- RuntimeClassBase.__init__(self, atomdevs)
- self.associations = {}
- self.associations["parent"] = Association("Field", 1, 1)
-
- self.semantics.big_step_maximality = StatechartSemantics.TakeMany
- self.semantics.internal_event_lifeline = StatechartSemantics.Queue
- self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
- self.semantics.priority = StatechartSemantics.SourceParent
- self.semantics.concurrency = StatechartSemantics.Single
-
- # build Statechart structure
- self.build_statechart_structure()
-
- # user defined attributes
- self.window_id = None
- self.event_name = None
- self.button_id = None
-
- # call user defined constructor
- ButtonInstance.user_defined_constructor(self, window_id, event_name, button_text)
- self.inports['button_ui'] = ('button_ui', ButtonInstance.num_instances)
- ButtonInstance.num_instances += 1
-
- def user_defined_constructor(self, window_id, event_name, button_text):
- self.window_id = window_id;
- self.event_name = event_name;
-
- def user_defined_destructor(self):
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, "", self)
-
- # state /creating_button
- self.states["/creating_button"] = State(1, "/creating_button", self)
- self.states["/creating_button"].setEnter(self._creating_button_enter)
-
- # state /running
- self.states["/running"] = State(2, "/running", self)
-
- # add children
- self.states[""].addChild(self.states["/creating_button"])
- self.states[""].addChild(self.states["/running"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/creating_button"]
-
- # transition /creating_button
- _creating_button_0 = Transition(self, self.states["/creating_button"], [self.states["/running"]])
- _creating_button_0.setAction(self._creating_button_0_exec)
- _creating_button_0.setTrigger(Event("button_created", None))
- self.states["/creating_button"].addTransition(_creating_button_0)
-
- # transition /running
- _running_0 = Transition(self, self.states["/running"], [self.states["/running"]])
- _running_0.setAction(self._running_0_exec)
- _running_0.setTrigger(Event("mouse_click", self.getInPortName("button_ui")))
- _running_0.setGuard(self._running_0_guard)
- self.states["/running"].addTransition(_running_0)
-
- def _creating_button_enter(self):
- self.big_step.outputEvent(Event("create_button", self.getOutPortName("ui"), [self.window_id, self.event_name, self.inports['button_ui']]))
-
- def _creating_button_0_exec(self, parameters):
- button_id = parameters[0]
- self.button_id = button_id
- self.big_step.outputEvent(Event("bind_event", self.getOutPortName("ui"), [button_id, ui.EVENTS.MOUSE_CLICK, "mouse_click", self.inports['button_ui']]))
-
- def _running_0_exec(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("button_pressed", None, [self.event_name])]))
-
- def _running_0_guard(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- return button == ui.MOUSE_BUTTONS.LEFT
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/creating_button"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class Button(AtomicDEVS, ObjectManagerBase):
- def __init__(self, name):
- AtomicDEVS.__init__(self, name)
- ObjectManagerBase.__init__(self)
- self.elapsed = 0
- self.name = "Button"
- self.obj_manager_out = self.addOutPort("obj_manager_out")
- self.outputs = {}
- self.outputs["parent"] = self.addOutPort("parent")
- self.button_ui = self.addInPort("button_ui")
- self.obj_manager_in = self.addInPort("obj_manager_in")
- self.input = self.addInPort("input")
- self.next_time = INFINITY
-
- def extTransition(self, inputs):
- self.next_time = 0
- all_inputs = []
- if self.button_ui in inputs:
- all_inputs.extend(inputs[self.button_ui])
- if self.obj_manager_in in inputs:
- all_inputs.extend(inputs[self.obj_manager_in])
- if self.input in inputs:
- all_inputs.extend(inputs[self.input])
- for input in all_inputs:
- if isinstance(input, str):
- tem = eval(input)
- self.addInput(tem)
- elif input[3].name == "create_instance":
- new_instance = ButtonInstance(self, input[3].parameters[1], input[3].parameters[2], input[3].parameters[3])
- self.instances.add(new_instance)
- #TODO: hardcoded but needs to be fixed
- p = new_instance.associations.get("parent")
- if p:
- p.addInstance(f"fields[0]")
- ev = Event("instance_created", None, parameters=[f"{input[3].parameters[0]}[{len(self.instances)-1}]"])
- self.to_send.append((input[1], input[0], input[2], ev))
- elif input[3].name == "start_instance":
- instance = list(self.instances)[input[2]]
- instance.start()
- ev = Event("instance_started", None, parameters=[f"{input[0]}[{input[2]}]"])
- self.to_send.append((input[0], input[1], input[2], ev))
- elif input[3].name == "delete_instance":
- instance = list(self.instances)[input[2]]
- instance.user_defined_destructor()
- instance.stop()
- ev = Event("instance_deleted", None, parameters=[self, input[0]])
- self.to_send.append((self.name, input[1], input[2], ev))
- elif input[3].name == "associate_instance":
- ev = Event("instance_associated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "disassociate_instance":
- ev = Event("instance_disassociated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "instance_created":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- instance.associations['fields'].instances[0] = input[3].parameters[0]
- elif input[3].name == "instance_started":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_deleted":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_associated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_disassociated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "set_association_name":
- ev = input[3]
- self.addInput(ev, force_internal=True)
- return self.instances
-
- def intTransition(self):
- earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (earliest == INFINITY):
- self.simulated_time = earliest
- self.to_send = []
- self.handleInput()
- self.stepAll()
- next_earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (len(self.to_send) == 0):
- self.next_time = 0
- elif next_earliest == INFINITY:
- self.next_time = INFINITY
- else:
- self.next_time = next_earliest - earliest
- return self.instances
-
- def outputFnc(self):
- to_dict = {}
- for sending in self.to_send:
- if sending[3].port == None:
- if self.obj_manager_out in to_dict:
- to_dict[self.obj_manager_out].append(sending)
- else:
- to_dict[self.obj_manager_out] = [sending]
- else:
- the_port = None
- for port in self.OPorts:
- if port.name == sending[0]:
- the_port = port
- if the_port in to_dict:
- to_dict[the_port].append(sending)
- else:
- to_dict[the_port] = [sending]
- return to_dict
-
- def timeAdvance(self):
- return self.next_time
- class BallInstance(RuntimeClassBase):
- num_instances = 0
- def __init__(self, atomdevs, canvas_id, x, y):
- RuntimeClassBase.__init__(self, atomdevs)
- self.associations = {}
- self.associations["parent"] = Association("Field", 1, 1)
-
- self.semantics.big_step_maximality = StatechartSemantics.TakeMany
- self.semantics.internal_event_lifeline = StatechartSemantics.Queue
- self.semantics.input_event_lifeline = StatechartSemantics.FirstComboStep
- self.semantics.priority = StatechartSemantics.SourceParent
- self.semantics.concurrency = StatechartSemantics.Single
-
- # build Statechart structure
- self.build_statechart_structure()
-
- # user defined attributes
- self.canvas_id = None
- self.pos = None
-
- # call user defined constructor
- BallInstance.user_defined_constructor(self, canvas_id, x, y)
- self.inports['ball_ui'] = ('ball_ui', BallInstance.num_instances)
- BallInstance.num_instances += 1
-
- def user_defined_constructor(self, canvas_id, x, y):
- self.canvas_id = canvas_id;
- self.r = 20.0;
- self.vel = {'x': random.uniform(-5.0, 5.0), 'y': random.uniform(-5.0, 5.0)};
- self.pos = {'x': x, 'y': y};
- self.smooth = 0.6; # value between 0 and 1
-
- # TODO:
- #circle = self.canvas.add_circle(x, y, self.r, {'fill':'#000'});
- #ui.bind_event(circle, ui.EVENTS.MOUSE_PRESS, self.controller, 'mouse_press', self.inports["ball_ui"]);
- #ui.bind_event(circle, ui.EVENTS.MOUSE_MOVE, self.controller, 'mouse_move', self.inports['ball_ui']);
- #ui.bind_event(circle, ui.EVENTS.MOUSE_RELEASE, self.controller, 'mouse_release', self.inports['ball_ui']);
- #self.element = circle;
-
- def user_defined_destructor(self):
- #self.canvas.remove_element(self.element);
- pass
-
-
- # builds Statechart structure
- def build_statechart_structure(self):
-
- # state <root>
- self.states[""] = State(0, "", self)
-
- # state /main_behaviour
- self.states["/main_behaviour"] = State(1, "/main_behaviour", self)
-
- # state /main_behaviour/initializing
- self.states["/main_behaviour/initializing"] = State(2, "/main_behaviour/initializing", self)
-
- # state /main_behaviour/creating_circle
- self.states["/main_behaviour/creating_circle"] = State(3, "/main_behaviour/creating_circle", self)
- self.states["/main_behaviour/creating_circle"].setEnter(self._main_behaviour_creating_circle_enter)
-
- # state /main_behaviour/bouncing
- self.states["/main_behaviour/bouncing"] = State(4, "/main_behaviour/bouncing", self)
- self.states["/main_behaviour/bouncing"].setEnter(self._main_behaviour_bouncing_enter)
- self.states["/main_behaviour/bouncing"].setExit(self._main_behaviour_bouncing_exit)
-
- # state /main_behaviour/dragging
- self.states["/main_behaviour/dragging"] = State(5, "/main_behaviour/dragging", self)
-
- # state /main_behaviour/selected
- self.states["/main_behaviour/selected"] = State(6, "/main_behaviour/selected", self)
-
- # state /deleted
- self.states["/deleted"] = State(7, "/deleted", self)
-
- # add children
- self.states[""].addChild(self.states["/main_behaviour"])
- self.states[""].addChild(self.states["/deleted"])
- self.states["/main_behaviour"].addChild(self.states["/main_behaviour/initializing"])
- self.states["/main_behaviour"].addChild(self.states["/main_behaviour/creating_circle"])
- self.states["/main_behaviour"].addChild(self.states["/main_behaviour/bouncing"])
- self.states["/main_behaviour"].addChild(self.states["/main_behaviour/dragging"])
- self.states["/main_behaviour"].addChild(self.states["/main_behaviour/selected"])
- self.states[""].fixTree()
- self.states[""].default_state = self.states["/main_behaviour"]
- self.states["/main_behaviour"].default_state = self.states["/main_behaviour/initializing"]
-
- # transition /main_behaviour/initializing
- _main_behaviour_initializing_0 = Transition(self, self.states["/main_behaviour/initializing"], [self.states["/main_behaviour/creating_circle"]])
- _main_behaviour_initializing_0.setAction(self._main_behaviour_initializing_0_exec)
- _main_behaviour_initializing_0.setTrigger(Event("set_association_name", None))
- self.states["/main_behaviour/initializing"].addTransition(_main_behaviour_initializing_0)
-
- # transition /main_behaviour/creating_circle
- _main_behaviour_creating_circle_0 = Transition(self, self.states["/main_behaviour/creating_circle"], [self.states["/main_behaviour/bouncing"]])
- _main_behaviour_creating_circle_0.setAction(self._main_behaviour_creating_circle_0_exec)
- _main_behaviour_creating_circle_0.setTrigger(Event("circle_created", None))
- self.states["/main_behaviour/creating_circle"].addTransition(_main_behaviour_creating_circle_0)
-
- # transition /main_behaviour/bouncing
- _main_behaviour_bouncing_0 = Transition(self, self.states["/main_behaviour/bouncing"], [self.states["/main_behaviour/bouncing"]])
- _main_behaviour_bouncing_0.setAction(self._main_behaviour_bouncing_0_exec)
- _main_behaviour_bouncing_0.setTrigger(Event("_0after"))
- self.states["/main_behaviour/bouncing"].addTransition(_main_behaviour_bouncing_0)
- _main_behaviour_bouncing_1 = Transition(self, self.states["/main_behaviour/bouncing"], [self.states["/main_behaviour/selected"]])
- _main_behaviour_bouncing_1.setAction(self._main_behaviour_bouncing_1_exec)
- _main_behaviour_bouncing_1.setTrigger(Event("mouse_press", self.getInPortName("ball_ui")))
- _main_behaviour_bouncing_1.setGuard(self._main_behaviour_bouncing_1_guard)
- self.states["/main_behaviour/bouncing"].addTransition(_main_behaviour_bouncing_1)
-
- # transition /main_behaviour/dragging
- _main_behaviour_dragging_0 = Transition(self, self.states["/main_behaviour/dragging"], [self.states["/main_behaviour/dragging"]])
- _main_behaviour_dragging_0.setAction(self._main_behaviour_dragging_0_exec)
- _main_behaviour_dragging_0.setTrigger(Event("mouse_move", self.getInPortName("ball_ui")))
- self.states["/main_behaviour/dragging"].addTransition(_main_behaviour_dragging_0)
- _main_behaviour_dragging_1 = Transition(self, self.states["/main_behaviour/dragging"], [self.states["/main_behaviour/bouncing"]])
- _main_behaviour_dragging_1.setAction(self._main_behaviour_dragging_1_exec)
- _main_behaviour_dragging_1.setTrigger(Event("mouse_release", self.getInPortName("ball_ui")))
- self.states["/main_behaviour/dragging"].addTransition(_main_behaviour_dragging_1)
-
- # transition /main_behaviour/selected
- _main_behaviour_selected_0 = Transition(self, self.states["/main_behaviour/selected"], [self.states["/main_behaviour/dragging"]])
- _main_behaviour_selected_0.setAction(self._main_behaviour_selected_0_exec)
- _main_behaviour_selected_0.setTrigger(Event("mouse_press", self.getInPortName("ball_ui")))
- _main_behaviour_selected_0.setGuard(self._main_behaviour_selected_0_guard)
- self.states["/main_behaviour/selected"].addTransition(_main_behaviour_selected_0)
- _main_behaviour_selected_1 = Transition(self, self.states["/main_behaviour/selected"], [self.states["/deleted"]])
- _main_behaviour_selected_1.setAction(self._main_behaviour_selected_1_exec)
- _main_behaviour_selected_1.setTrigger(Event("delete_self", None))
- self.states["/main_behaviour/selected"].addTransition(_main_behaviour_selected_1)
-
- def _main_behaviour_creating_circle_enter(self):
- self.big_step.outputEvent(Event("create_circle", self.getOutPortName("ui"), [self.canvas_id, self.pos['x'], self.pos['y'], self.r, {'fill':'#000'}, self.inports['ball_ui']]))
-
- def _main_behaviour_bouncing_enter(self):
- self.addTimer(0, 0.02)
-
- def _main_behaviour_bouncing_exit(self):
- self.removeTimer(0)
-
- def _main_behaviour_initializing_0_exec(self, parameters):
- association_name = parameters[0]
- self.association_name = association_name
-
- def _main_behaviour_creating_circle_0_exec(self, parameters):
- canvas_id = parameters[0]
- circle_id = parameters[1]
- self.circle_id = circle_id
- self.big_step.outputEvent(Event("bind_canvas_event", self.getOutPortName("ui"), [self.canvas_id, circle_id, ui.EVENTS.MOUSE_PRESS, 'mouse_press', self.inports['ball_ui']]))
- self.big_step.outputEvent(Event("bind_canvas_event", self.getOutPortName("ui"), [self.canvas_id, circle_id, ui.EVENTS.MOUSE_MOVE, 'mouse_move', self.inports['ball_ui']]))
- self.big_step.outputEvent(Event("bind_canvas_event", self.getOutPortName("ui"), [self.canvas_id, circle_id, ui.EVENTS.MOUSE_RELEASE, 'mouse_release', self.inports['ball_ui']]))
-
- def _main_behaviour_bouncing_0_exec(self, parameters):
- # Invert velocity when colliding with canvas border:
- if self.pos['x']-self.r <= 0 or self.pos['x']+self.r >= CANVAS_WIDTH:
- self.vel['x'] = -self.vel['x'];
- if self.pos['y']-self.r <= 0 or self.pos['y']+self.r >= CANVAS_HEIGHT:
- self.vel['y'] = -self.vel['y'];
- self.big_step.outputEvent(Event("move_element", self.getOutPortName("ui"), [self.canvas_id, self.circle_id, self.vel['x'], self.vel['y']]))
- self.pos['x'] += self.vel['x']
- self.pos['y'] += self.vel['y']
-
- def _main_behaviour_bouncing_1_exec(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- self.big_step.outputEvent(Event("set_element_color", self.getOutPortName("ui"), [self.canvas_id, self.circle_id, '#ff0']))
-
- def _main_behaviour_bouncing_1_guard(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- return button == ui.MOUSE_BUTTONS.LEFT
-
- def _main_behaviour_dragging_0_exec(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- # Always keep ball within canvas:
- x = min(max(0+self.r, x), CANVAS_WIDTH-self.r)
- y = min(max(0+self.r, y), CANVAS_HEIGHT-self.r)
-
- dx = x - self.pos['x']
- dy = y - self.pos['y']
-
- self.vel = {
- 'x': (1-self.smooth)*dx + self.smooth*self.vel['x'],
- 'y': (1-self.smooth)*dy + self.smooth*self.vel['y']
- }
-
- self.pos = {'x': x, 'y': y}
- self.big_step.outputEvent(Event("set_element_pos", self.getOutPortName("ui"), [self.canvas_id, self.circle_id, x-self.r, y-self.r]))
-
- def _main_behaviour_dragging_1_exec(self, parameters):
- x = parameters[0]
- y = parameters[1]
- self.big_step.outputEvent(Event("set_element_color", self.getOutPortName("ui"), [self.canvas_id, self.circle_id, '#f00']))
-
- def _main_behaviour_selected_0_exec(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- self.mouse_pos = {'x':x, 'y':y};
-
- def _main_behaviour_selected_0_guard(self, parameters):
- x = parameters[0]
- y = parameters[1]
- button = parameters[2]
- return button == ui.MOUSE_BUTTONS.LEFT
-
- def _main_behaviour_selected_1_exec(self, parameters):
- self.big_step.outputEventOM(Event("narrow_cast", None, [self, 'parent', Event("delete_ball", None, [self.association_name])]))
- self.big_step.outputEvent(Event("destroy_element", self.getOutPortName("ui"), [self.canvas_id, self.element_id]))
-
- def initializeStatechart(self):
- # enter default state
- self.default_targets = self.states["/main_behaviour"].getEffectiveTargetStates()
- RuntimeClassBase.initializeStatechart(self)
- class Ball(AtomicDEVS, ObjectManagerBase):
- def __init__(self, name):
- AtomicDEVS.__init__(self, name)
- ObjectManagerBase.__init__(self)
- self.elapsed = 0
- self.name = "Ball"
- self.obj_manager_out = self.addOutPort("obj_manager_out")
- self.outputs = {}
- self.outputs["parent"] = self.addOutPort("parent")
- self.ball_ui = self.addInPort("ball_ui")
- self.obj_manager_in = self.addInPort("obj_manager_in")
- self.input = self.addInPort("input")
- self.next_time = INFINITY
-
- def extTransition(self, inputs):
- self.simulated_time += self.elapsed
- self.next_time = 0
- all_inputs = []
- if self.ball_ui in inputs:
- all_inputs.extend(inputs[self.ball_ui])
- if self.obj_manager_in in inputs:
- all_inputs.extend(inputs[self.obj_manager_in])
- if self.input in inputs:
- all_inputs.extend(inputs[self.input])
- for input in all_inputs:
- if isinstance(input, str):
- tem = eval(input)
- self.addInput(tem)
- elif input[3].name == "create_instance":
- self.instances.add(BallInstance(self, input[3].parameters[1], input[3].parameters[2], input[3].parameters[3]))
- ev = Event("instance_created", None, parameters=[f"{input[3].parameters[0]}[{len(self.instances)-1}]"])
- self.to_send.append((self.name, input[0], input[2], ev))
- elif input[3].name == "start_instance":
- instance = list(self.instances)[input[3].parameters[0]]
- instance.start()
- ev = Event("instance_started", None, parameters=[input[3].parameters[0]])
- self.to_send.append((input[0], input[1], input[3].parameters[0], ev))
- elif input[3].name == "delete_instance":
- ev = Event("instance_deleted", None, parameters=[])
- self.to_send.append((self.name, input[0], input[2], ev))
- elif input[3].name == "associate_instance":
- ev = Event("instance_associated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "disassociate_instance":
- ev = Event("instance_disassociated", None, parameters=[TODO])
- self.to_send.append((self.name, TODO, TODO, ev))
- elif input[3].name == "instance_created":
- association = self.processAssociationReference(input[3].parameters[0])[0]
- instance = list(self.instances)[association[1]]
- instance.addEvent(input[3])
- instance.associations['fields'].instances[0] = input[3].parameters[0]
- elif input[3].name == "instance_started":
- instance = list(self.instances)[input[3].parameters[0]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_deleted":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_associated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "instance_disassociated":
- instance = list(self.instances)[input[2]]
- instance.addEvent(input[3])
- elif input[3].name == "set_association_name":
- ev = input[3]
- self.addInput(ev, force_internal=True)
- return self.instances
-
- def intTransition(self):
- # TODO: self.simulated_time added here, do this everywhere
- earliest = min(self.getEarliestEventTime(), self.simulated_time + self.input_queue.getEarliestTime())
- if not (earliest == INFINITY):
- self.simulated_time = earliest
- self.to_send = []
- self.handleInput()
- self.stepAll()
- next_earliest = min(self.getEarliestEventTime(), self.input_queue.getEarliestTime())
- if not (len(self.to_send) == 0):
- self.next_time = 0
- elif next_earliest == INFINITY:
- self.next_time = INFINITY
- else:
- self.next_time = next_earliest - earliest
- #helping = self.time_next[0] - self.time_last[0]
- return self.instances
-
- def outputFnc(self):
- to_dict = {}
- for sending in self.to_send:
- if sending[3].port == None:
- if self.obj_manager_out in to_dict:
- to_dict[self.obj_manager_out].append(sending)
- else:
- to_dict[self.obj_manager_out] = [sending]
- else:
- the_port = None
- for port in self.OPorts:
- if port.name == sending[0]:
- the_port = port
- if the_port in to_dict:
- to_dict[the_port].append(sending)
- else:
- to_dict[the_port] = [sending]
- return to_dict
-
- def timeAdvance(self):
- return self.next_time
- class ObjectManagerState:
- def __init__(self):
- self.to_send = [(None, "MainApp", 0, Event("start_instance", None, None))]
- class ObjectManager(AtomicDEVS):
- def __init__(self, name):
- AtomicDEVS.__init__(self, name)
- self.State = ObjectManagerState()
- self.input = self.addInPort("input")
- self.output = {}
- self.output["MainApp"] = self.addOutPort()
- self.output["Field"] = self.addOutPort()
- self.output["Button"] = self.addOutPort()
- self.output["Ball"] = self.addOutPort()
-
- def extTransition(self, inputs):
- all_inputs = inputs[self.input]
- for input in all_inputs:
- self.State.to_send.append(input)
- return self.State
-
- def intTransition(self):
- self.State.to_send = []
- return self.State
-
- def outputFnc(self):
- out_dict = {}
- for (source, target, id, message) in self.State.to_send:
- if self.output[target] in out_dict:
- out_dict[self.output[target]].append((source, target, id, message))
- else:
- out_dict[self.output[target]] = [(source, target, id, message)]
- return out_dict
-
- def timeAdvance(self):
- if self.State.to_send:
- return 0
- return INFINITY
- class Controller(CoupledDEVS):
- def __init__(self, name):
- CoupledDEVS.__init__(self, name)
- self.ui = self.addInPort("ui")
- self.addOutPort("ui")
- self.objectmanager = self.addSubModel(ObjectManager("ObjectManager"))
- self.atomic0 = self.addSubModel(MainApp("MainApp"))
- self.atomic1 = self.addSubModel(Field("Field"))
- self.atomic2 = self.addSubModel(Button("Button"))
- self.atomic3 = self.addSubModel(Ball("Ball"))
- self.connectPorts(self.atomic0.obj_manager_out, self.objectmanager.input)
- self.connectPorts(self.objectmanager.output["MainApp"], self.atomic0.obj_manager_in)
- self.connectPorts(self.atomic0.outputs["fields"], self.atomic1.input)
- self.connectPorts(self.atomic1.obj_manager_out, self.objectmanager.input)
- self.connectPorts(self.objectmanager.output["Field"], self.atomic1.obj_manager_in)
- self.connectPorts(self.atomic1.outputs["balls"], self.atomic3.input)
- self.connectPorts(self.atomic1.outputs["buttons"], self.atomic2.input)
- self.connectPorts(self.atomic1.outputs["parent"], self.atomic0.input)
- self.connectPorts(self.atomic2.obj_manager_out, self.objectmanager.input)
- self.connectPorts(self.objectmanager.output["Button"], self.atomic2.obj_manager_in)
- self.connectPorts(self.atomic2.outputs["parent"], self.atomic1.input)
- self.connectPorts(self.atomic3.obj_manager_out, self.objectmanager.input)
- self.connectPorts(self.objectmanager.output["Ball"], self.atomic3.obj_manager_in)
- self.connectPorts(self.atomic3.outputs["parent"], self.atomic1.input)
|