Tag environment as node vs default to sentry (#23667)

Provide as part of the log event api

GitOrigin-RevId: b57a7e3b335703c9a35d93a38d3d8aa81060ea7c

Author: nipunn1313

crates/application/src/application_function_runner/mod.rs

@@ -1082,6 +1082,7 @@ impl<RT: Runtime> ApplicationFunctionRunner<RT> {
                             unix_timestamp,
                             context.clone(),
                             vec![log_line].into(),
+                            module_version.environment,
                         )
                     },
                 )
@@ -1180,6 +1181,7 @@ impl<RT: Runtime> ApplicationFunctionRunner<RT> {
                             unix_timestamp,
                             context.clone(),
                             vec![log_line].into(),
+                            module_version.environment,
                         )
                     },
                 )

crates/application/src/function_log.rs

@@ -191,6 +191,7 @@ impl FunctionExecution {
         FunctionEventSource {
             path: udf_id,
             udf_type: self.udf_type,
+            module_environment: self.environment,
             cached,
             context: self.context.clone(),
         }
@@ -756,13 +757,15 @@ impl<RT: Runtime> FunctionExecutionLog<RT> {
         unix_timestamp: UnixTimestamp,
         context: RequestContext,
         log_lines: LogLines,
+        module_environment: ModuleEnvironment,
     ) {
         if identifier.is_system() {
             return;
         }
         let event_source = FunctionEventSource {
             path: identifier.strip().to_string(),
             udf_type: UdfType::Action,
+            module_environment,
             cached: Some(false),
             context,
         };
@@ -776,10 +779,12 @@ impl<RT: Runtime> FunctionExecutionLog<RT> {
         unix_timestamp: UnixTimestamp,
         context: RequestContext,
         log_lines: LogLines,
+        module_environment: ModuleEnvironment,
     ) {
         let event_source = FunctionEventSource {
             path: identifier.to_string(),
             udf_type: UdfType::HttpAction,
+            module_environment,
             cached: Some(false),
             context,
         };

crates/application/src/lib.rs

@@ -1094,6 +1094,8 @@ impl<RT: Runtime> Application<RT> {
                     unix_timestamp,
                     context.clone(),
                     vec![log_line].into(),
+                    // http actions are always run in Isolate
+                    ModuleEnvironment::Isolate,
                 )
             })
             .await;

crates/common/src/log_streaming.rs

@@ -8,7 +8,10 @@ use crate::{
         Runtime,
         UnixTimestamp,
     },
-    types::UdfType,
+    types::{
+        ModuleEnvironment,
+        UdfType,
+    },
 };
 
 /// Public worker for the LogManager.
@@ -99,6 +102,7 @@ impl LogEvent {
             context: RequestContext::new(None),
             path: "test".to_string(),
             udf_type: UdfType::Action,
+            module_environment: ModuleEnvironment::Isolate,
             cached: None,
         });
         Self::construct_exception(
@@ -193,6 +197,7 @@ pub struct FunctionEventSource {
     pub context: RequestContext,
     pub path: String,
     pub udf_type: UdfType,
+    pub module_environment: ModuleEnvironment,
     // Only queries can be cached, so this is only Some for queries. This is important
     // information to transmit to the client to distinguish from logs users explicitly created
     // and logs that we created for by redoing a query when its readset changes.
@@ -215,7 +220,10 @@ mod tests {
             LogTopic,
         },
         runtime::UnixTimestamp,
-        types::UdfType,
+        types::{
+            ModuleEnvironment,
+            UdfType,
+        },
     };
 
     #[test]
@@ -232,6 +240,7 @@ mod tests {
                 context: RequestContext::new(None),
                 path: "test:test".to_string(),
                 udf_type: UdfType::Query,
+                module_environment: ModuleEnvironment::Isolate,
                 cached: Some(true),
             }),
             payload,
@@ -269,6 +278,7 @@ mod tests {
                 context: RequestContext::new(None),
                 path: "test:test".to_string(),
                 udf_type: UdfType::Query,
+                module_environment: ModuleEnvironment::Isolate,
                 cached: Some(true),
             }),
             payload,

crates/common/src/types/functions.rs

@@ -194,6 +194,17 @@ impl fmt::Display for ModuleEnvironment {
     }
 }
 
+impl ModuleEnvironment {
+    pub fn as_sentry_tag(&self) -> &'static str {
+        match self {
+            // "isolate" is an internal term. Simply the default environment externally.
+            ModuleEnvironment::Isolate => "default",
+            ModuleEnvironment::Node => "node",
+            ModuleEnvironment::Invalid => "unknown",
+        }
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use proptest::prelude::*;