File manager

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

Back
<?php /** * CustomApi Integration / namespace BitCode\FI\Actions\CustomApi; use BitCode\FI\Core\Util\Common; use BitCode\FI\Core\Util\HttpHelper; use BitCode\FI\Log\LogHandler; /* * Provide functionality for webhooks */ class CustomApiController { public static function execute($integrationDetails, $fieldValues) { $fieldValues = self::iterate($fieldValues); $details = $integrationDetails->flow_details; $type = $details->type; $integId = isset($integrationDetails->id) ? $integrationDetails->id : ''; $method = isset($details->actionMethod) ? $details->actionMethod : 'get'; $url = isset($details->url) ? self::urlParserWrapper($details->url, $fieldValues) : false; $payload = self::processPayload($details, $fieldValues); $headers = self::processHeaders($details, $fieldValues); if ($details->authType === 'apikey') { if ($details->apiKeyAddTo === 'query') { $separator = (strpos($url, '?') !== false) ? '&' : '?'; $url = "{$url}{$separator}{$details->key}={$details->value}"; } else { $headers = array_merge($headers, [$details->key => $details->value]); } } elseif ($details->authType === 'bearer') { $headers = array_merge($headers, [$details->key => $details->token]); } elseif ($details->authType === 'basic') { $headers = array_merge($headers, [$details->key => 'Basic ' . base64_encode("{$details->username}:{$details->password}")]); } if ($url) { switch (strtoupper($method)) { case 'GET': $response = HttpHelper::get($url, $payload, $headers); break; case 'POST': $response = HttpHelper::post($url, $payload, $headers); break; default: $response = HttpHelper::request($url, $method, $payload, $headers); break; } } if (is_wp_error($response) \|\| !empty($response->error)) { LogHandler::save($integId, wp_json_encode(['type' => $type, 'type_name' => $type]), 'error', $response); } else { // file_put_contents(__DIR__ . '/bit-integrations-webhook-response.json', wp_json_encode($response)); LogHandler::save($integId, wp_json_encode(['type' => $type, 'type_name' => $type]), 'success', !empty($response) ? wp_json_encode($response) : 'Successfully executed webhook'); } return $response; } private static function urlParserWrapper($url, $fieldValues = []) { if (empty($url)) { return $url; } $parsedURL = wp_parse_url($url); $Scheme = isset($parsedURL['scheme']) ? $parsedURL['scheme'] . '://' : null; $Usr = isset($parsedURL['usr']) ? $parsedURL['usr'] : null; $Pass = isset($parsedURL['pass']) ? ':' . $parsedURL['pass'] : null; $Host = isset($parsedURL['host']) ? $parsedURL['host'] : null; $Port = isset($parsedURL['port']) ? ':' . $parsedURL['port'] : null; $Path = isset($parsedURL['path']) ? $parsedURL['path'] : null; $Query = isset($parsedURL['query']) ? $parsedURL['query'] : null; $Pass = ($Pass \|\| $Usr) ? "{$Pass}@" : null; $cleanURL = "{$Scheme}{$Usr}{$Pass}{$Host}{$Port}{$Path}"; $params = []; if (empty($Query)) { return $cleanURL; } foreach (explode('&', $Query) as $keyValue) { if (empty($keyValue)) { continue; } list($field, $value) = explode('=', $keyValue); if ('' == trim($value)) { continue; } if (isset($params[$field])) { if (\is_array($params[$field])) { $params[$field][] = sanitize_text_field($value); } else { $params[$field] = [$params[$field], sanitize_text_field($value)]; } } else { $params[$field] = sanitize_text_field($value); } } $params = Common::replaceFieldWithValue($params, $fieldValues); $params = http_build_query($params); if (!empty($params)) { $cleanURL .= "?{$params}"; } return $cleanURL; } private static function processHeaders($details, $fieldValues) { $headers = isset($details->headers) ? self::processKeyValue((array) $details->headers, $fieldValues) : []; if (isset($details->body->type)) { $headers['Content-Type'] = $details->body->type === 'raw' ? 'application/json' : $details->body->type; } return $headers; } private static function processPayload($details, $fieldValues) { if ($details->body->type === 'raw' && isset($details->body->raw)) { return Common::replaceFieldWithValue(sanitize_text_field($details->body->raw), $fieldValues); } $payload = []; if (isset($details->body->data)) { $fieldValues = self::pushMissingFields($fieldValues, $details->body->data); $payload = self::processKeyValue($details->body->data, $fieldValues); } if (isset($details->body->type) && ($details->body->type === 'application/json' \|\| $details->body->type === 'raw')) { $payload = wp_json_encode((object) $payload, JSON_PRETTY_PRINT); } return $payload; } private static function pushMissingFields($fieldValues, $fields) { foreach ($fields as $field) { if (!isset($fieldValues[$field->key])) { $fieldValues[$field->key] = ''; } } return $fieldValues; } private static function processKeyValue($data, $fieldValues) { $processedData = []; foreach ($data as $keyValuePair) { $processedData[$keyValuePair->key] = Common::replaceFieldWithValue(sanitize_text_field($keyValuePair->value), $fieldValues); } return $processedData; } private static function iterate($array) { $ar = []; if (\is_array($array)) { foreach ($array as $k => $v) { if (\is_string($v)) { $ar[$k] = str_replace("\'", "'", $v); } else { $ar[$k] = $v; } } } return $ar; } }

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