observer

Defines the abstract observer interface for safety analysis visualization.

SafetyObserver

Bases: ABC

Abstract base class for all observers in the safety system.

Allows the separation of calculation logic (Model) from visualization or reporting (View), implementing the Observer design pattern.

Source code in src/ecc_analyzer/interfaces/observer.py

class SafetyObserver(ABC):
    """Abstract base class for all observers in the safety system.

    Allows the separation of calculation logic (Model) from visualization or
    reporting (View), implementing the Observer design pattern.
    """

    @abstractmethod
    def on_block_computed(
        self,
        block: "BlockInterface",
        input_ports: dict,
        spfm_in: dict[FaultType, float],
        lfm_in: dict[FaultType, float],
        spfm_out: dict[FaultType, float],
        lfm_out: dict[FaultType, float],
    ) -> dict:
        """Triggered after a hardware block completes its FIT rate transformation.

        The observer acts upon this event (e.g., drawing the block in a diagram)
        and returns the new visual connection points (ports).

        Args:
            block (BlockInterface): The instance of the logic block (defines shape and type).
            input_ports (dict): Mapping of fault types to incoming node IDs (defines edge origins).
            spfm_in (dict[FaultType, float]): Dictionary of incoming residual/SPFM FIT rates.
            lfm_in (dict[FaultType, float]): Dictionary of incoming latent/LFM FIT rates.
            spfm_out (dict[FaultType, float]): Updated dictionary of outgoing residual/SPFM FIT rates.
            lfm_out (dict[FaultType, float]): Updated dictionary of outgoing latent/LFM FIT rates.

        Returns:
            dict: A dictionary containing the newly created output ports (node IDs) to be
            used as inputs for the next block in the chain.
        """
        pass

on_block_computed(block, input_ports, spfm_in, lfm_in, spfm_out, lfm_out) abstractmethod

Triggered after a hardware block completes its FIT rate transformation.

The observer acts upon this event (e.g., drawing the block in a diagram) and returns the new visual connection points (ports).

Parameters:

Name	Type	Description	Default
block	BlockInterface	The instance of the logic block (defines shape and type).	required
input_ports	dict	Mapping of fault types to incoming node IDs (defines edge origins).	required
spfm_in	dict[FaultType, float]	Dictionary of incoming residual/SPFM FIT rates.	required
lfm_in	dict[FaultType, float]	Dictionary of incoming latent/LFM FIT rates.	required
spfm_out	dict[FaultType, float]	Updated dictionary of outgoing residual/SPFM FIT rates.	required
lfm_out	dict[FaultType, float]	Updated dictionary of outgoing latent/LFM FIT rates.	required

Returns:

Name	Type	Description
dict	dict	A dictionary containing the newly created output ports (node IDs) to be
	dict	used as inputs for the next block in the chain.

Source code in src/ecc_analyzer/interfaces/observer.py

@abstractmethod
def on_block_computed(
    self,
    block: "BlockInterface",
    input_ports: dict,
    spfm_in: dict[FaultType, float],
    lfm_in: dict[FaultType, float],
    spfm_out: dict[FaultType, float],
    lfm_out: dict[FaultType, float],
) -> dict:
    """Triggered after a hardware block completes its FIT rate transformation.

    The observer acts upon this event (e.g., drawing the block in a diagram)
    and returns the new visual connection points (ports).

    Args:
        block (BlockInterface): The instance of the logic block (defines shape and type).
        input_ports (dict): Mapping of fault types to incoming node IDs (defines edge origins).
        spfm_in (dict[FaultType, float]): Dictionary of incoming residual/SPFM FIT rates.
        lfm_in (dict[FaultType, float]): Dictionary of incoming latent/LFM FIT rates.
        spfm_out (dict[FaultType, float]): Updated dictionary of outgoing residual/SPFM FIT rates.
        lfm_out (dict[FaultType, float]): Updated dictionary of outgoing latent/LFM FIT rates.

    Returns:
        dict: A dictionary containing the newly created output ports (node IDs) to be
        used as inputs for the next block in the chain.
    """
    pass