public function AcquiaContentHubSubscriberCommands::upgrade in Acquia Content Hub 8.2

Subscriber Upgrade Command.

Migrates filters and adds imported entities to interest list.

@command acquia:contenthub-subscriber-upgrade @aliases ach-subscriber-upgrade,ach-suup

File

modules/acquia_contenthub_subscriber/src/Commands/AcquiaContentHubSubscriberCommands.php, line 92

Class

AcquiaContentHubSubscriberCommands

Drush commands for Acquia Content Hub subscribers.

Namespace

Drupal\acquia_contenthub_subscriber\Commands

Code

public function upgrade() {

  // Only proceed if there still exists a legacy tracking table.
  if (!$this->database
    ->schema()
    ->tableExists('acquia_contenthub_entities_tracking')) {
    $this->logger
      ->log(LogLevel::CANCEL, dt('Legacy tracking table does not exist.'));
    return;
  }

  // Make sure webhook stored is actually registered for this site in Plexus.
  $settings = $this->clientFactory
    ->getSettings();
  $client = $this->clientFactory
    ->getClient($settings);
  if (!$client
    ->getSettings()
    ->getWebhook()) {

    // Proceed to register a webhook in HMAC v2.
    $webhook_url = Url::fromUri('internal:' . '/acquia-contenthub/webhook', [
      'absolute' => TRUE,
    ])
      ->toString();
    $webhook = $client
      ->getWebHook($webhook_url);
    if (empty($webhook)) {
      $connection_manager = \Drupal::service('acquia_contenthub.connection_manager');
      $response = $connection_manager
        ->registerWebhook($webhook_url);
      if (isset($response['success']) && FALSE === $response['success']) {
        $message = dt('Registering webhooks encountered an error (code @code). @reason', [
          '@code' => $response['error']['code'],
          '@reason' => $response['error']['message'],
        ]);
        $this->logger
          ->log(LogLevel::ERROR, $message);
        return;
      }
    }
  }

  // Bail out early if legacy filters do not exist.
  $filters = $this->state
    ->get('acquia_contenthub_subscriber_82002_acquia_contenthub_filters', []);
  if (empty($filters)) {
    $this->logger
      ->alert('This site has no filters to migrate.');
  }
  else {

    // Migrating filters.
    module_load_include('inc', 'acquia_contenthub_subscriber', 'acquia_contenthub_subscriber.filters.migrate');
    $unmigrated_filters = [];
    $migrated_filters = [];
    foreach ($filters as $contenthub_filter) {
      $cloud_filter = acquia_contenthub_subscriber_migrate_filter($contenthub_filter);
      if (!acquia_contenthub_subscriber_put_filter($cloud_filter)) {

        // Could not migrate to Cloud Filter. Save filter on a state variable.
        $unmigrated_filters[] = $contenthub_filter;
      }
      else {
        $migrated_filters[] = $contenthub_filter['name'];
      }
    }
    if (!empty($migrated_filters)) {
      $this->logger
        ->log(LogLevel::INFO, dt('Filters migrated successfully: %filters.', [
        '%filters' => implode(',', $migrated_filters),
      ]));
    }
    if (!empty($unmigrated_filters)) {

      // Saving unmigrated filters in state variable.
      $this->state
        ->set('acquia_contenthub_subscriber_82002_unmigrated_filters', $unmigrated_filters);
      $this->logger
        ->log(LogLevel::WARNING, dt('The following filters could not be properly migrated: %filters.', [
        '%filters' => implode(',', array_column($unmigrated_filters, 'name')),
      ]));
    }

    // Delete State variable.
    $this->state
      ->delete('acquia_contenthub_subscriber_82002_acquia_contenthub_filters');
  }

  // Adding imported entities to interest list.
  $path = $this->moduleHandler
    ->getModule('acquia_contenthub_subscriber')
    ->getPath();
  $batch = [
    'title' => t('Adding Imported Entities to Interest List'),
    'operations' => [
      [
        'acquia_contenthub_subscriber_track_imported_linked_entities',
        [],
      ],
      [
        'acquia_contenthub_subscriber_track_imported_unlinked_entities',
        [],
      ],
    ],
    'file' => $path . '/acquia_contenthub_subscriber.migrate.inc',
  ];
  batch_set($batch);
  drush_backend_batch_process();
}