Add Windows support for Scala & Java frameworks

Added support for most (all?) remaining Scala & Java based frameworks.

finagle/setup.py

@@ -7,23 +7,30 @@ import os
 def start(args=None):
 
 
-    
-    subprocess.check_call("../sbt/sbt update compile", shell=True, cwd="finagle")
-    subprocess.Popen("../sbt/sbt -Ddb.host=" + args.database_host + " run", cwd="finagle", shell=True)
+    if os.name == 'nt':
+      subprocess.check_call("..\\sbt\\sbt.bat update compile", shell=True, cwd="finagle")
+      subprocess.Popen("..\\sbt\\sbt.bat -Ddb.host=" + args.database_host + " run", cwd="finagle", shell=True)
+    else:
+      subprocess.check_call("../sbt/sbt update compile", shell=True, cwd="finagle")
+      subprocess.Popen("../sbt/sbt -Ddb.host=" + args.database_host + " run", cwd="finagle", shell=True)
+
     time.sleep(5)
     return 0
 
 
 
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if 'sbt' in line:
-      try:
-        pid = int(line.split(None, 2)[1])
-        os.kill(pid, 9)
-      except OSError:
-        pass
+  if os.name == 'nt':
+    subprocess.check_call("wmic process where \"CommandLine LIKE '%\\\\sbt\\\\sbt%'\" call terminate")
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if 'sbt' in line:
+        try:
+          pid = int(line.split(None, 2)[1])
+          os.kill(pid, 9)
+        except OSError:
+          pass
   
   return 0

installer.ps1

@@ -188,7 +188,7 @@ if ($jdk_master_hash -ne $jdk_local_hash)
 
 Start-Process $jdk_local "/s INSTALLDIR=$jdk_dir" -Wait
 $env:Path += ";$jdk_dir\bin"; [Environment]::SetEnvironmentVariable("Path", $env:Path, [System.EnvironmentVariableTarget]::Machine)
-$env:JAVA_HOME = $jdk_dir; [Environment]::SetEnvironmentVariable("JAVA_HOME", $jre_dir, [System.EnvironmentVariableTarget]::Machine)
+$env:JAVA_HOME = $jdk_dir; [Environment]::SetEnvironmentVariable("JAVA_HOME", $jdk_dir, [System.EnvironmentVariableTarget]::Machine)
 
 # resin
 $resin_url = "http://www.caucho.com/download/resin-4.0.36.zip"
@@ -199,6 +199,7 @@ $resin_dir = "C:\Java\resin"
 [System.IO.Compression.ZipFile]::ExtractToDirectory($resin_local, $workdir) | Out-Null
 Move-Item "$workdir\resin-4.0.36" $resin_dir
 Copy-Item "$basedir\config\resin.properties" "$resin_dir\conf\resin.properties"
+[Environment]::SetEnvironmentVariable("RESIN_HOME", $resin_dir, [System.EnvironmentVariableTarget]::Machine)
 #$env:Path += ";$resin_dir\bin"; [Environment]::SetEnvironmentVariable("Path", $env:Path, [System.EnvironmentVariableTarget]::Machine)
 
 # ant
@@ -221,16 +222,6 @@ $maven_dir = "C:\Java\maven"
 Move-Item "$workdir\apache-maven-3.0.5" $maven_dir
 $env:Path += ";$maven_dir\bin"; [Environment]::SetEnvironmentVariable("Path", $env:Path, [System.EnvironmentVariableTarget]::Machine)
 
-# play
-$play_url = "http://downloads.typesafe.com/play/2.1.2-RC1/play-2.1.2-RC1.zip"
-$play_local = "$workdir\play-2.1.2-RC1.zip"
-$play_dir = "C:\Java\play"
-(New-Object System.Net.WebClient).DownloadFile($play_url, $play_local)
-[System.Reflection.Assembly]::LoadWithPartialName("System.IO.Compression.FileSystem") | Out-Null
-[System.IO.Compression.ZipFile]::ExtractToDirectory($play_local, $workdir) | Out-Null
-Move-Item "$workdir\play-2.1.2-RC1" $play_dir
-$env:Path += ";$play_dir"; [Environment]::SetEnvironmentVariable("Path", $env:Path, [System.EnvironmentVariableTarget]::Machine)
-
 #
 # Firewall
 #

lift-stateless/run.bat

@@ -0,0 +1,3 @@
+cd %~dp0\target
+java -server -XX:+CMSClassUnloadingEnabled -Xmx2G -Xss512M -XX:MaxPermSize=512m -jar lift-stateless-assembly-0.0.1.jar > nul 2>&1
+cd %~dp0

lift-stateless/setup.py

@@ -3,19 +3,28 @@ import subprocess
 import sys
 import setup_util
 import os
+import time
 
 def start(args):
   setup_util.replace_text("lift-stateless/src/main/scala/Main.scala", "> \".*:3306", "> \"" + args.database_host + ":3306")
 
-  subprocess.check_call("../sbt/sbt update assembly", shell=True, cwd="lift-stateless")
-  subprocess.Popen("./run", shell=True, cwd="lift-stateless")
+  if os.name == 'nt':
+    subprocess.check_call('"..\\sbt\\sbt.bat" update assembly', shell=True, cwd="lift-stateless")
+    subprocess.Popen(".\\run.bat", shell=True, cwd="lift-stateless")  
+  else:
+    subprocess.check_call("../sbt/sbt update assembly", shell=True, cwd="lift-stateless")
+    subprocess.Popen("./run", shell=True, cwd="lift-stateless")
 
+  time.sleep(5)
   return 0
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if 'lift-stateless-assembly' in line and 'java' in line:
-      pid = int(line.split(None, 2)[1])
-      os.kill(pid, 9)
+  if os.name == 'nt':
+    subprocess.check_call("wmic process where \"CommandLine LIKE '%lift-stateless-assembly%'\" call terminate")
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if 'lift-stateless-assembly' in line and 'java' in line:
+        pid = int(line.split(None, 2)[1])
+        os.kill(pid, 9)
   return 0

netty/setup.py

@@ -11,10 +11,13 @@ def start(args):
   except subprocess.CalledProcessError:
     return 1
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if 'netty-example' in line:
-      pid = int(line.split(None, 2)[1])
-      os.kill(pid, 9)
+  if os.name == 'nt':
+    subprocess.check_call("wmic process where \"CommandLine LIKE '%netty-example%'\" call terminate")
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if 'netty-example' in line:
+        pid = int(line.split(None, 2)[1])
+        os.kill(pid, 9)
   return 0

play-java/setup.py

@@ -3,23 +3,37 @@ import subprocess
 import sys
 import setup_util
 import os
+from zipfile import ZipFile
 
 def start(args):
   setup_util.replace_text("play-java/conf/application.conf", "jdbc:mysql:\/\/.*:3306", "jdbc:mysql://" + args.database_host + ":3306")
   
   subprocess.check_call("play dist", shell=True, cwd="play-java")
-  subprocess.check_call("unzip play-java-1.0-SNAPSHOT.zip", shell=True, cwd="play-java/dist")
-  subprocess.check_call("chmod +x start", shell=True, cwd="play-java/dist/play-java-1.0-SNAPSHOT")
-  subprocess.Popen("./start", shell=True, cwd="play-java/dist/play-java-1.0-SNAPSHOT")
+
+  if os.name == 'nt':
+    ZipFile("./play-java/dist/play-java-1.0-SNAPSHOT.zip").extractall("./play-java/dist")
+    with open("./play-java/dist/play-java-1.0-SNAPSHOT/start.bat", "w+") as f:
+      f.write("java %1 -cp \"./lib/*;\" play.core.server.NettyServer .")
+    subprocess.Popen("start.bat", shell=True, cwd="play-java/dist/play-java-1.0-SNAPSHOT")
+  else:
+    subprocess.check_call("unzip play-java-1.0-SNAPSHOT.zip", shell=True, cwd="play-java/dist")
+    subprocess.check_call("chmod +x start", shell=True, cwd="play-java/dist/play-java-1.0-SNAPSHOT")
+    subprocess.Popen("./start", shell=True, cwd="play-java/dist/play-java-1.0-SNAPSHOT")
 
   return 0
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if './start' in line or ('play' in line and 'java' in line):   
-      pid = int(line.split(None, 2)[1])
+  if os.name == 'nt':
+    with open("./play-java/dist/play-java-1.0-SNAPSHOT/RUNNING_PID") as f:
+      pid = int(f.read())
       os.kill(pid, 9)
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if './start' in line or ('play' in line and 'java' in line):   
+        pid = int(line.split(None, 2)[1])
+        os.kill(pid, 9)
+
   try:
     os.remove("play-java/RUNNING_PID")
   except OSError:

play-scala-mongodb/setup.py

@@ -3,23 +3,37 @@ import subprocess
 import sys
 import setup_util
 import os
+from zipfile import ZipFile
 
 def start(args):
   setup_util.replace_text("play-scala-mongodb/conf/application.conf", "localhost:27017", "" + args.database_host + ":27017")
 
   subprocess.check_call("play dist", shell=True, cwd="play-scala-mongodb")
-  subprocess.check_call("unzip play-scala-mongodb-1.0-SNAPSHOT.zip", shell=True, cwd="play-scala-mongodb/dist")
-  subprocess.check_call("chmod +x start", shell=True, cwd="play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT")
-  subprocess.Popen("./start", shell=True, cwd="play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT")
+  
+  if os.name == 'nt':
+    ZipFile("./play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT.zip").extractall("./play-scala-mongodb/dist")
+    with open("./play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT/start.bat", "w+") as f:
+      f.write("java %1 -cp \"./lib/*;\" play.core.server.NettyServer .")
+    subprocess.Popen("start.bat", shell=True, cwd="play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT")
+  else:
+    subprocess.check_call("unzip play-scala-mongodb-1.0-SNAPSHOT.zip", shell=True, cwd="play-scala-mongodb/dist")
+    subprocess.check_call("chmod +x start", shell=True, cwd="play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT")
+    subprocess.Popen("./start", shell=True, cwd="play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT")
 
   return 0
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if './start' in line or ('play' in line and 'java' in line):
-      pid = int(line.split(None, 2)[1])
+  if os.name == 'nt':
+    with open("./play-scala-mongodb/dist/play-scala-mongodb-1.0-SNAPSHOT/RUNNING_PID") as f:
+      pid = int(f.read())
       os.kill(pid, 9)
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if './start' in line or ('play' in line and 'java' in line):
+        pid = int(line.split(None, 2)[1])
+        os.kill(pid, 9)
+        
   try:
     os.remove("play-scala-mongodb/RUNNING_PID")
   except OSError:

play-scala/setup.py

@@ -3,23 +3,36 @@ import subprocess
 import sys
 import setup_util
 import os
+from zipfile import ZipFile
 
 def start(args):
   setup_util.replace_text("play-scala/conf/application.conf", "jdbc:mysql:\/\/.*:3306", "jdbc:mysql://" + args.database_host + ":3306")
 
   subprocess.check_call("play dist", shell=True, cwd="play-scala")
-  subprocess.check_call("unzip play-scala-1.0-SNAPSHOT.zip", shell=True, cwd="play-scala/dist")
-  subprocess.check_call("chmod +x start", shell=True, cwd="play-scala/dist/play-scala-1.0-SNAPSHOT")
-  subprocess.Popen("./start", shell=True, cwd="play-scala/dist/play-scala-1.0-SNAPSHOT")
+
+  if os.name == 'nt':
+    ZipFile("./play-scala/dist/play-scala-1.0-SNAPSHOT.zip").extractall("./play-scala/dist")
+    with open("./play-scala/dist/play-scala-1.0-SNAPSHOT/start.bat", "w+") as f:
+      f.write("java %1 -cp \"./lib/*;\" play.core.server.NettyServer .")
+    subprocess.Popen("start.bat", shell=True, cwd="play-scala/dist/play-scala-1.0-SNAPSHOT")
+  else:
+    subprocess.check_call("unzip play-scala-1.0-SNAPSHOT.zip", shell=True, cwd="play-scala/dist")
+    subprocess.check_call("chmod +x start", shell=True, cwd="play-scala/dist/play-scala-1.0-SNAPSHOT")
+    subprocess.Popen("./start", shell=True, cwd="play-scala/dist/play-scala-1.0-SNAPSHOT")
 
   return 0
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if './start' in line or ('play' in line and 'java' in line):
-      pid = int(line.split(None, 2)[1])
+  if os.name == 'nt':
+    with open("./play-scala/dist/play-scala-1.0-SNAPSHOT/RUNNING_PID") as f:
+      pid = int(f.read())
       os.kill(pid, 9)
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if './start' in line or ('play' in line and 'java' in line):
+        pid = int(line.split(None, 2)[1])
+        os.kill(pid, 9)
   try:
     os.remove("play-scala/RUNNING_PID")
   except OSError:

