os2web_citizen_proposals.module

<?php

/**
 * @file
 * OS2Web Citizen Proposals module file.
 */

use Drupal\Core\Cache\Cache;
use Drupal\Core\Entity\EntityInterface;
use Drupal\node\Entity\Node;
use Drupal\os2web_citizen_proposals\Form\SettingsForm;

/**
 * Implements hook_theme().
 */
function os2web_citizen_proposals_theme($existing, $type, $theme, $path) {
  return [
    'paragraph__os2web_citizen_proposals__default' => [
      'template' => 'paragraph--os2web-citizen-proposals',
      'base hook' => 'paragraph',
      'variables' => [
        'new_proposal_form' => NULL,
        'active_proposals' => NULL,
      ],
    ],
  ];
}

/**
 * Implements hook_preprocess_paragraph().
 *
 * Adding proposal page into into paragraph.
 */
function os2web_citizen_proposals_preprocess_paragraph__os2web_citizen_proposals(&$variables) {
  if ($variables['view_mode'] == 'preview') {
    return;
  }

  $form = \Drupal::formBuilder()->getForm('Drupal\os2web_citizen_proposals\Form\CreateProposalForm');
  $variables['new_proposal_form'] = $form;

  $query = \Drupal::entityQuery('node');
  $query->accessCheck();
  $query->condition('status', 1);
  $query->condition('type', 'os2web_citizen_proposals');
  $entity_ids = $query->execute();
  if (!empty($entity_ids)) {
    $proposals = Node::loadMultiple($entity_ids);

    foreach ($proposals as $proposal) {
      $variables['published_proposals'][$proposal->id()] = [
        'proposal_node' => $proposal,
        'vote_form' => \Drupal::formBuilder()->getForm('Drupal\os2web_citizen_proposals\Form\ProposalVoteForm', $proposal->id()),
        'votes_count' => $proposal->get('field_os2web_cit_props_votes')->comment_count,
      ];

      $tags = Cache::buildTags('node', [$proposal->id()]);
      $variables['#cache']['tags'] = Cache::mergeTags($variables['#cache']['tags'] ?? [], $tags);
    }
  }

  $tags = Cache::buildTags('node_list', ['os2web_citizen_proposals']);
  $variables['#cache']['tags'] = Cache::mergeTags($variables['#cache']['tags'] ?? [], $tags);
}

/**
 * Implements hook_ENTITY_TYPE_presave().
 */
function os2web_citizen_proposals_node_presave(EntityInterface $entity) {
  if ($entity->bundle() != 'os2web_citizen_proposals') {
    return;
  }

  // Skip for new nodes.
  if ($entity->isNew()) {
    return;
  }

  // Publish node if proposal is accepted.
  // Unpublish node if proposal is rejected.
  $status = $entity->field_os2web_cit_props_status->value;
  if ($status == 'accept') {
	$entity->setPublished();

	$config = \Drupal::config('os2web_citizen_proposals.settings');
	$writePublishDate = ($config->get('proposal_publish_date_on_author') == 1);
	if ($writePublishDate && $entity->original->field_os2web_cit_props_status->value != $status) {
        	$entity->setCreatedTime(time());
	}

  } elseif ($status == 'reject') {
    $entity->setUnpublished();
  }

  // Send emails only if status updated.
  if ($entity->original->field_os2web_cit_props_status->value != $status) {
    /** @var \Drupal\os2web_citizen_proposals\Service\ProposalEmailService $emailService */
    $emailService = \Drupal::service('os2web_citizen_proposals.email_service');

    if ($status == 'accept') {
      $emailService->sendUserProposalAcceptedEmail($entity);
    }
    elseif ($status == 'reject') {
      $emailService->sendUserProposalRejectedEmail($entity);
    }
  }
}

/**
 * Implements hook_mail().
 */
