Merge pull request #8 from RedisGraph/index

Index

Author: gkorland

.gitignore

@@ -1,4 +1,6 @@
 /.settings/
 /node_modules/
 .project
-package-lock.json
+package-lock.json
+yarn.lock
+/examples/node_modules

.jshintrc

@@ -0,0 +1,15 @@
+{
+	"name": "redisgraph-example",
+	"version": "1.0.0",
+	"description": "Example using redisgraph.js",
+	"author": "RedisLabs",
+	"license": "BSD 3",
+	"repository": {
+		"type": "git",
+		"url": "git://github.com/redislabs/redisgraph.js.git"
+	},
+	"dependencies": {
+		"redisgraph.js": "^1.1.0"
+	},
+	"main": "redisGraphExample.js"
+}

examples/RedisGraphExample.js

@@ -0,0 +1,27 @@
+const RedisGraph = require("redisgraph.js").RedisGraph;
+
+let graph = new RedisGraph("social");
+
+graph
+	.query("CREATE (:person{name:'roi',age:32})")
+	.then(() => {
+		return graph.query("CREATE (:person{name:'amit',age:30})");
+	})
+	.then(() => {
+		return graph.query(
+			"MATCH (a:person), (b:person) WHERE (a.name = 'roi' AND b.name='amit') CREATE (a)-[:knows]->(a)"
+		);
+	})
+	.then(() => {
+		return graph.query("MATCH (a:person)-[:knows]->(:person) RETURN a");
+	})
+	.then(res => {
+		while (res.hasNext()) {
+			let record = res.next();
+			console.log(record.getString("a.name"));
+		}
+		console.log(res.getStatistics().queryExecutionTime());
+	})
+	.catch(err => {
+		console.log(err);
+	});

examples/package.json

@@ -0,0 +1,13 @@
+const Record = require("./src/record"),
+	RedisGraph = require("./src/redisGraph"),
+	ResultSet = require("./src/resultSet"),
+	Statistics = require("./src/statistics"),
+	Label = require("./label");
+
+module.exports = {
+	Record: Record,
+	RedisGraph: RedisGraph,
+	ResultSet: ResultSet,
+	Statistics: Statistics,
+	Label: Label
+};

examples/redisGraphExample.js

@@ -1,6 +1,6 @@
 {
 	"name": "redisgraph.js",
-	"version": "1.0.4",
+	"version": "1.1.0",
 	"description": "Connect to RedisGraph 1.0.0 and up from JavaScript",
 	"author": "RedisLabs",
 	"license": "BSD 3",
@@ -16,5 +16,6 @@
 	},
 	"scripts": {
 		"test": "mocha --exit"
-	}
+	},
+	"main": "index.js"
 }

index.js

@@ -0,0 +1,14 @@
+/**
+ * Different Statistics labels
+ */
+var Label = Object.freeze({
+	LABELS_ADDED: "Labels added",
+	NODES_CREATED: "Nodes created",
+	NODES_DELETED: "Nodes deleted",
+	RELATIONSHIPS_DELETED: "Relationships deleted",
+	PROPERTIES_SET: "Properties set",
+	RELATIONSHIPS_CREATED: "Relationships created",
+	QUERY_INTERNAL_EXECUTION_TIME: "Query internal execution time"
+});
+
+module.exports = Label;

package.json

@@ -1,16 +1,15 @@
 /**
  * Hold a query record
  */
-module.exports = class Record {
-	
-    constructor(header, values){
-    	this._header = header;
-    	this._values = values;
-    }
-    
+class Record {
+	constructor(header, values) {
+		this._header = header;
+		this._values = values;
+	}
+
 	getString(key) {
 		let index = key;
-		if(typeof key === "string"){
+		if (typeof key === "string") {
 			index = this._header.indexOf(key);
 		}
 		return this._values[index];
@@ -30,5 +29,7 @@ module.exports = class Record {
 
 	size() {
 		return this._header.length;
-	}	
-}
+	}
+}
+
+module.exports = Record;

src/label.js

@@ -1,50 +1,53 @@
-const redis = require('redis'),
-util = require('util'),
-ResultSet = require('./resultSet');
+const redis = require("redis"),
+	util = require("util"),
+	ResultSet = require("./resultSet");
 
 /**
  * RedisGraph client
  */
-module.exports = class RedisGraph {
-
+class RedisGraph {
 	/**
 	 * Creates a client to a specific graph running on the specific host/post
-	 * See: node_redis for more options on createClient 
+	 * See: node_redis for more options on createClient
 	 *
 	 * @param graphId the graph id
 	 * @param host Redis host or node_redis client
 	 * @param port Redis port
 	 * @param options node_redis options
 	 */
 	constructor(graphId, host, port, options) {
-		this._graphId = graphId;		
-		let client = (host instanceof redis.RedisClient) ? host : redis.createClient.apply(redis, [].slice.call(arguments,1)); 
+		this._graphId = graphId;
+		let client =
+			host instanceof redis.RedisClient
+				? host
+				: redis.createClient.apply(redis, [].slice.call(arguments, 1));
 		this._sendCommand = util.promisify(client.send_command).bind(client);
 	}
-	
+
 	/**
 	 * Execute a Cypher query
-	 * 
+	 *
 	 * @param query Cypher query
-	 * @return a result set 
+	 * @return a result set
 	 */
-	query(query) {		
-		return this._sendCommand('graph.QUERY',[this._graphId, query])
-		.then((res) => {
-			return new ResultSet(res);
-		});
+	query(query) {
+		return this._sendCommand("graph.QUERY", [this._graphId, query]).then(
+			res => {
+				return new ResultSet(res);
+			}
+		);
 	}
-	
-    /**
-     * Deletes the entire graph
-     * 
-     * @return delete running time statistics 
-     */
-    deleteGraph() {
-		return this._sendCommand('graph.DELETE',[this._graphId])
-		.then((res) => {
+
+	/**
+	 * Deletes the entire graph
+	 *
+	 * @return delete running time statistics
+	 */
+	deleteGraph() {
+		return this._sendCommand("graph.DELETE", [this._graphId]).then(res => {
 			return new ResultSet(res);
 		});
-    }
-   
-};
+	}
+}
+
+module.exports = RedisGraph;