play-slick/setup.py

@@ -3,23 +3,37 @@ import subprocess
 import sys
 import setup_util
 import os
+from zipfile import ZipFile
 
 def start(args):
   setup_util.replace_text("play-slick/conf/application.conf", "jdbc:mysql:\/\/.*:3306", "jdbc:mysql://" + args.database_host + ":3306")
 
   subprocess.check_call("play dist", shell=True, cwd="play-slick")
-  subprocess.check_call("unzip play-slick-1.0-SNAPSHOT.zip", shell=True, cwd="play-slick/dist")
-  subprocess.check_call("chmod +x start", shell=True, cwd="play-slick/dist/play-slick-1.0-SNAPSHOT")
-  subprocess.Popen("./start", shell=True, cwd="play-slick/dist/play-slick-1.0-SNAPSHOT")
+
+  if os.name == 'nt':
+    ZipFile("./play-slick/dist/play-slick-1.0-SNAPSHOT.zip").extractall("./play-slick/dist")
+    with open("./play-slick/dist/play-slick-1.0-SNAPSHOT/start.bat", "w+") as f:
+      f.write("java %1 -cp \"./lib/*;\" play.core.server.NettyServer .")
+    subprocess.Popen("start.bat", shell=True, cwd="play-slick/dist/play-slick-1.0-SNAPSHOT")
+  else:
+    subprocess.check_call("unzip play-slick-1.0-SNAPSHOT.zip", shell=True, cwd="play-slick/dist")
+    subprocess.check_call("chmod +x start", shell=True, cwd="play-slick/dist/play-slick-1.0-SNAPSHOT")
+    subprocess.Popen("./start", shell=True, cwd="play-slick/dist/play-slick-1.0-SNAPSHOT")
 
   return 0
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if './start' in line or ('play' in line and 'java' in line):
-      pid = int(line.split(None, 2)[1])
+  if os.name == 'nt':
+    with open("./play-slick/dist/play-slick-1.0-SNAPSHOT/RUNNING_PID") as f:
+      pid = int(f.read())
       os.kill(pid, 9)
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if './start' in line or ('play' in line and 'java' in line):
+        pid = int(line.split(None, 2)[1])
+        os.kill(pid, 9)
+
   try:
     os.remove("play-slick/RUNNING_PID")
   except OSError:

sbt/sbt.bat

@@ -0,0 +1,2 @@
+set SCRIPT_DIR=%~dp0
+java -Xss2M -XX:MaxPermSize=512M -Xmx1536M -XX:+CMSClassUnloadingEnabled -jar "%SCRIPT_DIR%sbt-launch.jar" %*

scalatra/setup.py

@@ -2,21 +2,36 @@
 import subprocess
 import sys
 import setup_util
+import os
+import glob
 
 def start(args):
   setup_util.replace_text("scalatra/src/main/webapp/WEB-INF/resin-web.xml", "mysql:\/\/.*:3306", "mysql://" + args.database_host + ":3306")
 
   try:
-    subprocess.check_call("../sbt/sbt clean package", shell=True, cwd="scalatra")
-    subprocess.check_call("rm -rf $RESIN_HOME/webapps/*", shell=True)
-    subprocess.check_call("cp scalatra/target/scala-2.10/scalatra*.war $RESIN_HOME/webapps/scalatra.war", shell=True)
-    subprocess.check_call("$RESIN_HOME/bin/resinctl start", shell=True)
+    if os.name == 'nt':
+      subprocess.check_call('"..\\sbt\\sbt.bat" clean package', shell=True, cwd="scalatra")
+      subprocess.check_call('rmdir /S /Q "%RESIN_HOME%\\webapps\\"', shell=True)
+      subprocess.check_call('mkdir "%RESIN_HOME%\\webapps\\"', shell=True)
+      
+      # 'copy' on windows doesn't like the wildcard war file selector
+      warFile = glob.glob("scalatra\\target\\scala-2.10\\scalatra*.war")[0]
+      subprocess.check_call('copy "{0}" "%RESIN_HOME%\\webapps\\scalatra.war"'.format(warFile), shell=True)
+      subprocess.check_call('"%RESIN_HOME%\\bin\\start.bat"', shell=True)
+    else:
+      subprocess.check_call("../sbt/sbt clean package", shell=True, cwd="scalatra")
+      subprocess.check_call("rm -rf $RESIN_HOME/webapps/*", shell=True)
+      subprocess.check_call("cp scalatra/target/scala-2.10/scalatra*.war $RESIN_HOME/webapps/scalatra.war", shell=True)
+      subprocess.check_call("$RESIN_HOME/bin/resinctl start", shell=True)
     return 0
   except subprocess.CalledProcessError:
     return 1
 def stop():
   try:
