fixed path

examples/twitter/demo1.coffee

@@ -1,20 +1,24 @@
 #!/usr/bin/env coffee
 
-Hydrant = require '../../lib/hydrant'
+Hydrant = require 'hydrant'
 {inspect} = require 'util'
 hydrant = new Hydrant
   defaults:
     encoding: no # yaml, json, none
     compress: no # deflateRaw, deflate, gzip, or none
 
   twitter:
-    module:               '../../lib/input/twitter'
+    module:               './input/twitter'
 
     consumer_key:         'CONSUMER_KEY'
     consumer_secret:      'CONSUMER_SECRET'
     access_token_key:     'ACCESS_TOKEN_KEY'
     access_token_secret:  'ACCES_TOKEN_SECRET'
 
+    endpoint: 'statuses/filter' # or 'statuses/sample' (remove 'search' in this case)
+    search:
+      track: 'node,javascript,clojure'
+
     # you can pass conditions to ignore some entries of the flow
     # warning: they are directly executed by Node, so be sure
     # your Hydrant config file come from a trusted source!

package.json

@@ -5,7 +5,7 @@
         "email" : "julian.bilcke@daizoru.com",
         "url" : "http://github.com/daizoru"
    },
-  "name": "node-hydrant",
+  "name": "hydrant",
   "description": "Complex event stream aggregator and broadcaster",
   "version": "0.0.0",
   "repository": {
@@ -14,7 +14,7 @@
   },
     "directories" : {
       "lib" : "./lib",
-      "example" : "./example",
+      "examples" : "./examples",
       "test" : "./test"
     },
   "main" : "./lib/hydrant",

src/input/twitter.coffee

@@ -30,16 +30,25 @@ ntwitter = require 'ntwitter'
 class module.exports
 
   constructor: (@config) ->
+    @endpoint = 'statuses/sample'
+    if @config.endpoint?
+      @endpoint = @config.endpoint
+
+    @search = undefined
+    if @config.search?
+      @search = @config.search
+
     @filters = []
     if @config.ignores?
       for ignore in @config.ignores
         @filters.push ignore
       delete @config['ignores']
     @twitter = new ntwitter @config
 
+
   start: => 
     # rate limit: 400 keywords, 5,000 follow userids
-    @twitter.stream 'statuses/sample', undefined, (s) =>
+    @twitter.stream @endpoint, @search, (s) =>
 
       process = (data) =>
         #console.log "data: #{inspect data}"