| /* |
| * Copyright 2015-2016 IBM Corporation |
| * |
| * Licensed 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 actionContainers |
| |
| import org.junit.runner.RunWith |
| import org.scalatest.junit.JUnitRunner |
| |
| import ActionContainer.withContainer |
| import spray.json.JsObject |
| import spray.json.JsString |
| |
| import common.WskActorSystem |
| |
| @RunWith(classOf[JUnitRunner]) |
| class SwiftActionContainerTests extends BasicActionRunnerTests with WskActorSystem { |
| |
| // note: "out" will likely not be empty in some swift build as the compiler |
| // prints status messages and there doesn't seem to be a way to quiet them |
| val enforceEmptyOutputStream = true |
| lazy val swiftContainerImageName = "swiftaction" |
| |
| // Helpers specific to swiftaction |
| override def withActionContainer(env: Map[String, String] = Map.empty)(code: ActionContainer => Unit) = { |
| withContainer(swiftContainerImageName, env)(code) |
| } |
| |
| behavior of swiftContainerImageName |
| |
| testNotReturningJson( |
| """ |
| |func main(args: [String: Any]) -> String { |
| | return "not a json object" |
| |} |
| """.stripMargin) |
| |
| testEcho(Seq { |
| ("swift", """ |
| |import Glibc |
| |func main(args: [String: Any]) -> [String: Any] { |
| | print("hello stdout") |
| | fputs("hello stderr", stderr) |
| | return args |
| |} |
| """.stripMargin) |
| }) |
| |
| testEnv(Seq { |
| ("swift", """ |
| |func main(args: [String: Any]) -> [String: Any] { |
| | let env = NSProcessInfo.processInfo().environment |
| | var auth = "???" |
| | var edge = "???" |
| | if let authKey : String = env["AUTH_KEY"] { |
| | auth = "\(authKey)" |
| | } |
| | if let edgeHost : String = env["EDGE_HOST"] { |
| | edge = "\(edgeHost)" |
| | } |
| | return ["auth": auth, "edge": edge] |
| |} |
| """.stripMargin) |
| }, enforceEmptyOutputStream) |
| |
| it should "return some error on action error" in { |
| val (out, err) = withActionContainer() { c => |
| val code = """ |
| | // You need an indirection, or swiftc detects the div/0 |
| | // at compile-time. Smart. |
| | func div(x: Int, _ y: Int) -> Int { |
| | return x/y |
| | } |
| | func main(args: [String: Any]) -> [String: Any] { |
| | return [ "divBy0": div(5,0) ] |
| | } |
| """.stripMargin |
| |
| val (initCode, _) = c.init(initPayload(code)) |
| initCode should be(200) |
| |
| val (runCode, runRes) = c.run(runPayload(JsObject())) |
| runCode should be(502) |
| |
| runRes shouldBe defined |
| runRes.get.fields.get("error") shouldBe defined |
| } |
| |
| checkStreams(out, err, { |
| case (o, e) => |
| if (enforceEmptyOutputStream) o shouldBe empty |
| e shouldBe empty |
| }) |
| } |
| |
| it should "log compilation errors" in { |
| val (out, err) = withActionContainer() { c => |
| val code = """ |
| | 10 PRINT "Hello!" |
| | 20 GOTO 10 |
| """.stripMargin |
| |
| val (initCode, _) = c.init(initPayload(code)) |
| initCode should not be (200) |
| |
| val (runCode, runRes) = c.run(runPayload(JsObject("basic" -> JsString("forever")))) |
| runCode should be(502) |
| } |
| |
| checkStreams(out, err, { |
| case (o, e) => |
| if (enforceEmptyOutputStream) o shouldBe empty |
| e.toLowerCase should include("error") |
| }) |
| } |
| |
| it should "support application errors" in { |
| val (out, err) = withActionContainer() { c => |
| val code = """ |
| | func main(args: [String: Any]) -> [String: Any] { |
| | return [ "error": "sorry" ] |
| | } |
| """.stripMargin |
| |
| val (initCode, _) = c.init(initPayload(code)) |
| initCode should be(200) |
| |
| val (runCode, runRes) = c.run(runPayload(JsObject())) |
| runCode should be(200) // action writer returning an error is OK |
| |
| runRes shouldBe defined |
| runRes should be(Some(JsObject("error" -> JsString("sorry")))) |
| } |
| |
| checkStreams(out, err, { |
| case (o, e) => |
| if (enforceEmptyOutputStream) o shouldBe empty |
| e shouldBe empty |
| }) |
| } |
| } |