Update: bindFlow use old callback

iGdea · Sep 10, 2018 · f204bc3 · f204bc3
1 parent 3f28707
commit f204bc3
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/lib/deps/dep_linker.js b/lib/deps/dep_linker.js
@@ -65,6 +65,7 @@ exports.proto = function(Linker)
 			var self = this;
 			function bindFlow(handler, name)
 			{
+				if (typeof handler != 'function') return false;
 				if (typeof handler.init == 'function')
 				{
 					var ret = handler.init(self);
@@ -74,7 +75,11 @@ exports.proto = function(Linker)
 				try {
 					self.flow(name, function(flow)
 					{
-						flow.register(handler);
+						// flow.register(handler);
+						flow.register(function(runtime, callback)
+						{
+							return handler.call(this, runtime, callback.toFuncCallback());
+						});
 						if (handler.methods)
 						{
 							flow.register('methods', handler.methods);

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "clientlinker",
-  "version": "7.1.2",
+  "version": "7.1.3",
   "description": "Linker all clients whether rpc, addon, http request, mock data, local file ...",
   "main": "index.js",
   "scripts": {

diff --git a/test/test_deps.js b/test/test_deps.js
@@ -165,9 +165,9 @@ describe('#deps', function()
 		expect(flow).to.be.ok();
 
 		linker.addClient('client1',
-			{
-				flows: ['flow1', 'flow_empty', 'flow_next', 'flow_resolve']
-			});
+		{
+			flows: ['flow1', 'flow_empty', 'flow_next', 'flow_resolve']
+		});
 
 		return linker.run('client1.xxxx')
 			.then(function(data)