add support for windows environment

README.md

@@ -12,7 +12,7 @@ This plugin runs a command and reads data from its stdout (or stderr).
 - **command**: command line (string, required)
 - **pipe**: stdout or stderr (string, default: stdout)
 
-The **command** is exected using a shell. So it can include pipe (`|`), environment variables (`$VAR`), redirects, and so on.
+The **command** is exected using a shell (`sh -c` on UNIX/Linux, `PowerShell.exe -Command` on Windows). Therefore, it can include pipe (`|`), environment variables (`$VAR`), redirects, and so on.
 
 ## Example
 

build.gradle

@@ -15,8 +15,9 @@ configurations {
 version = "0.1.3"
 
 dependencies {
-    compile  "org.embulk:embulk-core:0.7.0"
-    provided "org.embulk:embulk-core:0.7.0"
+    compile  "org.embulk:embulk-core:0.7.+"
+    provided "org.embulk:embulk-core:0.7.+"
+    testCompile 'org.embulk:embulk-core:0.7.+:tests'
     testCompile "junit:junit:4.+"
 }
 

src/main/java/org/embulk/input/CommandFileInputPlugin.java

@@ -5,6 +5,7 @@
 import java.io.InputStream;
 import java.io.IOException;
 import java.io.FilterInputStream;
+import com.google.common.annotations.VisibleForTesting;
 import org.slf4j.Logger;
 import com.google.common.base.Optional;
 import com.google.common.collect.ImmutableList;
@@ -88,7 +89,7 @@ public TransactionalFileInput open(TaskSource taskSource, int taskIndex)
         PluginTask task = taskSource.loadTask(PluginTask.class);
 
         List<String> cmdline = new ArrayList<String>();
-        cmdline.addAll(SHELL);
+        cmdline.addAll(buildShell());
         cmdline.add(task.getCommand());
 
         logger.info("Running command {}", cmdline);
@@ -131,6 +132,17 @@ public TransactionalFileInput open(TaskSource taskSource, int taskIndex)
         }
     }
 
+    @VisibleForTesting
+    static List<String> buildShell()
+    {
+        String osName = System.getProperty("os.name");
+        if(osName.indexOf("Windows") >= 0) {
+            return ImmutableList.of("PowerShell.exe", "-Command");
+        } else {
+            return ImmutableList.of("sh", "-c");
+        }
+    }
+
     private static class ProcessWaitInputStream
             extends FilterInputStream
     {

src/test/java/org/embulk/input/TestCommandFileInputPlugin.java

@@ -1,5 +1,28 @@
 package org.embulk.input;
 
+import com.google.common.collect.ImmutableList;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.embulk.EmbulkTestRuntime;
+import static org.embulk.input.CommandFileInputPlugin.buildShell;
+
+import java.util.List;
+
+import static org.junit.Assert.assertEquals;
+
 public class TestCommandFileInputPlugin
 {
+    @Rule
+    public EmbulkTestRuntime runtime = new EmbulkTestRuntime();
+
+    @Test
+    public void testShell() {
+        if (System.getProperty("os.name").indexOf("Windows") >= 0) {
+            assertEquals(ImmutableList.of("PowerShell.exe", "-Command"), buildShell());
+        }
+        else {
+            assertEquals(ImmutableList.of("sh", "-c"), buildShell());
+        }
+    }
 }