opensourcepos/app/Plugins/MailchimpPlugin/Libraries/MailchimpConnector.php

<?php

namespace App\Plugins\MailchimpPlugin\Libraries;

/**
 * MailChimp API v3 REST client Connector
 *
 * Interface for communicating with the Mailchimp v3 API
 *
 * Inspired by the work of:
 *   - Rajitha Bandara: https://github.com/rajitha-bandara/ci-mailchimp-v3-rest-client
 *   - Stefan Ashwell: https://github.com/stef686/codeigniter-mailchimp-api-v3
 */
class MailchimpConnector
{
    private string $apiKey = '';
    private string $apiEndpoint = 'https://<dc>.api.mailchimp.com/3.0/';

    public function __construct(string $apiKey)
    {
        $this->apiKey = $apiKey;

        if (!empty($this->apiKey)) {
            // Replace <dc> with correct datacenter obtained from the last part of the api key
            $strings = explode('-', $this->apiKey);
            if (is_array($strings) && !empty($strings[1])) {
                $this->apiEndpoint = str_replace('<dc>', $strings[1], $this->apiEndpoint);
            }
        }
    }

    /**
     * Call an API method. Every request needs the API key
     * @param string $httpVerb The HTTP method to be used
     * @param string $method The API method to call, e.g. 'lists/list'
     * @param array $args An array of arguments to pass to the method. Will be json-encoded for you.
     * @return true|array|false true on HTTP 204 (no content), decoded JSON array on all other responses
     *                          including API errors (RFC 7807: check $result['status'] >= 400 to detect errors).
     *                          false on curl transport failure or missing API key.
     */
    public function call(string $method, string $httpVerb = 'POST', array $args = []): bool|array
    {
        return !empty($this->apiKey)
            ? $this->request($httpVerb, $method, $args)
            : false;
    }

    /**
     * Builds the request URL based on the request type
     * @param  string $httpVerb The HTTP method to be used
     * @param  string $method   The API method to be called
     * @param  array  $args     Assoc array of parameters to be passed
     * @return string           Request URL
     */
    private function buildRequestUrl(string $method, string $httpVerb = 'POST', array $args = []): string
    {
        return $httpVerb == 'GET'
            ? $this->apiEndpoint . $method . '?' . http_build_query($args)
            : $this->apiEndpoint . $method;
    }

    /**
     * Performs the underlying HTTP request.
     * @param string $httpVerb The HTTP method to be used
     * @param string $method The API method to be called
     * @param array $args Associative array of parameters to be passed
     * @return true|array|false true on HTTP 204 (no content), decoded JSON array for all other HTTP responses
     *                          including 4xx/5xx API errors (RFC 7807: keys 'status', 'title', 'detail').
     *                          Callers must inspect $result['status'] >= 400 to detect API errors.
     *                          false only on curl transport failure or unparseable non-204 response.
     */
    private function request(string $httpVerb, string $method, array $args = []): bool|array
    {
        if (($ch = curl_init()) === false) {
            return false;
        }

        curl_setopt($ch, CURLOPT_URL, $this->buildRequestUrl($method, $httpVerb, $args));
        curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
        curl_setopt($ch, CURLOPT_USERPWD, "user:" . $this->apiKey);
        curl_setopt($ch, CURLOPT_USERAGENT, 'PHP-MCAPI/3.0');
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, 10);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($args));
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $httpVerb);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($response === false) {
            return false;
        }

        if ($httpCode === 204) {
            return true;
        }

        $decoded = json_decode($response, true);
        return $decoded ?? false;
    }
}