content_workflow_bynder-1.0.0/content_workflow_bynder_upload/content_workflow_bynder_upload.module

<?php

/**
 * @file
 * Main module file for Content Workflow Upload module.
 */

use Drupal\Core\Entity\EntityInterface;
use Drupal\content_workflow_bynder\Entity\MappingInterface;

/**
 * Upload batch operation callback.
 *
 * @param \Drupal\Core\Entity\EntityInterface $entity
 *   Object of entity we want to upload.
 * @param \Drupal\content_workflow_bynder\Entity\MappingInterface $mapping
 *   Mapping object.
 * @param int|null $cwbId
 *   ContentWorkflowBynder ID.
 * @param array $context
 *   Context of operation.
 */
function content_workflow_bynder_upload_process(EntityInterface $entity, MappingInterface $mapping, $cwbId = NULL, &$context = []) {
  /** @var \Drupal\content_workflow_bynder_upload\Export\Exporter $exporter */
  $exporter = \Drupal::service('content_workflow_bynder_upload.exporter');

  if (!isset($context['results']['success'])) {
    $context['results']['success'] = 0;
  }

  if (!isset($context['results']['failed'])) {
    $context['results']['failed'] = 0;
  }

  try {
    $exporter->export($entity, $mapping, $cwbId, $context);
    $context['results']['success']++;
  }
  catch (\Exception $e) {
    $context['results']['messages'][] = $e->getMessage();
    $context['results']['failed']++;
  }
}

/**
 * Upload batch operation callback.
 *
 * @param array $context
 *   Context of operation.
 */
function content_workflow_bynder_upload_migrate_update_process(&$context) {
  /** @var \Drupal\content_workflow_bynder_upload\Export\MigrateUpdater $migrateUpdater */
  $migrateUpdater = \Drupal::service('content_workflow_bynder_upload.migrate_updater');
  try {
    $migrateUpdater->updateIdMap($context);
  }
  catch (\Exception $e) {
    $context['results']['messages'][] = $e->getMessage();
  }
}