<?php
// $Id: activity.module,v 1.7 2007-11-29 00:36:26 sirkitree Exp $

/**
 * @file
 * Activity module: Allow users to see their friends' activity on the site.
 */

/**
 * Implementation of hook_perm().
 */
function activity_perm() {
  return array('administer activity', 'view activity');
}

/**
 * Implementation of hook_menu().
 */
function activity_menu($may_cache) {
  $items = array();

  if ($may_cache) {
    $items[] = array(
      'path' => 'activity',
      'title' => t('activity'),
      'callback' => 'activity_page',
      'callback arguments' => array(arg(1)),
      'access' => user_access('view activity'),
      'type' => MENU_CALLBACK,
    );
    $items[] = array(
      'path' => 'activity/feed',
      'callback' => 'activity_feed',
      'callback arguments' => array(arg(2)),
      'access' => user_access('view activity'),
      'type' => MENU_CALLBACK,
    );
    $items[] = array(
      'path' => 'admin/settings/activity',
      'title' => t('Activity Settings'),
      'description' => t('Customize what will display on your users activity page.'),
      'callback' => 'drupal_get_form',
      'callback arguments' => array('activity_admin_settings'),
      'access' => user_access('administer site configuration'),
    );
    $items[] = array(
      'path' => 'admin/settings/activity/implements',
      'title' => t('Choose modules'),
      'callback' => 'activity_admin_settings',
      'access' => user_access('administer site configuration'),
      'type' => MENU_DEFAULT_LOCAL_TASK,
    );
    $items[] = array(
      'path' => 'admin/settings/activity/tokens',
      'title' => t('Choose tokens'),
      'callback' => 'drupal_get_form',
      'callback arguments' => array('activity_admin_settings'),
      'access' => user_access('administer site configuration'),
      'type' => MENU_LOCAL_TASK,
    );
  }
  return $items;
}

/**
 * Admin section
 */
function activity_admin_settings() {
  foreach (module_implements('activity_info') as $module) {
    $modules[] = module_invoke($module, 'activity_info');
  }
  if (!empty($modules[0])) {
    foreach ($modules as $module) {
      if (!empty($module)) {
        switch (arg(3)) {
          case 'tokens':
            if (variable_get('activity_'. $module['name'] .'_module', 0) == 1) {
              $tokens = array();
              foreach ($module['tokens'] as $token => $desc) {
                $tokens[] = '['. $token .']: '. $desc;
              }
              $form['activity_'. $module['name'] .'_token'] = array(
                '#type' => 'fieldset',
                '#title' => $module['name'],
                '#collapsible' => true,
                '#collapsed' => true,
                '#description' => t('Available tokens') . theme('item_list', $tokens),
              );
              foreach ($module['ops'] as $op) {
                foreach ($module['types'] as $type => $name) {
                  if (variable_get('activity_'. $module['name'] .'_'. $type, 0) == 1) {
                    $form['activity_'. $module['name'] .'_token']['activity_'. $module['name'] .'_'. $op .'_'. $type .'_token'] = array(
                      '#type' => 'textfield',
                      '#title' => t($op .' '. $name),
                      '#default_value' => variable_get('activity_'. $module['name'] .'_'. $op .'_'. $type .'_token', ''),
                    );
                  }
                }
                if (empty($module['types'])) {
                  $form['activity_'. $module['name'] .'_token']['activity_'. $module['name'] .'_'. $op .'_token'] = array(
                    '#type' => 'textfield',
                    '#title' => t($op),
                    '#default_value' => variable_get('activity_'. $module['name'] .'_'. $op .'_token', ''),
                  );
                }
              }
            }
            break;
          default:
            $form['activity_message_limit'] = array(
              '#type' => 'textfield',
              '#title' => 'Message Limit',
              '#description' => t('Set a limit for how many messages display on the activity display.'),
              '#default_value' => variable_get('activity_message_limit', 20),
            );
            $form['activity_'. $module['name']] = array(
              '#type' => 'fieldset',
              '#title' => $module['name'],
              '#collapsible' => true,
              '#collapsed' => false,
            );
            $form['activity_'. $module['name']]['activity_'. $module['name'] .'_module'] = array(
              '#type' => 'checkbox',
              '#title' => $module['name'],
              '#default_value' => variable_get('activity_'. $module['name'] .'_module', 0),
              '#description' => t('Check to enable activity tracking for this module.'),
            );
            if (!empty($module['types'])) {
              $form['activity_'. $module['name']]['activity_'. $module['name'] .'_type'] = array(
                '#type' => 'fieldset',
                '#title' => t('activity types'),
                '#collapsible' => true,
                '#collapsed' => true,
                '#description' => t('Check to enable activity tracking for this type of activity.'),
              );
              foreach ($module['types'] as $type => $name) {
                $form['activity_'. $module['name']]['activity_'. $module['name'] .'_type']['activity_'. $module['name'] .'_'. $type] = array(
                  '#type' => 'checkbox',
                  '#title' => $name,
                  '#default_value' => variable_get('activity_'. $module['name'] .'_'. $type, 0),
                );
              }
            }
            break;
        }
      }
    }
  }
  else {
    $form = array();
    drupal_set_message('No supported modules enabled. Check the '. l('Activity section', 'admin/build/modules') .' for supported modules.');
  }
  return system_settings_form($form);
}

