This is an activity stream server and client. It's intended to implement a RESTful service to create, publish, (un)subscribe activity streams (according to the "JSON Activity Streams 1.0"1).
A Stream contains multiple Activities. Those Activities are posted by Objects. An Object can subscribe/unsubscribe to/from multiple Streams. The Object can pull the most recent Activities (from the Streams he subscribed to) by fetching his Feed.
A Stream can be created with auto_subscribe attribute, which marks it as subscribed by all Objects. Objects are still able to unsubscribe these Streams.
Creating a new Client
The endpoint for the client is here:
$client = new AsClient('http://localhost/server/pub/index.php/');
Create/Open an Application
Now you have to create your application:
$application = $client->createApplication('my_app');
You should store the credentials for this application somewhere. You can
recieve the id by using
$application->getId() and the secret by using
If you already have id and secret, you can get the application by using the credentials.
$application = $client->getApplicationByIdAndSecret($id, $secret);
Create/Open a Stream
To create a new stream, choose if you want to make it public or private. A public stream will automatically be subscribed by all actors.
// every actor subscribes this stream! $public_stream = $application->createStream("public_stream"); // actors have to subscribe to this stream manually! $private_stream = $application->createStream("private_stream", array("auto_subscribe" => 0));
You can fetch a stream by id, if you created the stream earlier:
$public_stream = $application->getStreamById("public_stream");
Subscribe/Unsubscribe to/from a Stream
To create a new reader or writer for the stream, you have to create an object.
$actor1 = $application->createObject('user1');
Now you can write with that object to any stream (it does not matter if the object subscribed to this stream or not).
$public_stream->createActivity(array('title' => 'I posted a (public) new link', 'verb' => 'post'), $actor1); $private_stream->createActivity(array('title' => 'I posted a (private) new link', 'verb' => 'post'), $actor1);
For now the object would only get the data from the public_stream, so you have to subscribe to the private_stream to receive the activities from this stream, too.
Finally we can fetch the most recent posts of an actor (will be 2!).
$activities = $client->getFeedForObject($actor1, 0, 20); assert(count($activities) == 2);
Starting with 1.2.0, you can add a
$before_activity to the gedFeedForObject-Method:
$activities = $client->getFeedForObject($actor1, 0, 20, $before_activity); assert(count($activities) == 2);
This will return only those activities, which have been posted before a the
$before_activity was created. Useful if you want to implement a load more button.
Ondemand object and stream creation
In case of e.g. user activity streams, you may want to create those streams on demand. To avoid checking if the stream
exists, before creating it on demand, you can use the
AsApplication#recreateStream and the
Best practice for creation of objects in those streams:
$actor1 = $application->recreateObject('user1'); $user_stream = $application->recreateStream('user1'); $user_stream->createActivity(array('title' => 'I posted a new link in my personal stream', 'verb' => 'post'), $actor1);
Updating events with recreateObject
If you just want to push the latest object into a stream and don't want to check if the object already exists or not, you
can use the
// will create or update the guest-object, so that it has only set the foo=bar property $guest = $application->recreateObject('guest', array('foo' => 'bar')); // post an activity with that object $media_comments_stream->createActivity(array('title' => 'I posted a link!', 'verb' => 'post'), $guest);
Updating streams with recreateStream
If you just want to push the latest version of a stream and don't want to check if the stream already exists or not, you
can use the
// will create or update the public_stream-stream, so that it has only set the name='The Public Stream' property $public_stream = $application->recreateStream('public_stream', array('name' => 'The Public Stream'));
- Implement the paper "Feeding Frenzy: Selectively Materializing Users’ Event Feeds" from http://research.yahoo.com/pub/3203
- Add database structure and way to create the database from scratch
- 1.2.0 (2013/05/28)
- added parameter
AsObject#getFeed($offset = 0, $limit = 20, AsActivity $before_activity = null)and to
AsApplication#getFeedForObject(AsObject $object, $offset = 0, $limit = 20, AsActivity $before_activity)(see #4)
- 1.1.0 (2013/02/04)
- added possibility to set the activity id when creating the activity
- added new methods on
AsActivity(getTitle, getVerb, getId, getPublished, getUrl)
- remove all activites as soon as an object was removed
update-Link and auto_subscribe:bool property to stream resources
- 1.0.0 (2013/01/13)
- Initial release
This work is copyright by DracoBlue (http://dracoblue.net) and licensed under the terms of MIT License.