feat: Add PulsarInstant and PulsarTimestamp as PulsarPayload to exten…

…d schemas

.spi.yml

@@ -1,4 +1,4 @@
 version: 1
 builder:
   configs:
-    - documentation_targets: [Pulsar]
+    - documentation_targets: [Pulsar, SchemaTypes]

.swiftpm/xcode/xcshareddata/xcschemes/pulsar-client-swift-Package.xcscheme

@@ -49,6 +49,20 @@
                ReferencedContainer = "container:">
             </BuildableReference>
          </BuildActionEntry>
+         <BuildActionEntry
+            buildForTesting = "YES"
+            buildForRunning = "YES"
+            buildForProfiling = "YES"
+            buildForArchiving = "YES"
+            buildForAnalyzing = "YES">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "SchemaTypes"
+               BuildableName = "SchemaTypes"
+               BlueprintName = "SchemaTypes"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </BuildActionEntry>
       </BuildActionEntries>
    </BuildAction>
    <TestAction

Package.swift

@@ -9,6 +9,10 @@ let package = Package(
 		.library(
 			name: "Pulsar",
 			targets: ["Pulsar"]
+		),
+		.library(
+			name: "SchemaTypes",
+			targets: ["SchemaTypes"]
 		)
 	],
 	dependencies: [
@@ -25,7 +29,8 @@ let package = Package(
 				.product(name: "SwiftProtobuf", package: "swift-protobuf"),
 				.product(name: "NIOSSL", package: "swift-nio-ssl"),
 				.product(name: "NIOFoundationCompat", package: "swift-nio"),
-				.product(name: "Logging", package: "swift-log")
+				.product(name: "Logging", package: "swift-log"),
+				.target(name: "SchemaTypes")
 			]
 
 		),
@@ -38,7 +43,8 @@ let package = Package(
 		.testTarget(
 			name: "PulsarTests",
 			dependencies: ["Pulsar"]
-		)
+		),
+		.target(name: "SchemaTypes")
 	],
 	swiftLanguageModes: [.v6]
 )

Sources/Pulsar/BackoffStrategy.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ByteBuffer+PulsarPayload.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/CRC32C.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ClientHandler/PulsarClientHandler+Consumers.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ClientHandler/PulsarClientHandler+Producers.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ClientHandler/PulsarClientHandler.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ConsumerCache.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ConsumerStateHandler.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/HandlerStateMap.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/Message.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ProducerAccessMode.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ProducerCache.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/ProducerStateManager.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/Protos.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarClient/PulsarClient+Consumers.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarClient/PulsarClient+Producers.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarClient/PulsarClient+Reconnection.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarClient/PulsarClient.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.
@@ -14,6 +14,7 @@
 
 import Logging
 import NIO
+@_exported import SchemaTypes
 
 /// The core Pulsar Client used to connect to the server. All control of the library, like consumers and producers and its settings are controlled via the Client.
 public final actor PulsarClient {

Sources/Pulsar/PulsarClientError.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarConsumer.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarFrameDecoder.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarFrameEncoder.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarMesage.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarPayload.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.
@@ -15,13 +15,58 @@
 import Foundation
 import NIOCore
 import NIOFoundationCompat
+import SchemaTypes
 
 /// The Pulsar Payload protocol enables types to be used as a payload of a Pulsar Message.
 public protocol PulsarPayload: Sendable {
 	func encode() -> ByteBuffer
 	static func decode(from buffer: ByteBuffer) throws -> Self
 }
 
+extension PulsarInstant: PulsarPayload {
+	/// Encode into a ByteBuffer.
+	/// - Returns: The ByteBuffer.
+	public func encode() -> ByteBuffer {
+		var buffer = ByteBufferAllocator().buffer(capacity: 12)
+		buffer.writeInteger(seconds)
+		buffer.writeInteger(nanos)
+		return buffer
+	}
+	/// Decode from a ByteBuffer.
+	/// - Parameter buffer: The buffer to decode.
+	/// - Returns: The decoded type.
+	/// - Throws: DecodingError.dataCorrupted when the decoding fails.
+	public static func decode(from buffer: ByteBuffer) throws -> PulsarInstant {
+		var mutableBuffer = buffer
+		guard let seconds = mutableBuffer.readInteger(as: Int64.self) else {
+			throw DecodingError.dataCorrupted(.init(codingPath: [], debugDescription: "Failed to decode seconds."))
+		}
+		guard let nanos = mutableBuffer.readInteger(as: Int32.self) else {
+			throw DecodingError.dataCorrupted(.init(codingPath: [], debugDescription: "Failed to decode nanos."))
+		}
+		return PulsarInstant(seconds: seconds, nanos: nanos)
+
+	}
+
+}
+
+extension PulsarTimestamp: PulsarPayload {
+	/// Encode into a ByteBuffer.
+	/// - Returns: The ByteBuffer.
+	public func encode() -> ByteBuffer {
+		pulsarDate.encode()
+	}
+	/// Decode from a ByteBuffer.
+	/// - Parameter buffer: The buffer to decode.
+	/// - Returns: The decoded type.
+	/// - Throws: DecodingError.dataCorrupted when the decoding fails.
+	public static func decode(from buffer: ByteBuffer) throws -> PulsarTimestamp {
+		let timestamp = try Int64.decode(from: buffer)
+		return PulsarTimestamp(timestamp: timestamp)
+	}
+
+}
+
 extension Data: PulsarPayload {
 	/// Encode into a ByteBuffer.
 	/// - Returns: The ByteBuffer.

Sources/Pulsar/PulsarProducer.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarSchema+Decode.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/PulsarSchema.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/SubscriptionMode.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/Pulsar/SubscriptionType.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/PulsarExample/PulsarExample.swift

@@ -1,4 +1,4 @@
-// Copyright 2024 Felix Ruppert
+// Copyright 2025 Felix Ruppert
 //
 // Licensed under the Apache License, Version 2.0 (the License );
 // you may not use this file except in compliance with the License.

Sources/SchemaTypes/Date+PulsarInstant.swift

@@ -0,0 +1,28 @@
+// Copyright 2025 Felix Ruppert
+//
+// 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.
+
+import Foundation
+
+extension Date {
+	/// The ``PulsarInstant`` representation of the date.
+	public var pulsarInstant: PulsarInstant {
+		PulsarInstant(date: self)
+	}
+
+	/// Initialize a Date with ``PulsarInstant``.
+	/// - Parameter pulsarInstant: The object to initialize with.
+	public init(pulsarInstant: PulsarInstant) {
+		self = pulsarInstant.date
+	}
+}

Sources/SchemaTypes/Date+PulsarTimestamp.swift

@@ -0,0 +1,28 @@
+// Copyright 2025 Felix Ruppert
+//
+// 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.
+
+import Foundation
+
+extension Date {
+	/// The ``PulsarTimestamp`` representation of the date.
+	public var pulsarTimestamp: PulsarTimestamp {
+		PulsarTimestamp(timestamp: Int64(timeIntervalSince1970 * 1000))
+	}
+
+	/// Initialize a Date with ``pulsarTimestamp``.
+	/// - Parameter pulsarTimestamp: The object to initialize with.
+	public init(pulsarTimestamp: PulsarTimestamp) {
+		self = Date(timeIntervalSince1970: Double(pulsarTimestamp.pulsarDate) / 1000)
+	}
+}