blakeridgway/supercell-wx
1
0
Fork 0
mirror of https://github.com/ciphervance/supercell-wx.git synced 2025-10-30 18:40:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Load archived warnings when making a timeline selection

Browse source
This commit is contained in:
Dan Paulat 2025-04-05 20:48:36 -05:00
parent e4fc13aa92
commit cc54e4d834
3 changed files with 57 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

55
scwx-qt/source/scwx/qt/manager/text_event_manager.cpp
View file

@ -2,6 +2,7 @@
#include <scwx/qt/main/application.hpp>
#include <scwx/qt/settings/general_settings.hpp>
#include <scwx/awips/text_product_file.hpp>
#include <scwx/provider/iem_api_provider.hpp>
#include <scwx/provider/warnings_provider.hpp>
#include <scwx/util/logger.hpp>
@ -27,6 +28,9 @@ static constexpr std::chrono::hours kInitialLoadHistoryDuration_ =
static constexpr std::chrono::hours kDefaultLoadHistoryDuration_ =
std::chrono::hours {1};
static const std::array<std::string, 5> kPils_ = {
"TOR", "SVR", "SVS", "FFW", "FFS"};
class TextEventManager::Impl
{
public:
@ -82,10 +86,17 @@ public:
void
HandleMessage(const std::shared_ptr<awips::TextProductMessage>& message);
void LoadArchive(std::chrono::sys_days date, const std::string& pil);
void LoadArchives(std::chrono::sys_days date);
void RefreshAsync();
void Refresh();
boost::asio::thread_pool threadPool_ {1u};
// Thread pool sized for:
// - Live Refresh (1x)
// - Archive Loading (15x)
// - 3 day window (3x)
// - TOR, SVR, SVS, FFW, FFS (5x)
boost::asio::thread_pool threadPool_ {16u};
TextEventManager* self_;
@ -98,6 +109,8 @@ public:
textEventMap_;
std::shared_mutex textEventMutex_;
std::unique_ptr<provider::IemApiProvider> iemApiProvider_ {
std::make_unique<provider::IemApiProvider>()};
std::shared_ptr<provider::WarningsProvider> warningsProvider_ {nullptr};
std::chrono::hours loadHistoryDuration_ {kInitialLoadHistoryDuration_};
std::chrono::sys_time<std::chrono::hours> prevLoadTime_ {};
@ -171,6 +184,20 @@ void TextEventManager::LoadFile(const std::string& filename)
});
}
void TextEventManager::SelectTime(
std::chrono::system_clock::time_point dateTime)
{
const auto today = std::chrono::floor<std::chrono::days>(dateTime);
const auto yesterday = today - std::chrono::days {1};
const auto tomorrow = today + std::chrono::days {1};
const auto dates = {yesterday, today, tomorrow};
for (auto& date : dates)
{
p->LoadArchives(date);
}
}
void TextEventManager::Impl::HandleMessage(
const std::shared_ptr<awips::TextProductMessage>& message)
{
@ -249,6 +276,32 @@ void TextEventManager::Impl::HandleMessage(
}
}
void TextEventManager::Impl::LoadArchive(std::chrono::sys_days date,
const std::string& pil)
{
const auto& productIds = iemApiProvider_->ListTextProducts(date, {}, pil);
const auto& products = iemApiProvider_->LoadTextProducts(productIds);
for (auto& product : products)
{
const auto& messages = product->messages();
for (auto& message : messages)
{
HandleMessage(message);
}
}
}
void TextEventManager::Impl::LoadArchives(std::chrono::sys_days date)
{
for (auto& pil : kPils_)
{
boost::asio::post(threadPool_,
[this, date, &pil]() { LoadArchive(date, pil); });
}
}
void TextEventManager::Impl::RefreshAsync()
{
boost::asio::post(threadPool_,

2
scwx-qt/source/scwx/qt/manager/text_event_manager.hpp
View file

@ -3,6 +3,7 @@
#include <scwx/awips/text_product_message.hpp>
#include <scwx/qt/types/text_event_key.hpp>
#include <chrono>
#include <memory>
#include <string>
@ -29,6 +30,7 @@ public:
message_list(const types::TextEventKey& key) const;
void LoadFile(const std::string& filename);
void SelectTime(std::chrono::system_clock::time_point dateTime);
static std::shared_ptr<TextEventManager> Instance();