modules/interact/interact.module

<?php

// $Id: interact.module 415 2008-05-03 01:35:51Z prarie $

define('INTERACT_NOTIFY_NO_EMAIL', 1);
define('INTERACT_NOTIFY_IMMEDIATE', 2);
define('INTERACT_NOTIFY_DIGEST_DAILY', 3);
define('INTERACT_NOTIFY_DIGEST_WEEKLY', 4);

define('INTERACT_EMAIL_NOTIFY_SUBJECT', "[@site_name] Actions taken");
define('INTERACT_EMAIL_NOTIFY_BODY', "There @were_#_actions_taken on\n@site_name:\n\n@actions_text\nAbove activity and more:\n@all_activity_url\n\nThis is the latest activity from all site activity you have requested\nnotification. You can change your preferences for receiving email\nor your notifications by clicking the links below.\n\nNotifications:\n@notify_url\n\nEmail:\n@user_prefs_url\n\nThis message sent automatically by @site_url. Please inform us if you feel you should not have received this email.\n");

define('INTERACT_THICKBOX_QUERY', 'height=300&width=450&modal=true');

/**
 * Implementation of menu hook.
 *
 * @param bool $may_cache
 * @return array
 */
function interact_menu($may_cache) {
  $items = array();
  if ($may_cache) {
    $items[] = array(
      'path' => 'admin/settings/interact',
      'title' => t('Interaction centre'),
      'description' => t('Configure user interaction options.'),
      'access' => user_access('administer interaction centre'),
      'callback' => 'drupal_get_form',
      'callback arguments' => array('interact_settings'),
    );
    $items[] = array(
      'path' => 'my-interests',
      'title' => t('My interests and notifications'),
      'description' => t('All activity you requested to be notified about or relating to content you posted.'),
      'access' => user_access('view user actions'),
      'callback' => 'interact_my_interests',
      'type' => MENU_SUGGESTED_ITEM,
    );
    $items[] = array(
      'path' => 'my-interests/notify',
      'title' => t('My notification requests'),
      'description' => t('Items you have requested to be notified about.'),
      'access' => user_access('view user actions'),
      'callback' => 'interact_notification_requests',
      'type' => MENU_SUGGESTED_ITEM,
    );
    $items[] = array(
      'path' => 'public-messages',
      'title' => t('Message centre'),
      'access' => user_access('view public messages'),
      'callback' => 'interact_view_public_messages',
      'type' => MENU_CALLBACK,
    );
    $items[] = array(
      'path' => 'user-actions',
      'title' => t('User actions'),
      'access' => user_access('view user actions'),
      'callback' => 'interact_view_actions',
      'type' => MENU_CALLBACK,
    );
    $items[] = array(
      'path' => 'interact-watch',
      'title' => t('Request notification'),
      'access' => user_access('view user actions'),
      'callback' => 'interact_watch',
      'type' => MENU_CALLBACK,
    );
  }
  return $items;
}

/**
 * Implementation of perm hook.
 *
 * @return array
 */
function interact_perm() {
  return array(
    'administer interaction centre',
    'view public messages',
    'post public messages',
    'view user actions',
    'add notification requests'
//    'create interaction groups',
//    'join interaction groups',
  );
}

/**
 * Implementation of nodeapi hook.
 *
 * @param object $node
 * @param string $op
 * @param mixed $a3
 * @param mixed $a4
 */
function interact_nodeapi(&$node, $op, $a3 = NULL, $a4 = NULL) {
  global $user;

  $action_type = NULL;
  switch ($op) {
    case 'insert' :
      if ($node->status) {
        $action_type = 'node-new';
      }
      break;
    case 'update' :
      if ($node->status) {
        $action_type = 'node-edit';
      }
      break;
    case 'delete' :
      interact_delete_actions('node', $node->nid);
      break;
  }
  if (isset($action_type)) {
    $type_name = node_get_types('name', $node);
    $message = '';
    $teaser = '';
    if ('node-new' == $action_type) {
      $message = t('!user posted a new %type !title', array('!user' => l($user->name, 'user/' . $user->uid), '%type' => $type_name, '!title' => l($node->title, 'node/' . $node->nid)));
      $teaser = interact_action_teaser($node->teaser);
    }
    else {
      $message = t('!user edited the %type !title', array('!user' => l($user->name, 'user/' . $user->uid), '%type' => $type_name, '!title' => l($node->title, 'node/' . $node->nid)));
    }
    if (drupal_strlen($teaser) > variable_get('interact_teaser_length', 100)) {
      $teaser = drupal_substr($teaser, 0, strrpos($teaser, ' '));
    }
    $aid = interact_save_user_action($user->uid, $action_type, $node->nid, $message, $teaser);
    $notify_types = array();
    $uid_array = array();
    if ('node-edit' == $action_type) {
      $result = db_query('SELECT edit_own_items FROM {interact_preference} WHERE uid = %d', $node->uid);
      if (0 == db_num_rows($result) || db_result($result)) {
        // default is to notify of node edits to the user that owns the node
        $uid_array[$node->uid] = 0;
      }
      interact_queue_notification($aid, 'user', 'edit', $user->uid);
      interact_get_preference_users('edit_nodes', $uid_array);
    }
    else {
      interact_queue_notification($aid, 'user', 'new', $user->uid);
      interact_get_preference_users('new_nodes', $uid_array);
    }
    $result = db_query('SELECT tid FROM {term_node} WHERE nid = %d', $node->nid);
    while ($row = db_fetch_object($result)) {
      interact_queue_notification($aid, 'term', 'node-edit' == $action_type ? 'edit' : 'new', $row->tid);
    }
    interact_queue_users($uid_array, $aid);
    interact_immediate_notification();
  }
}

