function Messaging_API_Tests::testMessagingBasicAPI in Messaging 6.4
Same name and namespace in other branches
- 5 tests/messaging_api.test \Messaging_API_Tests::testMessagingBasicAPI()
- 6 tests/messaging_api.test \Messaging_API_Tests::testMessagingBasicAPI()
- 6.2 tests/messaging_api.test \Messaging_API_Tests::testMessagingBasicAPI()
- 6.3 tests/messaging_api.test \Messaging_API_Tests::testMessagingBasicAPI()
- 7 tests/messaging_api.test \Messaging_API_Tests::testMessagingBasicAPI()
Exercise basic API functions
File
- tests/
messaging_api.test, line 29
Class
Code
function testMessagingBasicAPI() {
// Try messaging store functions, build foo method info for rendering
$message = $this
->randomMessage();
$send_method = messaging_send_method('simple');
$message->uid = $message->sender = 0;
$message->method = 'mail';
$message->queue = 1;
$send_method
->message_prepare($message);
$send_method
->message_render($message);
$result = messaging_store()
->message_save($message);
$this
->assertTrue($result && $message->mqid, 'The message has been stored successfully');
$load = messaging_message_load($message->mqid);
$this
->assertTrue($message->mqid == $load->mqid && $message->subject == $load->subject, 'The message has been retrieved successfully');
// Try destination API
$user = $this
->drupalCreateUser();
$this
->assertTrue(Messaging_Destination::validate_method('mail', $user->mail, $user->uid), 'Mail destination for user is OK.');
$this
->assertFalse(Messaging_Destination::validate_method('mail', $user->mail, 0), 'Mail destination is not valid for anonymous user.');
$destination = Messaging_Destination::create_method('mail', $user->mail, $user->uid);
$this
->assertTrue($destination->mdid, 'A mail destination can be created for user.');
$destination = Messaging_Destination::get_by_address('mail', $user->mail);
$this
->assertTrue($destination, 'The destination for user can be retrieved.');
$destination
->delete();
$saved = Messaging_Destination::get_by_address('mail', $user->mail);
$this
->assertFalse($saved, 'The mail destination has been deleted.');
/**
* Play with creating, retrieving, deleting a pair messages
*/
// Clean up the store
messaging_store()
->delete_multiple(array(
'uid' => 0,
));
// Create fake method for testing
$test_method = 'test';
$test_info = array(
'glue' => '+',
'subject_glue' => '-',
'footer' => '--',
'filter' => 0,
'address_type' => 'user',
'log' => 1,
'enabled' => TRUE,
);
$send_method = messaging_send_method($test_method, $test_info);
$user = $this
->drupalCreateUser();
$user->messaging_default = $test_method;
// Check messaging settings API
$info = messaging_send_method($test_method)
->get_info();
$this
->assertEqual(!empty($info), TRUE, 'Messaging method info retrieves information about methods');
$this
->assertEqual($info['filter'] === 0, TRUE, 'Messaging method info retrieves filter information');
$this
->assertEqual(messaging_method_default($user) === $test_method, TRUE, 'Messaging method default is working for test user');
// Try message composition, a pair simple cases, no filter
$message = $this
->randomMessage($test_method);
// Calculate the rendered body
$body = implode($info['glue'], array(
$message->body['header'],
$message->body['main'],
$info['footer'],
$message->body['footer'],
));
// The render function now returns a message object
$render = clone $message;
$render
->render();
$this
->assertEqual($render->subject == $message->subject && $render->body == $body, TRUE, 'Message successfully rendered, first try');
// Now give it a twist, make subject an array, body a plain text
$message->subject = array(
$message->subject,
$message->subject,
);
$message->body = $body;
$render = clone $message;
$render
->render();
$this
->assertEqual($render->subject == implode($info['subject_glue'], $message->subject) && $render->body == $body, TRUE, 'Message successfully rendered, second try');
// Create fake messages and try sending, they'll end up in messaging queue
$message1 = $this
->randomMessage($test_method);
$message1->queue = 1;
$message1->log = 1;
$message2 = $this
->randomMessage($test_method);
$message2->queue = 1;
$message2->log = 1;
$this
->assertTrue(messaging_user_destination($user, $test_method), 'Destination can be found for user');
$this
->assertTrue(messaging_message_send_user($user, $message1, NULL, 1), 'Message successfully sent for user');
$message2->account = $user;
$this
->assertTrue(messaging_message_send(array(
$user->uid,
$user->uid,
), $message2, $test_method, 1), 'Bulk message successfully sent');
// Now there should be two messages in queue for this user retrieve using two different methods
$queued = messaging_store()
->get_messages(array(
'uid' => $user->uid,
));
$this
->assertEqual(count($queued), 2, 'We have the right number of messages in queue: ' . count($queued));
// Make messages into logs and then delete
messaging_store()
->message_sent(array_keys($queued), TRUE);
$logged = messaging_store()
->get_messages(array(
'uid' => $user->uid,
'queue' => 0,
'log' => 1,
));
$this
->assertEqual(count($logged), 2, 'We have the right number of messages as logs');
// Try deleting function with many parameters, more than needed actually
messaging_store()
->delete_multiple(array(
'uid' => $user->uid,
'mqid' => array_keys($queued),
));
$this
->assertEqual(count(messaging_store()
->get_messages(array(
'uid' => $user->uid,
))), 0, 'The logs have been successfully deleted');
// Now try queueing for later sending, we need a push method for that
$test_method = 'mail';
$user = $this
->drupalCreateUser();
$user->messaging_default = $test_method;
$message1 = $this
->randomMessage($test_method);
$message2 = $this
->randomMessage($test_method);
$this
->assertTrue(messaging_message_send_user($user, $message1, NULL, 1), 'Message successfully queued for user');
$this
->assertTrue(messaging_message_send(array(
$user->mail,
$user->mail,
), $message2, $test_method, 1), 'Bulk message successfully queued for multiple destinations.');
$queued = messaging_store()
->get_messages(array(
'method' => $test_method,
'cron' => 1,
'queue' => 1,
));
$this
->assertEqual(count($queued), 2, 'We have the right number of messages in queue: ' . count($queued));
// Process queue and check again
$results = messaging_store()
->queue_process();
$this
->assertEqual(count($results), 2, 'Two rows have been processed.');
$this
->assertEqual(count(array_filter($results)), 2, 'Both rows have been processed successfully.');
$queued = messaging_store()
->get_messages(array(
'method' => $test_method,
));
$this
->assertEqual(count($queued), 0, 'We have sent the messages in queue: ' . count($queued));
}