343 lines
10 KiB
C#
343 lines
10 KiB
C#
using System;
|
||
using System.Collections;
|
||
using System.Collections.Generic;
|
||
using System.IO;
|
||
|
||
namespace YooAsset
|
||
{
|
||
internal class HostPlayModeImpl : IBundleServices
|
||
{
|
||
// 补丁清单
|
||
internal PatchManifest AppPatchManifest { private set; get; }
|
||
internal PatchManifest LocalPatchManifest { private set; get; }
|
||
|
||
// 参数相关
|
||
internal bool LocationToLower { private set; get; }
|
||
internal bool ClearCacheWhenDirty { private set; get; }
|
||
private string _defaultHostServer;
|
||
private string _fallbackHostServer;
|
||
|
||
/// <summary>
|
||
/// 异步初始化
|
||
/// </summary>
|
||
public InitializationOperation InitializeAsync(bool locationToLower, bool clearCacheWhenDirty, string defaultHostServer, string fallbackHostServer)
|
||
{
|
||
LocationToLower = locationToLower;
|
||
ClearCacheWhenDirty = clearCacheWhenDirty;
|
||
_defaultHostServer = defaultHostServer;
|
||
_fallbackHostServer = fallbackHostServer;
|
||
|
||
var operation = new HostPlayModeInitializationOperation(this);
|
||
OperationSystem.ProcessOperaiton(operation);
|
||
return operation;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 异步更新资源版本号
|
||
/// </summary>
|
||
public UpdateStaticVersionOperation UpdateStaticVersionAsync(int timeout)
|
||
{
|
||
var operation = new HostPlayModeUpdateStaticVersionOperation(this, timeout);
|
||
OperationSystem.ProcessOperaiton(operation);
|
||
return operation;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 异步更新补丁清单
|
||
/// </summary>
|
||
public UpdateManifestOperation UpdatePatchManifestAsync(int resourceVersion, int timeout)
|
||
{
|
||
var operation = new HostPlayModeUpdateManifestOperation(this, resourceVersion, timeout);
|
||
OperationSystem.ProcessOperaiton(operation);
|
||
return operation;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 异步更新资源包裹
|
||
/// </summary>
|
||
public UpdatePackageOperation UpdatePackageAsync(int resourceVersion, int timeout)
|
||
{
|
||
var operation = new HostPlayModeUpdatePackageOperation(this, resourceVersion, timeout);
|
||
OperationSystem.ProcessOperaiton(operation);
|
||
return operation;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取资源版本号
|
||
/// </summary>
|
||
public int GetResourceVersion()
|
||
{
|
||
if (LocalPatchManifest == null)
|
||
return 0;
|
||
return LocalPatchManifest.ResourceVersion;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 清空未被使用的缓存文件
|
||
/// </summary>
|
||
public void ClearUnusedCacheFiles()
|
||
{
|
||
string cacheFolderPath = SandboxHelper.GetCacheFolderPath();
|
||
if (Directory.Exists(cacheFolderPath) == false)
|
||
return;
|
||
|
||
DirectoryInfo directoryInfo = new DirectoryInfo(cacheFolderPath);
|
||
foreach (FileInfo fileInfo in directoryInfo.GetFiles())
|
||
{
|
||
bool used = false;
|
||
foreach (var patchBundle in LocalPatchManifest.BundleList)
|
||
{
|
||
if (fileInfo.Name == patchBundle.Hash)
|
||
{
|
||
used = true;
|
||
break;
|
||
}
|
||
}
|
||
if(used == false)
|
||
{
|
||
YooLogger.Log($"Delete unused cache file : {fileInfo.Name}");
|
||
File.Delete(fileInfo.FullName);
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建下载器
|
||
/// </summary>
|
||
public PatchDownloaderOperation CreatePatchDownloaderByAll(int fileLoadingMaxNumber, int failedTryAgain)
|
||
{
|
||
List<BundleInfo> downloadList = GetDownloadListByAll();
|
||
var operation = new PatchDownloaderOperation(downloadList, fileLoadingMaxNumber, failedTryAgain);
|
||
return operation;
|
||
}
|
||
private List<BundleInfo> GetDownloadListByAll()
|
||
{
|
||
List<PatchBundle> downloadList = new List<PatchBundle>(1000);
|
||
foreach (var patchBundle in LocalPatchManifest.BundleList)
|
||
{
|
||
// 忽略缓存文件
|
||
if (DownloadSystem.ContainsVerifyFile(patchBundle.Hash))
|
||
continue;
|
||
|
||
// 忽略APP资源
|
||
// 注意：如果是APP资源并且哈希值相同，则不需要下载
|
||
if (AppPatchManifest.Bundles.TryGetValue(patchBundle.BundleName, out PatchBundle appPatchBundle))
|
||
{
|
||
if (appPatchBundle.IsBuildin && appPatchBundle.Hash == patchBundle.Hash)
|
||
continue;
|
||
}
|
||
|
||
downloadList.Add(patchBundle);
|
||
}
|
||
|
||
return ConvertToDownloadList(downloadList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建下载器
|
||
/// </summary>
|
||
public PatchDownloaderOperation CreatePatchDownloaderByTags(string[] tags, int fileLoadingMaxNumber, int failedTryAgain)
|
||
{
|
||
List<BundleInfo> downloadList = GetDownloadListByTags(tags);
|
||
var operation = new PatchDownloaderOperation(downloadList, fileLoadingMaxNumber, failedTryAgain);
|
||
return operation;
|
||
}
|
||
private List<BundleInfo> GetDownloadListByTags(string[] tags)
|
||
{
|
||
List<PatchBundle> downloadList = new List<PatchBundle>(1000);
|
||
foreach (var patchBundle in LocalPatchManifest.BundleList)
|
||
{
|
||
// 忽略缓存文件
|
||
if (DownloadSystem.ContainsVerifyFile(patchBundle.Hash))
|
||
continue;
|
||
|
||
// 忽略APP资源
|
||
// 注意：如果是APP资源并且哈希值相同，则不需要下载
|
||
if (AppPatchManifest.Bundles.TryGetValue(patchBundle.BundleName, out PatchBundle appPatchBundle))
|
||
{
|
||
if (appPatchBundle.IsBuildin && appPatchBundle.Hash == patchBundle.Hash)
|
||
continue;
|
||
}
|
||
|
||
// 如果是纯内置资源，则统一下载
|
||
// 注意：可能是新增的或者变化的内置资源
|
||
// 注意：可能是由热更资源转换的内置资源
|
||
if (patchBundle.IsPureBuildin())
|
||
{
|
||
downloadList.Add(patchBundle);
|
||
}
|
||
else
|
||
{
|
||
// 查询DLC资源
|
||
if (patchBundle.HasTag(tags))
|
||
{
|
||
downloadList.Add(patchBundle);
|
||
}
|
||
}
|
||
}
|
||
|
||
return ConvertToDownloadList(downloadList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建下载器
|
||
/// </summary>
|
||
public PatchDownloaderOperation CreatePatchDownloaderByPaths(List<string> assetPaths, int fileLoadingMaxNumber, int failedTryAgain)
|
||
{
|
||
List<BundleInfo> downloadList = GetDownloadListByPaths(assetPaths);
|
||
var operation = new PatchDownloaderOperation(downloadList, fileLoadingMaxNumber, failedTryAgain);
|
||
return operation;
|
||
}
|
||
private List<BundleInfo> GetDownloadListByPaths(List<string> assetPaths)
|
||
{
|
||
// 获取资源对象的资源包和所有依赖资源包
|
||
List<PatchBundle> checkList = new List<PatchBundle>();
|
||
foreach (var assetPath in assetPaths)
|
||
{
|
||
string mainBundleName = LocalPatchManifest.GetBundleName(assetPath);
|
||
if (string.IsNullOrEmpty(mainBundleName) == false)
|
||
{
|
||
if (LocalPatchManifest.Bundles.TryGetValue(mainBundleName, out PatchBundle mainBundle))
|
||
{
|
||
if (checkList.Contains(mainBundle) == false)
|
||
checkList.Add(mainBundle);
|
||
}
|
||
}
|
||
|
||
string[] dependBundleNames = LocalPatchManifest.GetAllDependencies(assetPath);
|
||
foreach (var dependBundleName in dependBundleNames)
|
||
{
|
||
if (LocalPatchManifest.Bundles.TryGetValue(dependBundleName, out PatchBundle dependBundle))
|
||
{
|
||
if (checkList.Contains(dependBundle) == false)
|
||
checkList.Add(dependBundle);
|
||
}
|
||
}
|
||
}
|
||
|
||
List<PatchBundle> downloadList = new List<PatchBundle>(1000);
|
||
foreach (var patchBundle in checkList)
|
||
{
|
||
// 忽略缓存文件
|
||
if (DownloadSystem.ContainsVerifyFile(patchBundle.Hash))
|
||
continue;
|
||
|
||
// 忽略APP资源
|
||
// 注意：如果是APP资源并且哈希值相同，则不需要下载
|
||
if (AppPatchManifest.Bundles.TryGetValue(patchBundle.BundleName, out PatchBundle appPatchBundle))
|
||
{
|
||
if (appPatchBundle.IsBuildin && appPatchBundle.Hash == patchBundle.Hash)
|
||
continue;
|
||
}
|
||
|
||
downloadList.Add(patchBundle);
|
||
}
|
||
|
||
return ConvertToDownloadList(downloadList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 创建解压器
|
||
/// </summary>
|
||
public PatchUnpackerOperation CreatePatchUnpackerByTags(string[] tags, int fileUpackingMaxNumber, int failedTryAgain)
|
||
{
|
||
List<BundleInfo> unpcakList = PatchHelper.GetUnpackListByTags(AppPatchManifest, tags);
|
||
var operation = new PatchUnpackerOperation(unpcakList, fileUpackingMaxNumber, failedTryAgain);
|
||
return operation;
|
||
}
|
||
|
||
// WEB相关
|
||
public string GetPatchDownloadMainURL(string fileName)
|
||
{
|
||
return $"{_defaultHostServer}/{fileName}";
|
||
}
|
||
public string GetPatchDownloadFallbackURL(string fileName)
|
||
{
|
||
return $"{_fallbackHostServer}/{fileName}";
|
||
}
|
||
|
||
// 下载相关
|
||
public List<BundleInfo> ConvertToDownloadList(List<PatchBundle> downloadList)
|
||
{
|
||
List<BundleInfo> result = new List<BundleInfo>(downloadList.Count);
|
||
foreach (var patchBundle in downloadList)
|
||
{
|
||
var bundleInfo = ConvertToDownloadInfo(patchBundle);
|
||
result.Add(bundleInfo);
|
||
}
|
||
return result;
|
||
}
|
||
public BundleInfo ConvertToDownloadInfo(PatchBundle patchBundle)
|
||
{
|
||
// 注意：资源版本号只用于确定下载路径
|
||
string remoteMainURL = GetPatchDownloadMainURL(patchBundle.Hash);
|
||
string remoteFallbackURL = GetPatchDownloadFallbackURL(patchBundle.Hash);
|
||
BundleInfo bundleInfo = new BundleInfo(patchBundle, BundleInfo.ELoadMode.LoadFromRemote, remoteMainURL, remoteFallbackURL);
|
||
return bundleInfo;
|
||
}
|
||
|
||
// 设置资源清单
|
||
internal void SetAppPatchManifest(PatchManifest patchManifest)
|
||
{
|
||
AppPatchManifest = patchManifest;
|
||
}
|
||
internal void SetLocalPatchManifest(PatchManifest patchManifest)
|
||
{
|
||
LocalPatchManifest = patchManifest;
|
||
LocalPatchManifest.InitAssetPathMapping(LocationToLower);
|
||
}
|
||
|
||
#region IBundleServices接口
|
||
BundleInfo IBundleServices.GetBundleInfo(string bundleName)
|
||
{
|
||
if (string.IsNullOrEmpty(bundleName))
|
||
return new BundleInfo(string.Empty);
|
||
|
||
if (LocalPatchManifest.Bundles.TryGetValue(bundleName, out PatchBundle patchBundle))
|
||
{
|
||
// 查询沙盒资源
|
||
if (DownloadSystem.ContainsVerifyFile(patchBundle.Hash))
|
||
{
|
||
BundleInfo bundleInfo = new BundleInfo(patchBundle, BundleInfo.ELoadMode.LoadFromCache);
|
||
return bundleInfo;
|
||
}
|
||
|
||
// 查询APP资源
|
||
if (AppPatchManifest.Bundles.TryGetValue(bundleName, out PatchBundle appPatchBundle))
|
||
{
|
||
if (appPatchBundle.IsBuildin && appPatchBundle.Hash == patchBundle.Hash)
|
||
{
|
||
BundleInfo bundleInfo = new BundleInfo(appPatchBundle, BundleInfo.ELoadMode.LoadFromStreaming);
|
||
return bundleInfo;
|
||
}
|
||
}
|
||
|
||
// 从服务端下载
|
||
return ConvertToDownloadInfo(patchBundle);
|
||
}
|
||
else
|
||
{
|
||
YooLogger.Warning($"Not found bundle in patch manifest : {bundleName}");
|
||
BundleInfo bundleInfo = new BundleInfo(bundleName);
|
||
return bundleInfo;
|
||
}
|
||
}
|
||
AssetInfo[] IBundleServices.GetAssetInfos(string[] tags)
|
||
{
|
||
return PatchHelper.GetAssetsInfoByTag(LocalPatchManifest, tags);
|
||
}
|
||
string IBundleServices.MappingToAssetPath(string location)
|
||
{
|
||
return LocalPatchManifest.MappingToAssetPath(location);
|
||
}
|
||
string IBundleServices.GetBundleName(string assetPath)
|
||
{
|
||
return LocalPatchManifest.GetBundleName(assetPath);
|
||
}
|
||
string[] IBundleServices.GetAllDependencies(string assetPath)
|
||
{
|
||
return LocalPatchManifest.GetAllDependencies(assetPath);
|
||
}
|
||
#endregion
|
||
}
|
||
} |