File manager

File manager - Edit - /home/palg2351/public_html/wp-content/plugins/bit-integrations/includes/Actions/ZohoDesk/ZohoDeskController.php

Back
<?php /** * ZohoDesk Integration / namespace BitCode\FI\Actions\ZohoDesk; use WP_Error; use BitCode\FI\Flow\FlowController; use BitCode\FI\Core\Util\HttpHelper; /* * Provide functionality for ZohoCrm integration / class ZohoDeskController { private $_integrationID; public function __construct($integrationID) { $this->_integrationID = $integrationID; } /* * Process ajax request for generate_token * * @param mixed $requestsParams * * @return JSON zoho crm api response and status / public static function generateTokens($requestsParams) { if (empty($requestsParams->{'accounts-server'}) \|\| empty($requestsParams->dataCenter) \|\| empty($requestsParams->clientId) \|\| empty($requestsParams->clientSecret) \|\| empty($requestsParams->redirectURI) \|\| empty($requestsParams->code) ) { wp_send_json_error( __( 'Requested parameter is empty', 'bit-integrations' ), 400 ); } $apiEndpoint = urldecode($requestsParams->{'accounts-server'}) . '/oauth/v2/token'; $requestParams = [ 'grant_type' => 'authorization_code', 'client_id' => $requestsParams->clientId, 'client_secret' => $requestsParams->clientSecret, 'redirect_uri' => urldecode($requestsParams->redirectURI), 'code' => $requestsParams->code ]; $apiResponse = HttpHelper::post($apiEndpoint, $requestParams); if (is_wp_error($apiResponse) \|\| !empty($apiResponse->error)) { wp_send_json_error( empty($apiResponse->error) ? 'Unknown' : $apiResponse->error, 400 ); } $apiResponse->generates_on = time(); wp_send_json_success($apiResponse, 200); } public static function refreshOrganizations($queryParams) { if (empty($queryParams->tokenDetails) \|\| empty($queryParams->dataCenter) \|\| empty($queryParams->clientId) \|\| empty($queryParams->clientSecret) ) { wp_send_json_error( __( 'Requested parameter is empty', 'bit-integrations' ), 400 ); } $response = []; if ((\intval($queryParams->tokenDetails->generates_on) + (55 60)) < time()) { $response['tokenDetails'] = self::refreshAccessToken($queryParams); } $organizationsMetaApiEndpoint = "https://desk.zoho.{$queryParams->dataCenter}/api/v1/organizations"; $authorizationHeader['Authorization'] = "Zoho-oauthtoken {$queryParams->tokenDetails->access_token}"; $organizationsMetaResponse = HttpHelper::get($organizationsMetaApiEndpoint, null, $authorizationHeader); if (!is_wp_error($organizationsMetaResponse)) { $allOrganizations = []; $organizations = $organizationsMetaResponse->data; if (\count($organizations) > 0) { foreach ($organizations as $organization) { $allOrganizations[$organization->companyName] = (object) [ 'orgId' => $organization->id, 'portalName' => $organization->companyName ]; } } uksort($allOrganizations, 'strnatcasecmp'); $response['organizations'] = $allOrganizations; } else { wp_send_json_error( empty($organizationsMetaResponse->data) ? 'Unknown' : $organizationsMetaResponse->error, 400 ); } if (!empty($response['tokenDetails']) && !empty($queryParams->id)) { self::saveRefreshedToken($queryParams->formID, $queryParams->id, $response['tokenDetails'], $response['lists']); } wp_send_json_success($response, 200); // } else { // wp_send_json_error( // __( // 'Token expired', // 'bit-integrations' // ), // 401 // ); // } } /** * Process ajax request for refresh crm modules * * @param mixed $queryParams * * @return JSON crm module data / public static function refreshDepartments($queryParams) { if (empty($queryParams->tokenDetails) \|\| empty($queryParams->dataCenter) \|\| empty($queryParams->clientId) \|\| empty($queryParams->clientSecret) \|\| empty($queryParams->orgId) ) { wp_send_json_error( __( 'Requested parameter is empty', 'bit-integrations' ), 400 ); } $response = []; if ((\intval($queryParams->tokenDetails->generates_on) + (55 60)) < time()) { $response['tokenDetails'] = self::refreshAccessToken($queryParams); } $departmentsMetaApiEndpoint = "https://desk.zoho.{$queryParams->dataCenter}/api/v1/departments?isEnabled=true&limit=100"; $authorizationHeader['orgId'] = "{$queryParams->orgId}"; $authorizationHeader['Authorization'] = "Zoho-oauthtoken {$queryParams->tokenDetails->access_token}"; $departmentsMetaResponse = HttpHelper::get($departmentsMetaApiEndpoint, null, $authorizationHeader); if (!is_wp_error($departmentsMetaResponse)) { $allDepartments = []; $departments = $departmentsMetaResponse->data; if (\count($departments) > 0) { foreach ($departments as $department) { $allDepartments[$department->name] = (object) [ 'departmentId' => $department->id, 'departmentName' => $department->name ]; } } uksort($allDepartments, 'strnatcasecmp'); $response['departments'] = $allDepartments; } else { wp_send_json_error( empty($departmentsMetaResponse->data) ? 'Unknown' : $departmentsMetaResponse->error, 400 ); } if (!empty($response['tokenDetails']) && !empty($queryParams->id)) { self::saveRefreshedToken($queryParams->formID, $queryParams->id, $response['tokenDetails'], $response['lists']); } wp_send_json_success($response, 200); } /** * Process ajax request for refresh crm layouts * * @param object $queryParams Params to fetch fields * * @return JSON crm layout data / public static function refreshFields($queryParams) { if (empty($queryParams->tokenDetails) \|\| empty($queryParams->dataCenter) \|\| empty($queryParams->clientId) \|\| empty($queryParams->clientSecret) \|\| empty($queryParams->orgId) ) { wp_send_json_error( __( 'Requested parameter is empty', 'bit-integrations' ), 400 ); } $response = []; if ((\intval($queryParams->tokenDetails->generates_on) + (55 60)) < time()) { $response['tokenDetails'] = self::refreshAccessToken($queryParams); } $fieldsMetaApiEndpoint = "https://desk.zoho.{$queryParams->dataCenter}/api/v1/organizationFields?module=tickets"; $authorizationHeader['orgId'] = "{$queryParams->orgId}"; $authorizationHeader['Authorization'] = "Zoho-oauthtoken {$queryParams->tokenDetails->access_token}"; $fieldsMetaResponse = HttpHelper::get($fieldsMetaApiEndpoint, null, $authorizationHeader); if (!is_wp_error($fieldsMetaResponse)) { $fields = $fieldsMetaResponse->data; if (\count($fields) > 0) { $response['fields']['Contact Name - Last Name'] = (object) [ 'apiName' => 'lastName', 'displayLabel' => __('Contact Name - Last Name', 'bit-integrations'), 'isCustomField' => false, 'required' => true ]; $response['fields']['Contact Name - First Name'] = (object) [ 'apiName' => 'firstName', 'displayLabel' => __('Contact Name - First Name', 'bit-integrations'), 'isCustomField' => false, 'required' => false ]; $response['required'][] = 'lastName'; foreach ($fields as $field) { if ($field->apiName === 'contactId' \|\| $field->apiName === 'assigneeId') { continue; } $response['fields'][$field->displayLabel] = (object) [ 'apiName' => $field->apiName, 'displayLabel' => $field->displayLabel, 'isCustomField' => $field->isCustomField, 'required' => $field->isMandatory ]; if ($field->isMandatory) { $response['required'][] = $field->apiName; } } } uksort($response['fields'], 'strnatcasecmp'); usort($response['required'], 'strnatcasecmp'); } else { wp_send_json_error( $fieldsMetaResponse->status === 'error' ? $fieldsMetaResponse->message : 'Unknown', 400 ); } if (!empty($response['tokenDetails']) && $response['tokenDetails'] && !empty($queryParams->id)) { $response['queryModule'] = $queryParams->module; self::saveRefreshedToken($queryParams->formID, $queryParams->id, $response['tokenDetails'], $response); } wp_send_json_success($response, 200); } /** * Process ajax request for refresh crm modules * * @param object $queryParams Params to refresh ticket owner * * @return JSON crm module data / public static function refreshTicketOwners($queryParams) { if (empty($queryParams->tokenDetails) \|\| empty($queryParams->dataCenter) \|\| empty($queryParams->clientId) \|\| empty($queryParams->clientSecret) \|\| empty($queryParams->orgId) ) { wp_send_json_error( __( 'Requested parameter is empty', 'bit-integrations' ), 400 ); } $response = []; if ((\intval($queryParams->tokenDetails->generates_on) + (55 60)) < time()) { $response['tokenDetails'] = self::refreshAccessToken($queryParams); } $ownersMetaApiEndpoint = "https://desk.zoho.{$queryParams->dataCenter}/api/v1/agents?status=ACTIVE&limit=100"; $authorizationHeader['orgId'] = "{$queryParams->orgId}"; $authorizationHeader['Authorization'] = "Zoho-oauthtoken {$queryParams->tokenDetails->access_token}"; $ownersMetaResponse = HttpHelper::get($ownersMetaApiEndpoint, null, $authorizationHeader); if (!is_wp_error($ownersMetaResponse)) { $owners = $ownersMetaResponse->data; if (\count($owners) > 0) { foreach ($owners as $owner) { $response['owners'][] = (object) [ 'ownerId' => $owner->id, 'ownerName' => $owner->name ]; } } } else { wp_send_json_error( empty($ownersMetaResponse->data) ? 'Unknown' : $ownersMetaResponse->error, 400 ); } if (!empty($response['tokenDetails']) && !empty($queryParams->id)) { self::saveRefreshedToken($queryParams->formID, $queryParams->id, $response['tokenDetails'], $response['lists']); } wp_send_json_success($response, 200); } /** * Process ajax request for refresh crm modules * * @param object $queryParams Params to refresh ticket Products * * @return JSON crm module data / public static function refreshProducts($queryParams) { if (empty($queryParams->tokenDetails) \|\| empty($queryParams->dataCenter) \|\| empty($queryParams->clientId) \|\| empty($queryParams->clientSecret) \|\| empty($queryParams->orgId) \|\| empty($queryParams->departmentId) ) { wp_send_json_error( __( 'Requested parameter is empty', 'bit-integrations' ), 400 ); } $response = []; if ((\intval($queryParams->tokenDetails->generates_on) + (55 60)) < time()) { $response['tokenDetails'] = self::refreshAccessToken($queryParams); } $productsMetaApiEndpoint = "https://desk.zoho.{$queryParams->dataCenter}/api/v1/products?departmentId={$queryParams->departmentId}&limit=100"; $authorizationHeader['orgId'] = "{$queryParams->orgId}"; $authorizationHeader['Authorization'] = "Zoho-oauthtoken {$queryParams->tokenDetails->access_token}"; $productsMetaResponse = HttpHelper::get($productsMetaApiEndpoint, null, $authorizationHeader); if (!is_wp_error($productsMetaResponse)) { $products = $productsMetaResponse->data; if (\count($products) > 0) { foreach ($products as $product) { $response['products'][] = (object) [ 'productId' => $product->id, 'productName' => $product->productName ]; } } } else { wp_send_json_error( empty($productsMetaResponse->data) ? 'Unknown' : $productsMetaResponse->error, 400 ); } if (!empty($response['tokenDetails']) && !empty($queryParams->id)) { self::saveRefreshedToken($queryParams->formID, $queryParams->id, $response['tokenDetails'], $response['lists']); } wp_send_json_success($response, 200); } public function execute($integrationData, $fieldValues) { $integrationDetails = $integrationData->flow_details; $tokenDetails = $integrationDetails->tokenDetails; $orgId = $integrationDetails->orgId; $department = $integrationDetails->department; $dataCenter = $integrationDetails->dataCenter; $fieldMap = $integrationDetails->field_map; $required = $integrationDetails->default->fields->{$orgId}->required; $actions = $integrationDetails->actions; if (empty($tokenDetails) \|\| empty($orgId) \|\| empty($department) \|\| empty($fieldMap) ) { return new WP_Error('REQ_FIELD_EMPTY', __('list are required for zoho desk api', 'bit-integrations')); } if ((\intval($tokenDetails->generates_on) + (55 * 60)) < time()) { $requiredParams['clientId'] = $integrationDetails->clientId; $requiredParams['clientSecret'] = $integrationDetails->clientSecret; $requiredParams['dataCenter'] = $integrationDetails->dataCenter; $requiredParams['tokenDetails'] = $tokenDetails; $newTokenDetails = self::refreshAccessToken((object) $requiredParams); if ($newTokenDetails) { self::saveRefreshedToken($this->_integrationID, $newTokenDetails); $tokenDetails = $newTokenDetails; } } // $actions = $integrationDetails->actions; $recordApiHelper = new RecordApiHelper($tokenDetails, $orgId, $this->_integrationID); $zdeskApiResponse = $recordApiHelper->execute( $department, $dataCenter, $fieldValues, $fieldMap, $required, $actions ); if (is_wp_error($zdeskApiResponse)) { return $zdeskApiResponse; } return $zdeskApiResponse; } /** * Helps to refresh zoho crm access_token * * @param array $apiData Contains required data for refresh access token * * @return JSON $tokenDetails API token details / protected static function refreshAccessToken($apiData) { if (!\is_object($apiData) \|\| empty($apiData->dataCenter) \|\| empty($apiData->clientId) \|\| empty($apiData->clientSecret) \|\| empty($apiData->tokenDetails) ) { return false; } $tokenDetails = $apiData->tokenDetails; $dataCenter = $apiData->dataCenter; $apiEndpoint = "https://accounts.zoho.{$dataCenter}/oauth/v2/token"; $requestParams = [ 'grant_type' => 'refresh_token', 'client_id' => $apiData->clientId, 'client_secret' => $apiData->clientSecret, 'refresh_token' => $tokenDetails->refresh_token, ]; $apiResponse = HttpHelper::post($apiEndpoint, $requestParams); if (is_wp_error($apiResponse) \|\| !empty($apiResponse->error)) { return false; } $tokenDetails->generates_on = time(); $tokenDetails->access_token = $apiResponse->access_token; return $tokenDetails; } /* * Save updated access_token to avoid unnecessary token generation * * @param int $formID ID of Integration related form * @param int $integrationID ID of Zoho crm Integration * @param Obeject $tokenDetails refreshed token info * @param null\|mixed $others * * @return null */ protected static function saveRefreshedToken($integrationID, $tokenDetails, $others = null) { if (empty($formID) \|\| empty($integrationID)) { return; } $flow = new FlowController(); $zdeskDetails = $flow->get(['id' => $integrationID]); if (is_wp_error($zdeskDetails)) { return; } $newDetails = json_decode($zdeskDetails[0]->flow_details); $newDetails->tokenDetails = $tokenDetails; if (!empty($others['organizations'])) { $newDetails->default->organizations = $others['organizations']; } $flow->update($integrationID, ['flow_details' => wp_json_encode($newDetails)]); } }

| ver. 1.4 | Github | . | PHP 8.3.30 | Generation time: 0.35 | proxy | phpinfo | Settings