-
Notifications
You must be signed in to change notification settings - Fork 2
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Retain IEEE 1609.2 Security Headers #65
Conversation
…ines merged. Currently only support BSM for both
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/coder/stream/LogFileToAsn1CodecPublisher.java
Show resolved
Hide resolved
jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/coder/stream/LogFileToAsn1CodecPublisher.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looking good & the unit tests pass now, just a few comments:
- The ODE Data Flow Overview diagram appears to have an inaccuracy.
- The changes to the data flow still need to be reflected in the corresponding data flow explanations in the relevant README file.
Note: I've yet to run the solution and send data through with these changes.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good!
jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/coder/stream/LogFileToAsn1CodecPublisher.java
Show resolved
Hide resolved
jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/importer/parser/PayloadParser.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good. Locally tested and works for all Commsignia log files.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good, just the one question!
...cs/src/main/java/us/dot/its/jpo/ode/services/asn1/message/AbstractAsn1DecodeMessageJSON.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm!
PR Details
Description
Includes updates to both the UDP endpoints and the log ingest endpoint to ensure ASN.1 encoded messages are recorded in Kafka with signed IEEE 1609.2 security headers on them (when present).
The log ingestion no longer deposits J2735 message types directly to the topic.Asn1DecoderInput topic, instead routes the messages depending upon their message type to the corresponding topic.OdeRawEncodedXJson topic.
The UDP endpoints now build out proper OdeData objects before depositing ASN.1 messages to their corresponding topic.OdeRawEncodedXJson topic. This is to ensure all data within the RawEncoded topics conform to the same message structure.
Everything downstream from the RawEncoded topics remain unaffected by these changes. (topic.Asn1DecoderInput and beyond)
Related Issue
N/A
Motivation and Context
How Has This Been Tested?
Types of changes
Checklist:
ODE Contributing Guide