Skip to content
This repository has been archived by the owner on Jul 16, 2023. It is now read-only.

Commit

Permalink
dev: SavedataSyncService
Browse files Browse the repository at this point in the history
  • Loading branch information
@luojunyuan
luojunyuan committed Feb 26, 2022
1 parent 69bc4e4 commit 754f6b4
Show file tree
Hide file tree
Showing 10 changed files with 242 additions and 186 deletions.
6 changes: 6 additions & 0 deletions ErogeHelper.Model/Services/Interface/IWindowsGuid.cs
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
namespace ErogeHelper.Model.Services.Interface;

public interface IWindowsGuid
{
string MachineGuid { get; }
}
297 changes: 166 additions & 131 deletions ErogeHelper.Model/Services/SavedataSyncService.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,65 +5,133 @@
using System.Threading.Tasks;
using ErogeHelper.Model.Repositories.Interface;
using ErogeHelper.Model.Services.Interface;
using ErogeHelper.Shared;
using ErogeHelper.Shared.Contracts;
using ErogeHelper.Shared.Entities;
using Newtonsoft.Json;
using Vanara.PInvoke;

namespace ErogeHelper.Model.Services;

public class SavedataSyncService : ISavedataSyncService
{
//private readonly IEhConfigRepository _ehConfigDataService;
//private readonly INetworkListManager _networkListManager;
//private bool IsNetConnected => _networkListManager.IsConnectedToInternet;
//private string GameMd5 => _gameDataService.Md5;
//private string LocalSavedataFolder => _ehDbRepository.GameInfo?.SavedataPath ?? string.Empty;
//private string CloudSavedataFolder => Path.Combine(
// _ehConfigDataService.ExternalSharedDrivePath, Path.GetFileNameWithoutExtension(LocalSavedataFolder));
//private string CloudDbFilePath => Path.Combine(
// _ehConfigDataService.ExternalSharedDrivePath, ConstantValues.EhCloudDbFilename);

//public string[] ExcludeFiles { get; }
public static Func<bool> MessageBox { get; set; } = null!;

private string FolderName => Path.GetFileNameWithoutExtension(LocalSavedataFolder);
private string LocalSavedataFolder => _gameInfoRepository.GameInfo.SaveDataPath;
private string CloudGameSaveFolder => Path.Combine(
_ehConfigRepository.ExternalSharedDrivePath, FolderName);
private string CloudDBFilePath => Path.Combine(
_ehConfigRepository.ExternalSharedDrivePath, ConstantValue.CloudDbFilename);

private readonly IGameInfoRepository _gameInfoRepository;
private readonly IEHConfigRepository _ehConfigRepository;

public SavedataSyncService(
IGameInfoRepository? gameInfoRepository = null)
IGameInfoRepository? gameInfoRepository = null,
IEHConfigRepository? ehConfigRepository = null)
{
_gameInfoRepository = gameInfoRepository ?? Shared.DependencyResolver.GetService<IGameInfoRepository>();
_ehConfigRepository = ehConfigRepository ?? Shared.DependencyResolver.GetService<IEHConfigRepository>();
}

//public void InitGameData()
//{
// var cloudGameDatas = File.Exists(CloudDbFilePath) ?
// JsonConvert.DeserializeObject<List<CloudSaveDataEntity>>(File.ReadAllText(CloudDbFilePath)) :
// new();
// 打开设置switch上传时
// 云端没有 就上传当前存档
// 云端有了 -> 对比。。。

// var currentData = CreateGameData();
// cloudGameDatas.Add(currentData);
// Directory.CreateDirectory(CloudSavedataFolder);
// File.WriteAllText(CloudDbFilePath, JsonConvert.SerializeObject(cloudGameDatas));
// 游戏启动时
// 连不上网 None
// 找不到数据库|找不到游戏存档 throw Toast提示
// 连得上网 -> 对比。。。

// Task.Run(UploadFiles);
// 游戏结束时
// 连不上网 None
// 找不到数据库|找不到游戏存档 throw 弹窗提示或直接报错
// 连得上网 -> 对比。。。

// 对比时需要询问用户输入，使用 回调 或 IObservable 或 Interaction

//public void UpdateSync()
//{
// if (!WinINet.InternetGetConnectedState(out _))
// {
// return;
// }
// var cloadDBFilePath = CloudDBFilePath;
// if (File.Exists(cloadDBFilePath))
// {
// throw new FileNotFoundException(cloadDBFilePath);
// }
// var localSavedataFolder = LocalSavedataFolder;
// if (File.Exists(localSavedataFolder))
// {
// throw new FileNotFoundException(localSavedataFolder);
// }

// //if (File.Exists(cloudDbFile))
// //{
// // var cloudGameDatas =
// // JsonConvert.DeserializeObject<List<CloudGameDataEntity>>(File.ReadAllText(cloudDbFile))
// // .CheckNull();

