fix popByte undefined

Author: apb2006

README.md

@@ -1,7 +1,7 @@
 # basex - A BaseX client for node.js  
 ===========================
 
-This is BaseX client for Node.js. It is work in progress. 
+This is BaseX client for Node.js. It is work in progress. It uses the client interface via a socket connection to the BaseX server.
 
 [BaseX](http://basex.org/) is a very light-weight, high-performance and scalable
  XML Database engine and XPath/XQuery 3.0 Processor, 
@@ -37,7 +37,7 @@ Once BaseX is installed and the BaseX server is running, test it.
 ## Installing BaseX
 1. Java is required
 1. [Download](http://basex.org/products/download/all-downloads/) and install BaseX
-(tested against version 7.5)
+(tested against version 7.6)
 1. Run `basexserver -S`
 
 ## API specification

changelog.md

@@ -1,3 +1,7 @@
+## v0.6.2 - 2013-07-13
+- fix query array result timing issue (#10)
+- fix session.create
+
 ## v0.6.1 - 2013-02-17
 - fix authorization bug (#8)
 

examples/Example.js

@@ -3,7 +3,7 @@
  * This example shows how database commands can be executed.
  */
 var basex  = require("../index");
-var client = new basex.Session();
+var client = new basex.Session("127.0.0.1", 1984, "admin", "admin");
 basex.debug_mode = false;
 function print(err, reply) {
 	if (err) {

examples/issue10.js

@@ -0,0 +1,19 @@
+/*
+ * This example shows how new databases can be created.
+ *
+ */
+var basex = require("../index");
+var log = require("../debug");
+basex.debug_mode = true;
+// create session
+var client = new basex.Session("localhost", 1984, "admin", "admin");
+  
+// create new database
+client.execute("create database gumby", log.print);
+client.add("people.xml","<people><person>Gumby\nman</person><something>else</something><person>Pokey\nhorse</person></people>",log.print);
+// run query on database
+  
+var query = client.query("//bad");
+query.results(log.print);
+// close session
+client.close();

index.js

@@ -199,7 +199,7 @@ var Session = function(host, port, username, password) {
 	};
 	// Creates a database from an input stream:
 	this.create = function(name, input, callback) {
-		self._dbop("\x08" ,path , input,callback)
+		self._dbop("\x08" ,name , input,callback)
 	};
 	// Adds a document to the current database from an input stream:
 	this.add = function(path, input, callback) {
@@ -213,6 +213,7 @@ var Session = function(host, port, username, password) {
 	this.store = function(path, input, callback) {
 		self._dbop("\x0D" ,path , input,callback)
 	};
+	//@TODO allow input to be stream, currently just string
 	this._dbop=function(op,path, input, callback) {
 		self.send_command({
 			send : op + path + "\0" + input+"\0",

lib/parser2.js

@@ -55,10 +55,13 @@ var parse = function(stream) {
                 	self.data.unshift(s.substring(1))
                 	return {data:s[0]}
 		        }
-		}else{
-			var s=self.buffer;
-			self.buffer=s.substring(1)
-			return {data:s[0]};			
+	    }else if (self.buffer.length) {
+	        var s = self.buffer;
+	        self.buffer = s.substring(1)
+	        return {data: s[0]};
+	    }
+	    else {
+	        return null;
 	    }	
 	};
 };

package.json

@@ -1,5 +1,5 @@
 {   "name" : "basex",
-    "version" : "0.6.1",
+    "version" : "0.6.2",
     "description" : "A BaseX (XML database) client library",
     "keywords": ["xml", "xquery", "xslt", "search", "database" ],
     "author": "Andy Bunce ",

someFile.txt

@@ -37,7 +37,7 @@ describe('Authorization failure ', function() {
 		session.close(function(e, r) {
 			reply = r;
 			err = e;
-			done();
+			//done();
 
 	});
 

test/test-auth.js

@@ -60,10 +60,10 @@ describe('Send an invalid command:  2+', function() {
 	});
 });
 
-describe('Create a database', function() {
+describe('Create a database with execute', function() {
 	var reply, err;
 	before(function(done) {
-		session.execute("create db database", function(e, r) {
+		session.execute("create db testdb", function(e, r) {
 			reply = r;
 			err = e;
 			done();
@@ -93,7 +93,22 @@ describe('Add a document', function() {
 describe('drop db database', function() {
 	var reply, err;
 	before(function(done) {
-		session.execute("drop db database", function(e, r) {
+		session.execute("drop db testdb", function(e, r) {
+			reply = r;
+			err = e;
+			done();
+		});
+	});
+
+	it('It should not error', function() {
+		should.not.exist(err);
+	});
+});
+
+describe('create database', function() {
+	var reply, err;
+	before(function(done) {
+		session.create("testdb", "<x>Hello World!</x>", function(e, r) {
 			reply = r;
 			err = e;
 			done();
@@ -108,7 +123,7 @@ describe('drop db database', function() {
 describe('drop db database', function() {
 	var reply, err;
 	before(function(done) {
-		session.execute("drop db database", function(e, r) {
+		session.execute("drop db testdb", function(e, r) {
 			reply = r;
 			err = e;
 			done();