From 5f610ca09132e444ddab1e10063d04f375c85eda Mon Sep 17 00:00:00 2001
From: "Alex A. Naanou" <alex.nanou@gmail.com>
Date: Fri, 24 Feb 2017 19:47:04 +0300
Subject: [PATCH] experimenting with peer protocol/api...

Signed-off-by: Alex A. Naanou <alex.nanou@gmail.com>
---
 ui (gen4)/features/peer.js | 70 +++++++++++++++++++++++++++++++-------
 1 file changed, 57 insertions(+), 13 deletions(-)

diff --git a/ui (gen4)/features/peer.js b/ui (gen4)/features/peer.js
index 3e2ee578..5de0ceb0 100755
--- a/ui (gen4)/features/peer.js	
+++ b/ui (gen4)/features/peer.js	
@@ -16,6 +16,18 @@ var core = require('features/core')
 
 
 
+/*********************************************************************/
+// helpers...
+
+// XXX should this parse out the protocol???
+// 		...technically we no longer need it....
+var makeProtocolHandiler = function(protocol, func){
+	return function(id){
+		return id.startsWith(protocol + ':')
+			&& func.apply(this, arguments) } } 
+
+
+
 /*********************************************************************/
 
 // XXX this is a generic API, add ability to define protocols...
@@ -154,25 +166,54 @@ module.Peer = core.ImageGridFeatures.Feature({
 
 //---------------------------------------------------------------------
 
+// XXX all the return values here will be ignored -- need a way to figure
+// 		out a cooperative mechanic to return promises...
 var ChildProcessPeerActions = actions.Actions({
-
 	peerConnect: ['- Peer/',
-		function(id, options){
-			// XXX
-		}],
+		makeProtocolHandiler('child', function(id, options){
+			// XXX need a cooperative way to pass this to the root method return...
+			return new Promise((function(resolve, reject){
+				// already connected...
+				if(id in this.__peers){
+					return resolve(id) 
+				}
+
+				// XXX run ig.js in child_process + add peer feature to setup...
+				// XXX
+			}).bind(this))
+		})],
 	peerDisconnect: ['- Peer/',
-		function(id){
-			// XXX
-		}],
+		makeProtocolHandiler('child', function(id){
+			// XXX need a cooperative way to pass this to the root method return...
+			return new Promise((function(resolve, reject){
+				// already disconnected...
+				if(this.__peers[id] == null){
+					return resolve(id) 
+				}
+
+				// trigger stop...
+				this.peerCall(id, 'stop')
+					.then(function(){
+						// XXX terminate child...
+						// XXX
+					})
+			}).bind(this))
+		})],
 
 	peerCall: ['- Peer/',
-		function(id, action){
-			// XXX 
-		}],
+		makeProtocolHandiler('child', function(id, action){
+			// XXX need a cooperative way to pass this to the root method return...
+			return new Promise((function(resolve, reject){
+				// XXX
+			}).bind(this))
+		})],
 	peerApply: ['- Peer/',
-		function(id, action, args){
-			// XXX
-		}],
+		makeProtocolHandiler('child', function(id, action, args){
+			// XXX need a cooperative way to pass this to the root method return...
+			return new Promise((function(resolve, reject){
+				// XXX
+			}).bind(this))
+		})],
 })
 
 
@@ -186,6 +227,9 @@ module.ChildProcessPeer = core.ImageGridFeatures.Feature({
 		'peer',
 	],
 
+	isApplicable: function(){ 
+		return this.runtime == 'nw' || this.runtime == 'node' },
+
 	actions: ChildProcessPeerActions, 
 })