Twitter integration - Notices now broadcast (directly) to Twitter from linked accts.

darcs-hash:20080828192509-7b5ce-8387c67500c082eb5a0107c0f78d4cf5620825af.gz

2 files changed, 80 insertions, 1 deletions

diff --git a/classes/Foreign_link.php b/classes/Foreign_link.php
index 4fcad4b17..f4f8abfc4 100644
--- a/classes/Foreign_link.php
+++ b/classes/Foreign_link.php
@@ -29,7 +29,6 @@ class Foreign_link extends DB_DataObject
 	// XXX:  This only returns a 1->1 single obj mapping.  Change?  Or make
 	// a getForeignUsers() that returns more than one? --Zach
 	static function getForeignLink($user_id, $service) {
-		
 		$flink = new Foreign_link();
 		$flink->whereAdd("service = $service");
 		$flink->whereAdd("user_id = $user_id");
@@ -43,4 +42,19 @@ class Foreign_link extends DB_DataObject
 		return NULL;		
 	}
 	
+	// Convenience method
+	function getForeignUser() {		
+		$fuser = new Foreign_user();
+		$fuser->whereAdd('service = ' . $this->service);
+		$fuser->whereAdd('id = ' . $this->foreign_id);
+		$fuser->limit(1);
+		
+		if ($fuser->find()) {
+			$fuser->fetch();
+			return $fuser;
+		}
+		
+		return NULL;		
+	}
+		
 }
diff --git a/lib/util.php b/lib/util.php
index 0ac679afc..016821c57 100644
--- a/lib/util.php
+++ b/lib/util.php
@@ -1088,6 +1088,16 @@ function common_save_replies($notice) {
 }
 
 function common_broadcast_notice($notice, $remote=false) {
+	
+	// Check to see if notice should go to Twitter
+	$flink = Foreign_link::getForeignLink($notice->profile_id, 1); // 1 == Twitter
+	
+	if ($flink) {
+		if (!common_twitter_broadcast($notice, $flink)) {
+			common_debug('Unable to send notice: ' . $notice->id . ' to Twitter.', __FILE__);
+		}
+	}
+	
 	if (common_config('queue', 'enabled')) {
 		# Do it later!
 		return common_enqueue_notice($notice);
@@ -1096,6 +1106,61 @@ function common_broadcast_notice($notice, $remote=false) {
 	}
 }
 
+function common_twitter_broadcast($notice, $flink) {	
+	$success = true;
+	$fuser = $flink->getForeignUser();
+	$twitter_user = $fuser->nickname;
+	$twitter_password = $flink->credentials;
+	$uri = 'http://www.twitter.com/statuses/update.json';
+	$statustxt = $notice->content;
+	
+	$options = array(
+		CURLOPT_USERPWD 		=> "$twitter_user:$twitter_password",
+		CURLOPT_POST			=> true,
+		CURLOPT_POSTFIELDS		=> array(
+									'status'	=> $statustxt,
+									'source'	=> 'Laconica'
+									),
+		CURLOPT_RETURNTRANSFER	=> true,
+		CURLOPT_FAILONERROR		=> true,
+		CURLOPT_HEADER			=> false,
+		CURLOPT_FOLLOWLOCATION	=> true,
+		// CURLOPT_USERAGENT		=> "identi.ca",
+		CURLOPT_CONNECTTIMEOUT	=> 120,  // XXX: Scary!!!! How long should this be?
+		CURLOPT_TIMEOUT			=> 120
+	);
+	
+	$ch = curl_init($uri);
+    curl_setopt_array($ch, $options);
+    $data = curl_exec($ch);
+    $errmsg = curl_error($ch);
+
+	if ($errmsg) {
+		common_debug("cURL error: $errmsg - trying to send notice for $twitter_user.", 
+			__FILE__);
+		$success = false;
+	}
+
+	curl_close($ch);
+	
+	if (!$data) {
+		common_debug("No data returned by Twitter's API trying to send update for $twitter_user",
+			__FILE__);
+		$success = false;
+	}
+
+	// Twitter should return a status	
+	$status = json_decode($data);
+
+	if (!$status->id) {
+		common_debug("Unexpected data returned by Twitter API trying to send update for $twitter_user",
+			__FILE__);
+		$success = false;
+	}
+	
+	return $status;
+}
+
 # Stick the notice on the queue
 
 function common_enqueue_notice($notice) {