Redisfire - realtime memory DB Service.

Let's make Firebase features using Express, Socket.io, Redis and other powerful opensources.

Redisfire is not related with Firebase. But Redisfire provides very similar features like Firebase.

Features

RESTful apis
Realtime notifications for CURD actions
JSON import/export
Schema free
Express.js simple route.

Installation

# 1. install & start Redis
# 2. install Redisfire
$ npm install redisfire

if redis server is run with "requirepass" or use other options for redis, add "redis-client" connfig option to "redisfire-conf.json"

$ cat conf/redisfire-conf.json
{
    "projects": [
        {
            "name": "theverge",
            "description": "http://www.theverge.com RSS sample data"
        },
        {
            "name": "redisfire-test",
            "description": "redisfire Mocha test project"
        }
    ],
    "redis-client": {
        "host": "127.0.0.1",
        "port": "6379",
        "auth_pass": "your password"
    }
}

CLI

the CLI command real path is 'node_modules/.bin/redisfire'

redisfire - manage server process

# Examples:
$ ./node_modules/.bin/redisfire --help  # show help
$ ./node_modules/.bin/redisfire start -p 10001 # start Redisfire

redisfire-import - Import JSON file to Redisfire

# Examples:
$ ./node_modules/.bin/redisfire-import --help  # show help
$ ./node_modules/.bin/redisfire-import test.json testProject  # import test.json to testProject
// after import, edit redisfire-conf.json
// and check http://localhost:3000/rest/testProject

# if you want to update redisfire-conf.json directly, use -s --save option
$ redisfire-import foo.json foo -s -d "foo project"

REST

GET

# get all datas
curl http://localhost:3000/rest/theverge;

# get single item
curl http://localhost:3000/rest/theverge/feed/entry/0
curl http://localhost:3000/rest/theverge/feed/entry/0/content

POST - create

# get single item
curl http://localhost:3000/rest/theverge/feed/entry/0/content

# create new attribute to ".../entry/0/content/test";
curl -i \
  -H "Content-Type: application/json" \
  -X POST -d '{"foo":"bar"}' \
  http://localhost:3000/rest/theverge/feed/entry/0/content/test

# get result again
curl http://localhost:3000/rest/theverge/feed/entry/0/content

NOTE: if the request key exists, the POST request is delegated to PUT method below.

PUT - update (& delete)

# get single item
curl http://localhost:3000/rest/theverge/feed/entry/0/content

# replace existing one to new data
curl -i \
  -H "Content-Type: application/json" \
  -X PUT -d '{"foo":"bar"}' \
  http://localhost:3000/rest/theverge/feed/entry/0/content

# get result again
curl http://localhost:3000/rest/theverge/feed/entry/0/content

DELETE - delete

# get single item
curl http://localhost:3000/rest/theverge/feed/entry/0/content

# replay existing one to new data
curl -i \
  -H "Content-Type: application/json" \
  -X DELETE \
  http://localhost:3000/rest/theverge/feed/entry/0

# get result again
curl http://localhost:3000/rest/theverge/feed/entry/0

CURD realtime notifications

It's developed with socket.io.

Client side - demo:

http://localhost:3000/

Server side

var redisfire = require('redisfire');

var socketHost = 'http://localhost:/redis';
socket_client = require('socket.io-client')(socketHost);

var reqKey = new Date().getTime();
socket_client.emit('GET', (key || 'redisfire-test/feed/entry/2/author/name'), {key:, reqKey, foo:'bar'});
// "redsfire" event is fired as REDIS MONITOR events.
socket_client.on('redisfire', function(eventType, socket_res, params){
  if (eventType === 'GET' && params.key === reqKey) {
    console.log(socket_res);
  }
}, function(err) {
  console.log(err);
});

CURD over socket.io

open http://localhost:3000/
try Javascript code on the developer console in Browser.

// GET
socket.emit('GET', 'theverge/feed/entry/2/author/name', {foo:'bar'});
// CREATE (POST)
socket.emit('POST', 'theverge/feed/entry/2/author/name2', {hello: 'WORLD'}, {foo:'bar'});
 // DELETE
socket.emit('DELETE', 'theverge/feed/entry/2/author/name2', {foo:'bar'});
// PUT
socket.emit('PUT', 'theverge/feed/entry/2/author', {name: 'Jongsoon'}, {foo:'bar'});

Get socket.io instance

var redisfire = require('redisfire');

redisfire.getIO().then(function(_io) {
  var foo_namespace = _io.of('/redis_foo');

  console.log('FOO SOCKET /redis_foo initialized');

  foo_namespace.on('connection', function(socket){
    console.log('FOO someone connected to redis_foo namespace');
    socket.emit('hi', {message: 'emulate new socket.io namespace'});
  });

  // emulate socket.io client
  var client = require('socket.io-client')('http://localhost:3000/redis_foo');
  client.on('connect', function(){
    console.log('FOO SOCKET redis_foo connected to socketHost:', socketHost);
  });

  client.on('hi', function(data) {
    console.log('FOO namespace hi event: ' + JSON.stringify(data));
  });
});

Authentication

to enable Authentication for some project, add auth options to redisfire-conf.json

{
  "projects": [
    {
      "name": "redisfire-test-auth",
      "description": "redisfire Mocha test project for Authentication",
      "auth": "redisfire-test-auth-member", // hidden project for Authentication for this Project
      "auth_key": "redisfire-test-auth-key",  // cookie name for check auth
      "auth_secure": false // encrypt auth value or not
    }
  ],
  "CRYPTO_KEY": "test-key"  // encrypt/decrypt crypto key
}

If auth is enabled, redisfire check hidden Authentication project for each request. Hidden Authentication is just key / value pair and the key is exists, redisfire regards valid request.

redisfire.setUser(projectName, userInfo) - Add user to auth project

Add user for specific project - user object must have "key"

exports.auth_test_setUser = function(req, res) {
  var user = {
    key: 'member_12345',  // must have this key
    info: {foo: 'bar'},
    other_info: "blablabla"
  };

  redisfire.setUser('redisfire-test-auth', user).then(function(o) {
    res.send(o);

    // if user added successfully, set cookie for the login.
    // if auth_secure is true, the auth cookie value must encrypted.
    res.cookie(conf.auth_key, redisfire.encrypt(user.key), { domain: '.redisfire.com', path: '/' });
    res.redirect('/');
  });
}

redisfire.getUser(projectName) - get userinfo for login-ed user

user for specific project - user object must have "key"

exports.auth_getUser = function(req, res) {
  req.cookies['redisfire-test-auth-key'] = 'member_12345';
  redisfire.getUser('redisfire-test-auth', req).then(function(o) {
    res.send(o);
  });
}

redisfire.encrtpt(text) - encrypt text

redisfire crypto function use 'aes-256-cbc'.

var cipherText = redisfire.encrypt('hihi');
console.log(cipherText);
// 2fa23612e09e3c46be74607353233769

redisfire.decrypt(cipherText) - decrypt text