PoC: Telemetry for Data.read

distribution/lib/Standard/Base/0.0.0-dev/src/Logging.enso

@@ -1,10 +1,16 @@
 import project.Any.Any
+import project.Data.Dictionary.Dictionary
+import project.Data.Json.JS_Object
 import project.Data.Text.Text
 import project.Data.Vector.Vector
 import project.Data.Numbers.Integer
+import project.Errors.Illegal_Argument
 import project.Meta
 import project.Nothing.Nothing
+import project.Panic.Panic
 
+polyglot java import org.enso.base.enso_cloud.telemetry.TelemetryLog
+polyglot java import org.enso.base.enso_cloud.telemetry.TelemetryLog.TelemetryLogError
 polyglot java import org.slf4j.LoggerFactory
 
 ## PRIVATE
@@ -83,6 +89,29 @@ type Progress
     ## Simple name of the progress
     to_text self = "Progress"
 
+
+type Telemetry
+    logger_root = "org.enso.telemetry"
+
+    log self name:Text message:Text (metadata:Dictionary Text Any = Dictionary.empty) =
+        logger_name = Telemetry.logger_root + "." + name
+        metadata_js = JS_Object.from_pairs <| metadata.to_vector
+        Standard.Base.IO.println <| "Telemetry.log: name=" + name + ", message=" + message + ", metadata_js=" + metadata_js.to_text
+        Illegal_Argument.handle_java_exception <|
+            Telemetry_Log_Error.handle_java_exception <|
+                TelemetryLog.logAsync logger_name message metadata_js
+
+
+type Telemetry_Log_Error
+    private Error message:Text cause:Any
+
+    private handle_java_exception =
+        on_error caught_panic =
+            cause = caught_panic.payload
+            Panic.throw (Telemetry_Log_Error.Error cause.getMessage cause)
+        Panic.catch TelemetryLogError handler=on_error
+
+
 ## PRIVATE
 type Log_Level
     ## Finest (Trace) level log message.

std-bits/base/src/main/java/org/enso/base/enso_cloud/telemetry/TelemetryLog.java

@@ -0,0 +1,19 @@
+package org.enso.base.enso_cloud.telemetry;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.enso.base.enso_cloud.logging.LogApiAccess;
+
+public final class TelemetryLog {
+  private TelemetryLog() {}
+
+  public static void logAsync(String loggerName, String message, ObjectNode metadata) {
+    var event = TelemetryLogMessage.create(loggerName, message, metadata);
+    LogApiAccess.INSTANCE.logWithoutConfirmation(event);
+  }
+
+  public static class TelemetryLogError extends RuntimeException {
+    public TelemetryLogError(String message, Throwable cause) {
+      super(message, cause);
+    }
+  }
+}

std-bits/base/src/main/java/org/enso/base/enso_cloud/telemetry/TelemetryLogMessage.java

@@ -0,0 +1,27 @@
+package org.enso.base.enso_cloud.telemetry;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.fasterxml.jackson.databind.node.TextNode;
+import java.util.Objects;
+import org.enso.base.enso_cloud.logging.LogMessage;
+
+public final class TelemetryLogMessage extends LogMessage {
+
+  private TelemetryLogMessage(String message, ObjectNode extraMeta) {
+    super(message, extraMeta);
+  }
+
+  public static TelemetryLogMessage create(String loggerName, String message, ObjectNode metadata) {
+    Objects.requireNonNull(loggerName);
+    Objects.requireNonNull(message);
+    Objects.requireNonNull(metadata);
+    var copy = metadata.deepCopy();
+    copy.set("loggerName", TextNode.valueOf(loggerName));
+    return new TelemetryLogMessage(message, copy);
+  }
+
+  @Override
+  protected String kind() {
+    return "Telemetry";
+  }
+}