Spaces:
No application file
No application file
File size: 4,173 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 |
<?php
namespace MauticPlugin\MauticCrmBundle\Api;
use Mautic\EmailBundle\Helper\MailHelper;
use Mautic\PluginBundle\Exception\ApiErrorException;
use MauticPlugin\MauticCrmBundle\Integration\HubspotIntegration;
/**
* @property HubspotIntegration $integration
*/
class HubspotApi extends CrmApi
{
protected $requestSettings = [
'encode_parameters' => 'json',
];
protected function request($operation, $parameters = [], $method = 'GET', $object = 'contacts')
{
if ('oauth2' === $this->integration->getAuthenticationType()) {
$url = sprintf('%s/%s/%s/', $this->integration->getApiUrl(), $object, $operation);
} else {
$url = sprintf('%s/%s/%s/?hapikey=%s', $this->integration->getApiUrl(), $object, $operation, $this->integration->getHubSpotApiKey());
}
$request = $this->integration->makeRequest($url, $parameters, $method, $this->requestSettings);
if (isset($request['status']) && 'error' == $request['status']) {
$message = $request['message'];
if (isset($request['validationResults'])) {
$message .= " \n ".print_r($request['validationResults'], true);
}
if (isset($request['validationResults'][0]['error']) && 'PROPERTY_DOESNT_EXIST' == $request['validationResults'][0]['error']) {
$this->createProperty($request['validationResults'][0]['name']);
$this->request($operation, $parameters, $method, $object);
} else {
throw new ApiErrorException($message);
}
}
if (isset($request['error']) && 401 == $request['error']['code']) {
$response = json_decode($request['error']['message'] ?? null, true);
if (isset($response)) {
throw new ApiErrorException($response['message'], $request['error']['code']);
} else {
throw new ApiErrorException('401 Unauthorized - Error with Hubspot API', $request['error']['code']);
}
}
if (isset($request['error'])) {
throw new ApiErrorException($request['error']['message']);
}
return $request;
}
/**
* @return mixed
*/
public function getLeadFields($object = 'contacts')
{
if ('company' == $object) {
$object = 'companies'; // hubspot company object name
}
return $this->request('v2/properties', [], 'GET', $object);
}
/**
* Creates Hubspot lead.
*
* @return mixed
*/
public function createLead(array $data, $lead, $updateLink = false)
{
/*
* As Hubspot integration requires a valid email
* If the email is not valid we don't proceed with the request
*/
$email = $data['email'];
$result = [];
// Check if the is a valid email
MailHelper::validateEmail($email);
// Format data for request
$formattedLeadData = $this->integration->formatLeadDataForCreateOrUpdate($data, $lead, $updateLink);
if ($formattedLeadData) {
$result = $this->request('v1/contact/createOrUpdate/email/'.$email, $formattedLeadData, 'POST');
}
return $result;
}
/**
* gets Hubspot contact.
*
* @return mixed
*/
public function getContacts($params = [])
{
return $this->request('v1/lists/recently_updated/contacts/recent?', $params, 'GET', 'contacts');
}
/**
* gets Hubspot company.
*
* @return mixed
*/
public function getCompanies($params, $id)
{
if ($id) {
return $this->request('v2/companies/'.$id, $params, 'GET', 'companies');
}
return $this->request('v2/companies/recent/modified', $params, 'GET', 'companies');
}
/**
* @param string $object
*
* @return mixed|string
*/
public function createProperty($propertyName, $object = 'properties')
{
return $this->request('v1/contacts/properties', ['name' => $propertyName, 'groupName' => 'contactinformation', 'type' => 'string'], 'POST', $object);
}
}
|