Viewing file:  TelnyxMock.php (2.58 KB) -rwxr-xr-x
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace Telnyx;
use \Symfony\Component\Process\Process;
class TelnyxMock
{
protected static $process = null;
protected static $port = -1;
const PATH_SPEC = __DIR__ . '/openapi/spec3.json';
const PATH_FIXTURES = __DIR__ . '/openapi/fixtures3.json';
/**
* Starts a telnyx-mock process with custom OpenAPI spec and fixtures files, if they exist.
*
* @return bool true if a telnyx-mock process was started, false otherwise.
*/
public static function start()
{
if (!file_exists(self::PATH_SPEC)) {
return false;
}
if (!is_null(static::$process) && static::$process->isRunning()) {
echo "telnyx-mock already running on port " . static::$port . "\n";
return true;
}
static::$port = static::findAvailablePort();
echo "Starting telnyx-mock on port " . static::$port . "...\n";
static::$process = new Process(join(' ', [
'telnyx-mock',
'-http-port',
static::$port,
'-spec',
self::PATH_SPEC,
'-fixtures',
self::PATH_FIXTURES,
]));
static::$process->start();
sleep(1);
if (static::$process->isRunning()) {
echo "Started telnyx-mock, PID = " . static::$process->getPid() . "\n";
} else {
die("telnyx-mock terminated early, exit code = " . static::$process->wait());
}
return true;
}
/**
* Stops the telnyx-mock process, if one was started. Otherwise do nothing.
*/
public static function stop()
{
if (is_null(static::$process) || !static::$process->isRunning()) {
return;
}
echo "Stopping telnyx-mock...\n";
static::$process->stop(0, SIGTERM);
static::$process->wait();
static::$process = null;
static::$port = -1;
echo "Stopped telnyx-mock\n";
}
/**
* Returns the port number used by the telnyx-mock process.
*
* @return int the port number used by telnyx-mock, or -1 if no telnyx-mock process was started
*/
public static function getPort()
{
return static::$port;
}
/**
* Finds a random available TCP port.
*
* @return int the port number
*/
private static function findAvailablePort()
{
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($sock, "localhost", 0);
$addr = null;
$port = -1;
socket_getsockname($sock, $addr, $port);
socket_close($sock);
return $port;
}
}
|