PhpDraft\Domain\Repositories\LoginUserRepository

Complexity

Total Complexity

36

Size/Duplication

Total Lines	274
Duplicated Lines	0 %

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	2	1
A	EmailExists()	0	15	3
A	VerificationMatches()	0	11	2
A	SearchCommissioners()	0	25	3
A	LoadAll()	0	16	3
A	_ScrubUser()	0	6	1
A	NameIsUnique()	0	16	3
A	Update()	0	22	2
A	LoadById()	0	18	3
A	Delete()	0	9	2
A	Load()	0	17	3
A	GetRoles()	0	7	1
A	Create()	0	23	2
A	LoadPublicById()	0	27	3
A	EmailIsUnique()	0	10	2
A	EraseVerificationKey()	0	14	2

<?php

namespace PhpDraft\Domain\Repositories;

use Silex;
use Silex\Application;
use PhpDraft\Domain\Entities\LoginUser;
use Symfony\Component\Security\Core\Exception\UsernameNotFoundException;

class LoginUserRepository {
    /**
     * @var Silex\Application Application
     */
    private $app;

  public function __construct(Application $app) {
    $this->app = $app;
  }

  public function Load($email) {
    $user = new LoginUser();
    $email = strtolower($email);

    $load_stmt = $this->app['db']->prepare("SELECT * FROM users WHERE email = ? LIMIT 1");
    $load_stmt->setFetchMode(\PDO::FETCH_INTO, $user);
    $load_stmt->bindParam(1, $email);

    if (!$load_stmt->execute()) {
          throw new \Exception(sprintf('Email "%s" does not exist.', $email));
    }

    if (!$load_stmt->fetch()) {
          throw new \Exception(sprintf('Email "%s" does not exist.', $email));
    }

    return $user;
  }

  public function LoadById($id) {
    $user = new LoginUser();

    $id = (int)$id;

    $load_stmt = $this->app['db']->prepare("SELECT * FROM users WHERE id = ? LIMIT 1");
    $load_stmt->setFetchMode(\PDO::FETCH_INTO, $user);
    $load_stmt->bindParam(1, $id);

    if (!$load_stmt->execute()) {
          throw new \Exception(sprintf('User #%s does not exist.', $id));
    }

    if (!$load_stmt->fetch()) {
          throw new \Exception(sprintf('User #%s does not exist.', $id));
    }

    return $user;
  }

  public function LoadPublicById($id) {
    $user = new LoginUser();

    $id = (int)$id;

    $load_stmt = $this->app['db']->prepare("SELECT id, name FROM users WHERE id = ? LIMIT 1");
    $load_stmt->setFetchMode(\PDO::FETCH_INTO, $user);
    $load_stmt->bindParam(1, $id);

    if (!$load_stmt->execute()) {
          throw new \Exception(sprintf('User #%s does not exist.', $id));
    }

    if (!$load_stmt->fetch()) {
          throw new \Exception(sprintf('User #%s does not exist.', $id));
    }

    unset($user->enabled);
    unset($user->email);
    unset($user->password);
    unset($user->salt);
    unset($user->roles);
    unset($user->verificationKey);

    $user = $this->_ScrubUser($user);

    return $user;
  }

  public function LoadAll() {
    $load_stmt = $this->app['db']->prepare("SELECT * FROM users");
    $load_stmt->setFetchMode(\PDO::FETCH_CLASS, 'PhpDraft\Domain\Entities\LoginUser');

    $users = array();

    if (!$load_stmt->execute()) {
      throw new \Exception("Unable to load users.");
    }

    while ($user = $load_stmt->fetch()) {
      
      $users[] = $this->_ScrubUser($user);
    }

    return $users;
  }

