atmob_stream_api.c.dart 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  1. // GENERATED CODE - DO NOT MODIFY BY HAND
  2. part of 'atmob_stream_api.dart';
  3. // **************************************************************************
  4. // RetrofitGenerator
  5. // **************************************************************************
  6. // ignore_for_file: unnecessary_brace_in_string_interps,no_leading_underscores_for_local_identifiers,unused_element,unnecessary_string_interpolations
  7. class _AtmobStreamApi implements AtmobStreamApi {
  8. _AtmobStreamApi(
  9. this._dio, {
  10. this.baseUrl,
  11. this.errorLogger,
  12. });
  13. final Dio _dio;
  14. String? baseUrl;
  15. final ParseErrorLogger? errorLogger;
  16. @override
  17. Future<ResponseBody> dailySummary(QueryTrackRequest request) async {
  18. const _extra = <String, dynamic>{};
  19. final queryParameters = <String, dynamic>{};
  20. final _headers = <String, dynamic>{};
  21. final _data = <String, dynamic>{};
  22. _data.addAll(request.toJson());
  23. final _result =
  24. await _dio.fetch<ResponseBody>(_setStreamType<ResponseBody>(Options(
  25. method: 'POST',
  26. headers: _headers,
  27. extra: _extra,
  28. responseType: ResponseType.stream,
  29. )
  30. .compose(
  31. _dio.options,
  32. '/s/v1/chat/daily/summary',
  33. queryParameters: queryParameters,
  34. data: _data,
  35. )
  36. .copyWith(
  37. baseUrl: _combineBaseUrls(
  38. _dio.options.baseUrl,
  39. baseUrl,
  40. ))));
  41. return _result.data!;
  42. }
  43. @override
  44. Future<ResponseBody> dailyExceptionAnalyse(QueryTrackRequest request) async {
  45. const _extra = <String, dynamic>{};
  46. final queryParameters = <String, dynamic>{};
  47. final _headers = <String, dynamic>{};
  48. final _data = <String, dynamic>{};
  49. _data.addAll(request.toJson());
  50. final _result =
  51. await _dio.fetch<ResponseBody>(_setStreamType<ResponseBody>(Options(
  52. method: 'POST',
  53. headers: _headers,
  54. extra: _extra,
  55. responseType: ResponseType.stream,
  56. )
  57. .compose(
  58. _dio.options,
  59. '/s/v1/chat/daily/exception/analyse',
  60. queryParameters: queryParameters,
  61. data: _data,
  62. )
  63. .copyWith(
  64. baseUrl: _combineBaseUrls(
  65. _dio.options.baseUrl,
  66. baseUrl,
  67. ))));
  68. return _result.data!;
  69. }
  70. RequestOptions _setStreamType<T>(RequestOptions requestOptions) {
  71. if (T != dynamic &&
  72. !(requestOptions.responseType == ResponseType.bytes ||
  73. requestOptions.responseType == ResponseType.stream)) {
  74. if (T == String) {
  75. requestOptions.responseType = ResponseType.plain;
  76. } else {
  77. requestOptions.responseType = ResponseType.json;
  78. }
  79. }
  80. return requestOptions;
  81. }
  82. String _combineBaseUrls(
  83. String dioBaseUrl,
  84. String? baseUrl,
  85. ) {
  86. if (baseUrl == null || baseUrl.trim().isEmpty) {
  87. return dioBaseUrl;
  88. }
  89. final url = Uri.parse(baseUrl);
  90. if (url.isAbsolute) {
  91. return url.toString();
  92. }
  93. return Uri.parse(dioBaseUrl).resolveUri(url).toString();
  94. }
  95. }