mirror of
https://github.com/DarkStore-3DS/DarkStore.git
synced 2026-07-03 00:39:02 +00:00
Universal-Updater Full Rewrite based of UniStore v3.0.0. (#51)
* No Nightlies for the Full-Rewrite. * Initial push, i guess. * Forgot to push the Test UniStore + T3X... * Use C2D flags for wrapping and centering * gitignore t3x correctly * Remove Test Store and hardcode to `sdmc:/3ds/Universal-Updater/stores/Universal-DB.unistore` for now. * Is functional now. * *More special checks and work.* * const <typename T> &. * Universal-DB, not Universal DB. * Derp. * Make 3DSX, NDS & Archive path configurable. * Last fixes + Fade out screen on exit. * See Desc. for more. - Add QR Code scan for downloading UniStores. - Add new Graphics. - Some fixes + improvements. * Fix search filtering, re-sort after search * Fix update check * Clear search items with X, not just reset results * The next progress. * PLEASE tell me, this is the only error.. Co-authored-by: Pk11 <epicpkmn11@outlook.com>
This commit is contained in:
StackZ
@@ -0,0 +1,899 @@
|
||||
/*
|
||||
* This file is part of Universal-Updater
|
||||
* Copyright (C) 2019-2020 Universal-Team
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
* Additional Terms 7.b and 7.c of GPLv3 apply to this file:
|
||||
* * Requiring preservation of specified reasonable legal notices or
|
||||
* author attributions in that material or in the Appropriate Legal
|
||||
* Notices displayed by works containing it.
|
||||
* * Prohibiting misrepresentation of the origin of that material,
|
||||
* or requiring that modified versions of such material be marked in
|
||||
* reasonable ways as different from the original version.
|
||||
*/
|
||||
|
||||
#include "animation.hpp"
|
||||
#include "download.hpp"
|
||||
#include "files.hpp"
|
||||
#include "json.hpp"
|
||||
#include "lang.hpp"
|
||||
#include "scriptUtils.hpp"
|
||||
#include "stringutils.hpp"
|
||||
|
||||
#include <3ds.h>
|
||||
#include <curl/curl.h>
|
||||
#include <dirent.h>
|
||||
#include <malloc.h>
|
||||
#include <regex>
|
||||
#include <string>
|
||||
#include <vector>
|
||||
|
||||
#define USER_AGENT APP_TITLE "-" VERSION_STRING
|
||||
|
||||
static char *result_buf = nullptr;
|
||||
static size_t result_sz = 0;
|
||||
static size_t result_written = 0;
|
||||
std::vector<std::string> _topText;
|
||||
std::string jsonName;
|
||||
|
||||
#define TIME_IN_US 1
|
||||
#define TIMETYPE curl_off_t
|
||||
#define TIMEOPT CURLINFO_TOTAL_TIME_T
|
||||
#define MINIMAL_PROGRESS_FUNCTIONALITY_INTERVAL 3000000
|
||||
|
||||
curl_off_t downloadTotal = 1; // Dont initialize with 0 to avoid division by zero later.
|
||||
curl_off_t downloadNow = 0;
|
||||
|
||||
static FILE *downfile = nullptr;
|
||||
static size_t file_buffer_pos = 0;
|
||||
static size_t file_toCommit_size = 0;
|
||||
static char *g_buffers[2] = { nullptr };
|
||||
static u8 g_index = 0;
|
||||
static Thread fsCommitThread;
|
||||
static LightEvent readyToCommit;
|
||||
static LightEvent waitCommit;
|
||||
static bool killThread = false;
|
||||
static bool writeError = false;
|
||||
#define FILE_ALLOC_SIZE 0x60000
|
||||
|
||||
extern int filesExtracted;
|
||||
extern std::string extractingFile;
|
||||
char progressBarMsg[128] = "";
|
||||
bool showProgressBar = false;
|
||||
ProgressBar progressbarType = ProgressBar::Downloading;
|
||||
|
||||
extern u64 extractSize, writeOffset;
|
||||
extern u64 installSize, installOffset;
|
||||
|
||||
static int curlProgress(CURL *hnd,
|
||||
curl_off_t dltotal, curl_off_t dlnow,
|
||||
curl_off_t ultotal, curl_off_t ulnow)
|
||||
{
|
||||
downloadTotal = dltotal;
|
||||
downloadNow = dlnow;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
bool filecommit() {
|
||||
if (!downfile) return false;
|
||||
fseek(downfile, 0, SEEK_END);
|
||||
u32 byteswritten = fwrite(g_buffers[!g_index], 1, file_toCommit_size, downfile);
|
||||
if (byteswritten != file_toCommit_size) return false;
|
||||
file_toCommit_size = 0;
|
||||
return true;
|
||||
}
|
||||
|
||||
static void commitToFileThreadFunc(void *args) {
|
||||
LightEvent_Signal(&waitCommit);
|
||||
|
||||
while (true) {
|
||||
LightEvent_Wait(&readyToCommit);
|
||||
LightEvent_Clear(&readyToCommit);
|
||||
if (killThread) threadExit(0);
|
||||
writeError = !filecommit();
|
||||
LightEvent_Signal(&waitCommit);
|
||||
}
|
||||
}
|
||||
|
||||
static size_t file_handle_data(char *ptr, size_t size, size_t nmemb, void *userdata) {
|
||||
(void)userdata;
|
||||
const size_t bsz = size * nmemb;
|
||||
size_t tofill = 0;
|
||||
if (writeError) return 0;
|
||||
|
||||
if (!g_buffers[g_index]) {
|
||||
LightEvent_Init(&waitCommit, RESET_STICKY);
|
||||
LightEvent_Init(&readyToCommit, RESET_STICKY);
|
||||
|
||||
s32 prio = 0;
|
||||
svcGetThreadPriority(&prio, CUR_THREAD_HANDLE);
|
||||
fsCommitThread = threadCreate(commitToFileThreadFunc, NULL, 0x1000, prio - 1, -2, true);
|
||||
|
||||
g_buffers[0] = (char*)memalign(0x1000, FILE_ALLOC_SIZE);
|
||||
g_buffers[1] = (char*)memalign(0x1000, FILE_ALLOC_SIZE);
|
||||
|
||||
if (!fsCommitThread || !g_buffers[0] || !g_buffers[1]) return 0;
|
||||
}
|
||||
|
||||
if (file_buffer_pos + bsz >= FILE_ALLOC_SIZE) {
|
||||
tofill = FILE_ALLOC_SIZE - file_buffer_pos;
|
||||
memcpy(g_buffers[g_index] + file_buffer_pos, ptr, tofill);
|
||||
|
||||
LightEvent_Wait(&waitCommit);
|
||||
LightEvent_Clear(&waitCommit);
|
||||
file_toCommit_size = file_buffer_pos + tofill;
|
||||
file_buffer_pos = 0;
|
||||
svcFlushProcessDataCache(CUR_PROCESS_HANDLE, (u32)g_buffers[g_index], file_toCommit_size);
|
||||
g_index = !g_index;
|
||||
LightEvent_Signal(&readyToCommit);
|
||||
}
|
||||
|
||||
memcpy(g_buffers[g_index] + file_buffer_pos, ptr + tofill, bsz - tofill);
|
||||
file_buffer_pos += bsz - tofill;
|
||||
return bsz;
|
||||
}
|
||||
|
||||
Result downloadToFile(const std::string &url, const std::string &path) {
|
||||
downloadTotal = 1;
|
||||
downloadNow = 0;
|
||||
|
||||
CURLcode curlResult;
|
||||
CURL *hnd;
|
||||
Result retcode = 0;
|
||||
downloadTotal = 1;
|
||||
int res;
|
||||
|
||||
printf("Downloading from:\n%s\nto:\n%s\n", url.c_str(), path.c_str());
|
||||
const char *filepath = path.c_str();
|
||||
|
||||
void *socubuf = memalign(0x1000, 0x100000);
|
||||
if (!socubuf) {
|
||||
retcode = -1;
|
||||
goto exit;
|
||||
}
|
||||
|
||||
res = socInit((u32 *)socubuf, 0x100000);
|
||||
if (R_FAILED(res)) {
|
||||
retcode = res;
|
||||
goto exit;
|
||||
}
|
||||
|
||||
makeDirs(strdup(filepath));
|
||||
|
||||
downfile = fopen(filepath, "wb");
|
||||
if (!downfile) {
|
||||
retcode = -2;
|
||||
goto exit;
|
||||
}
|
||||
|
||||
hnd = curl_easy_init();
|
||||
curl_easy_setopt(hnd, CURLOPT_BUFFERSIZE, FILE_ALLOC_SIZE);
|
||||
curl_easy_setopt(hnd, CURLOPT_URL, url.c_str());
|
||||
curl_easy_setopt(hnd, CURLOPT_NOPROGRESS, 0L);
|
||||
curl_easy_setopt(hnd, CURLOPT_USERAGENT, USER_AGENT);
|
||||
curl_easy_setopt(hnd, CURLOPT_FOLLOWLOCATION, 1L);
|
||||
curl_easy_setopt(hnd, CURLOPT_FAILONERROR, 1L);
|
||||
curl_easy_setopt(hnd, CURLOPT_ACCEPT_ENCODING, "gzip");
|
||||
curl_easy_setopt(hnd, CURLOPT_MAXREDIRS, 50L);
|
||||
curl_easy_setopt(hnd, CURLOPT_XFERINFOFUNCTION, curlProgress);
|
||||
curl_easy_setopt(hnd, CURLOPT_HTTP_VERSION, (long)CURL_HTTP_VERSION_2TLS);
|
||||
curl_easy_setopt(hnd, CURLOPT_WRITEFUNCTION, file_handle_data);
|
||||
curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYPEER, 0L);
|
||||
curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L);
|
||||
curl_easy_setopt(hnd, CURLOPT_STDERR, stdout);
|
||||
|
||||
curlResult = curl_easy_perform(hnd);
|
||||
curl_easy_cleanup(hnd);
|
||||
|
||||
if (curlResult != CURLE_OK) {
|
||||
retcode = -curlResult;
|
||||
goto exit;
|
||||
}
|
||||
|
||||
LightEvent_Wait(&waitCommit);
|
||||
LightEvent_Clear(&waitCommit);
|
||||
|
||||
file_toCommit_size = file_buffer_pos;
|
||||
svcFlushProcessDataCache(CUR_PROCESS_HANDLE, (u32)g_buffers[g_index], file_toCommit_size);
|
||||
g_index = !g_index;
|
||||
|
||||
if (!filecommit()) {
|
||||
retcode = -3;
|
||||
goto exit;
|
||||
}
|
||||
|
||||
fflush(downfile);
|
||||
|
||||
exit:
|
||||
if (fsCommitThread) {
|
||||
killThread = true;
|
||||
LightEvent_Signal(&readyToCommit);
|
||||
threadJoin(fsCommitThread, U64_MAX);
|
||||
killThread = false;
|
||||
fsCommitThread = nullptr;
|
||||
}
|
||||
|
||||
socExit();
|
||||
|
||||
if (socubuf) free(socubuf);
|
||||
|
||||
if (downfile) {
|
||||
fclose(downfile);
|
||||
downfile = nullptr;
|
||||
}
|
||||
|
||||
if (g_buffers[0]) {
|
||||
free(g_buffers[0]);
|
||||
g_buffers[0] = nullptr;
|
||||
}
|
||||
|
||||
if (g_buffers[1]) {
|
||||
free(g_buffers[1]);
|
||||
g_buffers[1] = nullptr;
|
||||
}
|
||||
|
||||
g_index = 0;
|
||||
file_buffer_pos = 0;
|
||||
file_toCommit_size = 0;
|
||||
writeError = false;
|
||||
return retcode;
|
||||
}
|
||||
|
||||
/*
|
||||
following function is from
|
||||
https://github.com/angelsl/libctrfgh/blob/master/curl_test/src/main.c
|
||||
*/
|
||||
static size_t handle_data(char *ptr, size_t size, size_t nmemb, void *userdata) {
|
||||
(void)userdata;
|
||||
const size_t bsz = size*nmemb;
|
||||
|
||||
if (result_sz == 0 || !result_buf) {
|
||||
result_sz = 0x1000;
|
||||
result_buf = (char *)malloc(result_sz);
|
||||
}
|
||||
|
||||
bool need_realloc = false;
|
||||
while (result_written + bsz > result_sz) {
|
||||
result_sz <<= 1;
|
||||
need_realloc = true;
|
||||
}
|
||||
|
||||
if (need_realloc) {
|
||||
char *new_buf = (char *)realloc(result_buf, result_sz);
|
||||
if (!new_buf) return 0;
|
||||
|
||||
result_buf = new_buf;
|
||||
}
|
||||
|
||||
if (!result_buf) return 0;
|
||||
|
||||
memcpy(result_buf + result_written, ptr, bsz);
|
||||
result_written += bsz;
|
||||
return bsz;
|
||||
}
|
||||
|
||||
/*
|
||||
This + Above is Used for No File Write and instead into RAM.
|
||||
*/
|
||||
static Result setupContext(CURL *hnd, const char *url) {
|
||||
curl_easy_setopt(hnd, CURLOPT_BUFFERSIZE, 102400L);
|
||||
curl_easy_setopt(hnd, CURLOPT_URL, url);
|
||||
curl_easy_setopt(hnd, CURLOPT_NOPROGRESS, 0L);
|
||||
curl_easy_setopt(hnd, CURLOPT_USERAGENT, USER_AGENT);
|
||||
curl_easy_setopt(hnd, CURLOPT_FOLLOWLOCATION, 1L);
|
||||
curl_easy_setopt(hnd, CURLOPT_MAXREDIRS, 50L);
|
||||
curl_easy_setopt(hnd, CURLOPT_HTTP_VERSION, (long)CURL_HTTP_VERSION_2TLS);
|
||||
curl_easy_setopt(hnd, CURLOPT_WRITEFUNCTION, handle_data);
|
||||
curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYPEER, 0L);
|
||||
curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L);
|
||||
curl_easy_setopt(hnd, CURLOPT_STDERR, stdout);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
/*
|
||||
Download a file of a GitHub Release.
|
||||
|
||||
const std::string &url: Const Reference to the URL. (https://github.com/Owner/Repo)
|
||||
const std::string &asset: Const Reference to the Asset. (File.filetype)
|
||||
const std::string &path: Const Reference, where to store. (sdmc:/File.filetype)
|
||||
const bool &includePrereleases: Const Reference, if including Pre-Releases.
|
||||
*/
|
||||
Result downloadFromRelease(const std::string &url, const std::string &asset, const std::string &path, const bool &includePrereleases) {
|
||||
Result ret = 0;
|
||||
CURL *hnd;
|
||||
|
||||
void *socubuf = memalign(0x1000, 0x100000);
|
||||
if (!socubuf) {
|
||||
return -1;
|
||||
}
|
||||
|
||||
ret = socInit((u32*)socubuf, 0x100000);
|
||||
if (R_FAILED(ret)) {
|
||||
free(socubuf);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::regex parseUrl("github\\.com\\/(.+)\\/(.+)");
|
||||
std::smatch result;
|
||||
regex_search(url, result, parseUrl);
|
||||
|
||||
std::string repoOwner = result[1].str(), repoName = result[2].str();
|
||||
|
||||
std::stringstream apiurlStream;
|
||||
apiurlStream << "https://api.github.com/repos/" << repoOwner << "/" << repoName << (includePrereleases ? "/releases" : "/releases/latest");
|
||||
std::string apiurl = apiurlStream.str();
|
||||
|
||||
printf("Downloading latest release from repo:\n%s\nby:\n%s\n", repoName.c_str(), repoOwner.c_str());
|
||||
printf("Crafted API url:\n%s\n", apiurl.c_str());
|
||||
|
||||
hnd = curl_easy_init();
|
||||
|
||||
ret = setupContext(hnd, apiurl.c_str());
|
||||
if (ret != 0) {
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = NULL;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return ret;
|
||||
}
|
||||
|
||||
CURLcode cres = curl_easy_perform(hnd);
|
||||
curl_easy_cleanup(hnd);
|
||||
char *newbuf = (char *)realloc(result_buf, result_written + 1);
|
||||
result_buf = newbuf;
|
||||
result_buf[result_written] = 0; // nullbyte to end it as a proper C style string.
|
||||
|
||||
if (cres != CURLE_OK) {
|
||||
printf("Error in:\ncurl\n");
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return -1;
|
||||
}
|
||||
|
||||
printf("Looking for asset with matching name:\n%s\n", asset.c_str());
|
||||
std::string assetUrl;
|
||||
nlohmann::json parsedAPI = nlohmann::json::parse(result_buf);
|
||||
|
||||
if (parsedAPI.size() == 0) return -2; // All were prereleases and those are being ignored.
|
||||
if (includePrereleases) parsedAPI = parsedAPI[0];
|
||||
|
||||
if (parsedAPI["assets"].is_array()) {
|
||||
for (auto jsonAsset : parsedAPI["assets"]) {
|
||||
if (jsonAsset.is_object() && jsonAsset["name"].is_string() && jsonAsset["browser_download_url"].is_string()) {
|
||||
std::string assetName = jsonAsset["name"];
|
||||
|
||||
if (ScriptUtils::matchPattern(asset, assetName)) {
|
||||
assetUrl = jsonAsset["browser_download_url"];
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
if (assetUrl.empty()) {
|
||||
ret = DL_ERROR_GIT;
|
||||
|
||||
} else {
|
||||
ret = downloadToFile(assetUrl, path);
|
||||
}
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
/*
|
||||
Check Wi-Fi status.
|
||||
@return True if Wi-Fi is connected; false if not.
|
||||
*/
|
||||
bool checkWifiStatus(void) {
|
||||
//return true; // For citra.
|
||||
u32 wifiStatus;
|
||||
bool res = false;
|
||||
|
||||
if (R_SUCCEEDED(ACU_GetWifiStatus(&wifiStatus)) && wifiStatus) res = true;
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
void downloadFailed(void) { Msg::waitMsg(Lang::get("DOWNLOAD_FAILED")); }
|
||||
|
||||
void notImplemented(void) { Msg::waitMsg(Lang::get("NOT_IMPLEMENTED")); }
|
||||
|
||||
void doneMsg(void) { Msg::waitMsg(Lang::get("DONE")); }
|
||||
|
||||
void notConnectedMsg(void) { Msg::waitMsg(Lang::get("CONNECT_WIFI")); }
|
||||
|
||||
/*
|
||||
Display the progressbar.
|
||||
*/
|
||||
void displayProgressBar() {
|
||||
char str[256];
|
||||
|
||||
while(showProgressBar) {
|
||||
switch(progressbarType) {
|
||||
case ProgressBar::Downloading:
|
||||
if (downloadTotal < 1.0f) downloadTotal = 1.0f;
|
||||
if (downloadTotal < downloadNow) downloadTotal = downloadNow;
|
||||
|
||||
snprintf(str, sizeof(str), "%s / %s (%.2f%%)",
|
||||
StringUtils::formatBytes(downloadNow).c_str(),
|
||||
StringUtils::formatBytes(downloadTotal).c_str(),
|
||||
((float)downloadNow/(float)downloadTotal) * 100.0f);
|
||||
break;
|
||||
|
||||
case ProgressBar::Extracting:
|
||||
snprintf(str, sizeof(str), "%s / %s (%.2f%%)",
|
||||
StringUtils::formatBytes(writeOffset).c_str(),
|
||||
StringUtils::formatBytes(extractSize).c_str(),
|
||||
((float)writeOffset/(float)extractSize) * 100.0f);
|
||||
break;
|
||||
|
||||
case ProgressBar::Installing:
|
||||
snprintf(str, sizeof(str), "%s / %s (%.2f%%)",
|
||||
StringUtils::formatBytes(installOffset).c_str(),
|
||||
StringUtils::formatBytes(installSize).c_str(),
|
||||
((float)installOffset/(float)installSize) * 100.0f);
|
||||
break;
|
||||
}
|
||||
|
||||
Gui::clearTextBufs();
|
||||
C3D_FrameBegin(C3D_FRAME_SYNCDRAW);
|
||||
C2D_TargetClear(Top, TRANSPARENT);
|
||||
C2D_TargetClear(Bottom, TRANSPARENT);
|
||||
GFX::DrawTop();
|
||||
Gui::DrawStringCentered(0, 1, 0.7f, TEXT_COLOR, progressBarMsg, 400);
|
||||
|
||||
switch(progressbarType) {
|
||||
case ProgressBar::Downloading:
|
||||
Gui::DrawStringCentered(0, 80, 0.6f, TEXT_COLOR, str, 400);
|
||||
Animation::DrawProgressBar(downloadNow, downloadTotal);
|
||||
break;
|
||||
|
||||
case ProgressBar::Extracting:
|
||||
Gui::DrawStringCentered(0, 180, 0.6f, TEXT_COLOR, str, 400);
|
||||
Gui::DrawStringCentered(0, 100, 0.6f, TEXT_COLOR, std::to_string(filesExtracted) + " " + (filesExtracted == 1 ? (Lang::get("FILE_EXTRACTED")).c_str() :(Lang::get("FILES_EXTRACTED"))), 400);
|
||||
Gui::DrawStringCentered(0, 40, 0.6f, TEXT_COLOR, Lang::get("CURRENTLY_EXTRACTING") + "\n" + extractingFile, 400);
|
||||
Animation::DrawProgressBar(writeOffset, extractSize);
|
||||
break;
|
||||
|
||||
case ProgressBar::Installing:
|
||||
Gui::DrawStringCentered(0, 80, 0.6f, TEXT_COLOR, str, 400);
|
||||
Animation::DrawProgressBar(installOffset, installSize);
|
||||
break;
|
||||
}
|
||||
|
||||
GFX::DrawBottom();
|
||||
C3D_FrameEnd(0);
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
Return, if an update is available.
|
||||
|
||||
const std::string &URL: Const Reference to the URL of the UniStore.
|
||||
const int &revCurrent: Const Reference to the current Revision. (-1 if unused)
|
||||
*/
|
||||
bool IsUpdateAvailable(const std::string &URL, const int &revCurrent) {
|
||||
Msg::DisplayMsg(Lang::get("CHECK_UNISTORE_UPDATES"));
|
||||
Result ret = 0;
|
||||
|
||||
void *socubuf = memalign(0x1000, 0x100000);
|
||||
if (!socubuf) return false;
|
||||
|
||||
ret = socInit((u32 *)socubuf, 0x100000);
|
||||
|
||||
if (R_FAILED(ret)) {
|
||||
free(socubuf);
|
||||
return false;
|
||||
}
|
||||
|
||||
CURL *hnd = curl_easy_init();
|
||||
|
||||
ret = setupContext(hnd, URL.c_str());
|
||||
if (ret != 0) {
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
CURLcode cres = curl_easy_perform(hnd);
|
||||
curl_easy_cleanup(hnd);
|
||||
char *newbuf = (char *)realloc(result_buf, result_written + 1);
|
||||
result_buf = newbuf;
|
||||
result_buf[result_written] = 0; // nullbyte to end it as a proper C style string.
|
||||
|
||||
if (cres != CURLE_OK) {
|
||||
printf("Error in:\ncurl\n");
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
if (nlohmann::json::accept(result_buf)) {
|
||||
nlohmann::json parsedAPI = nlohmann::json::parse(result_buf);
|
||||
|
||||
if (parsedAPI.contains("storeInfo") && parsedAPI.contains("storeContent")) {
|
||||
if (parsedAPI["storeInfo"].contains("revision") && parsedAPI["storeInfo"]["revision"].is_number()) {
|
||||
const int rev = parsedAPI["storeInfo"]["revision"];
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return rev > revCurrent;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
/*
|
||||
Download a UniStore and return, if revision is higher than current.
|
||||
|
||||
const std::string &URL: Const Reference to the URL of the UniStore.
|
||||
const int ¤tRev: Const Reference to the current Revision. (-1 if unused)
|
||||
const bool &isDownload: Const Reference, if download or updating.
|
||||
const bool &isUDB: Const Reference, if Universal-DB download or not.
|
||||
*/
|
||||
bool DownloadUniStore(const std::string &URL, const int ¤tRev, std::string &fl, const bool &isDownload, const bool &isUDB) {
|
||||
if (isUDB) Msg::DisplayMsg(Lang::get("DOWNLOADING_UNIVERSAL_DB"));
|
||||
else {
|
||||
if (currentRev > -1) Msg::DisplayMsg(Lang::get("CHECK_UNISTORE_UPDATES"));
|
||||
else Msg::DisplayMsg((isDownload ? Lang::get("DOWNLOADING_UNISTORE") : Lang::get("UPDATING_UNISTORE")));
|
||||
}
|
||||
|
||||
Result ret = 0;
|
||||
|
||||
void *socubuf = memalign(0x1000, 0x100000);
|
||||
if (!socubuf) return false;
|
||||
|
||||
ret = socInit((u32 *)socubuf, 0x100000);
|
||||
|
||||
if (R_FAILED(ret)) {
|
||||
free(socubuf);
|
||||
return false;
|
||||
}
|
||||
|
||||
CURL *hnd = curl_easy_init();
|
||||
|
||||
ret = setupContext(hnd, URL.c_str());
|
||||
if (ret != 0) {
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
CURLcode cres = curl_easy_perform(hnd);
|
||||
curl_easy_cleanup(hnd);
|
||||
char *newbuf = (char *)realloc(result_buf, result_written + 1);
|
||||
result_buf = newbuf;
|
||||
result_buf[result_written] = 0; // nullbyte to end it as a proper C style string.
|
||||
|
||||
if (cres != CURLE_OK) {
|
||||
printf("Error in:\ncurl\n");
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
if (nlohmann::json::accept(result_buf)) {
|
||||
nlohmann::json parsedAPI = nlohmann::json::parse(result_buf);
|
||||
|
||||
if (parsedAPI.contains("storeInfo") && parsedAPI.contains("storeContent")) {
|
||||
/* Ensure, version == 3. */
|
||||
if (parsedAPI["storeInfo"].contains("version") && parsedAPI["storeInfo"]["version"].is_number()) {
|
||||
if (parsedAPI["storeInfo"]["version"] == 3) {
|
||||
if (currentRev > -1) {
|
||||
|
||||
if (parsedAPI["storeInfo"].contains("revision") && parsedAPI["storeInfo"]["revision"].is_number()) {
|
||||
const int rev = parsedAPI["storeInfo"]["revision"];
|
||||
|
||||
if (rev > currentRev) {
|
||||
Msg::DisplayMsg(Lang::get("UPDATING_UNISTORE"));
|
||||
if (parsedAPI["storeInfo"].contains("file") && parsedAPI["storeInfo"]["file"].is_string()) {
|
||||
fl = parsedAPI["storeInfo"]["file"];
|
||||
|
||||
/* Make sure it's not "/", otherwise it breaks. */
|
||||
if (!(fl.find("/") != std::string::npos)) {
|
||||
|
||||
FILE *out = fopen((std::string(_STORE_PATH) + fl).c_str(), "w");
|
||||
fwrite(result_buf, sizeof(char), result_written, out);
|
||||
fclose(out);
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return true;
|
||||
|
||||
} else {
|
||||
Msg::waitMsg(Lang::get("FILE_SLASH"));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
} else {
|
||||
if (parsedAPI["storeInfo"].contains("file") && parsedAPI["storeInfo"]["file"].is_string()) {
|
||||
fl = parsedAPI["storeInfo"]["file"];
|
||||
|
||||
/* Make sure it's not "/", otherwise it breaks. */
|
||||
if (!(fl.find("/") != std::string::npos)) {
|
||||
|
||||
FILE *out = fopen((std::string(_STORE_PATH) + fl).c_str(), "w");
|
||||
fwrite(result_buf, sizeof(char), result_written, out);
|
||||
fclose(out);
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return true;
|
||||
|
||||
} else {
|
||||
Msg::waitMsg(Lang::get("FILE_SLASH"));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
} else if (parsedAPI["storeInfo"]["version"] < 3) {
|
||||
Msg::waitMsg(Lang::get("UNISTORE_TOO_OLD"));
|
||||
|
||||
} else if (parsedAPI["storeInfo"]["version"] > 3) {
|
||||
Msg::waitMsg(Lang::get("UNISTORE_TOO_NEW"));
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
} else {
|
||||
Msg::waitMsg(Lang::get("UNISTORE_INVALID_ERROR"));
|
||||
}
|
||||
}
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
/*
|
||||
Download a SpriteSheet.
|
||||
|
||||
const std::string &URL: Const Reference to the SpriteSheet URL.
|
||||
const std::string &file: Const Reference to the filepath.
|
||||
*/
|
||||
bool DownloadSpriteSheet(const std::string &URL, const std::string &file) {
|
||||
if (file.find("/") != std::string::npos) return false;
|
||||
Result ret = 0;
|
||||
|
||||
void *socubuf = memalign(0x1000, 0x100000);
|
||||
if (!socubuf) return false;
|
||||
|
||||
ret = socInit((u32 *)socubuf, 0x100000);
|
||||
|
||||
if (R_FAILED(ret)) {
|
||||
free(socubuf);
|
||||
return false;
|
||||
}
|
||||
|
||||
CURL *hnd = curl_easy_init();
|
||||
|
||||
ret = setupContext(hnd, URL.c_str());
|
||||
if (ret != 0) {
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
CURLcode cres = curl_easy_perform(hnd);
|
||||
curl_easy_cleanup(hnd);
|
||||
char *newbuf = (char *)realloc(result_buf, result_written + 1);
|
||||
result_buf = newbuf;
|
||||
result_buf[result_written] = 0; // nullbyte to end it as a proper C style string.
|
||||
|
||||
if (cres != CURLE_OK) {
|
||||
printf("Error in:\ncurl\n");
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
C2D_SpriteSheet sheet = C2D_SpriteSheetLoadFromMem(result_buf, result_written);
|
||||
|
||||
if (sheet) {
|
||||
if (C2D_SpriteSheetCount(sheet) > 0) {
|
||||
FILE *out = fopen((std::string(_STORE_PATH) + file).c_str(), "w");
|
||||
fwrite(result_buf, sizeof(char), result_written, out);
|
||||
fclose(out);
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
C2D_SpriteSheetFree(sheet);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
/*
|
||||
Checks for U-U updates.
|
||||
*/
|
||||
bool IsUUUpdateAvailable() {
|
||||
if (!checkWifiStatus()) return false;
|
||||
|
||||
Msg::DisplayMsg(Lang::get("CHECK_UU_UPDATES"));
|
||||
Result ret = 0;
|
||||
|
||||
void *socubuf = memalign(0x1000, 0x100000);
|
||||
if (!socubuf) return false;
|
||||
|
||||
ret = socInit((u32 *)socubuf, 0x100000);
|
||||
|
||||
if (R_FAILED(ret)) {
|
||||
free(socubuf);
|
||||
return false;
|
||||
}
|
||||
|
||||
CURL *hnd = curl_easy_init();
|
||||
|
||||
ret = setupContext(hnd, "https://api.github.com/repos/Universal-Team/Universal-Updater/releases/latest");
|
||||
if (ret != 0) {
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
CURLcode cres = curl_easy_perform(hnd);
|
||||
curl_easy_cleanup(hnd);
|
||||
char *newbuf = (char *)realloc(result_buf, result_written + 1);
|
||||
result_buf = newbuf;
|
||||
result_buf[result_written] = 0; // nullbyte to end it as a proper C style string.
|
||||
|
||||
if (cres != CURLE_OK) {
|
||||
printf("Error in:\ncurl\n");
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
return false;
|
||||
}
|
||||
|
||||
if (nlohmann::json::accept(result_buf)) {
|
||||
nlohmann::json parsedAPI = nlohmann::json::parse(result_buf);
|
||||
|
||||
if (parsedAPI.contains("tag_name") && parsedAPI["tag_name"].is_string()) {
|
||||
const std::string tag = parsedAPI["tag_name"];
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return strcasecmp(StringUtils::lower_case(tag).c_str(), StringUtils::lower_case(C_V).c_str()) > 0;
|
||||
}
|
||||
}
|
||||
|
||||
socExit();
|
||||
free(result_buf);
|
||||
free(socubuf);
|
||||
result_buf = nullptr;
|
||||
result_sz = 0;
|
||||
result_written = 0;
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
extern bool is3DSX, exiting;
|
||||
extern std::string _3dsxPath;
|
||||
|
||||
/*
|
||||
Execute U-U update action.
|
||||
*/
|
||||
void UpdateAction() {
|
||||
if (ScriptUtils::downloadRelease("Universal-Team/Universal-Updater", (is3DSX ? "Universal-Updater.3dsx" : "Universal-Updater.cia"),
|
||||
(is3DSX ? _3dsxPath : "sdmc:/Universal-Updater.cia"),
|
||||
false, Lang::get("DONLOADING_UNIVERSAL_UPDATER")) == 0) {
|
||||
|
||||
if (is3DSX) {
|
||||
Msg::waitMsg(Lang::get("UPDATE_DONE"));
|
||||
exiting = true;
|
||||
return;
|
||||
}
|
||||
|
||||
ScriptUtils::installFile("sdmc:/Universal-Updater.cia", false, Lang::get("INSTALL_UNIVERSAL_UPDATER"));
|
||||
ScriptUtils::removeFile("sdmc:/Universal-Updater.cia", Lang::get("DELETE_UNNEEDED_FILE"));
|
||||
Msg::waitMsg(Lang::get("UPDATE_DONE"));
|
||||
exiting = true;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user