/**
 * Implementation of comment hook.
 *
 * @param mixed $a1
 * @param string $op
 */
function interact_comment($a1, $op) {
  global $user;

  $action_type = NULL;
  switch ($op) {
    case 'insert' :
      $action_type = 'comment-new';
      break;
    case 'update' :
      $action_type = 'comment-edit';
      break;
    case 'delete' :
      // remove any actions related to the node being deleted
      interact_delete_actions('comment', $a1->cid);
      break;
  }
  if (isset($action_type)) {
    $node = node_load($a1['nid']);
    $message = NULL;
    $uid_array = array();
    $teaser = '';
    if ('comment-new' == $action_type) {
      $message = t('!user posted a new !comment on !title', array('!user' => l($user->name, 'user/' . $user->uid), '!comment' => l(comment, 'node/' . $node->nid, array(), NULL, 'comment-' . $a1['cid']), '!title' => l($node->title, 'node/' . $node->nid)));
      $teaser = interact_action_teaser($a1['comment']);
    }
    else {
      $message = t('!user edited a !comment on !title', array('!user' => l($user->name, 'user/' . $user->uid), '!comment' => l(comment, 'node/' . $node->nid, array(), NULL, 'comment-' . $a1['cid']), '!title' => l($node->title, 'node/' . $node->nid)));
    }

    // save the user action
    $aid = interact_save_user_action($user->uid, $action_type, $a1['cid'], $message, $teaser);

    if ('comment-new' == $action_type) {
      // do the notification logic on the tree only when it's a new comment
      $uid_array = array();
      if (empty($a1['pid'])) {
        interact_queue_notification($aid, 'node', 'direct_comments', $a1['nid']);
      }
      else {
        interact_queue_notification($aid, 'node', 'all_comments', $a1['nid']);
        $pid = $a1['pid'];
        interact_queue_notification($aid, 'comment', 'direct', $pid);
        while (!empty($pid)) {
          interact_queue_notification($aid, 'comment', 'all', $pid);
          $row = db_fetch_object(db_query('SELECT pid, uid, cid FROM {comments} WHERE cid = %d', $pid));
          $pid = $row->pid;

          // inform the poster of the comment this is a reply to
          if ($a1['pid'] = $row->cid) {
            $result = db_query('SELECT new_posts_to_own FROM {interact_preference} WHERE uid = %d', $row->uid);
            if (0 == db_num_rows($result) || db_result($result)) {
              // default is to notify of node edits to the user that owns the node
              $uid_array[$row->uid] = 0;
            }
          }
        }
      }

      $result = db_query('SELECT new_posts_to_own FROM {interact_preference} WHERE uid = %d', $node->uid);
      if (0 == db_num_rows($result) || db_result($result)) {
        // default is to notify of node edits to the user that owns the node
        $uid_array[$node->uid] = 0;
      }
      interact_get_preference_users('new_comments', $uid_array);
      interact_queue_notification($aid, 'user', 'comment', $user->uid);
    }
    else {
      interact_get_preference_users('edit_comments', $uid_array);
    }
    $result = db_query('SELECT tid FROM {term_node} WHERE nid = %d', $node->nid);
    while ($row = db_fetch_object($result)) {
      interact_queue_notification($aid, 'term', 'node-edit' == $action_type ? 'edit' : 'new', $row->tid);
    }
    interact_queue_users($uid_array, $aid);
    interact_immediate_notification();
  }
}

function interact_delete_actions($type, $id) {
  $aids = array();
  $result = db_query('SELECT aid FROM {interact_action} WHERE type LIKE \'%s-%%\' AND id = %d', $type, $id);
  while ($row = db_fetch_object($result)) {
    $aids[$row->aid] = $row->aid;
  }
  $result = db_query('SELECT aid FROM {interact_notify} WHERE type = \'%s\' AND id = %d', $type, $id);
  while ($row = db_fetch_object($result)) {
    $aids[$row->aid] = $row->aid;
  }
  if (0 < count($aids)) {
    $aid_string = implode(',', $aids);
    db_query('DELETE FROM {interact_action} WHERE aid IN (%s)', $aid_string);
    db_query('DELETE FROM {interact_notify} WHERE aid IN (%s)', $aid_string);
    db_query('DELETE FROM {interact_notification} WHERE aid IN (%s)', $aid_string);
  }
}

