X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=lib%2Ftwitterapi.php;h=378716eaadec2ba53dae9235e76b6dc86f16c4fc;hb=8deac7248e7db35515d7810491f9136deffa3098;hp=12416bc36783e7563816ddd3ce096700679a1553;hpb=140689800b03ff704f6c70260c2b740ad41578c0;p=quix0rs-gnu-social.git diff --git a/lib/twitterapi.php b/lib/twitterapi.php index 12416bc367..378716eaad 100644 --- a/lib/twitterapi.php +++ b/lib/twitterapi.php @@ -21,25 +21,27 @@ if (!defined('LACONICA')) { exit(1); } class TwitterapiAction extends Action { + var $auth_user; + function handle($args) { parent::handle($args); } - + function twitter_user_array($profile, $get_notice=false) { - + $twitter_user = array(); - $twitter_user['name'] = $profile->getBestName(); + $twitter_user['name'] = $profile->getBestName(); $twitter_user['followers_count'] = $this->count_subscriptions($profile); $twitter_user['screen_name'] = $profile->nickname; $twitter_user['description'] = ($profile->bio) ? $profile->bio : NULL; $twitter_user['location'] = ($profile->location) ? $profile->location : NULL; $twitter_user['id'] = intval($profile->id); - + $avatar = $profile->getAvatar(AVATAR_STREAM_SIZE); - + $twitter_user['profile_image_url'] = ($avatar) ? common_avatar_display_url($avatar) : common_default_avatar(AVATAR_STREAM_SIZE); - $twitter_user['protected'] = false; # not supported by Laconica yet + $twitter_user['protected'] = 'false'; # not supported by Laconica yet $twitter_user['url'] = ($profile->homepage) ? $profile->homepage : NULL; if ($get_notice) { @@ -47,47 +49,54 @@ class TwitterapiAction extends Action { if ($notice) { # don't get user! $twitter_user['status'] = $this->twitter_status_array($notice, false); - } + } } - - return $twitter_user; + + return $twitter_user; } - function twitter_status_array($notice, $get_user=true) { - - $twitter_status = array(); + function twitter_status_array($notice, $include_user=true) { + + $profile = $notice->getProfile(); - $twitter_status['text'] = $notice->content; - $twitter_status['truncated'] = false; # Not possible on Laconica + $twitter_status = array(); + $twitter_status['text'] = common_xml_safe_str($notice->content); + $twitter_status['truncated'] = 'false'; # Not possible on Laconica $twitter_status['created_at'] = $this->date_twitter($notice->created); $twitter_status['in_reply_to_status_id'] = ($notice->reply_to) ? intval($notice->reply_to) : NULL; - $twitter_status['source'] = NULL; # XXX: twitterific, twitterfox, etc. Not supported yet. + $twitter_status['source'] = $this->source_link($notice->source); $twitter_status['id'] = intval($notice->id); - $twitter_status['in_reply_to_user_id'] = ($notice->reply_to) ? $this->replier_by_reply($notice->reply_to) : NULL; - $twitter_status['favorited'] = NULL; # XXX: Not implemented on Laconica yet. + $twitter_status['in_reply_to_user_id'] = ($notice->reply_to) ? $this->replier_by_reply(intval($notice->reply_to)) : NULL; + + if (isset($this->auth_user)) { + common_debug("auth user set: " . $this->auth_user->nickname); + $twitter_status['favorited'] = ($this->auth_user->hasFave($notice)) ? 'true' : 'false'; + } else { + common_debug("no auth user set"); + $twitter_status['favorited'] = 'false'; + } - if ($get_user) { - $profile = $notice->getProfile(); + if ($include_user) { # Don't get notice (recursive!) - $twitter_user = $this->twitter_user_array($profile, false); + $twitter_user = $this->twitter_user_array($profile, false, $user); $twitter_status['user'] = $twitter_user; } - + return $twitter_status; } - + function twitter_rss_entry_array($notice) { - + $profile = $notice->getProfile(); - $server = common_config('site', 'server'); + $server = common_config('site', 'server'); $entry = array(); - - $entry['content'] = $profile->nickname . ': ' . $notice->content; + + $entry['content'] = $profile->nickname . ': ' . common_xml_safe_str($notice->content); $entry['title'] = $entry['content']; - $entry['link'] = common_local_url('shownotice', array('notice' => $notice->id));; + $entry['link'] = common_local_url('shownotice', array('notice' => $notice->id)); $entry['published'] = common_date_iso8601($notice->created); - $entry['id'] = "tag:$server,$entry[published]:$entry[link]"; + $entry['id'] = "tag:$server,2008:$entry[link]"; $entry['updated'] = $entry['published']; # RSS Item specific @@ -97,40 +106,71 @@ class TwitterapiAction extends Action { return $entry; } - - function show_twitter_xml_status($twitter_status) { + + function twitter_rss_dmsg_array($message) { + + $server = common_config('site', 'server'); + $entry = array(); + + $entry['title'] = sprintf('Message from %s to %s', + $message->getFrom()->nickname, $message->getTo()->nickname); + + $entry['content'] = common_xml_safe_str($message->content); + $entry['link'] = $message->uri; + $entry['published'] = common_date_iso8601($message->created); + $entry['id'] = "tag:$server,2008:$entry[link]"; + $entry['updated'] = $entry['published']; + + # RSS Item specific + $entry['description'] = $entry['content']; + $entry['pubDate'] = common_date_rfc2822($message->created); + $entry['guid'] = $entry['link']; + + return $entry; + } + + function twitter_dmsg_array($message) { + + $twitter_dm = array(); + + $from_profile = $message->getFrom(); + $to_profile = $message->getTo(); + + $twitter_dm['id'] = $message->id; + $twitter_dm['sender_id'] = $message->from_profile; + $twitter_dm['text'] = common_xml_safe_str($message->content); + $twitter_dm['recipient_id'] = $message->to_profile; + $twitter_dm['created_at'] = $this->date_twitter($message->created); + $twitter_dm['sender_screen_name'] = $from_profile->nickname; + $twitter_dm['recipient_screen_name'] = $to_profile->nickname; + $twitter_dm['sender'] = $this->twitter_user_array($from_profile, false); + $twitter_dm['recipient'] = $this->twitter_user_array($to_profile, false); + + return $twitter_dm; + } + + function show_twitter_xml_status($twitter_status) { common_element_start('status'); - common_element('created_at', NULL, $twitter_status['created_at']); - common_element('id', NULL, $twitter_status['id']); - common_element('text', NULL, $twitter_status['text']); - common_element('source', NULL, $twitter_status['source']); - common_element('truncated', NULL, $twitter_status['truncated']); - common_element('in_reply_to_status_id', NULL, $twitter_status['in_reply_to_status_id']); - common_element('in_reply_to_user_id', NULL, $twitter_status['in_reply_to_user_id']); - common_element('favorited', Null, $twitter_status['favorited']); - - if ($twitter_status['user']) { - $this->show_twitter_xml_user($twitter_status['user']); + foreach($twitter_status as $element => $value) { + if ($element == 'user') { + $this->show_twitter_xml_user($twitter_status['user']); + } else { + common_element($element, NULL, $value); + } } - common_element_end('status'); - } - - function show_twitter_xml_user($twitter_user) { - common_element_start('user'); - common_element('id', NULL, $twitter_user['id']); - common_element('name', NULL, $twitter_user['name']); - common_element('screen_name', NULL, $twitter_user['screen_name']); - common_element('location', NULL, $twitter_user['location']); - common_element('description', NULL, $twitter_user['description']); - common_element('profile_image_url', NULL, $twitter_user['profile_image_url']); - common_element('url', NULL, $twitter_user['url']); - common_element('protected', NULL, $twitter_user['protected']); - common_element('followers_count', NULL, $twitter_user['followers_count']); - if ($twitter_user['status']) { - $this->show_twitter_xml_status($twitter_user['status']); + } + + function show_twitter_xml_user($twitter_user, $role='user') { + common_element_start($role); + foreach($twitter_user as $element => $value) { + if ($element == 'status') { + $this->show_twitter_xml_status($twitter_user['status']); + } else { + common_element($element, NULL, $value); + } } - common_element_end('user'); + common_element_end($role); } function show_twitter_rss_item($entry) { @@ -142,7 +182,7 @@ class TwitterapiAction extends Action { common_element('link', NULL, $entry['link']); common_element_end('item'); } - + function show_twitter_atom_entry($entry) { common_element_start('entry'); common_element('title', NULL, $entry['title']); @@ -153,100 +193,213 @@ class TwitterapiAction extends Action { common_element('link', array('href' => $entry['link'], 'rel' => 'alternate', 'type' => 'text/html'), NULL); common_element_end('entry'); } - - function show_twitter_json_statuses($twitter_statuses) { - print(json_encode($twitter_statuses)); + + function show_json_objects($objects) { + print(json_encode($objects)); } - function show_twitter_json_users($twitter_users) { - print(json_encode($twitter_users)); + function show_single_xml_status($notice) { + $this->init_document('xml'); + $twitter_status = $this->twitter_status_array($notice); + $this->show_twitter_xml_status($twitter_status); + $this->end_document('xml'); } - function show($args, $apidata) { - parent::handle($args); - - $id = $apidata['api_arg']; - $notice = Notice::staticGet($id); + function show_single_json_status($notice) { + $this->init_document('json'); + $status = $this->twitter_status_array($notice); + $this->show_json_objects($status); + $this->end_document('json'); + } - if ($notice) { + function show_single_xml_dmsg($message) { + $this->init_document('xml'); + $dmsg = $this->twitter_dmsg_array($message); + $this->show_twitter_xml_dmsg($dmsg); + $this->end_document('xml'); + } + + function show_single_json_dmsg($message) { + $this->init_document('json'); + $dmsg = $this->twitter_dmsg_array($message); + $this->show_json_objects($dmsg); + $this->end_document('json'); + } + + function show_twitter_xml_dmsg($twitter_dm) { + common_element_start('direct_message'); + foreach($twitter_dm as $element => $value) { + if ($element == 'sender' || $element == 'recipient') { + $this->show_twitter_xml_user($value, $element); + } else { + common_element($element, NULL, $value); + } + } + common_element_end('direct_message'); + } - if ($apidata['content-type'] == 'xml') { - $this->show_single_xml_status($notice); - } elseif ($apidata['content-type'] == 'json') { - $this->show_single_json_status($notice); + function show_xml_timeline($notice) { + + $this->init_document('xml'); + common_element_start('statuses', array('type' => 'array')); + + if (is_array($notice)) { + foreach ($notice as $n) { + $twitter_status = $this->twitter_status_array($n); + $this->show_twitter_xml_status($twitter_status); } } else { - header('HTTP/1.1 404 Not Found'); + while ($notice->fetch()) { + $twitter_status = $this->twitter_status_array($notice); + $this->show_twitter_xml_status($twitter_status); + } } - - exit(); + + common_element_end('statuses'); + $this->end_document('xml'); } - - function show_single_xml_status($notice) { - header('Content-Type: application/xml; charset=utf-8'); - common_start_xml(); - $twitter_status = $this->twitter_status_array($notice); - $this->show_twitter_xml_status($twitter_status); - common_end_xml(); - exit(); + + function show_rss_timeline($notice, $title, $link, $subtitle, $suplink=NULL) { + + $this->init_document('rss'); + + common_element_start('channel'); + common_element('title', NULL, $title); + common_element('link', NULL, $link); + if (!is_null($suplink)) { + # For FriendFeed's SUP protocol + common_element('link', array('xmlns' => 'http://www.w3.org/2005/Atom', + 'rel' => 'http://api.friendfeed.com/2008/03#sup', + 'href' => $suplink, + 'type' => 'application/json')); + } + common_element('description', NULL, $subtitle); + common_element('language', NULL, 'en-us'); + common_element('ttl', NULL, '40'); + + + if (is_array($notice)) { + foreach ($notice as $n) { + $entry = $this->twitter_rss_entry_array($n); + $this->show_twitter_rss_item($entry); + } + } else { + while ($notice->fetch()) { + $entry = $this->twitter_rss_entry_array($notice); + $this->show_twitter_rss_item($entry); + } + } + + common_element_end('channel'); + $this->end_twitter_rss(); } - - function show_single_json_status($notice) { - header('Content-Type: application/json; charset=utf-8'); - $status = $this->twitter_status_array($notice); - $this->show_twitter_json_statuses($status); - exit(); + + function show_atom_timeline($notice, $title, $id, $link, $subtitle=NULL, $suplink=NULL) { + + $this->init_document('atom'); + + common_element('title', NULL, $title); + common_element('id', NULL, $id); + common_element('link', array('href' => $link, 'rel' => 'alternate', 'type' => 'text/html'), NULL); + if (!is_null($suplink)) { + # For FriendFeed's SUP protocol + common_element('link', array('rel' => 'http://api.friendfeed.com/2008/03#sup', + 'href' => $suplink, + 'type' => 'application/json')); + } + common_element('subtitle', NULL, $subtitle); + + if (is_array($notice)) { + foreach ($notice as $n) { + $entry = $this->twitter_rss_entry_array($n); + $this->show_twitter_atom_entry($entry); + } + } else { + while ($notice->fetch()) { + $entry = $this->twitter_rss_entry_array($notice); + $this->show_twitter_atom_entry($entry); + } + } + + $this->end_document('atom'); + } - - // Anyone know what date format this is? - // Twitter's dates look like this: "Mon Jul 14 23:52:38 +0000 2008" -- Zach + + function show_json_timeline($notice) { + + $this->init_document('json'); + + $statuses = array(); + + if (is_array($notice)) { + foreach ($notice as $n) { + $twitter_status = $this->twitter_status_array($n); + array_push($statuses, $twitter_status); + } + } else { + while ($notice->fetch()) { + $twitter_status = $this->twitter_status_array($notice); + array_push($statuses, $twitter_status); + } + } + + $this->show_json_objects($statuses); + + $this->end_document('json'); + } + + // Anyone know what date format this is? + // Twitter's dates look like this: "Mon Jul 14 23:52:38 +0000 2008" -- Zach function date_twitter($dt) { $t = strtotime($dt); return date("D M d G:i:s O Y", $t); } - - function replier_by_reply($reply_id) { + function replier_by_reply($reply_id) { $notice = Notice::staticGet($reply_id); - - if (!$notice) { - common_debug("TwitterapiAction::replier_by_reply: Got a bad notice_id: $reply_id"); - } - - $profile = $notice->getProfile(); - - if (!$profile) { - common_debug("TwitterapiAction::replier_by_reply: Got a bad profile_id: $profile_id"); - return false; + if ($notice) { + $profile = $notice->getProfile(); + if ($profile) { + return intval($profile->id); + } else { + common_debug('Can\'t find a profile for notice: ' . $notice->id, __FILE__); + } + } else { + common_debug("Can't get notice: $reply_id", __FILE__); } - - return intval($profile->id); + return NULL; } - // XXX: Candidate for a general utility method somewhere? + // XXX: Candidate for a general utility method somewhere? function count_subscriptions($profile) { - + $count = 0; $sub = new Subscription(); $sub->subscribed = $profile->id; $count = $sub->find(); - + if ($count > 0) { - return $count; + return $count - 1; + } else { + return 0; } - - return NULL; } - function init_document($type='xml') { + function init_document($type='xml') { switch ($type) { case 'xml': - header('Content-Type: application/xml; charset=utf-8'); + header('Content-Type: application/xml; charset=utf-8'); common_start_xml(); break; case 'json': header('Content-Type: application/json; charset=utf-8'); + + // Check for JSONP callback + $callback = $this->arg('callback'); + if ($callback) { + print $callback . '('; + } break; case 'rss': header("Content-Type: application/rss+xml; charset=utf-8"); @@ -257,17 +410,25 @@ class TwitterapiAction extends Action { $this->init_twitter_atom(); break; default: - $this->client_error(_('Unsupported type')); + $this->client_error(_('Not a supported data format.')); break; } + + return; } - + function end_document($type='xml') { switch ($type) { case 'xml': common_end_xml(); break; case 'json': + + // Check for JSONP callback + $callback = $this->arg('callback'); + if ($callback) { + print ')'; + } break; case 'rss': $this->end_twitter_rss(); @@ -276,13 +437,14 @@ class TwitterapiAction extends Action { $this->end_twitter_rss(); break; default: - $this->client_error(_('Unsupported type')); + $this->client_error(_('Not a supported data format.')); break; } + return; } - + function client_error($msg, $code = 400, $content_type = 'json') { - + static $status = array(400 => 'Bad Request', 401 => 'Unauthorized', 402 => 'Payment Required', @@ -301,48 +463,49 @@ class TwitterapiAction extends Action { 415 => 'Unsupported Media Type', 416 => 'Requested Range Not Satisfiable', 417 => 'Expectation Failed'); - + $action = $this->trimmed('action'); - + common_debug("User error '$code' on '$action': $msg", __FILE__); - + if (!array_key_exists($code, $status)) { $code = 400; } $status_string = $status[$code]; header('HTTP/1.1 '.$code.' '.$status_string); - + if ($content_type == 'xml') { - common_start_xml(); + $this->init_document('xml'); common_element_start('hash'); common_element('error', NULL, $msg); common_element('request', NULL, $_SERVER['REQUEST_URI']); common_element_end('hash'); - common_end_xml(); + $this->end_document('xml'); } else { + $this->init_document('json'); $error_array = array('error' => $msg, 'request' => $_SERVER['REQUEST_URI']); - print(json_encode($error_array)); + print(json_encode($error_array)); + $this->end_document('json'); } - - exit(); + } function init_twitter_rss() { common_start_xml(); common_element_start('rss', array('version' => '2.0')); } - + function end_twitter_rss() { common_element_end('rss'); common_end_xml(); } - + function init_twitter_atom() { common_start_xml(); common_element_start('feed', array('xmlns' => 'http://www.w3.org/2005/Atom', 'xml:lang' => 'en-US')); } - + function end_twitter_atom() { common_end_xml(); common_element_end('feed'); @@ -355,11 +518,56 @@ class TwitterapiAction extends Action { $this->show_twitter_xml_user($profile_array); break; case 'json': - $this->show_twitter_json_users($profile_array); + $this->show_json_objects($profile_array); break; default: - $this->client_error(_('not a supported data format')); + $this->client_error(_('Not a supported data format.')); return; } + return; } + + function get_user($id, $apidata=NULL) { + if (!$id) { + return $apidata['user']; + } else if (is_numeric($id)) { + return User::staticGet($id); + } else { + $nickname = common_canonical_nickname($id); + return User::staticGet('nickname', $nickname); + } + } + + function get_profile($id) { + if (is_numeric($id)) { + return Profile::staticGet($id); + } else { + $user = User::staticGet('nickname', $id); + if ($user) { + return $user->getProfile(); + } else { + return NULL; + } + } + } + + function source_link($source) { + $source_name = _($source); + switch ($source) { + case 'web': + case 'xmpp': + case 'mail': + case 'omb': + case 'api': + break; + default: + $ns = Notice_source::staticGet($source); + if ($ns) { + $source_name = '' . $ns->name . ''; + } + break; + } + return $source_name; + } + } \ No newline at end of file