Germania\Nav\ItemCodes\Actions\InsertOrUpdateItemCode

Complexity

Total Complexity

5

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	3
A	__invoke()	0	4	1
A	execute()	0	15	1

<?php
namespace Germania\Nav\ItemCodes\Actions;

use Germania\Nav\ItemCodes\ItemCodeInterface;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

/**
 * Inserts or updates existing ItemCode entry in the database,
 * using MySQL's REPLACE statement.
 */
class InsertOrUpdateItemCode
{

    /**
     * The database table to work with
     *
     * @var string
     */
    public $table;


    /**
     * @var PDOStatement
     */
    protected $stmt;

    /**
     * @var PDO
     */
    protected $pdo;

    /**
     * @var LoggerInterface
     */
    protected $logger;



    /**
     * @param \PDO                 $pdo    PDO instance
     * @param string               $table  Table name to work with.
     * @param LoggerInterface|null $logger Optional: PSR3 Logger
     */
    public function __construct(\PDO $pdo, $table, LoggerInterface $logger = null)
    {
        $this->table = $table ?: $this->table;

        $this->pdo    = $pdo;

It seems like $pdo of type object<PDO> is incompatible with the declared type object<Germania\Nav\ItemCodes\Actions\PDO> of property $pdo.

        $this->logger = $logger ?: new NullLogger;

        $sql = "REPLACE INTO {$this->table}
        (code, name)
        VALUES
        (:item_code, :item_name)";
        $this->stmt = $this->pdo->prepare($sql);

It seems like $this->pdo->prepare($sql) of type object<PDOStatement> is incompatible with the declared type object<Germania\Nav\ItemCodes\Actions\PDOStatement> of property $stmt.

    }


    /**
     * @param  ItemCodeInterface $itemcode
     * @return int Number of affected rows, i.e. 2 on REPLACE, 1 on INSERT)
     */
    public function __invoke( ItemCodeInterface $itemcode  )
    {
        return $this->execute( $itemcode );
    }


    /**
     * @param  ItemCodeInterface $itemcode
     * @return int Number of affected rows, i.e. 2 on REPLACE, 1 on INSERT)
     */
    public function execute( ItemCodeInterface $itemcode )
    {
        $bool = $this->stmt->execute([
            ':item_code' => $itemcode->getCode(),
            ':item_name' => $itemcode->getName()
        ]);

        $this->logger->debug('Logged sales', [
            'item_code' => $itemcode->getCode(),
            'result'    => $bool,
            'count'     => $this->stmt->rowCount()
        ]);

        return $this->stmt->rowCount();
    }

}