341 lines
9.7 KiB
C#
341 lines
9.7 KiB
C#
using System;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
|
|
namespace YooAsset
|
|
{
|
|
/// <summary>
|
|
/// 更新清单操作
|
|
/// </summary>
|
|
public abstract class UpdateManifestOperation : AsyncOperationBase
|
|
{
|
|
/// <summary>
|
|
/// 是否发现了新的补丁清单
|
|
/// </summary>
|
|
public bool FoundNewManifest { protected set; get; }
|
|
}
|
|
|
|
/// <summary>
|
|
/// 编辑器下模拟运行的更新清单操作
|
|
/// </summary>
|
|
internal sealed class EditorPlayModeUpdateManifestOperation : UpdateManifestOperation
|
|
{
|
|
internal override void Start()
|
|
{
|
|
Status = EOperationStatus.Succeed;
|
|
}
|
|
internal override void Update()
|
|
{
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 离线模式的更新清单操作
|
|
/// </summary>
|
|
internal sealed class OfflinePlayModeUpdateManifestOperation : UpdateManifestOperation
|
|
{
|
|
internal override void Start()
|
|
{
|
|
Status = EOperationStatus.Succeed;
|
|
}
|
|
internal override void Update()
|
|
{
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 联机模式的更新清单操作
|
|
/// </summary>
|
|
internal sealed class HostPlayModeUpdateManifestOperation : UpdateManifestOperation
|
|
{
|
|
private enum ESteps
|
|
{
|
|
None,
|
|
CheckManifestHash,
|
|
LoadWebManifest,
|
|
CheckWebManifest,
|
|
InitVerifyingCache,
|
|
UpdateVerifyingCache,
|
|
Done,
|
|
}
|
|
|
|
private static int RequestCount = 0;
|
|
private readonly HostPlayModeImpl _impl;
|
|
private readonly string _packageName;
|
|
private readonly string _packageCRC;
|
|
private readonly int _timeout;
|
|
private ESteps _steps = ESteps.None;
|
|
private UnityWebDataRequester _downloader;
|
|
private PatchCacheVerifier _patchCacheVerifier;
|
|
private float _verifyTime;
|
|
|
|
internal HostPlayModeUpdateManifestOperation(HostPlayModeImpl impl, string packageName, string packageCRC, int timeout)
|
|
{
|
|
_impl = impl;
|
|
_packageName = packageName;
|
|
_packageCRC = packageCRC;
|
|
_timeout = timeout;
|
|
|
|
#if UNITY_WEBGL
|
|
_patchCacheVerifier = new PatchCacheVerifierWithoutThread();
|
|
#else
|
|
_patchCacheVerifier = new PatchCacheVerifierWithThread();
|
|
#endif
|
|
}
|
|
internal override void Start()
|
|
{
|
|
RequestCount++;
|
|
_steps = ESteps.CheckManifestHash;
|
|
}
|
|
internal override void Update()
|
|
{
|
|
if (_steps == ESteps.None || _steps == ESteps.Done)
|
|
return;
|
|
|
|
if (_steps == ESteps.CheckManifestHash)
|
|
{
|
|
string cachedManifestCRC = GetSandboxPatchManifestFileHash(_packageName, _packageCRC);
|
|
|
|
// 如果补丁清单文件的哈希值相同
|
|
if (cachedManifestCRC == _packageCRC)
|
|
{
|
|
YooLogger.Log($"Patch manifest file hash is not change : {_packageCRC}");
|
|
LoadSandboxPatchManifest(_packageName, _packageCRC);
|
|
FoundNewManifest = false;
|
|
_steps = ESteps.InitVerifyingCache;
|
|
}
|
|
else
|
|
{
|
|
YooLogger.Log($"Patch manifest hash is change : {cachedManifestCRC} -> {_packageCRC}");
|
|
FoundNewManifest = true;
|
|
_steps = ESteps.LoadWebManifest;
|
|
}
|
|
}
|
|
|
|
if (_steps == ESteps.LoadWebManifest)
|
|
{
|
|
string fileName = YooAssetSettingsData.GetPatchManifestFileName(_packageName, _packageCRC);
|
|
string webURL = GetPatchManifestRequestURL(fileName);
|
|
YooLogger.Log($"Beginning to request patch manifest : {webURL}");
|
|
_downloader = new UnityWebDataRequester();
|
|
_downloader.SendRequest(webURL, _timeout);
|
|
_steps = ESteps.CheckWebManifest;
|
|
}
|
|
|
|
if (_steps == ESteps.CheckWebManifest)
|
|
{
|
|
if (_downloader.IsDone() == false)
|
|
return;
|
|
|
|
// Check error
|
|
if (_downloader.HasError())
|
|
{
|
|
_steps = ESteps.Done;
|
|
Status = EOperationStatus.Failed;
|
|
Error = _downloader.GetError();
|
|
}
|
|
else
|
|
{
|
|
// 解析补丁清单
|
|
if (ParseAndSaveRemotePatchManifest(_packageName, _packageCRC, _downloader.GetText()))
|
|
{
|
|
_steps = ESteps.InitVerifyingCache;
|
|
}
|
|
else
|
|
{
|
|
_steps = ESteps.Done;
|
|
Status = EOperationStatus.Failed;
|
|
Error = $"URL : {_downloader.URL} Error : remote patch manifest content is invalid";
|
|
}
|
|
}
|
|
_downloader.Dispose();
|
|
}
|
|
|
|
if (_steps == ESteps.InitVerifyingCache)
|
|
{
|
|
_patchCacheVerifier.InitVerifier(_impl, false);
|
|
_verifyTime = UnityEngine.Time.realtimeSinceStartup;
|
|
_steps = ESteps.UpdateVerifyingCache;
|
|
}
|
|
|
|
if (_steps == ESteps.UpdateVerifyingCache)
|
|
{
|
|
Progress = _patchCacheVerifier.GetVerifierProgress();
|
|
if (_patchCacheVerifier.UpdateVerifier())
|
|
{
|
|
_steps = ESteps.Done;
|
|
Status = EOperationStatus.Succeed;
|
|
float costTime = UnityEngine.Time.realtimeSinceStartup - _verifyTime;
|
|
YooLogger.Log($"Verify result : Success {_patchCacheVerifier.VerifySuccessCount}, Fail {_patchCacheVerifier.VerifyFailCount}, Elapsed time {costTime} seconds");
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取补丁清单请求地址
|
|
/// </summary>
|
|
private string GetPatchManifestRequestURL(string fileName)
|
|
{
|
|
// 轮流返回请求地址
|
|
if (RequestCount % 2 == 0)
|
|
return _impl.GetPatchDownloadFallbackURL(fileName);
|
|
else
|
|
return _impl.GetPatchDownloadMainURL(fileName);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 解析并保存远端请求的补丁清单
|
|
/// </summary>
|
|
private bool ParseAndSaveRemotePatchManifest(string packageName, string packageCRC, string content)
|
|
{
|
|
try
|
|
{
|
|
var remotePatchManifest = PatchManifest.Deserialize(content);
|
|
_impl.SetLocalPatchManifest(remotePatchManifest);
|
|
|
|
YooLogger.Log("Save remote patch manifest file.");
|
|
string fileName = YooAssetSettingsData.GetPatchManifestFileName(packageName, packageCRC);
|
|
string savePath = PathHelper.MakePersistentLoadPath(fileName);
|
|
PatchManifest.Serialize(savePath, remotePatchManifest);
|
|
return true;
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
YooLogger.Error(e.ToString());
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 加载沙盒内的补丁清单
|
|
/// 注意：在加载本地补丁清单之前，已经验证过文件的哈希值
|
|
/// </summary>
|
|
private void LoadSandboxPatchManifest(string packageName, string packageCRC)
|
|
{
|
|
YooLogger.Log("Load sandbox patch manifest file.");
|
|
string fileName = YooAssetSettingsData.GetPatchManifestFileName(packageName, packageCRC);
|
|
string filePath = PathHelper.MakePersistentLoadPath(fileName);
|
|
string jsonData = File.ReadAllText(filePath);
|
|
var sandboxPatchManifest = PatchManifest.Deserialize(jsonData);
|
|
_impl.SetLocalPatchManifest(sandboxPatchManifest);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取沙盒内补丁清单文件的哈希值
|
|
/// 注意：如果沙盒内补丁清单文件不存在，返回空字符串
|
|
/// </summary>
|
|
private string GetSandboxPatchManifestFileHash(string packageName, string packageCRC)
|
|
{
|
|
string fileName = YooAssetSettingsData.GetPatchManifestFileName(packageName, packageCRC);
|
|
string filePath = PathHelper.MakePersistentLoadPath(fileName);
|
|
if (File.Exists(filePath))
|
|
return HashUtility.FileCRC32(filePath);
|
|
else
|
|
return string.Empty;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 联机模式的更新清单操作（弱联网）
|
|
/// </summary>
|
|
internal sealed class HostPlayModeWeaklyUpdateManifestOperation : UpdateManifestOperation
|
|
{
|
|
private enum ESteps
|
|
{
|
|
None,
|
|
LoadSandboxManifestHash,
|
|
InitVerifyingCache,
|
|
UpdateVerifyingCache,
|
|
Done,
|
|
}
|
|
|
|
private readonly HostPlayModeImpl _impl;
|
|
private readonly string _packageName;
|
|
private readonly string _packageCRC;
|
|
private ESteps _steps = ESteps.None;
|
|
private PatchCacheVerifier _patchCacheVerifier;
|
|
private float _verifyTime;
|
|
|
|
internal HostPlayModeWeaklyUpdateManifestOperation(HostPlayModeImpl impl, string packageName, string packageCRC)
|
|
{
|
|
_impl = impl;
|
|
_packageName = packageName;
|
|
_packageCRC = packageCRC;
|
|
|
|
#if UNITY_WEBGL
|
|
_patchCacheVerifier = new PatchCacheVerifierWithoutThread();
|
|
#else
|
|
_patchCacheVerifier = new PatchCacheVerifierWithThread();
|
|
#endif
|
|
}
|
|
internal override void Start()
|
|
{
|
|
_steps = ESteps.LoadSandboxManifestHash;
|
|
}
|
|
internal override void Update()
|
|
{
|
|
if (_steps == ESteps.None || _steps == ESteps.Done)
|
|
return;
|
|
|
|
if (_steps == ESteps.LoadSandboxManifestHash)
|
|
{
|
|
LoadSandboxPatchManifest(_packageName, _packageCRC);
|
|
_steps = ESteps.InitVerifyingCache;
|
|
}
|
|
|
|
if (_steps == ESteps.InitVerifyingCache)
|
|
{
|
|
if (_patchCacheVerifier.InitVerifier(_impl, true))
|
|
{
|
|
_verifyTime = UnityEngine.Time.realtimeSinceStartup;
|
|
_steps = ESteps.UpdateVerifyingCache;
|
|
}
|
|
else
|
|
{
|
|
_steps = ESteps.Done;
|
|
Status = EOperationStatus.Failed;
|
|
Error = $"The package resource {_packageName}_{_packageCRC} content is not complete !";
|
|
}
|
|
}
|
|
|
|
if (_steps == ESteps.UpdateVerifyingCache)
|
|
{
|
|
Progress = _patchCacheVerifier.GetVerifierProgress();
|
|
if (_patchCacheVerifier.UpdateVerifier())
|
|
{
|
|
float costTime = UnityEngine.Time.realtimeSinceStartup - _verifyTime;
|
|
YooLogger.Log($"Verify result : Success {_patchCacheVerifier.VerifySuccessCount}, Fail {_patchCacheVerifier.VerifyFailCount}, Elapsed time {costTime} seconds");
|
|
if (_patchCacheVerifier.VerifyFailCount > 0)
|
|
{
|
|
_steps = ESteps.Done;
|
|
Status = EOperationStatus.Failed;
|
|
Error = $"The package resource {_packageName}_{_packageCRC} content has verify failed file !";
|
|
}
|
|
else
|
|
{
|
|
_steps = ESteps.Done;
|
|
Status = EOperationStatus.Succeed;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 加载沙盒内的补丁清单
|
|
/// 注意：在加载本地补丁清单之前，未验证过文件的哈希值
|
|
/// </summary>
|
|
private void LoadSandboxPatchManifest(string packageName, string packageCRC)
|
|
{
|
|
string fileName = YooAssetSettingsData.GetPatchManifestFileName(packageName, packageCRC);
|
|
string filePath = PathHelper.MakePersistentLoadPath(fileName);
|
|
if (File.Exists(filePath))
|
|
{
|
|
YooLogger.Log("Load sandbox patch manifest file.");
|
|
string jsonData = File.ReadAllText(filePath);
|
|
var sandboxPatchManifest = PatchManifest.Deserialize(jsonData);
|
|
_impl.SetLocalPatchManifest(sandboxPatchManifest);
|
|
}
|
|
}
|
|
}
|
|
} |