hiqdev / hiam-mrdp

src/storage/ClientQuery.php

<?php
/**
 * HIAM module for MRDP database compatibility
 *
 * @link      https://github.com/hiqdev/hiam-mrdp
 * @package   hiam-mrdp
 * @license   BSD-3-Clause
 * @copyright Copyright (c) 2016, HiQDev (http://hiqdev.com/)
 */

namespace hiam\mrdp\storage;

use yii\db\Query;

class ClientQuery extends \yii\db\ActiveQuery
{
    public function init()
    {
        parent::init();
        $this
            ->select([
                'c.obj_id       AS id',
                'c.login        AS username',
                'r.login        AS seller',
                'c.seller_id    AS seller_id',
                'y.name         AS type',
                'z.name         AS state',
                'e.roles        AS roles',
                'k.first_name   AS first_name',
                'k.last_name    AS last_name',
                't.value        AS totp_secret',
                'coalesce(i.value,l.value) AS allowed_ips',
                'coalesce(c.email,k.email) AS email',
                "encode(digest(c.password, 'sha1'), 'hex') AS password_hash",
                'o.value        AS email_confirmed'
            ])
            ->from('zclient             c')
            ->innerJoin('zclient        r', 'r.obj_id=c.seller_id')
            ->innerJoin('zref           y', 'y.obj_id=c.type_id')
            ->innerJoin('zref           z', 'z.obj_id=c.state_id')
            ->leftJoin('contact         k', 'k.obj_id=c.obj_id')
            ->leftJoin('value           t', "t.obj_id=c.obj_id AND t.prop_id=prop_id('client,access:totp_secret')")
            ->leftJoin('value           i', "i.obj_id=c.obj_id AND i.prop_id=prop_id('client,access:allowed_ips')")
            ->leftJoin('value           l', "l.obj_id=c.obj_id AND l.prop_id=prop_id('login_ips:panel')")
            ->leftJoin('value           o', "o.obj_id=c.obj_id AND o.prop_id=prop_id('contact:email_confirmed')")
            ->leftJoin('client2rolez    e', 'e.client_id=c.obj_id')
            ->andWhere(['in', 'z.name', ['ok', 'new']]);
    }

    public function andWhere($condition, $params = [])
    {
        if (!is_array($condition) || isset($condition[0])) {
            return parent::andWhere($condition, $params);
        }
        foreach (['id', 'username', 'password', 'email', 'active'] as $key) {
            /// XXX `isset` does not fit here
            if (array_key_exists($key, $condition)) {
                $this->{"where$key"}($condition[$key]);
                unset($condition[$key]);
            }
        }
        if (!empty($condition)) {
            parent::andWhere($condition, $params);
        }

        return $this;
    }

    public function whereId($id)
    {
        return parent::andWhere(['c.obj_id' => $id]);

It seems like you call parent on a different method (andWhere() instead of whereId()). Are you sure this is correct? If so, you might want to change this to $this->andWhere().

    }

    public function whereEmail($username)
    {
        return parent::andWhere(['or', 'c.login=:username', 'c.email=:username'], [':username' => $username]);

It seems like you call parent on a different method (andWhere() instead of whereEmail()). Are you sure this is correct? If so, you might want to change this to $this->andWhere().

    }

    public function whereUsername($username)
    {
        $userId = (int)$username;
        if ($userId > 0 && "$userId" === trim($username)) {
            return $this->whereId($userId);
        }

        return parent::andWhere(['or', 'c.login=:username', 'c.email=:username'], [':username' => $username]);

It seems like you call parent on a different method (andWhere() instead of whereUsername()). Are you sure this is correct? If so, you might want to change this to $this->andWhere().

    }

    public function wherePassword($password)
    {
        return parent::andWhere(

It seems like you call parent on a different method (andWhere() instead of wherePassword()). Are you sure this is correct? If so, you might want to change this to $this->andWhere().

            'check_password(:password,c.password) OR check_password(:password,tmp.value)',
            [':password' => $password]
        )->leftJoin('value tmp', "tmp.obj_id=c.obj_id AND tmp.prop_id=prop_id('client,access:tmp_pwd')");
    }

    public function whereActive($is_active)
    {
        if (is_null($is_active)) {
            return $this;
        }

        return parent::andWhere([$is_active ? 'in' : 'not in', 'z.name', ['ok', 'active']]);

It seems like you call parent on a different method (andWhere() instead of whereActive()). Are you sure this is correct? If so, you might want to change this to $this->andWhere().

    }
}