File indexing completed on 2024-12-22 05:33:26

 <?php
 
 /**
  *  ocs-webserver
  *
  *  Copyright 2016 by pling GmbH.
  *
  *    This file is part of ocs-webserver.
  *
  *    This program is free software: you can redistribute it and/or modify
  *    it under the terms of the GNU Affero General Public License as
  *    published by the Free Software Foundation, either version 3 of the
  *    License, or (at your option) any later version.
  *
  *    This program is distributed in the hope that it will be useful,
  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  *    GNU Affero General Public License for more details.
  *
  *    You should have received a copy of the GNU Affero General Public License
  *    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  *
  * Created: 06.08.2018
  */
 class Backend_CdiscourseController extends Local_Controller_Action_CliAbstract
 {
 
     const filename = "members";
     const filename_errors = "members";
 
     protected $logfile;
     protected $errorlogfile;
     /** @var Zend_Config */
     protected $config;
     protected $log;
 
     /**
      * @inheritDoc
      */
     public function __construct(
         Zend_Controller_Request_Abstract $request,
         Zend_Controller_Response_Abstract $response,
         array $invokeArgs = array()
     ) {
         parent::__construct($request, $response, $invokeArgs);
         $this->config = Zend_Registry::get('config')->settings->server->forum;
         $this->log = Zend_Registry::get('logger');
         $this->_helper->viewRenderer->setNoRender(false);
     }
 
 
     /**
      * @throws Zend_Db_Statement_Exception
      * @throws Zend_Exception
      */
     public function runAction()
     {
         ini_set('memory_limit', '1024M');
 
         $force = (boolean)$this->getParam('force', false);
         $method = $this->getParam('method', 'create');
 
         $this->log->info("METHOD: {$method}\n--------------\n");
 
         if ('delete' == $method) {
             //$this->deleteMember($this->getParam('member_id'));
             echo "not implemented";
 
             return;
         }
 
         if ($this->hasParam('member_id')) {
             $memberId = $this->getParam('member_id');
             $operator = $this->getParam('op', null);
             $members = $this->getMemberList($memberId, $operator);
         } else {
             $members = $this->getMemberList();
         }
 
         if ('create' == $method) {
             $this->exportMembers($members, $force);
 
             return;
         }
         if ('update' == $method) {
             //$this->updateMembers($members);
             echo "not implemented";
 
             return;
         }
         if ('validate' == $method) {
             //$this->validateMembers($members);
             echo "not implemented";
 
             return;
         }
         if ('block' == $method) {
             $this->blockMembers($members);
 
             return;
         }
         if ('posts' == $method) {
             $this->postsMembers($members);
 
             return;
         }
         if ('posts_delete' == $method) {
             $this->deletePostsMembers($members);
 
             return;
         }
         if ('posts_undelete' == $method) {
             $this->undeletePostsMembers($members);
 
             return;
         }
         if ('silence' == $method) {
             $this->silenceMembers($members);
 
             return;
         }
     }
 
     /**
      * @param null   $member_id
      * @param string $operator
      *
      * @return Zend_Db_Statement_Interface
      * @throws Zend_Db_Statement_Exception
      */
     private function getMemberList($member_id = null, $operator = "=")
     {
         $filter = "";
         if (empty($operator)) {
             $operator = "=";
         }
         if ($operator == "gt") {
             $operator = ">";
         }
         if ($operator == "lt") {
             $operator = "<";
         }
         if (isset($member_id)) {
             $filter = " AND `m`.`member_id` {$operator} " . $member_id;
         }
 
         $sql = "
             SELECT `mei`.`external_id`,`m`.`member_id`, `m`.`username`, `me`.`email_address`, `m`.`password`, `m`.`roleId`, `m`.`firstname`, `m`.`lastname`, `m`.`profile_image_url`, `m`.`created_at`, `m`.`changed_at`, `m`.`source_id`, `m`.`biography`, `m`.`is_active`, `me`.`email_checked`
             FROM `member` AS `m`
             LEFT JOIN `member_email` AS `me` ON `me`.`email_member_id` = `m`.`member_id` AND `me`.`email_primary` = 1
             LEFT JOIN `member_external_id` AS `mei` ON `mei`.`member_id` = `m`.`member_id`
             WHERE `m`.`is_active` = 1 
               AND `m`.`is_deleted` = 0 
               AND `me`.`email_checked` IS NOT NULL 
               AND `me`.`email_deleted` = 0
               AND LOCATE('_double', `m`.`username`) = 0 
               AND LOCATE('_double', `me`.`email_address`) = 0
             " . $filter . "
             ORDER BY `m`.`member_id` ASC
         ";
 
         $result = Zend_Db_Table::getDefaultAdapter()->query($sql);
 
         $this->log->info("Load : " . $result->rowCount() . " members...");
 
         return $result;
     }
 
     /**
      * @param Zend_Db_Statement_Interface $members
      *
      * @param bool                        $force
      *
      * @return bool
      * @throws Zend_Db_Statement_Exception
      * @throws Zend_Exception
      */
     private function exportMembers($members, $force = false)
     {
         // only usernames which are valid in github/gitlab
         $usernameValidChars = new Local_Validate_UsernameValid();
         $emailValidate = new Zend_Validate_EmailAddress();
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         while ($member = $members->fetch()) {
             $this->log->info("process " . Zend_Json::encode($member));
             echo "process " . Zend_Json::encode($member) . PHP_EOL;
 
             //if (false === $usernameValidChars->isValid($member['username'])) {
             //    file_put_contents($this->errorlogfile, print_r($member, true) . "user name validation error" . "\n\n", FILE_APPEND);
             //    continue;
             //}
             if (false === $emailValidate->isValid($member["email_address"])) {
                 $this->log->info("messages [\"email address validation error\"] ");
                 echo "response [\"email address validation error\"]" . PHP_EOL;
                 continue;
             }
             try {
                 //Export User, if he not exists
                 $result = $modelSubSystem->createUserFromArray($member, $force);
                 if (false === $result AND $modelSubSystem->hasRateLimitError()) {
                     $this->log->info("RateLimitError: Wait " . $modelSubSystem->getRateLimitWaitSeconds() . " seconds for next execution.");
 
                     sleep((int)$modelSubSystem->getRateLimitWaitSeconds()+5);
                     $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
                     $modelSubSystem->createUserFromArray($member, $force);
                 }
             } catch (Exception $e) {
                 $this->log->info($e->getMessage() . PHP_EOL . $e->getTraceAsString());
             }
             $messages = $modelSubSystem->getMessages();
             $this->log->info("messages " . Zend_Json::encode($messages));
             echo "response " . Zend_Json::encode($messages) . PHP_EOL;
         }
 
         return true;
     }
 
     private function blockMembers($members)
     {
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         while ($member = $members->fetch()) {
             $result = $modelSubSystem->blockUser($member);
             if (false == $result) {
                 $this->log->info('Fail');
             }
             $messages = $modelSubSystem->getMessages();
             if (false === empty($messages)) {
                 $this->log->info("Message : " . Zend_Json::encode($messages));
             }
         }
     }
 
     private function postsMembers($members)
     {
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         while ($member = $members->fetch()) {
             $result = $modelSubSystem->getPostsFromUser($member);
             if (false == $result) {
                 $this->log->info('Fail');
             }
             $this->log->info("Posts : " . Zend_Json::encode($result));
             $messages = $modelSubSystem->getMessages();
             if (false === empty($messages)) {
                 $this->log->info("Message : " . Zend_Json::encode($messages));
             }
         }
     }
 
     private function deletePostsMembers($members)
     {
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         while ($member = $members->fetch()) {
             $result = $modelSubSystem->blockUserPosts($member);
             $this->log->info("Posts : " . Zend_Json::encode($result));
             $messages = $modelSubSystem->getMessages();
             if (false === empty($messages)) {
                 $this->log->info("Message : " . Zend_Json::encode($messages));
             }
         }
     }
 
     private function undeletePostsMembers($members)
     {
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         while ($member = $members->fetch()) {
             $result = $modelSubSystem->unblockUserPosts($member);
             $this->log->info("Posts : " . Zend_Json::encode($result));
             $messages = $modelSubSystem->getMessages();
             if (false === empty($messages)) {
                 $this->log->info("Message : " . Zend_Json::encode($messages));
             }
         }
     }
 
     private function silenceMembers($members)
     {
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         while ($member = $members->fetch()) {
             $result = $modelSubSystem->silenceUser($member);
             if (false == $result) {
                 $this->log->info('Fail');
             }
             $messages = $modelSubSystem->getMessages();
             if (false === empty($messages)) {
                 $this->log->info("Message : " . Zend_Json::encode($messages));
             }
         }
     }
 
     public function groupAction()
     {
         $groupname = $this->getParam('name', null);
 
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
 
         //$result = $modelSubSystem->createGroup($groupname);
         //
         //echo $result;
         //
         //$result = $modelSubSystem->deleteGroup($result);
         //
         //echo $result;
 
         $result = $modelSubSystem->getUserByEmail("info@dschinnweb.de");
 
         print_r($result);
 
         echo json_encode($result);
     }
 
     private function deleteMember($member)
     {
         $modelSubSystem = new Default_Model_Ocs_Forum($this->config);
         try {
             //Export User, if he not exists
             $modelSubSystem->deleteUser($member);
         } catch (Exception $e) {
             $this->log->info($e->getMessage() . PHP_EOL . $e->getTraceAsString());
         }
         $messages = $modelSubSystem->getMessages();
         $this->log->info("messages " . Zend_Json::encode($messages));
         echo "response " . Zend_Json::encode($messages) . PHP_EOL;
     }
 
 }