-    subprocess.check_call("$RESIN_HOME/bin/resinctl shutdown", shell=True)
+    if os.name == 'nt':
+      subprocess.check_call('"%RESIN_HOME%\\bin\\stop.bat"', shell=True)
+    else:
+      subprocess.check_call("$RESIN_HOME/bin/resinctl shutdown", shell=True)
     return 0
   except subprocess.CalledProcessError:
     return 1

spray/setup.py

@@ -5,20 +5,27 @@ import time
 import os
 
 def start(args=None):
+  if os.name == 'nt':
+    subprocess.check_call('"..\\sbt\\sbt.bat" assembly', shell=True, cwd="spray")
+  else:
     subprocess.check_call("../sbt/sbt assembly", shell=True, cwd="spray")
-    subprocess.Popen("java -jar target/scala-2.10/spray-benchmark-assembly-1.0.jar", cwd="spray", shell=True)
-    time.sleep(5)
-    return 0
+    
+  subprocess.Popen("java -jar target/scala-2.10/spray-benchmark-assembly-1.0.jar", cwd="spray", shell=True)  
+  time.sleep(5)
+  return 0
 
 def stop():
-  p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
-  out, err = p.communicate()
-  for line in out.splitlines():
-    if 'spray-benchmark' in line:
-      try:
-        pid = int(line.split(None, 2)[1])
-        os.kill(pid, 9)
-      except OSError:
-        pass
+  if os.name == 'nt':
+    subprocess.check_call("wmic process where \"CommandLine LIKE '%spray-benchmark%'\" call terminate")
+  else:
+    p = subprocess.Popen(['ps', 'aux'], stdout=subprocess.PIPE)
+    out, err = p.communicate()
+    for line in out.splitlines():
+      if 'spray-benchmark' in line:
+        try:
+          pid = int(line.split(None, 2)[1])
+          os.kill(pid, 9)
+        except OSError:
+          pass
   
   return 0

spring/setup.py

@@ -2,21 +2,32 @@
 import subprocess
 import sys
 import setup_util
+import os
 
 def start(args):
   setup_util.replace_text("spring/src/main/webapp/WEB-INF/resin-web.xml", "mysql:\/\/.*:3306", "mysql://" + args.database_host + ":3306")
   
   try:
     subprocess.check_call("mvn clean compile war:war", shell=True, cwd="spring")
-    subprocess.check_call("rm -rf $RESIN_HOME/webapps/*", shell=True)
-    subprocess.check_call("cp spring/target/spring.war $RESIN_HOME/webapps/spring.war", shell=True)
-    subprocess.check_call("$RESIN_HOME/bin/resinctl start", shell=True)
+
+    if os.name == 'nt':
+      subprocess.check_call('rmdir /S /Q "%RESIN_HOME%\\webapps\\"', shell=True)
+      subprocess.check_call('mkdir "%RESIN_HOME%\\webapps\\"', shell=True)
+      subprocess.check_call('copy spring\\target\\spring.war "%RESIN_HOME%\\webapps\\spring.war"', shell=True)
+      subprocess.check_call('"%RESIN_HOME%\\bin\\start.bat"', shell=True)
+    else:
+      subprocess.check_call("rm -rf $RESIN_HOME/webapps/*", shell=True)
+      subprocess.check_call("cp spring/target/spring.war $RESIN_HOME/webapps/spring.war", shell=True)
+      setup_utilbprocess.check_call("$RESIN_HOME/bin/resinctl start", shell=True)
     return 0
   except subprocess.CalledProcessError:
     return 1
 def stop():
   try:
-    subprocess.check_call("$RESIN_HOME/bin/resinctl shutdown", shell=True)
+    if os.name == 'nt':
+      subprocess.check_call('"%RESIN_HOME%\\bin\\stop.bat"', shell=True)
+    else:
+      subprocess.check_call("$RESIN_HOME/bin/resinctl shutdown", shell=True)
     return 0
   except subprocess.CalledProcessError:
     return 1