opMemberAction.class.php

<?php

/**
 * This file is part of the OpenPNE package.
 * (c) OpenPNE Project (http://www.openpne.jp/)
 *
 * For the full copyright and license information, please view the LICENSE
 * file and the NOTICE file that were distributed with this source code.
 */

/**
 * opMemberAction
 *
 * @package    OpenPNE
 * @subpackage action
 * @author     Kousuke Ebihara <ebihara@php.net>
 */
abstract class opMemberAction extends sfActions
{
  public function preExecute()
  {
    if ('homepage' === sfContext::getInstance()->getRouting()->getCurrentRouteName())
    {
      if (isset($this->request['a']))
      {
        $this->handleOpenPNE2FormatUrl();
      }
    }

    $this->id = $this->getRequestParameter('id', $this->getUser()->getMemberId());

    $this->relation = Doctrine::getTable('MemberRelationship')->retrieveByFromAndTo($this->getUser()->getMemberId(), $this->id);
    if (!$this->relation)
    {
      $this->relation = new MemberRelationship();
      $this->relation->setMemberIdFrom($this->getUser()->getMemberId());
      $this->relation->setMemberIdTo($this->id);
    }
  }

  protected function handleOpenPNE2FormatUrl()
  {
    $path = sfConfig::get('sf_app_config_dir').'/op2urls.php';
    if (!is_file($path))
    {
      return null;
    }

    $list = include_once($path);
    if (array_key_exists($this->request['a'], $list))
    {
      $table = $list[$this->request['a']];
      $this->forward404Unless($table);

      unset($this->request['m'], $this->request['a']);
      foreach ($table['params'] as $k => $v)
      {
        if (isset($this->request[$k]))
        {
          $this->request[$v] = $this->request[$k];
          unset($this->request[$k]);
        }
      }

      if (isset($table['route']))
      {
        $this->redirect($table['route'], $this->request->getParameterHolder()->getAll());
      }
      else
      {
        unset($this->request['module'], $this->request['action']);
        $this->redirect($table['url'].'?'.http_build_query($this->request->getParameterHolder()->getAll()));
      }
    }
  }

  public function executeLogin(opWebRequest $request)
  {
    $this->getUser()->logout();

    $this->redirectToLoginIfSslRequired($request);

    $this->forms = $this->getUser()->getAuthForms();

    if ($request->hasParameter('authMode'))
    {
      $uri = $this->getUser()->login();

      $this->redirectIf($this->getUser()->isRegisterBegin(), $this->getUser()->getRegisterInputAction());
      $this->redirectIf($this->getUser()->isRegisterFinish(), $this->getUser()->getRegisterEndAction());

      if ($uri)
      {
        $this->redirectIf($this->getUser()->isMember(), $uri);
      }

      return sfView::ERROR;
    }

    $routing = sfContext::getInstance()->getRouting();
    if ('homepage' !== $routing->getCurrentRouteName()
      && 'login' !== $routing->getCurrentRouteName()
    )
    {
      $this->getUser()->setFlash('notice', 'Please login to visit this page', false);
    }

    return sfView::SUCCESS;
  }

  private function redirectToLoginIfSslRequired(opWebRequest $request)
  {
    $routing = sfContext::getInstance()->getRouting();
    if (sfConfig::get('op_use_ssl', false) && !$request->isSecure())
    {
      $app = sfConfig::get('sf_app');
      $sslRequiredList = sfConfig::get('op_ssl_required_actions', array(
        $app => array(),
      ));

      $moduleName = sfConfig::get('sf_login_module');
      $actionName = sfConfig::get('sf_login_action');
      if (in_array($moduleName.'/'.$actionName, $sslRequiredList[$app]))
      {
        $nextUri = $routing->getCurrentInternalUri();
        if ($_SERVER['QUERY_STRING'])
        {
          if (false !== strpos($nextUri, '?'))
          {
            $nextUri .= '&';
          }
          else
          {
            $nextUri .= '?';
          }

          $nextUri .= $_SERVER['QUERY_STRING'];
        }

        $nextUriParam = array(
          'next_uri' => $nextUri
        );

        $baseUrl = sfConfig::get('op_ssl_base_url');
        $scriptName = basename($request->getScriptName());
        $replacement = (false !== strpos($request->getPathInfoPrefix(), $scriptName)) ? '/'.$scriptName : '';
        $loginPath = str_replace($request->getPathInfoPrefix(), $replacement, $this->generateUrl('login'));
        $loginUrl = $baseUrl[$app].$loginPath;
        $loginUrl .= '?'.http_build_query($nextUriParam, '', '&');

        $this->redirect($loginUrl);
      }
    }
  }

