. */ /** * @package OStatusPlugin * @author James Walker */ if (!defined('STATUSNET')) { exit(1); } class SalmonAction extends Action { var $user = null; var $xml = null; var $activity = null; function prepare($args) { parent::prepare($args); if ($_SERVER['REQUEST_METHOD'] != 'POST') { $this->clientError(_('This method requires a POST.')); } if ($_SERVER['CONTENT_TYPE'] != 'application/atom+xml') { $this->clientError(_('Salmon requires application/atom+xml')); } $id = $this->trimmed('id'); if (!$id) { $this->clientError(_('No ID.')); } $this->user = User::staticGet($id); if (empty($this->user)) { $this->clientError(_('No such user.')); } $xml = file_get_contents('php://input'); $dom = DOMDocument::loadXML($xml); // XXX: check that document element is Atom entry // XXX: check the signature $this->act = new Activity($dom->documentElement); return true; } /** * @fixme probably call Ostatus_profile::processFeed */ function handle($args) { common_log(LOG_INFO, 'Salmon: incoming post for user '. $this->user->id); // TODO : Insert new $xml -> notice code if (Event::handle('StartHandleSalmon', array($this->user, $this->activity))) { switch ($this->act->verb) { case ActivityVerb::POST: $this->handlePost(); break; case ActivityVerb::SHARE: $this->handleShare(); break; case ActivityVerb::FAVORITE: $this->handleFavorite(); break; case ActivityVerb::FOLLOW: case ActivityVerb::FRIEND: $this->handleFollow(); break; } Event::handle('EndHandleSalmon', array($this->user, $this->activity)); } } /** * @fixme probably call Ostatus_profile::processFeed */ function handlePost() { switch ($this->act->object->type) { case ActivityObject::ARTICLE: case ActivityObject::BLOGENTRY: case ActivityObject::NOTE: case ActivityObject::STATUS: case ActivityObject::COMMENT: break; default: throw new Exception("Can't handle that kind of post."); } $profile = $this->ensureProfile(); } /** * @fixme probably call Ostatus_profile::processFeed */ function handleFollow() { } /** * @fixme probably call Ostatus_profile::processFeed */ function handleFavorite() { } /** * @fixme probably call Ostatus_profile::processFeed */ function handleShare() { } function ensureProfile() { $actor = $this->act->actor; if (empty($actor->id)) { throw new Exception("Received a salmon slap from unidentified actor."); } $ostatusProfile = Ostatus_profile::ensureActorProfile($this->act); return $oprofile->localProfile(); } /** * @fixme anything new in here probably should be merged into Ostatus_profile::ensureActorProfile and friends */ function createProfile() { $actor = $this->act->actor; $profile = new Profile(); $profile->nickname = $this->nicknameFromURI($actor->id); if (empty($profile->nickname)) { $profile->nickname = common_nicknamize($actor->title); } $profile->fullname = $actor->title; $profile->bio = $actor->summary; // XXX: is that right? $profile->profileurl = $actor->link; // XXX: is that right? $profile->created = common_sql_now(); $id = $profile->insert(); if (empty($id)) { common_log_db_error($profile, 'INSERT', __FILE__); throw new Exception("Couldn't save new profile for $actor->id\n"); } // XXX: add avatars $op = new Ostatus_profile(); $op->profile_id = $id; $op->homeuri = $actor->id; $op->created = $profile->created; // XXX: determine feed URI from source or Webfinger or whatever $id = $op->insert(); if (empty($id)) { common_log_db_error($op, 'INSERT', __FILE__); throw new Exception("Couldn't save new ostatus profile for $actor->id\n"); } return $profile; } /** * @fixme should be merged into Ostatus_profile */ function nicknameFromURI($uri) { preg_match('/(\w+):/', $uri, $matches); $protocol = $matches[1]; switch ($protocol) { case 'acct': case 'mailto': if (preg_match("/^$protocol:(.*)?@.*\$/", $uri, $matches)) { return common_canonical_nickname($matches[1]); } return null; case 'http': return common_url_to_nickname($uri); break; default: return null; } } }