[SNOW-3249917] JDBC removal Step 9b: Replicate OOB telemetry classes

Verbatim replication of JDBC OOB telemetry infrastructure:

- TelemetryEvent (182 lines) — telemetry event builder with
  MetricBuilder/LogBuilder. Source:
  net.snowflake.client.jdbc.telemetryOOB.TelemetryEvent
- TelemetryService (651 lines) — OOB telemetry singleton with
  deployment configuration and async upload. Source:
  net.snowflake.client.jdbc.telemetryOOB.TelemetryService
- version.properties — resource bundle for driver version string
  (used by TelemetryEvent.Builder)
- SnowflakeDriverConstants — constants from LoginInfoDTO.SF_JDBC_APP_ID
  and SnowflakeDriver.implementVersion

SFException kept from JDBC temporarily (used as parameter type in
TelemetryEvent.LogBuilder.withException).

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: sfc-gh-ggeng

src/main/java/net/snowflake/ingest/streaming/internal/fileTransferAgent/TelemetryEvent.java

@@ -0,0 +1,191 @@
+/*
+ * Replicated from snowflake-jdbc (v3.25.1)
+ * Source: https://github.com/snowflakedb/snowflake-jdbc/blob/v3.25.1/src/main/java/net/snowflake/client/jdbc/telemetryOOB/TelemetryEvent.java
+ *
+ * Permitted differences: package, UUIDUtils/SecretDetector use ingest versions
+ * (fileTransferAgent.log package), SFTimestamp/ResourceBundleManager/TelemetryService
+ * use ingest versions (same package).
+ * SFException kept from JDBC temporarily (used as parameter type).
+ * ResourceBundleManager path updated to ingest package.
+ */
+package net.snowflake.ingest.streaming.internal.fileTransferAgent;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.util.HashMap;
+import net.minidev.json.JSONArray;
+import net.minidev.json.JSONObject;
+import net.snowflake.client.core.SFException;
+import net.snowflake.ingest.streaming.internal.fileTransferAgent.log.SecretDetector;
+import net.snowflake.ingest.streaming.internal.fileTransferAgent.log.UUIDUtils;
+
+/** Telemetry Event Class */
+public class TelemetryEvent extends JSONObject {
+  private static final long serialVersionUID = 1L;
+  private static final int schemaVersion = 1;
+
+  public enum Type {
+    Metric,
+    Log
+  }
+
+  /** Build metric json object */
+  public static class MetricBuilder extends Builder<MetricBuilder> {
+
+    public MetricBuilder withException(Exception ex) {
+      this.withName("Exception:" + ex.getMessage());
+      this.withValue(1);
+      return this;
+    }
+
+    public MetricBuilder() {
+      super(MetricBuilder.class);
+    }
+
+    public MetricBuilder withValue(int value) {
+      body.put("Value", value);
+      return this;
+    }
+
+    public MetricBuilder withValue(float value) {
+      body.put("Value", value);
+      return this;
+    }
+
+    public TelemetryEvent build() {
+      TelemetryEvent event = super.build();
+      event.put("Type", Type.Metric);
+      return event;
+    }
+  }
+
+  /** Build log json object */
+  public static class LogBuilder extends Builder<LogBuilder> {
+    public LogBuilder() {
+      super(LogBuilder.class);
+    }
+
+    /**
+     * build a log event for an exception including the full stack trace
+     *
+     * @param ex The exception to build a log event
+     * @return The log event builder
+     */
+    public LogBuilder withException(Exception ex) {
+      this.withName("Exception:" + ex.getMessage());
+      StringWriter sw = new StringWriter();
+      PrintWriter pw = new PrintWriter(sw);
+      ex.printStackTrace(pw);
+      String stackTrace = sw.toString(); // stack trace as a string
+      this.withValue(stackTrace);
+      return this;
+    }
+
+    public LogBuilder withException(final SFException ex) {
+      this.withName("Exception:" + ex.getMessage());
+      StringWriter sw = new StringWriter();
+      PrintWriter pw = new PrintWriter(sw);
+      ex.printStackTrace(pw);
+      String stackTrace = sw.toString(); // stack trace as a string
+      this.withValue(stackTrace);
+      return this;
+    }
+
+    public LogBuilder withValue(String value) {
+      body.put("Value", SecretDetector.maskSecrets(value));
+      return this;
+    }
+
+    public LogBuilder withValue(JSONObject value) {
+      body.put("Value", SecretDetector.maskJsonObject(value));
+      return this;
+    }
+
+    public LogBuilder withValue(JSONArray value) {
+      body.put("Value", SecretDetector.maskJsonArray(value));
+      return this;
+    }
+
+    public TelemetryEvent build() {
+      TelemetryEvent event = super.build();
+      event.put("Type", Type.Log);
+      return event;
+    }
+  }
+
+  private static class Builder<T> {
+    protected final Class<T> builderClass;
+    protected TelemetryEvent body = new TelemetryEvent();
+    protected HashMap<String, String> tags = new HashMap<>();
+    private static final String version =
+        ResourceBundleManager.getSingleton(
+                "net.snowflake.ingest.streaming.internal.fileTransferAgent.version")
+            .getLocalizedMessage("version");
+    private static final String driver = "JDBC";
+
+    public Builder(Class<T> builderClass) {
+      this.builderClass = builderClass;
+      withTag("driver", driver);
+      withTag("version", version);
+      TelemetryService instance = TelemetryService.getInstance();
+      withTag("telemetryServerDeployment", instance.getServerDeploymentName());
+      withTag("connectionString", instance.getDriverConnectionString());
+      JSONObject context = instance.getContext();
+      if (context != null) {
+        for (String key : context.keySet()) {
+          Object val = context.get(key);
+          if (val != null) {
+            withTag(
+                "ctx_" + key.toLowerCase(), SecretDetector.maskParameterValue(key, val.toString()));
+          }
+        }
+      }
+    }
+
+    public T withName(String name) {
+      body.put("Name", SecretDetector.maskSecrets(name));
+      return builderClass.cast(this);
+    }
+
+    public T withTag(String name, int value) {
+      return withTag(name, Integer.toString(value));
+    }
+
+    public T withTag(String name, String value) {
+      if (value != null && value.length() > 0) {
+        tags.put(name, SecretDetector.maskSecrets(value));
+      }
+      return builderClass.cast(this);
+    }
+
+    protected TelemetryEvent build() {
+      body.put("UUID", UUIDUtils.getUUID().toString());
+      body.put("Created_On", SFTimestamp.getUTCNow());
+      body.put("SchemaVersion", schemaVersion);
+      this.putMap("Tags", tags);
+      return body;
+    }
+
+    private void putMap(String name, HashMap<String, String> map) {
+      JSONObject tags = new JSONObject();
+      for (String key : map.keySet()) {
+        tags.put(key, map.get(key));
+      }
+      body.put(name, tags);
+    }
+  }
+
+  /**
+   * @return the deployment of this event
+   */
+  public String getDeployment() {
+    JSONArray tags = (JSONArray) this.get("Tags");
+    for (Object tag : tags) {
+      JSONObject json = (JSONObject) tag;
+      if (json.get("Name").toString().compareTo("deployment") == 0) {
+        return json.get("Value").toString();
+      }
+    }
+    return "Unknown";
+  }
+}