add ICE port range

Author: QuasarStream Team

src/RTCIceConnection.php

@@ -179,6 +179,8 @@ class RTCIceConnection extends EventEmitter implements RTCIceConnectionInterface
     /** @var int Count of failed binding attempts */
     private int $tryFailedCount = 0;
 
+    private ?array $icePortRange = null;
+
     /**
      * Constructor - Creates a new ICE connection
      *
@@ -584,7 +586,7 @@ private function getTurnCandidate(TurnInterface $turn, int $componentId): RTCIce
     private function getStun(string $address): StunInterface|false
     {
         try {
-            return Stun::create($this, $address, $this->logger);
+            return Stun::create($this, $address, $this->logger, $this->icePortRange);
         } catch (Throwable) {
             return false;
         }
@@ -2058,4 +2060,9 @@ public function setIceRole(IceRole $iceRole): void
     {
         $this->iceRole = $iceRole;
     }
+
+    public function setIcePortRange(?array $icePortRange): void
+    {
+        $this->icePortRange = $icePortRange;
+    }
 }

src/RTCIceGatherer.php

@@ -17,6 +17,7 @@
 use Throwable;
 use Webrtc\ICE\Enum\IceGatheringState;
 use Webrtc\ICE\Enum\IceRole;
+use Webrtc\ICE\Enum\TransportPolicyType;
 
 /**
  * The RTCIceGatherer is responsible for gathering ICE candidates on the local machine.
@@ -44,14 +45,25 @@ class RTCIceGatherer extends EventEmitter implements RTCIceGathererInterface
      *
      * @throws RandomException
      */
-    public function __construct(private readonly array $iceServes, IceRole $role = IceRole::Controlling, ?LoggerInterface $logger = null)
+    public function __construct(
+        private readonly array $iceServes,
+        ?array $icePortRange = null,
+        ?TransportPolicyType $transportPolicy = null,
+        IceRole $role = IceRole::Controlling,
+        ?LoggerInterface $logger = null
+    )
     {
         $protocolParser = new IceProtocolParser($iceServes);
         $this->iceConnection = new RTCIceConnection($protocolParser->getIceConnectionConfiguration(), $role);
+        $this->iceConnection->setIcePortRange($icePortRange);
 
         if ($logger) {
             $this->iceConnection->setLogger($logger);
         }
+
+        if ($transportPolicy) {
+            $this->iceConnection->setTransportPolicy($transportPolicy);
+        }
     }
 
     /**
@@ -70,10 +82,10 @@ public function getIceServes(): array
      * Changes state from 'new' to 'gathering', then to 'complete' after gathering is finished.
      * Emits a 'statechange' event on state transitions.
      *
-     * @throws RandomException
+     * @return void
      * @throws Throwable
      *
-     * @return void
+     * @throws RandomException
      */
     public function gather(): void
     {

tests/RTCIceTransportTest.php

@@ -107,10 +107,10 @@ public function testConstruct()
 
     public function testConnect()
     {
-        $gatherer1 = new RTCIceGatherer([],IceRole::Controlling);
+        $gatherer1 = new RTCIceGatherer([], role: IceRole::Controlling);
         $transport1 = new RTCIceTransport($gatherer1);
 
-        $gatherer2 = new RTCIceGatherer([], IceRole::Controlled);
+        $gatherer2 = new RTCIceGatherer([], role: IceRole::Controlled);
         $transport2 = new RTCIceTransport($gatherer2);
 
         $gatherer1->gather();
@@ -140,10 +140,10 @@ public function testConnect()
 
     public function testConnectFail()
     {
-        $gatherer1 = new RTCIceGatherer([],IceRole::Controlling);
+        $gatherer1 = new RTCIceGatherer([], role: IceRole::Controlling);
         $transport1 = new RTCIceTransport($gatherer1);
 
-        $gatherer2 = new RTCIceGatherer([], IceRole::Controlled);
+        $gatherer2 = new RTCIceGatherer([], role: IceRole::Controlled);
         $transport2 = new RTCIceTransport($gatherer2);
 
         $gatherer1->gather();
@@ -173,10 +173,10 @@ public function testConnectFail()
 
     public function testConnectThenConsentExpires()
     {
-        $gatherer1 = new RTCIceGatherer([],IceRole::Controlling);
+        $gatherer1 = new RTCIceGatherer([], role: IceRole::Controlling);
         $transport1 = new RTCIceTransport($gatherer1);
 
-        $gatherer2 = new RTCIceGatherer([], IceRole::Controlled);
+        $gatherer2 = new RTCIceGatherer([], role: IceRole::Controlled);
         $transport2 = new RTCIceTransport($gatherer2);
 
         $gatherer1->gather();