j

lib/features/home/latest_store_tickets/blocs/latest_store_tickets_bloc.dart

@@ -0,0 +1,58 @@
+import 'package:flutter_bloc/flutter_bloc.dart';
+import 'package:equatable/equatable.dart';
+import 'package:flux/features/tickets/data/ticket_repository.dart';
+import 'package:flux/features/tickets/models/ticket_model.dart';
+import 'package:get_it/get_it.dart';
+
+part 'latest_store_tickets_events.dart';
+part 'latest_store_tickets_state.dart';
+
+class LatestStoreTicketsBloc
+    extends Bloc<LatestStoreTicketsEvent, LatestStoreTicketsState> {
+  final _repository = GetIt.I.get<TicketRepository>();
+  LatestStoreTicketsBloc()
+    : super(
+        const LatestStoreTicketsState(status: LatestStoreTicketsStatus.initial),
+      ) {
+    on<InitLatestStoreTicketsEvent>((event, emit) async {
+      emit(state.copyWith(status: LatestStoreTicketsStatus.loading));
+      try {
+        final hydratedStream = _repository
+            .getLatestStoreTicketsStream(storeId: event.storeId, limit: 10)
+            .asyncMap((List<TicketModel> rawTickets) async {
+              List<TicketModel> fullyHydratedTickets = [];
+
+              for (TicketModel ticket in rawTickets) {
+                TicketModel fullTicket = await _repository.getTicketById(
+                  ticket.id!,
+                );
+                fullyHydratedTickets.add(fullTicket);
+              }
+
+              return fullyHydratedTickets;
+            });
+        await emit.forEach(
+          hydratedStream,
+          onData: (List<TicketModel> fullyHydratedTickets) {
+            return state.copyWith(
+              tickets: fullyHydratedTickets,
+              status: LatestStoreTicketsStatus.success,
+            );
+          },
+          onError: (error, stackTrace) => state.copyWith(
+            status: LatestStoreTicketsStatus.failure,
+            error: error.toString(),
+          ),
+        );
+      } catch (e) {
+        emit(
+          state.copyWith(
+            status: LatestStoreTicketsStatus.failure,
+            error: e.toString(),
+          ),
+        );
+      }
+    });
+    // TODO: implement event handlers
+  }
+}

lib/features/home/latest_store_tickets/blocs/latest_store_tickets_events.dart

@@ -0,0 +1,17 @@
+part of 'latest_store_tickets_bloc.dart';
+
+abstract class LatestStoreTicketsEvent extends Equatable {
+  const LatestStoreTicketsEvent();
+
+  @override
+  List<Object> get props => [];
+}
+
+class InitLatestStoreTicketsEvent extends LatestStoreTicketsEvent {
+  final String storeId;
+
+  const InitLatestStoreTicketsEvent(this.storeId);
+
+  @override
+  List<Object> get props => [storeId];
+}

lib/features/home/latest_store_tickets/blocs/latest_store_tickets_state.dart

@@ -0,0 +1,29 @@
+part of 'latest_store_tickets_bloc.dart';
+
+enum LatestStoreTicketsStatus { initial, loading, success, failure }
+
+class LatestStoreTicketsState extends Equatable {
+  final LatestStoreTicketsStatus status;
+  final String? error;
+  final List<TicketModel> tickets;
+  const LatestStoreTicketsState({
+    required this.status,
+    this.error,
+    this.tickets = const [],
+  });
+
+  @override
+  List<Object?> get props => [status, error, tickets];
+
+  LatestStoreTicketsState copyWith({
+    LatestStoreTicketsStatus? status,
+    String? error,
+    List<TicketModel>? tickets,
+  }) {
+    return LatestStoreTicketsState(
+      status: status ?? this.status,
+      error: error,
+      tickets: tickets ?? this.tickets,
+    );
+  }
+}