import asyncio
from asyncua import Client
from asyncua.common.subscription import Subscription

opc_ua_client: Client
clients = {} # {WebSocket: set(subscribed_tags)}
node_storage = {}
event_storage = {}
queue = asyncio.Queue(maxsize=10000)
event_queue = asyncio.Queue(maxsize=1000)
subscription_handler: Subscription
subscribed_nodes = set()