function interact_action_teaser($text) {
  $teaser = strip_tags($text);
  $max_length = variable_get('interact_teaser_length', 150);
  if (drupal_strlen($teaser) > $max_length) {
    $teaser = drupal_substr($teaser, 0, $max_length);
    if (FALSE !== ($pos = strrpos($teaser, ' '))) {
      $teaser = drupal_substr($teaser, 0, $pos) . t('...');
    }
  }
  return $teaser;
}

/**
 * Implementation of user hook.
 *
 * @param string $op
 * @param array $edit form values entered
 * @param object $account user object that is applicable
 * @param string $category active category
 * @return mixed
 */
function interact_user($op, &$edit, &$account, $category = NULL) {
  switch ($op) {
    case 'view' :
      $user_actions = interact_view_actions($account->uid, NULL, FALSE);
      $user_messages = interact_view_public_messages($account->uid, NULL, FALSE);
      if (!empty($user_actions) || !empty($user_messages)) {
        drupal_add_css(_interact_get_path() . '/interact.css');
        return array(t('User interaction') => array('interact' => array(
          'title' => t('Actions and public messages'),
          'value' => theme('interact_user_view', $user_actions, $user_messages),
          'class' => 'interact',
        )));
      }
      break;
    case 'form' :
      if ('account' == $category) {
        $form['interact'] = array(
          '#type' => 'fieldset',
          '#title' => t('Interaction centre preferences'),
          '#weight' => 1,
          '#collapsible' => TRUE,
          '#description' => t('<a name="interact"></a>Settings for how you will be informed when items posted show in your !interaction-centre. All comments or edits to content you have !marked will show in your interaction centre and will be emailed to you.', array('!interaction-centre' => l(t('interaction centre'), 'interact'), '!marked' => l(t('marked'), 'interact/notify'))),
        );
        $form['interact_form_presented'] = array(
          '#type' => 'value',
          '#value' => TRUE,
        );
        $prefs = interact_get_user_prefs($account->uid);
        $form['interact']['interact_notification_email'] = array(
          '#type' => 'select',
          '#title' => 'Email notification',
          '#default_value' => $prefs['email_pref'],
          '#options' => array(
            INTERACT_NOTIFY_NO_EMAIL => t('No email'),
            INTERACT_NOTIFY_IMMEDIATE => t('Send email immediately'),
            INTERACT_NOTIFY_DIGEST_DAILY => t('Send at most one email per day'),
            INTERACT_NOTIFY_DIGEST_WEEKLY => t('Send at most one email per week'),
          ),
          '#description' => t('Email notifiction will apply for the global preferences below and the items that you have !marked.', array('!marked' => l(t('marked'), 'interact/marked')))
        );
        $default = 0;
        $default = 0;
        if ($prefs['new_nodes']) {
          $default = 1;
          if ($prefs['edit_nodes']) {
            $default = 3;
          }
        }
        elseif ($prefs['edit_nodes']) {
          $default = 2;
        }
        elseif ($prefs['edit_own_items']) {
          $default = 4;
        }
        $form['interact']['interact_notification_content'] = array(
          '#type' => 'select',
          '#title' => t('Global notification of content'),
          '#default_value' => $default,
          '#options' => array(
            t('No notification'),
            t('All new content'),
            t('All edits of content'),
            t('All new content and edits of content'),
            t('Only edits of content you posted'),
          ),
        );
        $default = 0;
        if ($prefs['new_comments']) {
          $default = 1;
          if ($prefs['edit_comments']) {
            $default = 3;
          }
        }
        elseif ($prefs['edit_comments']) {
          $default = 2;
        }
        elseif ($prefs['new_posts_to_own']) {
          $default = 4;
        }
        $form['interact']['interact_notification_comment'] = array(
          '#type' => 'select',
          '#title' => t('Global notification of comments'),
          '#default_value' => $default,
          '#options' => array(
            t('No notification'),
            t('All new comments'),
            t('All edits of comments'),
            t('All new comments and edits to comments'),
            t('Only comments on content you posted'),
          ),
        );
        return $form;
      }
      break;
    case 'update' :
      // only update values if the form was presented
      if (isset($edit['interact_form_presented']) && $edit['interact_form_presented']) {
        if (!empty($edit['interact_mini_pic'])) {
          file_delete($edit['interact_mini_pic']);
        }
        $edit['interact_mini_pic'] = NULL;
        $profile_picture = NULL;
        if (!empty($edit['picture'])) {
          $profile_picture = $edit['picture'];
        }
        elseif ($account->picture) {
          $profile_picture = $account->picture;
        }
        if (isset($profile_picture)) {
          $edit['interact_mini_pic'] = interact_mini_pic($profile_picture);
        }

        $insert_prefs = FALSE;
        $new_nodes = 0;
        $new_comments = 0;
        $edit_nodes = 0;
        $edit_comments = 0;
        $edit_own_items = 1;
        $new_posts_to_own = 1;

        db_query('DELETE FROM {interact_preference} WHERE uid = %d', $account->uid);
        watchdog('interact-preference', t('Deleted preference record for user %user (if any existed).', array('%user' => $account->uid)));
        if (isset($edit['interact_notification_email']) && INTERACT_NOTIFY_IMMEDIATE != $edit['interact_notification_email']) {
          $insert_prefs = TRUE;
        }
        if (4 != $edit['interact_notification_content']) {
          $insert_prefs = TRUE;
          $edit_own_items = 0;
          switch ($edit['interact_notification_content']) {
            case 1 :
              $new_nodes = 1;
              break;
            case 2 :
              $edit_nodes = 1;
              break;
            case 3 :
              $new_nodes = 1;
              $edit_nodes = 1;
              break;
          }
        }
        if (4 != $edit['interact_notification_comment']) {
          $insert_prefs = TRUE;
          $new_posts_to_own = 0;
          switch ($edit['interact_notification_comment']) {
            case 1 :
              $new_comments = 1;
              break;
            case 2 :
              $edit_comments = 1;
              break;
            case 3 :
              $new_comments = 1;
              $edit_comments = 1;
              break;
          }
        }
        if ($insert_prefs) {
          db_query('INSERT INTO {interact_preference} (uid, email_pref, new_nodes, new_comments, edit_nodes, edit_comments, edit_own_items, new_posts_to_own) VALUES (%d, %d, %d, %d, %d, %d, %d, %d)', $account->uid, $edit['interact_notification_email'], $new_nodes, $new_comments, $edit_nodes, $edit_comments, $edit_own_items, $edit_own_items, $new_posts_to_own);
          watchdog('interact-preference', t('Inserted new preference record for user %user', array('%user' => $account->uid)));
        }
        $edit['interact_notification_email'] = NULL;
        $edit['interact_notification_content'] = NULL;
        $edit['interact_notification_comment'] = NULL;
      }
      break;
  }
}

