128 lines
3.3 KiB
Dart
128 lines
3.3 KiB
Dart
import 'dart:convert';
|
|
import 'dart:typed_data';
|
|
|
|
import 'package:get/get.dart';
|
|
import 'package:path/path.dart';
|
|
import 'package:solian/models/attachment.dart';
|
|
import 'package:solian/providers/auth.dart';
|
|
import 'package:solian/services.dart';
|
|
|
|
class AttachmentProvider extends GetConnect {
|
|
static Map<String, String> mimetypeOverrides = {
|
|
'mov': 'video/quicktime',
|
|
'mp4': 'video/mp4'
|
|
};
|
|
|
|
@override
|
|
void onInit() {
|
|
httpClient.baseUrl = ServiceFinder.buildUrl('files', null);
|
|
}
|
|
|
|
final Map<int, Attachment> _cachedResponses = {};
|
|
|
|
Future<Attachment?> getMetadata(int id, {noCache = false}) async {
|
|
if (!noCache && _cachedResponses.containsKey(id)) {
|
|
return _cachedResponses[id]!;
|
|
}
|
|
|
|
final resp = await get('/attachments/$id/meta');
|
|
if (resp.statusCode == 200) {
|
|
final result = Attachment.fromJson(resp.body);
|
|
if (result.destination != 0 && result.isAnalyzed) {
|
|
_cachedResponses[id] = result;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
Future<Response> createAttachment(
|
|
Uint8List data,
|
|
String path,
|
|
String usage,
|
|
Map<String, dynamic>? metadata,
|
|
) async {
|
|
final AuthProvider auth = Get.find();
|
|
if (auth.isAuthorized.isFalse) throw Exception('unauthorized');
|
|
|
|
final client = auth.configureClient(
|
|
'files',
|
|
timeout: const Duration(minutes: 3),
|
|
);
|
|
|
|
final filePayload = MultipartFile(data, filename: basename(path));
|
|
final fileAlt = basename(path).contains('.')
|
|
? basename(path).substring(0, basename(path).lastIndexOf('.'))
|
|
: basename(path);
|
|
final fileExt = basename(path)
|
|
.substring(basename(path).lastIndexOf('.') + 1)
|
|
.toLowerCase();
|
|
|
|
// Override for some files cannot be detected mimetype by server-side
|
|
String? mimetypeOverride;
|
|
if (mimetypeOverrides.keys.contains(fileExt)) {
|
|
mimetypeOverride = mimetypeOverrides[fileExt];
|
|
}
|
|
final payload = FormData({
|
|
'alt': fileAlt,
|
|
'file': filePayload,
|
|
'usage': usage,
|
|
if (mimetypeOverride != null) 'mimetype': mimetypeOverride,
|
|
'metadata': jsonEncode(metadata),
|
|
});
|
|
final resp = await client.post('/attachments', payload);
|
|
if (resp.statusCode != 200) {
|
|
throw Exception(resp.bodyString);
|
|
}
|
|
|
|
return resp;
|
|
}
|
|
|
|
Future<Response> updateAttachment(
|
|
int id,
|
|
String alt,
|
|
String usage, {
|
|
bool isMature = false,
|
|
}) async {
|
|
final AuthProvider auth = Get.find();
|
|
if (auth.isAuthorized.isFalse) throw Exception('unauthorized');
|
|
|
|
final client = auth.configureClient('files');
|
|
|
|
var resp = await client.put('/attachments/$id', {
|
|
'alt': alt,
|
|
'usage': usage,
|
|
'is_mature': isMature,
|
|
});
|
|
|
|
if (resp.statusCode != 200) {
|
|
throw Exception(resp.bodyString);
|
|
}
|
|
|
|
return resp;
|
|
}
|
|
|
|
Future<Response> deleteAttachment(int id) async {
|
|
final AuthProvider auth = Get.find();
|
|
if (auth.isAuthorized.isFalse) throw Exception('unauthorized');
|
|
|
|
final client = auth.configureClient('files');
|
|
|
|
var resp = await client.delete('/attachments/$id');
|
|
if (resp.statusCode != 200) {
|
|
throw Exception(resp.bodyString);
|
|
}
|
|
|
|
return resp;
|
|
}
|
|
|
|
void clearCache({int? id}) {
|
|
if (id != null) {
|
|
_cachedResponses.remove(id);
|
|
} else {
|
|
_cachedResponses.clear();
|
|
}
|
|
}
|
|
}
|