api_client.dart

Go to the documentation of this file.

import 'dart:convert';
import 'package:dio/dio.dart';
import '../services/analytics_service.dart';
 
import '../error/exceptipns/server_exception.dart';
import 'api_endpoints.dart';
import 'auth_interceptor.dart';
 
class ApiClient {
  late final Dio _dio;
  final _analytics = AnalyticsService.instance;
 
  ApiClient({
    Duration connectTimeout = const Duration(seconds: 30),
    Duration receiveTimeout = const Duration(seconds: 30),
    Duration sendTimeout = const Duration(seconds: 30),
  }) {
    _dio = _createDioInstance(
      connectTimeout: connectTimeout,
      receiveTimeout: receiveTimeout,
      sendTimeout: sendTimeout,
    );
  }
 
  Dio _createDioInstance({
    required Duration connectTimeout,
    required Duration receiveTimeout,
    required Duration sendTimeout,
  }) {
    final dio = Dio(
      BaseOptions(
        baseUrl: ApiEndpoints.hostname,
        connectTimeout: connectTimeout,
        receiveTimeout: receiveTimeout,
        sendTimeout: sendTimeout,
        contentType: 'application/json',
        headers: {'Accept': 'application/json'},
        validateStatus: (status) {
          return status != null && status < 500;
        },
      ),
    );
 
    dio.interceptors.add(AuthInterceptor(dio: dio));
    return dio;
  }
 
  Future<dynamic> get({String? path, String? url}) async {
    try {
      final endpoint = url ?? ApiEndpoints.buildUrl(path!);
      final response = await _dio.get(endpoint);
      
      _analytics.captureEvent('api_call_success', properties: {
        'method': 'GET',
        'endpoint': endpoint,
      });
      
      return _handleResponse(response);
    } on DioException catch (e) {
      _analytics.captureEvent('api_call_error', properties: {
        'method': 'GET',
        'endpoint': (url ?? path) as Object,
        'status_code': e.response?.statusCode as Object,
        'error_message': e.message as Object,
        'response_data': e.response?.data as Object,
      });
      
      throw ServerException.fromStatus(e.response?.statusCode ?? 500);
    } catch (e) {
      throw ServerException.fromStatus(500);
    }
  }
 
  Future<Map<String, dynamic>> post({
    String? url,
    String? path,
    required Map<String, dynamic> data,
  }) async {
    try {
      final endpoint = url ?? ApiEndpoints.buildUrl(path!);
      final response = await _dio.post(
        endpoint,
        data: jsonEncode(data),
      );
      
      _analytics.captureEvent('api_call_success', properties: {
        'method': 'POST',
        'endpoint': endpoint,
        'request_body': data.toString(),
      });
      
      final result = _handleResponse(response);
      if (result is Map<String, dynamic>) {
        return result;
      } else if (result == null) {
        return {};
      } else {
        return {'data': result};
      }
    } on DioException catch (e) {
      _analytics.captureEvent('api_call_error', properties: {
        'method': 'POST',
        'endpoint': (url ?? path) as Object,
        'status_code': e.response?.statusCode as Object,
        'error_message': e.message as Object,
        'response_data': e.response?.data as Object,
      });
      
      throw ServerException.fromStatus(e.response?.statusCode ?? 500);
    }
  }
 
  dynamic _handleResponse(Response response) {
    final statusCode = response.statusCode ?? 500;
    if (statusCode == 204 || response.data == null || response.data == '') {
      return {};
    }
    if (statusCode == 200) {
      if (response.data is Map) {
        final statusCodeValue = response.data['statusCodeValue'];
        if (statusCodeValue != null && statusCodeValue != 200) {
          throw ServerException.fromStatus(statusCodeValue);
        }
        if (response.data['code'] == 400 && response.data['message'] == 'NO Data Found') {
          return {};
        }
      }
      return response.data;
    }
    throw ServerException.fromStatus(statusCode);
  }
}