Initial import

Author: Dr. Brandon Wiley

.gitignore

@@ -1,3 +1,7 @@
+Package.resolved
+.swiftpm
+.build
+
 # Xcode
 #
 # gitignore contributors: remember to update Global/Xcode.gitignore, Objective-C.gitignore & Swift.gitignore

Package.swift

@@ -0,0 +1,37 @@
+// swift-tools-version: 5.9
+// The swift-tools-version declares the minimum version of Swift required to build this package.
+
+import PackageDescription
+
+let package = Package(
+    name: "TransmissionData",
+    platforms: [
+        .macOS(.v14),
+        .iOS(.v17)
+    ],
+    products: [
+        // Products define the executables and libraries a package produces, making them visible to other packages.
+        .library(
+            name: "TransmissionData",
+            targets: ["TransmissionData"]),
+    ],
+    dependencies: [
+        .package(url: "https://github.com/OperatorFoundation/Straw", branch: "main"),
+        .package(url: "https://github.com/OperatorFoundation/Transmission", branch: "main"),
+    ],
+    targets: [
+        // Targets are the basic building blocks of a package, defining a module or a test suite.
+        // Targets can depend on other targets in this package and products from dependencies.
+        .target(
+            name: "TransmissionData",
+            dependencies: [
+                "Straw",
+                "Transmission",
+            ]
+        ),
+        .testTarget(
+            name: "TransmissionDataTests",
+            dependencies: ["TransmissionData"]),
+    ],
+    swiftLanguageVersions: [.v5]
+)

Sources/TransmissionData/TransmissionData.swift

@@ -0,0 +1,138 @@
+//
+//  TransmissionData.swift
+//
+//
+//  Created by Dr. Brandon Wiley on 1/15/24.
+//
+
+import Foundation
+
+import Straw
+import Transmission
+
+public class TransmissionData: Transmission.Connection
+{
+    var readBuffer: UnsafeStraw = UnsafeStraw()
+    var writeBuffer: UnsafeStraw = UnsafeStraw()
+    var closed: Bool = false
+
+    let readLock: DispatchSemaphore = DispatchSemaphore(value: 1)
+    let writeLock: DispatchSemaphore = DispatchSemaphore(value: 1)
+
+    public init(readBuffer: Data = Data(), writeBuffer: Data = Data())
+    {
+        self.readBuffer.write(readBuffer)
+        self.writeBuffer.write(writeBuffer)
+    }
+
+    // Transmission.Connection
+    public func read(size: Int) -> Data?
+    {
+        defer
+        {
+            self.readLock.signal()
+        }
+        self.readLock.wait()
+
+        if closed
+        {
+            return nil
+        }
+
+        return try? self.readBuffer.read(size: size)
+    }
+
+    public func unsafeRead(size: Int) -> Data?
+    {
+        if closed
+        {
+            return nil
+        }
+
+        return try? self.readBuffer.read(size: size)
+    }
+
+    public func read(maxSize: Int) -> Data?
+    {
+        defer
+        {
+            self.readLock.signal()
+        }
+        self.readLock.wait()
+
+        if closed
+        {
+            return nil
+        }
+
+        return try? self.readBuffer.read(maxSize: maxSize)
+    }
+
+    public func readWithLengthPrefix(prefixSizeInBits: Int) -> Data?
+    {
+        if closed
+        {
+            return nil
+        }
+
+        return Transmission.readWithLengthPrefix(prefixSizeInBits: prefixSizeInBits, connection: self)
+    }
+
+    public func write(string: String) -> Bool
+    {
+        defer
+        {
+            self.writeLock.signal()
+        }
+        self.writeLock.wait()
+
+        if closed
+        {
+            return false
+        }
+
+        self.writeBuffer.write(string.data)
+
+        return true
+    }
+
+    public func write(data: Data) -> Bool
+    {
+        defer
+        {
+            self.writeLock.signal()
+        }
+        self.writeLock.wait()
+
+        if closed
+        {
+            return false
+        }
+
+        self.writeBuffer.write(data)
+
+        return true
+    }
+
+    public func writeWithLengthPrefix(data: Data, prefixSizeInBits: Int) -> Bool
+    {
+        if closed
+        {
+            return false
+        }
+
+        return Transmission.writeWithLengthPrefix(data: data, prefixSizeInBits: prefixSizeInBits, connection: self)
+    }
+
+    public func close()
+    {
+        self.closed = true
+    }
+    // End Transmission.Connection
+
+    public func flip()
+    {
+        self.readBuffer = self.writeBuffer
+        self.writeBuffer = UnsafeStraw()
+    }
+}

Tests/TransmissionDataTests/TransmissionDataTests.swift

@@ -0,0 +1,12 @@
+import XCTest
+@testable import TransmissionData
+
+final class TransmissionDataTests: XCTestCase {
+    func testExample() throws {
+        // XCTest Documentation
+        // https://developer.apple.com/documentation/xctest
+
+        // Defining Test Cases and Test Methods
+        // https://developer.apple.com/documentation/xctest/defining_test_cases_and_test_methods
+    }
+}