root/events/phpframework/piece_framework/trunk/libs/Phwittr/Self.php @ 15430

<?php
/* vim: set expandtab tabstop=4 shiftwidth=4: */

/* 
 * PHP versions 5
 *
 * @package    Phwittr_PieceFramework
 * @copyright  2008 KUMAKURA Yousuke All rights reserved.
 * @version    SVN: $Id$
 * @since      File available since Release 0.1.0
 */

require_once 'Phwittr/User.php';
require_once 'Phwittr/Self/Exception.php';

// {{{ Phwittr_Self

/**
 * Phwittr ログインユーザ
 *
 * @package    Phwittr_PieceFramework
 * @copyright  2008 KUMAKURA Yousuke All rights reserved.
 * @version    Release: @package_version@
 * @since      Class available since Release 0.1.0
 */
class Phwittr_Self extends Phwittr_User
{

    // {{{ properties

    /**#@+
     * @access public
     */

    /**#@-*/

    /**#@+
     * @access protected
     */

    /**#@-*/

    /**#@+
     * @access private
     */

    /**#@-*/

    /**#@+
     * @access public
     */

    // }}}
    // {{{ __construct

    /**
     * __construct
     * 
     * @param integer $userId
     * @return void
     */
    public function __construct($id)
    {
        Phwittr_Config::configurePieceORM();
        
        $mapper = Piece_ORM::getMapper('Users');
        $user = $mapper->findById($id);
        if (is_null($user)) {
            throw new Phwittr_Self_Exception();
        }

        foreach ($user as $key => $value) {
            $this->$key = $value;
        }

        $this->_normalizePictureFilename($this);
    }

    // }}}
    // {{{ listByFollowers

    /**
     * フォローしているユーザと自身の発言リストを取得する
     * 
     * @param  integer $page
     * @return mixed
     */
    public function listByFollowers($page = 1)
    {
        $criteria->userId = $this->id;

        $mapper = $this->_createStatusListMapper($this->_limit * ($page - 1));
        $statusList = $mapper->findAllByUserIdForListFollowersStatus($criteria);
        if (count($statusList) == 0 && $page > 1) {
            return $this->listByFollowers();
        }

        $this->_checkNextPage($mapper, $page);

        foreach ($statusList as &$status) {
            $this->_normalizePictureFilename($status);
        }

        return $statusList;
    }

    // }}}
    // {{{ listReplies

    /**
     * 自身への返信リストを取得する
     * 
     * @param  integer $page
     * @return mixed
     */
    public function listReplies($page = 1)
    {
        $mapper = $this->_createStatusListMapper($this->_limit * ($page - 1));
        $statusList = $mapper->findAllByReplyUserId($this->id);
        if (count($statusList) == 0 && $page > 1) {
            return $this->listReplies();
        }

        $this->_checkNextPage($mapper, $page);

        foreach ($statusList as &$status) {
            $this->_normalizePictureFilename($status);
        }

        return $statusList;
    }

    // }}}
    // {{{ update

    /**
     * ステータスを更新する
     * 
     * @param string $comment
     * @return mixed
     */
    public function update($comment)
    {
        $status = Piece_ORM::createObject('Statuses');
        $status->userId = $this->id;
        $status->comment = $comment;
        $status->replyUserId = $this->_findReplyUserId($comment);
        $status->createdAt = date('Y-m-d H:i:s');

        $mapper = Piece_ORM::getMapper('Statuses');
        return $mapper->insert($status);
    }

    // }}}
    // {{{ delete

    /**
     * ステータスを削除する
     * 
     * @param integer $id
     * @return mixed
     */
    public function delete($id)
    {
        $criteria->id = $id;
        $criteria->userId = $this->id;

        $mapper = Piece_ORM::getMapper('Statuses');
        $result = $mapper->deleteByIdAndUserId($criteria);
        if (!$result) {
            throw new Phwittr_Self_Exception();
        }

        return $result;
    }

    // }}}
    // {{{ follow

