Look for specific impact based warning tags in text products

wxdata/source/scwx/awips/impact_based_warnings.cpp

@@ -0,0 +1,31 @@
+#include <scwx/awips/impact_based_warnings.hpp>
+#include <scwx/util/enum.hpp>
+
+#include <unordered_map>
+
+#include <boost/algorithm/string.hpp>
+
+namespace scwx
+{
+namespace awips
+{
+
+static const std::string logPrefix_ = "scwx::awips::impact_based_warnings";
+
+static const std::unordered_map<ThreatCategory, std::string>
+   threatCategoryName_ {{ThreatCategory::Base, "Base"},
+                        {ThreatCategory::Significant, "Significant"},
+                        {ThreatCategory::Considerable, "Considerable"},
+                        {ThreatCategory::Destructive, "Destructive"},
+                        {ThreatCategory::Catastrophic, "Catastrophic"},
+                        {ThreatCategory::Unknown, "?"}};
+
+SCWX_GET_ENUM(ThreatCategory, GetThreatCategory, threatCategoryName_)
+
+const std::string& GetThreatCategoryName(ThreatCategory threatCategory)
+{
+   return threatCategoryName_.at(threatCategory);
+}
+
+} // namespace awips
+} // namespace scwx

wxdata/source/scwx/awips/text_product_message.cpp

@@ -3,6 +3,7 @@
 #include <scwx/util/logger.hpp>
 #include <scwx/util/streams.hpp>
 
+#include <algorithm>
 #include <istream>
 #include <string>
 
@@ -304,6 +305,14 @@ void ParseCodedInformation(std::shared_ptr<Segment> segment,
 {
    typedef std::vector<std::string>::const_iterator StringIterator;
 
+   static constexpr std::size_t kThreatCategoryTagCount = 4;
+   static const std::array<std::string, kThreatCategoryTagCount>
+      kThreatCategoryTags {"FLASH FLOOD DAMAGE THREAT...",
+                           "SNOW SQUALL IMPACT...",
+                           "THUNDERSTORM DAMAGE THREAT...",
+                           "TORNADO DAMAGE THREAT..."};
+   std::array<std::string, kThreatCategoryTagCount>::const_iterator threatTagIt;
+
    std::vector<std::string>& productContent = segment->productContent_;
 
    StringIterator codedLocationBegin = productContent.cend();
@@ -325,8 +334,8 @@ void ParseCodedInformation(std::shared_ptr<Segment> segment,
          codedLocationEnd = it;
       }
 
-      if (codedMotionBegin == productContent.cend() &&
-          it->starts_with("TIME...MOT...LOC"))
+      else if (codedMotionBegin == productContent.cend() &&
+               it->starts_with("TIME...MOT...LOC"))
       {
          codedMotionBegin = it;
       }
@@ -338,6 +347,37 @@ void ParseCodedInformation(std::shared_ptr<Segment> segment,
       {
          codedMotionEnd = it;
       }
+
+      else if (!segment->observed_ &&
+               it->find("...OBSERVED") != std::string::npos)
+      {
+         segment->observed_ = true;
+      }
+
+      else if (!segment->tornadoPossible_ && *it == "TORNADO...POSSIBLE")
+      {
+         segment->tornadoPossible_ = true;
+      }
+
+      else if (segment->threatCategory_ == ThreatCategory::Base &&
+               (threatTagIt = std::find_if(kThreatCategoryTags.cbegin(),
+                                           kThreatCategoryTags.cend(),
+                                           [&it](const std::string& tag) {
+                                              return it->starts_with(tag);
+                                           })) != kThreatCategoryTags.cend() &&
+               it->length() > threatTagIt->length())
+      {
+         const std::string threatCategoryName =
+            it->substr(threatTagIt->length());
+
+         ThreatCategory threatCategory = GetThreatCategory(threatCategoryName);
+         if (threatCategory == ThreatCategory::Unknown)
+         {
+            threatCategory = ThreatCategory::Base;
+         }
+
+         segment->threatCategory_ = threatCategory;
+      }
    }
 
    if (codedLocationBegin != productContent.cend())