function interact_get_user_prefs($uid) {
  $interact_settings = db_fetch_array(db_query('SELECT * FROM {interact_preference} WHERE uid = %d', $uid));
  if (empty($interact_settings)) {
    $interact_settings = variable_get('interact_prefs_default', array('email_pref' => INTERACT_NOTIFY_IMMEDIATE, 'edit_own_items' => 1, 'new_posts_to_own' => 1));
  }
  return $interact_settings;
}

function interact_mini_pic($profile_picture) {
  $image = image_get_info($profile_picture);
  $mini_icon = NULL;
  if (FALSE !== $image) {
    $dirname = file_create_path() . '/interact/mini-pics';
    if (!is_dir($dirname)) {
      if (!is_file($dirname)) {
        if (!is_dir(dirname($dirname))) {
          if (!is_file(dirname($dirname))) {
            mkdir(dirname($dirname));
          }
          else {
            watchdog('interact', t('File %dir exists so directory cannot be created.', array('%dir' => $dirname)), WATCHDOG_ERROR);
          }
        }
        mkdir($dirname);
      }
      else {
        watchdog('interact', t('File %dir exists so directory cannot be created.', array('%dir' => $dirname)), WATCHDOG_ERROR);
      }
    }
    $filename = $dirname . '/' . basename($profile_picture);
    if (file_exists($filename)) {
      file_delete($filename);
    }
    $dims = explode('x', variable_get('interact_mini_pic_max_size', '50x100'));
    if ($image['width'] > $dims[0] || $image['height'] > $dims[1]) {
      image_scale($profile_picture, $filename, $dims[0], $dims[1]);
    } else {
      file_copy($profile_picture, $filename);
    }
    $mini_icon = $filename;
  }
  return $mini_icon;
}

function interact_form_alter($form_id, &$form) {
  switch ($form_id) {
    case 'user_admin_settings' :
      $form['#submit']['interact_save_default_profile_picture'] = array();
      break;
  }
}

function interact_save_default_profile_picture($form_id, $values) {
  $default_mini_pic = variable_get('interact_mini_pic_default', '');
  if (!empty($default_mini_pic)) {
    file_delete($default_mini_pic);
  }
  if (!empty($values['user_picture_default'])) {
    if ($default_mini_pic = interact_mini_pic($values['user_picture_default'])) {
      variable_set('interact_mini_pic_default', $default_mini_pic);
    }
  }
}

function interact_save_user_action($uid, $type, $id, $message, $teaser = '') {
  $aid = db_next_id('{interact_action}_aid');
  db_query('INSERT INTO {interact_action} (aid, uid, type, id, create_time, message, teaser) VALUES (%d, %d, \'%s\', %d, %d, \'%s\', \'%s\')', $aid, $uid, $type, $id, time(), $message, $teaser);
  return $aid;
}

