Async API added to iOS package

Author: SanttuRantanen

packages/streamr-libstreamrproxyclient/.gitignore

@@ -7,13 +7,10 @@
 wrappers/python/dist
 wrappers/python/src/streamrproxyclient/libstreamrproxyclient.dylib
 wrappers/python/src/streamrproxyclient/libstreamrproxyclient.so
-dist/*
 **/**.dylib
 **/**.so
 **/wheelhouse/
 *.tgz
 *.so.*
 **/libstreamrproxyclient.[0-9].[0-9].[0-9].dylib
-dist/
-dist/**
-wrappers/python/src/streamrproxyclient/libstreamrproxyclient.dylib
+wrappers/python/src/streamrproxyclient/libstreamrproxyclient.dylib

packages/streamr-libstreamrproxyclient/dist/ios-swift-package/StreamrProxyClient/Package.swift

@@ -10,6 +10,9 @@ let package = Package(
         .iOS(.v17)
     ],
     products: [
+           .library(
+                name: "StreamrProxyClientActor",
+                targets: ["StreamrProxyClientActor"]),
            .library(
                name: "StreamrProxyClient",
                targets: ["StreamrProxyClient"]),
@@ -19,6 +22,13 @@ let package = Package(
        ],
 
     targets: [
+        .target(
+            name: "StreamrProxyClientActor",
+            dependencies: ["StreamrProxyClient"],
+            linkerSettings: [
+                .linkedFramework("Foundation")
+                // Add any other frameworks your library depends on
+            ]),
         .target(
             name: "StreamrProxyClient",
             dependencies: ["streamr", "ProxyClientAPI"],

packages/streamr-libstreamrproxyclient/dist/ios-swift-package/StreamrProxyClient/README.md

@@ -80,6 +80,35 @@ func test() throws {
 }
 ```
 
+Async API:
+
+```swift
+func test() async throws {
+    // Initialize client
+    let client = try StreamrProxyClientActor(
+        ownEthereumAddress: "0x1234567890123456789012345678901234567890",
+        streamPartId: "0xd2078dc2d780029473a39ce873fc182587be69db/low-level-client#0"
+    )
+    
+    // Create proxy configuration
+    let proxy = StreamrProxyAddress(
+        websocketUrl: "ws://95.216.15.80:44211",
+        ethereumAddress: "0xd0d14b38d1f6b59d3772a63d84ece0a79e6e1c1f"
+    )
+    
+    // Connect to proxy
+    let connectResult = await client.connect(proxies: [proxy])
+    
+    // Check connection result
+    if connectResult.numConnected > 0 {
+        // Publish message
+        let publishResult = await client.publish(
+            content: "test message",
+            ethereumPrivateKey: "0x..."
+        )
+    }
+}
+
 ## API Documentation
 
 StreamrProxyClient provides a Swift interface to the C++ StreamrProxyClient library. The interface is defined in the StreamrProxyClientAPI protocol.

packages/streamr-libstreamrproxyclient/dist/ios-swift-package/StreamrProxyClient/Sources/StreamrProxyClientActor/StreamrProxyClientActor.swift

@@ -0,0 +1,31 @@
+//
+//  StreamrProxyClientActor.swift
+//  StreamrProxyClient
+//
+//  Created by Santtu Rantanen on 21.12.2024.
+//
+import ProxyClientAPI
+import StreamrProxyClient
+
+public actor StreamrProxyClientActor {
+    let client: StreamrProxyClient
+    
+    public init(ownEthereumAddress: String, streamPartId: String) throws {
+        self.client = try StreamrProxyClient(
+            ownEthereumAddress: ownEthereumAddress,
+            streamPartId: streamPartId
+        )
+    }
+    
+    public init(client: StreamrProxyClient) {
+        self.client = client
+    }
+    
+    public func connect(proxies: [StreamrProxyAddress]) -> StreamrProxyResult {
+        client.connect(proxies: proxies)
+    }
+    
+    public func publish(content: String, ethereumPrivateKey: String) -> StreamrProxyResult {
+        client.publish(content: content, ethereumPrivateKey: ethereumPrivateKey)
+    }
+}

packages/streamr-libstreamrproxyclient/examples/ios/LocationShare/LocationShare.xcodeproj/project.pbxproj

@@ -20,6 +20,12 @@
 		413E46F62C7898D40030132D /* PeerDesc.swift in Sources */ = {isa = PBXBuildFile; fileRef = 413E46F52C7898D40030132D /* PeerDesc.swift */; };
 		4154A2B22CDC93770057D042 /* StreamrProxyClient in Frameworks */ = {isa = PBXBuildFile; productRef = 4154A2B12CDC93770057D042 /* StreamrProxyClient */; };
 		4154A2B52CDCAFC70057D042 /* ProxyClientTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4154A2B42CDCAFB40057D042 /* ProxyClientTests.swift */; };
