Added ShellScript-task to run Linux shell scripts.

Author: codejitsu

tasks-dsl/src/main/scala/net/codejitsu/tasks/GenericTask.scala

@@ -13,7 +13,7 @@ abstract class GenericTask(name: String, desc: String, hosts: Hosts, exec: Strin
   protected val procs: Processes = name on hosts ~> {
     case cmd => if (usingSudo) {
       Sudo ~ Exec(exec, params :_*)
-    } else{
+    } else {
       Exec(exec, params :_*)
     }
   }

tasks-dsl/src/main/scala/net/codejitsu/tasks/ShellScript.scala

@@ -0,0 +1,18 @@
+// Copyright (C) 2015, codejitsu.
+
+package net.codejitsu.tasks
+
+import net.codejitsu.tasks.dsl._
+
+/**
+ * Run shell scripts.
+ */
+final case class ShellScript[S <: Stage](hosts: Hosts, script: String, params: List[String] = List.empty[String],
+                                         usingSudo: Boolean = false, usingPar: Boolean = false,
+                                         shell: String = "/bin/sh")(implicit user: User, stage: S, rights: S Allow StartService[S])
+  extends GenericTask("script", "run shell script", hosts, s"$shell $script", params,
+    usingSudo, usingPar, taskRepr = s"run shell script '$script'") with UsingSudo[ShellScript[S]] with UsingParallelExecution[ShellScript[S]] {
+
+  override def sudo: ShellScript[S] = copy[S](usingSudo = true)
+  override def par: ShellScript[S] = copy[S](usingPar = true)
+}

tasks-dsl/src/main/scala/net/codejitsu/tasks/dsl/Allow.scala

@@ -28,4 +28,5 @@ object Allow {
   implicit val devAllowStopService: Dev Allow StopService[Dev] = new Allow[Dev, StopService[Dev]]
   implicit val devAllowStartTomcat: Dev Allow StartTomcat[Dev] = new Allow[Dev, StartTomcat[Dev]]
   implicit val devAllowStopTomcat: Dev Allow StopTomcat[Dev] = new Allow[Dev, StopTomcat[Dev]]
+  implicit val devAllowShellScripts: Dev Allow ShellScript[Dev] = new Allow[Dev, ShellScript[Dev]]
 }

tasks-dsl/src/test/scala/ShellScriptTest.scala

@@ -0,0 +1,26 @@
+package net.codejitsu.tasks.dsl
+
+import org.scalatest.{FlatSpec, Matchers}
+
+class ShellScriptTest extends FlatSpec with Matchers {
+  import net.codejitsu.tasks._
+  import net.codejitsu.tasks.dsl.Tasks._
+
+  import scala.concurrent.duration._
+
+  implicit val timeout = 30 seconds
+
+  implicit val stage = new Dev
+
+  "shell script task" should "run shell scripts" in {
+    val path = getClass.getResource("/program-param.sh").getPath
+
+    val task = ShellScript(Localhost, path, List("test", "1", "-z"))
+
+    val result = task.run()
+
+    result.res.isSuccess should be (true)
+    result.out should be (List("start test program with param: test 1 -z"))
+    result.err should be (empty)
+  }
+}