function privatemsg_limits_privatemsg_message_validate in Privatemsg 6.2

Same name and namespace in other branches

1. 7.2 privatemsg_limits/privatemsg_limits.module \privatemsg_limits_privatemsg_message_validate()
2. 7 privatemsg_limits/privatemsg_limits.module \privatemsg_limits_privatemsg_message_validate()

Implements hook_privatemsg_message_validate().

File

privatemsg_limits/privatemsg_limits.module, line 38

Privatemsg Quota module

Code

function privatemsg_limits_privatemsg_message_validate($message, $form = FALSE) {
  $errors = array();
  if (variable_get('privatemsg_limits_recipients_enabled', FALSE)) {
    $amount = _privatemsg_limits_get_amount('recipients_amount', $message['author']);
    if (!isset($message['thread_id']) && $amount > 0 && count($message['recipients']) > $amount) {
      $errors[] = t("You are not allowed to send a message to more than @number recipients.", array(
        '@number' => $amount,
      ));
    }
  }

  // Only check sending limit if enabled and if this is either not a reply or
  // messages should be checked and not threads. When the limit object are
  // threads, users can send an unlimited amount of replies.
  if (variable_get('privatemsg_limits_send_enabled', FALSE) && (empty($message['thread_id']) || variable_get('privatemsg_limits_send_object', 'message') == 'message')) {
    $amount = _privatemsg_limits_get_amount('send_amount', $message['author']);
    $used = _privatemsg_limits_get_sent($message['author'], variable_get('privatemsg_limits_send_timeframe', 3600));
    if ($amount > 0 && $used >= $amount) {
      $wait_time = _privatemsg_limits_get_oldest($message['author'], variable_get('privatemsg_limits_send_timeframe', 3600));
      $period = format_interval(variable_get('privatemsg_limits_send_timeframe', 3600));
      if (variable_get('privatemsg_limits_receive_object', 'message') == 'message') {
        $errors[] = t("Your message was not sent because you have exceeded your sending limit. You are allowed to send %limit messages every @period. You can send your next message in in @wait_time.", array(
          '@wait_time' => $wait_time,
          '%limit' => $amount,
          '@period' => $period,
        ));
      }
      else {
        $errors[] = t("Your message was not sent because you have exceeded your sending limit. You are allowed to start %limit conversations every @period. You can start your next conversation in in @wait_time.", array(
          '@wait_time' => $wait_time,
          '%limit' => $amount,
          '@period' => $period,
        ));
      }
    }
  }
  if (variable_get('privatemsg_limits_receive_enabled', FALSE) && (empty($message['thread_id']) || variable_get('privatemsg_limits_receive_object', 'message') == 'message')) {
    $amount = _privatemsg_limits_get_amount('receive_amount', $message['author']);
    $used = _privatemsg_limits_get_received($message['author']);
    $type = array(
      'message' => t('messages'),
      'thread' => t('conversations'),
    );
    if ($amount > 0 && $used >= $amount) {
      if (variable_get('privatemsg_limits_receive_object', 'message') == 'message') {
        $errors[] = t("Your message mailbox is currently full. You are allowed a maximum of %limit messages in your mailbox at one time. You won't be able to send or receive new messages until you delete some existing ones.", array(
          '%limit' => $amount,
        ));
      }
      else {
        $errors[] = t("Your message mailbox is currently full. You are allowed a maximum of %limit conversations in your mailbox at one time. You won't be able to start or receive new conversations until you delete some existing ones.", array(
          '%limit' => $amount,
        ));
      }
    }
  }

  // Blocks message sending if over number of messages per-thread.
  if (isset($message['thread_id']) && variable_get('privatemsg_limits_messages_per_thread', 0) > 0) {

    // If we're not blocking the message.
    if (variable_get('privatemsg_limits_messages_per_thread_action', 'create-new') == 'block-message') {
      $query = "SELECT COUNT(*) FROM {pm_index} WHERE thread_id = %d AND recipient = %d AND type IN ('hidden', 'user')";
      $result = db_result(db_query($query, $message['thread_id'], $message['author']->uid));
      if ($result >= variable_get('privatemsg_limits_messages_per_thread', 0)) {

        // If the number of messages per-thread has been exceeded, block message
        // from being sent.
        $errors[] = t("This message cannot be sent because the thread already contains %limit messages (the maximum number of messages permitted per thread). To send this message, please create a new message thread.", array(
          '%limit' => variable_get('privatemsg_limits_messages_per_thread', 0),
        ));
      }
    }
  }
  if (!empty($errors)) {
    if ($form) {
      foreach ($errors as $error) {
        form_set_error('recipient', $error);
      }
    }
    else {
      return array(
        'error' => $errors,
      );
    }
  }
}