/**
 * function to get all buddy activity
 * @returns array of activity
 */
function activity_buddy_activity($account_id) {
  global $user;
  $buddies = array();
  $buddy_activity = array();
  // took activity_account from here
  $account = activity_account($account_id);
  switch ($_GET['who']) {
    case 'me':
      $me['uid'] = $user->uid;
      $me['name'] = $user->name;
      $me['mail'] = $user->mail;
      $me['online'] = 1;
      array_push($buddies, $me);
      break;
    case 'friends':
      // find who current user's buddies are = obj
      // $account must be int
      $buddies = buddylist_get_buddies($account);
      break;
    default:
      // find who current user's buddies are = obj
      $buddies = buddylist_get_buddies($account);
      // add current user to list of buddies
      $me['uid'] = $user->uid;
      $me['name'] = $user->name;
      $me['mail'] = $user->mail;
      $me['online'] = 1;
      $buddies[$user->uid] = $me;
      break;
  }

  // see what activity each buddy has done
  if (!empty($buddies)) {
    foreach ($buddies as $buddy) {
      $query = db_query(db_rewrite_sql("SELECT * FROM {activity} a WHERE a.uid = %d ORDER BY a.timestamp DESC", 'a', 'aid', array('uid' => $buddy['uid'])), $buddy['uid']);
      while ($row = db_fetch_object($query)) {
        // appending count to make the time stamp unique for sorting purposes
        $buddy_activity[$row->timestamp . $count] = $row;
        $count++;
      }
    }
  }
  return $buddy_activity;
}

/**
 * -- activity account --
 * find what user we're getting buddy activity for
 * @param uid
 * @return a user object
 */
function activity_account($account_to_load) {

  // if we're on a user profile page, make sure we load that user
  $q = explode('/', $_GET['q']);
  if (is_numeric($q[1])) {
    $account = user_load(array('uid' => $q[1]));
  }

  $account = $account->uid ? $account->uid : $account_to_load;
  if (!$account) {
    // there was no # passed from 'q' or $account_to_load
    global $user;
    $account = $user;
  }
  return $account;
}

/**
 * create a block for display
 * @param op
 * @param delta
 * @returns block HTML
 */
function activity_block($op = 'list', $delta = 0) {
  global $user;
  if ($op == 'list') {
    $block[0]['info'] = t('Friend Activity');
    return $block;
  }
  elseif ($op == 'view') {
    $block['content'] = activity_page($user->uid);
    return $block;
  }
}

/**
 * Menu callback to display the records in a page
 */
function activity_page($uid) {
  $buddy_activity = activity_buddy_activity($uid);
  arsort($buddy_activity);
  $count = 0;
  if (!empty($buddy_activity)) {
    foreach ($buddy_activity as $ba) {
      if ($count < variable_get('activity_message_limit', 20)) {
        $offset = (strftime("%j") + strftime("%Y") * 365) - (strftime("%j", $ba->timestamp) + strftime("%Y", $ba->timestamp) * 365);
        $timeset = ($offset > 0 && $offset != $prev_offset) ? '<h3>'. activity_format_offset($ba->timestamp) .'</h3>' : '';
        $activity = activity_token_replace($ba);
        if ($activity) {
          $items[] = $timeset . $activity .' <span class="activity-time">'. date('g:ia', $ba->timestamp) .'</span> ';
        }
        $prev_offset = $offset;
      }
      $count++;
    }
    return theme('activity_page', $items);
  }
}

