You are here

Home » API reference » Opigno module 8 » ImportActivityForm.php » ImportActivityForm

public function ImportActivityForm::submitForm in Opigno module 8

Same name and namespace in other branches
  1. 3.x src/Form/ImportActivityForm.php \Drupal\opigno_module\Form\ImportActivityForm::submitForm()

Form submission handler.

Parameters

array $form: An associative array containing the structure of the form.

\Drupal\Core\Form\FormStateInterface $form_state: The current state of the form.

Overrides FormInterface::submitForm

File

src/Form/ImportActivityForm.php, line 76

Class

ImportActivityForm
Import Activity form.

Namespace

Drupal\opigno_module\Form

Code

public function submitForm(array &$form, FormStateInterface $form_state) {

  // Prepare folder.
  $temporary_file_path = 'public://opigno-import';
  \Drupal::service('file_system')
    ->deleteRecursive($temporary_file_path);
  \Drupal::service('file_system')
    ->prepareDirectory($temporary_file_path, FileSystemInterface::MODIFY_PERMISSIONS | FileSystemInterface::CREATE_DIRECTORY);

  // Prepare file validators.
  $extensions = [
    'opi',
  ];
  $validators = [
    'file_validate_extensions' => $extensions,
  ];
  $files = [];
  $file = file_save_upload('activity_opi', $validators, $temporary_file_path, NULL, FileSystemInterface::EXISTS_REPLACE);
  if (!empty($file[0])) {
    $path = \Drupal::service('file_system')
      ->realpath($file[0]
      ->getFileUri());
    $folder = DRUPAL_ROOT . '/sites/default/files/opigno-import';
    $zip = new \ZipArchive();
    $result = $zip
      ->open($path);
    if ($zip
      ->locateName('.htaccess') !== false) {
      \Drupal::messenger()
        ->addMessage(t('Unsafe files detected.'), 'error');
      $zip
        ->close();
      \Drupal::service('file_system')
        ->delete($path);
      \Drupal::service('file_system')
        ->deleteRecursive($temporary_file_path);
      return;
    }
    if ($result === TRUE) {
      $zip
        ->extractTo($folder);
      $zip
        ->close();
    }
    \Drupal::service('file_system')
      ->delete($path);
    $files = scandir($folder);
  }
  if (in_array('export-opigno_activity.json', $files)) {
    $file_path = $temporary_file_path . '/export-opigno_activity.json';
    $real_path = \Drupal::service('file_system')
      ->realpath($file_path);
    $file = file_get_contents($real_path);
    $format = 'json';
    $serializer = \Drupal::service('serializer');
    $activity_content_array = $serializer
      ->decode($file, $format);
    $content = reset($activity_content_array);
    if (empty($content['bundle'])) {
      \Drupal::messenger()
        ->addMessage(t('Incorrect archive structure.'), 'error');
      return;
    }
    $new_activity = OpignoActivity::create([
      'type' => $content['bundle'],
    ]);
    $new_activity
      ->setName($content['name'][0]['value']);
    $new_activity
      ->set('langcode', $content['langcode'][0]['value']);
    $new_activity
      ->set('status', $content['status'][0]['value']);
    prepare_directory_structure_for_import();
    switch ($content['bundle']) {
      case 'opigno_long_answer':
        $new_activity->opigno_body->value = $content['opigno_body'][0]['value'];
        $new_activity->opigno_body->format = $content['opigno_body'][0]['format'];
        $new_activity->opigno_evaluation_method->value = $content['opigno_evaluation_method'][0]['value'];
        break;
      case 'opigno_file_upload':
        $new_activity->opigno_body->value = $content['opigno_body'][0]['value'];
        $new_activity->opigno_body->format = $content['opigno_body'][0]['format'];
        $new_activity->opigno_evaluation_method->value = $content['opigno_evaluation_method'][0]['value'];
        $new_activity->opigno_allowed_extension->value = $content['opigno_allowed_extension'][0]['value'];
        break;
      case 'opigno_scorm':
        foreach ($content['files'] as $file_key => $file_content) {
          $scorm_file_path = $temporary_file_path . '/' . $file_key;
          $uri = \Drupal::service('file_system')
            ->copy($scorm_file_path, 'public://opigno_scorm/' . $file_content['file_name'], FileSystemInterface::EXISTS_RENAME);
          $file = File::Create([
            'uri' => $uri,
            'uid' => $this
              ->currentUser()
              ->id(),
            'status' => $file_content['status'],
          ]);
          $file
            ->save();
          $fid = $file
            ->id();
          $new_activity->opigno_scorm_package->target_id = $fid;
          $new_activity->opigno_scorm_package->display = 1;
        }
        break;
      case 'opigno_tincan':
        foreach ($content['files'] as $file_key => $file_content) {
          $tincan_file_path = $temporary_file_path . '/' . $file_key;
          $uri = \Drupal::service('file_system')
            ->copy($tincan_file_path, 'public://opigno_tincan/' . $file_content['file_name'], FileSystemInterface::EXISTS_RENAME);
          $file = File::Create([
            'uri' => $uri,
            'uid' => $this
              ->currentUser()
              ->id(),
            'status' => $file_content['status'],
          ]);
          $file
            ->save();
          $fid = $file
            ->id();
          $new_activity->opigno_tincan_package->target_id = $fid;
          $new_activity->opigno_tincan_package->display = 1;
        }
        break;
      case 'opigno_slide':
        foreach ($content['files'] as $file_key => $file_content) {
          $slide_file_path = $temporary_file_path . '/' . $file_key;
          $current_timestamp = \Drupal::time()
            ->getCurrentTime();
          $date = date('Y-m', $current_timestamp);
          $uri = \Drupal::service('file_system')
            ->copy($slide_file_path, 'public://' . $date . '/' . $file_content['file_name'], FileSystemInterface::EXISTS_RENAME);
          $file = File::Create([
            'uri' => $uri,
            'uid' => $this
              ->currentUser()
              ->id(),
            'status' => $file_content['status'],
          ]);
          $file
            ->save();
          $media = Media::create([
            'bundle' => $file_content['bundle'],
            'name' => $file_content['file_name'],
            'field_media_file' => [
              'target_id' => $file
                ->id(),
            ],
          ]);
          $media
            ->save();
          $new_activity->opigno_slide_pdf->target_id = $media
            ->id();
          $new_activity->opigno_slide_pdf->display = 1;
        }
        break;
      case 'opigno_video':
        foreach ($content['files'] as $file_key => $file_content) {
          $video_file_path = $temporary_file_path . '/' . $file_key;
          $current_timestamp = \Drupal::time()
            ->getCurrentTime();
          $date = date('Y-m', $current_timestamp);
          $uri = \Drupal::service('file_system')
            ->copy($video_file_path, 'public://video-thumbnails/' . $date . '/' . $file_content['file_name'], FileSystemInterface::EXISTS_RENAME);
          $file = File::Create([
            'uri' => $uri,
            'uid' => $this
              ->currentUser()
              ->id(),
            'status' => $file_content['status'],
          ]);
          $file
            ->save();
          $new_activity->field_video->target_id = $file
            ->id();
        }
        break;
      case 'opigno_h5p':
        $h5p_content_id = $content['opigno_h5p'][0]['h5p_content_id'];
        $file = $folder . "/interactive-content-{$h5p_content_id}.h5p";
        $interface = H5PDrupal::getInstance();
        if ($file) {
          $file_service = \Drupal::service('file_system');
          $dir = $file_service
            ->realpath($temporary_file_path . '/h5p');
          $interface
            ->getUploadedH5pFolderPath($dir);
          $interface
            ->getUploadedH5pPath($folder . "/interactive-content-{$h5p_content_id}.h5p");
          $editor = H5PEditorUtilities::getInstance();
          $h5pEditorAjax = new H5PEditorAjaxImport($editor->ajax->core, $editor, $editor->ajax->storage);
          if ($h5pEditorAjax
            ->isValidPackage(TRUE)) {

            // Add new libraries from file package.
            $storage = new H5PStorageImport($h5pEditorAjax->core->h5pF, $h5pEditorAjax->core);

            // Serialize metadata array in libraries.
            if (!empty($storage->h5pC->librariesJsonData)) {
              foreach ($storage->h5pC->librariesJsonData as &$library) {
                if (array_key_exists('metadataSettings', $library) && is_array($library['metadataSettings'])) {
                  $metadataSettings = serialize($library['metadataSettings']);
                  $library['metadataSettings'] = $metadataSettings;
                }
              }
            }
            $storage
              ->saveLibraries();
            $h5p_json = $dir . '/h5p.json';
            $real_path = \Drupal::service('file_system')
              ->realpath($h5p_json);
            $h5p_json = file_get_contents($real_path);
            $format = 'json';
            $serializer = \Drupal::service('serializer');
            $h5p_json = $serializer
              ->decode($h5p_json, $format);
            $dependencies = $h5p_json['preloadedDependencies'];
            $database = \Drupal::database();

            // Get ID of main library.
            foreach ($h5p_json['preloadedDependencies'] as $dependency) {
              if ($dependency['machineName'] == $h5p_json['mainLibrary']) {
                $h5p_json['majorVersion'] = $dependency['majorVersion'];
                $h5p_json['minorVersion'] = $dependency['minorVersion'];
              }
            }
            $query = $database
              ->select('h5p_libraries', 'h_l');
            $query
              ->condition('machine_name', $h5p_json['mainLibrary'], '=');
            $query
              ->condition('major_version', $h5p_json['majorVersion'], '=');
            $query
              ->condition('minor_version', $h5p_json['minorVersion'], '=');
            $query
              ->fields('h_l', [
              'library_id',
            ]);
            $query
              ->orderBy('patch_version', 'DESC');
            $main_library_id = $query
              ->execute()
              ->fetchField();
            if (!$main_library_id) {
              $query = $database
                ->select('h5p_libraries', 'h_l');
              $query
                ->condition('machine_name', $h5p_json['mainLibrary'], '=');
              $query
                ->fields('h_l', [
                'library_id',
              ]);
              $query
                ->orderBy('major_version', 'DESC');
              $query
                ->orderBy('minor_version', 'DESC');
              $query
                ->orderBy('patch_version', 'DESC');
              $main_library_id = $query
                ->execute()
                ->fetchField();
            }
            $content_json = $dir . '/content/content.json';
            $real_path = \Drupal::service('file_system')
              ->realpath($content_json);
            $content_json = file_get_contents($real_path);
            $fields = [
              'library_id' => $main_library_id,
              'title' => $h5p_json['title'],
              'parameters' => $content_json,
              'filtered_parameters' => $content_json,
              'disabled_features' => 0,
              'authors' => '[]',
              'changes' => '[]',
              'license' => 'U',
            ];
            $h5p_content = H5PContent::create($fields);
            $h5p_content
              ->save();
            $new_activity
              ->set('opigno_h5p', $h5p_content
              ->id());
            $h5p_dest_path = \Drupal::config('h5p.settings')
              ->get('h5p_default_path');
            $h5p_dest_path = !empty($h5p_dest_path) ? $h5p_dest_path : 'h5p';
            $dest_folder = DRUPAL_ROOT . '/sites/default/files/' . $h5p_dest_path . '/content/' . $h5p_content
              ->id();
            $source_folder = DRUPAL_ROOT . '/sites/default/files/opigno-import/h5p/content/*';
            \Drupal::service('file_system')
              ->prepareDirectory($dest_folder, FileSystemInterface::MODIFY_PERMISSIONS | FileSystemInterface::CREATE_DIRECTORY);
            shell_exec('rm ' . $dest_folder . '/content.json');
            shell_exec('cp -r ' . $source_folder . ' ' . $dest_folder);

            // Clean up.
            $h5pEditorAjax->storage
              ->removeTemporarilySavedFiles($h5pEditorAjax->core->h5pF
              ->getUploadedH5pFolderPath());
            foreach ($dependencies as $dependency_key => $dependency) {
              $query = $database
                ->select('h5p_libraries', 'h_l');
              $query
                ->condition('machine_name', $dependency['machineName'], '=');
              $query
                ->condition('major_version', $dependency['majorVersion'], '=');
              $query
                ->condition('minor_version', $dependency['minorVersion'], '=');
              $query
                ->fields('h_l', [
                'library_id',
              ]);
              $query
                ->orderBy('patch_version', 'DESC');
              $library_id = $query
                ->execute()
                ->fetchField();
              if (!$library_id) {
                $query = $database
                  ->select('h5p_libraries', 'h_l');
                $query
                  ->condition('machine_name', $dependency['machineName'], '=');
                $query
                  ->fields('h_l', [
                  'library_id',
                ]);
                $query
                  ->orderBy('major_version', 'DESC');
                $query
                  ->orderBy('minor_version', 'DESC');
                $query
                  ->orderBy('patch_version', 'DESC');
                $library_id = $query
                  ->execute()
                  ->fetchField();
              }
              if ($h5p_json['mainLibrary'] == $dependency['machineName']) {
                $main_library_values = [
                  'content_id' => $h5p_content
                    ->id(),
                  'library_id' => $library_id,
                  'dependency_type' => 'preloaded',
                  'drop_css' => 0,
                  'weight' => count($dependencies) + 1,
                ];
                continue;
              }
              if ($library_id) {
                $database
                  ->insert('h5p_content_libraries')
                  ->fields([
                  'content_id',
                  'library_id',
                  'dependency_type',
                  'drop_css',
                  'weight',
                ])
                  ->values([
                  'content_id' => $h5p_content
                    ->id(),
                  'library_id' => $library_id,
                  'dependency_type' => 'preloaded',
                  'drop_css' => 0,
                  'weight' => $dependency_key + 1,
                ])
                  ->execute();
              }
            }
            if (!empty($main_library_values)) {
              $database
                ->insert('h5p_content_libraries')
                ->fields([
                'content_id',
                'library_id',
                'dependency_type',
                'drop_css',
                'weight',
              ])
                ->values($main_library_values)
                ->execute();
            }
          }
        }
        break;
    }
    $new_activity
      ->save();
    $route_parameters = [
      'opigno_activity' => $new_activity
        ->id(),
    ];
    \Drupal::messenger()
      ->addMessage(t('Imported activity %activity', [
      '%activity' => Link::createFromRoute($new_activity
        ->label(), 'entity.opigno_activity.canonical', $route_parameters)
        ->toString(),
    ]));
    $form_state
      ->setRedirect('entity.opigno_activity.collection');
  }
}