View source
<?php
namespace Drupal\Tests\scheduler\Functional;
use Drupal\Core\Logger\RfcLogLevel;
use Drupal\rules\Context\ContextConfig;
class SchedulerRulesActionsTest extends SchedulerBrowserTestBase {
protected static $modules = [
'scheduler_rules_integration',
];
protected function setUp() : void {
parent::setUp();
$this->rulesStorage = $this->container
->get('entity_type.manager')
->getStorage('rules_reaction_rule');
$this->expressionManager = $this->container
->get('plugin.manager.rules_expression');
$this
->drupalLogin($this->adminUser);
$this->node_a = $this
->drupalCreateNode([
'title' => 'Initial Test Node',
'type' => $this->type,
'uid' => $this->adminUser
->id(),
'status' => TRUE,
]);
$this->node_b = $this
->drupalCreateNode([
'title' => 'Something Else',
'type' => $this->nonSchedulerNodeType
->id(),
'uid' => $this->adminUser
->id(),
'status' => TRUE,
]);
}
public function testPublishOnActions() {
$publish_on = $this->requestTime + 1800;
$publish_on_formatted = $this->dateFormatter
->format($publish_on, 'long');
$rule1 = $this->expressionManager
->createRule();
$rule1
->addCondition('rules_data_comparison', ContextConfig::create()
->map('data', 'node.title.value')
->setValue('operation', 'contains')
->setValue('value', 'Trigger Action Rule 1'));
$message1 = 'RULES message 1. Action to set Publish-on date.';
$rule1
->addAction('scheduler_set_publishing_date_action', ContextConfig::create()
->map('node', 'node')
->setValue('date', $publish_on))
->addAction('rules_system_message', ContextConfig::create()
->setValue('message', $message1)
->setValue('type', 'status'));
$config_entity = $this->rulesStorage
->create([
'id' => 'rule1',
'events' => [
[
'event_name' => 'rules_entity_presave:node',
],
],
'expression' => $rule1
->getConfiguration(),
]);
$config_entity
->save();
$rule2 = $this->expressionManager
->createRule();
$rule2
->addCondition('rules_data_comparison', ContextConfig::create()
->map('data', 'node.title.value')
->setValue('operation', 'contains')
->setValue('value', 'Trigger Action Rule 2'));
$message2 = 'RULES message 2. Action to remove Publish-on date and publish the node immediately.';
$rule2
->addAction('scheduler_remove_publishing_date_action', ContextConfig::create()
->map('node', 'node'))
->addAction('scheduler_publish_now_action', ContextConfig::create()
->map('node', 'node'))
->addAction('rules_system_message', ContextConfig::create()
->setValue('message', $message2)
->setValue('type', 'status'));
$config_entity = $this->rulesStorage
->create([
'id' => 'rule2',
'events' => [
[
'event_name' => 'rules_entity_presave:node',
],
],
'expression' => $rule2
->getConfiguration(),
]);
$config_entity
->save();
$assert = $this
->assertSession();
$edit = [
'title[0][value]' => 'New node - Trigger Action Rule 1',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/add/' . $this->type, $edit, 'Save');
$node = $this
->drupalGetNodeByTitle('New node - Trigger Action Rule 1');
$this
->assertSession()
->pageTextContains(sprintf('%s is scheduled to be published %s', 'New node - Trigger Action Rule 1', $publish_on_formatted));
$assert
->pageTextContains($message1);
$assert
->pageTextNotContains($message2);
$this
->assertEquals($node->publish_on->value, $publish_on, 'Node is scheduled for publishing at the correct time.');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$this
->assertFalse($node
->isPublished(), 'Node is now unpublished for title: "' . $node->title->value . '".');
$node = $this->node_a;
$edit = [
'title[0][value]' => 'Edit node - but no rules will be triggered',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$this->nodeStorage
->resetCache([
$node
->id(),
]);
$node = $this->nodeStorage
->load($node
->id());
$assert
->pageTextNotContains($message1);
$assert
->pageTextNotContains($message2);
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$this
->assertTrue($node
->isPublished(), 'Node remains published for title: "' . $node->title->value . '".');
$edit = [
'title[0][value]' => 'Edit node - Trigger Action Rule 1',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$this->nodeStorage
->resetCache([
$node
->id(),
]);
$node = $this->nodeStorage
->load($node
->id());
$assert
->pageTextContains($message1);
$assert
->pageTextNotContains($message2);
$this
->assertNotEmpty($node->publish_on->value, 'Node is scheduled for publishing.');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$this
->assertFalse($node
->isPublished(), 'Node is now unpublished for title: "' . $node->title->value . '".');
$edit = [
'title[0][value]' => 'Edit node - Trigger Action Rule 2',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$this->nodeStorage
->resetCache([
$node
->id(),
]);
$node = $this->nodeStorage
->load($node
->id());
$assert
->pageTextNotContains($message1);
$assert
->pageTextContains($message2);
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$this
->assertTrue($node
->isPublished(), 'Node is now published for title: "' . $node->title->value . '".');
$edit = [
'title[0][value]' => 'New non-enabled node - Trigger Action Rule 1',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/add/' . $this->nonSchedulerNodeType
->id(), $edit, 'Save');
$node = $this
->drupalGetNodeByTitle('New non-enabled node - Trigger Action Rule 1');
$assert
->pageTextContains('warning message');
$assert
->elementExists('xpath', '//div[@aria-label="Warning message" and contains(string(), "Action")]');
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$log = \Drupal::database()
->select('watchdog', 'w')
->condition('type', 'scheduler')
->condition('severity', RfcLogLevel::WARNING)
->countQuery()
->execute()
->fetchColumn();
$this
->assertEquals(1, $log, 'There is 1 watchdog warning message from Scheduler');
$node = $this->node_b;
$edit = [
'title[0][value]' => 'Edit non-enabled node - Trigger Action Rule 1',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$assert
->pageTextContains('warning message');
$assert
->elementExists('xpath', '//div[@aria-label="Warning message" and contains(string(), "Action")]');
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$log = \Drupal::database()
->select('watchdog', 'w')
->condition('type', 'scheduler')
->condition('severity', RfcLogLevel::WARNING)
->countQuery()
->execute()
->fetchColumn();
$this
->assertEquals(2, $log, 'There are now 2 watchdog warning messages from Scheduler');
$edit = [
'title[0][value]' => 'Edit non-enabled node - Trigger Action Rule 2',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$assert
->pageTextContains('warning message');
$assert
->elementExists('xpath', '//div[@aria-label="Warning message" and contains(string(), "Action")]');
$log = \Drupal::database()
->select('watchdog', 'w')
->condition('type', 'scheduler')
->condition('severity', RfcLogLevel::WARNING)
->countQuery()
->execute()
->fetchColumn();
$this
->assertEquals(3, $log, 'There are now 3 watchdog warning messages from Scheduler');
}
public function testUnpublishOnActions() {
$unpublish_on = $this->requestTime + 2400;
$unpublish_on_formatted = $this->dateFormatter
->format($unpublish_on, 'long');
$rule3 = $this->expressionManager
->createRule();
$rule3
->addCondition('rules_data_comparison', ContextConfig::create()
->map('data', 'node.title.value')
->setValue('operation', 'contains')
->setValue('value', 'Trigger Action Rule 3'));
$message3 = 'RULES message 3. Action to set Unpublish-on date.';
$rule3
->addAction('scheduler_set_unpublishing_date_action', ContextConfig::create()
->map('node', 'node')
->setValue('date', $unpublish_on))
->addAction('rules_system_message', ContextConfig::create()
->setValue('message', $message3)
->setValue('type', 'status'));
$config_entity = $this->rulesStorage
->create([
'id' => 'rule3',
'events' => [
[
'event_name' => 'rules_entity_presave:node',
],
],
'expression' => $rule3
->getConfiguration(),
]);
$config_entity
->save();
$rule4 = $this->expressionManager
->createRule();
$rule4
->addCondition('rules_data_comparison', ContextConfig::create()
->map('data', 'node.title.value')
->setValue('operation', 'contains')
->setValue('value', 'Trigger Action Rule 4'));
$message4 = 'RULES message 4. Action to remove Unpublish-on date and unpublish the node immediately.';
$rule4
->addAction('scheduler_remove_unpublishing_date_action', ContextConfig::create()
->map('node', 'node'))
->addAction('scheduler_unpublish_now_action', ContextConfig::create()
->map('node', 'node'))
->addAction('rules_system_message', ContextConfig::create()
->setValue('message', $message4)
->setValue('type', 'status'));
$config_entity = $this->rulesStorage
->create([
'id' => 'rule4',
'events' => [
[
'event_name' => 'rules_entity_presave:node',
],
],
'expression' => $rule4
->getConfiguration(),
]);
$config_entity
->save();
$assert = $this
->assertSession();
$edit = [
'title[0][value]' => 'New node - Trigger Action Rule 3',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/add/' . $this->type, $edit, 'Save');
$node = $this
->drupalGetNodeByTitle('New node - Trigger Action Rule 3');
$this
->assertSession()
->pageTextContains(sprintf('%s is scheduled to be unpublished %s', 'New node - Trigger Action Rule 3', $unpublish_on_formatted));
$assert
->pageTextContains($message3);
$assert
->pageTextNotContains($message4);
$this
->assertEquals($node->unpublish_on->value, $unpublish_on, 'Node is scheduled for unpublishing at the correct time.');
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$this
->assertTrue($node
->isPublished(), 'Node is published for title: "' . $node->title->value . '".');
$node = $this->node_a;
$edit = [
'title[0][value]' => 'Edit node - but no rules will be triggered',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$this->nodeStorage
->resetCache([
$node
->id(),
]);
$node = $this->nodeStorage
->load($node
->id());
$assert
->pageTextNotContains($message3);
$assert
->pageTextNotContains($message4);
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$this
->assertTrue($node
->isPublished(), 'Node remains published for title: "' . $node->title->value . '".');
$edit = [
'title[0][value]' => 'Edit node - Trigger Action Rule 3',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$this->nodeStorage
->resetCache([
$node
->id(),
]);
$node = $this->nodeStorage
->load($node
->id());
$assert
->pageTextContains($message3);
$assert
->pageTextNotContains($message4);
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$this
->assertNotEmpty($node->unpublish_on->value, 'Node is scheduled for unpublishing.');
$this
->assertTrue($node
->isPublished(), 'Node is still published for title: "' . $node->title->value . '".');
$edit = [
'title[0][value]' => 'Edit node - Trigger Action Rule 4',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$this->nodeStorage
->resetCache([
$node
->id(),
]);
$node = $this->nodeStorage
->load($node
->id());
$assert
->pageTextNotContains($message3);
$assert
->pageTextContains($message4);
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$this
->assertFalse($node
->isPublished(), 'Node is now unpublished for title: "' . $node->title->value . '".');
$edit = [
'title[0][value]' => 'New non-enabled node - Trigger Action Rule 3',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/add/' . $this->nonSchedulerNodeType
->id(), $edit, 'Save');
$node = $this
->drupalGetNodeByTitle('New non-enabled node - Trigger Action Rule 3');
$assert
->pageTextContains('warning message');
$assert
->elementExists('xpath', '//div[@aria-label="Warning message" and contains(string(), "Action")]');
$this
->assertEmpty($node->publish_on->value, 'Node is not scheduled for publishing.');
$log = \Drupal::database()
->select('watchdog', 'w')
->condition('type', 'scheduler')
->condition('severity', RfcLogLevel::WARNING)
->countQuery()
->execute()
->fetchColumn();
$this
->assertEquals(1, $log, 'There is 1 watchdog warning message from Scheduler');
$node = $this->node_b;
$edit = [
'title[0][value]' => 'Edit non-enabled node - Trigger Action Rule 3',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$assert
->pageTextContains('warning message');
$assert
->elementExists('xpath', '//div[@aria-label="Warning message" and contains(string(), "Action")]');
$this
->assertEmpty($node->unpublish_on->value, 'Node is not scheduled for unpublishing.');
$log = \Drupal::database()
->select('watchdog', 'w')
->condition('type', 'scheduler')
->condition('severity', RfcLogLevel::WARNING)
->countQuery()
->execute()
->fetchColumn();
$this
->assertEquals(2, $log, 'There are now 2 watchdog warning messages from Scheduler');
$edit = [
'title[0][value]' => 'Edit non-enabled node - Trigger Action Rule 4',
'body[0][value]' => $this
->randomString(30),
];
$this
->drupalPostForm('node/' . $node
->id() . '/edit', $edit, 'Save');
$assert
->pageTextContains('warning message');
$assert
->elementExists('xpath', '//div[@aria-label="Warning message" and contains(string(), "Action")]');
$log = \Drupal::database()
->select('watchdog', 'w')
->condition('type', 'scheduler')
->condition('severity', RfcLogLevel::WARNING)
->countQuery()
->execute()
->fetchColumn();
$this
->assertEquals(3, $log, 'There are now 3 watchdog warning messages from Scheduler');
}
}