getUnreadCount method

  1. @override
Future<Either<Failure, int>> getUnreadCount(
  1. Map<String, dynamic>? params
)
override

Implementation

@override
Future<Either<Failure, int>> getUnreadCount(Map<String, dynamic>? params) async {
  return wrapAndHandleHttpRequestResponse(
    () {
      final defaultQueryParams = queryMerge(
        params,
        {
          "filter": jsonEncode({
            "archivedAt": {"\$eq": null},
            "readAt": {"\$eq": null},
          }),
        },
      );

      final url = notificationConfig.getCountApiEndpoint(
        queryMerge(
          defaultQueryParams,
          params,
        ),
      );

      final response = client!.get(url);
      return response;
    },
    onResponse: (response, left, right) {
      return right(
        notificationConfig.getCountResponseParser?.call(response) ?? _defaultUnreadCountResponseParser(response.body),
      );
    },
  );
}