WebhookMessageReader.php 1.61 KB
Newer Older
Ketan's avatar
Ketan committed
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
<?php
/**
 * Copyright © Magento, Inc. All rights reserved.
 * See COPYING.txt for license details.
 */
namespace Magento\Signifyd\Model\SignifydGateway\Response;

use Magento\Framework\Json\DecoderInterface;

/**
 * Reads request and produces webhook message data object based on request params.
 */
class WebhookMessageReader
{
    /**
     * @var DecoderInterface
     */
    private $dataDecoder;

    /**
     * @var WebhookMessageFactory
     */
    private $webhookMessageFactory;

    /**
     * @param DecoderInterface $decoder
     * @param WebhookMessageFactory $webhookMessageFactory
     */
    public function __construct(
        DecoderInterface $decoder,
        WebhookMessageFactory $webhookMessageFactory
    ) {
        $this->dataDecoder = $decoder;
        $this->webhookMessageFactory = $webhookMessageFactory;
    }

    /**
     * Returns webhook message data object.
     *
     * @param WebhookRequest $request
     * @return WebhookMessage
     * @throws \InvalidArgumentException
     */
    public function read(WebhookRequest $request)
    {
        try {
            $decodedData = $this->dataDecoder->decode($request->getBody());
        } catch (\Exception $e) {
            throw new \InvalidArgumentException(
                'Webhook request body is not valid JSON: ' . $e->getMessage(),
                $e->getCode(),
                $e
            );
        }

        $webhookMessage = $this->webhookMessageFactory->create(
            [
                'data' => $decodedData,
                'eventTopic' => $request->getEventTopic()
            ]
        );

        return $webhookMessage;
    }
}