$config['properties']['consumer_key'],
'consumer_secret' => $config['properties']['consumer_secret'],
'call_back_url' => $config['properties']['OAUTH_CALLBACK'],
);
/*
* Check if the if the user is authenticated if not run the authenticating function and show the login link in the activity stream
*/
if (empty($_SESSION['access_token']) || empty($_SESSION['access_token']['oauth_token']) || empty($_SESSION['access_token']['oauth_token_secret'])) {
$connection = check_auth($sugar_config['site_url']);
}
//Pull in values set in the authenitcation function.
$html .= $_REQUEST['html'];
$request_token = $_REQUEST['request_token'];
/* Get user access tokens out of the session. */
$access_token = $_SESSION['access_token'];
/* Create a TwitterOauth object with consumer/user tokens. */
$connection = new TwitterOAuth($settings['consumer_key'], $settings['consumer_secret'], $access_token['oauth_token'], $access_token['oauth_token_secret']);
/* If method is set change API call made. Test is called by default. */
$tweets = $connection->get('statuses/home_timeline', array('screen_name' => $_SESSION['access_token']['screen_name'], 'exclude_replies' => false));
//Set the increment value.
$i = 0;
/*
-Loop through all the tweets.
- Replace any URLS for Hrefs first, this needs to be done first as this is what get stored in the DB so duplicate checking would not work otherwise.
- Reformat the Date from twitters date format.
- Check if the tweet has already been entered into the Activity Stream.
- if no duplicates found use insert query to add tweet to activity stream.
- Start loop again.
*/
if (empty($tweets['errors'])) {
while ($i < count($tweets)) {
$limit = 104;
$tweets[$i]['text'] = format_feed_tweets($db, $tweets[$i], $limit);
if (count($tweets[$i]['entities']['hashtags']) > 0) {
$tweets[$i]['text'] = replace_hashtags($db, $tweets[$i]);
}
if (count($tweets[$i]['entities']['user_mentions']) > 0) {
$tweets[$i]['text'] = replace_users($db, $tweets[$i]);
}
$date = date("Y-m-d H:i:s", strtotime($tweets[$i]['created_at']));
$image = "
";
$duplicate_found = duplicate_check($db, $tweets[$i]['text'], $date);
if (!$duplicate_found) {
$id = create_guid();
$sql = "INSERT INTO sugarfeed (id, name, date_entered, date_modified, modified_user_id, created_by, description, deleted, assigned_user_id, related_module, related_id, link_url, link_type)
VALUES
('" . $id . "',
'" . $image . "" . $tweets[$i]['user']['name'] . " ',
'" . $date . "',
'" . $date . "',
'1',
'1',
'" . $tweets[$i]['text'] . "',
'0',
'" . $current_user->id . "',
'twitter',
'" . $current_user->id . "',
NULL,
NULL);";
$results = $db->query($sql);
$i++;
} else {
$i++;
}
}
}
}
$facebook_enabled = check_enabled($db, 'facebook');
if ($facebook_enabled) {
require_once("include/social/facebook/facebook.class.php");
$facebook_helper = new facebook_helper();
//get current user logged in
$user = $facebook_helper->facebook->getUser();
$user_home = check_facebook_login($facebook_helper);
if ($user) {
$logoutUrl = $facebook_helper->get_logout_url();
} else {
$loginUrl = $facebook_helper->get_login_url($_REQUEST['url']);
}
if ($user) {
// $log = 'Facebook Logout';
} else {
;
$log = 'Facebook Login';
}
$html .= '';
$html .= $log;
$html .= '';
if (isset($user_home['data'])) { // Check to prevent Undefined index error
foreach ($user_home['data'] as $single) {
data_insert($single, "facebook");
}
}
}
function check_facebook_login($facebook_helper)
{
$user = $facebook_helper->facebook->getUser();
if ($user) {
$user_profile = $facebook_helper->get_my_user(); //get my user details
$user_home = $facebook_helper->get_my_newsfeed(); //gets my newsfeed,
}
if ($user) {
$logoutUrl = $facebook_helper->get_logout_url();
} else {
$loginUrl = $facebook_helper->get_login_url($url);
}
return $user_home;
}
function data_insert($single, $type)
{
$db = DBManagerFactory::getInstance();
$id = guid_maker();
$temp = generate_stream($single);
$message = $db->quote($temp[1]);
$name = $db->quote($temp[0]);
$assigned_user = '1';
$date = date("Y-m-d H:i:s", strtotime($single['created_time']));
$sql_check = "SELECT * FROM sugarfeed WHERE description = '" . $message . "' AND date_entered = '" . $date . "'";
$results = $db->query($sql_check);
while ($row = $db->fetchByAssoc($results)) {
$found_record = $row;
break;
}
if (empty($found_record)) {
$sql = "INSERT INTO sugarfeed (id, name, date_entered, date_modified, modified_user_id, created_by, description, deleted, assigned_user_id, related_module, related_id, link_url, link_type)
VALUES
('" . $id . "',
'" . $name . "',
'" . $date . "',
'" . $date . "',
'1',
'1',
'" . $message . "',
'0',
'" . $assigned_user . "',
'" . $type . "',
'" . $assigned_user . "',
NULL,
NULL);";
if (!empty($message)) {
$results = $db->query($sql);
}
}
}
function guid_maker()
{
if (function_exists('com_create_guid')) {
return com_create_guid();
}
mt_srand((double)microtime() * 10000); //optional for php 4.2.0 and up.
$charid = strtoupper(md5(uniqid(mt_rand(), true)));
$hyphen = chr(45);
$uuid = chr(123)
. substr($charid, 0, 8) . $hyphen
. substr($charid, 8, 4) . $hyphen
. substr($charid, 12, 4) . $hyphen
. substr($charid, 16, 4) . $hyphen
. substr($charid, 20, 12)
. chr(125);
return $uuid;
}
function generate_stream($stream)
{
// Fix to prevent undefined index notice
if (!isset($stream['type'])) {
$stream['type'] = "";
}
//if simple post
switch ($stream['type']) {
case "":
$string[1] = "" . $stream['from']['name'] . " - " . substr($stream['message'], 0, 100);
break;
case "link":
$string[0] = "![](http://graph.facebook.com/")
";
if (!empty($stream['name'])) {
$string[1] = '' . $stream['from']['name']. '' . $stream['name'] . '
' . 'View article';
} else {
//must be an article
$string[1] = '' . $stream['from']['name']. '' . " likes an article";
}
break;
case "status":
//
$string[0] = "";
if (!empty($stream['story'])) {
$string[1] = '' . $stream['from']['name']. '' . substr($stream['story'], 0, 100) . "
View post on Facebook";
} else {
//wall post.
$string[1] = '' . $stream['from']['name'] . '' . substr($stream['message'], 0, 100) . "
View post on Facebook";
}
break;
case "photos":
break;
}
return $string;
}