diff options
-rw-r--r-- | gentoobrowse-api/service/maintenanceBugs.cpp | 14 | ||||
-rw-r--r-- | gentoobrowse-api/service/maintenanceGitOperations.cpp | 24 | ||||
-rw-r--r-- | gentoobrowse-api/service/utils/git.cpp | 19 |
3 files changed, 33 insertions, 24 deletions
diff --git a/gentoobrowse-api/service/maintenanceBugs.cpp b/gentoobrowse-api/service/maintenanceBugs.cpp index 04a595e..73b5b63 100644 --- a/gentoobrowse-api/service/maintenanceBugs.cpp +++ b/gentoobrowse-api/service/maintenanceBugs.cpp @@ -14,6 +14,7 @@ #include <lexer-regex.h> #include <utils/dbUtils.h> #include <compileTimeFormatter.h> +#include <logger.h> namespace Gentoo { namespace Service { @@ -68,16 +69,17 @@ namespace Gentoo { Glib::ustring summary; }; - AdHocFormatter(UpdatingBugs, "Refreshing bug list from %?\n"); - AdHocFormatter(UpdatingBugUrl, " ... %?\n"); - AdHocFormatter(UpdatingBugsResult, "Refreshed bug list: %? added, %? updated, %? removed\n"); + AdHocFormatter(UpdatingBugs, "Refreshing bug list from %?"); + AdHocFormatter(UpdatingBugUrl, " ... %?"); + AdHocFormatter(UpdatingBugsResult, "Refreshed bug list: %? added, %? updated, %? removed"); void Maintenance::refreshBugs(const Ice::Current & c) { + auto log = LOGMANAGER()->getLogger(__FUNCTION__); std::filesystem::path root = properties(c)->getPropertyWithDefault( "GentooBrowseAPI.BugRoot", "https://bugs.gentoo.org/data/cached"); - UpdatingBugs::write(std::cerr, root); + log->messagectf<UpdatingBugs>(IceTray::Logging::LogLevel::INFO, root); auto dbc = db->get(); DB::TransactionScope tx(*dbc.get()); DB::TablePatch tp; @@ -91,14 +93,14 @@ namespace Gentoo { "buglist-CONFIRMED.html", "buglist-UNCONFIRMED.html", "buglist-IN_PROGRESS.html" }) { - UpdatingBugUrl::write(std::cerr, bl); + log->messagectf<UpdatingBugUrl>(IceTray::Logging::LogLevel::DEBUG, bl); AdHoc::Net::CurlStreamSource css((root / bl).string()); css.setopt(CURLOPT_ENCODING, "deflate, gzip"); AdHoc::Net::CurlStream cs(css); blp.parse_stream(cs); } auto result = dbc->patchTable(&tp); - UpdatingBugsResult::write(std::cerr, result.inserts, result.updates, result.deletes); + log->messagectf<UpdatingBugsResult>(IceTray::Logging::LogLevel::INFO, result.inserts, result.updates, result.deletes); Utils::Database::drop(dbc.get(), tp.src); } } diff --git a/gentoobrowse-api/service/maintenanceGitOperations.cpp b/gentoobrowse-api/service/maintenanceGitOperations.cpp index 1b59e43..dae0da2 100644 --- a/gentoobrowse-api/service/maintenanceGitOperations.cpp +++ b/gentoobrowse-api/service/maintenanceGitOperations.cpp @@ -14,6 +14,7 @@ #include "converters.impl.h" #include <compileTimeFormatter.h> #include <systemd/sd-daemon.h> +#include <logger.h> namespace Gentoo { namespace Service { @@ -39,13 +40,14 @@ namespace Gentoo { return onFile(delta, fileset); } - AdHocFormatter(UpdatingChangeLog, "Updating change log for repository %? with range %?...%?\n"); - AdHocFormatter(UpdatedChangeLog, "Updated change log for repository %?, added %? new entries\n"); + AdHocFormatter(UpdatingChangeLog, "Updating change log for repository %? with range %?...%?"); + AdHocFormatter(UpdatedChangeLog, "Updated change log for repository %?, added %? new entries"); static void writeChangeLog(DB::Connection * db, int64_t repoId, git_repository * repo, const git_oid & lastCommitOid, const git_oid & headCommitOid) { - UpdatingChangeLog::write(std::cerr, repoId, lastCommitOid, headCommitOid); + auto log = LOGMANAGER()->getLogger(__FUNCTION__); + log->messagectf<UpdatingChangeLog>(IceTray::Logging::LogLevel::INFO, repoId, lastCommitOid, headCommitOid); auto cli = sql::maintenance::changeLogInsert.modify(db); cli->bindParamI(0, repoId); // Set up walker @@ -87,7 +89,7 @@ namespace Gentoo { cli->bindParamS(7, Slicer::packPqArray(fs)); count += cli->execute(); } - UpdatedChangeLog::write(std::cerr, repoId, count); + log->messagectf<UpdatedChangeLog>(IceTray::Logging::LogLevel::INFO, repoId, count); } void @@ -148,11 +150,12 @@ namespace Gentoo { return writeChangesToFileList(repository.repoid, repo.get(), lastCommitOid, headCommitOid); } - AdHocFormatter(FindingChanges, "Finding changes for repository %? with range %?...%?\n"); + AdHocFormatter(FindingChanges, "Finding changes for repository %? with range %?...%?"); ChangeSet writeChangesToFileList(int64_t repoId, git_repository * repo, const git_oid & lastCommitOid, const git_oid & headCommitOid) { - FindingChanges::write(std::cerr, repoId, lastCommitOid, headCommitOid); + auto log = LOGMANAGER()->getLogger(__FUNCTION__); + log->messagectf<FindingChanges>(IceTray::Logging::LogLevel::DEBUG, repoId, lastCommitOid, headCommitOid); auto lastCommit = gitSafeGet(git_commit_lookup, git_commit_free, repo, &lastCommitOid); auto headCommit = gitSafeGet(git_commit_lookup, git_commit_free, repo, &headCommitOid); auto lastTree = gitSafeGet(git_commit_tree, git_tree_free, lastCommit.get()); @@ -178,12 +181,13 @@ namespace Gentoo { sd_notifyf(0, "STATUS=Last update %s", ctime(&now)); } - AdHocFormatter(UpdatingFileContent, "Updating file content\n"); - AdHocFormatter(UpdatedFileContent, "Updated file content\n"); + AdHocFormatter(UpdatingFileContent, "Updating file content"); + AdHocFormatter(UpdatedFileContent, "Updated file content"); void Maintenance::applyFileChanges(DB::Connection * dbc, const std::filesystem::path & repoRoot, const Repository & repo, ChangeSet & changes) const { - UpdatingFileContent::write(std::cerr); + auto log = LOGMANAGER()->getLogger(__FUNCTION__); + log->messagectf<UpdatingFileContent>(IceTray::Logging::LogLevel::DEBUG); // Map of phase, to order, to processor std::map<unsigned char, std::multimap<unsigned char, FileProcessorPtr>> fps; for (const auto & fpf : AdHoc::PluginManager::getDefault()->getAll<FileProcessorFactory>()) { @@ -228,7 +232,7 @@ namespace Gentoo { processor.second->tidy(dbc); } } - UpdatedFileContent::write(std::cerr); + log->messagectf<UpdatedFileContent>(IceTray::Logging::LogLevel::DEBUG); } } diff --git a/gentoobrowse-api/service/utils/git.cpp b/gentoobrowse-api/service/utils/git.cpp index 9a1cae2..450bfec 100644 --- a/gentoobrowse-api/service/utils/git.cpp +++ b/gentoobrowse-api/service/utils/git.cpp @@ -2,6 +2,7 @@ #include <maintenance.h> #include <execinfo.h> #include <compileTimeFormatter.h> +#include <logger.h> namespace Gentoo { namespace Utils { @@ -46,11 +47,12 @@ namespace Gentoo { return gitSafeGet(git_annotated_commit_from_revspec, git_annotated_commit_free, repo, "FETCH_HEAD"); } - AdHocFormatter(FastForward, "Performing fast-forward %? -> %?\n"); - AdHocFormatter(CheckOut, "Checking out %?\n"); + AdHocFormatter(FastForward, "Performing fast-forward %? -> %?"); + AdHocFormatter(CheckOut, "Checking out %?"); git_oid gitFastForward(git_repository * repo, const git_annotated_commit * fetch_head) { + auto log = LOGMANAGER()->getLogger(__FUNCTION__); // Test fast-forward is possible const git_annotated_commit * heads[] = { fetch_head }; git_merge_analysis_t analysis = GIT_MERGE_ANALYSIS_NONE; @@ -68,28 +70,29 @@ namespace Gentoo { // Perform fast-forward auto fetch_head_id = *git_annotated_commit_id(fetch_head); auto fetch_head_object = gitSafeGet(git_object_lookup, git_object_free, repo, &fetch_head_id, GIT_OBJ_ANY); - FastForward::write(std::cerr, *git_reference_target(head.get()), fetch_head_id); + log->messagectf<FastForward>(IceTray::Logging::LogLevel::INFO, *git_reference_target(head.get()), fetch_head_id); gitSafeGet(git_reference_set_target, git_reference_free, head.get(), &fetch_head_id, "fast-forward"); // Checkout new head - CheckOut::write(std::cerr, fetch_head_id); + log->messagectf<CheckOut>(IceTray::Logging::LogLevel::INFO, fetch_head_id); auto checkout_options = gitSafeGet(git_checkout_init_options, 0u + GIT_CHECKOUT_OPTIONS_VERSION); checkout_options.checkout_strategy = GIT_CHECKOUT_FORCE; gitSafe(git_checkout_head, repo, &checkout_options); return fetch_head_id; } - AdHocFormatter(Updating, "Updating repository in %? from %?/%?\n"); - AdHocFormatter(UpdateComplete, "Update complete to %?\n"); + AdHocFormatter(Updating, "Updating repository in %? from %?/%?"); + AdHocFormatter(UpdateComplete, "Update complete to %?"); void updateRepository(const std::string & path, const std::string & upstream, const std::string & branch) { - Updating::write(std::cerr, path, upstream, branch); + auto log = LOGMANAGER()->getLogger(__FUNCTION__); + log->messagectf<Updating>(IceTray::Logging::LogLevel::INFO, path, upstream, branch); auto repo = gitSafeGet(git_repository_open, git_repository_free, path.c_str()); auto origin = gitSafeGet(git_remote_lookup, git_remote_free, repo.get(), upstream.c_str()); auto fetchHead = gitFetch(repo.get(), origin.get(), branch.c_str()); auto oid = gitFastForward(repo.get(), fetchHead.get()); - UpdateComplete::write(std::cerr, oid); + log->messagectf<UpdateComplete>(IceTray::Logging::LogLevel::INFO, oid); } } } |