function Messaging_API_Tests::testMessagingSendingAPI in Messaging 6.3

Same name and namespace in other branches

1. 6 tests/messaging_api.test \Messaging_API_Tests::testMessagingSendingAPI()
2. 6.2 tests/messaging_api.test \Messaging_API_Tests::testMessagingSendingAPI()

Play with creating, retrieving, deleting a pair messages

File

tests/messaging_api.test, line 70

Class

Messaging_API_Tests

Code

function testMessagingSendingAPI() {
  $this
    ->messagingStartTest();
  $test_method = 'simple';
  $info = array(
    'glue' => '+',
    'subject_glue' => '-',
    'footer' => '--',
    'filter' => FALSE,
  );
  $send_method = new Messaging_Send_Method($info, $test_method);
  $user = $this
    ->drupalCreateUser();
  $user->messaging_default = $test_method;

  // Check messaging settings API
  $method_info = messaging_method_info(NULL, NULL, NULL, TRUE);
  $this
    ->assertEqual(!empty($method_info[$test_method]), TRUE, 'Messaging method info retrieves information about methods');
  $this
    ->assertEqual(messaging_method_info($test_method, '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();
  $message->method = $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;
  $send_method
    ->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,
  );
  $render = clone $message;
  $send_method
    ->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();
  $message2 = $this
    ->randomMessage();
  $this
    ->assertTrue(messaging_message_send_user($user, $message1, NULL, 1), 'Message successfully sent for user');

  // Send second message to this user and one more
  $user2 = $this
    ->drupalCreateUser();
  $user2->messaging_default = $test_method;
  $this
    ->assertTrue(messaging_message_send(array(
    $user->uid,
    $user2->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', array(
    'uid' => $user->uid,
  ));
  $this
    ->assertEqual(count($queued), 2, 'We have the right number of messages in queue: ' . count($queued));
  $pending = messaging_pull_pending($test_method, array(
    $user->uid,
  ), 0, FALSE);
  $this
    ->assertEqual(count($pending), 2, 'We can pull the right number of messages from queue: ' . count($pending));

  // Make messages into logs and then delete
  messaging_store('sent', array_keys($queued), TRUE);
  $logged = messaging_store('get', 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('del', array(
    'uid' => $user->uid,
    'mqid' => array_keys($queued),
  ));
  $this
    ->assertEqual(count(messaging_store('get', array(
    'uid' => $user->uid,
  ))), 0, 'The logs have been successfully deleted');

  // Now try queueing for later sending, we need a push method for that
  $user = $this
    ->drupalCreateUser();
  $user->messaging_default = $test_method;
  $message1 = $this
    ->randomMessage();
  $message2 = $this
    ->randomMessage();
  $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', 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
  messaging_store('queue_process', 10);
  $queued = messaging_store('get', array(
    'method' => $test_method,
  ));
  $this
    ->assertEqual(count($queued), 0, 'We have sent the messages in queue: ' . count($queued));

  // Check the messages have been sent
  $sent = messaging_simple_get_messages($user->uid, 0);
  $this
    ->assertEqual(count($sent), 2, 'Two messages have been sent.');

  // Final clean up of messages in store
  $this
    ->messagingCleanUp();
}