Use Rust FFI: Stub Server

pact-foundation · Mar 12, 2023 · 8a1f6db · 8a1f6db
1 parent 619cf39
commit 8a1f6db
Show file tree

Hide file tree

Showing 10 changed files with 583 additions and 102 deletions.
diff --git a/README.md b/README.md
@@ -385,13 +385,11 @@ If you would like to test with fixtures, you can use the `pact-stub-service` lik
 
 ```php
 $pactLocation             = __DIR__ . '/someconsumer-someprovider.json';
-$host                     = 'localhost';
 $port                     = 7201;
 $endpoint                 = 'test';
 
 $config = (new StubServerConfig())
-            ->setPactLocation($pactLocation)
-            ->setHost($host)
+            ->setFiles($pactLocation)
             ->setPort($port)
             ->setEndpoint($endpoint);
 

diff --git a/composer.json b/composer.json
@@ -28,7 +28,7 @@
         "amphp/process": "^1.1.1",
         "guzzlehttp/guzzle": "^6.5.8|^7.4.5",
         "phpunit/phpunit": ">=8.5.23 <10",
-        "tienvx/composer-downloads-plugin": "^1.1.0"
+        "tienvx/composer-downloads-plugin": "^1.2.0"
     },
     "require-dev": {
         "roave/security-advisories": "dev-latest",
@@ -77,10 +77,15 @@
                 "variables": {
                     "{$os}": "PHP_OS_FAMILY === 'Windows' ? 'win32' : (PHP_OS === 'Darwin' ? 'osx' : 'linux')",
                     "{$architecture}": "PHP_OS === 'Linux' ? '-x86_64' : ''",
-                    "{$extension}": "PHP_OS_FAMILY === 'Windows' ? 'zip' : 'tar.gz'"
+                    "{$extension}": "PHP_OS_FAMILY === 'Windows' ? 'zip' : 'tar.gz'",
+                    "{$keep}": "PHP_OS_FAMILY === 'Windows' ? 'pact-broker.bat' : 'pact-broker'"
                 },
                 "url": "https://github.com/pact-foundation/pact-ruby-standalone/releases/download/v{$version}/pact-{$version}-{$os}{$architecture}.{$extension}",
-                "path": "bin/pact-ruby-standalone"
+                "path": "bin/pact-ruby-standalone",
+                "ignore": [
+                    "bin/*",
+                    "!bin/{$keep}"
+                ]
             },
             "pact-ffi-headers": {
                 "version": "0.4.1",
@@ -97,6 +102,16 @@
                 },
                 "url": "https://github.com/pact-foundation/pact-reference/releases/download/libpact_ffi-v{$version}/{$prefix}-{$os}-{$architecture}.{$extension}.gz",
                 "path": "bin/pact-ffi-lib/pact.{$extension}"
+            },
+            "pact-stub-server": {
+                "version": "0.5.2",
+                "variables": {
+                    "{$os}": "PHP_OS === 'Darwin' ? 'osx' : strtolower(PHP_OS_FAMILY)",
+                    "{$extension}": "PHP_OS_FAMILY === 'Windows' ? '.exe' : ''"
+                },
+                "url": "https://github.com/pact-foundation/pact-stub-server/releases/download/v{$version}/pact-stub-server-{$os}-x86_64{$extension}.gz",
+                "path": "bin/pact-stub-server/pact-stub-server{$extension}",
+                "executable": true
             }
         }
     },

diff --git a/src/PhpPact/Standalone/Installer/Model/Scripts.php b/src/PhpPact/Standalone/Installer/Model/Scripts.php
@@ -40,19 +40,14 @@ public static function getLibrary(): string
      */
     public static function getStubService(): string
     {
-        return self::$destinationDir . '/bin/pact-ruby-standalone/bin/pact-stub-service' . self::getSuffix();
+        return self::$destinationDir . '/bin/pact-stub-server/pact-stub-server' . (PHP_OS_FAMILY === 'Windows' ? '.exe' : '');
     }
 
     /**
      * @return string
      */
     public static function getBroker(): string
     {
-        return self::$destinationDir . '/bin/pact-ruby-standalone/bin/pact-broker' . self::getSuffix();
-    }
-
-    private static function getSuffix(): string
-    {
-        return (PHP_OS_FAMILY === 'Windows' ? '.bat' : '');
+        return self::$destinationDir . '/bin/pact-ruby-standalone/bin/pact-broker' . (PHP_OS_FAMILY === 'Windows' ? '.bat' : '');
     }
 }
diff --git a/src/PhpPact/Standalone/StubService/Service/StubServerHttpService.php b/src/PhpPact/Standalone/StubService/Service/StubServerHttpService.php
@@ -17,12 +17,12 @@ class StubServerHttpService implements StubServerHttpServiceInterface
     /**
      * @var ClientInterface
      */
-    private $client;
+    private ClientInterface $client;
 
     /**
      * @var StubServerConfigInterface
      */
-    private $config;
+    private StubServerConfigInterface $config;
 
     /**
      * StubServerHttpService constructor.

diff --git a/src/PhpPact/Standalone/StubService/StubServer.php b/src/PhpPact/Standalone/StubService/StubServer.php
@@ -2,6 +2,7 @@
 
 namespace PhpPact\Standalone\StubService;
 
+use Amp\Process\ProcessException;
 use Exception;
 use PhpPact\Standalone\Installer\Model\Scripts;
 use PhpPact\Standalone\Runner\ProcessRunner;
@@ -13,14 +14,14 @@
 class StubServer
 {
     /** @var StubServerConfigInterface */
-    private $config;
+    private StubServerConfigInterface $config;
 
     /** @var ProcessRunner */
-    private $processRunner;
+    private ProcessRunner $processRunner;
 
     public function __construct(StubServerConfigInterface $config)
     {
-        $this->config         = $config;
+        $this->config = $config;
     }
 
     /**
@@ -32,7 +33,7 @@ public function __construct(StubServerConfigInterface $config)
      *
      * @return int process ID of the started Stub Server
      */
-    public function start($wait = 1): int
+    public function start(int $wait = 1): int
     {
         $this->processRunner = new ProcessRunner(Scripts::getStubService(), $this->getArguments());
 
@@ -45,6 +46,8 @@ public function start($wait = 1): int
     /**
      * Stop the Stub Server process.
      *
+     * @throws ProcessException
+     *
      * @return bool Was stopping successful?
      */
     public function stop(): bool
@@ -61,12 +64,64 @@ private function getArguments(): array
     {
         $results = [];
 
-        $results[] = $this->config->getPactLocation();
-        $results[] = "--host={$this->config->getHost()}";
-        $results[] = "--port={$this->config->getPort()}";
+        if ($this->config->getBrokerUrl() !== null) {
+            $results[] = "--broker-url={$this->config->getBrokerUrl()}";
+        }
+
+        foreach ($this->config->getDirs() as $dir) {
+            $results[] = "--dir={$dir}";
+        }
+
+        if ($this->config->getExtension() !== null) {
+            $results[] = "--extension={$this->config->getExtension()}";
+        }
+
+        foreach ($this->config->getFiles() as $file) {
+            $results[] = "--file={$file}";
+        }
+
+        if ($this->config->getLogLevel() !== null) {
+            $results[] = "--loglevel={$this->config->getLogLevel()}";
+        }
+
+        if ($this->config->getPort() !== null) {
+            $results[] = "--port={$this->config->getPort()}";
+        }
+
+        if ($this->config->getProviderState() !== null) {
+            $results[] = "--provider-state={$this->config->getProviderState()}";
+        }
+
+        if ($this->config->getProviderStateHeaderName() !== null) {
+            $results[] = "--provider-state-header-name={$this->config->getProviderStateHeaderName()}";
+        }
+
+        if ($this->config->getToken() !== null) {
+            $results[] = "--token={$this->config->getToken()}";
+        }
+
+        foreach ($this->config->getUrls() as $url) {
+            $results[] = "--url={$url}";
+        }
+
+        if ($this->config->getUser() !== null) {
+            $results[] = "--user={$this->config->getUser()}";
+        }
+
+        if ($this->config->isCors()) {
+            $results[] = '--cors';
+        }
+
+        if ($this->config->isCorsReferer()) {
+            $results[] = '--cors-referer';
+        }
+
+        if ($this->config->isEmptyProviderState()) {
+            $results[] = '--empty-provider-state';
+        }
 
-        if ($this->config->getLog() !== null) {
-            $results[] = "--log={$this->config->getLog()}";
+        if ($this->config->isInsecureTls()) {
+            $results[] = '--insecure-tls';
         }
 
         return $results;