Play-/Source/ui_shared/BootablesProcesses.cpp

#include <algorithm>
#include "BootablesProcesses.h"
#include "BootablesDbClient.h"
#include "LocalGamesDbClient.h"
#include "TheGamesDbClient.h"
#include "DiskUtils.h"
#include "string_format.h"

//Jobs
// Scan for new games (from input directory)
// Remove games that might not be available anymore
// Extract game ids from disk images
// Pull disc cover URLs and titles from GamesDb/TheGamesDb

bool IsBootableExecutablePath(const boost::filesystem::path& filePath)
{
	auto extension = filePath.extension().string();
	std::transform(extension.begin(), extension.end(), extension.begin(), ::tolower);
	return (extension == ".elf");
}

bool IsBootableDiscImagePath(const boost::filesystem::path& filePath)
{
	auto extension = filePath.extension().string();
	std::transform(extension.begin(), extension.end(), extension.begin(), ::tolower);
	return
		(extension == ".iso") ||
		(extension == ".isz") ||
		(extension == ".cso") ||
		(extension == ".bin");
}

void ScanBootables(const boost::filesystem::path& parentPath)
{
	for(auto pathIterator = boost::filesystem::directory_iterator(parentPath);
		pathIterator != boost::filesystem::directory_iterator(); pathIterator++)
	{
		auto& path = pathIterator->path();
		if(boost::filesystem::is_directory(path))
		{
			ScanBootables(path);
			continue;
		}
		if(
		   !IsBootableExecutablePath(path) &&
		   !IsBootableDiscImagePath(path))
		{
			continue;
		}
		BootablesDb::CClient::GetInstance().RegisterBootable(path);
	}
}

void PurgeInexistingFiles()
{
	auto bootables = BootablesDb::CClient::GetInstance().GetBootables();
	for(const auto& bootable : bootables)
	{
		if(boost::filesystem::exists(bootable.path)) continue;
		BootablesDb::CClient::GetInstance().UnregisterBootable(bootable.path);
	}
}

void ExtractDiscIds()
{
	auto bootables = BootablesDb::CClient::GetInstance().GetBootables();
	for(const auto& bootable : bootables)
	{
		std::string discId;
		if(!DiskUtils::TryGetDiskId(bootable.path, &discId)) continue;
		BootablesDb::CClient::GetInstance().SetDiscId(bootable.path, discId.c_str());
	}
}

void FetchGameTitles()
{
	auto bootables = BootablesDb::CClient::GetInstance().GetBootables();
	for(const auto& bootable : bootables)
	{
		if(bootable.discId.empty()) continue;
		try
		{
			auto game = LocalGamesDb::CClient::GetInstance().GetGame(bootable.discId.c_str());
			BootablesDb::CClient::GetInstance().SetTitle(bootable.path, game.title.c_str());
		}
		catch(...)
		{
			//Log or something?
		}
	}
}

uint32 GetTheGamesDbId(const char* discId)
{
	//Get the TheGamesDb ID from the local games db
	auto localGame = LocalGamesDb::CClient::GetInstance().GetGame(discId);
	if(localGame.theGamesDbId != 0)
	{
		return localGame.theGamesDbId;
	}
	
	//If no ID found in database, then, try a fuzzy lookup using the game name specified in the
	//local database
	auto gamesList = TheGamesDb::CClient::GetInstance().GetGamesList("sony playstation 2", localGame.title);
	if(gamesList.empty())
	{
		throw std::runtime_error("Game not found.");
	}
	else
	{
		//This is the one (might be wrong due to fuzzy search)
		auto gamesListItem = gamesList[0];
		return gamesListItem.id;
	}
}

std::string GetCoverUrl(const char* discId)
{
	try
	{
		auto theGamesDbId = GetTheGamesDbId(discId);
		auto theGamesDbGame = TheGamesDb::CClient::GetInstance().GetGame(theGamesDbId);
		auto coverUrl = string_format("%s/%s", theGamesDbGame.baseImgUrl.c_str(), theGamesDbGame.boxArtUrl.c_str());
		return coverUrl;
	}
	catch(const std::exception& exception)
	{
		return "";
	}
}

void FetchCoverUrls()
{
	auto bootables = BootablesDb::CClient::GetInstance().GetBootables();
	for(const auto& bootable : bootables)
	{
		//Don't fetch if bootable already has a coverUrl
		if(!bootable.coverUrl.empty()) continue;
		
		if(bootable.discId.empty()) continue;
		auto coverUrl = GetCoverUrl(bootable.discId.c_str());
		BootablesDb::CClient::GetInstance().SetCoverUrl(bootable.path, coverUrl.c_str());
	}
}