  public function executeLogout(opWebRequest $request)
  {
    $this->getUser()->logout();
    $this->redirect('member/login');
  }

  public function executeRegister(opWebRequest $request)
  {
    $member = $this->getUser()->setRegisterToken($request['token']);

    $this->forward404Unless($member && !$this->getUser()->isSNSMember() && $this->getUser()->isInvited());
  }

  public function executeRegisterInput(opWebRequest $request)
  {
    $this->forward404Unless(opToolkit::isEnabledRegistration((sfConfig::get('app_is_mobile') ? 'mobile' : 'pc')));

    $this->token = $request['token'];
    $member = $this->getUser()->setRegisterToken($this->token);

    $this->forward404Unless($member && $this->getUser()->isRegisterBegin());

    opActivateBehavior::disable();
    $this->form = $this->getUser()->getAuthAdapter()->getAuthRegisterForm();
    opActivateBehavior::enable();

    if ($request->isMethod('post'))
    {
      $this->form->bindAll($request);

      if ($this->form->isValidAll())
      {
        $result = $this->getUser()->register($this->form);
        $this->redirectIf($result, $this->getUser()->getRegisterEndAction($this->token));
      }
    }

    return sfView::SUCCESS;
  }

  public function executeHome(opWebRequest $request)
  {
    return sfView::SUCCESS;
  }

  public function executeSearch(opWebRequest $request)
  {
    $params = $request->getParameter('member', array());
    if ($request->hasParameter('search_query'))
    {
      $params = array_merge($params, array('name' => $request->getParameter('search_query', '')));
    }

    $this->filters = new opMemberProfileSearchForm();
    $this->filters->bind($params);

    if (!isset($this->size))
    {
      $this->size = 20;
    }

    $this->pager = new opNonCountQueryPager('Member', $this->size);
    $q = $this->filters->getQuery()->orderBy('id desc');
    $this->pager->setQuery($q);
    $this->pager->setPage($request->getParameter('page', 1));
    $this->pager->init();

    return sfView::SUCCESS;
  }

  public function executeProfile(opWebRequest $request)
  {
    $id = $this->getRequestParameter('id', $this->getUser()->getMemberId());
    if ('member_profile_mine' === sfContext::getInstance()->getRouting()->getCurrentRouteName())
    {
      if ($id !== $this->getUser()->getMemberId())
      {
        $this->redirect('member/profile?id='.$id);
      }
      $this->forward404Unless($id);
      $this->member = $this->getUser()->getMember();
    }
    else
    {
      $this->member = $this->getRoute()->getObject();
    }

    if (!$this->friendsSize)
    {
      $this->friendsSize = 9;
    }
    $this->friends = $this->member->getFriends($this->friendsSize, true);

    if (!$this->communitiesSize)
    {
      $this->communitiesSize = 9;
    }
    $this->communities = $this->member->getJoinCommunities($this->communitiesSize, true);
    $this->crownIds = Doctrine::getTable('CommunityMember')->getCommunityIdsOfAdminByMemberId($id);

    return sfView::SUCCESS;
  }

  public function executeEditProfile(opWebRequest $request)
  {
    $this->memberForm = new MemberForm($this->getUser()->getMember());

    $profiles = $this->getUser()->getMember()->getProfiles();
    $this->profileForm = new MemberProfileForm($profiles);
    $this->profileForm->setConfigWidgets();

    if ($request->isMethod('post'))
    {
      $this->memberForm->bind($request->getParameter('member'));
      $this->profileForm->bind($request->getParameter('profile'));
      if ($this->memberForm->isValid() && $this->profileForm->isValid())
      {
        $this->memberForm->save();
        $this->profileForm->save($this->getUser()->getMemberId());
        $this->redirect('@member_profile_mine');
      }
    }

    return sfView::SUCCESS;
  }

  public function executeConfigComplete(opWebRequest $request)
  {
    $type = $request->getParameter('type');
    $this->forward404Unless($type);

    $memberId = $request->getParameter('id');

    $memberConfig = Doctrine::getTable('MemberConfig')->retrieveByNameAndMemberId($type.'_token', $memberId);
    $this->forward404Unless($memberConfig);
    $this->forward404Unless($request->getParameter('token') === $memberConfig->getValue());

    $option = array('member' => $memberConfig->getMember());
    $this->form = new opPasswordForm(array(), $option);

    if ($request->isMethod('post'))
    {
      $this->form->bind($request->getParameter('password'));
      if ($this->form->isValid())
      {
        $config = Doctrine::getTable('MemberConfig')->retrieveByNameAndMemberId($type, $memberId);
        $pre = Doctrine::getTable('MemberConfig')->retrieveByNameAndMemberId($type.'_pre', $memberId);

        if (!$config)
        {
          $config = new MemberConfig();
          $config->setName($type);
          $config->setMemberId($memberId);
        }
        $config->setValue($pre->getValue());

        if ($config->save())
        {
          $pre->delete();
          $token = Doctrine::getTable('MemberConfig')->retrieveByNameAndMemberId($type.'_token', $memberId);
          $token->delete();
        }

        $this->redirect('@homepage');
      }
    }

    return sfView::SUCCESS;
  }

