Any-Db-Client

Lets you subscribe to custom Meteor publications of any database or data source via ccorcos:any-db outside of the Meteor client environment. Written in ES6, compatible with React Native.

Check out this article.

Getting Started

Simply add the two packages to your project:

meteor add ccorcos:any-db   // on your Meteor server
npm install any-db-client   // in your client folder

API

On the client, create a new DDP connection using node-ddp-client and initalize AnyDb:

var DDPClient = require('ddp-client');
var AnyDb = require('any-db-client');

var ddpClient = new DDPClient({
  url: 'ws://localhost:3000/websocket',
  maintainCollections: false    // so that only AnyDb manages our data
});

AnyDb.initialize({
  ddpClient: ddpClient,
  debug: true   // optional, for extra logging
});

// using a subset of ES7...
(async function() {
  try {
    await ddpClient.connect();
    var UsersSub = await AnyDb.subscribe('allUsers', []);
    console.log('UsersSub ready', UsersSub);
  
    UsersSub.onChange((data) => {
      // data is the entire subscription's dataset
      console.log("new UsersSub data:", data);
    });

    UsersSub.stop();
  } catch (err) {
    // handle errors
  }
})();

On the server, set up your publications as you would with ccorcos:any-db (this example uses ostrio:neo4jdriver, but you can use any Fiber-wrapped database library):

var db = new Neo4jDB('http://localhost:7474');

AnyDb.publish('allUsers', function() {
  var allUsersQuery = db.query('MATCH (users:User) RETURN users;').fetch();
  return Array.prototype.slice.call(allUsersQuery).map(function(node) {
    return node.users;
  });
});

var userCounter = 0;
Meteor.methods('addUser', function() {
  var _id = Random.id();
  var user = db.query('CREATE (user:User {props}) RETURN user;', {
    props: {
      _id: _id,
      username: 'testUser-' + _id
    }
  }).fetch();
  AnyDb.refresh('allUsers', function() { return true; });
  return user;
});

Meteor.methods('removeAllUsers', function() {
  var users = db.query('MATCH nodes DELETE nodes;').fetch();
  AnyDb.refresh('allUsers', function() { return true; });
  return users;
});