New backend, new query

index.js

@@ -103,7 +103,8 @@ relations.define = function (name, structure) {
 relations.stores = {
   memory: require('./stores/memory'),
   mysql: require('./stores/mysql'),
-  redis: require('./stores/redis')
+  redis: require('./stores/redis'),
+  mongoose: require('./stores/mongoose_backend')
 };
 
 relations.use = function (store, options) {

package.json

@@ -5,7 +5,8 @@
   "main": "index.js",
   "dependencies": {
     "eventflow": "0.0.6",
-    "async": "~0.1.22"
+    "async": "~0.1.22",
+    "mongoose": "~3.8.1"
   },
   "devDependencies": {
     "mocha": "*",

parser.pegjs

@@ -5,6 +5,7 @@
 start
   = ret:(
   ObjectVerbRequest
+  / ObjectRoleRequest
   / RoleSubjectRequest
   / VerbSubjectRequest
   / RoleQuestion
@@ -103,6 +104,15 @@ ObjectVerbRequest "object verb request"
     }
   }
 
+ObjectRoleRequest "object role request"
+  = "what roles does "i subject:Token " have"i Preposition " " object:Token "?"? {
+    return {
+      type: "object-role-request",
+      subject: subject,
+      object: object
+    }
+  }
+
 Token "token"
   = NamedToken / UnnamedToken / Literal
 

stores/mongoose_backend.js

@@ -0,0 +1,167 @@
+/**
+ * @author Jan Zaloudek
+ * @date 27.10.13
+ * @time 16:38
+ * @filename
+ */
+
+var store = module.exports = require('eventflow')();
+var RelationModel = require('./mongoose_model.js');
+
+store.on('init', function (options, cb) {
+    cb();
+});
+
+store.on('declaration', function (cmd, cb) {
+    var relation = new RelationModel({
+        context: cmd.ctx.name,
+        subject: cmd.subject,
+        role: cmd.role,
+        object: cmd.object || ""
+    });
+
+    relation.save(function(err) {
+       if(err && err.code === 11000) return cb();
+
+       return cb(err);
+    });
+});
+
+store.on('revocation', function (cmd, cb) {
+    RelationModel.findOneAndRemove({
+        context: cmd.ctx.name,
+        subject: cmd.subject,
+        role: cmd.role,
+        object: cmd.object
+    }, cb);
+});
+
+store.on('verb-question', function (cmd, cb) {
+    RelationModel.findOne({
+        context: cmd.ctx.name,
+        subject: cmd.subject,
+        role: { $in: cmd.ctx.verbs[cmd.verb] },
+        $or: [{
+                object: cmd.object || "",
+            },
+            {
+                object: ''
+            }]
+    }, function(err, relation) {
+        if(err) return cb(err);
+
+        if(relation) {
+            return cb(null, true);
+        }
+
+        cb(null, false);
+    });
+});
+
+store.on('role-question', function (cmd, cb) {
+    RelationModel.findOne({
+        context: cmd.ctx.name,
+        subject: cmd.subject,
+        role: cmd.role,
+        $or: [{
+            object: cmd.object || "",
+        },
+            {
+                object: ''
+            }]
+    }, function(err, relation) {
+        if(err) {
+            return cb(err);
+        }
+
+        if(relation) {
+            return cb(null, true);
+        }
+
+        cb(null, false);
+    });
+});
+
+store.on('verb-request', function (cmd, cb) {
+    RelationModel.find({
+        context: cmd.ctx.name,
+        subject: cmd.subject,
+        role: { $in: cmd.ctx.verbs[cmd.verb] },
+        object: { $ne: '' }
+    }, 'object', function(err, relations) {
+        if(err) return cb(err);
+
+        cb(null, relations.map(function(relation) { return relation.object; }));
+    });
+});
+
+store.on('role-request', function (cmd, cb) {
+    RelationModel.find({
+        context: cmd.ctx.name,
+        subject: cmd.subject,
+        role: cmd.role,
+        object: { $ne: '' }
+    }, 'object', function(err, relations) {
+        if(err) return cb(err);
+
+        cb(null, relations.map(function(relation) { return relation.object; }));
+    });
+});
+
+store.on('verb-subject-request', function (cmd, cb) {
+    RelationModel.find({
+        context: cmd.ctx.name,
+        object: cmd.object,
+        role: { $in: cmd.ctx.verbs[cmd.verb] }
+    }, 'subject', function(err, relations) {
+        if(err) return cb(err);
+
+        cb(null, relations.map(function(relation) { return relation.subject; }));
+    });
+});
+
+store.on('role-subject-request', function (cmd, cb) {
+    RelationModel.find({
+        context: cmd.ctx.name,
+        object: cmd.object,
+        role: cmd.role
+    }, 'subject', function(err, relations) {
+        if(err) return cb(err);
+
+        cb(null, relations.map(function(relation) { return relation.subject; }));
+    });
+});
+
+store.on('object-verb-request', function (cmd, cb) {
+    RelationModel.find({
+        context: cmd.ctx.name,
+        object: cmd.object,
+        subject: cmd.subject
+    }, 'role', function(err, relations) {
+        if(err) return cb(err);
+
+        cb(null, relations.reduce(function (verbs, row) {
+            return verbs.concat( cmd.ctx.roles[row.role] || [] );
+        }, []));
+    });
+});
+
+store.on('object-role-request', function(cmd, cb) {
+    RelationModel.find({
+        context: cmd.ctx.name,
+        object: cmd.object,
+        subject: cmd.subject
+    }, 'role', function(err, relations) {
+        if(err) return cb(err);
+
+        var roles = relations.map(function (row) {
+            return ( row.role );
+        });
+
+        cb(null, roles);
+    });
+});
+
+store.on('reset', function (cb) {
+    RelationModel.remove({}, cb);
+});

stores/mongoose_model.js

@@ -0,0 +1,31 @@
+/**
+ * @author Jan Zaloudek
+ * @date 28.10.13
+ * @time 0:25
+ * @filename
+ */
+
+var mongoose = require('mongoose');
+var Schema = mongoose.Schema;
+
+
+//client.query("CREATE TABLE IF NOT EXISTS `relations` ("
+//    + "`context` VARCHAR(255) NOT NULL,"
+//    + "`subject` VARCHAR(255) NOT NULL,"
+//    + "`role` VARCHAR(255) NOT NULL,"
+//    + "`object` VARCHAR(255) NOT NULL,"
+//    + "PRIMARY KEY (`context`, `subject`, `role`, `object`),"
+//    + "INDEX object (`context`, `role`, `object`)"
+//    + ") ENGINE=InnoDB", cb);
+
+var RelationSchema = new Schema({
+    context: String,
+    subject: String,
+    role: String,
+    object: String
+});
+
+RelationSchema.index({ context: 1, subject: 1, role: 1, object: 1 }, { unique: true });
+RelationSchema.index({ context: 1, role: 1, object: 1 });
+
+module.exports = mongoose.model('Relation', RelationSchema);