芝麻web文件管理V1.00

编辑当前文件:/home/royashxg/www/wp-content/plugins/fluentformpro/src/Integrations/Hubspot/API.php

<?php

namespace FluentFormPro\Integrations\Hubspot;

use FluentForm\Framework\Helpers\ArrayHelper;

if (!defined('ABSPATH')) {
    exit; // Exit if accessed directly.
}

class API
{
    protected $apiUrl = 'https://api.hubapi.com/';

protected $apiKey = null;
    protected $accessToken = null;

public function __construct($apiKey = null, $accessToken = null)
    {
        $this->apiKey = $apiKey;
        $this->accessToken = $accessToken;
    }

public function default_options()
    {
        return array(
            'hapikey' => $this->apiKey
        );
    }

public function make_request($action, $options = array(), $method = 'GET')
    {
        /* Build request options string. */
        $request_options = $this->default_options();
        $request_options = wp_parse_args($options, $request_options);

$options_string = http_build_query($request_options);
        
        /* Build request URL. */
        
        $request_url = $this->apiUrl . $action . '?' . $options_string;
        
        if ($this->accessToken) {
            $request_url = $this->apiUrl . $action;
        }

/* Execute request based on method. */
        switch ($method) {
            case 'POST':
                $args = array(
                    'body'    => json_encode($options),
                    'headers' => [
                        'Content-Type' => 'application/json'
                    ]
                );
                if ($this->accessToken) {
                    $args['headers']['Authorization'] = 'Bearer ' . $this->accessToken;
                }
                $response = wp_remote_post($request_url, $args);
                break;
            case 'GET':
                $args = [];
                if ($this->accessToken) {
                    $args['headers'] = [
                        'Content-Type'  => 'application/json',
                        'Authorization' => 'Bearer ' . $this->accessToken,
                    ];
                }
                $response = wp_remote_get($request_url, $args);
                break;
        }

/* If WP_Error, die. Otherwise, return decoded JSON. */
        if (is_wp_error($response)) {
            return new \WP_Error(400, $response->get_error_message());
        }

return \json_decode($response['body'], true);
    }

/**
     * Test the provided API credentials.
     *
     * @access public
     * @return bool
     */
    public function auth_test()
    {
        return $this->make_request('contacts/v1/lists/all/contacts/all', [], 'GET');
    }

public function subscribe($listId, $values, $updateContact = false)
    {
        $values = array_filter($values);
        $properties = [];
        foreach ($values as $property => $value) {
            $properties[$property] = [
                'property' => $property,
                'value'    => $value
            ];
        }

$properties = [
            'properties' => array_values($properties)
        ];
        if ($updateContact) {
            $response = $this->make_request('contacts/v1/contact/createOrUpdate/email/' . $values['email'], $properties, 'POST');
        } else {
            $response = $this->make_request('contacts/v1/contact/', $properties, 'POST');
        }

if (is_wp_error($response)) {
            return $response;
        }

if (!empty($response['error'])) {
            return new \WP_Error('api_error', $response['error']);
        }

if ('error' == ArrayHelper::get($response, 'status')) {
            return new \WP_Error('error', ArrayHelper::get($response, 'message', 'Values were not valid'));
        }

if (!empty($response['error']) && $response['error'] == 'CONTACT_EXISTS') {
            $contactId = $response['identityProfile']['vid'];
        } else {
            $contactId = $response['vid'];
        }

$data = [
            'vids' => [$contactId]
        ];
        // We have the contact ID now. Let's add the list to that contact
        $updateResponse = $this->make_request('contacts/v1/lists/' . $listId . '/add', $data, 'POST');

if (is_wp_error($updateResponse)) {
            return $updateResponse;
        }

if (!empty($updateResponse['error'])) {
            return new \WP_Error('api_error', $updateResponse['error']);
        } elseif (!$updateResponse) {
            return new \WP_Error('api_error', 'HubSpot API Request Failed');
        }

return $contactId;
    }

/**
     * Get all Forms in the system.
     *
     * @access public
     * @return array
     */
    public function getLists()
    {
        $response = $this->make_request('contacts/v1/lists/static', array(), 'GET');

if (is_wp_error($response)) {
            return [];
        }

if (!empty($response['lists'])) {
            return $response['lists'];
        }

return [];
    }

/**
     * Get all Tags in the system.
     *
     * @access public
     * @return array
     */
    public function getTags()
    {
        $response = $this->make_request('tags', array(), 'GET');

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

if (empty($response['error'])) {
            return $response['tags'];
        }

return false;
    }
	public function getAllFields()
	{
		$lists = $this->make_request('contacts/v1/properties', array(), 'GET');
        if (is_wp_error($lists)) {
            return [];
        }

$fields = array_filter($lists, function ($item) {
		    return ArrayHelper::get($item, 'formField') && ArrayHelper::get($item, 'hubspotDefined');
		});

return $fields;
	}

public function getCustomFields()
    {
        $lists = $this->make_request('contacts/v1/properties', array(), 'GET');

if (is_wp_error($lists)) {
            return [];
        }
        $customFields = array_filter($lists, function ($item) {
            return empty($item['hubspotDefined']);
        });

return $customFields;
    }

}