Work in Progress

Author: Drejzer

Sources/PrivMXEndpointStreamsLow/WebRtcInterfaceInstance.mm

@@ -0,0 +1,13 @@
+//
+// PrivMX Endpoint Swift
+// Copyright © 2024 Simplito sp. z o.o.
+//
+// This file is part of PrivMX Platform (https://privmx.dev).
+// This software is Licensed under the MIT License.
+//
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+#include "WebRtcInterfaceInstance.hpp"
+

Sources/PrivMXEndpointStreamsLow/include/WebRtcInterfaceInstance.hpp

@@ -28,6 +28,19 @@ typedef void(*UpdateSessionIdCallback)(const std::string&,const int64_t, const s
 typedef void(*CloseCallback)(const std::string&);
 typedef void(*UpdateKeysCallback)(const std::string&,const KeyVector&);
 
+typedef int(*ConvertToRGBAImpl)(uint8_t*,int,int,int);
+
+class FrameImpl : public endpoint::stream::Frame{
+	ConvertToRGBAImpl cb;
+public:
+	
+	FrameImpl(ConvertToRGBAImpl _imp) : cb(_imp) {}
+	
+	int ConvertToRGBA(uint8_t* dst_argb, int dst_stride_argb,int dest_width, int dest_height) override{
+		return cb(dst_argb,dst_stride_argb,dest_width,dest_height);
+	}
+};
+
 class WebRtcInterfaceInstance: public privmx::endpoint::stream::WebRTCInterface{
 public:
 	virtual std::string createOfferAndSetLocalDescription(const std::string& streamRoomId) override {
@@ -79,6 +92,7 @@ class WebRtcInterfaceInstance: public privmx::endpoint::stream::WebRTCInterface{
 
 };
 
+using SharedWebRTCInterfaceInstance = std::shared_ptr<WebRtcInterfaceInstance>;
 }
 #endif // !_WebRtcInterfaceInstance_
 

Sources/PrivMXEndpointSwift/Streams/PmxPeerConnectionObserver.swift

@@ -14,7 +14,52 @@ import Foundation
 import WebRTC
 import Synchronization
 
+
 public final class PmxPeerConnectionObserver:NSObject,RTCPeerConnectionDelegate, @unchecked Sendable{
+	private var streamRoomId: String
+	private var currentKeys = PMXKeyStore()
+	
+	private var onFrameCallback: (Int64, Int64) -> Void
+	
+	init(
+		streamRoomId: String,
+		currentKeys: PMXKeyStore = PMXKeyStore(),
+		onConnectionSignalingStateChanged: ((RTCPeerConnection, RTCSignalingState) -> Void)? = nil,
+		onConnectionPeerStateChanged: ((RTCPeerConnection, RTCPeerConnectionState) -> Void)? = nil,
+		onStreamAdded: ((RTCPeerConnection, RTCMediaStream) -> Void)? = nil,
+		onStreamRemoved: ((RTCPeerConnection, RTCMediaStream) -> Void)? = nil,
+		onShouldRenegotiate: ((RTCPeerConnection) -> Void)? = nil,
+		onIceCandidateErrorEvent: ((RTCPeerConnection, RTCIceCandidateErrorEvent) -> Void)? = nil,
+		onIceConnectionStateChanged: ((RTCPeerConnection, RTCIceConnectionState) -> Void)? = nil,
+		onIceGatheringStateChanged: ((RTCPeerConnection, RTCIceGatheringState) -> Void)? = nil,
+		onIceCandidateGenerated: ((RTCPeerConnection, RTCIceCandidate) -> Void)? = nil,
+		onIceCandidatesRemoved: ((RTCPeerConnection, [RTCIceCandidate]) -> Void)? = nil,
+		onDataChannelOpened: ((RTCPeerConnection, RTCDataChannel) -> Void)? = nil,
+		onStartedReceiving: ((RTCPeerConnection, RTCRtpTransceiver) -> Void)? = nil,
+		onStoppedReceiving: ((RTCPeerConnection, RTCRtpReceiver) -> Void)? = nil,
+		onTracksAdded: ((RTCPeerConnection, RTCRtpReceiver, [RTCMediaStream]) -> Void)? = nil,
+		onTracksRemoved: ((RTCPeerConnection, RTCRtpReceiver) -> Void)? = nil,
+		onLocalCandidateChanged: ((RTCPeerConnection, RTCIceCandidate, RTCIceCandidate, Int32, String) -> Void)? = nil
+	) {
+		self.streamRoomId = streamRoomId
+		self.currentKeys = currentKeys
+		self.onConnectionSignalingStateChanged = onConnectionSignalingStateChanged
+		self.onConnectionPeerStateChanged = onConnectionPeerStateChanged
+		self.onStreamAdded = onStreamAdded
+		self.onStreamRemoved = onStreamRemoved
+		self.onShouldRenegotiate = onShouldRenegotiate
+		self.onIceCandidateErrorEvent = onIceCandidateErrorEvent
+		self.onIceConnectionStateChanged = onIceConnectionStateChanged
+		self.onIceGatheringStateChanged = onIceGatheringStateChanged
+		self.onIceCandidateGenerated = onIceCandidateGenerated
+		self.onIceCandidatesRemoved = onIceCandidatesRemoved
+		self.onDataChannelOpened = onDataChannelOpened
+		self.onStartedReceiving = onStartedReceiving
+		self.onStoppedReceiving = onStoppedReceiving
+		self.onTracksAdded = onTracksAdded
+		self.onTracksRemoved = onTracksRemoved
+		self.onLocalCandidateChanged = onLocalCandidateChanged
+	}
 
 
 	private var onConnectionSignalingStateChanged: ((RTCPeerConnection,RTCSignalingState)->Void)?

Sources/PrivMXEndpointSwift/Streams/StreamApi.swift

@@ -21,6 +21,7 @@ public actor StreamApi: @unchecked Sendable{
 	private var api: privmx.NativeStreamApiLowWrapper
 	private var peerConnectionFactory: RTCPeerConnectionFactory
 	private var webRtcInstance: privmx.WebRtcInterfaceInstance
+	
 
 
 	//private var notificationListenerId : Int
@@ -410,9 +411,9 @@ public actor StreamApi: @unchecked Sendable{
 	}
 }
 
+
 public extension EventHandler{
-	
-	
+
 	static func isStreamRoomCreatedEvent(
 		eventHolder: privmx.endpoint.core.EventHolder
 	) throws -> Bool {

Sources/PrivMXEndpointSwift/Streams/StreamData.swift

@@ -0,0 +1,18 @@
+//
+// PrivMX Endpoint Swift
+// Copyright © 2024 Simplito sp. z o.o.
+//
+// This file is part of PrivMX Platform (https://privmx.dev).
+// This software is Licensed under the MIT License.
+//
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+import Foundation
+import PrivMXEndpointSwiftNative
+import PrivMXEndpointStreamsLow
+
+final class StreamData:Sendable{
+	
+}

Sources/PrivMXEndpointSwift/Streams/WebRTCNativeInterface.swift

@@ -0,0 +1,68 @@
+//
+// PrivMX Endpoint Swift
+// Copyright © 2024 Simplito sp. z o.o.
+//
+// This file is part of PrivMX Platform (https://privmx.dev).
+// This software is Licensed under the MIT License.
+//
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+import Foundation
+import PrivMXEndpointSwiftNative
+import PrivMXEndpointStreamsLow
+import WebRTC
+
+class FrameImpl{
+	private var _frame : RTCVideoFrame
+	public var cxxImpl : privmx.FrameImpl
+	init(_frame: RTCVideoFrame) {
+		self._frame = _frame
+		self.cxxImpl = privmx.FrameImpl{
+			dst_argb,dst_stride_argb,dest_width,dest_height in
+			
+			
+			
+			RTCYUVHelper.i420(
+				toARGB: <#T##UnsafePointer<UInt8>!#>,
+				srcStrideY: <#T##Int32#>,
+				srcU: <#T##UnsafePointer<UInt8>!#>,
+				srcStrideU: <#T##Int32#>,
+				srcV: <#T##UnsafePointer<UInt8>!#>,
+				srcStrideV: <#T##Int32#>,
+				dstARGB: dst_argb,
+				dstStrideARGB: dst_stride_argb,
+				width: <#T##Int32#>,
+				height: <#T##Int32#>)
+		}
+	}
+	
+}
+
+public final class WebRTCNativeInterface: Sendable {
+	nonisolated(unsafe) private var api : privmx.SharedWebRTCInterfaceInstance
+	nonisolated(unsafe) private var peerConnectionFactory: RTCPeerConnectionFactory
+	nonisolated(unsafe) private var constraints : RTCMediaConstraints
+	nonisolated(unsafe) private var onTrickle : @Sendable (Int64, String) -> Void
+	nonisolated(unsafe) private var peerConnectionManager: PeerConnectionManager
+	
+	init(
+		api: privmx.SharedWebRTCInterfaceInstance,
+		peerConnectionFactory: RTCPeerConnectionFactory,
+		constraints: RTCMediaConstraints,
+		onTrickle: @escaping @Sendable (Int64, String) -> Void,
+		peerConnectionManager: PeerConnectionManager) {
+		self.api = api
+		self.peerConnectionFactory = peerConnectionFactory
+		self.constraints = constraints
+		self.onTrickle = onTrickle
+		self.peerConnectionManager = PeerConnectionManager(
+			_createPeerConnection:{
+				streamRoomId in
+				peerConnectionFactory
+				
+			},
+		_onTrickle: onTrickle)
+	}
+}