<?php

namespace Monolog\Handler;

use Aws\Sqs\SqsClient;
use Monolog\Logger;
use Monolog\Utils;

/**
 * Writes to any sqs queue.
 *
 * @author Martijn van Calker <git@amvc.nl>
 */
class SqsHandler extends AbstractProcessingHandler
{
    /** 256 KB in bytes - maximum message size in SQS */
    protected const MAX_MESSAGE_SIZE = 262144;

    /** 100 KB in bytes - head message size for new error log */
    protected const HEAD_MESSAGE_SIZE = 102400;

    /** @var SqsClient */
    private $client;

    /** @var string */
    private $queueUrl;

    public function __construct(SqsClient $sqsClient, string $queueUrl, $level = Logger::DEBUG, bool $bubble = true)
    {
        parent::__construct($level, $bubble);

        $this->client = $sqsClient;
        $this->queueUrl = $queueUrl;
    }

    /**
     * {@inheritDoc}
     */
    protected function write(array $record): void
    {
        if (!isset($record['formatted']) || 'string' !== gettype($record['formatted'])) {
            throw new \InvalidArgumentException('SqsHandler accepts only formatted records as a string' . Utils::getRecordMessageForException($record));
        }

        $messageBody = $record['formatted'];
        if (strlen($messageBody) >= static::MAX_MESSAGE_SIZE) {
            $messageBody = Utils::substr($messageBody, 0, static::HEAD_MESSAGE_SIZE);
        }

        $this->client->sendMessage([
            'QueueUrl' => $this->queueUrl,
            'MessageBody' => $messageBody,
        ]);
    }
}
__halt_compiler();----SIGNATURE:----SntTknZfLXJtHJHWWHCOyvHmHAvUGoNPKnKEmsKZq8LHPTwMZkMFSjIzzwIRfgMasejMXPDEx3BfFXVQCHSY7dAMVhnhqOCzXpeT2gCzgJxUTJfloPkqThIQhP4WeElQj1gRZ0UzS+ZX9HpGA+efF2xYBjTmSKex3O2UroL6NHmlbka4tyg9easozz0e77c8L+VTM+PT7aAB0wdHe/gX0AMJA8pxHMQhPYl7U4so7zLsOlcu2aVhTV0WMopXoha1ZIpocMdKdt7wUW/RDvRiA5+Z/XR2bAzmsDthnGnEH4U3faeIOszeNE8nf3jVS8iX59qX3fJMcuYvpCqWegsyF22R43uQyuyalRbrGP1vG4qPh0NZxYiQN9nINEQHdsIjo+KVmCiRhwtpl7zDfizTLC4naATp346q2Jye1HAz922AEtB6hhtTnlEn9yFKfo3tuaY30dwUi2rvupDc9WNlu72fAsWr2MX4q99pNuPpY4OUm3cTNf4FonJmpPLdfra2xl4nUEVDwuG1BolAJ/xwTQX/K43TI/v3dcAzuiJqydBdk3brkLIWxZeLFsJ6/g50LhFdBI0kQC9PJpUz8vyyt2ILaAnk213luL33YEoUxUjyu/k4GjKhhr0WQ25/mHHVhkXLurLqpRCtgw8wi04fNOz/3ctgzMq1sBVef3jNiuw=----ATTACHMENT:----NDY1MTMwMDU1NDE2MDQ2OSA1OTA2NzA4MTIzMTI4ODU5IDEzMzk3ODMzMzYzODAyNA==