  public function executeConfig(opWebRequest $request)
  {
    $filteredCategory = $this->filterConfigCategory();
    $this->categories = $filteredCategory['category'];
    $this->categoryCaptions = $filteredCategory['captions'];

    $this->categoryName = $request->getParameter('category', null);
    if ($this->categoryName)
    {
      $this->forward404Unless(array_key_exists($this->categoryName, $this->categories), 'Undefined category');
      $formClass = 'MemberConfig'.ucfirst($this->categoryName).'Form';
      $this->form = new $formClass($this->getUser()->getMember());
    }

    if ($request->isMethod('post'))
    {
      $this->form->bind($request->getParameter('member_config'));
      if ($this->form->isValid())
      {
        $this->form->save($this->getUser()->getMemberId());
        $this->getUser()->setFlash('notice', $this->form->getCompleteMessage());
        $this->redirect('@member_config?category='.$this->categoryName);
      }
    }

    return sfView::SUCCESS;
  }

  public function executeInvite(opWebRequest $request)
  {
    if (
      !$this->getUser()->getAuthAdapter()->getAuthConfig('invite_mode')
      || !opToolkit::isEnabledRegistration()
    )
    {
      return sfView::ERROR;
    }

    $this->form = new InviteForm(null, array('invited' => true));
    $this->form->setOption('is_link', true);
    if ($request->isMethod('post'))
    {
      $this->form->bind($request->getParameter('member_config'));
      if ($this->form->isValid())
      {
        $this->form->save();

        return sfView::SUCCESS;
      }
    }

    $id = $this->getUser()->getMemberId();
    $this->invites = $this->getUser()->getMember()->getInvitingMembers();

    $this->listform = new InvitelistForm(
      array(),
      array('invites' => $this->invites)
    );
    if ($request->isMethod('post'))
    {
      $this->listform->bind($request->getParameter('invitelist'));
      if ($this->listform->isValid())
      {
        $this->listform->save();
        $this->redirect('member/invite');
      }
    }

    return sfView::INPUT;
  }

  public function executeDelete(opWebRequest $request)
  {
    if (1 == $this->getUser()->getMemberId())
    {
      return sfView::ERROR;
    }

    $this->form = new opPasswordForm(array(), array('member' => $this->getUser()->getMember()));
    if ($request->isMethod('post'))
    {
      $this->form->bind($request->getParameter('password'));
      if ($this->form->isValid())
      {
        $member = $this->getUser()->getMember();
        $this->getUser()->getMember()->delete();
        $this->sendDeleteAccountMail($member);
        $this->getUser()->setFlash('notice', '退会が完了しました');
        $this->getUser()->logout();
        $this->redirect('member/login');
      }
    }

    return sfView::INPUT;
  }

  public function executeConfigImage(opWebRequest $request)
  {
    return sfView::SUCCESS;
  }

  public function executeDeleteImage(opWebRequest $request)
  {
    $request->checkCSRFProtection();
    $image = Doctrine::getTable('MemberImage')->find($request->getParameter('member_image_id'));
    $this->forward404Unless($image);
    $this->forward404Unless($image->getMemberId() == $this->getUser()->getMemberId());

    $image->delete();

    $this->redirect('member/configImage');
  }

  public function executeChangeMainImage(opWebRequest $request)
  {
    $request->checkCSRFProtection();
    $image = Doctrine::getTable('MemberImage')->find($request->getParameter('member_image_id'));
    $this->forward404Unless($image);
    $this->forward404Unless($image->getMemberId() == $this->getUser()->getMemberId());

    $currentImage = $this->getUser()->getMember()->getImage();
    $currentImage->setIsPrimary(false);
    $currentImage->save();
    $image->setIsPrimary(true);
    $image->save();

    $this->redirect('member/configImage');
  }

  protected function sendDeleteAccountMail($member)
  {
    $param = array(
      'member'   => $member,
    );

    // to admin
    $mail = new opMailSend();
    $mail->setSubject(opConfig::get('sns_name') . '退会者情報');
    $mail->setGlobalTemplate('deleteAccountMail', $param);
    $mail->send(opConfig::get('admin_mail_address'), opConfig::get('admin_mail_address'));

    // to member
    $param['subject'] = sfContext::getInstance()->getI18N()->__('Leaving from this site is finished');
    opMailSend::sendTemplateMailToMember('leave', $member, $param);
  }

