DEMRUM-421: Log to span translation (#267)

* DEMRUM-421: Log to span translation

* warning fix

* Log to span event processor

* fix project

* Log to span exporter

* fix merge conflict

* finalize log to span

* body is body

* fix mr comments

* fix after merge

* chore: Properly update all resolved deps

* fix: Fix CiscoLogger and SplunkCommon integration issues

---------

Co-authored-by: Martin Budinsky <[email protected]>

Author: froseio

Splunk.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -215,6 +215,7 @@
 		C791AE002DAE8B81002AAA2B /* KeyBuilder+DefaultKeys.swift in Sources */ = {isa = PBXBuildFile; fileRef = C791ADFF2DAE8B81002AAA2B /* KeyBuilder+DefaultKeys.swift */; };
 		C791AE022DAE8B99002AAA2B /* CiscoDiskStorage in Frameworks */ = {isa = PBXBuildFile; productRef = C791AE012DAE8B99002AAA2B /* CiscoDiskStorage */; };
 		C7A2BD1B2BB45363005D4CFB /* AppStateModel.swift in Sources */ = {isa = PBXBuildFile; fileRef = C7A2BD1A2BB45363005D4CFB /* AppStateModel.swift */; };
+		C7C112672DB8D64C00B8E893 /* OTLPLogToSpanExporter.swift in Sources */ = {isa = PBXBuildFile; fileRef = C7C112652DB8D64C00B8E893 /* OTLPLogToSpanExporter.swift */; };
 		C7FFC4F52B7662E30035203B /* Service.swift in Sources */ = {isa = PBXBuildFile; fileRef = C7FFC4F42B7662E30035203B /* Service.swift */; };
 		E4032E622B552343003D4392 /* DefaultSessionTestBuilder.swift in Sources */ = {isa = PBXBuildFile; fileRef = E4032E612B552343003D4392 /* DefaultSessionTestBuilder.swift */; };
 		E4032E642B55278C003D4392 /* PersistentSessionsValidator.swift in Sources */ = {isa = PBXBuildFile; fileRef = E4032E632B55278C003D4392 /* PersistentSessionsValidator.swift */; };
@@ -795,6 +796,7 @@
 		C76AB8DD2B7B7A2400CB4307 /* AlternativeRemoteConfiguration.json */ = {isa = PBXFileReference; lastKnownFileType = text.json; path = AlternativeRemoteConfiguration.json; sourceTree = "<group>"; };
 		C791ADFF2DAE8B81002AAA2B /* KeyBuilder+DefaultKeys.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "KeyBuilder+DefaultKeys.swift"; sourceTree = "<group>"; };
 		C7A2BD1A2BB45363005D4CFB /* AppStateModel.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = AppStateModel.swift; sourceTree = "<group>"; };
+		C7C112652DB8D64C00B8E893 /* OTLPLogToSpanExporter.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = OTLPLogToSpanExporter.swift; sourceTree = "<group>"; };
 		C7FFC4F42B7662E30035203B /* Service.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Service.swift; sourceTree = "<group>"; };
 		E4032E612B552343003D4392 /* DefaultSessionTestBuilder.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DefaultSessionTestBuilder.swift; sourceTree = "<group>"; };
 		E4032E632B55278C003D4392 /* PersistentSessionsValidator.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = PersistentSessionsValidator.swift; sourceTree = "<group>"; };
@@ -2004,6 +2006,7 @@
 				2A2926342DAD114900AB6F03 /* Attribute Checker Exporters */,
 				4B5A5CA82D60ED3D009DA0D5 /* Utils */,
 				4B5A5CA92D60ED3D009DA0D5 /* OTel.swift */,
+				C7C112662DB8D64C00B8E893 /* LogToSpanExporter */,
 			);
 			path = SplunkOpenTelemetry;
 			sourceTree = "<group>";
@@ -2490,6 +2493,14 @@
 			path = Model;
 			sourceTree = "<group>";
 		};