function os2web_citizen_proposals_mail($key, &$message, $params) {
  $message['subject'] = $params['subject'];
  $message['body'][] = $params['body'];

  if (!isset($params['from'])) {
    $params['from'] = \Drupal::config('system.site')->get('mail');
  }

  if (!isset($params['sender'])) {
    $params['sender'] = \Drupal::config('system.site')->get('name');
  }
  $params['sender'] = '=?UTF-8?B?' . base64_encode($params['sender']) . '?=';

  $message['headers'] = array_merge($message['headers'], [
    'Content-Type' => 'text/html; charset=UTF-8;',
    'Content-Transfer-Encoding' => '8Bit',
    'MIME-Version' => '1.0',
    'Reply-To' => $params['from'],
  ]);

  if (isset($params['Cc'])) {
    $message['headers']['Cc'] = $params['Cc'];
  }

  if (isset($params['Bcc'])) {
    $message['headers']['Bcc'] = $params['Bcc'];
  }
}

/**
 * Implements hook_cron().
 */
function os2web_citizen_proposals_cron() {
  os2web_citizen_proposals_expire_nodes();
  os2web_citizen_proposals_delete_nodes();
}

/**
 * Unpublish proposals when they are older than specified period.
 */
function os2web_citizen_proposals_expire_nodes() {
  $config = \Drupal::config(SettingsForm::$configName);
  $publishPeriodMonths = $config->get('proposal_publish_period_months');
  if (!$publishPeriodMonths) {
    $publishPeriodMonths = 2;
  }

  $publishPeriodTs = strtotime("-$publishPeriodMonths months");

  $query = \Drupal::entityQuery('node');
  $query->accessCheck(false);
  $query->condition('status', 1);
  $query->condition('type', 'os2web_citizen_proposals');
  $query->condition('created', $publishPeriodTs, '<');
  $entity_ids = $query->execute();

  if (empty($entity_ids)) {
    return;
  }

    $max = $config->get('proposal_max_votes');
    $nodes = Node::loadMultiple($entity_ids);
    $emailService = \Drupal::service('os2web_citizen_proposals.email_service');


    $nodes = Node::loadMultiple($entity_ids);
  /** @var \Drupal\node\NodeInterface $node */
  foreach ($nodes as $node) {

      $votes = $node->get('field_os2web_cit_props_votes')->comment_count;
      if ($votes < $max ) {
          $emailService->sendUserProposalNotMaxedEmail($node);
      }

      if ($node->hasField('field_os2web_cit_props_status')) {
        $node->field_os2web_cit_props_status = "expired";
      }
      $node->setUnpublished();
      $node->save();
  }
}

/**
 * Deletes proposals when they are older than specified period.
 */
function os2web_citizen_proposals_delete_nodes() {
  $config = \Drupal::config(SettingsForm::$configName);
  $lifePeriodMonths = $config->get('proposal_life_period_months');
  if (!$lifePeriodMonths) {
    $lifePeriodMonths = 24;
  }

  $lifePeriodTs = strtotime("-$lifePeriodMonths months");

  $query = \Drupal::entityQuery('node');
  $query->accessCheck(false);
  $query->condition('type', 'os2web_citizen_proposals');
  $query->condition('created', $lifePeriodTs, '<');
  $entity_ids = $query->execute();

  if (empty($entity_ids)) {
    return;
  }

  $nodes = Node::loadMultiple($entity_ids);
  /** @var \Drupal\node\NodeInterface $node */
  foreach ($nodes as $node) {
    $node->delete();
  }
}

/**
 * Implements hook_entity_delete().
 *
 * Invalidates the cache of a node when a comment is deleted.
 */
function os2web_citizen_proposals_comment_delete(EntityInterface $entity) {
  // Get the commented entity (e.g., the node).
  $commented_entity = $entity->getCommentedEntity();

  // Check if the commented entity is a node.
  if ($commented_entity && $commented_entity->getEntityTypeId() === 'node') {
    // Invalidate the cache of the node.
    \Drupal::service('cache_tags.invalidator')->invalidateTags(['node:' . $commented_entity->id()]);
  }
}