tests/src/test/scala/runtime/sdk/SwiftSDKTests.scala - openwhisk-runtime-swift - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
  * The ASF licenses this file to You under the Apache License, Version 2.0
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 package runtime.sdk

 import java.io.File

 import scala.concurrent.duration.DurationInt
 import scala.language.postfixOps
 import common._
 import spray.json._
 import spray.json.DefaultJsonProtocol.StringJsonFormat

 abstract class SwiftSDKTests extends TestHelpers with WskTestHelpers with WskActorSystem {

   implicit val wskprops = WskProps()
   val wsk = new Wsk
   val activationPollDuration = 2.minutes
   lazy val actionKind = "swift:3.1.1"
   lazy val lang = actionKind.split(":")(0)
   lazy val majorVersion = actionKind.split(":")(1).split('.')(0)
   lazy val actionDir = s"$lang$majorVersion"
   lazy val actionTypeDir: String = "tests/dat/actions/sdk/" + actionDir
   val controllerHost = WhiskProperties.getBaseControllerHost()
   val controllerPort = WhiskProperties.getControllerBasePort()
   val baseUrl = s"http://$controllerHost:$controllerPort"
   //when running tests on environment with valid ssl certs in whisk host then pass -DswiftUseSSLWhiskHost=true
   val overridebaseURL = "true" != System.getProperty("swiftUseSSLWhiskHost")

   behavior of s"Swift Whisk SDK tests using $actionKind"

   it should "allow Swift actions to invoke other actions" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
     val file = Some(new File(actionTypeDir, "invoke.swift").toString())

     val actionName = "invokeAction"
     assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
       action.create(name = actionName, artifact = file, kind = Some(actionKind))
     }
     // invoke the action
     var params = Map("dummy" -> JsString("dummy"))
     if (overridebaseURL)
       params = params + ("baseUrl" -> JsString(baseUrl))

     val run = wsk.action.invoke(actionName, params)
     withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
       // should be successful
       activation.response.success shouldBe true

       // should have a field named "activationId" which is the date action's activationId
       activation.response.result.get.fields("activationId").toString.length should be >= 32

       // check for "date" field that comes from invoking the date action
       whisk.utils.JsHelpers.fieldPathExists(activation.response.result.get, "response", "result", "date") should be(
         true)
     }
   }

   it should "allow Swift actions to invoke other actions and not block" in withAssetCleaner(wskprops) {
     (wp, assetHelper) =>
       // use CLI to create action from dat/actions/invokeNonBlocking.swift
       val file = Some(new File(actionTypeDir, "invokeNonBlocking.swift").toString())
       val actionName = "invokeNonBlockingAction"
       assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
         action.create(name = actionName, file, kind = Some(actionKind))
       }

       // invoke the action
       var params = Map("dummy" -> JsString("dummy"))
       if (overridebaseURL)
         params = params + ("baseUrl" -> JsString(baseUrl))

       val run = wsk.action.invoke(actionName, params)
       withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
         // should not have a "response"
         whisk.utils.JsHelpers.fieldPathExists(activation.response.result.get, "response") shouldBe false

         // should have a field named "activationId" which is the date action's activationId
         activation.response.result.get.fields("activationId").toString.length should be >= 32
       }
   }

   it should "allow Swift actions to trigger events" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
     // create a trigger
     val triggerName = s"TestTrigger ${System.currentTimeMillis()}"
     val ruleName = s"TestTriggerRule ${System.currentTimeMillis()}"
     val ruleActionName = s"TestTriggerAction ${System.currentTimeMillis()}"
     assetHelper.withCleaner(wsk.trigger, triggerName) { (trigger, _) =>
       trigger.create(triggerName)
     }

     // create a dummy action
     assetHelper.withCleaner(wsk.action, ruleActionName) { (action, name) =>
       val dummyFile = Some(new File(actionTypeDir, "hello.swift").toString())
       action.create(name, dummyFile, kind = Some(actionKind))
     }
     // create a dummy rule
     assetHelper.withCleaner(wsk.rule, ruleName) { (rule, name) =>
       rule.create(name, trigger = triggerName, action = ruleActionName)
     }

     // create an action that fires the trigger
     val file = Some(new File(actionTypeDir, "trigger.swift").toString())
     val actionName = "ActionThatTriggers"
     assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
       action.create(name = actionName, file, kind = Some(actionKind))
     }

     // invoke the action
     var params = Map("triggerName" -> JsString(triggerName))
     if (overridebaseURL)
       params = params + ("baseUrl" -> JsString(baseUrl))

     val run = wsk.action.invoke(actionName, params)
     withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
       // should be successful
       activation.response.success shouldBe true

       // should have a field named "activationId" which is the date action's activationId
       activation.response.result.get.fields("activationId").toString.length should be >= 32

       // should result in an activation for triggerName
       val triggerActivations = wsk.activation.pollFor(1, Some(triggerName), retries = 20)
       withClue(s"trigger activations for $triggerName:") {
         triggerActivations.length should be(1)
       }
     }
   }

   it should "allow Swift actions to create a trigger" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
     // create an action that creates the trigger
     val file = Some(new File(actionTypeDir, "createTrigger.swift").toString())
     val actionName = "ActionThatTriggers"

     // the name of the trigger to create
     val triggerName = s"TestTrigger ${System.currentTimeMillis()}"

     assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
       assetHelper.withCleaner(wsk.trigger, triggerName) { (_, _) =>
         // using an asset cleaner on the created trigger name will clean it up at the conclusion of the test
         action.create(name = actionName, file, kind = Some(actionKind))
       }
     }

     // invoke the action
     var params = Map("triggerName" -> JsString(triggerName))
     if (overridebaseURL)
       params = params + ("baseUrl" -> JsString(baseUrl))

     val run = wsk.action.invoke(actionName, params)
     withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
       // should be successful
       activation.response.success shouldBe true

       // should have a field named "name" which is the name of the trigger created
       activation.response.result.get.fields("name") shouldBe JsString(triggerName)
     }
   }

   it should "allow Swift actions to create a rule" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
     val ruleTriggerName = s"TestTrigger ${System.currentTimeMillis()}"
     val ruleActionName = s"TestAction ${System.currentTimeMillis()}"
     val ruleName = s"TestRule ${System.currentTimeMillis()}"

     // create a dummy action and trigger for the rule
     assetHelper.withCleaner(wsk.action, ruleActionName) { (action, name) =>
       val dummyFile = Some(new File(actionTypeDir, "hello.swift").toString())
       action.create(name, dummyFile, kind = Some(actionKind))
     }

     assetHelper.withCleaner(wsk.trigger, ruleTriggerName) { (trigger, name) =>
       assetHelper.withCleaner(wsk.rule, ruleName) { (_, _) =>
         // using an asset cleaner on the created trigger name will clean it up at the conclusion of the test
         trigger.create(name)
       }
     }

     // create an action that creates the rule
     val createRuleFile = Some(new File(actionTypeDir, "createRule.swift").toString())
     assetHelper.withCleaner(wsk.action, "ActionThatCreatesRule") { (action, name) =>
       action.create(name, createRuleFile, kind = Some(actionKind))
     }

     // invoke the create rule action
     var params = Map(
       "triggerName" -> s"/_/$ruleTriggerName".toJson,
       "actionName" -> s"/_/$ruleActionName".toJson,
       "ruleName" -> ruleName.toJson)

     if (overridebaseURL)
       params = params + ("baseUrl" -> JsString(baseUrl))

     val run = wsk.action.invoke("ActionThatCreatesRule", params)
     withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
       // should be successful
       activation.response.success shouldBe true

       // should have a field named "trigger" which is the name of the trigger associated with the rule
       activation.response.result.get.fields("trigger").asJsObject.fields("name") shouldBe ruleTriggerName.toJson

       // should have a field named "action" which is the name of the action associated with the rule
       activation.response.result.get.fields("action").asJsObject.fields("name") shouldBe ruleActionName.toJson
     }
   }

 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package runtime.sdk

	import java.io.File

	import scala.concurrent.duration.DurationInt
	import scala.language.postfixOps
	import common._
	import spray.json._
	import spray.json.DefaultJsonProtocol.StringJsonFormat

	abstract class SwiftSDKTests extends TestHelpers with WskTestHelpers with WskActorSystem {

	implicit val wskprops = WskProps()
	val wsk = new Wsk
	val activationPollDuration = 2.minutes
	lazy val actionKind = "swift:3.1.1"
	lazy val lang = actionKind.split(":")(0)
	lazy val majorVersion = actionKind.split(":")(1).split('.')(0)
	lazy val actionDir = s"$lang$majorVersion"
	lazy val actionTypeDir: String = "tests/dat/actions/sdk/" + actionDir
	val controllerHost = WhiskProperties.getBaseControllerHost()
	val controllerPort = WhiskProperties.getControllerBasePort()
	val baseUrl = s"http://$controllerHost:$controllerPort"
	//when running tests on environment with valid ssl certs in whisk host then pass -DswiftUseSSLWhiskHost=true
	val overridebaseURL = "true" != System.getProperty("swiftUseSSLWhiskHost")

	behavior of s"Swift Whisk SDK tests using $actionKind"

	it should "allow Swift actions to invoke other actions" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
	val file = Some(new File(actionTypeDir, "invoke.swift").toString())

	val actionName = "invokeAction"
	assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
	action.create(name = actionName, artifact = file, kind = Some(actionKind))
	}
	// invoke the action
	var params = Map("dummy" -> JsString("dummy"))
	if (overridebaseURL)
	params = params + ("baseUrl" -> JsString(baseUrl))

	val run = wsk.action.invoke(actionName, params)
	withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
	// should be successful
	activation.response.success shouldBe true

	// should have a field named "activationId" which is the date action's activationId
	activation.response.result.get.fields("activationId").toString.length should be >= 32

	// check for "date" field that comes from invoking the date action
	whisk.utils.JsHelpers.fieldPathExists(activation.response.result.get, "response", "result", "date") should be(
	true)
	}
	}

	it should "allow Swift actions to invoke other actions and not block" in withAssetCleaner(wskprops) {
	(wp, assetHelper) =>
	// use CLI to create action from dat/actions/invokeNonBlocking.swift
	val file = Some(new File(actionTypeDir, "invokeNonBlocking.swift").toString())
	val actionName = "invokeNonBlockingAction"
	assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
	action.create(name = actionName, file, kind = Some(actionKind))
	}

	// invoke the action
	var params = Map("dummy" -> JsString("dummy"))
	if (overridebaseURL)
	params = params + ("baseUrl" -> JsString(baseUrl))

	val run = wsk.action.invoke(actionName, params)
	withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
	// should not have a "response"
	whisk.utils.JsHelpers.fieldPathExists(activation.response.result.get, "response") shouldBe false

	// should have a field named "activationId" which is the date action's activationId
	activation.response.result.get.fields("activationId").toString.length should be >= 32
	}
	}

	it should "allow Swift actions to trigger events" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
	// create a trigger
	val triggerName = s"TestTrigger ${System.currentTimeMillis()}"
	val ruleName = s"TestTriggerRule ${System.currentTimeMillis()}"
	val ruleActionName = s"TestTriggerAction ${System.currentTimeMillis()}"
	assetHelper.withCleaner(wsk.trigger, triggerName) { (trigger, _) =>
	trigger.create(triggerName)
	}

	// create a dummy action
	assetHelper.withCleaner(wsk.action, ruleActionName) { (action, name) =>
	val dummyFile = Some(new File(actionTypeDir, "hello.swift").toString())
	action.create(name, dummyFile, kind = Some(actionKind))
	}
	// create a dummy rule
	assetHelper.withCleaner(wsk.rule, ruleName) { (rule, name) =>
	rule.create(name, trigger = triggerName, action = ruleActionName)
	}

	// create an action that fires the trigger
	val file = Some(new File(actionTypeDir, "trigger.swift").toString())
	val actionName = "ActionThatTriggers"
	assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
	action.create(name = actionName, file, kind = Some(actionKind))
	}

	// invoke the action
	var params = Map("triggerName" -> JsString(triggerName))
	if (overridebaseURL)
	params = params + ("baseUrl" -> JsString(baseUrl))

	val run = wsk.action.invoke(actionName, params)
	withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
	// should be successful
	activation.response.success shouldBe true

	// should have a field named "activationId" which is the date action's activationId
	activation.response.result.get.fields("activationId").toString.length should be >= 32

	// should result in an activation for triggerName
	val triggerActivations = wsk.activation.pollFor(1, Some(triggerName), retries = 20)
	withClue(s"trigger activations for $triggerName:") {
	triggerActivations.length should be(1)
	}
	}
	}

	it should "allow Swift actions to create a trigger" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
	// create an action that creates the trigger
	val file = Some(new File(actionTypeDir, "createTrigger.swift").toString())
	val actionName = "ActionThatTriggers"

	// the name of the trigger to create
	val triggerName = s"TestTrigger ${System.currentTimeMillis()}"

	assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
	assetHelper.withCleaner(wsk.trigger, triggerName) { (_, _) =>
	// using an asset cleaner on the created trigger name will clean it up at the conclusion of the test
	action.create(name = actionName, file, kind = Some(actionKind))
	}
	}

	// invoke the action
	var params = Map("triggerName" -> JsString(triggerName))
	if (overridebaseURL)
	params = params + ("baseUrl" -> JsString(baseUrl))

	val run = wsk.action.invoke(actionName, params)
	withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
	// should be successful
	activation.response.success shouldBe true

	// should have a field named "name" which is the name of the trigger created
	activation.response.result.get.fields("name") shouldBe JsString(triggerName)
	}
	}

	it should "allow Swift actions to create a rule" in withAssetCleaner(wskprops) { (wp, assetHelper) =>
	val ruleTriggerName = s"TestTrigger ${System.currentTimeMillis()}"
	val ruleActionName = s"TestAction ${System.currentTimeMillis()}"
	val ruleName = s"TestRule ${System.currentTimeMillis()}"

	// create a dummy action and trigger for the rule
	assetHelper.withCleaner(wsk.action, ruleActionName) { (action, name) =>
	val dummyFile = Some(new File(actionTypeDir, "hello.swift").toString())
	action.create(name, dummyFile, kind = Some(actionKind))
	}

	assetHelper.withCleaner(wsk.trigger, ruleTriggerName) { (trigger, name) =>
	assetHelper.withCleaner(wsk.rule, ruleName) { (_, _) =>
	// using an asset cleaner on the created trigger name will clean it up at the conclusion of the test
	trigger.create(name)
	}
	}

	// create an action that creates the rule
	val createRuleFile = Some(new File(actionTypeDir, "createRule.swift").toString())
	assetHelper.withCleaner(wsk.action, "ActionThatCreatesRule") { (action, name) =>
	action.create(name, createRuleFile, kind = Some(actionKind))
	}

	// invoke the create rule action
	var params = Map(
	"triggerName" -> s"/_/$ruleTriggerName".toJson,
	"actionName" -> s"/_/$ruleActionName".toJson,
	"ruleName" -> ruleName.toJson)

	if (overridebaseURL)
	params = params + ("baseUrl" -> JsString(baseUrl))

	val run = wsk.action.invoke("ActionThatCreatesRule", params)
	withActivation(wsk.activation, run, initialWait = 5 seconds, totalWait = activationPollDuration) { activation =>
	// should be successful
	activation.response.success shouldBe true

	// should have a field named "trigger" which is the name of the trigger associated with the rule
	activation.response.result.get.fields("trigger").asJsObject.fields("name") shouldBe ruleTriggerName.toJson

	// should have a field named "action" which is the name of the action associated with the rule
	activation.response.result.get.fields("action").asJsObject.fields("name") shouldBe ruleActionName.toJson
	}
	}

	}