|
| 1 | +import 'dart:io'; |
| 2 | + |
| 3 | +import 'package:dio/dio.dart'; |
| 4 | +import 'package:rest_client/rest_client.dart'; |
| 5 | +import 'package:rest_client/src/dio/request/request_endpoint.dart'; |
| 6 | +import 'package:rest_client/src/dio/request/request_model.dart'; |
| 7 | + |
| 8 | +import 'dio_builder.dart'; |
| 9 | + |
| 10 | +abstract class IHttpHelper { |
| 11 | + Future<dynamic> request(IRequestEndPoint endPoint, IRequestModel requestModel, |
| 12 | + {Map<String, dynamic> headers}); |
| 13 | +} |
| 14 | + |
| 15 | +class HttpHelper implements IHttpHelper { |
| 16 | + final Dio _dio; |
| 17 | + CancelToken cancelToken = CancelToken(); |
| 18 | + IHttpConfig config; |
| 19 | + |
| 20 | + HttpHelper({this.config}) : _dio = DioBuilder(config: config).build(); |
| 21 | + |
| 22 | + @override |
| 23 | + Future request(IRequestEndPoint endPoint, IRequestModel requestModel, |
| 24 | + {Map<String, dynamic> headers}) async { |
| 25 | + try { |
| 26 | + switch (endPoint.method) { |
| 27 | + case RequestMethod.DELETE: |
| 28 | + return (await _dio.delete(endPoint.url, |
| 29 | + options: Options(headers: headers), |
| 30 | + queryParameters: requestModel.toJson(), |
| 31 | + cancelToken: cancelToken)) |
| 32 | + .data; |
| 33 | + case RequestMethod.GET: |
| 34 | + return (await _dio.get(endPoint.url, |
| 35 | + options: Options(headers: headers), |
| 36 | + queryParameters: requestModel.toJson(), |
| 37 | + cancelToken: cancelToken)) |
| 38 | + .data; |
| 39 | + case RequestMethod.POST: |
| 40 | + return (await _dio.post(endPoint.url, |
| 41 | + options: Options(headers: headers), |
| 42 | + data: requestModel.toJson(), |
| 43 | + cancelToken: cancelToken)) |
| 44 | + .data; |
| 45 | + case RequestMethod.PATCH: |
| 46 | + return (await _dio.patch(endPoint.url, |
| 47 | + options: Options(headers: headers), |
| 48 | + data: requestModel.toJson(), |
| 49 | + cancelToken: cancelToken)) |
| 50 | + .data; |
| 51 | + break; |
| 52 | + case RequestMethod.PUT: |
| 53 | + return (await _dio.put(endPoint.url, |
| 54 | + options: Options(headers: headers), |
| 55 | + data: requestModel.toJson(), |
| 56 | + cancelToken: cancelToken)) |
| 57 | + .data; |
| 58 | + } |
| 59 | + } on DioError catch (e) { |
| 60 | + switch (e.response.statusCode) { |
| 61 | + //logout |
| 62 | + } |
| 63 | + return e.response.data; |
| 64 | + } on SocketException catch (e) { |
| 65 | + throw SocketException(e.toString()); |
| 66 | + } on FormatException catch (_) { |
| 67 | + throw FormatException("Unable to process the data"); |
| 68 | + } catch (e) { |
| 69 | + throw e; |
| 70 | + } |
| 71 | + } |
| 72 | +} |
0 commit comments