Elgg-Lorea-Hydra/mod/blog_tools/classes/ColdTrick/BlogTools/Cron.php

<?php

namespace ColdTrick\BlogTools;

/**
 * Cron handling
 *
 * @package    ColdTrick
 * @subpackage BlogTools
 */
class Cron {
	
	/**
	 * Publish blogs based on advanced publication options
	 *
	 * @param string $hook         'cron'
	 * @param string $type         'daily'
	 * @param string $return_value optional stdout text
	 * @param array  $params       supplied params
	 *
	 * @return void
	 */
	public static function daily($hook, $type, $return_value, $params) {
		
		// only do if this is configured
		if (!blog_tools_use_advanced_publication_options()) {
			return $return_value;
		}
		
		$dbprefix = elgg_get_config("dbprefix");
		$publication_id = elgg_get_metastring_id("publication_date");
		$expiration_id = elgg_get_metastring_id("expiration_date");
		
		$time = elgg_extract("time", $params, time());
		
		$publish_options = array(
			"type" => "object",
			"subtype" => "blog",
			"limit" => false,
			"joins" => array(
				"JOIN " . $dbprefix . "metadata mdtime ON e.guid = mdtime.entity_guid",
				"JOIN " . $dbprefix . "metastrings mstime ON mdtime.value_id = mstime.id"
			),
			"metadata_name_value_pairs" => array(
				array(
					"name" => "status",
					"value" => "draft"
				)
			),
			"wheres" => array("((mdtime.name_id = " . $publication_id . ") AND (DATE(mstime.string) = DATE(NOW())))")
		);
		
		$unpublish_options = array(
			"type" => "object",
			"subtype" => "blog",
			"limit" => false,
			"joins" => array(
				"JOIN " . $dbprefix . "metadata mdtime ON e.guid = mdtime.entity_guid",
				"JOIN " . $dbprefix . "metastrings mstime ON mdtime.value_id = mstime.id"
			),
			"metadata_name_values_pairs" => array(
				array(
					"name" => "status",
					"value" => "published"
				)
			),
			"wheres" => array("((mdtime.name_id = " . $expiration_id . ") AND (DATE(mstime.string) = DATE(NOW())))")
		);
		
		// ignore access
		$ia = elgg_set_ignore_access(true);
		
		// get unpublished blogs that need to be published
		$entities = new \ElggBatch("elgg_get_entities_from_metadata", $publish_options);
		foreach ($entities as $entity) {
			// add river item
			elgg_create_river_item(array(
				"view" => "river/object/blog/create",
				"action_type" => "create",
				"subject_guid" => $entity->getOwnerGUID(),
				"object_guid" => $entity->getGUID(),
			));

			// set correct time created
			$entity->time_created = $time;

			// publish blog
			$entity->status = "published";
			
			// revert access
			$entity->access_id = $entity->future_access;
			unset($entity->future_access);
			
			
			// send notifications when post published
			elgg_trigger_event('publish', 'object', $entity);

			// notify owner
			notify_user($entity->getOwnerGUID(),
				$entity->site_guid,
				elgg_echo("blog_tools:notify:publish:subject"),
				elgg_echo("blog_tools:notify:publish:message", array(
					$entity->title,
					$entity->getURL()
				))
			);

			// save everything
			$entity->save();
		}
	
		// get published blogs that need to be unpublished
		$entities = new \ElggBatch("elgg_get_entities_from_metadata", $unpublish_options);
		foreach ($entities as $entity) {
			// remove river item
			elgg_delete_river(array(
				"object_guid" => $entity->getGUID(),
				"action_type" => "create",
			));

			// unpublish blog
			$entity->status = "draft";

			// notify owner
			notify_user($entity->getOwnerGUID(),
				$entity->site_guid,
				elgg_echo("blog_tools:notify:expire:subject"),
				elgg_echo("blog_tools:notify:expire:message", array(
					$entity->title,
					$entity->getURL()
				))
			);

			// save everything
			$entity->save();
		}
	
		// reset access
		elgg_set_ignore_access($ia);
	}
}