112 lines
3.4 KiB
Dart
112 lines
3.4 KiB
Dart
import 'dart:convert';
|
|
|
|
import 'package:dio/dio.dart';
|
|
import 'package:flutter_sodium/flutter_sodium.dart';
|
|
import 'package:logging/logging.dart';
|
|
import 'package:photos/core/event_bus.dart';
|
|
import 'package:photos/core/network.dart';
|
|
import 'package:photos/db/files_db.dart';
|
|
import 'package:photos/events/files_updated_event.dart';
|
|
import 'package:photos/models/file.dart';
|
|
import 'package:photos/core/configuration.dart';
|
|
import 'package:photos/models/file_magic_metadata.dart';
|
|
import 'package:photos/services/remote_sync_service.dart';
|
|
|
|
import 'crypto_util.dart';
|
|
import 'file_download_util.dart';
|
|
|
|
final _dio = Network.instance.getDio();
|
|
FilesDB _filesDB = FilesDB.instance;
|
|
|
|
Future<void> changeVisibility(List<File> files, int visibility) async {
|
|
final params = <String, dynamic>{};
|
|
params['metadataList'] = [];
|
|
int ownerID = Configuration.instance.getUserID();
|
|
|
|
for (final file in files) {
|
|
if (file.uploadedFileID == null) {
|
|
throw AssertionError("operation is only supported on backed up files");
|
|
} else if (file.ownerID != ownerID) {
|
|
throw AssertionError("can not modify memories not owned by you");
|
|
}
|
|
|
|
Map<String, dynamic> jsonToUpdate = jsonDecode(file.mMdEncodedJson);
|
|
jsonToUpdate['visibility'] = visibility;
|
|
|
|
// update the local information so that it's reflected on UI
|
|
file.mMdEncodedJson = jsonEncode(jsonToUpdate);
|
|
file.fileMagicMetadata = FileMagicMetadata.fromJson(jsonToUpdate);
|
|
|
|
final fileKey = decryptFileKey(file);
|
|
final encryptedMMd = await CryptoUtil.encryptChaCha(
|
|
utf8.encode(jsonEncode(jsonToUpdate)), fileKey);
|
|
params['metadataList'].add(UpdateMagicMetadata(
|
|
id: file.uploadedFileID,
|
|
data: MetadataPayload(
|
|
version: file.mMdVersion,
|
|
count: jsonToUpdate.length,
|
|
data: Sodium.bin2base64(encryptedMMd.encryptedData),
|
|
header: Sodium.bin2base64(encryptedMMd.header),
|
|
)));
|
|
}
|
|
return _dio
|
|
.post(
|
|
Configuration.instance.getHttpEndpoint() + "/files/update-magic-metadata",
|
|
data: params,
|
|
options:
|
|
Options(headers: {"X-Auth-Token": Configuration.instance.getToken()}),
|
|
)
|
|
.then((value) async {
|
|
// update the state of the selected file. Same file in other collection
|
|
// should be eventually synced after remote sync has completed
|
|
await _filesDB.insertMultiple(files);
|
|
Bus.instance.fire(FilesUpdatedEvent(files));
|
|
RemoteSyncService.instance.sync(silently: true);
|
|
});
|
|
}
|
|
|
|
class UpdateMagicMetadata {
|
|
int id;
|
|
MetadataPayload data;
|
|
|
|
UpdateMagicMetadata({this.id, this.data});
|
|
|
|
UpdateMagicMetadata.fromJson(dynamic json) {
|
|
id = json['id'];
|
|
data = json['data'] != null ? MetadataPayload.fromJson(json['data']) : null;
|
|
}
|
|
|
|
Map<String, dynamic> toJson() {
|
|
var map = <String, dynamic>{};
|
|
map['id'] = id;
|
|
if (data != null) {
|
|
map['data'] = data.toJson();
|
|
}
|
|
return map;
|
|
}
|
|
}
|
|
|
|
class MetadataPayload {
|
|
int version;
|
|
int count;
|
|
String data;
|
|
String header;
|
|
|
|
MetadataPayload({this.version, this.count, this.data, this.header});
|
|
|
|
MetadataPayload.fromJson(dynamic json) {
|
|
version = json['version'];
|
|
count = json['count'];
|
|
data = json['data'];
|
|
header = json['header'];
|
|
}
|
|
|
|
Map<String, dynamic> toJson() {
|
|
var map = <String, dynamic>{};
|
|
map['version'] = version;
|
|
map['count'] = count;
|
|
map['data'] = data;
|
|
map['header'] = header;
|
|
return map;
|
|
}
|
|
}
|