  protected function filterConfigCategory()
  {
    $categories = sfConfig::get('openpne_member_category');
    $categoryCaptions = array();
    $categoryAttributes = sfConfig::get('openpne_member_category_attribute');

    $ignoredSnsConfig = Doctrine::getTable('SnsConfig')->get('ignored_sns_config', array());
    if ($ignoredSnsConfig)
    {
      $ignoredSnsConfig = unserialize($ignoredSnsConfig);
    }

    if (isset($categories['language']))
    {
      if (!opConfig::get('enable_language'))
      {
        unset($categories['language']);
      }
    }

    foreach ($categories as $key => $value)
    {
      $title = $key;

      if (isset($categoryAttributes[$key]['depending_sns_config']))
      {
        $snsConfig = $categoryAttributes[$key]['depending_sns_config'];
        if (!opConfig::get($snsConfig))
        {
          unset($categories[$key]);
          continue;
        }
      }

      if (in_array($key, $ignoredSnsConfig))
      {
        unset($categories[$key]);
        continue;
      }

      $enabledKey = 'enable_pc';
      if (sfConfig::get('sf_app') == 'mobile_frontend')
      {
        $enabledKey = 'enable_mobile';
      }

      if (isset($categoryAttributes[$key][$enabledKey]))
      {
        if (!$categoryAttributes[$key][$enabledKey])
        {
          unset($categories[$key]);
          continue;
        }
      }

      if (!empty($categoryAttributes[$key]['caption']))
      {
        $title = $categoryAttributes[$key]['caption'];
      }

      $categoryCaptions[$key] = $title;
    }

    return array('category' => $categories, 'captions' => $categoryCaptions);
  }

  public function executeShowActivity(opWebRequest $request)
  {
    $this->forward404Unless($this->id);
    $this->forward404If($this->relation->isAccessBlocked());

    if (!isset($this->size))
    {
      $this->size = 20;
    }

    $this->member = Doctrine::getTable('Member')->find($this->id);
    $this->pager = Doctrine::getTable('ActivityData')->getActivityListPager($this->id, null, $request->getParameter('page', 1), $this->size);
  }

  public function executeDeleteActivity(opWebRequest $request)
  {
    $this->forward404Unless($request->hasParameter('id'));

    $this->activity = Doctrine::getTable('ActivityData')->find($this->id);
    $this->forward404Unless($this->activity instanceof ActivityData);
    $this->forward404Unless($this->activity->getMemberId() == $this->getUser()->getMemberId());

    if ($request->isMethod(sfWebRequest::POST))
    {
      $request->checkCSRFProtection();
      $this->activity->delete();
      $this->getUser()->setFlash('notice', 'An %activity% was deleted.');
      $this->redirect('friend/showActivity');
    }

    return sfView::INPUT;
  }

  public function executeUpdateActivity(opWebRequest $request)
  {
    if ($request->isMethod(sfWebRequest::POST))
    {
      $this->forward404Unless(opConfig::get('is_allow_post_activity'));
      $newObject = new ActivityData();
      $newObject->setMemberId($this->getUser()->getMemberId());
      $this->form = new ActivityDataForm($newObject);
      $params = $request->getParameter('activity_data');
      $this->form->bind($params);
      if ($this->form->isValid())
      {
        $this->form->save();
        if ($request->isXmlHttpRequest())
        {
          $activities = Doctrine::getTable('ActivityData')->getFriendActivityList();
          $this->getContext()->getConfiguration()->loadHelpers('Partial');
          return $this->renderText(get_partial('default/activityRecord', array('activity' => $this->form->getObject())));
        }
        else
        {
          $this->redirect($params['next_uri']);
        }
      }
      else
      {
        if ($request->isXmlHttpRequest())
        {
          $this->getResponse()->setStatusCode(500);
        }
        else
        {
          $this->getUser()->setFlash('error', 'Failed to post %activity%.');
          if (isset($params['next_uri']))
          {
            $this->redirect($params['next_uri']);
          }
          $this->redirect('@homepage');
        }
      }
    }
    return sfView::NONE;
  }

  public function executeShowAllMemberActivity(opWebRequest $request)
  {
    if (!isset($this->size))
    {
      $this->size = 20;
    }

    $page = $request->getParameter('page', 1);
    if ($page == 1 && opConfig::get('is_allow_post_activity'))
    {
      $activityData = new ActivityData();
      $activityData->setBody($request->getParameter('body'));
      $this->form = new ActivityDataForm($activityData);
    }

    $this->pager = Doctrine::getTable('ActivityData')->getAllMemberActivityListPager($page, $this->size);
  }
}