GermaniaKG / Coupons

src/PdoCouponFactory.php

<?php
namespace Germania\Coupons;

class PdoCouponFactory
{

    /**
     * @var string
     */
    public $php_class;

    /**
     * @var callable
     */
    public $coupon_sheet_factory;


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


    /**
     * @var string[]
     */
    protected static $coupon_fields_default = array(
        'id',
        'code',
        'coupon_sheet_id AS coupon_sheet',
    );

    /**
     * @var string[]
     */
    public static $coupon_fields = array();

    /**
     * @param \PDO   $pdo
     * @param string $coupons_table
     * @param callable $coupon_sheet_factory
     * @param string $php_class
     */
    public function __construct( \PDO $pdo, $coupons_table, callable $coupon_sheet_factory, $php_class = null)
    {
        $this->coupon_sheet_factory = $coupon_sheet_factory;
        $this->php_class = $php_class ?: Coupon::class;

        if (!is_subclass_of($this->php_class, CouponInterface::class ))

Due to PHP Bug #53727, is_subclass_of might return inconsistent results on some PHP versions if \Germania\Coupons\CouponInterface::class can be an interface. If so, you could instead use ReflectionClass::implementsInterface.

            throw new \InvalidArgumentException("Class name or instance of CouponInterface expected.");

        $sql_fields = join(",", array_merge(static::$coupon_fields_default, static::$coupon_fields));

        $sql = "SELECT
        {$sql_fields}
        FROM `{$coupons_table}`

        WHERE code = :code
        LIMIT 1";

        $this->stmt = $pdo->prepare( $sql );

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

        $this->stmt->setFetchMode( \PDO::FETCH_CLASS, $this->php_class );

    }

    /**
     * @param  string|CouponInterface $code
     * @return CouponInterface[]
     */
    public function __invoke( $code )
    {
        if ($code instanceOf CouponInterface)
            $code = $code->getCode();

        if (!$this->stmt->execute([
            'code' => $code
        ])) {
            throw new \RuntimeException("Could not execute PDOStatement.");
        }

        $coupon = $this->stmt->fetch();

        if ($coupon and $this->coupon_sheet_factory):
            $coupon_sheet_factory = $this->coupon_sheet_factory;
            $coupon->coupon_sheet = $coupon_sheet_factory( $coupon->coupon_sheet );
        endif;

        return $coupon;
    }

}