@@ -201,6 +201,7 @@ impl ErrorsIntakeConfig {
201
201
} ;
202
202
203
203
if let Ok ( parsed_url) = parse_uri ( & url) {
204
+ panic ! ( "parsed_url: {} api_key: {:?}" , parsed_url, api_key) ;
204
205
let _res = this. set_endpoint ( Endpoint {
205
206
url : parsed_url,
206
207
api_key,
@@ -655,4 +656,30 @@ mod tests {
655
656
std:: env:: remove_var ( "DD_TRACE_AGENT_URL" ) ;
656
657
std:: env:: remove_var ( "DD_API_KEY" ) ;
657
658
}
659
+
660
+ #[ test]
661
+ fn test_errors_intake_config_direct_submission ( ) {
662
+ let _lock = ENV_TEST_LOCK . lock ( ) . unwrap ( ) ;
663
+
664
+ std:: env:: remove_var ( "DD_TRACE_AGENT_URL" ) ;
665
+ std:: env:: remove_var ( "DD_AGENT_HOST" ) ;
666
+ std:: env:: remove_var ( "DD_TRACE_AGENT_PORT" ) ;
667
+ std:: env:: remove_var ( "DD_API_KEY" ) ;
668
+ std:: env:: remove_var ( "_DD_DIRECT_SUBMISSION_ENABLED" ) ;
669
+ std:: env:: remove_var ( "DD_SITE" ) ;
670
+
671
+ std:: env:: set_var ( "DD_API_KEY" , "test-key" ) ;
672
+ std:: env:: set_var ( "_DD_DIRECT_SUBMISSION_ENABLED" , "true" ) ;
673
+
674
+ let cfg = ErrorsIntakeConfig :: from_env ( ) ;
675
+ let endpoint = cfg. endpoint ( ) . unwrap ( ) ;
676
+
677
+ assert_eq ! (
678
+ endpoint. url. host( ) ,
679
+ Some ( "event-platform-intake.datad0g.com" )
680
+ ) ;
681
+ assert_eq ! ( endpoint. url. scheme_str( ) , Some ( "https" ) ) ;
682
+ assert ! ( endpoint. api_key. is_some( ) ) ;
683
+ assert_eq ! ( endpoint. url. path( ) , DIRECT_ERRORS_INTAKE_URL_PATH )
684
+ }
658
685
}
0 commit comments