* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
+if (!defined('GNUSOCIAL')) { exit(1); }
+
/**
* @package OStatusPlugin
* @author James Walker <james@status.net>
*/
-
-if (!defined('STATUSNET')) {
- exit(1);
-}
-
class GroupsalmonAction extends SalmonAction
{
var $group = null;
- function prepare($args)
+ protected function prepare(array $args=array())
{
parent::prepare($args);
$id = $this->trimmed('id');
if (!$id) {
- $this->clientError(_('No ID.'));
+ // TRANS: Client error.
+ $this->clientError(_m('No ID.'));
}
- $this->group = User_group::staticGet('id', $id);
+ $this->group = User_group::getKV('id', $id);
- if (empty($this->group)) {
- $this->clientError(_('No such group.'));
+ if (!$this->group instanceof User_group) {
+ // TRANS: Client error.
+ $this->clientError(_m('No such group.'));
+ }
+
+
+ $this->target = $this->group;
+
+ $remote_group = Ostatus_profile::getKV('group_id', $id);
+ if ($remote_group instanceof Ostatus_profile) {
+ // TRANS: Client error.
+ $this->clientError(_m('Cannot accept remote posts for a remote group.'));
}
return true;
/**
* We've gotten a post event on the Salmon backchannel, probably a reply.
*/
-
function handlePost()
{
- switch ($this->act->object->type) {
+ // @fixme process all objects?
+ switch ($this->activity->objects[0]->type) {
case ActivityObject::ARTICLE:
case ActivityObject::BLOGENTRY:
case ActivityObject::NOTE:
case ActivityObject::COMMENT:
break;
default:
- throw new ClientException("Can't handle that kind of post.");
+ // TRANS: Client exception.
+ throw new ClientException('Cannot handle that kind of post.');
}
// Notice must be to the attention of this group
-
- $context = $this->act->context;
-
- if (empty($context->attention)) {
+ if (empty($this->activity->context->attention)) {
+ // TRANS: Client exception.
throw new ClientException("Not to the attention of anyone.");
} else {
$uri = common_local_url('groupbyid', array('id' => $this->group->id));
- if (!in_array($context->attention, $uri)) {
+
+ if (!array_key_exists($uri, $this->activity->context->attention)) {
+ // TRANS: Client exception.
throw new ClientException("Not to the attention of this group.");
}
}
- $profile = $this->ensureProfile();
- // @fixme save the post
+ try {
+ $this->saveNotice();
+ } catch (AlreadyFulfilledException $e) {
+ return;
+ }
}
/**
* Save a subscription relationship for them.
*/
+ /**
+ * Postel's law: consider a "follow" notification as a "join".
+ */
function handleFollow()
{
- $this->handleJoin(); // ???
+ $this->handleJoin();
}
+ /**
+ * Postel's law: consider an "unfollow" notification as a "leave".
+ */
function handleUnfollow()
{
+ $this->handleLeave();
}
/**
* A remote user joined our group.
+ * @fixme move permission checks and event call into common code,
+ * currently we're doing the main logic in joingroup action
+ * and so have to repeat it here.
*/
-
function handleJoin()
{
+ if ($this->oprofile->isGroup()) {
+ // TRANS: Client error.
+ $this->clientError(_m('Groups cannot join groups.'));
+ }
+
+ common_log(LOG_INFO, sprintf('Remote profile %s joining local group %s', $this->oprofile->getUri(), $this->group->getNickname()));
+
+ if ($this->actor->isMember($this->group)) {
+ // Already a member; we'll take it silently to aid in resolving
+ // inconsistencies on the other side.
+ return true;
+ }
+
+ if (Group_block::isBlocked($this->group, $this->actor)) {
+ // TRANS: Client error displayed when trying to join a group the user is blocked from by a group admin.
+ $this->clientError(_m('You have been blocked from that group by the admin.'), 403);
+ }
+
+ try {
+ $this->actor->joinGroup($this->group);
+ } catch (Exception $e) {
+ // TRANS: Server error. %1$s is a profile URI, %2$s is a group nickname.
+ $this->serverError(sprintf(_m('Could not join remote user %1$s to group %2$s.'),
+ $this->oprofile->getUri(), $this->group->getNickname()));
+ }
}
+ /**
+ * A remote user left our group.
+ */
+ function handleLeave()
+ {
+ if ($this->oprofile->isGroup()) {
+ // TRANS: Client error displayed when trying to have a group join another group.
+ throw new AlreadyFulfilledException(_m('Groups cannot be members of groups'));
+ }
+
+ common_log(LOG_INFO, sprintf('Remote profile %s leaving local group %s', $this->oprofile->getUri(), $this->group->getNickname()));
+
+ try {
+ $this->actor->leaveGroup($this->group);
+ } catch (Exception $e) {
+ // TRANS: Server error. %1$s is a profile URI, %2$s is a group nickname.
+ $this->serverError(sprintf(_m('Could not remove remote user %1$s from group %2$s.'),
+ $this->oprofile->getUri(), $this->group->getNickname()));
+ }
+ }
}