Added Pokemon Example App

packages/clean_framework/example/lib/features/home/domain/home_entity.dart

@@ -0,0 +1,6 @@
+import 'package:clean_framework/clean_framework_core.dart';
+
+class HomeEntity extends Entity {
+  @override
+  List<Object?> get props => [];
+}

packages/clean_framework/lib/src/core/core.dart

@@ -4,5 +4,6 @@ export 'external_interface/request.dart';
 export 'external_interface/response.dart';
 export 'gateway/gateway.dart';
 export 'gateway/gateway_provider.dart';
+export 'use_case/entity.dart';
 export 'use_case/use_case.dart';
 export 'use_case/use_case_provider.dart';

packages/clean_framework/lib/src/core/gateway/gateway.dart

@@ -11,12 +11,13 @@ import 'package:meta/meta.dart';
 
 abstract class Gateway<O extends Output, R extends Request,
     P extends SuccessResponse, S extends SuccessInput> {
-  UseCase? _useCase;
-
   void attach(
     ProviderRef<Object> ref, {
     required List<UseCaseProvider> providers,
   }) {
+    _ref = ref;
+    _useCaseProviders = providers;
+
     for (final useCaseProvider in providers) {
       useCaseProvider.notifier.then(
         (notifier) {
@@ -28,6 +29,9 @@ abstract class Gateway<O extends Output, R extends Request,
     }
   }
 
+  late final ProviderRef<Object> _ref;
+  late final List<UseCaseProvider> _useCaseProviders;
+
   @visibleForTesting
   @nonVirtual
   // ignore: use_setters_to_change_properties
@@ -60,40 +64,25 @@ abstract class Gateway<O extends Output, R extends Request,
   }
 }
 
-abstract class BridgeGateway<SUBSCRIBER_OUTPUT extends Output,
-    PUBLISHER_OUTPUT extends Output, SUBSCRIBER_INPUT extends Input> {
-  BridgeGateway({
-    required UseCase subscriberUseCase,
-    required UseCase publisherUseCase,
-  })  : _subscriberUseCase = subscriberUseCase,
-        _publisherUseCase = publisherUseCase {
-    _subscriberUseCase.subscribe<SUBSCRIBER_OUTPUT, SUBSCRIBER_INPUT>(
-      (output) {
-        return Either<FailureInput, SUBSCRIBER_INPUT>.right(
-          onResponse(
-            _publisherUseCase.getOutput<PUBLISHER_OUTPUT>(),
-          ),
-        );
-      },
-    );
-  }
-  late final UseCase _subscriberUseCase;
-  late final UseCase _publisherUseCase;
-
-  SUBSCRIBER_INPUT onResponse(PUBLISHER_OUTPUT output);
-}
-
 abstract class WatcherGateway<
     O extends Output,
     R extends Request,
     P extends SuccessResponse,
     S extends SuccessInput> extends Gateway<O, R, P, S> {
   @override
-  FailureInput onFailure(FailureResponse failureResponse) => FailureInput();
+  FailureInput onFailure(FailureResponse failureResponse) {
+    return FailureInput(message: failureResponse.message);
+  }
 
   @nonVirtual
   void yieldResponse(P response) {
-    _useCase?.setInput(onSuccess(response));
+    for (final useCaseProvider in _useCaseProviders) {
+      useCaseProvider.notifier.then(
+        (notifier) {
+          _ref.read(notifier).setInput(onSuccess(response));
+        },
+      );
+    }
   }
 }
 

packages/clean_framework/lib/src/core/use_case/entity.dart

@@ -5,4 +5,6 @@ import 'package:flutter/foundation.dart';
 abstract class Entity extends Equatable {
   @override
   bool get stringify => true;
+
+  external Entity copyWith();
 }

packages/clean_framework/lib/src/core/use_case/use_case.dart

@@ -14,9 +14,9 @@ abstract class UseCase<E extends Entity> extends StateNotifier<E>
     with UseCaseDebounceMixin {
   UseCase({
     required E entity,
+    List<UseCaseTransformer<E>>? transformers,
     @Deprecated('Use transformers instead') OutputFilterMap<E>? outputFilters,
     @Deprecated('Use transformers instead') InputFilterMap<E>? inputFilters,
-    List<UseCaseTransformer<E>>? transformers,
   })  : _outputFilters = Map.of(outputFilters ?? const {}),
         _inputFilters = Map.of(inputFilters ?? const {}),
         super(entity) {
@@ -34,6 +34,7 @@ abstract class UseCase<E extends Entity> extends StateNotifier<E>
   @protected
   E get entity => super.state;
 
+  @visibleForTesting
   @protected
   set entity(E newEntity) => super.state = newEntity;
 
@@ -49,6 +50,7 @@ abstract class UseCase<E extends Entity> extends StateNotifier<E>
     _requestSubscriptions.add<O>(subscription);
   }
 
+  @visibleForTesting
   @protected
   Future<void> request<O extends Output, S extends SuccessInput>(
     O output, {

packages/clean_framework/lib/src/core/use_case/use_case_debounce_mixin.dart

@@ -10,6 +10,7 @@ mixin UseCaseDebounceMixin {
   /// in a given frame of [duration].
   ///
   /// If [immediate] is false, then then first action will also be debounced.
+  @visibleForTesting
   @protected
   void debounce({
     required void Function() action,

packages/clean_framework/test/core/gateway/gateway_test.dart

@@ -0,0 +1,137 @@
+import 'package:clean_framework/clean_framework.dart';
+import 'package:clean_framework/clean_framework_core.dart';
+import 'package:flutter_test/flutter_test.dart';
+
+void main() {
+  group('Gateway tests |', () {
+    test('success', () async {
+      final gateway = TestGateway()
+        ..feedResponse(
+          (request) async => Either.right(
+            TestSuccessResponse('Hello ${request.name}!'),
+          ),
+        );
+
+      final input = await gateway.buildInput(
+        TestGatewayOutput('Acme Software'),
+      );
+
+      expect(input.isRight, isTrue);
+      expect(input.right.message, 'Hello Acme Software!');
+    });
+
+    test('failure', () async {
+      final gateway = TestGateway()
+        ..feedResponse(
+          (request) async => const Either.left(
+            TypedFailureResponse(
+              message: 'Something went wrong',
+              type: 'failure',
+            ),
+          ),
+        );
+
+      final input = await gateway.buildInput(
+        TestGatewayOutput('Acme Software'),
+      );
+
+      expect(input.isLeft, isTrue);
+      expect(input.left.message, 'Something went wrong');
+    });
+  });
+
+  group('Watcher Gateway', () {
+    test('success', () async {
+      final gateway = TestWatcherGateway()
+        ..feedResponse(
+          (request) async => Either.right(
+            TestSuccessResponse('Hello ${request.name}!'),
+          ),
+        );
+
+      final input = await gateway.buildInput(
+        TestGatewayOutput('Acme Software'),
+      );
+
+      expect(input.isRight, isTrue);
+      expect(input.right.message, 'Hello Acme Software!');
+    });
+
+    test('failure', () async {
+      final gateway = TestWatcherGateway()
+        ..feedResponse(
+          (request) async => const Either.left(
+            TypedFailureResponse(
+              message: 'Something went wrong',
+              type: 'failure',
+            ),
+          ),
+        );
+
+      final input = await gateway.buildInput(
+        TestGatewayOutput('Acme Software'),
+      );
+
+      expect(input.isLeft, isTrue);
+      expect(input.left.message, 'Something went wrong');
+    });
+  });
+}
+
+class TestGateway extends Gateway<TestGatewayOutput, TestRequest,
+    TestSuccessResponse, TestSuccessInput> {
+  @override
+  TestRequest buildRequest(TestGatewayOutput output) {
+    return TestRequest(output.name);
+  }
+
+  @override
+  FailureInput onFailure(FailureResponse failureResponse) {
+    return FailureInput(message: failureResponse.message);
+  }
+
+  @override
+  TestSuccessInput onSuccess(TestSuccessResponse response) {
+    return TestSuccessInput(response.message);
+  }
+}
+
+class TestWatcherGateway extends WatcherGateway<TestGatewayOutput, TestRequest,
+    TestSuccessResponse, TestSuccessInput> {
+  @override
+  TestRequest buildRequest(TestGatewayOutput output) {
+    return TestRequest(output.name);
+  }
+
+  @override
+  TestSuccessInput onSuccess(covariant TestSuccessResponse response) {
+    return TestSuccessInput(response.message);
+  }
+}
+
+class TestGatewayOutput extends Output {
+  TestGatewayOutput(this.name);
+
+  final String name;
+
+  @override
+  List<Object?> get props => [name];
+}
+
+class TestSuccessInput extends SuccessInput {
+  TestSuccessInput(this.message);
+
+  final String message;
+}
+
+class TestSuccessResponse extends SuccessResponse {
+  const TestSuccessResponse(this.message);
+
+  final String message;
+}
+
+class TestRequest extends Request {
+  const TestRequest(this.name);
+
+  final String name;
+}

packages/clean_framework/test/core/gateway/gateyway_provider_test.dart

@@ -0,0 +1 @@
+void main() {}