# wpvr/8.5.39/vendor/posthog/posthog-php/lib/Consumer/ForkCurl.php

WPVR – 360 Panorama viewer and Virtual Tour Builder for WordPress, version 8.5.39. 109 lines.

- Page: https://pluginprobe.com/plugins/wpvr/8.5.39/code/vendor/posthog/posthog-php/lib/Consumer/ForkCurl.php
- Raw: https://pluginprobe.com/plugins/wpvr/8.5.39/raw/vendor/posthog/posthog-php/lib/Consumer/ForkCurl.php
- Modified: 2025-08-27T09:45:30+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/wpvr/8.5.39/code/vendor/posthog/posthog-php/lib/Consumer/ForkCurl.php#L10-L20`.

```php
<?php

namespace PostHog\Consumer;

use PostHog\QueueConsumer;

class ForkCurl extends QueueConsumer
{
    protected $type = "ForkCurl";

    /**
     * Creates a new queued fork consumer which queues fork and identify
     * calls before adding them to
     * @param string $apiKey
     * @param array $options
     *     boolean  "debug" - whether to use debug output, wait for response.
     *     number   "max_queue_size" - the max size of messages to enqueue
     *     number   "batch_size" - how many messages to send in a single request
     */
    public function __construct($apiKey, $options = array())
    {
        parent::__construct($apiKey, $options);
    }

    /**
     * Define getter method for consumer type
     *
     * @return string
     */
    public function getConsumer()
    {
        return $this->type;
    }

    /**
     * Make an async request to our API. Fork a curl process, immediately send
     * to the API. If debug is enabled, we wait for the response.
     * @param array $messages array of all the messages to send
     * @return boolean whether the request succeeded
     */
    public function flushBatch($messages)
    {
        $body = $this->payload($messages);
        $payload = json_encode($body);

        // Escape for shell usage.
        $payload = escapeshellarg($payload);

        $protocol = $this->ssl() ? "https://" : "http://";

        $path = "/batch/";
        $url = $protocol . $this->host . $path;

        $cmd = "curl -X POST -H 'Content-Type: application/json'";

        $tmpfname = "";
        if ($this->compress_request) {
            // Compress request to file
            $tmpfname = tempnam("/tmp", "forkcurl_");
            $cmd2 = "echo " . $payload . " | gzip > " . $tmpfname;
            exec($cmd2, $output, $exit);

            if (0 != $exit) {
                $this->handleError($exit, $output);
                return false;
            }

            $cmd .= " -H 'Content-Encoding: gzip'";

            $cmd .= " --data-binary '@" . $tmpfname . "'";
        } else {
            $cmd .= " -d " . $payload;
        }

        $cmd .= " '" . $url . "'";

        // Verify message size is below than 32KB
        if (strlen($payload) >= 32 * 1024) {
            if ($this->debug()) {
                $msg = "Message size is larger than 32KB";
                error_log("[PostHog][" . $this->type . "] " . $msg);
            }

            return false;
        }

        // Send user agent in the form of {library_name}/{library_version} as per RFC 7231.
        $libName = $messages[0]['library'];
        $libVersion = $messages[0]['library_version'];
        $cmd .= " -H 'User-Agent: ${libName}/${libVersion}'";

        if (!$this->debug()) {
            $cmd .= " > /dev/null 2>&1 &";
        }

        exec($cmd, $output, $exit);

        if (0 != $exit) {
            $this->handleError($exit, $output);
        }

        if ($tmpfname != "") {
            unlink($tmpfname);
        }

        return 0 == $exit;
    }
}

```