芝麻web文件管理V1.00

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

<?php

namespace FluentFormPro\Integrations\WebHook;

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

use FluentForm\App\Helpers\Helper;
use FluentForm\App\Modules\Form\FormFieldsParser;
use FluentForm\Framework\Helpers\ArrayHelper;
use FluentFormPro\Payments\Orders\OrderData;
use FluentForm\App\Services\Integrations\LogResponseTrait;

trait NotifyTrait
{
    use LogResponseTrait;

public function notify($feed, $formData, $entry, $form)
    {
        $settings = $feed['processedValues'];

try {
            $requestHeaders = $this->getWebHookRequestHeaders($settings, $formData, $form, $entry->id);

$requestMethod = $this->getWebHookRequestMethod($settings, $formData, $form, $entry->id);

$requestData = $this->getWebHookRequestData($feed, $formData, $form, $entry);

$requestUrl = $this->getWebHookRequestUrl(
                $settings, $formData, $form, $entry->id, $requestMethod, $requestData
            );

$requestFormat = $settings['request_format'];
            if (in_array($requestMethod, ['POST', 'PUT', 'PATCH']) && $requestFormat == 'JSON') {
                $requestHeaders['Content-Type'] = 'application/json';
                $requestData = json_encode($requestData);
            }

$sslVerify =  apply_filters_deprecated(
                'ff_webhook_ssl_verify',
                [
                    false
                ],
                FLUENTFORM_FRAMEWORK_UPGRADE,
                'fluentform/webhook_ssl_verify',
                'Use fluentform/webhook_ssl_verify instead of ff_webhook_ssl_verify.'
            );

$payload = [
                'body'      => !in_array($requestMethod, ['GET', 'DELETE']) ? $requestData : null,
                'method'    => $requestMethod,
                'headers'   => $requestHeaders,
                'sslverify' => apply_filters('fluentform/webhook_ssl_verify', $sslVerify),
            ];
    
            $payload = apply_filters_deprecated(
                'fluentform_webhook_request_args',
                [
                    $payload,
                    $settings,
                    $formData,
                    $form,
                    $entry->id
                ],
                FLUENTFORM_FRAMEWORK_UPGRADE,
                'fluentform/webhook_request_args',
                'Use fluentform/webhook_request_args instead of fluentform_webhook_request_args.'
            );

$payload = apply_filters(
                'fluentform/webhook_request_args',
                $payload, $settings, $formData, $form, $entry->id
            );

$response = wp_remote_request($requestUrl, $payload);

if (is_wp_error($response)) {
                $code = ArrayHelper::get($response, 'response.code');
                throw new \Exception($response->get_error_message() .', with response code: '.$code, (int)$response->get_error_code());
            } else {
                return $response;
            }
        } catch (\Exception $e) {
            return new \WP_Error('broke', $e->getMessage());
        }
    }

protected function getWebHookRequestMethod($settings, $data, $form, $entryId)
    {
        $method = $settings['request_method'];
    
        $method = apply_filters_deprecated(
            'fluentform_webhook_request_method',
            [
                $method,
                $settings,
                $data,
                $form,
                $entryId
            ],
            FLUENTFORM_FRAMEWORK_UPGRADE,
            'fluentform/webhook_request_method',
            'Use fluentform/webhook_request_method instead of fluentform_webhook_request_method.'
        );

$method = apply_filters(
            'fluentform/webhook_request_method',
            $method, $settings, $data, $form, $entryId
        );

return strtoupper($method);
    }

protected function getWebHookRequestHeaders($settings, $data, $form, $entryId)
    {
        if ($settings['with_header'] == 'nop') return [];

$parsedHeaders = $settings['request_headers'];

$requestHeaders = [];
        foreach ($parsedHeaders as $header) {
            $requestHeaders[$header['key']] = $header['value'];
        }
    
        $requestHeaders = apply_filters_deprecated(
            'fluentform_webhook_request_headers',
            [
                $requestHeaders,
                $settings,
                $data,
                $form,
                $entryId
            ],
            FLUENTFORM_FRAMEWORK_UPGRADE,
            'fluentform/webhook_request_headers',
            'Use fluentform/webhook_request_headers instead of fluentform_webhook_request_headers.'
        );

$requestHeaders = apply_filters(
            'fluentform/webhook_request_headers',
            $requestHeaders, $settings, $data, $form, $entryId
        );

unset($requestHeaders[null]);

return $requestHeaders;
    }

protected function getWebHookRequestData($feed, $data, $form, $entry)
    {
        $settings = $feed['processedValues'];
        $formData = ArrayHelper::except($data, [
            '_wp_http_referer',
            '__fluent_form_embded_post_id',
            '_fluentform_15_fluentformnonce'
        ]);

$selectedData = [];
        if ($settings['request_body'] == 'all_fields') {
            $selectedData = $formData;
			$entry->user_inputs = Helper::replaceBrTag($entry->user_inputs);
            $submission = clone $entry;
            unset($submission->response);
            $selectedData['__submission'] = $submission;
            if($entry->payment_total) {
                $selectedData['__order_items'] = OrderData::getOrderItems($entry);
                $selectedData['__transactions'] = OrderData::getTransactions($entry->id);
            }
        } else {
            foreach ($settings['fields'] as $index => $input) {
                if ($name = Helper::getInputNameFromShortCode(ArrayHelper::get($feed, "settings.fields.$index.value", ''))) {
                    $hasRepeaterOrGridField = FormFieldsParser::getField($form, ['repeater_field', 'tabular_grid'], $name);
                    if ($hasRepeaterOrGridField && $value = ArrayHelper::get($formData, $name)) {
                        $input['value'] = $value;
                    }
                }
	            $input['value'] = Helper::replaceBrTag($input['value']);
                if ("[]" == substr($input['key'], -2)) {
                    // merge array data for same key inserting '[]' at last key
                    $input['key'] = substr($input['key'], 0, -2);
                    $selectedData[$input['key']][] = $input['value'];
                } else {
                    $selectedData[$input['key']] = $input['value'];
                }
            }
        }
    
        $selectedData = apply_filters_deprecated(
            'fluentform_webhook_request_data',
            [
                $selectedData,
                $settings,
                $data,
                $form,
                $entry
            ],
            FLUENTFORM_FRAMEWORK_UPGRADE,
            'fluentform/webhook_request_data',
            'Use fluentform/webhook_request_data instead of fluentform_webhook_request_data.'
        );

return apply_filters(
            'fluentform/webhook_request_data',
            $selectedData, $settings, $data, $form, $entry
        );
    }

protected function getWebHookRequestUrl($settings, $data, $form, $entryId, $requestMethod, $requestData)
    {
        $url = $settings['request_url'];

if (in_array($requestMethod, ['GET', 'DELETE']) && !empty($requestData)) {
            $url = add_query_arg($requestData, $url);
        }
    
        $url = apply_filters_deprecated(
            'fluentform_webhook_request_url',
            [
                $url,
                $settings,
                $data,
                $form,
                $entryId
            ],
            FLUENTFORM_FRAMEWORK_UPGRADE,
            'fluentform/webhook_request_url',
            'Use fluentform/webhook_request_url instead of fluentform_webhook_request_url.'
        );

return apply_filters(
            'fluentform/webhook_request_url',
            $url, $settings, $data, $form, $entryId
        );
    }
}