import networkx as nx

import heapq

import datetime

import logging

logging.basicConfig(level=logging.INFO)

node_types = {

"sensor": {

"default_state": {"value": 0},

"on_threshold_event": lambda node, event: logging.info(f"Sensor {node} event: {event}")

},

"controller": {

"default_state": {"status": "idle"},

"on_state_change": lambda node, event: logging.info(f"Controller {node} event: {event}")

}

}

event_queue = []

def add_node_with_type(graph, node_id, node_type, **kwargs):

state = node_types[node_type]["default_state"].copy()

state.update(kwargs)

graph.add_node(node_id, node_type=node_type, **state)

def add_event(event_type, node, priority, **kwargs):

event = {"event_type": event_type, "node": node, "timestamp": datetime.datetime.now(), "priority": priority, **kwargs}

heapq.heappush(event_queue, (priority, event))

logging.info(f"Event added: {event}")

def process_events(graph):

while event_queue:

priority, event = heapq.heappop(event_queue)

logging.info(f"Processing: {event}")

node_type = graph.nodes[event["node"]]["node_type"]

if event["event_type"] == "threshold_event" and "on_threshold_event" in node_types[node_type]:

node_types[node_type]["on_threshold_event"](event["node"], event)

elif event["event_type"] == "state_change" and "on_state_change" in node_types[node_type]:

node_types[node_type]["on_state_change"](event["node"], event)

graph = nx.Graph()

add_node_with_type(graph, "sensor1", "sensor", value=5)

add_node_with_type(graph, "controller1", "controller", status="active")

add_event("threshold_event", "sensor1", 1, value=10)

add_event("state_change", "controller1", 2, status="inactive")

process_events(graph)