November Perfect Moustache


    0.9.2-13 • Public • Published


    Build real-time collaborative DApps on top of IPFS

    Build Status Greenkeeper badge made by Protocol Labs



    $ npm install peer-star-app


    const PeerStar = require('peer-star-app')


    Create app

    const app = PeerStar('app name', options)
    app.on('error', (err) => {
      console.error('error in app:', err)

    Options (are not required):

    • ipfs: object with:
      • repo: IPFS repo path or repo object
      • swarm: ipfs swarm addresses (array of strings)
      • bootstrap: IPFS Bootstrap nodes (array of multiaddresses)
      • relay: an (optional) object containing the following attributes:
        • apiAddr: the multiaddress for the API server of the relay
        • relayWSAddr: the multiaddress for the relay websocket server address
    • samplingIntervalMS: (defaults to 1000): membership gossip frequency heuristic sampling interval
    • targetGlobalMembershipGossipFrequencyMS: (defaults to 1000): target global membership gossip frequency, in ms.
    • urgencyFrequencyMultiplier: (defaults to 10): urgency multiplier when someone is wrong about membership
    • transport: optional object containing:
      • maxThrottleDelayMS: the maximum delay betweeen discovering a new peer and querying it to see whether they're interested in the app.

    Start app

    await app.start()

    js-IPFS node

    A peer-star app comes with a js-ipfs node. You can access it through app.ipfs. Example:


    Guess peer count

    app.peerCountGuess() // returns integer Number >= 0


    Keys can be used to collaborate. If provided, they authenticate changes to the collaboration and encrypts them for transmission and storage. You can either create new keys or parse them from a string.

    await Keys.generate()

    const Keys = require('peer-star-app').keys
    const keys = await Keys.generate()


    Encode keys into a URI-acceptable string:

    const Keys = require('peer-star-app').keys
    const keys = await Keys.generate()
    const string = Keys.uriEncode(keys)


    Encode the read-only key into a URI-acceptable string:

    const Keys = require('peer-star-app').keys
    const keys = await Keys.generate()
    const string = Keys.uriEncodeReadOnly(keys)

    await Keys.uriDecode

    Decode keys from a string:

    const Keys = require('peer-star-app').keys
    const keys = await Keys.generate()
    const string = Keys.uriEncode(keys)
    const decodedKeys = await Keys.uriDecode(string)

    Read-only keys

    You can distribute a read-only key by using PeerStar.keys.uriEncodeReadOnly(keys):

    const Keys = require('peer-star-app').keys
    const keys = await Keys.generate()
    const string = Keys.uriEncodeReadOnly(keys)

    Generate symmetrical key

    const Keys = require('peer-star-app').keys
    // options are optional. defaults to:
    const options = {
      keyLength: 32,
      ivLength: 16
    const keys = await Keys.generateSymmetrical(options)
    key.raw // contains raw key (buffer)
    key.key // contains AES key

    Returns (asynchronously) a key of type AES, as defined in libp2p-crypto.

    Create collaboration

    const collaboration = await app.collaborate(collaborationName, type, options)
    // stop collaboration
    await collaboration.stop()


    • collaborationName: string: should uniquely identify this collaboration in the whole world
    • type: a string, identifying which type of CRDT should be used. Use this reference table in the delta-crdts package.
    • options: object, not required. Can contain the keys:
      • keys: keys, generated or parsed from URL. See keys section
      • maxDeltaRetention: number: maximum number of retained deltas. Defaults to 1000.
      • deltaTrimTimeoutMS: number: after a delta was added to the store, the time it waits before trying to trim the deltas.
      • debounceResetConnectionsMS: (defaults to 1000): debounce membership changes before resetting connections.

    Create your own collaboration type

    You can create your own collaboration type by registering it:

    // useless type here:
    const Zero = (id) => ({
      initial: () => 0,
      join: (s1, s2) => 0,
      value: (state) => state
    PeerStar.collaborationTypes.define('zero', Zero)

    Peer count estimate

    Returns estimate of peers in app.



    You can create sub-collaborations to a given "root" collaboration, with it's separate CRDT type, but that is causally consistent with the root CRDT. Here's how:

    const subCollaboration = await collaboration.sub('name', 'type')

    A sub-collaboration has the same API as a collaboration.

    Collaboration gossip

    You can have collaboration-level private gossip like this:

    const gossip = await collaboration.gossip('gossip name')
    gossip.on('message', (message, fromPeer) => {
      console.log('got message from peer ${fromPeer}: ${JSON.stringify(message)}')
    const message = ['any', 'JSON', 'object']

    Collaboration stats

    You can observe some collaboration traffic and topology statistics by doing:

    collaboration.stats.on('peer updated', (peerId, stats) => {
      console.log('peer %s updated its stats to:', peerId, stats)

    The stats object looks something like this:

      connections: {
        inbound: new Set(<peerId>),
        outbound: new Set(<peerId>)
      traffic: {
        total: {
          in: <number>,
          out: <number>
        perPeer: new Map(
          <peerId => {
            in: <number>,
            out: <number>
      messages: {
        total: {
          in: <number>,
          out: <number>
        perPeer: new Map(
          <peerId => {
            in: <number>,
            out: <number>

    App Events

    app.emit('error', err)

    app.emit('peer connected', (peerInfo) => {})

    When a peer connects.

    app.emit('outbound peer connected', (peerInfo) => {})

    When a push connection is created.

    app.emit('inbound peer connected', (peerInfo) => {})

    When a pull connection is created.

    app.emit('peer disconnected', (peerInfo) => {})

    When a peer disconnects.

    app.emit('outbound peer disconnected', (peerInfo) => {})

    When a push connection ends.

    app.emit('inbound peer disconnected', (peerInfo) => {})

    When a pull connection ends.



    Returns the peers of the collaboration, a Set of peer ids (string).

    Array.from(collaboration.peers()).forEach((peer) => {
      console.log('member peer: %s', peer)


    Returns the number of peers this peer is pushing data to.


    Returns the number of peers this peer is pulling data from.

    The name of the collaboration (String).

    Convenience reference to the app object.


    "membership changed" (peers: Set<peer id (String)>)

    collaboration.on('membership changed', (peers) => {
      for (peer of peers) {
        console.log('member peer: %s', peer)

    "state changed"

    Emitted every time the state changes. Has one argument, a boolean, saying true if and only if the change came from this peer. This is emitted immediately after a change is applied on the CRDT state.

    collaboration.on('state changed', (fromSelf) => {
      console.log('state changed. New collaboration value is: %j', collaboration.shared.value())

    NOTE: When receiving remote updates, this event may fire many times per second. You may want to use a debounce or a throttle mechanism when handling this event. If you do that, beware that the state in your UI may be out of sync with the state of the CRDT.


    When the collaboration is stopped locally.

    collaboration.once('stopped', () => {
      console.log('collaboration %s stopped',


    The shared data in this collaboration.


    Returns the CRDT view value.

    shared mutators

    Each shared document has document-specific mutators. See the delta-crdts documentation for these.


    collaboration.shared.push('some element')

    Stop collaboration

    await collaboration.stop()

    Stop app

    await app.stop()

    IPFS Circuit Relay support

    Peer-star-app supports using a circuit relay peer. For that you need to set up a go-ipfs node with circuit relay enabled. On your peer-star-app options, you can then pass in options.ipfs.relay with an object with the following attributes:

    • relayWSAddr: the multiaddress for the websocket server of the relay server
    • apiAddr: the multiaddress for the relay server API address (which we need for polling the known peers)


    You can pin collaborations for peer-* apps without delegating keys. To install a pinner you can:

    $ npm install -g peer-star-app
    $ pinner "app name" ["swarm address"]

    Run example app

    Clone this repo.

    $ cd peer-star-app
    $ cd examples/react-app
    $ npm install

    In a different window, on the same dir, start the rendezvous server:

    $ npm run start:rv

    In a different window, on the same dir, run the app server:

    $ npm start

    Open http://localhost:3000 and test the app.


    Clone this repo and run:

    $ npm install
    $ npm test


    You can activate the debugging logs by manipulating the DEBUG environment variable. Example:

    $ DEBUG=peer-star:* npm test

    For file-specific DEBUG values, see the source code and look for usages of the debug package.


    Peer-star app and the IPFS implementation in JavaScript is a work in progress. As such, there's a few things you can do right now to help out:

    • Check out existing issues. This would be especially useful for modules in active development. Some knowledge of IPFS may be required, as well as the infrastructure behind it - for instance, you may need to read up on p2p and more complex operations like muxing to be able to help technically.
    • Perform code reviews. More eyes will help (a) speed the project along, (b) ensure quality, and (c) reduce possible future bugs.
    • Add tests. There can never be enough tests.

    Want to hack on peer-star-app?




    npm i @jimpick/peer-star-app

    DownloadsWeekly Downloads






    Unpacked Size

    294 kB

    Total Files


    Last publish


    • jimpick