View source
<?php
define('ACTIVITY_ALL', -1);
function activity_perm() {
return array(
'administer activity',
'view own activity',
'view public activity',
);
}
function activity_menu($may_cache) {
$items = array();
global $user;
if ($may_cache) {
$items[] = array(
'path' => 'activity',
'title' => t('Activity'),
'callback' => 'activity_page',
'access' => user_access('view public activity'),
'weight' => 1,
);
$items[] = array(
'path' => 'activity/delete',
'title' => t('Delete activity'),
'callback' => 'activity_delete',
'access' => user_access('administer activity'),
'type' => MENU_CALLBACK,
);
$items[] = array(
'path' => 'activity/all',
'title' => t('All activity'),
'type' => MENU_DEFAULT_LOCAL_TASK,
'access' => user_access('view public activity'),
);
$items[] = array(
'path' => 'activity/mine',
'title' => t('My activity'),
'access' => $user->uid,
'type' => MENU_LOCAL_TASK,
'access' => user_access('view own activity'),
);
$items[] = array(
'path' => 'activity/all/feed',
'title' => t('All activity RSS'),
'callback' => 'activity_feed',
'callback arguments' => array(
ACTIVITY_ALL,
),
'type' => MENU_CALLBACK,
'access' => user_access('view public activity'),
);
$items[] = array(
'path' => 'activity/all/json',
'title' => t('All activity JSON'),
'callback' => 'activity_json',
'callback arguments' => array(
ACTIVITY_ALL,
1,
),
'type' => MENU_CALLBACK,
'access' => user_access('view public activity'),
);
$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',
),
);
}
else {
if (arg(0) == 'admin' && arg(1) == 'settings' && arg(2) == 'activity') {
if ($activity_info = activity_get_info()) {
foreach ($activity_info as $module => $info) {
$module_nice_name = drupal_ucfirst(str_replace('_', ' ', substr($module, 0, -8)));
$items[] = array(
'path' => 'admin/settings/activity/' . $module,
'title' => $module_nice_name . ' ' . t('Module Activity Settings'),
'description' => t('Customize what will display on your activity pages for the @module module', array(
'@module' => $module_nice_name,
)),
'callback' => 'drupal_get_form',
'callback arguments' => array(
'activity_module_settings',
arg(3),
),
'type' => MENU_CALLBACK,
);
}
}
}
if ($user->uid) {
$items[] = array(
'path' => 'activity/' . $user->uid . '/feed',
'title' => t('My activity'),
'callback' => 'activity_feed',
'callback arguments' => array(
$user->uid,
),
'type' => MENU_CALLBACK,
);
$items[] = array(
'path' => 'activity/' . $user->uid . '/json',
'callback' => 'activity_json',
'callback arguments' => array(
$user->uid,
1,
),
'type' => MENU_CALLBACK,
);
}
}
return $items;
}
function activity_admin_settings() {
$form['general_settings'] = array(
'#type' => 'fieldset',
'#title' => t('General settings'),
'#collapsible' => FALSE,
);
$form['general_settings']['activity_page_pager'] = array(
'#type' => 'select',
'#title' => t('Activity Page Results per Page'),
'#description' => t('Select the number of activity records to show on activity pages such as <a href="@activity">this one</a>.', array(
'@activity' => url('activity'),
)),
'#options' => drupal_map_assoc(array(
5,
10,
20,
25,
30,
50,
)),
'#default_value' => variable_get('activity_page_pager', 20),
);
$form['general_settings']['activity_user_profile_records'] = array(
'#type' => 'select',
'#title' => t('Activity Results per User Profile'),
'#description' => t('Select the number of activity records to show on a user\'s profile page. Selecting 0 will disable activity from showing on user profile pages.'),
'#options' => drupal_map_assoc(array(
0,
5,
10,
20,
25,
30,
50,
)),
'#default_value' => variable_get('activity_user_profile_records', 5),
);
$form['general_settings']['activity_time_limit'] = array(
'#type' => 'select',
'#title' => t('Activity time limiter'),
'#description' => t("Allows you to set a time limit for recording activity so repeated actions don't flood your activity feed. If the same action is submitted within X seconds of the last activity record of the same type from the same user then the activity is not logged."),
'#options' => drupal_map_assoc(array(
5,
10,
20,
30,
60,
120,
300,
600,
1800,
), format_interval),
'#default_value' => variable_get('activity_time_limit', 30),
);
$form['general_settings']['activity_purge'] = array(
'#type' => 'select',
'#title' => t('Activity log purge'),
'#description' => t("Allows you to set a time limit for storing activity records. Select 0 to keep all activity records."),
'#options' => drupal_map_assoc(array(
0,
3600,
7200,
14400,
21600,
43200,
86400,
604800,
1209600,
2419200,
7257600,
15724800,
31536000,
), format_interval),
'#default_value' => variable_get('activity_purge', 0),
);
$form['general_settings']['activity_user_optout'] = array(
'#type' => 'checkbox',
'#title' => t('Allow user privacy opt-out'),
'#description' => t('If you wish to allows users to opt-out of Activity then check the box above. If a user opts-out then activity that the user originates will not be recorded.'),
'#default_value' => variable_get('activity_user_optout', 0),
);
if ($activity_info = activity_get_info()) {
$form['module_settings'] = array(
'#type' => 'fieldset',
'#title' => t('Activity contrib modules'),
'#description' => t('Click on the links below to configure the activity settings for the activity contrib modules you have installed.'),
'#collapsible' => FALSE,
);
foreach ($activity_info as $module => $info) {
if (!empty($info)) {
$module_nice_name = drupal_ucfirst(str_replace('_', ' ', substr($module, 0, -8)));
$form['module_settings'][$module] = array(
'#type' => 'markup',
'#value' => '<p>' . l($module_nice_name . ' activity settings page', 'admin/settings/activity/' . $module, array(
'title' => 'Configure ' . $module_nice_name,
)) . '</p>',
);
}
}
}
else {
drupal_set_message(t('No supported modules enabled. Check the !activity_section for supported modules.', array(
'!activity_section' => l(t('Activity section'), 'admin/build/modules'),
)));
}
return system_settings_form($form);
}
function activity_module_settings($module) {
drupal_add_js(drupal_get_path('module', 'activity') . '/activity_admin.js');
$module_nice_name = drupal_ucfirst(str_replace('_', ' ', substr($module, 0, -8)));
$module_help = t('<p>The configuration settings below determine how activity generated by the <strong><em>@module</em></strong> module is recorded. Select which types of activity and which operations to record by checking/unchecking the options for <strong>Token Types</strong> and <strong>Operation Types</strong>. You can customize the text that is displayed on an activity record by changing the text in the fields below for each combination of token type and operation type and role.</p>', array(
'@module' => $module_nice_name,
));
$form['help'] = array(
'#type' => 'markup',
'#value' => $module_help,
);
$info = module_invoke($module, 'activity_info');
if (!empty($info)) {
$tokens = array();
$token_list = array();
foreach (token_get_list($module) as $name => $token_array) {
$token_list = array_merge($token_list, $token_array);
}
foreach (token_get_list('activity') as $name => $token_array) {
$token_list = array_merge($token_list, $token_array);
}
ksort($token_list);
foreach ($token_list as $token => $desc) {
$tokens[] = '[' . $token . ']: ' . $desc;
}
if (count($info['types'])) {
$form['token_op_types'] = array(
'#type' => 'fieldset',
'#title' => t('Token and operation types'),
'#collapsible' => TRUE,
'#collapsed' => FALSE,
);
$form['token_op_types'][$module . '_token_types'] = array(
'#type' => 'checkboxes',
'#title' => t('Token types'),
'#description' => t('Select the token types that you wish to record activity from.'),
'#options' => $info['types'],
'#default_value' => variable_get($module . '_token_types', array_keys($info['types'])),
'#attributes' => array(
'class' => 'activity-token-types',
),
);
$form['token_op_types'][$module . '_op_types'] = array(
'#type' => 'checkboxes',
'#title' => t('Operation types'),
'#description' => t('Select the operation types that you wish to record activity from.'),
'#options' => $info['ops'],
'#default_value' => variable_get($module . '_op_types', array_keys($info['ops'])),
'#attributes' => array(
'class' => 'activity-operation-types',
),
);
$form['token_settings'] = array(
'#type' => 'fieldset',
'#title' => t('Tokens available to @name activity', array(
'@name' => t($module_nice_name),
)),
'#collapsible' => TRUE,
'#collapsed' => TRUE,
'#description' => t('Available tokens') . theme('item_list', $tokens),
);
if ($ops = $info['ops']) {
if ($roles = $info['roles']) {
foreach ($roles as $role_name => $role) {
$form[$module][$role_name] = array(
'#type' => 'fieldset',
'#title' => t('Messages visible to the "@role_name" role.', array(
'@role_name' => $role['#name'],
)),
'#collapsible' => TRUE,
'#collapsed' => FALSE,
'#description' => $role['#description'] ? $role['#description'] : '',
);
if ($types = $info['types']) {
$token_types = variable_get($module . '_token_types', $info['types']);
$op_types = variable_get($module . '_op_types', $info['ops']);
foreach ($types as $type_name => $type) {
if (count($types) > 1) {
$form[$module][$role_name][$type_name] = array(
'#type' => 'fieldset',
'#title' => t($type),
'#collapsible' => TRUE,
'#collapsed' => TRUE,
);
}
foreach ($ops as $op_name => $op) {
$token_field = "{$module}_{$type_name}_{$op_name}_{$role_name}";
$default = '';
if (!is_array($role['#default']) && $role['#default']) {
$default = $role['#default'];
}
else {
if (is_array($role['#default']) && isset($role['#default'][$op_name])) {
$default = $role['#default'][$op_name];
}
}
if ($default) {
$form[$module][$role_name][$type_name][$token_field] = array(
'#type' => 'textfield',
'#title' => $type . ': ' . $op,
'#default_value' => variable_get($token_field, $default),
);
}
}
}
}
}
}
}
}
}
return system_settings_form($form);
}
function activity_user($op, &$edit, &$account, $category = NULL) {
switch ($op) {
case 'view':
if (user_access('view public activity') && variable_get('activity_user_profile_records', 5) != 0) {
$activity = activity_get_activity($account->uid, NULL, variable_get('activity_user_profile_records', 5));
$activities = array();
foreach ($activity as $item) {
$activities[] = theme('activity', activity_token_replace($item), $item);
}
$items['activity'] = array(
'value' => theme('activity_user_profile_activity', $activities),
);
return array(
t('Activity') => $items,
);
}
break;
case 'form':
if ($category == 'account' && variable_get('activity_user_optout', 0)) {
$form['activity'] = array(
'#type' => 'fieldset',
'#title' => t('Activity privacy settings'),
'#collapsible' => TRUE,
'#collapsed' => FALSE,
'#weight' => 6,
);
$form['activity']['activity_optout'] = array(
'#type' => 'checkbox',
'#title' => t('Do not record my site activity'),
'#description' => t('If you wish keep your site activity from appearing in the <a href="@activity">activity</a> pages, check the box.', array(
'@activity' => url('activity'),
)),
'#default_value' => isset($edit['activity_optout']) ? $edit['activity_optout'] : '',
);
}
return $form;
break;
case 'delete':
db_query('DELETE FROM {activity_targets} WHERE aid IN (SELECT aid FROM {activity} WHERE uid = %d)', $account->uid);
db_query('DELETE FROM {activity} WHERE uid = %d', $account->uid);
db_query('DELETE FROM {activity} WHERE aid IN (SELECT aid FROM {activity_targets} WHERE target_uid = %d)', $account->uid);
db_query('DELETE FROM {activity_targets} WHERE target_uid = %d', $account->uid);
break;
}
}
function activity_cron() {
$interval = variable_get('activity_purge', 0);
if ($interval > 0) {
$time = time() - $interval;
if (module_exists('activityhistory')) {
db_query('DELETE FROM {activity_history} WHERE aid IN (SELECT aid FROM {activity} WHERE created < %d)', $time);
}
db_query('DELETE FROM {activity_targets} WHERE aid IN (SELECT aid FROM {activity} WHERE created < %d)', $time);
db_query('DELETE FROM {activity} WHERE created < %d', $time);
}
}
function activity_get_info() {
foreach (module_implements('activity_info') as $module) {
$info[$module] = module_invoke($module, 'activity_info');
}
return $info;
}
function activity_insert($uid, $module, $type, $operation, $data, $target_users_roles) {
$result = db_query("SELECT COUNT(*) FROM {activity} WHERE uid = %d AND module = '%s' AND type = '%s' AND operation = '%s' AND data = '%s' AND created >= %d", $uid, $module, $type, $operation, serialize($data), time() - variable_get('activity_time_limit', 30));
if (db_fetch_object($result)->count != 0) {
return FALSE;
}
$aid = db_next_id('activity');
db_query("INSERT INTO {activity} (aid, uid, module, type, operation, created, data)\n VALUES (%d, %d, '%s', '%s', '%s', %d, '%s')", $aid, $uid, $module, $type, $operation, time(), serialize($data));
foreach ($target_users_roles as $target_uid => $role) {
db_query("INSERT INTO {activity_targets} (aid, target_uid, target_role) VALUES (%d, %d, '%s')", $aid, $target_uid, $role);
}
$activity = array(
'aid' => $aid,
'uid' => $uid,
'module' => $module,
'type' => $type,
'operation' => $operation,
'data' => $data,
'target_user_roles' => $target_users_roles,
);
activity_invoke_activityapi($activity, 'insert');
return $aid;
}
function activity_delete($aid = NULL) {
if ($aid && is_numeric($aid)) {
if (module_exists('activityhistory')) {
db_query('DELETE FROM {activity_history} WHERE aid = %d', $aid);
}
db_query('DELETE FROM {activity_targets} WHERE aid = %d', $aid);
db_query('DELETE FROM {activity} WHERE aid = %d', $aid);
}
drupal_goto(drupal_get_destination());
}
function activity_delete_link($activity) {
global $user;
if ($user->uid != 0 && $activity['uid'] == $user->uid || user_access('administer activity')) {
return theme('activity_delete_link', $activity);
}
return NULL;
}
function activity_get_activity($uids = ACTIVITY_ALL, $filters = NULL, $limit = NULL, $tablesort_headers = NULL) {
$wheres = array();
if (!is_array($uids)) {
$wheres[] = "activity_targets.target_uid = %d";
$params[] = $uids;
}
else {
foreach ($uids as $uid) {
$nums[] = "%d";
$params[] = $uid;
}
$wheres[] = 'activity_targets.target_uid IN (' . implode(',', $nums) . ')';
}
if (!empty($filters) && is_array($filters)) {
$ops = array(
'include' => " = '%s'",
'exclude' => " != '%s'",
'lt' => ' < %d',
'gt' => ' > %d',
'lte' => ' <= %d',
'gte' => ' >= %d',
);
foreach ($filters as $column => $filter) {
if ($column == 'target_role') {
$column = 'activity_targets.target_role';
}
else {
$column = "activity.{$column}";
}
if (!is_array($filter) || count(array_intersect(array_keys($ops), array_keys($filter))) == 0) {
$filter = array(
'include' => $filter,
);
}
foreach ($filter as $criteria => $values) {
if (is_array($values)) {
$strings = array();
foreach ($values as $value) {
$strings[] = "'%s'";
$params[] = $value;
}
$wheres[] = $column . ($criteria == 'exclude' ? ' NOT IN ' : ' IN ') . '(' . implode(',', $strings) . ')';
}
else {
$wheres[] = $column . $ops[$criteria];
$params[] = $values;
}
}
}
}
if (count($wheres) > 0) {
$where = implode(' AND ', $wheres);
$where = "WHERE {$where}";
}
if (empty($tablesort_headers)) {
$tablesort_headers = activity_get_tablesort_headers();
$tablesort_headers['activity.created']['sort'] = 'desc';
}
$sql = "SELECT activity.*, activity_targets.target_uid, activity_targets.target_role\n FROM {activity_targets} activity_targets INNER JOIN {activity} activity ON activity.aid = activity_targets.aid\n {$where} ";
$tablesort_sql = tablesort_sql($tablesort_headers);
$sql = db_rewrite_sql("{$sql} {$tablesort_sql}", 'activity_targets', 'aid', array(
'uids' => $uids,
));
if (is_numeric($limit)) {
$result = pager_query($sql, $limit, 0, NULL, $params);
}
else {
$result = db_query($sql, $params);
}
$activity = array();
while ($row = db_fetch_array($result)) {
$row['data'] = unserialize($row['data']);
$row['data']['aid'] = $row['aid'];
$row['data']['uid'] = $row['uid'];
$row['data']['module'] = $row['module'];
$row['data']['type'] = $row['type'];
$row['data']['operation'] = $row['data']['operation'] ? $row['data']['operation'] : $row['operation'];
$row['data']['created'] = $row['created'];
activity_invoke_activityapi($row, 'load');
if (!empty($row)) {
$activity[] = $row;
}
}
return $activity;
}
function activity_invoke_activityapi(&$activity, $op) {
$return = array();
foreach (module_implements('activityapi') as $name) {
$function = $name . '_activityapi';
$result = $function($activity, $op);
if (isset($result) && is_array($result)) {
$return = array_merge($return, $result);
}
else {
if (isset($result)) {
$return[] = $result;
}
}
}
return $return;
}
function activity_get_tablesort_headers() {
return array(
'activity_targets.aid' => array(
'field' => 'activity_targets.aid',
'data' => t('Id'),
),
'activity.module' => array(
'field' => 'activity.module',
'data' => t('Module'),
),
'activity.type' => array(
'field' => 'activity.type',
'data' => t('Type'),
),
'activity.operation' => array(
'field' => 'activity.operation',
'data' => t('Operation'),
),
'activity.created' => array(
'field' => 'activity.created',
'data' => t('Created'),
),
);
}
function activity_block($op = 'list', $delta = 0, $edit = array()) {
global $user;
switch ($op) {
case 'list':
$block['my']['info'] = t("Activity: Mine: show the current user's activity.");
$block['all']['info'] = t("Activity: All: show all recent activity");
return $block;
break;
case 'configure':
$form['items'] = array(
'#type' => 'select',
'#title' => t('Number of items'),
'#default_value' => variable_get('activity_block_' . $delta, 5),
'#options' => drupal_map_assoc(range(1, 50)),
);
return $form;
break;
case 'save':
variable_set('activity_block_' . $delta, $edit['items']);
break;
case 'view':
switch ($delta) {
case 'my':
if (user_access('view own activity')) {
$activity = activity_get_activity($user->uid, NULL, variable_get('activity_block_' . $delta, 5) + 1);
if ($count = count($activity)) {
drupal_add_css(drupal_get_path('module', 'activity') . '/activity.css');
if ($count > variable_get('activity_block_' . $delta, 5)) {
$more_link = theme('activity_more_link', 'activity/mine');
array_pop($activity);
}
$activities = array();
foreach ($activity as $item) {
$activities[] = theme('activity', activity_token_replace($item), $item) . activity_delete_link($item);
}
return array(
'subject' => t('My activity'),
'content' => theme('activity_block', $activities, $more_link),
);
}
}
break;
case 'all':
if (user_access('view public activity')) {
$activity = activity_get_activity(ACTIVITY_ALL, NULL, variable_get('activity_block_' . $delta, 5) + 1);
if ($count = count($activity)) {
drupal_add_css(drupal_get_path('module', 'activity') . '/activity.css');
if ($count > variable_get('activity_block_' . $delta, 5)) {
$more_link = theme('activity_more_link', 'activity');
array_pop($activity);
}
$activities = array();
foreach ($activity as $item) {
$activities[] = theme('activity', activity_token_replace($item), $item) . activity_delete_link($item);
}
return array(
'subject' => t('Recent activity'),
'content' => theme('activity_block', $activities, $more_link),
);
}
}
break;
}
break;
}
}
function activity_page($page = 'all') {
global $user;
drupal_add_css(drupal_get_path('module', 'activity') . '/activity.css');
if ($page == 'mine') {
$activities = activity_get_activity($user->uid, NULL, variable_get('activity_page_pager', 20));
$table = theme('activity_table', $activities);
$feed_url = url('activity/' . $user->uid . '/feed');
drupal_add_feed($feed_url);
$feed = theme('feed_icon', $feed_url);
return theme('activity_page', $activities, $table);
}
else {
if ($page == 'all') {
$activities = activity_get_activity(ACTIVITY_ALL, NULL, variable_get('activity_page_pager', 20));
$table = theme('activity_table', $activities);
$feed_url = url('activity/all/feed');
drupal_add_feed($feed_url);
$feed = theme('feed_icon', $feed_url);
return theme('activity_page', $activities, $table);
}
}
}
function activity_feed($arg) {
global $locale;
if ($arg == ACTIVITY_ALL) {
$activities = activity_get_activity(ACTIVITY_ALL, NULL, variable_get('activity_page_pager', 20));
$url = url('activity/all', NULL, NULL, TRUE);
$feed_title = t('All activity');
}
else {
if (is_numeric($arg)) {
$user = db_fetch_object(db_query('SELECT uid, name FROM {users} WHERE uid = %d', $arg));
if ($user) {
$activities = activity_get_activity($arg, NULL, variable_get('activity_page_pager', 20));
$url = url('activity/' . $user->uid, NULL, NULL, TRUE);
$feed_title = t('Activity for @username', array(
'@username' => $user->name,
));
}
}
}
if (count($activities) > 0) {
foreach ($activities as $activity) {
$function = $activity['module'] . '_format_rss_item';
if (function_exists($function)) {
$items .= $function($activity);
}
else {
$message = activity_token_replace($activity);
$items .= format_rss_item(strip_tags($message), url('activity/' . $user->uid, NULL, NULL, TRUE), format_date($activity['created']) . '<p>' . $message . '</p>');
}
}
}
$channel = array(
'version' => '2.0',
'title' => variable_get('site_name', 'Drupal') . ' - ' . $feed_title,
'link' => $url,
'description' => variable_get('site_mission', ''),
'language' => $locale,
);
$namespaces = array(
'xmlns:dc="http://purl.org/dc/elements/1.1/"',
);
$output = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n";
$output .= "<rss version=\"" . $channel["version"] . "\" xml:base=\"" . $url . "\" " . implode(' ', $namespaces) . ">\n";
$output .= format_rss_channel($channel['title'], $channel['link'], $channel['description'], $items, $channel['language']);
$output .= "</rss>\n";
drupal_set_header('Content-Type: application/rss+xml; charset=utf-8');
print $output;
}
function activity_json($arg) {
global $locale;
$args = func_get_args();
if ($args[0] == ACTIVITY_ALL) {
$activities = activity_get_activity(ACTIVITY_ALL, NULL, $args[1]);
$url = url('activity/all', NULL, NULL, TRUE);
$feed_title = t('All activity');
}
else {
if (is_numeric($args[0])) {
$user = db_fetch_object(db_query('SELECT uid, name FROM {users} WHERE uid = %d', $args[0]));
if ($user) {
$activities = activity_get_activity($arg[0], NULL, $args[1]);
$url = url('activity/' . $user->uid, NULL, NULL, TRUE);
$feed_title = t('Activity for @username', array(
'@username' => theme('username', $user),
));
}
}
}
if (count($activities) > 0) {
foreach ($activities as $activity) {
$message = activity_token_replace($activity);
$items .= '<item><date>' . format_date($activity['created'], 'small') . '</date>';
$items .= '<url>' . url('activity/' . $user->uid, NULL, NULL, TRUE) . '</url>';
$items .= '<message>' . $message . '</message></item>';
}
}
drupal_set_header('Content-Type: application/x-javascript');
print drupal_to_js($items);
die;
}
function activity_token_list($type = 'all') {
if ($type == 'activity') {
$tokens = array(
'activity' => array(),
);
$tokens['activity'] = array(
'author-uid' => t('User Id of the person who initiated the activity'),
'author' => t('Themed username of the person who initiated the activity (used for "author" role)'),
'author-all' => t('Themed username of the person who initiated the activity (used for "all" role)'),
'author-name' => t('Plain text username of the person who initiated the activity'),
'author-picture' => t('The user picture of the person who initiated the activity'),
'operation' => t('The verb of the operation that took place, eg. "create", "update", "delete"'),
'time-small' => t('Date and time in small format: @example', array(
'@example' => format_date(time(), 'small'),
)),
'time-medium' => t('Date and time in medium format: @example', array(
'@example' => format_date(time(), 'medium'),
)),
'time-large' => t('Date and time in large format: @example', array(
'@example' => format_date(time(), 'large'),
)),
'time-ago' => t('How long ago did this happen? Example: %time-ago', array(
'%time-ago' => format_interval(time() - 60 * 60 * 36),
)),
);
return $tokens;
}
}
function activity_token_values($type, $data = NULL, $options = array()) {
if ($type == 'activity' && !empty($data)) {
$author = activity_user_load($data['uid']);
$tokens = array(
'author' => theme('activity_username', $author, TRUE),
'author-all' => theme('activity_username', $author),
'author-name' => $author->name,
'author-picture' => theme('activity_user_picture', $author),
'operation' => $data['operation'],
'time-small' => format_date($data['created'], 'small'),
'time-medium' => format_date($data['created'], 'medium'),
'time-large' => format_date($data['created'], 'large'),
'time-ago' => format_interval(time() - $data['created']),
);
return $tokens;
}
}
function activity_token_replace($activity) {
extract($activity);
$var = "{$module}_{$type}_{$operation}_{$target_role}";
if ($pattern = variable_get($var, FALSE)) {
activity_invoke_activityapi($activity, 'render');
$message = token_replace($pattern, $module, $data);
$message = token_replace($message, 'activity', $data);
return $message;
}
}
function activity_install_activity_defaults($module) {
require_once drupal_get_path('module', $module) . '/' . $module . '.module';
$info = call_user_func($module . '_activity_info');
if ($info) {
variable_set($module . '_token_types', array_keys($info['types']));
variable_set($module . '_op_types', array_keys($info['ops']));
foreach ($info['roles'] as $role_name => $role) {
foreach ($info['types'] as $type_name => $type) {
foreach ($info['ops'] as $op_name => $op) {
$token_field = "{$module}_{$type_name}_{$op_name}_{$role_name}";
$default = is_array($role['#default']) ? $role['#default'][$op_name] : $role['#default'];
variable_set($token_field, $default ? $default : '');
}
}
}
}
}
function activity_user_load($uid) {
static $users;
if (!isset($users[$uid])) {
$users[$uid] = db_fetch_object(db_query('SELECT uid, name, picture FROM {users} WHERE uid = %d', $uid));
}
return $users[$uid];
}
function activity_user_privacy_optout($user) {
if (variable_get('activity_user_optout', 0) && $user->activity_optout) {
return TRUE;
}
return FALSE;
}
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;
}
function activity_simpletest() {
$module_name = 'activity';
$dir = drupal_get_path('module', $module_name) . '/tests';
$tests = file_scan_directory($dir, '\\.test$');
return array_keys($tests);
}
function theme_activity_page($activities, $table) {
return $table;
}
function theme_activity_table($activities) {
$display_headers = array(
'created' => array(
'field' => 'created',
'data' => t('Date'),
),
t('Message'),
);
$rows = array();
foreach ($activities as $activity) {
if ($activity_message = activity_token_replace($activity)) {
$row = array(
array(
'data' => theme('activity_timestamp', $activity['created']),
'class' => 'activity-table-timestamp',
),
array(
'data' => theme('activity', $activity_message, $activity),
'class' => 'activity-table-message',
),
);
if ($delete_link = activity_delete_link($activity)) {
array_push($row, array(
'data' => $delete_link,
'class' => 'activity-table-delete-link',
));
}
$rows[] = $row;
}
}
$output = theme('table', $display_headers, $rows, array(
'class' => 'activity-table',
));
$output .= theme('pager');
return $output;
}
function theme_activity_block($activities, $more_link = '') {
if ($content = theme('item_list', $activities, NULL, 'ul', array(
'class' => 'activity-list',
))) {
$content .= $more_link;
return $content;
}
}
function theme_activity_user_profile_activity($activities) {
if ($content = theme('item_list', $activities, NULL, 'ul', array(
'class' => 'activity-list',
))) {
return $content;
}
}
function theme_activity_user_picture($account) {
return theme('user_picture', $account);
}
function theme_activity_username($account, $self = FALSE) {
global $user;
return $self && $user->uid == $account->uid ? t('you') : theme('username', $account);
}
function theme_activity_more_link($path) {
return '<div class="more-link">' . l(t('more'), $path, array(
'title' => t('See all of your activity.'),
)) . '</div>';
}
function theme_activity($message, $item) {
return $item['mark'] . '<span class="activity activity-module-' . $item['module'] . ' activity-type-' . $item['type'] . ' activity-operation-' . $item['operation'] . '">' . $message . '</span>';
}
function theme_activity_timestamp($timestamp) {
return format_date($timestamp, 'small');
}
function theme_activity_node_type($node_type) {
return strtolower(node_get_types('name', $node_type));
}
function theme_activity_delete_link($activity) {
return l('X', 'activity/delete/' . $activity['aid'], array(
'title' => t('Delete this activity record'),
'class' => 'activity-delete-record',
), drupal_get_destination());
}