ente/lib/photo_sync_manager.dart

import 'package:logger/logger.dart';
import 'package:myapp/db/db_helper.dart';
import 'package:myapp/photo_loader.dart';
import 'package:path/path.dart';
import 'package:path_provider/path_provider.dart';
import 'package:photo_manager/photo_manager.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:dio/dio.dart';
import 'package:myapp/models/photo.dart';

class PhotoSyncManager {
  final logger = Logger();
  final dio = Dio();
  final endpoint = "http://172.20.10.6:8080";
  final user = "umbu";
  static final lastSyncTimestampKey = "last_sync_timestamp_0";

  PhotoSyncManager(List<AssetEntity> assets) {
    logger.i("PhotoSyncManager init");
    _syncPhotos(assets);
  }

  _syncPhotos(List<AssetEntity> assets) async {
    SharedPreferences prefs = await SharedPreferences.getInstance();
    var lastSyncTimestamp = prefs.getInt(lastSyncTimestampKey);
    if (lastSyncTimestamp == null) {
      lastSyncTimestamp = 0;
    }
    logger.i("Last sync timestamp: " + lastSyncTimestamp.toString());

    await _downloadDiff(lastSyncTimestamp, prefs);

    await _uploadDiff(assets, prefs);

    // TODO:  Fix race conditions triggered due to concurrent syncs.
    //        Add device_id/last_sync_timestamp to the upload request?
  }

  Future _uploadDiff(List<AssetEntity> assets, SharedPreferences prefs) async {
    assets.sort((first, second) => second
        .modifiedDateTime.millisecondsSinceEpoch
        .compareTo(first.modifiedDateTime.millisecondsSinceEpoch));
    var uploadedAssetCount = 0;
    for (AssetEntity asset in assets) {
      // TODO: Fix me
      if (uploadedAssetCount == 100) {
        return;
      }
      var containsPath = await DatabaseHelper.instance
          .containsPath((await asset.originFile).path);
      if (!containsPath) {
        var response = await _uploadFile(asset);
        prefs.setInt(lastSyncTimestampKey, response.syncTimestamp);
        uploadedAssetCount++;
      }
    }
  }

  Future _downloadDiff(int lastSyncTimestamp, SharedPreferences prefs) async {
    Response response = await dio.get(endpoint + "/diff", queryParameters: {
      "user": user,
      "lastSyncTimestamp": lastSyncTimestamp
    });
    logger.i(response.toString());
    var externalPath = (await getApplicationDocumentsDirectory()).path;
    logger.i("External path: " + externalPath);
    var path = externalPath + "/photos/";

    List<Photo> photos = (response.data["diff"] as List)
        .map((photo) => new Photo.fromJson(photo))
        .toList();
    for (Photo photo in photos) {
      await dio.download(endpoint + photo.url, path + basename(photo.url));
      photo.hash = _getHash(photo);
      photo.localPath = path + basename(photo.url);
      insertPhotoToDB(photo);
      prefs.setInt(lastSyncTimestampKey, photo.syncTimestamp);
      logger.i("Downloaded " + photo.url + " to " + path);
    }
  }

  Future<Photo> _uploadFile(AssetEntity entity) async {
    logger.i("Uploading: " + entity.id);
    var path = (await entity.originFile).path;
    var formData = FormData.fromMap({
      "file": await MultipartFile.fromFile(path, filename: entity.title),
      "user": user,
    });
    var response = await dio.post(endpoint + "/upload", data: formData);
    logger.i(response.toString());
    var photo = Photo.fromJson(response.data);
    photo.hash = _getHash(photo);
    photo.localPath = path;
    insertPhotoToDB(photo);
    return photo;
  }

  String _getHash(Photo photo) {
    // TODO: Compute hash
    return "hash";
  }

  Future<void> insertPhotoToDB(Photo photo) async {
    logger.i("Inserting to DB");
    await DatabaseHelper.instance.insertPhoto(photo);
    PhotoLoader.instance.reloadPhotos();
  }
}