forked from Mirror/Ryujinx
561 lines
21 KiB
C#
561 lines
21 KiB
C#
using Gtk;
|
|
using ICSharpCode.SharpZipLib.GZip;
|
|
using ICSharpCode.SharpZipLib.Tar;
|
|
using ICSharpCode.SharpZipLib.Zip;
|
|
using Mono.Unix;
|
|
using Newtonsoft.Json.Linq;
|
|
using Ryujinx.Common.Logging;
|
|
using Ryujinx.Ui;
|
|
using Ryujinx.Ui.Widgets;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.NetworkInformation;
|
|
using System.Runtime.InteropServices;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Ryujinx.Modules
|
|
{
|
|
public static class Updater
|
|
{
|
|
internal static bool Running;
|
|
|
|
private static readonly string HomeDir = AppDomain.CurrentDomain.BaseDirectory;
|
|
private static readonly string UpdateDir = Path.Combine(Path.GetTempPath(), "Ryujinx", "update");
|
|
private static readonly string UpdatePublishDir = Path.Combine(UpdateDir, "publish");
|
|
private static readonly int ConnectionCount = 4;
|
|
|
|
private static string _jobId;
|
|
private static string _buildVer;
|
|
private static string _platformExt;
|
|
private static string _buildUrl;
|
|
private static long _buildSize;
|
|
|
|
private const string AppveyorApiUrl = "https://ci.appveyor.com/api";
|
|
|
|
// On Windows, GtkSharp.Dependencies adds these extra dirs that must be cleaned during updates.
|
|
private static readonly string[] WindowsDependencyDirs = new string[] { "bin", "etc", "lib", "share" };
|
|
|
|
public static async Task BeginParse(MainWindow mainWindow, bool showVersionUpToDate)
|
|
{
|
|
if (Running) return;
|
|
|
|
Running = true;
|
|
mainWindow.UpdateMenuItem.Sensitive = false;
|
|
|
|
int artifactIndex = -1;
|
|
|
|
// Detect current platform
|
|
if (RuntimeInformation.IsOSPlatform(OSPlatform.OSX))
|
|
{
|
|
_platformExt = "osx_x64.zip";
|
|
artifactIndex = 1;
|
|
}
|
|
else if (RuntimeInformation.IsOSPlatform(OSPlatform.Windows))
|
|
{
|
|
_platformExt = "win_x64.zip";
|
|
artifactIndex = 2;
|
|
}
|
|
else if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
|
{
|
|
_platformExt = "linux_x64.tar.gz";
|
|
artifactIndex = 0;
|
|
}
|
|
|
|
if (artifactIndex == -1)
|
|
{
|
|
GtkDialog.CreateErrorDialog("Your platform is not supported!");
|
|
|
|
return;
|
|
}
|
|
|
|
Version newVersion;
|
|
Version currentVersion;
|
|
|
|
try
|
|
{
|
|
currentVersion = Version.Parse(Program.Version);
|
|
}
|
|
catch
|
|
{
|
|
GtkDialog.CreateWarningDialog("Failed to convert the current Ryujinx version.", "Cancelling Update!");
|
|
Logger.Error?.Print(LogClass.Application, "Failed to convert the current Ryujinx version!");
|
|
|
|
return;
|
|
}
|
|
|
|
// Get latest version number from Appveyor
|
|
try
|
|
{
|
|
using (WebClient jsonClient = new WebClient())
|
|
{
|
|
// Fetch latest build information
|
|
string fetchedJson = await jsonClient.DownloadStringTaskAsync($"{AppveyorApiUrl}/projects/gdkchan/ryujinx/branch/master");
|
|
JObject jsonRoot = JObject.Parse(fetchedJson);
|
|
JToken buildToken = jsonRoot["build"];
|
|
|
|
_jobId = (string)buildToken["jobs"][0]["jobId"];
|
|
_buildVer = (string)buildToken["version"];
|
|
_buildUrl = $"{AppveyorApiUrl}/buildjobs/{_jobId}/artifacts/ryujinx-{_buildVer}-{_platformExt}";
|
|
|
|
// If build not done, assume no new update are availaible.
|
|
if ((string)buildToken["jobs"][0]["status"] != "success")
|
|
{
|
|
if (showVersionUpToDate)
|
|
{
|
|
GtkDialog.CreateUpdaterInfoDialog("You are already using the latest version of Ryujinx!", "");
|
|
}
|
|
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
Logger.Error?.Print(LogClass.Application, exception.Message);
|
|
GtkDialog.CreateErrorDialog("An error has occurred when trying to get release information from AppVeyor.");
|
|
|
|
return;
|
|
}
|
|
|
|
try
|
|
{
|
|
newVersion = Version.Parse(_buildVer);
|
|
}
|
|
catch
|
|
{
|
|
GtkDialog.CreateWarningDialog("Failed to convert the received Ryujinx version from AppVeyor.", "Cancelling Update!");
|
|
Logger.Error?.Print(LogClass.Application, "Failed to convert the received Ryujinx version from AppVeyor!");
|
|
|
|
return;
|
|
}
|
|
|
|
if (newVersion <= currentVersion)
|
|
{
|
|
if (showVersionUpToDate)
|
|
{
|
|
GtkDialog.CreateUpdaterInfoDialog("You are already using the latest version of Ryujinx!", "");
|
|
}
|
|
|
|
Running = false;
|
|
mainWindow.UpdateMenuItem.Sensitive = true;
|
|
|
|
return;
|
|
}
|
|
|
|
// Fetch build size information to learn chunk sizes.
|
|
using (WebClient buildSizeClient = new WebClient())
|
|
{
|
|
try
|
|
{
|
|
buildSizeClient.Headers.Add("Range", "bytes=0-0");
|
|
await buildSizeClient.DownloadDataTaskAsync(new Uri(_buildUrl));
|
|
|
|
string contentRange = buildSizeClient.ResponseHeaders["Content-Range"];
|
|
_buildSize = long.Parse(contentRange.Substring(contentRange.IndexOf('/') + 1));
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logger.Warning?.Print(LogClass.Application, ex.Message);
|
|
Logger.Warning?.Print(LogClass.Application, "Couldn't determine build size for update, will use single-threaded updater");
|
|
|
|
_buildSize = -1;
|
|
}
|
|
}
|
|
|
|
// Show a message asking the user if they want to update
|
|
UpdateDialog updateDialog = new UpdateDialog(mainWindow, newVersion, _buildUrl);
|
|
updateDialog.Show();
|
|
}
|
|
|
|
public static void UpdateRyujinx(UpdateDialog updateDialog, string downloadUrl)
|
|
{
|
|
// Empty update dir, although it shouldn't ever have anything inside it
|
|
if (Directory.Exists(UpdateDir))
|
|
{
|
|
Directory.Delete(UpdateDir, true);
|
|
}
|
|
|
|
Directory.CreateDirectory(UpdateDir);
|
|
|
|
string updateFile = Path.Combine(UpdateDir, "update.bin");
|
|
|
|
// Download the update .zip
|
|
updateDialog.MainText.Text = "Downloading Update...";
|
|
updateDialog.ProgressBar.Value = 0;
|
|
updateDialog.ProgressBar.MaxValue = 100;
|
|
|
|
if (_buildSize >= 0)
|
|
{
|
|
DoUpdateWithMultipleThreads(updateDialog, downloadUrl, updateFile);
|
|
}
|
|
else
|
|
{
|
|
DoUpdateWithSingleThread(updateDialog, downloadUrl, updateFile);
|
|
}
|
|
}
|
|
|
|
private static void DoUpdateWithMultipleThreads(UpdateDialog updateDialog, string downloadUrl, string updateFile)
|
|
{
|
|
// Multi-Threaded Updater
|
|
long chunkSize = _buildSize / ConnectionCount;
|
|
long remainderChunk = _buildSize % ConnectionCount;
|
|
|
|
int completedRequests = 0;
|
|
int totalProgressPercentage = 0;
|
|
int[] progressPercentage = new int[ConnectionCount];
|
|
|
|
List<byte[]> list = new List<byte[]>(ConnectionCount);
|
|
List<WebClient> webClients = new List<WebClient>(ConnectionCount);
|
|
|
|
for (int i = 0; i < ConnectionCount; i++)
|
|
{
|
|
list.Add(new byte[0]);
|
|
}
|
|
|
|
for (int i = 0; i < ConnectionCount; i++)
|
|
{
|
|
using (WebClient client = new WebClient())
|
|
{
|
|
webClients.Add(client);
|
|
|
|
if (i == ConnectionCount - 1)
|
|
{
|
|
client.Headers.Add("Range", $"bytes={chunkSize * i}-{(chunkSize * (i + 1) - 1) + remainderChunk}");
|
|
}
|
|
else
|
|
{
|
|
client.Headers.Add("Range", $"bytes={chunkSize * i}-{chunkSize * (i + 1) - 1}");
|
|
}
|
|
|
|
client.DownloadProgressChanged += (_, args) =>
|
|
{
|
|
int index = (int)args.UserState;
|
|
|
|
Interlocked.Add(ref totalProgressPercentage, -1 * progressPercentage[index]);
|
|
Interlocked.Exchange(ref progressPercentage[index], args.ProgressPercentage);
|
|
Interlocked.Add(ref totalProgressPercentage, args.ProgressPercentage);
|
|
|
|
updateDialog.ProgressBar.Value = totalProgressPercentage / ConnectionCount;
|
|
};
|
|
|
|
client.DownloadDataCompleted += (_, args) =>
|
|
{
|
|
int index = (int)args.UserState;
|
|
|
|
if (args.Cancelled)
|
|
{
|
|
webClients[index].Dispose();
|
|
|
|
return;
|
|
}
|
|
|
|
list[index] = args.Result;
|
|
Interlocked.Increment(ref completedRequests);
|
|
|
|
if (Interlocked.Equals(completedRequests, ConnectionCount))
|
|
{
|
|
byte[] mergedFileBytes = new byte[_buildSize];
|
|
for (int connectionIndex = 0, destinationOffset = 0; connectionIndex < ConnectionCount; connectionIndex++)
|
|
{
|
|
Array.Copy(list[connectionIndex], 0, mergedFileBytes, destinationOffset, list[connectionIndex].Length);
|
|
destinationOffset += list[connectionIndex].Length;
|
|
}
|
|
|
|
File.WriteAllBytes(updateFile, mergedFileBytes);
|
|
|
|
try
|
|
{
|
|
InstallUpdate(updateDialog, updateFile);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Logger.Warning?.Print(LogClass.Application, e.Message);
|
|
Logger.Warning?.Print(LogClass.Application, $"Multi-Threaded update failed, falling back to single-threaded updater.");
|
|
|
|
DoUpdateWithSingleThread(updateDialog, downloadUrl, updateFile);
|
|
|
|
return;
|
|
}
|
|
}
|
|
};
|
|
|
|
try
|
|
{
|
|
client.DownloadDataAsync(new Uri(downloadUrl), i);
|
|
}
|
|
catch (WebException ex)
|
|
{
|
|
Logger.Warning?.Print(LogClass.Application, ex.Message);
|
|
Logger.Warning?.Print(LogClass.Application, $"Multi-Threaded update failed, falling back to single-threaded updater.");
|
|
|
|
for (int j = 0; j < webClients.Count; j++)
|
|
{
|
|
webClients[j].CancelAsync();
|
|
}
|
|
|
|
DoUpdateWithSingleThread(updateDialog, downloadUrl, updateFile);
|
|
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void DoUpdateWithSingleThread(UpdateDialog updateDialog, string downloadUrl, string updateFile)
|
|
{
|
|
// Single-Threaded Updater
|
|
using (WebClient client = new WebClient())
|
|
{
|
|
client.DownloadProgressChanged += (_, args) =>
|
|
{
|
|
updateDialog.ProgressBar.Value = args.ProgressPercentage;
|
|
};
|
|
|
|
client.DownloadDataCompleted += (_, args) =>
|
|
{
|
|
File.WriteAllBytes(updateFile, args.Result);
|
|
InstallUpdate(updateDialog, updateFile);
|
|
};
|
|
|
|
client.DownloadDataAsync(new Uri(downloadUrl));
|
|
}
|
|
}
|
|
|
|
private static void SetUnixPermissions()
|
|
{
|
|
string ryuBin = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Ryujinx");
|
|
|
|
if (!RuntimeInformation.IsOSPlatform(OSPlatform.Windows))
|
|
{
|
|
UnixFileInfo unixFileInfo = new UnixFileInfo(ryuBin);
|
|
unixFileInfo.FileAccessPermissions |= FileAccessPermissions.UserExecute;
|
|
}
|
|
}
|
|
|
|
private static async void InstallUpdate(UpdateDialog updateDialog, string updateFile)
|
|
{
|
|
// Extract Update
|
|
updateDialog.MainText.Text = "Extracting Update...";
|
|
updateDialog.ProgressBar.Value = 0;
|
|
|
|
if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
|
{
|
|
using (Stream inStream = File.OpenRead(updateFile))
|
|
using (Stream gzipStream = new GZipInputStream(inStream))
|
|
using (TarInputStream tarStream = new TarInputStream(gzipStream, Encoding.ASCII))
|
|
{
|
|
updateDialog.ProgressBar.MaxValue = inStream.Length;
|
|
|
|
await Task.Run(() =>
|
|
{
|
|
TarEntry tarEntry;
|
|
while ((tarEntry = tarStream.GetNextEntry()) != null)
|
|
{
|
|
if (tarEntry.IsDirectory) continue;
|
|
|
|
string outPath = Path.Combine(UpdateDir, tarEntry.Name);
|
|
|
|
Directory.CreateDirectory(Path.GetDirectoryName(outPath));
|
|
|
|
using (FileStream outStream = File.OpenWrite(outPath))
|
|
{
|
|
tarStream.CopyEntryContents(outStream);
|
|
}
|
|
|
|
File.SetLastWriteTime(outPath, DateTime.SpecifyKind(tarEntry.ModTime, DateTimeKind.Utc));
|
|
|
|
TarEntry entry = tarEntry;
|
|
|
|
Application.Invoke(delegate
|
|
{
|
|
updateDialog.ProgressBar.Value += entry.Size;
|
|
});
|
|
}
|
|
});
|
|
|
|
updateDialog.ProgressBar.Value = inStream.Length;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
using (Stream inStream = File.OpenRead(updateFile))
|
|
using (ZipFile zipFile = new ZipFile(inStream))
|
|
{
|
|
updateDialog.ProgressBar.MaxValue = zipFile.Count;
|
|
|
|
await Task.Run(() =>
|
|
{
|
|
foreach (ZipEntry zipEntry in zipFile)
|
|
{
|
|
if (zipEntry.IsDirectory) continue;
|
|
|
|
string outPath = Path.Combine(UpdateDir, zipEntry.Name);
|
|
|
|
Directory.CreateDirectory(Path.GetDirectoryName(outPath));
|
|
|
|
using (Stream zipStream = zipFile.GetInputStream(zipEntry))
|
|
using (FileStream outStream = File.OpenWrite(outPath))
|
|
{
|
|
zipStream.CopyTo(outStream);
|
|
}
|
|
|
|
File.SetLastWriteTime(outPath, DateTime.SpecifyKind(zipEntry.DateTime, DateTimeKind.Utc));
|
|
|
|
Application.Invoke(delegate
|
|
{
|
|
updateDialog.ProgressBar.Value++;
|
|
});
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
// Delete downloaded zip
|
|
File.Delete(updateFile);
|
|
|
|
List<string> allFiles = EnumerateFilesToDelete().ToList();
|
|
|
|
updateDialog.MainText.Text = "Renaming Old Files...";
|
|
updateDialog.ProgressBar.Value = 0;
|
|
updateDialog.ProgressBar.MaxValue = allFiles.Count;
|
|
|
|
// Replace old files
|
|
await Task.Run(() =>
|
|
{
|
|
foreach (string file in allFiles)
|
|
{
|
|
try
|
|
{
|
|
File.Move(file, file + ".ryuold");
|
|
|
|
Application.Invoke(delegate
|
|
{
|
|
updateDialog.ProgressBar.Value++;
|
|
});
|
|
}
|
|
catch
|
|
{
|
|
Logger.Warning?.Print(LogClass.Application, "Updater was unable to rename file: " + file);
|
|
}
|
|
}
|
|
|
|
Application.Invoke(delegate
|
|
{
|
|
updateDialog.MainText.Text = "Adding New Files...";
|
|
updateDialog.ProgressBar.Value = 0;
|
|
updateDialog.ProgressBar.MaxValue = Directory.GetFiles(UpdatePublishDir, "*", SearchOption.AllDirectories).Length;
|
|
});
|
|
|
|
MoveAllFilesOver(UpdatePublishDir, HomeDir, updateDialog);
|
|
});
|
|
|
|
Directory.Delete(UpdateDir, true);
|
|
|
|
SetUnixPermissions();
|
|
|
|
updateDialog.MainText.Text = "Update Complete!";
|
|
updateDialog.SecondaryText.Text = "Do you want to restart Ryujinx now?";
|
|
updateDialog.Modal = true;
|
|
|
|
updateDialog.ProgressBar.Hide();
|
|
updateDialog.YesButton.Show();
|
|
updateDialog.NoButton.Show();
|
|
}
|
|
|
|
public static bool CanUpdate(bool showWarnings)
|
|
{
|
|
if (RuntimeInformation.OSArchitecture != Architecture.X64)
|
|
{
|
|
if (showWarnings)
|
|
{
|
|
GtkDialog.CreateWarningDialog("You are not running a supported system architecture!", "(Only x64 systems are supported!)");
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
if (!NetworkInterface.GetIsNetworkAvailable())
|
|
{
|
|
if (showWarnings)
|
|
{
|
|
GtkDialog.CreateWarningDialog("You are not connected to the Internet!", "Please verify that you have a working Internet connection!");
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
if (Program.Version.Contains("dirty"))
|
|
{
|
|
if (showWarnings)
|
|
{
|
|
GtkDialog.CreateWarningDialog("You Cannot update a Dirty build of Ryujinx!", "Please download Ryujinx at https://ryujinx.org/ if you are looking for a supported version.");
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
// NOTE: This method should always reflect the latest build layout.
|
|
private static IEnumerable<string> EnumerateFilesToDelete()
|
|
{
|
|
var files = Directory.EnumerateFiles(HomeDir); // All files directly in base dir.
|
|
|
|
if (RuntimeInformation.IsOSPlatform(OSPlatform.Windows))
|
|
{
|
|
foreach (string dir in WindowsDependencyDirs)
|
|
{
|
|
string dirPath = Path.Combine(HomeDir, dir);
|
|
if (Directory.Exists(dirPath))
|
|
{
|
|
files = files.Concat(Directory.EnumerateFiles(dirPath, "*", SearchOption.AllDirectories));
|
|
}
|
|
}
|
|
}
|
|
|
|
return files;
|
|
}
|
|
|
|
private static void MoveAllFilesOver(string root, string dest, UpdateDialog dialog)
|
|
{
|
|
foreach (string directory in Directory.GetDirectories(root))
|
|
{
|
|
string dirName = Path.GetFileName(directory);
|
|
|
|
if (!Directory.Exists(Path.Combine(dest, dirName)))
|
|
{
|
|
Directory.CreateDirectory(Path.Combine(dest, dirName));
|
|
}
|
|
|
|
MoveAllFilesOver(directory, Path.Combine(dest, dirName), dialog);
|
|
}
|
|
|
|
foreach (string file in Directory.GetFiles(root))
|
|
{
|
|
File.Move(file, Path.Combine(dest, Path.GetFileName(file)), true);
|
|
|
|
Application.Invoke(delegate
|
|
{
|
|
dialog.ProgressBar.Value++;
|
|
});
|
|
}
|
|
}
|
|
|
|
public static void CleanupUpdate()
|
|
{
|
|
foreach (string file in EnumerateFilesToDelete())
|
|
{
|
|
if (Path.GetExtension(file).EndsWith(".ryuold"))
|
|
{
|
|
File.Delete(file);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|