TF-56 Implement upload single attachment

This commit is contained in:
dab246
2021-09-17 18:04:47 +07:00
committed by Dat H. Pham
parent 6aaa8f93d3
commit 39ca213285
23 changed files with 575 additions and 12 deletions
@@ -1,5 +1,8 @@
import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
import 'package:model/model.dart';
abstract class ComposerDataSource {
Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress);
Future<Attachment> uploadAttachment(UploadRequest uploadRequest);
}
@@ -1,12 +1,26 @@
import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
import 'package:model/model.dart';
import 'package:tmail_ui_user/features/composer/data/datasource/composer_datasource.dart';
import 'package:tmail_ui_user/features/composer/data/network/composer_api.dart';
class ComposerDataSourceImpl extends ComposerDataSource {
ComposerDataSourceImpl();
final ComposerAPI _composerAPI;
ComposerDataSourceImpl(this._composerAPI);
@override
Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress) {
throw UnimplementedError();
}
@override
Future<Attachment> uploadAttachment(UploadRequest uploadRequest) {
return Future.sync(() async {
final uploadResponse = await _composerAPI.uploadAttachment(uploadRequest);
return uploadResponse.toAttachmentFile(uploadRequest.fileInfo.fileName);
}).catchError((error) {
throw error;
});
}
}
@@ -1,4 +1,6 @@
import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
import 'package:model/model.dart';
import 'package:model/upload/upload_request.dart';
import 'package:tmail_ui_user/features/composer/data/datasource/composer_datasource.dart';
import 'package:tmail_ui_user/features/composer/data/local/email_address_database_manager.dart';
@@ -16,4 +18,9 @@ class LocalComposerDataSourceImpl extends ComposerDataSource {
throw error;
});
}
@override
Future<Attachment> uploadAttachment(UploadRequest uploadRequest) {
throw UnimplementedError();
}
}
@@ -0,0 +1,28 @@
import 'dart:io';
import 'package:core/core.dart';
import 'package:dio/dio.dart';
import 'package:model/model.dart';
class ComposerAPI {
final DioClient _dioClient;
ComposerAPI(this._dioClient);
Future<UploadResponse> uploadAttachment(UploadRequest uploadRequest) async {
final resultJson = await _dioClient.post(
Uri.decodeFull(uploadRequest.uploadUrl.toString()),
options: Options(headers: _buildHeaderRequestParam(uploadRequest.accountRequest.basicAuth())),
data: File(uploadRequest.fileInfo.filePath).readAsBytesSync());
return UploadResponse.fromJson(resultJson);
}
Map<String, dynamic> _buildHeaderRequestParam(String basicAuth) {
final headerParam = _dioClient.getHeaders();
headerParam[HttpHeaders.authorizationHeader] = basicAuth;
headerParam[HttpHeaders.acceptHeader] = DioClient.jmapHeader;
return headerParam;
}
}
@@ -1,6 +1,8 @@
import 'package:core/core.dart';
import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
import 'package:model/model.dart';
import 'package:model/upload/upload_request.dart';
import 'package:tmail_ui_user/features/composer/data/datasource/composer_datasource.dart';
import 'package:tmail_ui_user/features/composer/domain/repository/composer_repository.dart';
@@ -14,4 +16,9 @@ class ComposerRepositoryImpl extends ComposerRepository {
Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress) {
return composerDataSources[DataSourceType.local]!.saveEmailAddresses(listEmailAddress);
}
@override
Future<Attachment> uploadAttachment(UploadRequest uploadRequest) {
return composerDataSources[DataSourceType.network]!.uploadAttachment(uploadRequest);
}
}