Convert stream timestamps from/to ms (#637)

Noticed that while working with text streams 🕙

Author: pblazej

.nanpa/fix-stream-timestamps.kdl

@@ -0,0 +1 @@
+patch type="fixed" "Wrong stream timestamp conversion"

Sources/LiveKit/DataStream/Outgoing/OutgoingStreamManager.swift

@@ -272,9 +272,10 @@ extension Livekit_DataStream.Header {
         }
     }
 
+    // Stream timestamps are in ms (13 digits)
     var timestampDate: Date {
-        get { Date(timeIntervalSince1970: TimeInterval(timestamp)) }
-        set { timestamp = Int64(newValue.timeIntervalSince1970) }
+        get { Date(timeIntervalSince1970: TimeInterval(timestamp) / TimeInterval(1000)) }
+        set { timestamp = Int64(newValue.timeIntervalSince1970 * TimeInterval(1000)) }
     }
 }
 

Tests/LiveKitTests/DataStream/ByteStreamInfoTests.swift

@@ -32,7 +32,7 @@ class ByteStreamInfoTests: LKTestCase {
         XCTAssertEqual(header.streamID, info.id)
         XCTAssertEqual(header.mimeType, info.mimeType)
         XCTAssertEqual(header.topic, info.topic)
-        XCTAssertEqual(header.timestamp, Int64(info.timestamp.timeIntervalSince1970))
+        XCTAssertEqual(header.timestamp, Int64(info.timestamp.timeIntervalSince1970 * TimeInterval(1000)))
         XCTAssertEqual(header.totalLength, UInt64(info.totalLength ?? -1))
         XCTAssertEqual(header.attributes, info.attributes)
         XCTAssertEqual(header.byteHeader.name, info.name)

Tests/LiveKitTests/DataStream/TextStreamInfoTests.swift

@@ -34,7 +34,7 @@ class TextStreamInfoTests: LKTestCase {
         let header = Livekit_DataStream.Header(info)
         XCTAssertEqual(header.streamID, info.id)
         XCTAssertEqual(header.topic, info.topic)
-        XCTAssertEqual(header.timestamp, Int64(info.timestamp.timeIntervalSince1970))
+        XCTAssertEqual(header.timestamp, Int64(info.timestamp.timeIntervalSince1970 * TimeInterval(1000)))
         XCTAssertEqual(header.totalLength, UInt64(info.totalLength ?? -1))
         XCTAssertEqual(header.attributes, info.attributes)
         XCTAssertEqual(header.textHeader.operationType.rawValue, info.operationType.rawValue)