// // var currentData = CreateGameData();
// // cloudGameDatas.Add(currentData);
// var gamedata = GetCurrentGameData(FolderName, cloadDBFilePath);

// // File.WriteAllText(cloudDbFile, JsonConvert.SerializeObject(cloudGameDatas));
// //}
// //else
// //{
// // var currentData = CreateGameData();
// // var cloudGameDatas = new List<CloudGameDataEntity> { currentData };
// if (gamedata is null)
// {
// // 没有数据库 或 当前游戏信息
// // first time
// return;
// }

// // File.WriteAllText(cloudDbFile, JsonConvert.SerializeObject(cloudGameDatas));
// //}
// var guid = DependencyResolver.GetService<IWindowsGuid>().MachineGuid;
// var saveTime = GetLastDirectoryModifiedTime(localSavedataFolder);
// if (gamedata.PCId.Equals(guid, StringComparison.Ordinal) && gamedata.LastTimeModified < saveTime)
// {
// UploadFiles(localSavedataFolder, CloudGameSaveFolder);
// UpdateLastModifiedTime(saveTime);
// }
// else if (!gamedata.PCId.Equals(guid, StringComparison.Ordinal))
// {
// var result = MessageBox();
// if (result == true)
// {
// UploadFiles(localSavedataFolder, CloudGameSaveFolder);
// UpdateSavedataInfo();
// }
// }
//}

//public CloudSaveDataEntity CreateGameData() =>
// new(GameMd5,

////public void InitGameData()
////{
//// var cloudGameDatas = File.Exists(CloudDbFilePath) ?
//// JsonConvert.DeserializeObject<List<CloudSaveDataEntity>>(File.ReadAllText(CloudDbFilePath)) :
//// new();

//// var currentData = CreateGameData();
//// cloudGameDatas.Add(currentData);
//// Directory.CreateDirectory(CloudSavedataFolder);
//// File.WriteAllText(CloudDbFilePath, JsonConvert.SerializeObject(cloudGameDatas));

//// Task.Run(UploadFiles);

//// //if (File.Exists(cloudDbFile))
//// //{
//// // var cloudGameDatas =
//// // JsonConvert.DeserializeObject<List<CloudGameDataEntity>>(File.ReadAllText(cloudDbFile))
//// // .CheckNull();

//// // var currentData = CreateGameData();
//// // cloudGameDatas.Add(currentData);

//// // File.WriteAllText(cloudDbFile, JsonConvert.SerializeObject(cloudGameDatas));
//// //}
//// //else
//// //{
//// // var currentData = CreateGameData();
//// // var cloudGameDatas = new List<CloudGameDataEntity> { currentData };

//// // File.WriteAllText(cloudDbFile, JsonConvert.SerializeObject(cloudGameDatas));
//// //}
////}

