notifications_repository_impl.dart

Go to the documentation of this file.

import '/core/errors/failures.dart';
import '/features/notifications/data/models/notitfication_model.dart';
import '/features/notifications/domain/entities/notification_entity.dart';
import '/features/notifications/domain/repository/notifactions_repository.dart';
import 'package:dartz/dartz.dart';
 
import '../../../../core/errors/exception_failure_adapter.dart';
import '../../../../core/services/service_locator.dart';
import '../data_sources/remote_datasources/notification_remote_datasource.dart';
 
class NotificationsRepositoryImpl extends NotificationsRepository {
  final _remoteDataSource = sl<NotificationsRemoteDataSource>();
 
  @override
  Future<Either<Failure, List<NotificationEntity>>> loadNotifications({
    required String userId,
  }) async {
    try {
      final List<dynamic> results =
          await _remoteDataSource.getNotifications(param: userId);
 
      return right(
        (results)
            .map((json) =>
                NotificationModel.fromJson(json as Map<String, dynamic>))
            .toList(),
      );
    } catch (e) {
      return left(ExceptionFailureAdapter.adapt(e));
    }
  }
}