Merge branch '1-0-1' into 'main'

1-0-1

See merge request fluxlabs/flux-eco/global-stream!4

CHANGELOG.md

@@ -1,5 +1,8 @@
 # CHANGELOG
 
+## [1.0.1]
+* fix functional usage
+
 ## [1.0.0]
 * added functional usage
 

composer.json

@@ -1,7 +1,7 @@
 {
   "name": "flux-eco/global-stream",
   "description": "Stores cross domain events and publishes them to subscribed consumers",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "type": "flux-app",
   "keywords": [
     "flux-eco",

src/Adapters/Outbounds.php

@@ -7,13 +7,9 @@
 use FluxEco\GlobalStream\Adapters;
 use FluxEco\GlobalStream\Core;
 use FluxEco\GlobalStream\Core\Ports;
-use FluxEco\GlobalStream\Adapters\ValueObjectProvider\ValueObjectAdapter;
-use FluxEco\GlobalStream\Adapters\Publisher\Message;
 use fluxValueObject;
 use fluxStorage;
-use fluxJsonSchemaDocument;
 use fluxProjection;
-use FluxEco\GlobalStream\Core\Domain;
 
 class Outbounds implements Core\Ports\Outbounds
 {
@@ -40,26 +36,6 @@ public static function new(
         return new self($streamStorageConfigEnvPrefix, $streamTableName, $streamStateSchemaFile);
     }
 
-    final public function getGlobalStreamStorageClient() : Ports\Storage\GlobalStreamStorageClient
-    {
-        return Adapters\Storage\GlobalStreamStorageClient::new($this->streamStorageName, $this->streamTableName,
-            $this->streamStateSchema);
-    }
-
-    final public function getValueObjectProvider() : Ports\ValueObject\ValueObjectProviderClient
-    {
-        return Adapters\ValueObjectProvider\ValueObjectProviderClient::new();
-    }
-
-
-
-    public function getStatePublisher() : Ports\Publisher\StatePublisher
-    {
-        $consumerRegistry = Adapters\Publisher\ConsumerRegistry::new(
-            Adapters\Publisher\ConsumerRegistry::SUBJECT_AGGREGATE_ROOT, [Adapters\Projection\ProjectionClient::new()]
-        );
-        return Adapters\Publisher\StatePublisherClient::new($consumerRegistry);
-    }
 
     public function getCurrentTime() : string
     {

src/Api.php

@@ -17,6 +17,7 @@ private function __construct(Ports\GlobalStreamService $globalStreamService)
     public static function newFromEnv(array $subjectNames = []) : self
     {
         $env = Env::new();
+
         $outbounds = Outbounds::new(
             $env->getStreamStorageConfigEnvPrefix(),
             $env->getStreamTableName(),