Basic Append, Read, and Subscribe Options

.gitignore

@@ -1,4 +1,5 @@
 *.sublime-*
 node_modules
 .OpenIDE
-EventStore
+EventStore
+goal

README.md

@@ -1,7 +1,7 @@
 ges-client
 =======
 
-**A client library for [(Get) Event Store](http://geteventstore.com)**
+**A nodejs client library for [(Get) Event Store](http://geteventstore.com)**
 
 
 [![Build Status](https://secure.travis-ci.org/bmavity/ges-client.svg)](http://travis-ci.org/bmavity/ges-client)
@@ -12,6 +12,7 @@ ges-client
   * <a href="#intro">Introduction</a>
   * <a href="#basic">Basic usage</a>
   * <a href="#licence">Licence &amp; copyright</a>
+  * <a href="#thanks">Special Thanks</a>
 
 <a name="intro"></a>
 Introduction
@@ -29,26 +30,52 @@ Install
 $ npm install ges-client
 ```
 
-Read from an event stream
+Append and read from an event stream
 
 ```js
 var ges = require('ges-client')
 
 // 1) Create a connection to a running EventStore
 //    using default connection options and credentials
-var es = ges()
+var connection = ges()
+	, stream = 'intro-events'
 
-// 2) 
+// 2) Append events that can be read
 var thingsThatHappened = [array of events]
-es.appendToStream('intro-events', thingsThatHappened, function (err) {
-  if (err) return console.log('Ooops!', err) // connection error
+connection.on('connect', function() {
+	connection.appendToStream(stream, ges.expectedVersion.emptyStream, thingsThatHappened, function(err, appendResult) {
+	  if(err) return console.log('Ooops!', err) // connection error
+
+	  // 3) Read first events from the stream
+  	connection.readStreamEventsForward(stream, { start: 0, count: 1 }, function(err, readResult) {
+	    if(err) return console.log('Ooops!', err) // connection error or stream does not exist
+
+	    // ta da!
+  		console.log(readResult.Events)
+  	})
+  })
+})
+```
+
+Subscribe to stream updates
+
+```js
+var ges = require('ges-client')
 
-  // 3) Read all events from the stream
-  es.readStreamForward('intro-events', function (err, events) {
-    if (err) return console.log('Ooops!', err) // connection error or stream does not exist
+// 1) Create a connection to a running EventStore
+//    using default connection options and credentials
+var connection = ges()
+	, stream = 'intro-events'
+
+// 2) Create a subscription
+var thingsThatHappened = [array of events]
+connection.on('connect', function() {
+  var subscription = connection.subscribeToStream(stream)
 
-    // ta da!
-    console.log(events)
+	// 3) Listen for events
+  subscription.on('event', function(evt) {
+  	// ta da!
+  	console.log(evt)
   })
 })
 ```
@@ -62,4 +89,11 @@ Copyright (c) 2014 Brian Mavity.
 ges-client is licensed under the MIT license. All rights not explicitly granted in the MIT license are reserved. See the included LICENSE.md file for more details.
 
 
+<a name="thanks"></a>
+Special Thanks
+-----------
+
+Special thanks to Ken Pratt for writing the first version of this over at https://github.com/kenpratt/nodejs-EventStore .
+It made early development go by much faster.
+
 

eventData.js

@@ -0,0 +1,17 @@
+module.exports = function EventData(eventId, type, isJson, data, metadata) {
+	if(!(this instanceof EventData)) {
+		return new EventData(eventId, type, isJson, data, metadata)
+	}
+
+	isJson = !!isJson
+	data = data || new Buffer(0)
+	metadata = metadata || new Buffer(0)
+
+	Object.defineProperties(this, {
+		EventId: { value: eventId, enumerable: true }
+  , Type: { value: type, enumerable: true }
+  , IsJson: { value: isJson, enumerable: true }
+  , Data: { value: data, enumerable: true }
+  , Metadata: { value: metadata, enumerable: true }
+	})
+}

ges-client.js

@@ -1,8 +1,28 @@
 var tcpConnect = require('./tcp/connection')
+	, expectedVersion = {}
+	, streamPosition = {}
 
 module.exports = createConnection
 
 
+Object.defineProperties(module.exports, {
+	expectedVersion: { value: expectedVersion }
+, maxRecordCount: { value: 2147483647 }
+, streamPosition: { value: streamPosition }
+})
+
+Object.defineProperties(streamPosition, {
+	start: { value: 0 }
+, end: { value: -1 }
+})
+
+Object.defineProperties(expectedVersion, {
+	any: { value: -2 }
+, noStream: { value: -1 }
+, emptyStream: { value: -1 }
+})
+
+
 function createConnection(opts) {
 	return tcpConnect(opts)
 }

package.json

@@ -19,16 +19,17 @@
     "request": "2.34.x"
   },
   "devDependencies": {
+    "async": "^0.9.0",
+    "ges-test-helper": "^0.1.2",
     "mocha": "^1.21.4",
-    "should": "^4.0.4",
-    "ges-test-helper": "^0.1.1"
+    "should": "^4.0.4"
   },
   "engines": {
     "node": "0.10.x"
   },
   "scripts": {
     "test": "mocha -r should -R tap -t 10s test/**/*.js",
-    "watch": "mocha -w -r should -R spec test/**/*.js"
+    "watch": "mocha -w -r should -R spec -t 10s test/**/*.js"
   },
   "keywords": [],
   "license": "MIT +no-false-attribs, +no-advertising License",