//public CloudSaveDataTerm CreateGameData() =>
// new(FolderName,
// LocalSavedataFolder,
// GetLastDirectoryModifiedTime(LocalSavedataFolder),
// ExcludeFiles,
Expand All @@ -73,11 +141,65 @@ public SavedataSyncService(
///// <summary>
///// Get savedata info from cloud
///// </summary>
//public CloudSaveDataEntity? GetCurrentGameData() =>
// !File.Exists(CloudDbFilePath)
// ? null
// : JsonConvert.DeserializeObject<List<CloudSaveDataEntity>>(File.ReadAllText(CloudDbFilePath))
// .FirstOrDefault(g => g.Md5.Equals(GameMd5, StringComparison.Ordinal));
//// TODO: Use System.Text.Json
//private static CloudSaveDataTerm? GetCurrentGameData(string folderName, string cloudDBFilePath) =>
// JsonConvert.DeserializeObject<List<CloudSaveDataTerm>>(File.ReadAllText(cloudDBFilePath))
// ?.FirstOrDefault(g => g.FolderName.Equals(folderName, StringComparison.Ordinal));

//private static DateTime GetLastDirectoryModifiedTime(string path) =>
// new DirectoryInfo(path)
// .EnumerateFileSystemInfos()
// .Max(i => i.LastWriteTime);

//private static void UploadFiles(string localSavedataFolder, string cloudSavedataFolder) =>
// DirectoryCopy(localSavedataFolder, cloudSavedataFolder, true, true);

//private void UpdateLastModifiedTime(string cloudDBFilePath, DateTime time)
//{
// var cloudGameDatas =
// JsonConvert.DeserializeObject<List<CloudSaveDataTerm>>(File.ReadAllText(cloudDBFilePath))
// ?? new();

// var currentData = CreateGameData();

// cloudGameDatas.RemoveAll(item => item.Md5.Equals(currentData.Md5, StringComparison.Ordinal));
// cloudGameDatas.Add(currentData with { LastTimeModified = time });
// File.WriteAllText(cloudDBFilePath, JsonConvert.SerializeObject(cloudGameDatas));
//}

//private static void DirectoryCopy(string sourceDirName, string destDirName, bool copySubDirs, bool overwrite = false)
//{
// // 不需要的文件
// // md5相同的文件 变化的
// DirectoryInfo dir = new(sourceDirName);

// if (!dir.Exists)
// {
// throw new DirectoryNotFoundException(
// "Source directory does not exist or could not be found: "
// + sourceDirName);
// }

// var dirs = dir.GetDirectories();

// Directory.CreateDirectory(destDirName);

// var files = dir.GetFiles();
// foreach (var file in files)
// {
// var tempPath = Path.Combine(destDirName, file.Name);
// file.CopyTo(tempPath, overwrite);
// }

// if (copySubDirs)
// {
// foreach (var subdir in dirs)
// {
// var tempPath = Path.Combine(destDirName, subdir.Name);
// DirectoryCopy(subdir.FullName, tempPath, copySubDirs, overwrite);
// }
// }
//}

//public void DownloadSync()
//{
Expand Down Expand Up @@ -130,40 +252,6 @@ public SavedataSyncService(
// }
//}

//public void UpdateSync()
//{
// try
// {
// if (!IsNetConnected)
// {
// return;
// }

// CloudSaveDataEntity gamedata = GetCurrentGameData() ?? throw new ArgumentNullException(nameof(gamedata));

// var savedataPath = _ehDbRepository.GameInfo?.SavedataPath ?? string.Empty;
// var saveTime = GetLastDirectoryModifiedTime(savedataPath);
// if (gamedata.PCId.Equals(Utils.MachineGuid, StringComparison.Ordinal) && gamedata.LastTimeModified < saveTime)
// {
// UploadFiles();
// UpdateLastModifiedTime(saveTime);
// }
// else if (!gamedata.PCId.Equals(Utils.MachineGuid, StringComparison.Ordinal))
// {
// var result = ModernWpf.MessageBox.Show("Upload savedata to cloud?", "Warning", System.Windows.MessageBoxButton.YesNo);
// if (result == System.Windows.MessageBoxResult.Yes)
// {
// UploadFiles();
// UpdateSavedataInfo();
// }
// }
// }
// catch (Exception ex)
// {
// this.Log().Debug(ex);
// };
//}

//private void UpdateSavedataInfo()
//{
// CloudDbFilePath.CheckFileExist();
Expand All @@ -179,60 +267,7 @@ public SavedataSyncService(
// File.WriteAllText(CloudDbFilePath, JsonConvert.SerializeObject(cloudGameDatas));
//}

//private void UpdateLastModifiedTime(DateTime time)
//{
// CloudDbFilePath.CheckFileExist();
// var cloudGameDatas =
// JsonConvert.DeserializeObject<List<CloudSaveDataEntity>>(File.ReadAllText(CloudDbFilePath))
// ?? new();

// var currentData = CreateGameData();

// cloudGameDatas.RemoveAll(item => item.Md5.Equals(currentData.Md5, StringComparison.Ordinal));
// cloudGameDatas.Add(currentData with { LastTimeModified = time });
// File.WriteAllText(CloudDbFilePath, JsonConvert.SerializeObject(cloudGameDatas));
//}

//private void DownloadFiles() => DirectoryCopy(CloudSavedataFolder, LocalSavedataFolder, true, true);

//private void UploadFiles() => DirectoryCopy(LocalSavedataFolder, CloudSavedataFolder, true, true);

//private static DateTime GetLastDirectoryModifiedTime(string path) =>
// new DirectoryInfo(path)
// .EnumerateFileSystemInfos()
// .Max(i => i.LastWriteTime);

//private static void DirectoryCopy(string sourceDirName, string destDirName, bool copySubDirs, bool overwrite = false)
//{
// // 不需要的文件
// // md5相同的文件 变化的
// DirectoryInfo dir = new(sourceDirName);

// if (!dir.Exists)
// {
// throw new DirectoryNotFoundException(
// "Source directory does not exist or could not be found: "
// + sourceDirName);
// }

// var dirs = dir.GetDirectories();

// Directory.CreateDirectory(destDirName);

// var files = dir.GetFiles();
// foreach (var file in files)
// {
// var tempPath = Path.Combine(destDirName, file.Name);
// file.CopyTo(tempPath, overwrite);
// }

// if (copySubDirs)
// {
// foreach (var subdir in dirs)
// {
// var tempPath = Path.Combine(destDirName, subdir.Name);
// DirectoryCopy(subdir.FullName, tempPath, copySubDirs, overwrite);
// }
// }
//}
}
Loading

0 comments on commit 754f6b4

Please sign in to comment.