From e11bd261ab50b9cab7fa280f0295a785feed04e3 Mon Sep 17 00:00:00 2001
From: markfisher <mfisher@pivotal.io>
Date: Wed, 8 Feb 2017 10:37:48 -0500
Subject: [PATCH] add function chain support to stream.sh

---
 scripts/stream.sh | 26 ++++++++++++++++++++------
 1 file changed, 20 insertions(+), 6 deletions(-)

diff --git a/scripts/stream.sh b/scripts/stream.sh
index 7c07970bf..9a7e9fd19 100755
--- a/scripts/stream.sh
+++ b/scripts/stream.sh
@@ -1,5 +1,14 @@
 #!/bin/bash
 
+PREFIX="--spring.cloud.function.proxy"
+DIR="file:///tmp/function-registry"
+
+tokenize() {
+  local IFS=,
+  local TOKENS=($1)
+  echo ${TOKENS[@]}
+}
+
 while getopts ":i:s:f:c:o:p:" opt; do
   case $opt in
     i)
@@ -7,15 +16,20 @@ while getopts ":i:s:f:c:o:p:" opt; do
       ;;
     s)
       FUNC=$OPTARG
-      TYPE=supplier
+      TYPE="$PREFIX.$FUNC.type=supplier"
+      RESOURCE="$PREFIX.$FUNC.resource=$DIR/suppliers/$FUNC.fun"
       ;;
     f)
       FUNC=$OPTARG
-      TYPE=function
+      for i in `tokenize $OPTARG`; do
+        RESOURCE="$RESOURCE $PREFIX.${i}.resource=$DIR/functions/${i}.fun"
+        TYPE="$TYPE $PREFIX.${i}.type=function"
+      done
       ;;
     c)
       FUNC=$OPTARG
-      TYPE=consumer
+      TYPE="$PREFIX.$FUNC.type=consumer"
+      RESOURCE="$PREFIX.$FUNC.resource=$DIR/consumers/$FUNC.fun"
       ;;
     o)
       OUT=--spring.cloud.stream.bindings.output.destination=$OPTARG
@@ -29,8 +43,8 @@ done
 java -jar ../spring-cloud-function-samples/spring-cloud-function-sample-compiler/target/function-sample-compiler-1.0.0.BUILD-SNAPSHOT.jar\
  --management.security.enabled=false\
  --server.port=$PORT\
+ --function.name=$FUNC\
  $IN\
  $OUT\
- --function.name=$FUNC\
- --spring.cloud.function.proxy.$FUNC.type=$TYPE\
- --spring.cloud.function.proxy.$FUNC.resource=file:///tmp/function-registry/$TYPE's'/$FUNC.fun
+ $RESOURCE\
+ $TYPE