/*
 * Copyright 2019, Andrew Lindesay <apl@lindesay.co.nz>.
 * All rights reserved. Distributed under the terms of the MIT License.
 */
 
 
#include "ServerReferenceDataUpdateProcess.h"
 
#include <stdio.h>
#include <sys/stat.h>
#include <time.h>
 
#include <AutoDeleter.h>
#include <AutoLocker.h>
#include <Catalog.h>
#include <FileIO.h>
#include <Url.h>
 
#include "ServerSettings.h"
#include "StorageUtils.h"
#include "Logger.h"
#include "DumpExportReference.h"
#include "DumpExportReferenceNaturalLanguage.h"
#include "DumpExportReferencePkgCategory.h"
#include "DumpExportReferenceUserRatingStability.h"
#include "DumpExportReferenceCountry.h"
#include "DumpExportReferenceJsonListener.h"
 
 
#undef B_TRANSLATION_CONTEXT
#define B_TRANSLATION_CONTEXT "ServerReferenceDataUpdateProcess"
 
 
ServerReferenceDataUpdateProcess::ServerReferenceDataUpdateProcess(
	Model* model,
	uint32 serverProcessOptions)
	:
	AbstractSingleFileServerProcess(serverProcessOptions),
	fModel(model)
{
}
 
 
ServerReferenceDataUpdateProcess::~ServerReferenceDataUpdateProcess()
{
}
 
 
const char*
ServerReferenceDataUpdateProcess::Name() const
{
	return "ServerReferenceDataUpdateProcess";
}
 
 
const char*
ServerReferenceDataUpdateProcess::Description() const
{
	return B_TRANSLATE("Synchronizing reference data from server");
}
 
 
BString
ServerReferenceDataUpdateProcess::UrlPathComponent()
{
	BString result;
	AutoLocker<BLocker> locker(fModel->Lock());
	result.SetToFormat("/__reference/all-%s.json.gz",
		fModel->Language().PreferredLanguage().Code());
	return result;
}
 
 
status_t
ServerReferenceDataUpdateProcess::GetLocalPath(BPath& path) const
{
	return fModel->DumpExportReferenceDataPath(path);
}
 
 
status_t
ServerReferenceDataUpdateProcess::ProcessLocalData()
{
	SingleDumpExportReferenceJsonListener* listener =
		new SingleDumpExportReferenceJsonListener();
 
	BPath localPath;
	status_t result = GetLocalPath(localPath);
 
	if (result != B_OK)
		return result;
 
	result = ParseJsonFromFileWithListener(listener, localPath);
 
	if (result != B_OK)
		return result;
 
	result = listener->ErrorStatus();
 
	if (result != B_OK)
		return result;
 
	return _ProcessData(listener->Target());
}
 
 
status_t
ServerReferenceDataUpdateProcess::_ProcessData(DumpExportReference* data)
{
	status_t result = B_OK;
	if (result == B_OK)
		result = _ProcessNaturalLanguages(data);
	if (result == B_OK)
		result = _ProcessPkgCategories(data);
	return result;
}
 
 
status_t
ServerReferenceDataUpdateProcess::_ProcessNaturalLanguages(
	DumpExportReference* data)
{
	printf("[%s] will populate %" B_PRId32 " natural languages\n",
		Name(), data->CountNaturalLanguages());
 
	LanguageList result;
 
	for (int32 i = 0; i < data->CountNaturalLanguages(); i++) {
		DumpExportReferenceNaturalLanguage* naturalLanguage =
			data->NaturalLanguagesItemAt(i);
		result.Add(LanguageRef(
			new Language(
				*(naturalLanguage->Code()),
				*(naturalLanguage->Name()),
				naturalLanguage->IsPopular()
			),
			true));
	}
 
	{
		AutoLocker<BLocker> locker(fModel->Lock());
		fModel->Language().AddSupportedLanguages(result);
	}
 
	printf("[%s] did add %" B_PRId32 " supported languages\n",
		Name(), result.CountItems());
 
	return B_OK;
}
 
 
status_t
ServerReferenceDataUpdateProcess::_ProcessPkgCategories(
	DumpExportReference* data)
{
	printf("[%s] will populate %" B_PRId32 " pkg categories\n",
		Name(), data->CountPkgCategories());
 
	CategoryList result;
 
	for (int32 i = 0; i < data->CountPkgCategories(); i++) {
		DumpExportReferencePkgCategory* pkgCategory =
			data->PkgCategoriesItemAt(i);
		result.Add(CategoryRef(
			new PackageCategory(
				*(pkgCategory->Code()),
				*(pkgCategory->Name())
			),
			true));
	}
 
	{
		AutoLocker<BLocker> locker(fModel->Lock());
		fModel->AddCategories(result);
	}
 
	return B_OK;
}
 
 
status_t
ServerReferenceDataUpdateProcess::GetStandardMetaDataPath(BPath& path) const
{
	return GetLocalPath(path);
}
 
 
void
ServerReferenceDataUpdateProcess::GetStandardMetaDataJsonPath(
	BString& jsonPath) const
{
	jsonPath.SetTo("$.info");
}