Example validation proposal

src/CMakeLists.txt

@@ -11,6 +11,7 @@ target_sources (quicr PRIVATE
     ctrl_message_types.cpp
     ${ctrl_messages_SOURCE}
     messages.cpp
+    moqt_validate.cpp
     publish_fetch_handler.cpp
     publish_track_handler.cpp
     fetch_track_handler.cpp

src/moqt_validate.cpp

@@ -0,0 +1,152 @@
+#include <quicr/detail/messages.h>
+
+namespace quicr::messages {
+    bool SubscribeUpdate::Validate() const
+    {
+        return true;
+    }
+
+    bool Subscribe::Validate() const
+    {
+        return true;
+    }
+
+    bool SubscribeOk::Validate() const
+    {
+        return true;
+    }
+
+    bool SubscribeError::Validate() const
+    {
+        return true;
+    }
+
+    bool Announce::Validate() const
+    {
+        return true;
+    }
+
+    bool AnnounceOk::Validate() const
+    {
+        return true;
+    }
+
+    bool AnnounceError::Validate() const
+    {
+        return true;
+    }
+
+    bool Unannounce::Validate() const
+    {
+        return true;
+    }
+
+    bool Unsubscribe::Validate() const
+    {
+        return true;
+    }
+
+    bool SubscribeDone::Validate() const
+    {
+        return true;
+    }
+
+    bool AnnounceCancel::Validate() const
+    {
+        return true;
+    }
+
+    bool TrackStatusRequest::Validate() const
+    {
+        return true;
+    }
+
+    bool TrackStatus::Validate() const
+    {
+        return true;
+    }
+
+    bool Goaway::Validate() const
+    {
+        return true;
+    }
+
+    bool SubscribeAnnounces::Validate() const
+    {
+        return true;
+    }
+
+    bool SubscribeAnnouncesOk::Validate() const
+    {
+        return true;
+    }
+
+    bool SubscribeAnnouncesError::Validate() const
+    {
+        return true;
+    }
+
+    bool UnsubscribeAnnounces::Validate() const
+    {
+        return true;
+    }
+
+    bool MaxRequestId::Validate() const
+    {
+        return true;
+    }
+
+    bool Fetch::Validate() const
+    {
+        return true;
+    }
+    bool FetchCancel::Validate() const
+    {
+        return true;
+    }
+
+    bool FetchOk::Validate() const
+    {
+        return true;
+    }
+
+    bool FetchError::Validate() const
+    {
+        return true;
+    }
+
+    bool RequestsBlocked::Validate() const
+    {
+        return true;
+    }
+
+    bool Publish::Validate() const
+    {
+        return true;
+    }
+
+    bool PublishOk::Validate() const
+    {
+        return true;
+    }
+
+    bool PublishError::Validate() const
+    {
+        return true;
+    }
+
+    bool ClientSetup::Validate() const
+    {
+        return true;
+    }
+
+    bool ServerSetup::Validate() const
+    {
+        return true;
+    }
+
+    bool NewGroupRequest::Validate() const
+    {
+        return true;
+    }
+}

tools/draft_parser/moqt_parser/templates/cpp/MessageSpec_Header_Structs_tmpl.jinja2

@@ -63,6 +63,8 @@
         {% endif %}
 
     public:
+        virtual bool Validate() const;
+
         {% for field in message.fields %}
             {% if field.spec_name not in field_discards %}
                 {% if field.is_optional %}

tools/draft_parser/moqt_parser/templates/cpp/MessageSpec_Source_Structs_tmple.jinja2

@@ -44,6 +44,9 @@
                 {% endif %}
             {% endif %}
         {% endfor %}
+        if (!msg.Validate()) {
+            throw ProtocolViolationException("Invalid message");
+        }
         return buffer;
     }
 
@@ -52,6 +55,9 @@
      */
     Bytes& operator<<(Bytes& buffer, const {{message.name}}& msg)
     {
+        if (!msg.Validate()) {
+            throw std::invalid_argument("Invalid message");
+        }
         Bytes payload;
         // fill out payload
         {% for field in message.fields %}