Modified server to use process and to support windows. Renamed classes to have uppercase M in Wiremock word

Author: mcustiel

src/Wiremock.php src/WireMock.phpsrc/Wiremock.php renamed to src/WireMock.php

@@ -1,38 +1,38 @@
 <?php
 namespace Codeception\Extension;
 
-class Wiremock extends \Codeception\Platform\Extension
+class WireMock extends \Codeception\Platform\Extension
 {
-    const DEFAULT_LOGS_PATH = '/tmp/codeceptionWiremock/logs/';
+    const DEFAULT_LOGS_PATH = '/tmp/codeceptionWireMock/logs/';
 
     /**
      *
-     * @var WiremockDownloader
+     * @var WireMockDownloader
      */
     private $downloader;
     /**
      *
-     * @var WiremockServer
+     * @var WireMockServer
      */
     private $server;
     /**
      *
-     * @var WiremockArguments
+     * @var WireMockArguments
      */
     private $argumentsManager;
 
     public function __construct(
         $config,
         $options,
-        WiremockDownloader $downloader = null,
-        WiremockServer $server = null,
-        WiremockArguments $argumentsManager = null
+        WireMockDownloader $downloader = null,
+        WireMockServer $server = null,
+        WireMockArguments $argumentsManager = null
     ) {
         parent::__construct($config, $options);
 
-        $this->initWiremockDownloader($downloader);
-        $this->initWiremockServer($server);
-        $this->initWiremockArgumentsManager($argumentsManager);
+        $this->initWireMockDownloader($downloader);
+        $this->initWireMockServer($server);
+        $this->initWireMockArgumentsManager($argumentsManager);
 
         $this->config = $this->argumentsManager->sanitize($this->config);
 
@@ -42,44 +42,44 @@ public function __construct(
             $this->server->start(
                 $this->getJarPath(),
                 $this->getLogsPath(),
-                $this->mapConfigToWiremockArguments($this->config)
+                $this->mapConfigToWireMockArguments($this->config)
             );
             $host = 'localhost';
             sleep($this->config['start-delay']);
         }
-        WiremockConnection::setConnection(\WireMock\Client\WireMock::create($host, $this->config['port']));
+        WireMockConnection::setConnection(\WireMock\Client\WireMock::create($host, $this->config['port']));
     }
 
-    private function initWiremockServer($server)
+    private function initWireMockServer($server)
     {
         if ($server === null) {
-            $this->server = new WiremockServer();
+            $this->server = new WireMockServer();
         } else {
             $this->server = $server;
         }
     }
 
-    private function initWiremockDownloader($downloader)
+    private function initWireMockDownloader($downloader)
     {
         if ($downloader === null) {
-            $this->downloader = new WiremockDownloader();
+            $this->downloader = new WireMockDownloader();
         } else {
             $this->downloader = $downloader;
         }
     }
 
-    private function initWiremockArgumentsManager($argumentsManager)
+    private function initWireMockArgumentsManager($argumentsManager)
     {
         if ($argumentsManager === null) {
-            $this->argumentsManager = new WiremockArguments();
+            $this->argumentsManager = new WireMockArguments();
         } else {
             $this->argumentsManager = $argumentsManager;
         }
     }
 
     public function __destruct()
     {
-        $this->server->stop($this->getJarPath(), $this->mapConfigToWiremockArguments($this->config));
+        $this->server->stop();
     }
 
     private function getJarPath()
@@ -123,7 +123,7 @@ private function checkJarExists($jar)
         }
     }
 
-    private function mapConfigToWiremockArguments($config)
+    private function mapConfigToWireMockArguments($config)
     {
         return $this->argumentsManager->generateArgumentsString($config);
     }

src/WiremockArguments.php src/WireMockArguments.phpsrc/WiremockArguments.php renamed to src/WireMockArguments.php

@@ -1,7 +1,7 @@
 <?php
 namespace Codeception\Extension;
 
-class WiremockArguments
+class WireMockArguments
 {
     private $map = [
         'root-dir' => true,

src/WiremockConnection.php src/WireMockConnection.phpsrc/WiremockConnection.php renamed to src/WireMockConnection.php

@@ -1,7 +1,7 @@
 <?php
 namespace Codeception\Extension;
 
-class WiremockConnection
+class WireMockConnection
 {
     /**
      * @var \WireMock\Client\WireMock

src/WiremockDownloader.php src/WireMockDownloader.phpsrc/WiremockDownloader.php renamed to src/WireMockDownloader.php

@@ -1,9 +1,9 @@
 <?php
 namespace Codeception\Extension;
 
-class WiremockDownloader
+class WireMockDownloader
 {
-    const DESTINATION_PATH = '/tmp/codeceptionWiremock/jars/';
+    const DESTINATION_PATH = '/tmp/codeceptionWireMock/jars/';
 
     public function downloadAndGetLocalJarPath($version)
     {

src/WireMockServer.php

@@ -0,0 +1,62 @@
+<?php
+namespace Codeception\Extension;
+
+class WireMockServer
+{
+    const LOG_FILE_NAME = 'wiremock.out';
+
+    /**
+     * @var resource
+     */
+    private $process;
+    /**
+     * @var resource[]
+     */
+    private $pipes;
+
+    public function start($jarPath, $logsPath, $arguments)
+    {
+        if ($this->process !== null) {
+            throw new \Exception('The server is already running');
+        }
+        $logFile = rtrim($logsPath, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR . self::LOG_FILE_NAME;
+        $descriptors = [
+            ['pipe', 'r'],
+            ['file', $logFile, 'w'],
+            ['file', $logFile, 'a'],
+        ];
+        $this->process = proc_open(
+            $this->getCommandPrefix() . "java -jar {$jarPath}{$arguments}",
+            $descriptors,
+            $this->pipes
+        );
+        $this->checkProcessIsRunning();
+    }
+
+    private function checkProcessIsRunning()
+    {
+        if (!is_resource($this->process)) {
+            throw new \Exception('Could not start local wiremock server');
+        }
+    }
+
+    public function stop()
+    {
+        if ($this->process !== null) {
+            foreach ($this->pipes AS $pipe) {
+                if (is_resource($pipe)) {
+                    fclose($pipe);
+                }
+            }
+            proc_terminate($this->process, SIGINT);
+        }
+    }
+
+    private function getCommandPrefix()
+    {
+        if (PHP_OS == 'WIN32' || PHP_OS == 'WINNT' || PHP_OS == 'Windows') {
+            return 'exec ';
+        }
+        return '';
+    }
+}

src/WiremockServer.php

@@ -12,9 +12,9 @@ settings:
 extensions:
     enabled:
         - Codeception\Extension\RunFailed
-        - Codeception\Extension\Wiremock
+        - Codeception\Extension\WireMock
     config:
-        Codeception\Extension\Wiremock:
+        Codeception\Extension\WireMock:
             download-version: 1.57
             root-dir: /tmp
             port: 18080