gistfile1.js

queried: function(rcp) {
      switch(rpc.getMethod()) {
        case 'PING':
          rpc.resolve();
          break;
        case 'FIND_NODE':
          rpc.resolve(
            this.routingTable.getClosePeers(
              rpc.getTarget(),
              BETA,
              rpc.getQuerying()),
            false);
          break;
        case 'APPEND':
          var key = SHA1(rpc.getRessource());
          this.store
              .retrieve(key)
              .pipe(function(value) {
                if(!Array.isArray(value))
                  return new Error('not an array');
                value.push(rpc.getData());
                return value;
              }, function() {
                //go for resolve..
                return [rpc.getData()];
              })
              .pipe(function(value) {
                return this.store.save(key, value, -1)
              }, this)
              .then(rpc.resolve, rcp.reject, rpc);
          break;
      }
    }