hunk ./actions/facebookhome.php 39 - $facebook = $this->get_facebook(); + $facebook = get_facebook(); hunk ./actions/facebookinvite.php 37 - $facebook = $this->get_facebook(); + $facebook = get_facebook(); hunk ./actions/facebooksettings.php 37 - $facebook = $this->get_facebook(); + $facebook = get_facebook(); hunk ./actions/facebooksettings.php 47 + $fbml .= '

Allow Identi.ca to update my Facebook status

'; + hunk ./classes/Foreign_link.php 7 -class Foreign_link extends Memcached_DataObject +class Foreign_link extends Memcached_DataObject hunk ./classes/Foreign_link.php 16 - public $credentials; // varchar(255) + public $credentials; // varchar(255) hunk ./classes/Foreign_link.php 32 - static function getByUserID($user_id, $service) { + static function getByUserID($user_id, $service) + { hunk ./classes/Foreign_link.php 43 - return null; + return null; hunk ./classes/Foreign_link.php 45 - - static function getByForeignID($foreign_id, $service) { + + static function getByForeignID($foreign_id, $service) + { hunk ./classes/Foreign_link.php 57 - return null; + return null; hunk ./classes/Foreign_link.php 59 - + hunk ./classes/Foreign_link.php 62 - { + { hunk ./classes/Foreign_link.php 66 - + hunk ./classes/Foreign_link.php 68 - + hunk ./classes/Foreign_link.php 72 - - return null; + + return null; hunk ./classes/Foreign_link.php 75 - + hunk ./classes/Foreign_link.php 80 - + hunk ./lib/facebookaction.php 22 -require_once(INSTALLDIR.'/extlib/facebook/facebook.php'); +require_once(INSTALLDIR.'/lib/facebookutil.php'); + hunk ./lib/facebookaction.php 32 - - function get_facebook() - { - $apikey = common_config('facebook', 'apikey'); - $secret = common_config('facebook', 'secret'); - return new Facebook($apikey, $secret); - } addfile ./lib/facebookutil.php hunk ./lib/facebookutil.php 1 +. + */ + +require_once(INSTALLDIR.'/extlib/facebook/facebook.php'); + +// Gets all the notices from users with a Facebook link since a given ID +function get_facebook_notices($since) +{ + $qry = 'SELECT notice.* ' . + 'FROM notice ' . + 'JOIN foreign_link ' . + 'WHERE notice.profile_id = foreign_link.user_id ' . + 'AND foreign_link.service = 2'; + + // XXX: What should the limit be? + return Notice::getStreamDirect($qry, 0, 100, 0, 0, null, $since); +} + +function get_facebook() +{ + $apikey = common_config('facebook', 'apikey'); + $secret = common_config('facebook', 'secret'); + return new Facebook($apikey, $secret); +} addfile ./scripts/update_facebook.php hunk ./scripts/update_facebook.php 1 +#!/usr/bin/env php +. + */ + +# Abort if called from a web server +if (isset($_SERVER) && array_key_exists('REQUEST_METHOD', $_SERVER)) { + print "This script must be run from the command line\n"; + exit(); +} + +define('INSTALLDIR', realpath(dirname(__FILE__) . '/..')); +define('LACONICA', true); + +require_once(INSTALLDIR . '/lib/common.php'); +require_once(INSTALLDIR . '/lib/facebookutil.php'); + +// For storing the last run date-time +$last_updated_file = "/home/zach/laconica/scripts/facebook_last_updated"; + +// Lock file name +$tmp_file = "/tmp/update_facebook.lock"; + +// Make sure only one copy of the script is running at a time +if (!($tmp_file = @fopen($tmp_file, "w"))) +{ + die("Can't open lock file. Script already running?"); +} + +$facebook = get_facebook(); + +$current_time = time(); + +$notice = get_facebook_notices(get_last_updated()); + +while($notice->fetch()) { + + $flink = Foreign_link::getByUserID($notice->profile_id, 2); + $fbuid = $flink->foreign_id; + + update_status($fbuid, $notice); + +} + +update_last_updated($current_time); + +exit(0); + + + +function update_status($fbuid, $notice) { + global $facebook; + + try { + + $result = $facebook->api_client->users_setStatus($notice->content, $fbuid, false, true); + + } catch(FacebookRestClientException $e){ + + print_r($e); + } + +} + +function get_last_updated(){ + global $last_updated_file, $current_time; + + $file = fopen($last_updated_file, 'r'); + + if ($file) { + $last = fgets($file); + } else { + print "Unable to read $last_updated_file. Using current time.\n"; + return $current_time; + } + + fclose($file); + + return $last; +} + +function update_last_updated($time){ + global $last_updated_file; + $file = fopen($last_updated_file, 'w') or die("Can't open $last_updated_file for writing!"); + fwrite($file, $time); + fclose($file); +}