from threading import Thread
from triggers import *
import db_routing


class Executor(Thread):
    def __init__(self, scenario):
        threading.Thread.__init__(self)
        self.sceanrio_id = scenario.id
        self.trigger_def = db_routing.get_trigers(scenario.id).def_name
        self.trigger_args = scenario.trigger_args
        self.action_def = db_routing.get_actions(scenario.id).def_name
        self.action_args = scenario.action_args

    def execute(self):
        self.trigger_def(self.trigger_args)
        self.action_def.def_name(self.action_args)

    def run(self):
        thread = Thread(target=self.execute)
        thread.start()
        thread.join()
        db_routing.delete_scenario(self.sceanrio_id)