notifications_repository.dart

import '../../api/graphql_api.dart';
import '../../model/request_result_model.dart';
import '../../utils/log_service.dart';

import 'notification.dart';

abstract class NotificationsRepository {
  NotificationsRepository();

  factory NotificationsRepository.create(GraphqlAPI graphqlAPI) {
    return NotificationRepositoryImpl(graphqlAPI);
  }

  Future<RequestResultModel> loadNotifications();
  Future<RequestResultModel> loadNotification(String id);
  Future<RequestResultModel> markAsRead(List<String> data);
}

class NotificationRepositoryImpl extends NotificationsRepository {
  GraphqlAPI graphqlAPI;

  NotificationRepositoryImpl(this.graphqlAPI);

  @override
  Future<RequestResultModel> loadNotifications() async {
    final query = 'query { notifications { id title body type date unread enable data } }';
    try {
      final response = await graphqlAPI.sendAsync(query);
      final notifications = <NotificationsItem>[];
      response.data['data']['notifications']
          ?.forEach((n) => notifications.add(NotificationsItem.fromJson(n)));
      return RequestResultModel(result: true, value: notifications);
    } on Exception catch (e) {
      LogService.log('Exception during loading notifications', exception: e);
      return RequestResultModel(result: false, value: e);
    }
  }

  Future<RequestResultModel> loadNotification(String id) async {
    final query =
        'query { notification(notificationId: "$id") { id title body type date unread enable data } }';
    try {
      final response = await graphqlAPI.sendAsync(query);
      final notification = response.data['data']['notification'];
      return RequestResultModel(
          result: true, value: NotificationsItem.fromJson(notification));
    } on Exception catch (e) {
      LogService.log('Exception during loading notifications', exception: e);
      return RequestResultModel(result: false, value: e);
    }
  }

  @override
  Future<RequestResultModel> markAsRead(List<String> data) async {
    if (data?.isEmpty != false) {
      return RequestResultModel(result: true);
    }

    var mutation = 'mutation { ';
    for (var i = 0; i < data.length; i++) {
      mutation += 'm$i: notificationMarkAsRead(notificationId: "${data[i]}") ';
    }
    mutation += '}';

    try {
      final response = await graphqlAPI.sendAsync(mutation);
      var success = true;
      response.data['data'].forEach((_, val) => success &= val == 'OK');
      return RequestResultModel(result: success, value: data);
    } on Exception catch (e) {
      LogService.log('Exception during marking notifications as read',
          exception: e);
      return RequestResultModel(result: false, value: e);
    }
  }
}