/**
 * theme function for displaying the users activity page
 */
function theme_activity_page($items) {
  return theme('item_list', $items, NULL, 'ul', array('class' => 'activity-list'));
}

/**
 * menu callback to return a feed of a signed in user's activity page
 */
function activity_feed($user_name) {
  $account = user_load(array('name' => $user_name));
  $buddy_activity = activity_buddy_activity($account->uid);
  drupal_set_header('Content-Type: text/xml; charset=utf-8');
  print theme('activity_feed', $buddy_activity);
  exit;
}

function theme_activity_feed($buddy_activity) {
  global $base_url;
  $channel = array(
    'version'     => '2.0',
    'title'       => variable_get('site_name', 'drupal') .' - '. variable_get('site_slogan', ''),
    'link'        => $base_url,
    'description' => variable_get('site_mission', ''),
    'language'    => $GLOBALS['locale'],
  );

  arsort($buddy_activity);
  if (!empty($buddy_activity)) {
    foreach ($buddy_activity as $ba) {
      $item_title = $ba->module;
      $item_tokens = unserialize($ba->tokens);
      $link = l($item_tokens['node-title'], 'node/'. $item_tokens['node-id']);
      $item_text = activity_token_replace($ba);
      $items .= format_rss_item($item->title, $link, $item_text);
    }
  }

  $output = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n";
  $output .= "<rss version=\"". $channel["version"] . "\" xml:base=\"". $base_url ."\">\n";
  $output .= format_rss_channel($channel['title'], $channel['link'], $channel['description'], $items, $channel['language']);
  $output .= "</rss>\n";

  return $output;
}

/**
 * determine what the message should say
 */
function activity_token_replace($activity) {
  // what tokens are available for this module
  if (variable_get('activity_'. $activity->module .'_module', 0) == 1) {

    // FORMAT: (array)token => value
    $tokens = unserialize($activity->tokens);

    // FORMAT: [user] did [something] to [what]
    if (variable_get('activity_'. $activity->module .'_'. $activity->action .'_'. $activity->type .'_token', FALSE)) {
      $pattern = variable_get('activity_'. $activity->module .'_'. $activity->action .'_'. $activity->type .'_token', 0);
    }
    else {
      $pattern = variable_get('activity_'. $activity->module .'_'. $activity->action .'_token', 0);
    }

    // user-link
    if (strstr($pattern, 'user-link') !== FALSE) {
      $tokens['user-link'] = l($tokens['user-name'], 'user/'. $tokens['user-id']);
    }

    // buddy-link
    if (strstr($pattern, 'buddy-link') !== FALSE) {
      $tokens['buddy-link'] = l($tokens['buddy-name'], 'user/'. $tokens['buddy-id']);
    }

    // node-title-link
    if (strstr($pattern, 'node-title-link') !== FALSE) {
      $tokens['node-title-link'] = l($tokens['node-title'], 'node/'. $tokens['node-id']);
    }

    foreach ($tokens as $key => $val) {
      $pattern = str_replace('['. $key .']', $val, $pattern);
    }

    return $pattern;
  }
  else {
    $tokens = unserialize($activity->tokens);
    return $tokens['contents'];
  }

}

/**
 * function that does all the recording
 */
function activity_insert($module, $type, $action, $tokens) {
  global $user;
  $aid = db_next_id('activity');
  db_query("INSERT INTO {activity} VALUES (%d, %d, '%s', '%s', '%s', '%s', %d)", $aid, $user->uid, $module, $type, $action, serialize($tokens), time());
}

/**
 * date formatter
 * $timestamp is the unix timestamp() of when an activity occurred.
 * $end is the human language formatted string expressing how long ago this was.
 */
function activity_format_offset($timestamp) {
  $offset = (strftime("%j") + strftime("%Y") * 365) - (strftime("%j", $timestamp) + strftime("%Y", $timestamp) * 365);
  if ($offset >= 7) {
    $offset = (strftime("%V") + strftime("%Y") * 52) - (strftime("%V", $timestamp) + strftime("%Y", $timestamp) * 52);
    $end = $offset != 0 ? format_plural($offset, t("a week ago"), t("@count weeks ago", array("@count" => $offset))) : t("Today");
  }
  else if ($offset > 0) {
    $end = format_plural($offset, t('Yesterday'), t('@count days ago', array('@count' => $offset)));
  }
  else {
    $end = t('Today');
  }
  return $end;
}