UploadPluginForm.inc.php

<?php
 
// Import the base Form.
import('lib.pkp.classes.form.Form');
 
import('lib.pkp.classes.plugins.PluginHelper');
import('lib.pkp.classes.file.FileManager');
 
class UploadPluginForm extends Form {
 
   var $_function;
 
 
   function __construct($function) {
      parent::__construct('controllers/grid/plugins/form/uploadPluginForm.tpl');
 
      $this->_function = $function;
 
      $this->addCheck(new FormValidator($this, 'temporaryFileId', 'required', 'manager.plugins.uploadFailed'));
   }
 
   //
   // Implement template methods from Form.
   //
   function readInputData() {
      $this->readUserVars(array('temporaryFileId'));
   }
 
   function fetch($request, $template = null, $display = false) {
      $templateMgr = TemplateManager::getManager($request);
      $templateMgr->assign(array(
         'function' => $this->_function,
         'category' => $request->getUserVar('category'),
         'plugin' => $request->getUserVar('plugin'),
      ));
 
      return parent::fetch($request, $template, $display);
   }
 
   function execute(...$functionArgs) {
      parent::execute(...$functionArgs);
 
      $request = Application::get()->getRequest();
      $user = $request->getUser();
      $pluginHelper = new PluginHelper();
      $notificationMgr = new NotificationManager();
 
      // Retrieve the temporary file.
      import('lib.pkp.classes.file.TemporaryFileManager');
      $temporaryFileManager = new TemporaryFileManager();
      $temporaryFileDao = DAORegistry::getDAO('TemporaryFileDAO'); /* @var $temporaryFileDao TemporaryFileDAO */
      $temporaryFile = $temporaryFileDao->getTemporaryFile($this->getData('temporaryFileId'), $user->getId());
 
      // Extract the temporary file into a temporary location.
      try {
         $pluginDir = $pluginHelper->extractPlugin($temporaryFile->getFilePath(), $temporaryFile->getOriginalFileName());
      } catch (Exception $e) {
         $notificationMgr->createTrivialNotification($user->getId(), NOTIFICATION_TYPE_ERROR, array('contents' => $e->getMessage()));
         return false;
      } finally {
         $temporaryFileManager->deleteById($temporaryFile->getId(), $user->getId());
      }
 
      // Install or upgrade the extracted plugin.
      try {
         switch ($this->_function) {
            case PLUGIN_ACTION_UPLOAD:
               $pluginVersion = $pluginHelper->installPlugin($pluginDir);
               $notificationMgr->createTrivialNotification(
                  $user->getId(),
                  NOTIFICATION_TYPE_SUCCESS,
                  array('contents' =>
                     __('manager.plugins.installSuccessful', array('versionNumber' => $pluginVersion->getVersionString(false))))
               );
               break;
            case PLUGIN_ACTION_UPGRADE:
               $plugin = PluginRegistry::getPlugin($request->getUserVar('category'), $request->getUserVar('plugin'));
               $pluginVersion = $pluginHelper->upgradePlugin(
                  $request->getUserVar('category'),
                  basename($plugin->getPluginPath()),
                  $pluginDir
               );
               $notificationMgr->createTrivialNotification(
                  $user->getId(),
                  NOTIFICATION_TYPE_SUCCESS,
                  array('contents' => __('manager.plugins.upgradeSuccessful', array('versionString' => $pluginVersion->getVersionString(false))))
               );
               break;
            default: assert(false); // Illegal PLUGIN_ACTION_...
         }
      } catch (Exception $e) {
         $notificationMgr->createTrivialNotification($user->getId(), NOTIFICATION_TYPE_ERROR, array('contents' => $e->getMessage()));
         $temporaryFileManager->rmtree($pluginDir);
         return false;
      }
      return true;
   }
}