+		C7C112662DB8D64C00B8E893 /* LogToSpanExporter */ = {
+			isa = PBXGroup;
+			children = (
+				C7C112652DB8D64C00B8E893 /* OTLPLogToSpanExporter.swift */,
+			);
+			path = LogToSpanExporter;
+			sourceTree = "<group>";
+		};
 		E405497D2DACF57500B7A2E4 /* User */ = {
 			isa = PBXGroup;
 			children = (
@@ -4322,6 +4333,7 @@
 				2A2926372DAD11C800AB6F03 /* AttributeCheckerLogExporter.swift in Sources */,
 				E4A537422DA655E2002323E2 /* OLTPAttributesSpanProcessor.swift in Sources */,
 				4B96421A2D61375E009A2E7F /* OTel.swift in Sources */,
+				C7C112672DB8D64C00B8E893 /* OTLPLogToSpanExporter.swift in Sources */,
 				2A5949DB2DA3FC2100F2E857 /* SplunkStdoutSpanExporter.swift in Sources */,
 				2A5949DC2DA3FC2100F2E857 /* SplunkStdoutLogExporter.swift in Sources */,
 				2A2926352DAD114900AB6F03 /* AttributeCheckerSpanExporter.swift in Sources */,

SplunkAgent/SplunkAgent.xcodeproj/project.pbxproj

@@ -56,16 +56,10 @@ public class OTLPLogEventProcessor: LogEventProcessor {
         let configuration = OtlpConfiguration()
         let envVarHeaders = [(String, String)]()
 
-        // Initialize background exporter
-        let backgroundLogExporter = OTLPBackgroundHTTPLogExporter(
-            endpoint: logsEndpoint,
-            config: configuration,
-            qosConfig: SessionQOSConfiguration(),
-            envVarHeaders: envVarHeaders
-        )
+        let logToSpanExporter = OTLPLogToSpanExporter(agentVersion: resources.agentVersion)
 
         // Initialize attribute checker proxy exporter
-        let attributeCheckerExporter = AttributeCheckerLogExporter(proxy: backgroundLogExporter)
+        let attributeCheckerExporter = AttributeCheckerLogExporter(proxy: logToSpanExporter)
 
         // Initialize LogRecordProcessor
         let simpleLogRecordProcessor = SimpleLogRecordProcessor(

SplunkOpenTelemetry/Sources/SplunkOpenTelemetry/Log Event Processor/OTLPLogEventProcessor.swift

@@ -0,0 +1,90 @@
+//
+/*
+Copyright 2025 Splunk Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+internal import CiscoLogger
+import Foundation
+import OpenTelemetryProtocolExporterCommon
+import OpenTelemetrySdk
+import OpenTelemetryApi
+import SplunkCommon
+
+public class OTLPLogToSpanExporter: LogRecordExporter {
+
+    // MARK: - Private properties
+
+    private let agentVersion: String
+
+    // Internal Logger
+    private let logger = DefaultLogAgent(poolName: PackageIdentifier.instance(), category: "Log to Span Exporter")
+
+
+    // MARK: - Initialization
+
+    init(agentVersion: String) {
+        self.agentVersion = agentVersion
+    }
+
+
+    // MARK: - LogRecordExporter protocol implementation
+
+    public func export(logRecords: [OpenTelemetrySdk.ReadableLogRecord], explicitTimeout: TimeInterval?) -> OpenTelemetrySdk.ExportResult {
+
+        let tracer = OpenTelemetry.instance
+            .tracerProvider
+            .get(
+                instrumentationName: "LogToSpan",
+                instrumentationVersion: agentVersion
+            )
+
+        for log in logRecords {
+
+            guard
+                let spanName = spanName(from: log),
+                !spanName.isEmpty
+            else {
+                logger.log(level: .error) {
+                    "Missing span name for log record"
+                }
+                continue
+            }
+
+            let span = tracer
+                .spanBuilder(spanName: spanName)
+                .setStartTime(time: log.timestamp)
+                .startSpan()
+
+            for (key, value) in log.attributes {
+                span.setAttribute(key: key, value: value)
+            }
+
+            span.setAttribute(key: "body", value: log.body)
+
+            span.end(time: log.timestamp)
+        }
+        return .success
+    }
+
+    private func spanName(from log: ReadableLogRecord) -> String? {
+        return log.attributes["event.name"]?.description
+    }
+
+    public func shutdown(explicitTimeout: TimeInterval?) {}
+
+    public func forceFlush(explicitTimeout: TimeInterval?) -> OpenTelemetrySdk.ExportResult {
+        return .success
+    }
+}