+		41B663952D1650B200281EDB /* ProxyClientAPI in Frameworks */ = {isa = PBXBuildFile; productRef = 41B663942D1650B200281EDB /* ProxyClientAPI */; };
+		41B663972D1650B200281EDB /* StreamrProxyClient in Frameworks */ = {isa = PBXBuildFile; productRef = 41B663962D1650B200281EDB /* StreamrProxyClient */; };
+		41B663992D1650B200281EDB /* StreamrProxyClientActor in Frameworks */ = {isa = PBXBuildFile; productRef = 41B663982D1650B200281EDB /* StreamrProxyClientActor */; };
+		41B6639E2D165AAA00281EDB /* ProxyClientAPI in Frameworks */ = {isa = PBXBuildFile; productRef = 41B6639D2D165AAA00281EDB /* ProxyClientAPI */; };
+		41B663A02D165AAA00281EDB /* StreamrProxyClient in Frameworks */ = {isa = PBXBuildFile; productRef = 41B6639F2D165AAA00281EDB /* StreamrProxyClient */; };
+		41B663A22D165AAA00281EDB /* StreamrProxyClientActor in Frameworks */ = {isa = PBXBuildFile; productRef = 41B663A12D165AAA00281EDB /* StreamrProxyClientActor */; };
 /* End PBXBuildFile section */
 
 /* Begin PBXContainerItemProxy section */
@@ -63,8 +69,14 @@
 			isa = PBXFrameworksBuildPhase;
 			buildActionMask = 2147483647;
 			files = (
+				41B663A02D165AAA00281EDB /* StreamrProxyClient in Frameworks */,
 				412FDA7B2CAF8DC3008DC50E /* libc++abi.tbd in Frameworks */,
+				41B6639E2D165AAA00281EDB /* ProxyClientAPI in Frameworks */,
+				41B663972D1650B200281EDB /* StreamrProxyClient in Frameworks */,
+				41B663992D1650B200281EDB /* StreamrProxyClientActor in Frameworks */,
+				41B663952D1650B200281EDB /* ProxyClientAPI in Frameworks */,
 				4154A2B22CDC93770057D042 /* StreamrProxyClient in Frameworks */,
+				41B663A22D165AAA00281EDB /* StreamrProxyClientActor in Frameworks */,
 			);
 			runOnlyForDeploymentPostprocessing = 0;
 		};
@@ -245,7 +257,7 @@
 			);
 			mainGroup = 413E46B62C7867670030132D;
 			packageReferences = (
-				418411792CE0BD3C0046B113 /* XCLocalSwiftPackageReference "../../../dist/ios-swift-package/StreamrProxyClient" */,
+				41B6639C2D165AAA00281EDB /* XCLocalSwiftPackageReference "../../../dist/ios-swift-package/StreamrProxyClient" */,
 			);
 			productRefGroup = 413E46C02C7867670030132D /* Products */;
 			projectDirPath = "";
@@ -639,7 +651,7 @@
 /* End XCConfigurationList section */
 
 /* Begin XCLocalSwiftPackageReference section */
-		418411792CE0BD3C0046B113 /* XCLocalSwiftPackageReference "../../../dist/ios-swift-package/StreamrProxyClient" */ = {
+		41B6639C2D165AAA00281EDB /* XCLocalSwiftPackageReference "../../../dist/ios-swift-package/StreamrProxyClient" */ = {
 			isa = XCLocalSwiftPackageReference;
 			relativePath = "../../../dist/ios-swift-package/StreamrProxyClient";
 		};
@@ -650,6 +662,30 @@
 			isa = XCSwiftPackageProductDependency;
 			productName = StreamrProxyClient;
 		};
+		41B663942D1650B200281EDB /* ProxyClientAPI */ = {
+			isa = XCSwiftPackageProductDependency;
+			productName = ProxyClientAPI;
+		};
+		41B663962D1650B200281EDB /* StreamrProxyClient */ = {
+			isa = XCSwiftPackageProductDependency;
+			productName = StreamrProxyClient;
+		};
+		41B663982D1650B200281EDB /* StreamrProxyClientActor */ = {
+			isa = XCSwiftPackageProductDependency;
+			productName = StreamrProxyClientActor;
+		};
+		41B6639D2D165AAA00281EDB /* ProxyClientAPI */ = {
+			isa = XCSwiftPackageProductDependency;
+			productName = ProxyClientAPI;
+		};
+		41B6639F2D165AAA00281EDB /* StreamrProxyClient */ = {
+			isa = XCSwiftPackageProductDependency;
+			productName = StreamrProxyClient;
+		};
+		41B663A12D165AAA00281EDB /* StreamrProxyClientActor */ = {
+			isa = XCSwiftPackageProductDependency;
+			productName = StreamrProxyClientActor;
+		};
 /* End XCSwiftPackageProductDependency section */
 	};
 	rootObject = 413E46B72C7867670030132D /* Project object */;