function interact_get_preference_users($field, &$uid_array) {
  $result = db_query('SELECT uid FROM {interact_preference} WHERE ' . $field . ' = 1');
  while ($row = db_fetch_object($result)) {
    $uid_array[$row->uid] = empty($row->aid) ? 0 : $row->aid;
  }
}

function interact_queue_users($uid_array, $aid) {
  global $user;
  if (isset($uid_array[$user->uid])) {
    // don't notify someone of an action they took
    unset($uid_array[$user->uid]);
  }
  foreach ($uid_array as $uid => $notify_aid) {
    db_query('REPLACE INTO {interact_notification} (uid, aid, notify_aid) VALUES (%d, %d, %d)', $uid, $aid, $notify_aid);
  }
}

function interact_immediate_notification() {
  global $user;
  // get the actions to report immediately
  $result = db_query('SELECT a.*, n.uid AS to_uid FROM {interact_action} a JOIN {interact_notification} n ON a.aid = n.aid LEFT JOIN {interact_preference} p ON n.uid = p.uid WHERE (p.email_pref IS NULL OR p.email_pref = %d) AND status = 0 ORDER BY n.uid', INTERACT_NOTIFY_IMMEDIATE);
  $actions_taken = array();
  $last_uid = NULL;
  $start_time = time();
  $time_limit = variable_get('interact_email_max_time_immediate', 5);
  while ($row = db_fetch_object($result)) {
    if ($last_uid != $row->to_uid) {
      // make sure we don't send notification to the current user
      if (0 < count($actions_taken)) {
        interact_mail($last_uid, $actions_taken, INTERACT_NOTIFY_IMMEDIATE);
        $actions_taken = array();
        if (time() - $start_time > $time_limit) {
          break;
        }
      }
    }
    $last_uid = $row->to_uid;
    $actions_taken[] = $row;
  }
  // make sure we don't send notification to the current user
  if (0 < count($actions_taken)) {
    interact_mail($last_uid, $actions_taken, INTERACT_NOTIFY_IMMEDIATE);
  }
}

function interact_queue_notification($aid, $type, $sub_type, $id) {
  // add new notifications for users that had previously requested
  // notifications for the type, sub_type and id given but ignore if
  // the user is the same as the current user (do not notify the posting
  // user in any case)
  global $user;
  db_query('REPLACE INTO {interact_notification} (uid, aid, notify_aid) SELECT a.uid, %d, n.aid FROM {interact_action} a JOIN {interact_notify} n ON a.aid = n.aid WHERE n.type = \'%s\' AND n.sub_type = \'%s\' AND n.id = %d AND a.uid != %d', $aid, $type, $sub_type, $id, $user->uid);
}

function interact_mail($to_uid, $actions, $notification_type) {
  $from = variable_get('site_mail', ini_get('sendmail_from'));
  $subject = t(variable_get('interact_email_subject', INTERACT_EMAIL_NOTIFY_SUBJECT), array('@site_name' => variable_get('site_name', 'Drupal')));
  $actions_text = '';
  $aids = array();
  foreach ($actions as $action) {
    $actions_text .= strip_tags($action->message) . "\n";
    $aids[] = $action->aid;
  }
  $to_user = interact_get_user($to_uid);
  if (!empty($to_user->mail)) {
    $body = t(variable_get('interact_email_body', INTERACT_EMAIL_NOTIFY_BODY), array('@were_#_actions_taken' => format_plural(count($actions), 'was one action taken', 'were @count actions taken'), '@actions_text' => $actions_text, '@site_name' => variable_get('site_name', 'Drupal'), '@site_url' => url('', NULL, NULL, TRUE), '@all_activity_url' => url('interact', NULL, NULL, TRUE), '@notify_url' => url('interact/notify', NULL, NULL, TRUE), '@user_prefs_url' => url('user/' . $to_user->uid . '/edit', NULL, 'interact', TRUE)));
    if (drupal_mail('interact_mail', $to_user->mail, $subject, $body, $from)) {
      db_query('UPDATE {interact_notification} SET status = %d WHERE uid = %d AND aid IN (%s)', $notification_type, $to_uid, implode(',', $aids));
      if (variable_get('interact_log_mail', 1)) {
        watchdog('interact', t('Sent notification mail of type %type to %mail for actions %action_ids.', array('%type' => $notification_type, '%mail' => $to_user->mail, '%action_ids' => implode(', ', $aids))));
      }
    }
  }
  else {
    watchdog('interact', t('Mail attempted to be sent to user %uid with no address for a notification type %type.', array('%uid' => $to_user->uid, '%type' => $notification_type)));
  }
}

/**
 * View user interaction actions.
 *
 * @param int $uid
 * @param int $type
 * @return rendered HTML
 */
