Add Windows support for "Curl" publisher (#80)

Author: keelerm84

.circleci/config.yml

@@ -1,5 +1,8 @@
 version: 2.1
 
+orbs:
+  win: circleci/[email protected]
+
 workflows:
   workflow:
     jobs:
@@ -12,8 +15,39 @@ workflows:
       - test-with-preinstalled-php:
          name: PHP 8.0
          docker-image: cimg/php:8.0
+      - test-on-windows
 
 jobs:
+  test-on-windows:
+    executor:
+      name: win/default
+      shell: powershell.exe
+
+    environment:
+      LD_INCLUDE_INTEGRATION_TESTS: 1
+
+    steps:
+      - checkout
+      - run:
+          name: install php and java support
+          command: choco install -y php composer javaruntime
+      - run:
+          name: download wiremock
+          command: Invoke-WebRequest -Uri https://repo1.maven.org/maven2/com/github/tomakehurst/wiremock-jre8-standalone/2.31.0/wiremock-jre8-standalone-2.31.0.jar -UseBasicParsing -OutFile wiremock.jar
+      - run:
+          name: start wiremock
+          background: true
+          command: java -jar ./wiremock.jar
+      - run:
+          name: wait for wiremock to be available
+          command: PowerShell -Command Start-Sleep -Seconds 5
+      - run:
+          name: install dependencies
+          command: composer install --no-progress
+      - run:
+          name: run tests
+          command: .\vendor\bin\phpunit
+
   test-with-preinstalled-php:
     parameters:
       docker-image:

src/LaunchDarkly/Impl/Integrations/CurlEventPublisher.php

@@ -33,6 +33,9 @@ class CurlEventPublisher implements EventPublisher
     /** @var int */
     private $_connectTimeout;
 
+    /** @var bool */
+    private $_isWindows;
+
     public function __construct(string $sdkKey, array $options = array())
     {
         $this->_sdkKey = $sdkKey;
@@ -56,16 +59,33 @@ public function __construct(string $sdkKey, array $options = array())
         }
 
         $this->_connectTimeout = $options['connect_timeout'];
+        $this->_isWindows = PHP_OS_FAMILY == 'Windows';
     }
 
     public function publish(string $payload): bool
     {
-        $args = $this->createArgs($payload);
+        if (!$this->_isWindows) {
+            $args = $this->createCurlArgs($payload);
+            return $this->makeCurlRequest($args);
+        }
+
+        $tmpfile = tempnam(sys_get_temp_dir(), 'ld-');
+        if ($tmpfile === false) {
+            return false;
+        }
+
+        if (file_put_contents($tmpfile, $payload) === false) {
+            return false;
+        };
+
+        $args = $this->createPowershellArgs($tmpfile);
+        $this->makePowershellRequest($args);
+
+        return true;
 
-        return $this->makeRequest($args);
     }
 
-    private function createArgs(string $payload): string
+    private function createCurlArgs(string $payload): string
     {
         $scheme = $this->_ssl ? "https://" : "http://";
         $args = " -X POST";
@@ -83,10 +103,48 @@ private function createArgs(string $payload): string
     /**
      * @psalm-suppress ForbiddenCode
      */
-    private function makeRequest(string $args): bool
+    private function makeCurlRequest(string $args): bool
     {
         $cmd = $this->_curl . " " . $args . ">> /dev/null 2>&1 &";
         shell_exec($cmd);
         return true;
     }
+
+    private function createPowershellArgs(string $payloadFile): string
+    {
+        $headers = [
+            'Content-Type' => 'application/json',
+            'Authorization' => $this->_sdkKey,
+            'User-Agent' => 'PHPClient/' . LDClient::VERSION,
+            'X-LaunchDarkly-Event-Schema' => EventPublisher::CURRENT_SCHEMA_VERSION,
+            'Accept' => 'application/json',
+        ];
+
+        $headerString = "";
+        foreach ($headers as $key => $value) {
+            $headerString .= sprintf("'%s'='%s';", $key, $value);
+        }
+
+        $scheme = $this->_ssl ? "https://" : "http://";
+        $args = " Invoke-WebRequest";
+        $args.= " -Method POST";
+        $args.= " -UseBasicParsing";
+        $args.= " -InFile $payloadFile";
+        $args.= " -H @{" . $headerString . "}";
+        $args.= " -Uri " . escapeshellarg($scheme . $this->_host . ":" . $this->_port . $this->_path . "/bulk");
+        $args.= " ; Remove-Item $payloadFile";
+
+        return $args;
+    }
+
+    /**
+     * @psalm-suppress ForbiddenCode
+     */
+    private function makePowershellRequest(string $args): bool
+    {
+        $cmd = base64_encode(iconv("UTF-8", "UTF-16LE", utf8_encode($args)));
+        shell_exec("start /B powershell.exe -encodedCommand $cmd > nul 2>&1");
+
+        return true;
+    }
 }