diff --git a/README.txt b/README.txt index 75ba2ff..3d97695 100644 --- a/README.txt +++ b/README.txt @@ -22,13 +22,15 @@ INSTALLATION 1. Extract the notify module directory, including all its subdirectories, into your sites/all/modules directory. -2. Enable the notify module on the Administer >> Site building >> Modules page. +2. Enable the notify module on the Modules list page. The database tables will be created automagically for you at this point. -3. Modify permissions on the Administer >> Users >> Permissions page. +3. Modify permissions on the People >> Permissions page. + +4. Find the module in the Modules list page and click the Configuration link + to edit the settings to your liking. You can also navigate directly to + admin/config/notify. -4. Go to Administer >> Content >> Notification settings and modify the settings - to your liking. Note: e-mail updates can only happen as frequently as the cron is setup to. Check your cron settings. @@ -49,6 +51,9 @@ Rob Barreca was a previous maintainer. Matt Chapman is the current maintainer. +Ishmael Sanchez (http://ishmaelsanchez.com) and +John Oltman co-developed the Drupal 7 port. + ------------------------ RELATED PROJECTS & ALTERNATIVES ------------------------ diff --git a/notify.info b/notify.info index fb66523..58b049e 100644 --- a/notify.info +++ b/notify.info @@ -2,3 +2,6 @@ name = Notify description = "Enables notifications of new content and comments by e-mail." package = Mail core = 7.x +files[] = notify.install +files[] = notify.module +configure = admin/config/notify diff --git a/notify.module b/notify.module index d40a086..3339017 100644 --- a/notify.module +++ b/notify.module @@ -32,6 +32,11 @@ function notify_help($section) { */ function notify_admin_settings($form, &$form_state) { $period = array( + 60 => format_interval(60), + 120 => format_interval(120), + 180 => format_interval(180), + 300 => format_interval(300), + 600 => format_interval(600), 900 => format_interval(900), 1800 => format_interval(1800), 3600 => format_interval(3600), @@ -304,8 +309,9 @@ function notify_user_settings_form($form, &$form_state, $arg) { return; } - $result = db_query('SELECT u.uid, u.name, u.mail, n.status, n.node, n.teasers, n.comment FROM {users} u LEFT JOIN {notify} n ON u.uid = n.uid WHERE u.uid = :u.uid AND u.status = :u.status', array(':u.uid' => $account->uid, ':u.status' => 1)); - $notify = db_fetch_object($result); + $result = db_query('SELECT u.uid, u.name, u.mail, n.status, n.node, n.teasers, n.comment FROM {users} u LEFT JOIN {notify} n ON u.uid = n.uid WHERE u.uid = :uid AND u.status = :status', array(':uid' => $account->uid, ':status' => 1)); + foreach ($result as $notify) { + } $form = array(); if (!$notify->mail) { drupal_set_message(t('Your e-mail address must be specified on your my account page.', array('@url' => url('user/' . $account->uid . '/edit'))), 'error'); @@ -517,15 +523,22 @@ function theme_notify_admin_users($variables) { */ function _notify_content($node, $notify) { static $i = 0; + $txt = ''; switch ($notify->teasers) { case 0: - return; + return $txt; case 1: - $txt = check_markup($node->teaser, $node->format, $langcode = '' /* TODO Set this variable. */, FALSE); + $content = node_view($node,'teaser'); + if (isset($content['body'][0]['#markup'])) { + $txt = $content['body'][0]['#markup']; + } break; case 2: - $txt = check_markup($node->body, $node->format, $langcode = '' /* TODO Set this variable. */, FALSE); + $content = node_view($node,'full'); + if (isset($content['body'][0]['#markup'])) { + $txt = $content['body'][0]['#markup']; + } } return drupal_html_to_text($txt); @@ -548,41 +561,58 @@ function _notify_send($send_start = NULL) { _notify_switch_user(); // Store current user // Fetch all node type authorized by notify settings - //Note that queries use 'nn' alias to avoid conflicts when query is rewritten by access control modules $ntype = array(); foreach (node_type_get_types() as $type => $name) { if (variable_get(NOTIFY_NODE_TYPE . $type, 0)) { $ntype[] = $type; } - if (count($ntype) >= 1) { - $nodetypes_query = "AND (nn.type = '" . implode("' OR nn.type = '", $ntype) . "') "; - } - else { - $nodetypes_query = ''; - } } // build query to fetch desired nodes. - $q = 'SELECT nn.nid FROM {node} nn WHERE (nn.status = 1 OR nn.moderate = 1) ' . $nodetypes_query . ' AND ((nn.created > %d AND nn.created <= %d)'; - //include updated nodes? - $q .= variable_get('notify_include_updates', 1) ? ' OR (nn.changed > %d AND nn.changed <= %d))' : ')'; - $q .= ' ORDER BY nn.created ASC'; + $q = db_select('node', 'n'); + $q->fields('n', array('nid')); + $q->condition('status', 1); + if (count($ntype) >= 1) { + $q->condition('n.type', $ntype, 'IN'); + } + if (variable_get('notify_include_updates', 1)) { + $q->condition(db_or()->condition(db_and()->condition('n.created', $period, '>')->condition('n.created', $send_start, '<=')) + ->condition(db_and()->condition('n.changed', $period, '>')->condition('n.changed', $send_start, '<='))); + } else { + $q->condition('n.created', $period, '>'); + $q->condition('n.created', $send_start, '<='); + } + $q->orderBy('n.created', 'asc'); + $result = $q->execute(); //Run the query, and load the nodes _notify_switch_user(1); //Query as if user 1, we check for individual user access later. - // TODO Please convert this statement to the D7 database API syntax. - $nresult = db_query(db_rewrite_sql($q, 'nn'), $period, $send_start, $period, $send_start); $nodes = array(); - while ($node = db_fetch_object($nresult)) { + foreach ($result as $node) { $nodes[$node->nid] = node_load($node->nid); } // Fetch new comments. $comments = array(); if (module_exists('comment')) { - // TODO Please convert this statement to the D7 database API syntax. - $cresult = db_query(db_rewrite_sql('SELECT c.nid, c.cid, c.subject, c.name, c.status FROM {comments} c INNER JOIN {node} nn ON c.nid = nn.nid WHERE c.timestamp > %d AND c.timestamp <= %d ' . $nodetypes_query . ' ORDER BY c.nid, c.timestamp', 'c'), $period, $send_start); - while ($comment = db_fetch_object($cresult)) { + $q = db_select('comment', 'c'); + $q->join('node', 'n', 'c.nid = n.nid'); + $q->fields('c'); + if (count($ntype) >= 1) { + $q->condition('n.type', $ntype, 'IN'); + } + if (variable_get('notify_include_updates', 1)) { + $q->condition(db_or()->condition(db_and()->condition('c.created', $period, '>')->condition('c.created', $send_start, '<=')) + ->condition(db_and()->condition('c.changed', $period, '>')->condition('c.changed', $send_start, '<='))); + } else { + $q->condition('c.created', $period, '>'); + $q->condition('c.created', $send_start, '<='); + } + $q->orderBy('c.nid', 'asc'); + $q->orderBy('c.changed', 'asc'); + $cresult = $q->execute(); + + foreach ($cresult as $comment) { $comments[$comment->nid][] = $comment; } } @@ -590,9 +620,19 @@ function _notify_send($send_start = NULL) { if (count($nodes) || count($comments)) { // Fetch users with notify enabled - $uresult = db_query('SELECT u.uid, u.name, u.mail, u.language, n.status, n.node, n.teasers, n.comment FROM {notify} n INNER JOIN {users} u ON n.uid = u.uid WHERE n.status = :n.status AND u.status = :u.status AND n.attempts <= :n.attempts', array(':n.status' => 1, ':u.status' => 1, ':n.attempts' => variable_get('notify_attempts', 5))); + $q = db_select('notify', 'n'); + $q->join('users', 'u', 'n.uid = u.uid'); + $q->fields('u', array('uid', 'name', 'mail', 'language')); + $q->fields('n', array('status', 'node', 'teasers', 'comment')); + $q->condition('n.status', 1); + $q->condition('u.status', 1); + $q->condition('n.attempts', variable_get('notify_attempts', 5), '<='); + if (count($ntype) >= 1) { + $q->condition('n.type', $ntype, 'IN'); + } + $uresult = $q->execute(); - while ($user = db_fetch_object($uresult)) { + foreach ($uresult as $user) { // Switch current user to this account to use node_access functions, etc. _notify_switch_user($user->uid); @@ -611,10 +651,7 @@ function _notify_send($send_start = NULL) { } // @TODO: Add functionality to hook into moderation modules? - if ($node->moderate == 1) { - $status = t('Queued'); - } - elseif ($node->status == 1) { + if ($node->status == 1) { $status = t('Published'); } elseif ($node->status == 0) { @@ -640,6 +677,7 @@ function _notify_send($send_start = NULL) { // Write new comments to e-mail if user has permissions and there are // comments to be sent. + if ($user->comment && user_access('access comments') && count($comments)) { $total_comment_count = 0; foreach ($comments as $nid => $comment) { @@ -668,13 +706,17 @@ function _notify_send($send_start = NULL) { $status = $c->status == COMMENT_PUBLISHED ? t('Published') : t('Unpublished'); $status = " [$status]"; } - $comment_body .= ' ' . ++$comment_count . '.' . t('!status !title by !author', - array( - '!status' => $status, - '!title' => $c->subject, - '!author' => ($c->name ? $c->name : variable_get('anonymous', 'Anonymous')), + $comment_body .= ' ' . ++$comment_count . '.' . t('!status !title by !author', array( + '!status' => $status, '!title' => $c->subject, '!author' => ($c->name ? $c->name : variable_get('anonymous', 'Anonymous')), )) . "\n" . ' ' . url('node/' . $nid, array('fragment' => 'comment-' . $c->cid, 'absolute' => TRUE)) . "\n\n"; + + /* @TODO - some people may not want comment body in the email, so make it an option instead of always included */ + $comment_loaded = comment_load($c->cid); + if (isset($comment_loaded->comment_body[$comment_loaded->language][0]['value'])) { + $format = $comment_loaded->comment_body[$comment_loaded->language][0]['format']; + $comment_body .= drupal_html_to_text(check_markup($comment_loaded->comment_body[$comment_loaded->language][0]['value'], $format, $comment_loaded->language, FALSE)) . "\n\n" ; + } $total_comment_count++; } } @@ -695,14 +737,10 @@ function _notify_send($send_start = NULL) { $headers = array(); //'From' => "$from_name <$from>"); if (!drupal_mail('notify', 'send', $user->mail, user_preferred_language($user), array('content' => $body))) { $num_failed++; - // TODO Please review the conversion of this statement to the D7 database API syntax. - /* db_query('UPDATE {notify} SET attempts = attempts + 1 WHERE uid = %d', $user->uid) */ db_update('notify') - ->fields(array( - 'attempts' => attempts + 1, - )) - ->condition('uid', $user->uid) - ->execute(); + ->expression('attempts', 'attempts + 1') + ->condition('uid', $user->uid) + ->execute(); watchdog('notify', 'User %name (%mail) could not be notified. Mail error.', array('%name' => $user->name, '%mail' => $user->mail), WATCHDOG_ERROR); } else { @@ -718,18 +756,20 @@ function _notify_send($send_start = NULL) { } /** - * @todo Please document this function. - * @see http://drupal.org/node/1354 + * Implementation of hook_mail(). */ function notify_mail($key, &$message, $params) { global $user; + $message['headers']['MIME-Version'] = '1.0'; + $message['headers']['Content-Type'] = 'text/plain'; + $message['subject'] = t('!sitename new content notification for !username', array('!username' => $user->name, '!sitename' => variable_get('site_name', 'Drupal'))); - $message['body'] = t('Greetings !user,', array('!user' => $user->name)) . "\n\n"; - $message['body'] .= $params['content']; - $message['body'] .= "\n-- \n"; - $message['body'] .= t('This is an automatic e-mail from !sitename.', array('!sitename' => variable_get('site_name', 'Drupal'))) . "\n"; - $message['body'] .= t('To stop receiving these e-mails, change your notification preferences at !notify-url', array('!notify-url' => url("user/$user->uid/notify", array('absolute' => TRUE)))) . "\n"; + $message['body'][] = t('Greetings !user,', array('!user' => $user->name)) . "\n\n"; + $message['body'][] = $params['content']; + $message['body'][] = "\n-- \n"; + $message['body'][] = t('This is an automatic e-mail from !sitename.', array('!sitename' => variable_get('site_name', 'Drupal'))) . "\n"; + $message['body'][] = t('To stop receiving these e-mails, change your notification preferences at !notify-url', array('!notify-url' => url("user/$user->uid/notify", array('absolute' => TRUE)))) . "\n"; } /** @@ -751,14 +791,14 @@ function _notify_switch_user($uid = NULL) { // Should a user visit cron.php, or should this module be invoked via poormanscron and _notify_send() does not complete, // the visitor will end up logged in as the "switched to user" for subsequent requests unless we disable saving the session // until we are sure we're the invoking user again. - session_save_session(FALSE); + drupal_save_session(FALSE); $user = user_load($uid); } // Retrieve the initial user, can be called multiple times. elseif (count($orig_user)) { $user = array_shift($orig_user); array_unshift($orig_user, $user); - session_save_session(TRUE); + drupal_save_session(TRUE); } // Store the initial user. else {