function interact_view_actions($uid, $type = NULL, $full_page = TRUE) {
  $output = '';

  if ($full_page) {
    drupal_add_css(_interact_get_path() . '/interact.css');
    $output .= "<div id=\"interact-centre\">\n";
  }

  if (user_access('view user actions')) {
    if ($full_page) {
      // make the callout box
      $all_types = module_invoke_all('interact_types_text');
      if (isset($type)) {
        drupal_set_title(t('@type actions', array('@type' => $all_types[$type])));
        $breadcrumb = drupal_get_breadcrumb();
        $breadcrumb[] = l(t('User actions'), 'user-actions/' . $uid);
        drupal_set_breadcrumb($breadcrumb);
      }
      $items = array();
      $result = db_query('SELECT type, COUNT(*) AS count FROM {interact_action} WHERE uid = %d GROUP BY type', $uid);
      while ($row = db_fetch_object($result)) {
        $items[] = theme('interact_action_icon', $row->type) . ' ' . l($all_types[$row->type], 'user-actions/' . $uid . '/' . $row->type, array('style' => 'margin: 0.2em 0 0.2em 0.5em'), NULL, NULL, FALSE, TRUE) . ' (' . $row->count . ')';
      }
      $output .= '<div id="interact-callout">';
      $output .= theme('item_list', $items, t('Action types'));
      $output .= '</div>';
    }
    $output .= interact_get_actions_html($uid, $type, $full_page);
  }
  if ($full_page) {
    $output .= "</div>\n";
  }
  return $output;
}

function interact_get_actions_html($uid, $type, $full_page, $show_remove_button = FALSE) {
  $output = '';
  $sql = 'SELECT * FROM {interact_action} WHERE uid = %d';
  $ids = array($uid);
  if (isset($type)) {
    $sql .= ' AND type = \'%s\'';
    $ids[] = $type;
  }
  $sql .= ' ORDER BY create_time DESC';

  $result = NULL;
  if ($full_page) {
    $result = pager_query($sql, 50, 0, NULL, $ids);
  }
  else {
    $result = db_query_range($sql, $ids, 0, 25);
  }

  $page = '';
  $last_date = NULL;
  while ($row = db_fetch_object($result)) {
    $date = interact_datetime($row->create_time, TRUE);
    if ($date != $last_date) {
      $last_date = $date;
    }
    else {
      $date = NULL;
    }
    $page .= theme('interact_user_action', $row, $date);
    if ($show_remove_button) {
      $page .= drupal_get_form('interact_remove_action_form', $row->aid);
    }
  }

  if (empty($page)) {
    $user = interact_get_user($uid);
    $all_types = module_invoke_all('interact_types_text');
    $page = theme('interact_no_actions', t('No @type_actions have been taken by @user, yet.', array('@type_' => isset($type) ? drupal_strtolower($all_types[$type]) . ' ': '', '@user' => $user->name)));
  }

  $output .= $page;
  if ($full_page) {
    $output .= theme('pager');
  }
  else {
    $output .= '<div class="interact-see-all-link">' . l('Show all user actions', 'user-actions/' . $uid) . '</div>';
  }
  return $output;
}

function interact_remove_action_form($aid) {
  $form = array();
  $form['aid'] = array(
    '#type' => 'value',
    '#value' => $aid,
  );
  $form['submit'] = array(
    '#type' => 'submit',
    '#value' => t('Remove'),
  );
  return $form;
}

function interact_remove_action_form_submit($form_id, $values) {
  db_query('DELETE FROM {interact_action} WHERE aid = %d', $values['aid']);
  db_query('DELETE FROM {interact_notify} WHERE aid = %d', $values['aid']);
  drupal_set_message('You will no longer be notified.');
}

/**
 * View user interaction messages.
 *
 * @param int $to_uid
 * @param int $from_uid
 * @return rendered HTML
 */
