mirror of
https://github.com/immich-app/immich.git
synced 2024-11-19 20:08:57 -07:00
897d49f734
* refactor serving file function asset service * Remove PhotoViewer for now since it creates a problem in 2.10 * Added error message for wrong decode file and logo for failed to load file * Fixed error when read stream cannot be created and crash server * Added method to get all assets as a raw array * Implemented cleaner way of grouping image * Implemented operation to delete assets in the database * Implemented delete on database operation * Implemented delete on device operation * Fixed issue display wrong information when the auto backup is enabled after deleting all assets
108 lines
3.2 KiB
Dart
108 lines
3.2 KiB
Dart
import 'dart:convert';
|
|
|
|
import 'package:dio/dio.dart';
|
|
import 'package:flutter/cupertino.dart';
|
|
import 'package:hive/hive.dart';
|
|
import 'package:immich_mobile/constants/hive_box.dart';
|
|
import 'package:immich_mobile/utils/dio_http_interceptor.dart';
|
|
|
|
class NetworkService {
|
|
Future<dynamic> deleteRequest({required String url, dynamic data}) async {
|
|
try {
|
|
var dio = Dio();
|
|
dio.interceptors.add(AuthenticatedRequestInterceptor());
|
|
|
|
var savedEndpoint = Hive.box(userInfoBox).get(serverEndpointKey);
|
|
Response res = await dio.delete('$savedEndpoint/$url', data: data);
|
|
|
|
if (res.statusCode == 200) {
|
|
return res;
|
|
}
|
|
} on DioError catch (e) {
|
|
debugPrint("DioError: ${e.response}");
|
|
} catch (e) {
|
|
debugPrint("ERROR getRequest: ${e.toString()}");
|
|
}
|
|
}
|
|
|
|
Future<dynamic> getRequest({required String url}) async {
|
|
try {
|
|
var dio = Dio();
|
|
dio.interceptors.add(AuthenticatedRequestInterceptor());
|
|
|
|
var savedEndpoint = Hive.box(userInfoBox).get(serverEndpointKey);
|
|
Response res = await dio.get('$savedEndpoint/$url');
|
|
|
|
if (res.statusCode == 200) {
|
|
return res;
|
|
}
|
|
} on DioError catch (e) {
|
|
debugPrint("DioError: ${e.response}");
|
|
} catch (e) {
|
|
debugPrint("ERROR getRequest: ${e.toString()}");
|
|
}
|
|
}
|
|
|
|
Future<dynamic> postRequest({required String url, dynamic data}) async {
|
|
try {
|
|
var dio = Dio();
|
|
dio.interceptors.add(AuthenticatedRequestInterceptor());
|
|
|
|
var savedEndpoint = Hive.box(userInfoBox).get(serverEndpointKey);
|
|
String validUrl = Uri.parse('$savedEndpoint/$url').toString();
|
|
Response res = await dio.post(validUrl, data: data);
|
|
|
|
return res;
|
|
} on DioError catch (e) {
|
|
debugPrint("DioError: ${e.response}");
|
|
return false;
|
|
} catch (e) {
|
|
debugPrint("ERROR BackupService: $e");
|
|
}
|
|
}
|
|
|
|
Future<dynamic> patchRequest({required String url, dynamic data}) async {
|
|
try {
|
|
var dio = Dio();
|
|
dio.interceptors.add(AuthenticatedRequestInterceptor());
|
|
|
|
var savedEndpoint = Hive.box(userInfoBox).get(serverEndpointKey);
|
|
|
|
String validUrl = Uri.parse('$savedEndpoint/$url').toString();
|
|
Response res = await dio.patch(validUrl, data: data);
|
|
|
|
return res;
|
|
} on DioError catch (e) {
|
|
debugPrint("DioError: ${e.response}");
|
|
} catch (e) {
|
|
debugPrint("ERROR BackupService: $e");
|
|
}
|
|
}
|
|
|
|
Future<bool> pingServer() async {
|
|
try {
|
|
var dio = Dio();
|
|
|
|
var savedEndpoint = Hive.box(userInfoBox).get(serverEndpointKey);
|
|
|
|
String validUrl = Uri.parse('$savedEndpoint/server-info/ping').toString();
|
|
|
|
debugPrint("pint server at url $validUrl");
|
|
Response res = await dio.get(validUrl);
|
|
var jsonRespsonse = jsonDecode(res.toString());
|
|
|
|
if (jsonRespsonse["res"] == "pong") {
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
} on DioError catch (e) {
|
|
debugPrint("[PING SERVER] DioError: ${e.response} - $e");
|
|
return false;
|
|
} catch (e) {
|
|
debugPrint("ERROR BackupService: $e");
|
|
return false;
|
|
}
|
|
}
|
|
}
|