    /**
     * 指定ユーザをフォローする
     * 
     * @param integer $userId
     * @return boolean
     */
    public function follow($userId)
    {
        if ($userId == $this->id) {
            throw new Phwittr_Self_Exception();
        }

        $user = new Phwittr_User($userId, $this->id,
                                 PHWITTR_USER_CONSTRUCTOR_FIND_BY_ID
                                 );
        if ($user->isProtected()) {
            $entity = Piece_ORM::createObject('FriendRequests');
            $entity->userId = $userId;
            $entity->requesterId = $this->id;
            $entity->createdAt = date('Y-m-d H:i:s');
            $mapper = Piece_ORM::getMapper('FriendRequests');
        } else {
            $entity = Piece_ORM::createObject('Followers');
            $entity->userId = $this->id;
            $entity->followId = $userId;
            $entity->createdAt = date('Y-m-d H:i:s');
            $mapper = Piece_ORM::getMapper('Followers');
        }

        try {
            $result = $mapper->insert($entity);
        } catch (Exception $e) {
            if ($e->getCode() === PIECE_ORM_ERROR_CONSTRAINT) {
                throw new Phwittr_Self_Exception();
            } else {
                throw new Exception();
            }
        }
    }

    // }}}
    // {{{ removeFriend

    /**
     * 指定したユーザを友人リストから消去する
     * 
     * @param integer $userId
     * @return boolean
     */
    public function removeFriend($userId)
    {
        if ($userId == $this->id) {
            throw new Phwittr_Self_Exception();
        }

        $follower = Piece_ORM::createObject('Followers');
        $follower->userId = $this->id;
        $follower->followId = $userId;

        $mapper = Piece_ORM::getMapper('Followers');
        $result = $mapper->delete($follower);

        if ($result) {
            return true;
        } else {
            throw new Phwittr_Self_Exception();
        }
    }

    // }}}
    // {{{ cancel

    /**
     * 指定フレンドリクエストをキャンセルする
     * 
     * @param integer $requestId
     * @return boolean
     */
    public function cancel($requestId)
    {
        $requestMapper = Piece_ORM::getMapper('FriendRequests');
        $friendRequest = $requestMapper->findById($requestId);
        if (!$friendRequest) {
            throw new Phwittr_Self_Exception();
        }

        if ($friendRequest->requesterId !== $this->id) {
            throw new Phwittr_Self_Exception();
        }

        $requestMapper->delete($friendRequest);
    }

    // }}}
    // {{{ accept

    /**
     * 指定フレンドリクエストを許可する
     * 
     * @param integer $requestId
     * @return boolean
     */
    public function accept($requestId)
    {
        $requestMapper = Piece_ORM::getMapper('FriendRequests');
        $friendRequest = $requestMapper->findById($requestId);
        if (!$friendRequest) {
            throw new Phwittr_Self_Exception();
        }

        if ($friendRequest->userId !== $this->id) {
            throw new Phwittr_Self_Exception();
        }

        $entity1 = Piece_ORM::createObject('Followers');
        $entity2 = Piece_ORM::createObject('Followers');

        $entity1->userId = $friendRequest->requesterId;
        $entity1->followId = $friendRequest->userId;
        $entity1->createdAt = date('Y-m-d H:i:s');

        $entity2->userId = $friendRequest->userId;
        $entity2->followId = $friendRequest->requesterId;
        $entity2->createdAt = date('Y-m-d H:i:s');

        $followerMapper = Piece_ORM::getMapper('Followers');

        try {
            if (!$followerMapper->findByUserIdAndFollowId($entity1)) {
                $followerMapper->insert($entity1);
            }
            if (!$followerMapper->findByUserIdAndFollowId($entity2)) {
                $followerMapper->insert($entity2);
            }
            $requestMapper->delete($friendRequest);
        } catch (Exception $e) {
            if ($e->getCode() === PIECE_ORM_ERROR_CONSTRAINT) {
                throw new Phwittr_Self_Exception();
            } else {
                throw new Exception();
            }
        }
    }