function interact_view_public_messages($to_uid, $from_uid = NULL, $full_page = TRUE) {
  global $user;

  $output = '';

  if ($full_page) {
    drupal_add_css(_interact_get_path() . '/interact.css');
    $output .= "<div id=\"interact-centre\">\n";
  }

  if (user_access('view public messages')) {
    $where = '';
    $to_user = interact_get_user($to_uid);
    $ids = NULL;
    $sql = 'SELECT * FROM {interact_public_message} WHERE';
    if (isset($from_uid)) {
      // include only messages from or to the other user
      $sql .= ' (to_uid = %d AND from_uid = %d) OR (to_uid  = %d AND from_uid = %d)';
      $ids = array($to_uid, $from_uid, $from_uid, $to_uid);
      $from_user = interact_get_user($from_uid);
      $output .= t('Public messages between !to_user and !from_user.', array('!to_user' => l($to_user->name, 'user/' . $to_user->uid), '!from_user' => l($from_user->name, 'user/' . $from_user->uid)));
      if (user_access('post public messages') && ($user->uid == $from_uid || $user->uid == $to_uid)) {
        $output .= drupal_get_form('interact_public_message_form', $to_uid == $user->uid ? $from_uid : $to_uid);
      }
    }
    else {
      // include all messages to this user
      $sql .= ' to_uid = %d';
      $ids = array($to_uid);
      if ($full_page) {
        $output .= t('Public messages to !to_user', array('!to_user' => l($to_user->name, 'user/' . $to_user->uid)));
      }
      if (user_access('post public messages')) {
        $output .= drupal_get_form('interact_public_message_form', $to_uid);
      }
    }
    $sql .= ' ORDER BY create_time DESC';
    $result = NULL;
    if ($full_page) {
      $result = pager_query($sql, 25, 0, NULL, $ids);
    }
    else {
      $result = db_query_range($sql, $ids, 0, 8);
    }
    $page = '';
    while ($row = db_fetch_object($result)) {
      $from_user = interact_get_user($row->from_uid);
      $page .= theme('interact_public_message', $from_user, $to_user, $row, isset($from_uid));
    }
    if (empty($page)) {
      $page = theme('interact_no_public_message', t('No one has sent @user a public message.', array('@user' => $to_user->name)));
    }
    $output .= theme('interact_public_messages', $page);
    if ($full_page) {
      $output .= theme('pager');
    }
    else {
      $output .= '<div class="interact-see-all-link">' . l('Show all public messages', 'public-messages/' . $to_uid) . '<div>';
    }
  }
  if ($full_page) {
    $output .= "</div>\n";
  }
  return $output;
}

function interact_public_message_form($to_uid) {
  global $user;
  $form = array();
  $form['from_uid'] = array(
    '#type' => 'value',
    '#value' => $user->uid,
  );
  $form['to_uid'] = array(
    '#type' => 'value',
    '#value' => $to_uid,
  );
  $form['message'] = array(
    '#type' => 'textarea',
    '#title' => t('New message'),
    '#rows' => 2,
    '#required' => TRUE,
  );
  $form['post'] = array(
    '#type' => 'submit',
    '#value' => t('Post'),
  );
  return $form;
}

function interact_public_message_form_submit($form_id, $values) {
  $mid = db_next_id('{interact_public_message}_mid');
  db_query("INSERT INTO {interact_public_message} (mid, from_uid, to_uid, create_time, message) VALUES (%d, %d, %d, %d, '%s')", $mid, $values['from_uid'], $values['to_uid'], time(), $values['message']);
  drupal_set_message('Public message posted.');
  $from_user = interact_get_user($values['from_uid']);
  $to_user = interact_get_user($values['to_uid']);
  $message = t('!from posted a public !message for !to', array('!from' => l($from_user->name, 'user/' . $from_user->uid), '!message' => l(t('message'), 'interact/public-messages/' . $to_user->uid, array(), NULL, 'message-' . $mid), '!to' => l($to_user->name, 'user/' . $to_user->uid)));
  $teaser = interact_action_teaser($values['message']);
  $aid = interact_save_user_action($values['from_uid'], 'public-message', $mid, $message, $teaser);
  $user_array = array($values['to_uid'] => 0);
  interact_queue_notification($aid, 'user', 'public_message', $to_user->uid);
  interact_queue_notification($aid, 'user', 'public_message', $from_user->uid);
  interact_queue_users($user_array, $aid);
  interact_immediate_notification();
}

function interact_get_user($uid) {
  static $users = array();
  if (!isset($users[$uid])) {
    $users[$uid] = user_load(array('uid' => $uid));
    if (variable_get('user_pictures', 0)) {
      if (empty($users[$uid]->interact_mini_pic)) {
        $default_mini_pic = variable_get('interact_mini_pic_default', '');
        if (!empty($default_mini_pic)) {
          $users[$uid]->interact_mini_pic = $default_mini_pic;
        }
      }
    }
    else {
      unset($users[$uid]->interact_mini_pic);
    }
  }
  return $users[$uid];
}

function interact_datetime($time, $date_only = FALSE) {
  $format = variable_get('date_format_long', 'l, F j, Y - H:i');
  list($date_format, $time_format) = explode(' - ', $format);
  $date = format_date($time, 'custom', $date_format);
  $time_yesterday = time() - 86400;
  $yesterday = format_date($time_yesterday, 'custom', $date_format);
  if ($date == $yesterday) {
    $date = t('Yesterday');
  }
  elseif ($time > $time_yesterday) {
    $date = t('Today');
  }
  $datetime = $date;
  if (!$date_only) {
    $datetime .= t(' at ') . format_date($time, 'custom', $time_format);
  }
  return $datetime;
}

/**
 * Show a list of notifications.
 *
 * @param int $uid user id
 * @param int $type what type of things to show
 * @return string rendered HTML
 */
