atom.module

<?php

/**
 * @file
 * Contains atom.module.
 */

use Drupal\Core\Routing\RouteMatchInterface;

function atom_page_attachments(array &$attachments) {
  $attachments['#attached']['library'][] = 'atom/atom';
}

/**
 * Implements hook_help().
 */
function atom_help($route_name, RouteMatchInterface $route_match)
{
    switch ($route_name) {
        // Main module help for the atom module.
        case 'help.page.atom':
            $output = '';
            $output .= '<h3>' . t('About') . '</h3>';
            $output .= '<p>' . t('This module integrates AtoM REST API and feed to drupal nodes Holdings') . '</p>';
            return $output;

        default:
    }
}

/**
 * Implements hook_theme().
 */
function atom_theme()
{
    return [
        'atom' => [
            'render element' => 'children',
        ],
    ];
}

/**
 *  Implement hook_cron
 */
function atom_cron()
{
   startDownloadAtomHoldings();
}

/**
 * Trigger download Holdings process
 */
function startDownloadAtomHoldings() {
    $config = \Drupal::config('atom.atomapiconfig');
    $service = \Drupal::service('atom.download');

    $repoIds = explode(',', $config->get('atom-repoid'));

    $result = [];

    foreach ($repoIds as $repoId) {
        $r = $service->get($repoId, null);
        $result = array_merge($result, $r);
    }

    $nids = $service->atomHoldingToNode($result);
    $service->deleteStaleHoldings($nids);

    \Drupal::logger('atom')->notice(
        'AtoM sync complete. Found @total holdings, created @created, updated @updated, deleted @deleted.',
        [
            '@total' => count($nids),
            '@created' => $service->created,
            '@updated' => $service->updated,
            '@deleted' => $service->deleted
        ]
    );
}

/**
 * Generate Path Alias for Holding node only
 * @param $node
 */
function generateHoldingAlias($node)
{
    $tag = "/holdings/" . createSlug($node->title->value);
    if (!\Drupal::service('path_alias.repository')->lookupByAlias($tag, 'en')) {
        //$path = \Drupal::service('path_alias.repository')->save("/node/" . $node->id(), $tag, "en");
        $path_alias = \Drupal::entityTypeManager()->getStorage('path_alias')->create([
            'path' => "/node/" . $node->id(),
            'langcode' => "en",
        ]);
        $path_alias->save();

    }
}

/**
 * Implements hook_insert().
 */
function atom_entity_insert(\Drupal\Core\Entity\EntityInterface $node)
{
    // Set the URL alias
    //if (get_class($node) == 'Drupal\node\Entity\Node') {
    if ($node->getEntityType()->id() == 'node' && in_array($node->getType(), ['holding'])) {
        generateHoldingAlias($node);

        // trigger email sending action.
        $action = \Drupal::entityTypeManager()
          ->getStorage('action')
          ->load('send_email');

        if ($action) {
          $action->execute([$node]);
        }
    }
}

function atom_entity_update(\Drupal\Core\Entity\EntityInterface $node)
{
    // Set the URL alias
    //if (get_class($node) == 'Drupal\node\Entity\Node') {
    if ($node->getEntityType()->id() == 'node' && in_array($node->getType(), ['holding'])) {
        generateHoldingAlias($node);
    }
}

/**
 * Debug function: display any variable to error log
 *
 * @param $thing
 */
if (!function_exists('logging')) {
    function print_log($thing)
    {
        error_log(print_r($thing, true), 0);
    }

}

/**
 * Debug function: display any variable to current webpage
 * @param $thing
 */
if (!function_exists('logging')) {
    function logging($thing)
    {
        echo "<pre>";
        print_r($thing);
        echo "</pre>";
    }
}

function atom_update_9020() {
    $schema = \Drupal\Core\Database\Database::getConnection()->schema();

    $spec = ['type' => 'text', 'size' => 'big', 'not null' => TRUE];

    $tables = [
        'node__field_conditions_governing_acces',
        'node_revision__field_conditions_governing_acces'
    ];

    foreach ($tables as $table) {
        $schema->changeField(
            $table,
            'field_conditions_governing_acces_value',
            'field_conditions_governing_acces_value',
            $spec
        );
    }
}