Ninja Pirate Marksman

    activity-engine

    0.0.2-alpha • Public • Published

    node-activity-engine

    WARNING: This project is still in alpha, use with caution.

    A nimble and follower aware fan out activity stream framework that uses Redis as backend.

    Why?

    Activity streams are a major part of how people consume information on the web today. Twitter's timeline is an activity stream where the activities are tweets and they are ordered by time, Facebook's news feed is an activity stream ordered by EdgeRank. This framework is for managing such activity streams abstracting away they nitty-gritty of routing activities to the right stream and ordering them.

    This framework was inspired by the talk "Timelines @ Twitter" given by Arya Asemanfar.

    Example

    https://github.com/olahol/node-activity-engine/blob/master/examples/twitter.coffee

    Concepts

    Activity

    A unique identifier, should usually be a key pointing to a database row (for example a primary key in a SQL table).

    Activity stream

    A list of activities ordered by their score (default score is time).

    Entity

    Something that performs or receives activities, a user, a group, a tag, an image etc. All entities have two activity streams, a sent activity stream which consists of its own activities and an inbox activity stream which consist of the activities of the entities it's following. Like an activity an entity should usually be a key pointing to a database object, show that metadata can be retrieved.

    Following

    An entity can follow another entity, which means it will be routed activies from that entitiy.

    API

    Engine.sent(entity, offset, take, cb(err, activities))

    Engine.inbox(entity, offset, take, cb(err, activities))


    Engine.post(entity, activity, cb(err))

    Engine.put(entity, activity, cb(err))

    Engine.spread(entity, activity, cb(err))


    Engine.unpost(entity, activity, cb(err))

    Engine.unput(entity, activity, cb(err))

    Engine.unspread(entity, activity, cb(err))


    Engine.follow(from, to, cb(err))

    Engine.subscribe(from, to, cb(err))

    Engine.sprinkle(from, to, cb(err))


    Engine.unfollow(from, to, cb(err))

    Engine.unsubscribe(from, to, cb(err))

    Engine.nub(from, to, cb(err))

    Keywords

    none

    Install

    npm i activity-engine

    DownloadsWeekly Downloads

    0

    Version

    0.0.2-alpha

    License

    none

    Last publish

    Collaborators

    • olahol