diff --git a/README.md b/README.md
index d51bc49..ef158d1 100644
--- a/README.md
+++ b/README.md
@@ -55,7 +55,7 @@ The `mapping` is optional field, if it's missing when Elastic Seach default mapp
 Once, config file is updated run exporter,
 
 ```bash
-$ node source/elaster
+$ bin/elaster
 ```
 
 ## Licence (MIT)
diff --git a/bin/elaster b/bin/elaster
new file mode 100755
index 0000000..6bb5aa3
--- /dev/null
+++ b/bin/elaster
@@ -0,0 +1,5 @@
+#!/usr/bin/env node
+var elaster = require('../source/elaster');
+var config = require('../config');
+
+elaster.run(config.collections);
diff --git a/source/elaster.js b/source/elaster.js
index eb689de..707edfc 100644
--- a/source/elaster.js
+++ b/source/elaster.js
@@ -1,4 +1,147 @@
+var _ = require('underscore');
+var async = require('async');
 var config = require('../config');
-var exporter = require('./exporter');
 
-exporter.run(config.collections);
\ No newline at end of file
+var db = require('./db')(config);
+var elastic = require('./elastic')(config);
+
+var through = require('through');
+var single = require('single-line-log');
+
+require('colors');
+
+function exportCollection(desc, callback) {
+	var collection = db[desc.name];
+
+	if (!collection) {
+		return callback('collection ' + desc.name + ' does not exist.');
+	}
+
+	console.log(('====> exporting collection [' + desc.name + ']').bold.white);
+
+	async.waterfall([
+		function (next) {
+			console.log('----> checking connection to elastic');
+			elastic.ping({requestTimeout: 1000}, function (err) {
+				next(err);
+			});
+		},
+		function (next) {
+			console.log('----> dropping existing index [' + desc.index + ']');
+			elastic.indices.delete({index: desc.index}, function (err) {
+				var indexMissing = err && err.message.indexOf('IndexMissingException') === 0;
+				next(indexMissing ? null : err);
+			});
+		},
+		function (next) {
+			console.log('----> creating new index [' + desc.index + ']');
+			elastic.indices.create({index: desc.index}, function (err) {
+				next(err);
+			});
+		},
+		function (next) {
+			console.log('----> initialize index mapping');
+
+			if (!desc.mappings) {
+				return next();
+			}
+
+			elastic.indices.putMapping({index: desc.index, type: desc.type, body: desc.mappings }, function (err) {
+				next(err);
+			});
+		},
+		function (next) {
+			console.log('----> analizing collection [' + desc.name + ']');
+			collection.count(function (err, count) {
+				if (err) {
+					return next(err);
+				}
+
+				console.log('----> find ' + count + ' documentents to export');
+				next(null, count);
+			});
+		},
+		function (count, next) {
+			console.log('----> streaming collection to elastic');
+
+			var takeFields = through(function (item) {
+				if (desc.fields) {
+					item = _.pick(item, desc.fields);
+				}
+
+				this.queue(item);
+			});
+
+			var postToElastic = through(function (item) {
+				var me = this;
+
+				me.pause();
+
+				elastic.create({
+					index: desc.index,
+					type: desc.type,
+					id: item._id.toString(),
+					body: item
+				}, function (err) {
+					if (err) {
+						console.error(('failed to create document in elastic.').bold.red);
+						console.error(err);
+					}
+
+					me.queue(item);
+					me.resume();
+				});
+			});
+
+			var progress = function () {
+				var count = 0;
+				return through(function () {
+					single(('------> processed ' + (++count) + ' documents').magenta);
+				});
+			};
+
+			var stream = collection
+				.find({})
+				.sort({_id: 1})
+				.pipe(takeFields)
+				.pipe(postToElastic)
+				.pipe(progress());
+
+			stream.on('end', function (err) {
+				next(err, count);
+			});
+		},
+	], function (err) {
+		if (err) {
+			console.error(('====> collection [' + desc.name + '] - failed to export.\n').bold.red);
+			console.error(err);
+			return callback(err);
+		}
+
+		console.log(('====> collection [' + desc.name + '] - exported successfully.\n').bold.green);
+
+		callback(null);
+	});
+}
+
+function close() {
+	async.each([db, elastic], _close);
+
+	function _close(conn, callback) {
+		conn.close(callback);
+	}
+}
+
+function exporter(collections) {
+	var exports = collections.map(function (c) {
+		return function (callback) {
+			exportCollection(c, callback);
+		};
+	});
+
+	async.series(exports, close);
+}
+
+module.exports = {
+	run: exporter
+};
\ No newline at end of file
diff --git a/source/exporter.js b/source/exporter.js
deleted file mode 100644
index 707edfc..0000000
--- a/source/exporter.js
+++ /dev/null
@@ -1,147 +0,0 @@
-var _ = require('underscore');
-var async = require('async');
-var config = require('../config');
-
-var db = require('./db')(config);
-var elastic = require('./elastic')(config);
-
-var through = require('through');
-var single = require('single-line-log');
-
-require('colors');
-
-function exportCollection(desc, callback) {
-	var collection = db[desc.name];
-
-	if (!collection) {
-		return callback('collection ' + desc.name + ' does not exist.');
-	}
-
-	console.log(('====> exporting collection [' + desc.name + ']').bold.white);
-
-	async.waterfall([
-		function (next) {
-			console.log('----> checking connection to elastic');
-			elastic.ping({requestTimeout: 1000}, function (err) {
-				next(err);
-			});
-		},
-		function (next) {
-			console.log('----> dropping existing index [' + desc.index + ']');
-			elastic.indices.delete({index: desc.index}, function (err) {
-				var indexMissing = err && err.message.indexOf('IndexMissingException') === 0;
-				next(indexMissing ? null : err);
-			});
-		},
-		function (next) {
-			console.log('----> creating new index [' + desc.index + ']');
-			elastic.indices.create({index: desc.index}, function (err) {
-				next(err);
-			});
-		},
-		function (next) {
-			console.log('----> initialize index mapping');
-
-			if (!desc.mappings) {
-				return next();
-			}
-
-			elastic.indices.putMapping({index: desc.index, type: desc.type, body: desc.mappings }, function (err) {
-				next(err);
-			});
-		},
-		function (next) {
-			console.log('----> analizing collection [' + desc.name + ']');
-			collection.count(function (err, count) {
-				if (err) {
-					return next(err);
-				}
-
-				console.log('----> find ' + count + ' documentents to export');
-				next(null, count);
-			});
-		},
-		function (count, next) {
-			console.log('----> streaming collection to elastic');
-
-			var takeFields = through(function (item) {
-				if (desc.fields) {
-					item = _.pick(item, desc.fields);
-				}
-
-				this.queue(item);
-			});
-
-			var postToElastic = through(function (item) {
-				var me = this;
-
-				me.pause();
-
-				elastic.create({
-					index: desc.index,
-					type: desc.type,
-					id: item._id.toString(),
-					body: item
-				}, function (err) {
-					if (err) {
-						console.error(('failed to create document in elastic.').bold.red);
-						console.error(err);
-					}
-
-					me.queue(item);
-					me.resume();
-				});
-			});
-
-			var progress = function () {
-				var count = 0;
-				return through(function () {
-					single(('------> processed ' + (++count) + ' documents').magenta);
-				});
-			};
-
-			var stream = collection
-				.find({})
-				.sort({_id: 1})
-				.pipe(takeFields)
-				.pipe(postToElastic)
-				.pipe(progress());
-
-			stream.on('end', function (err) {
-				next(err, count);
-			});
-		},
-	], function (err) {
-		if (err) {
-			console.error(('====> collection [' + desc.name + '] - failed to export.\n').bold.red);
-			console.error(err);
-			return callback(err);
-		}
-
-		console.log(('====> collection [' + desc.name + '] - exported successfully.\n').bold.green);
-
-		callback(null);
-	});
-}
-
-function close() {
-	async.each([db, elastic], _close);
-
-	function _close(conn, callback) {
-		conn.close(callback);
-	}
-}
-
-function exporter(collections) {
-	var exports = collections.map(function (c) {
-		return function (callback) {
-			exportCollection(c, callback);
-		};
-	});
-
-	async.series(exports, close);
-}
-
-module.exports = {
-	run: exporter
-};
\ No newline at end of file