Updating package & added support for connector origin

FastyBird · Jan 20, 2022 · aa87e32 · aa87e32
1 parent 0fc3dba
commit aa87e32
Show file tree

Hide file tree

Showing 7 changed files with 12 additions and 12 deletions.
diff --git a/composer.json b/composer.json
@@ -41,7 +41,7 @@
   "require" : {
     "php" : ">=7.4.0|>=8.0.0",
     "cweagans/composer-patches" : "^1.7",
-    "fastybird/metadata" : "^0.31",
+    "fastybird/metadata" : "^0.33",
     "nette/bootstrap" : "^3.1",
     "nette/di" : "^3.0",
     "nette/utils" : "^3.2"

diff --git a/fb_exchange/__init__.py b/fb_exchange/__init__.py
@@ -18,4 +18,4 @@
 Exchange library
 """
 
-__version__ = "0.12.0"
+__version__ = "0.13.0"
diff --git a/fb_exchange/consumer.py b/fb_exchange/consumer.py
@@ -24,7 +24,7 @@
 
 # Library dependencies
 from fb_metadata.routing import RoutingKey
-from fb_metadata.types import ModuleOrigin, PluginOrigin
+from fb_metadata.types import ConnectorOrigin, ModuleOrigin, PluginOrigin
 
 
 class IConsumer(ABC):  # pylint: disable=too-few-public-methods
@@ -40,7 +40,7 @@ class IConsumer(ABC):  # pylint: disable=too-few-public-methods
     @abstractmethod
     def consume(
         self,
-        origin: Union[ModuleOrigin, PluginOrigin],
+        origin: Union[ModuleOrigin, PluginOrigin, ConnectorOrigin],
         routing_key: RoutingKey,
         data: Optional[Dict[str, Union[str, int, float, bool, None]]],
     ) -> None:
@@ -75,7 +75,7 @@ def __init__(
 
     def consume(
         self,
-        origin: Union[ModuleOrigin, PluginOrigin],
+        origin: Union[ModuleOrigin, PluginOrigin, ConnectorOrigin],
         routing_key: RoutingKey,
         data: Optional[Dict],
     ) -> None:

diff --git a/fb_exchange/publisher.py b/fb_exchange/publisher.py
@@ -24,7 +24,7 @@
 
 # Library dependencies
 from fb_metadata.routing import RoutingKey
-from fb_metadata.types import ModuleOrigin, PluginOrigin
+from fb_metadata.types import ConnectorOrigin, ModuleOrigin, PluginOrigin
 
 
 class IPublisher(ABC):  # pylint: disable=too-few-public-methods
@@ -40,7 +40,7 @@ class IPublisher(ABC):  # pylint: disable=too-few-public-methods
     @abstractmethod
     def publish(
         self,
-        origin: Union[ModuleOrigin, PluginOrigin],
+        origin: Union[ModuleOrigin, PluginOrigin, ConnectorOrigin],
         routing_key: RoutingKey,
         data: Optional[Dict],
     ) -> None:
@@ -66,7 +66,7 @@ def set_publishers(self, publishers: List[IPublisher]) -> None:
     @abstractmethod
     def append(
         self,
-        origin: Union[ModuleOrigin, PluginOrigin],
+        origin: Union[ModuleOrigin, PluginOrigin, ConnectorOrigin],
         routing_key: RoutingKey,
         data: Optional[Dict],
     ) -> None:
@@ -117,7 +117,7 @@ def __init__(
 
     def publish(
         self,
-        origin: Union[ModuleOrigin, PluginOrigin],
+        origin: Union[ModuleOrigin, PluginOrigin, ConnectorOrigin],
         routing_key: RoutingKey,
         data: Optional[Dict],
     ) -> None:

diff --git a/requirements.txt b/requirements.txt
@@ -1,3 +1,3 @@
-fastybird-metadata>=0.31
+fastybird-metadata>=0.33
 kink>=0.6
 setuptools>=57.4
diff --git a/src/Consumer/IConsumer.php b/src/Consumer/IConsumer.php
@@ -30,7 +30,7 @@ interface IConsumer
 {
 
 	/**
-	 * @param MetadataTypes\ModuleOriginType|MetadataTypes\PluginOriginType $origin
+	 * @param MetadataTypes\ModuleOriginType|MetadataTypes\PluginOriginType|MetadataTypes\ConnectorOriginType $origin
 	 * @param MetadataTypes\RoutingKeyType $routingKey
 	 * @param Utils\ArrayHash|null $data
 	 *

diff --git a/src/Publisher/IPublisher.php b/src/Publisher/IPublisher.php
@@ -30,7 +30,7 @@ interface IPublisher
 {
 
 	/**
-	 * @param MetadataTypes\ModuleOriginType|MetadataTypes\PluginOriginType $origin
+	 * @param MetadataTypes\ModuleOriginType|MetadataTypes\PluginOriginType|MetadataTypes\ConnectorOriginType $origin
 	 * @param MetadataTypes\RoutingKeyType $routingKey
 	 * @param Utils\ArrayHash|null $data
 	 *