File manager

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

Back
<?php /** * WebHooks Integration / namespace BitCode\FI\Actions\WebHooks; use BitCode\FI\Log\LogHandler; use BitCode\FI\Core\Util\Common; use BitCode\FI\Core\Util\HttpHelper; /* * Provide functionality for webhooks */ class WebHooksController { public static function testWebhook($webhookDetails) { $data['flow_details'] = $webhookDetails->hookDetails; $response = self::execute((object) $data, []); if (is_wp_error($response)) { wp_send_json_error( empty($response) ? 'Unknown Error Occurred' : $response->get_error_message(), 400 ); } wp_send_json_success(__('Test webhook executed succcessfully', 'bit-integrations'), 200); } 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->method) ? $details->method : 'get'; $url = isset($details->url) ? self::urlParserWrapper($details->url, $fieldValues) : false; $boundary = wp_generate_password(24); $payload = self::processPayload($details, $fieldValues, $boundary); $headers = self::processHeaders($details, $fieldValues, $boundary); if ($url) { switch (strtoupper($method)) { case 'GET': $response = HttpHelper::get($url, [], $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 = []; foreach (explode('&', (string) $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); $cleanURL .= "?{$params}"; return $cleanURL; } private static function processHeaders($details, $fieldValues, $boundary = null) { $headers = isset($details->headers) ? self::processKeyValue((array) $details->headers, $fieldValues) : []; if (isset($details->body->type)) { if ('multipart/form-data' === $details->body->type) { $headers['Content-Type'] = 'multipart/form-data; boundary=' . $boundary; } else { $headers['Content-Type'] = $details->body->type === 'raw' ? 'application/json' : $details->body->type; } } return $headers; } private static function processPayload($details, $fieldValues, $boundary) { 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); } elseif ('multipart/form-data' === $details->body->type) { if (!empty($payload)) { $payloadString = ''; foreach ($payload as $key => $value) { $payloadString .= '--' . $boundary; $payloadString .= "\r\n"; $payloadString .= 'Content-Disposition: form-data; name="' . $key . '"' . "\r\n\r\n"; $payloadString .= $value; $payloadString .= "\r\n"; } $payloadString .= '--' . $boundary . '--'; return $payloadString; } } return $payload; } private static function pushMissingFields($fieldValues, $fields) { foreach ($fields as $field) { if (isset($field->key) && !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.13 | proxy | phpinfo | Settings