<filename>modules/ravestate/activation.py
# Ravestate class which encapsualtes the activation of a single state

from ravestate import state
from ravestate import wrappers
from ravestate import icontext
from threading import Thread


class StateActivation:

    def __init__(self, st: state.State, ctx: icontext.IContext):
        self.state_to_activate = st
        self.unfulfilled = [set(trigger_clause) for trigger_clause in st.triggers]
        self.ctx = ctx
        self.args = []
        self.kwargs = {}

    def specificity(self):
        # TODO: Calculate specificity properly
        return 1.

    def notify_signal(self, signal_name: str):
        for unfulfilled_trigger in self.unfulfilled:
            if signal_name in unfulfilled_trigger:
                unfulfilled_trigger.remove(signal_name)
                if len(unfulfilled_trigger) == 0:
                    return 1
        return 0

    def run(self, args=(), kwargs={}):
        self.args = args
        self.kwargs = kwargs
        return Thread(target=self._run_private)

    def _run_private(self):
        context_wrapper = wrappers.ContextWrapper(self.ctx, self.state_to_activate)
        result = self.state_to_activate(context_wrapper, self.args, self.kwargs)
        if result == context_wrapper.EmitSignal and self.state_to_activate.signal:
            self.ctx.emit(self.state_to_activate.signal)
        if result == context_wrapper.DeleteMe:
            self.ctx.rm_state(st=self.state_to_activate)

<filename>modules/ravestate/activation.py
# Ravestate class which encapsualtes the activation of a single state

from ravestate import state
from ravestate import wrappers
from ravestate import icontext
from threading import Thread


class StateActivation:

    def __init__(self, st: state.State, ctx: icontext.IContext):
        self.state_to_activate = st
        self.unfulfilled = [set(trigger_clause) for trigger_clause in st.triggers]
        self.ctx = ctx
        self.args = []
        self.kwargs = {}

    def specificity(self):
        # TODO: Calculate specificity properly
        return 1.

    def notify_signal(self, signal_name: str):
        for unfulfilled_trigger in self.unfulfilled:
            if signal_name in unfulfilled_trigger:
                unfulfilled_trigger.remove(signal_name)
                if len(unfulfilled_trigger) == 0:
                    return 1
        return 0

    def run(self, args=(), kwargs={}):
        self.args = args
        self.kwargs = kwargs
        return Thread(target=self._run_private)

    def _run_private(self):
        context_wrapper = wrappers.ContextWrapper(self.ctx, self.state_to_activate)
        result = self.state_to_activate(context_wrapper, self.args, self.kwargs)
        if result == context_wrapper.EmitSignal and self.state_to_activate.signal:
            self.ctx.emit(self.state_to_activate.signal)
        if result == context_wrapper.DeleteMe:
            self.ctx.rm_state(st=self.state_to_activate)

# Ravestate class which encapsualtes the activation of a single state # TODO: Calculate specificity properly