Source code for caspia.gateway.services.base

from abc import ABCMeta, abstractmethod, abstractproperty

from caspia.meadow.client.gateway import ServiceGatewayMixin
from caspia.meadow.services import ServiceMeta

service_classes = set()


class GatewayServiceMeta(ServiceMeta, ABCMeta):
    def __new__(mcs, name, bases, attrs):
        cls = super().__new__(mcs, name, bases, attrs)
        service_classes.add(cls)
        return cls


class GatewayService(ServiceGatewayMixin, metaclass=GatewayServiceMeta):
    type = None

    def __init__(self, config, network, storage):
        self.config = config
        super().__init__(config['name'])
        self.network = network
        self.storage = storage

    @abstractmethod
    def configure(self):
        raise NotImplementedError

    @abstractproperty
    @property
    def dependant_components(self):
        pass

    async def on_component_event(self, component, event):
        pass

    def get_node(self):
        return self.network.get_node(self.config['node'])