Remove folder service
This commit is contained in:
Vishnu Mohandas
parent
0af41fd97b
commit
54558c4d92
2 changed files with 1 additions and 189 deletions
|
|
@ -1,187 +0,0 @@
|
|||
import 'dart:developer';
|
||||
|
||||
import 'package:dio/dio.dart';
|
||||
import 'package:logging/logging.dart';
|
||||
import 'package:photos/core/configuration.dart';
|
||||
import 'package:photos/db/folders_db.dart';
|
||||
import 'package:photos/db/files_db.dart';
|
||||
import 'package:photos/events/remote_sync_event.dart';
|
||||
import 'package:photos/events/user_authenticated_event.dart';
|
||||
import 'package:photos/models/folder.dart';
|
||||
import 'package:photos/models/file.dart';
|
||||
|
||||
import '../core/event_bus.dart';
|
||||
|
||||
class FolderSharingService {
|
||||
final _logger = Logger("FolderSharingService");
|
||||
final _dio = Dio();
|
||||
static final _diffLimit = 100;
|
||||
|
||||
bool _isSyncInProgress = false;
|
||||
|
||||
FolderSharingService._privateConstructor() {
|
||||
Bus.instance.on<UserAuthenticatedEvent>().listen((event) {
|
||||
sync();
|
||||
});
|
||||
}
|
||||
|
||||
static final FolderSharingService instance =
|
||||
FolderSharingService._privateConstructor();
|
||||
|
||||
Future<void> sync() {
|
||||
_logger.info("Syncing...");
|
||||
if (_isSyncInProgress || !Configuration.instance.hasConfiguredAccount()) {
|
||||
return Future.value();
|
||||
}
|
||||
_isSyncInProgress = true;
|
||||
return getFolders().then((f) async {
|
||||
var folders = f.toSet();
|
||||
var currentFolders = await FoldersDB.instance.getFolders();
|
||||
for (final currentFolder in currentFolders) {
|
||||
if (!folders.contains(currentFolder)) {
|
||||
_logger.info("Folder deleted: " + currentFolder.toString());
|
||||
await FilesDB.instance.deleteFilesInRemoteFolder(currentFolder.id);
|
||||
await FoldersDB.instance.deleteFolder(currentFolder);
|
||||
}
|
||||
}
|
||||
for (final folder in folders) {
|
||||
if (folder.ownerID != Configuration.instance.getUserID()) {
|
||||
await syncDiff(folder);
|
||||
await FoldersDB.instance.putFolder(folder);
|
||||
}
|
||||
}
|
||||
Bus.instance.fire(RemoteSyncEvent(true));
|
||||
_isSyncInProgress = false;
|
||||
return Future.value();
|
||||
});
|
||||
}
|
||||
|
||||
Future<void> syncDiff(Folder folder) async {
|
||||
int lastSyncTimestamp = 0;
|
||||
try {
|
||||
File file =
|
||||
await FilesDB.instance.getLastSyncedFileInRemoteFolder(folder.id);
|
||||
lastSyncTimestamp = file.updationTime;
|
||||
} catch (e) {
|
||||
// Folder has never been synced
|
||||
}
|
||||
var diff = await getDiff(folder.id, lastSyncTimestamp, _diffLimit);
|
||||
for (File file in diff) {
|
||||
try {
|
||||
var existingPhoto =
|
||||
await FilesDB.instance.getMatchingRemoteFile(file.uploadedFileID);
|
||||
await FilesDB.instance.update(
|
||||
existingPhoto.generatedID,
|
||||
file.uploadedFileID,
|
||||
file.updationTime,
|
||||
file.encryptedKey,
|
||||
file.keyDecryptionNonce,
|
||||
file.fileDecryptionHeader,
|
||||
file.thumbnailDecryptionHeader,
|
||||
file.metadataDecryptionHeader,
|
||||
);
|
||||
} catch (e) {
|
||||
await FilesDB.instance.insert(file);
|
||||
}
|
||||
}
|
||||
if (diff.length == _diffLimit) {
|
||||
await syncDiff(folder);
|
||||
}
|
||||
}
|
||||
|
||||
Future<List<File>> getDiff(int folderId, int sinceTime, int limit) async {
|
||||
Response response = await _dio.get(
|
||||
Configuration.instance.getHttpEndpoint() +
|
||||
"/folders/diff/" +
|
||||
folderId.toString(),
|
||||
options:
|
||||
Options(headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
||||
queryParameters: {
|
||||
"sinceTime": sinceTime,
|
||||
"limit": limit,
|
||||
},
|
||||
).catchError((e) => _logger.severe(e));
|
||||
if (response != null) {
|
||||
return (response.data["diff"] as List).map((p) {
|
||||
File file = new File.fromJson(p);
|
||||
file.localID = null;
|
||||
file.remoteFolderID = folderId;
|
||||
return file;
|
||||
}).toList();
|
||||
} else {
|
||||
return List<File>();
|
||||
}
|
||||
}
|
||||
|
||||
Future<List<Folder>> getFolders() async {
|
||||
return _dio
|
||||
.get(
|
||||
Configuration.instance.getHttpEndpoint() + "/folders/",
|
||||
options:
|
||||
Options(headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
||||
)
|
||||
.then((foldersResponse) {
|
||||
return (foldersResponse.data as List)
|
||||
.map((f) => Folder.fromMap(f))
|
||||
.toList();
|
||||
});
|
||||
}
|
||||
|
||||
Future<Folder> getFolder(String deviceFolder) async {
|
||||
return _dio
|
||||
.get(
|
||||
Configuration.instance.getHttpEndpoint() + "/folders/folder/",
|
||||
queryParameters: {
|
||||
"deviceFolder": deviceFolder,
|
||||
},
|
||||
options:
|
||||
Options(headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
||||
)
|
||||
.then((response) {
|
||||
return Folder.fromMap(response.data);
|
||||
}).catchError((e) {
|
||||
try {
|
||||
return Folder(
|
||||
null,
|
||||
Configuration.instance.getEmail() + "s " + deviceFolder,
|
||||
Configuration.instance.getUserID(),
|
||||
deviceFolder,
|
||||
Set<int>(),
|
||||
null,
|
||||
);
|
||||
} catch (e) {
|
||||
_logger.severe(e);
|
||||
return null;
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Future<Map<int, bool>> getSharingStatus(Folder folder) async {
|
||||
return _dio
|
||||
.get(
|
||||
Configuration.instance.getHttpEndpoint() + "/users",
|
||||
options:
|
||||
Options(headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
||||
)
|
||||
.then((response) {
|
||||
final users = (response.data["users"] as List).toList();
|
||||
final result = Map<int, bool>();
|
||||
for (final user in users) {
|
||||
if (user["id"] != Configuration.instance.getUserID()) {
|
||||
result[user["id"]] = folder.sharedWith.contains(user["id"]);
|
||||
}
|
||||
}
|
||||
return result;
|
||||
});
|
||||
}
|
||||
|
||||
Future<void> updateFolder(Folder folder) {
|
||||
return _dio
|
||||
.put(Configuration.instance.getHttpEndpoint() + "/folders/",
|
||||
options: Options(
|
||||
headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
||||
data: folder.toMap())
|
||||
.then((response) => log(response.toString()))
|
||||
.catchError((error) => log(error.toString()));
|
||||
}
|
||||
}
|
||||
|
|
@ -1,6 +1,5 @@
|
|||
import 'package:flutter/material.dart';
|
||||
import 'package:photos/db/files_db.dart';
|
||||
import 'package:photos/services/folder_service.dart';
|
||||
import 'package:photos/models/folder.dart';
|
||||
import 'package:photos/models/selected_files.dart';
|
||||
import 'package:photos/ui/gallery.dart';
|
||||
|
|
@ -27,7 +26,7 @@ class _RemoteFolderPageState extends State<RemoteFolderPage> {
|
|||
? DateTime.now().microsecondsSinceEpoch
|
||||
: lastFile.creationTime,
|
||||
limit),
|
||||
onRefresh: () => FolderSharingService.instance.syncDiff(widget.folder),
|
||||
// onRefresh: () => FolderSharingService.instance.syncDiff(widget.folder),
|
||||
tagPrefix: "remote_folder",
|
||||
selectedFiles: _selectedFiles,
|
||||
);
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue