php-censor/src/PHPCensor/Store/BuildErrorWriter.php

<?php

namespace PHPCensor\Store;

use b8\Config;
use b8\Database;

/**
 * Class BuildErrorWriter
 */
class BuildErrorWriter
{
    /**
     * @var integer
     */
    protected $buildId;

    /**
     * @var array
     */
    protected $errors = [];

    /**
     * @var integer
     *
     * @see https://stackoverflow.com/questions/40361164/pdoexception-sqlstatehy000-general-error-7-number-of-parameters-must-be-bet
     */
    protected $bufferSize;

    /**
     * BuildErrorWriter constructor.
     *
     * @param int $buildId
     */
    public function __construct($buildId)
    {
        $this->bufferSize = (integer)Config::getInstance()->get('php-censor.build.writer_buffer_size', 500);
        $this->buildId    = $buildId;
    }

    /**
     * Destructor
     */
    public function __destruct()
    {
        $this->flush();
    }

    /**
     * Write error
     *
     * @param string    $plugin
     * @param string    $message
     * @param integer   $severity
     * @param string    $file
     * @param integer   $lineStart
     * @param integer   $lineEnd
     * @param \DateTime $createdDate
     */
    public function write(
        $plugin,
        $message,
        $severity,
        $file = null,
        $lineStart = null,
        $lineEnd = null,
        $createdDate = null
    ) {
        if (is_null($createdDate)) {
            $createdDate = new \DateTime();
        }
        $this->errors[] = [
            'plugin'      => (string)$plugin,
            'message'     => (string)$message,
            'severity'    => (int)$severity,
            'file'        => !is_null($file) ? (string)$file : null,
            'line_start'  => !is_null($lineStart) ? (int)$lineStart : null,
            'line_end'    => !is_null($lineEnd) ? (int)$lineEnd : null,
            'create_date' => $createdDate->format('Y-m-d H:i:s'),
        ];

        if (count($this->errors) >= $this->bufferSize) {
            $this->flush();
        }
    }

    /**
     * Flush buffer
     */
    public function flush()
    {
        if (empty($this->errors)) {
            return;
        }

        $insertValuesPlaceholders = [];
        $insertValuesData         = [];
        foreach ($this->errors as $i => $error) {
            $insertValuesPlaceholders[] = '(
                :build_id' . $i . ',
                :plugin' . $i . ',
                :file' . $i . ',
                :line_start' . $i . ',
                :line_end' . $i . ',
                :severity' . $i . ',
                :message' . $i . ',
                :create_date' . $i . '
            )';
            $insertValuesData['build_id' . $i]    = $this->buildId;
            $insertValuesData['plugin' . $i]      = $error['plugin'];
            $insertValuesData['file' . $i]        = $error['file'];
            $insertValuesData['line_start' . $i]  = $error['line_start'];
            $insertValuesData['line_end' . $i]    = $error['line_end'];
            $insertValuesData['severity' . $i]    = $error['severity'];
            $insertValuesData['message' . $i]     = $error['message'];
            $insertValuesData['create_date' . $i] = $error['create_date'];
        }
        $query = '
            INSERT INTO {{build_error}} (
                {{build_id}},
                {{plugin}},
                {{file}},
                {{line_start}},
                {{line_end}},
                {{severity}},
                {{message}},
                {{create_date}}
            )
            VALUES ' . join(', ', $insertValuesPlaceholders) . '
        ';
        $stmt = Database::getConnection('write')->prepareCommon($query);
        $stmt->execute($insertValuesData);
        $this->errors = [];
    }
}