  public function Create(LoginUser $user) {
    $insert_stmt = $this->app['db']->prepare("INSERT INTO users 
        (id, email, password, salt, name, roles, verificationKey, creationTime) 
        VALUES 
        (NULL, ?, ?, ?, ?, ?, ?, UTC_TIMESTAMP())");

    $email = strtolower($user->email);
    $roles = implode(',', $user->roles);

    $insert_stmt->bindParam(1, $email);
    $insert_stmt->bindParam(2, $user->password);
    $insert_stmt->bindParam(3, $user->salt);
    $insert_stmt->bindParam(4, $user->name);
    $insert_stmt->bindParam(5, $roles);
    $insert_stmt->bindParam(6, $user->verificationKey);

    if (!$insert_stmt->execute()) {
      throw new \Exception("Unable to create user.");
    }

    $user->id = (int)$this->app['db']->lastInsertId();

    return $user;
  }

  public function Update(LoginUser $user) {
    $update_stmt = $this->app['db']->prepare("UPDATE users 
        SET email = ?, password = ?, salt = ?,
          name = ?, roles = ?, verificationKey = ?, enabled = ?
        WHERE id = ?");

    $update_stmt->bindParam(1, $user->email);
    $update_stmt->bindParam(2, $user->password);
    $update_stmt->bindParam(3, $user->salt);
    $update_stmt->bindParam(4, $user->name);
    $update_stmt->bindParam(5, $user->roles);
    $update_stmt->bindParam(6, $user->verificationKey);
    $update_stmt->bindParam(7, $user->enabled);
    $update_stmt->bindParam(8, $user->id);

    $result = $update_stmt->execute();

    if ($result == false) {
      throw new \Exception("Unable to update user.");
    }

    return $user;
  }

  public function EraseVerificationKey($user_email) {
    $update_stmt = $this->app['db']->prepare("UPDATE users
      SET verificationKey = NULL
      WHERE email = ?");

    $update_stmt->bindParam(1, $user_email);

    $result = $update_stmt->execute();

    if ($result == false) {
      throw new \Exception("Unable to erase verification key for user.");
    }

    return;
  }

  public function Delete(LoginUser $user) {
    $delete_stmt = $this->app['db']->prepare("DELETE FROM users WHERE id = ?");
    $delete_stmt->bindParam(1, $user->id);

    if (!$delete_stmt->execute()) {
      throw new \Exception("Unable to delete user #$user->id");
    }

    return;
  }

  public function NameIsUnique($name, $id = null) {
    $name = strtolower($name);
    if ($id == null) {
      $name_stmt = $this->app['db']->prepare("SELECT name FROM users WHERE name LIKE ?");
      $name_stmt->bindParam(1, $name);
    } else {
      $name_stmt = $this->app['db']->prepare("SELECT name FROM users WHERE name LIKE ? AND id <> ?");
      $name_stmt->bindParam(1, $name);
      $name_stmt->bindParam(2, $id);
    }

    if (!$name_stmt->execute()) {
      throw new \Exception(sprintf('Name %s is invalid', $name));
    }

    return $name_stmt->rowCount() == 0;
  }

  public function EmailExists($email, $id = null) {
    if ($id == null) {
      $email_stmt = $this->app['db']->prepare("SELECT email FROM users WHERE email = ?");
      $email_stmt->bindParam(1, $email);
    } else {
      $email_stmt = $this->app['db']->prepare("SELECT email FROM users WHERE email = ? AND id <> ?");
      $email_stmt->bindParam(1, $email);
      $email_stmt->bindParam(2, $id);
    }

    if (!$email_stmt->execute()) {
      throw new \Exception(sprintf('Email "%s" is invalid', $email));
    }

    return $email_stmt->rowCount() == 1;
  }

  public function EmailIsUnique($email) {
    $email = strtolower($email);
    $email_stmt = $this->app['db']->prepare("SELECT email FROM users WHERE email = ? LIMIT 1");
    $email_stmt->bindParam(1, $email);

    if (!$email_stmt->execute()) {
      throw new \Exception(sprintf('Email %s is invalid', $email));
    }

    return $email_stmt->rowCount() == 0;
  }

  public function SearchCommissioners($searchTerm) {
    $searchTerm = "%$searchTerm%";
    $search_stmt = $this->app['db']->prepare("SELECT id, name FROM users WHERE name LIKE ?");

    $search_stmt->setFetchMode(\PDO::FETCH_CLASS, 'PhpDraft\Domain\Entities\LoginUser');
    $search_stmt->bindParam(1, $searchTerm);

    $users = array();

    if (!$search_stmt->execute()) {
      throw new \Exception("Unable to load users");
    }

    while ($user = $search_stmt->fetch()) {
      unset($user->enabled);
      unset($user->email);
      unset($user->password);
      unset($user->salt);
      unset($user->roles);
      unset($user->verificationKey);

      $users[] = $this->_ScrubUser($user);
    }

    return $users;
  }

  public function VerificationMatches($email, $verificationKey) {
    $email = strtolower($email);
    $verification_stmt = $this->app['db']->prepare("SELECT email, verificationKey FROM users WHERE email = ? AND verificationKey = ? LIMIT 1");
    $verification_stmt->bindParam(1, $email);
    $verification_stmt->bindParam(2, $verificationKey);

    if (!$verification_stmt->execute()) {
      throw new \Exception('Verification is invalid.');
    }

    return $verification_stmt->rowCount() == 1;
  }

  public function GetRoles() {
    $roles = array();

    $roles['ROLE_COMMISH'] = "Commissioner";
    $roles['ROLE_ADMIN'] = "Administrator";

    return $roles;
  }

  private function _ScrubUser(LoginUser $user) {
    unset($user->password);
    unset($user->salt);
    unset($user->verificationKey);

    return $user;
  }
}