m3_lightmeter/test/screens/metering/components/light_sensor/bloc_container_light_sensor_test.dart

import 'package:bloc_test/bloc_test.dart';
import 'package:lightmeter/interactors/metering_interactor.dart';
import 'package:lightmeter/screens/metering/communication/bloc_communication_metering.dart';
import 'package:lightmeter/screens/metering/communication/event_communication_metering.dart'
    as communication_events;
import 'package:lightmeter/screens/metering/communication/state_communication_metering.dart'
    as communication_states;
import 'package:lightmeter/screens/metering/components/light_sensor_container/bloc_container_light_sensor.dart';
import 'package:lightmeter/screens/metering/components/light_sensor_container/state_container_light_sensor.dart';
import 'package:m3_lightmeter_resources/m3_lightmeter_resources.dart';
import 'package:mocktail/mocktail.dart';
import 'package:test/test.dart';

class _MockMeteringCommunicationBloc extends MockBloc<
    communication_events.MeteringCommunicationEvent,
    communication_states.MeteringCommunicationState> implements MeteringCommunicationBloc {}

class _MockMeteringInteractor extends Mock implements MeteringInteractor {}

void main() {
  late _MockMeteringInteractor meteringInteractor;
  late _MockMeteringCommunicationBloc communicationBloc;
  late LightSensorContainerBloc bloc;

  setUpAll(() {
    meteringInteractor = _MockMeteringInteractor();
    communicationBloc = _MockMeteringCommunicationBloc();
  });

  setUp(() {
    bloc = LightSensorContainerBloc(
      meteringInteractor,
      communicationBloc,
    );
  });

  tearDown(() {
    bloc.close();
  });

  group(
    '`LuxMeteringEvent`',
    () {
      const List<int> luxIterable = [1, 2, 2, 2, 3];
      final List<double> resultList = luxIterable.map((lux) => log2(lux / 2.5)).toList();
      blocTest<LightSensorContainerBloc, LightSensorContainerState>(
        'Turn measuring on/off',
        build: () => bloc,
        setUp: () {
          when(() => meteringInteractor.luxStream())
              .thenAnswer((_) => Stream.fromIterable(luxIterable));
          when(() => meteringInteractor.lightSensorEvCalibration).thenReturn(0.0);
        },
        act: (bloc) async {
          bloc.onCommunicationState(const communication_states.MeasureState());
          await Future.delayed(Duration.zero);
          bloc.onCommunicationState(const communication_states.MeasureState());
        },
        verify: (_) {
          verify(() => meteringInteractor.luxStream().listen((_) {})).called(1);
          verify(() => meteringInteractor.lightSensorEvCalibration).called(5);
          verify(() {
            communicationBloc.add(communication_events.MeteringInProgressEvent(resultList.first));
          }).called(1);
          verify(() {
            communicationBloc.add(communication_events.MeteringInProgressEvent(resultList[1]));
          }).called(3);
          verify(() {
            communicationBloc.add(communication_events.MeteringInProgressEvent(resultList.last));
          }).called(1);
          verify(() {
            communicationBloc.add(communication_events.MeteringEndedEvent(resultList.last));
          }).called(2); // +1 from dispose
        },
        expect: () => resultList.map(
          (e) => isA<LightSensorContainerState>().having((state) => state.ev100, 'ev100', e),
        ),
      );
    },
  );

  group(
    '`communication_states.SettingsOpenedState()`',
    () {
      const List<int> luxIterable = [1, 2, 2, 2, 3];
      final List<double> resultList = luxIterable.map((lux) => log2(lux / 2.5)).toList();
      blocTest<LightSensorContainerBloc, LightSensorContainerState>(
        'Metering is already canceled',
        build: () => bloc,
        setUp: () {
          when(() => meteringInteractor.luxStream())
              .thenAnswer((_) => Stream.fromIterable(luxIterable));
          when(() => meteringInteractor.lightSensorEvCalibration).thenReturn(0.0);
        },
        act: (bloc) async {
          bloc.onCommunicationState(const communication_states.SettingsOpenedState());
        },
        verify: (_) {
          verifyNever(() => meteringInteractor.luxStream().listen((_) {}));
          verifyNever(() => meteringInteractor.lightSensorEvCalibration);
          verify(() {
            communicationBloc.add(const communication_events.MeteringEndedEvent(null));
          }).called(2); // +1 from dispose
        },
        expect: () => [],
      );

      blocTest<LightSensorContainerBloc, LightSensorContainerState>(
        'Metering is in progress',
        build: () => bloc,
        setUp: () {
          when(() => meteringInteractor.luxStream())
              .thenAnswer((_) => Stream.fromIterable(luxIterable));
          when(() => meteringInteractor.lightSensorEvCalibration).thenReturn(0.0);
        },
        act: (bloc) async {
          bloc.onCommunicationState(const communication_states.MeasureState());
          await Future.delayed(Duration.zero);
          bloc.onCommunicationState(const communication_states.SettingsOpenedState());
          bloc.onCommunicationState(const communication_states.SettingsClosedState());
        },
        verify: (_) {
          verify(() => meteringInteractor.luxStream().listen((_) {})).called(1);
          verify(() => meteringInteractor.lightSensorEvCalibration).called(5);
          verify(() {
            communicationBloc.add(communication_events.MeteringInProgressEvent(resultList.first));
          }).called(1);
          verify(() {
            communicationBloc.add(communication_events.MeteringInProgressEvent(resultList[1]));
          }).called(3);
          verify(() {
            communicationBloc.add(communication_events.MeteringInProgressEvent(resultList.last));
          }).called(1);
          verify(() {
            communicationBloc.add(communication_events.MeteringEndedEvent(resultList.last));
          }).called(3); // +1 from settings closed, +1 from dispose
        },
        expect: () => resultList.map(
          (e) => isA<LightSensorContainerState>().having((state) => state.ev100, 'ev100', e),
        ),
      );
    },
  );
}