    // }}}
    // {{{ deny

    /**
     * 指定フレンドリクエストを拒否する
     * 
     * @param integer $requestId
     * @return boolean
     */
    public function deny($requestId)
    {
        $requestMapper = Piece_ORM::getMapper('FriendRequests');
        $friendRequest = $requestMapper->findById($requestId);
        if (!$friendRequest) {
            throw new Phwittr_Self_Exception();
        }

        if ($friendRequest->userId !== $this->id) {
            throw new Phwittr_Self_Exception();
        }

        $requestMapper->delete($friendRequest);
    }

    // }}}
    // {{{ isFriend

    /**
     * 指定ユーザがフレンドかどうか
     * 
     * @param  $userId
     * @return integer
     */
    public function isFriend($userId)
    {
        $criteria = new stdClass();
        $criteria->userId = $this->id;
        $criteria->followId = $userId;

        $mapper = Piece_ORM::getMapper('Followers');
        $followers = $mapper->findByUserIdAndFollowId($criteria);

        if ($followers) {
            return 1;
        } else {
            return 0;
        }
    }

    // }}}
    // {{{ getRequestId

    /**
     * 指定ユーザに対してのフレンドリクエストidを取得する
     * 
     * @param  $userId
     * @return mixed
     */
    public function getRequestId($userId)
    {
        $criteria = new stdClass();
        $criteria->userId = $userId;
        $criteria->requesterId = $this->id;

        $mapper = Piece_ORM::getMapper('FriendRequests');
        $friendRequest = $mapper->findByUserIdAndRequesterId($criteria);

        if ($friendRequest) {
            return $friendRequest->id;
        } else {
            return false;
        }
    }


    // }}}
    // {{{ countFriendRequests

    /**
     * フレンドリクエスト件数を取得する
     * 
     * @return integer
     */
    public function countFriendRequests()
    {
        if (!$this->privateFlag) {
            return 0;
        }

        $mapper = Piece_ORM::getMapper('FriendRequests');
        return count($mapper->findAllByUserId($this->id));
    }

    // }}}
    // {{{ listFriendRequests

    /**
     * フレンドリクエストをしているユーザを一覧化する
     * 
     * @param  integer $page
     * @return array
     */
    public function listFriendRequests($page = 1)
    {
        $mapper = $this->_createUserListMapper($this->_limit * ($page - 1));
        $userList = $mapper->findAllByUserIdForListFriendRequests($this);
        if (count($userList) == 0 && $page > 1) {
            return $this->listFriendRequests();
        }

        $this->_checkNextPage($mapper, $page);

        foreach ($userList as &$user) {
            $this->_normalizePictureFilename($user);
        }

        return $userList;
    }



    /**#@-*/

    /**#@+
     * @access private
     */

    // }}}
    // {{{ _findReplyUserIdByComment

    /**
     * コメントから返信先ユーザIdを取得する
     * 
     * @param string $comment
     * @return mixed
     */
    private function _findReplyUserId($comment)
    {
        $replyUserId = null;
        if (preg_match('/^@([0-9a-zA-Z_]{1,20}+).*$/', $comment, $matches)) {
            $replyUserName = $matches[1];

            $mapper = Piece_ORM::getMapper('Users');
            $replyUser = $mapper->findByUserName($replyUserName);
            if ($replyUser) {
                $replyUserId = $replyUser->id;
            }
        }

        return $replyUserId;
    }

    // }}}
    // {{{ _raiseException

    /**
     * 例外を発生させる
     * 
     */
    private function _raiseException()
    {
        throw new Phwittr_Self_Exception();
    }

    /**#@-*/

    // }}}
}

// }}}

/*
 * Local Variables:
 * mode: php
 * coding: utf-8
 * tab-width: 4
 * c-basic-offset: 4
 * c-hanging-comment-ender-p: nil
 * indent-tabs-mode: nil
 * End:
 */
?>