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

Read blocks from level 3 file

Browse source
This commit is contained in:
Dan Paulat 2021-12-28 15:49:46 -06:00
parent 6544b9df74
commit 95a3bb7cb7
1 changed files with 64 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

67
wxdata/source/scwx/wsr88d/level3_file.cpp
View file

@ -1,6 +1,7 @@
#include <scwx/wsr88d/level3_file.hpp> #include <scwx/wsr88d/level3_file.hpp>
#include <scwx/wsr88d/rpg/level3_message_header.hpp> #include <scwx/wsr88d/rpg/level3_message_header.hpp>
#include <scwx/wsr88d/rpg/product_description_block.hpp> #include <scwx/wsr88d/rpg/product_description_block.hpp>
#include <scwx/wsr88d/rpg/product_symbology_block.hpp>
#include <scwx/wsr88d/rpg/wmo_header.hpp> #include <scwx/wsr88d/rpg/wmo_header.hpp>
#include <scwx/util/rangebuf.hpp> #include <scwx/util/rangebuf.hpp>
#include <scwx/util/time.hpp> #include <scwx/util/time.hpp>
@ -23,14 +24,23 @@ class Level3FileImpl
{ {
public: public:
explicit Level3FileImpl() : explicit Level3FileImpl() :
wmoHeader_ {}, messageHeader_ {}, description_ {} {}; wmoHeader_ {},
messageHeader_ {},
descriptionBlock_ {},
symbologyBlock_ {},
graphicBlock_ {},
tabularBlock_ {} {};
~Level3FileImpl() = default; ~Level3FileImpl() = default;
void LoadBlocks(std::istream& is); void LoadBlocks(std::istream& is);
rpg::WmoHeader wmoHeader_; rpg::WmoHeader wmoHeader_;
rpg::Level3MessageHeader messageHeader_; rpg::Level3MessageHeader messageHeader_;
rpg::ProductDescriptionBlock description_; rpg::ProductDescriptionBlock descriptionBlock_;
std::shared_ptr<rpg::ProductSymbologyBlock> symbologyBlock_;
std::shared_ptr<void> graphicBlock_;
std::shared_ptr<void> tabularBlock_;
size_t numRecords_; size_t numRecords_;
}; };
@ -87,12 +97,12 @@ bool Level3File::LoadData(std::istream& is)
BOOST_LOG_TRIVIAL(debug) BOOST_LOG_TRIVIAL(debug)
<< logPrefix_ << "Code: " << p->messageHeader_.message_code(); << logPrefix_ << "Code: " << p->messageHeader_.message_code();
dataValid = p->description_.Parse(is); dataValid = p->descriptionBlock_.Parse(is);
} }
if (dataValid) if (dataValid)
{ {
if (p->description_.IsCompressionEnabled()) if (p->descriptionBlock_.IsCompressionEnabled())
{ {
size_t messageLength = p->messageHeader_.length_of_message(); size_t messageLength = p->messageHeader_.length_of_message();
size_t prefixLength = size_t prefixLength =
@ -137,7 +147,56 @@ void Level3FileImpl::LoadBlocks(std::istream& is)
{ {
BOOST_LOG_TRIVIAL(debug) << logPrefix_ << "Loading Blocks"; BOOST_LOG_TRIVIAL(debug) << logPrefix_ << "Loading Blocks";
std::streampos offsetBasePos = is.tellg();
constexpr size_t offsetBase =
rpg::Level3MessageHeader::SIZE + rpg::ProductDescriptionBlock::SIZE;
const size_t offsetToSymbology =
descriptionBlock_.offset_to_symbology() * 2u;
const size_t offsetToGraphic = descriptionBlock_.offset_to_graphic() * 2u;
const size_t offsetToTabular = descriptionBlock_.offset_to_tabular() * 2u;
if (offsetToSymbology >= offsetBase)
{
bool symbologyValid;
symbologyBlock_ = std::make_shared<rpg::ProductSymbologyBlock>();
is.seekg(offsetToSymbology - offsetBase, std::ios_base::cur);
symbologyValid = symbologyBlock_->Parse(is);
is.seekg(offsetBasePos, std::ios_base::beg);
BOOST_LOG_TRIVIAL(debug)
<< logPrefix_ << "Product symbology block valid: " << symbologyValid;
if (!symbologyValid)
{
symbologyBlock_ = nullptr;
}
}
if (offsetToGraphic >= offsetBase)
{
// TODO // TODO
is.seekg(offsetToGraphic - offsetBase, std::ios_base::cur);
is.seekg(offsetBasePos, std::ios_base::beg);
BOOST_LOG_TRIVIAL(debug)
<< logPrefix_
<< "Graphic alphanumeric block found: " << offsetToGraphic;
}
if (offsetToTabular >= offsetBase)
{
// TODO
is.seekg(offsetToTabular - offsetBase, std::ios_base::cur);
is.seekg(offsetBasePos, std::ios_base::beg);
BOOST_LOG_TRIVIAL(debug)
<< logPrefix_
<< "Tabular alphanumeric block found: " << offsetToTabular;
}
} }
} // namespace wsr88d } // namespace wsr88d