Merge pull request #1 from rtckit/v0.0.2

v0.0.2
rtckit · Feb 2, 2023 · b1ff9e1 · b1ff9e1
2 parents fa4e348 + 03adf19
commit b1ff9e1
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 5 deletions.
diff --git a/composer.json b/composer.json
@@ -1,7 +1,7 @@
 {
     "name": "rtckit/ficore",
     "description": "FreeSWITCH Integration Core",
-    "version": "0.0.1",
+    "version": "0.0.2",
     "keywords": [
         "telecommunications",
         "voip",

diff --git a/src/Command/Channel/Originate/Handler.php b/src/Command/Channel/Originate/Handler.php
@@ -16,7 +16,7 @@
     AbstractHandler,
     RequestInterface,
 };
-
+use RTCKit\FiCore\Exception\CoreException;
 use RTCKit\FiCore\Switch\{
     Core,
     HangupCauseEnum,
@@ -37,7 +37,13 @@ public function execute(RequestInterface $request): PromiseInterface
         $response->originateJobs = [];
 
         if (!isset($request->core)) {
-            $request->core = $this->app->allocateCore();
+            try {
+                $request->core = $this->app->allocateCore();
+            } catch (CoreException $t) {
+                $response->successful = false;
+
+                return resolve($response);
+            }
         }
 
         if ($enterprise) {

diff --git a/src/Command/Conference/Record/Handler.php b/src/Command/Conference/Record/Handler.php
@@ -25,6 +25,7 @@ public function execute(RequestInterface $request): PromiseInterface
 
         $response = new Response();
         $response->successful = true;
+        $response->medium = $request->medium;
 
         return $request->conference->core->client->api(
             (new ESL\Request\Api())->setParameters("conference {$request->conference->room} {$request->action->value} {$request->medium}")

diff --git a/src/Plan/Consumer.php b/src/Plan/Consumer.php
@@ -503,9 +503,9 @@ public function pushToEventQueue(Channel $channel, ?Event $event = null): void
     public function consume(Channel $channel, string $sequence, ?AbstractSignal $signal = null): PromiseInterface
     {
         return $this->app->planProducer->produce($channel, $sequence, $signal)
-            ->then(function (array $elements) use ($channel): PromiseInterface {
+            ->then(function (?array $elements) use ($channel): PromiseInterface {
                 /** @var list<AbstractElement> $elements */
-                if (!count($elements)) {
+                if (empty($elements)) {
                     return resolve();
                 }