| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194 |
- <?php
- namespace MailPoet\Newsletter;
- if (!defined('ABSPATH')) exit;
- use DateTimeInterface;
- use MailPoet\Logging\LoggerFactory;
- use MailPoet\Newsletter\Editor\Transformer;
- use MailPoet\WP\Functions as WPFunctions;
- class AutomatedLatestContent {
- const DEFAULT_POSTS_PER_PAGE = 10;
- /** @var LoggerFactory */
- private $loggerFactory;
- /** @var int|false */
- private $newsletterId;
- /** @var WPFunctions */
- private $wp;
- public function __construct(
- LoggerFactory $loggerFactory,
- WPFunctions $wp
- ) {
- $this->loggerFactory = $loggerFactory;
- $this->wp = $wp;
- }
- public function filterOutSentPosts(string $where): string {
- $sentPostsQuery = 'SELECT ' . MP_NEWSLETTER_POSTS_TABLE . '.post_id FROM '
- . MP_NEWSLETTER_POSTS_TABLE . ' WHERE '
- . MP_NEWSLETTER_POSTS_TABLE . ".newsletter_id='" . $this->newsletterId . "'";
- $wherePostUnsent = 'ID NOT IN (' . $sentPostsQuery . ')';
- if (!empty($where)) $wherePostUnsent = ' AND ' . $wherePostUnsent;
- return $where . $wherePostUnsent;
- }
- public function ensureConsistentQueryType(\WP_Query $query) {
- // Queries with taxonomies are autodetected as 'is_archive=true' and 'is_home=false'
- // while queries without them end up being 'is_archive=false' and 'is_home=true'.
- // This is to fix that by always enforcing constistent behavior.
- $query->is_archive = true; // phpcs:ignore Squiz.NamingConventions.ValidVariableName.MemberNotCamelCaps
- $query->is_home = false; // phpcs:ignore Squiz.NamingConventions.ValidVariableName.MemberNotCamelCaps
- }
- public function getPosts($args, $postsToExclude = [], $newsletterId = false, $newerThanTimestamp = false) {
- $this->newsletterId = $newsletterId;
- // Get posts as logged out user, so private posts hidden by other plugins (e.g. UAM) are also excluded
- $currentUserId = $this->wp->getCurrentUserId();
- $this->wp->wpSetCurrentUser(0);
- $this->loggerFactory->getLogger(LoggerFactory::TOPIC_POST_NOTIFICATIONS)->addInfo(
- 'loading automated latest content',
- ['args' => $args, 'posts_to_exclude' => $postsToExclude, 'newsletter_id' => $newsletterId, 'newer_than_timestamp' => $newerThanTimestamp]
- );
- $postsPerPage = (!empty($args['amount']) && (int)$args['amount'] > 0)
- ? (int)$args['amount']
- : self::DEFAULT_POSTS_PER_PAGE;
- $parameters = [
- 'posts_per_page' => $postsPerPage,
- 'post_type' => (isset($args['contentType'])) ? $args['contentType'] : 'post',
- 'post_status' => (isset($args['postStatus'])) ? $args['postStatus'] : 'publish',
- 'orderby' => 'date',
- 'order' => ($args['sortBy'] === 'newest') ? 'DESC' : 'ASC',
- ];
- if (!empty($args['offset']) && (int)$args['offset'] > 0) {
- $parameters['offset'] = (int)$args['offset'];
- }
- if (isset($args['search'])) {
- $parameters['s'] = $args['search'];
- }
- if (isset($args['posts']) && is_array($args['posts'])) {
- $parameters['post__in'] = $args['posts'];
- $parameters['posts_per_page'] = -1; // Get all posts with matching IDs
- }
- if (!empty($postsToExclude)) {
- $parameters['post__not_in'] = $postsToExclude;
- }
- $parameters['tax_query'] = $this->constructTaxonomiesQuery($args);
- // WP posts with the type attachment have always post_status `inherit`
- if ($parameters['post_type'] === 'attachment' && $parameters['post_status'] === 'publish') {
- $parameters['post_status'] = 'inherit';
- }
- // This enables using posts query filters for get_posts, where by default
- // it is disabled.
- // However, it also enables other plugins and themes to hook in and alter
- // the query.
- $parameters['suppress_filters'] = false;
- if ($newerThanTimestamp instanceof DateTimeInterface) {
- $parameters['date_query'] = [
- [
- 'column' => 'post_date',
- 'after' => $newerThanTimestamp->format('Y-m-d H:i:s'),
- ],
- ];
- }
- // set low priority to execute 'ensureConstistentQueryType' before any other filter
- $filterPriority = defined('PHP_INT_MIN') ? constant('PHP_INT_MIN') : ~PHP_INT_MAX;
- $this->wp->addAction('pre_get_posts', [$this, 'ensureConsistentQueryType'], $filterPriority);
- $this->_attachSentPostsFilter($newsletterId);
- $this->loggerFactory->getLogger(LoggerFactory::TOPIC_POST_NOTIFICATIONS)->addInfo(
- 'getting automated latest content',
- ['parameters' => $parameters]
- );
- $posts = $this->wp->getPosts($parameters);
- $this->logPosts($posts);
- $this->wp->removeAction('pre_get_posts', [$this, 'ensureConsistentQueryType'], $filterPriority);
- $this->_detachSentPostsFilter($newsletterId);
- $this->wp->wpSetCurrentUser($currentUserId);
- return $posts;
- }
- public function transformPosts($args, $posts) {
- $transformer = new Transformer($args);
- return $transformer->transform($posts);
- }
- public function constructTaxonomiesQuery($args) {
- $taxonomiesQuery = [];
- if (isset($args['terms']) && is_array($args['terms'])) {
- $taxonomies = [];
- // Categorize terms based on their taxonomies
- foreach ($args['terms'] as $term) {
- $taxonomy = $term['taxonomy'];
- if (!isset($taxonomies[$taxonomy])) {
- $taxonomies[$taxonomy] = [];
- }
- $taxonomies[$taxonomy][] = $term['id'];
- }
- foreach ($taxonomies as $taxonomy => $terms) {
- if (!empty($terms)) {
- $tax = [
- 'taxonomy' => $taxonomy,
- 'field' => 'id',
- 'terms' => $terms,
- ];
- if ($args['inclusionType'] === 'exclude') $tax['operator'] = 'NOT IN';
- $taxonomiesQuery[] = $tax;
- }
- }
- if (!empty($taxonomiesQuery)) {
- // With exclusion we want to use 'AND', because we want posts that
- // don't have excluded tags/categories. But with inclusion we want to
- // use 'OR', because we want posts that have any of the included
- // tags/categories
- $taxonomiesQuery['relation'] = ($args['inclusionType'] === 'exclude') ? 'AND' : 'OR';
- }
- }
- // make $taxonomies_query nested to avoid conflicts with plugins that use taxonomies
- return empty($taxonomiesQuery) ? [] : [$taxonomiesQuery];
- }
- private function _attachSentPostsFilter($newsletterId) {
- if ($newsletterId > 0) {
- $this->wp->addAction('posts_where', [$this, 'filterOutSentPosts']);
- }
- }
- private function _detachSentPostsFilter($newsletterId) {
- if ($newsletterId > 0) {
- $this->wp->removeAction('posts_where', [$this, 'filterOutSentPosts']);
- }
- }
- private function logPosts(array $posts) {
- $postsToLog = [];
- foreach ($posts as $post) {
- $postsToLog[] = [
- 'id' => $post->ID,
- 'post_date' => $post->post_date, // phpcs:ignore Squiz.NamingConventions.ValidVariableName.MemberNotCamelCaps
- ];
- }
- $this->loggerFactory->getLogger(LoggerFactory::TOPIC_POST_NOTIFICATIONS)->addInfo(
- 'automated latest content loaded posts',
- ['posts' => $postsToLog]
- );
- }
- }
|