function interact_my_interests($uid = 0, $type = NULL) {
  global $user;

  drupal_add_css(_interact_get_path() . '/interact.css');

  $output = "<div id=\"interact-centre\">\n";

  if (empty($uid)) {
    $uid = $user->uid;
  }
  elseif ($uid != $user->uid) {
    if (user_access('administer interaction centre')) {
      $other_user = user_load(array('uid' => $uid));
      $output .= '<p>' . t('Interest list for !user.', array('!user' => l($other_user->name, 'user/' . $uid))) . "</p>\n";
    }
    else {
      drupal_access_denied();
      exit();
    }
  }

  // make the callout box
  $all_types = module_invoke_all('interact_types_text');
  if (isset($type)) {
    drupal_set_title(t('@type notifications', array('@type' => $all_types[$type])));
    $breadcrumb = drupal_get_breadcrumb();
    $breadcrumb[] = l(t('My interests'), 'my-interests/' . $uid);
    drupal_set_breadcrumb($breadcrumb);
  }
  $items = array();
  $result = db_query('SELECT a.type, COUNT(*) AS count FROM {interact_action} a JOIN {interact_notification} n ON a.aid = n.aid WHERE n.uid = %d GROUP BY a.type', $uid);
  while ($row = db_fetch_object($result)) {
    $items[] = theme('interact_action_icon', $row->type) . ' ' . l($all_types[$row->type], 'my-interests/' . $uid . '/' . $row->type, array('style' => 'margin: 0.2em 0 0.2em 0.5em'), NULL, NULL, FALSE, TRUE) . ' (' . $row->count . ')';
  }
  $output .= '<div id="interact-callout">';
  $output .= theme('item_list', $items, t('Notification types'));
  $items = array(
    l(t('Your requests to be notified'), 'my-interests/notify/' . $uid),
    l(t('General settings'), 'user/' . $uid . '/edit', array(), NULL, 'interact'),
  );
  $output .= theme('item_list', $items, t('Settings'));
  $output .= '</div>';


  // make the main list
  $sql = 'SELECT * FROM {interact_action} a JOIN {interact_notification} n ON a.aid = n.aid WHERE n.uid = %d';
  $args = array($uid);
  if (isset($type)) {
    $sql .= ' AND a.type = \'%s\'';
    $args[] = $type;
  }
  $sql .= ' ORDER BY create_time DESC';
  $result = pager_query($sql, 25, 0, NULL, $args);
  if (0 < db_num_rows($result)) {
    // output each action
    while ($row = db_fetch_object($result)) {
      $date = interact_datetime($row->create_time, TRUE);
      if ($date != $last_date) {
        $last_date = $date;
      }
      else {
        $date = NULL;
      }
      $output .= theme('interact_user_action', $row, $date, TRUE);
    }

    // mark them as seen if the actual user looked at the list
    if ($uid == $user->uid) {
      db_query('UPDATE {interact_notification} SET status = %d WHERE uid = %d AND status = 0', INTERACT_NOTIFY_NO_EMAIL, $uid);
    }
  }
  else {
    $path = _interact_get_path();
    $output .= t('Nothing has happened on the site that you have expressed interest in being notified about. If you would like to express interest in any part of the site keep an eye out for the grey stars (!image). Click on the star to be notified when activity takes place for that item.', array('!image' => '<img src="' . url($path . '/icons/star-none.png') . '" alt="Grey star" />'));
  }
  $output .= "</div>\n";
  return $output;
}

function interact_notification_requests($uid) {
  global $user;
  $output = '';

  drupal_add_css(_interact_get_path() . '/interact.css');

  $output = "<div id=\"interact-centre\">\n";

  if (empty($uid)) {
    $uid = $user->uid;
  }
  elseif ($uid != $user->uid) {
    if (user_access('administer interaction centre')) {
      $other_user = user_load(array('uid' => $uid));
      $output .= '<p>' . t('Notifications requested by !user.', array('!user' => l($other_user->name, 'user/' . $uid))) . "</p>\n";
    }
    else {
      drupal_access_denied();
      exit();
    }
  }

  $output .= interact_get_actions_html($uid, 'notification-requested', TRUE, TRUE);

  $output .= "</div>\n";

  return $output;
}

function interact_interact_types_text() {
  return array(
    'node-new' => t('New content'),
    'node-edit' => t('Content edit'),
    'comment-new' => t('New comment'),
    'comment-edit' => t('Comment edit'),
    'notification-requested' => t('Notification request'),
    'public-message' => t('Public message'),
  );
}

function interact_notify_link($type, $obj = NULL) {
  global $user;
  $content = NULL;
  if (user_access('add notification requests')) {
    $url = NULL;
    $thickbox_query = INTERACT_THICKBOX_QUERY . '&destination=' . drupal_urlencode($_GET['q']);
    $active_notify = array();
    switch ($type) {
      case 'page' :
        if ('taxonomy' == arg(0) && 'term' == arg(1)) {
          $active_notify = interact_get_notify('term', arg(2));
          $url = url('interact-watch/term/' . arg(2), $thickbox_query);
          $type = 'term';
        }
        elseif ('node' == arg(0) && is_numeric(arg(1)) && !arg(2)) {
          $node = node_load(arg(1));
          if ($user->uid == $node->uid) {
            $thickbox_query .= 