added java_process module to allow start java app from node and communicate through stdin and stderr

abner · abner · commit 57f7af4647c2 · 2016-02-06T02:33:11.000-03:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1 @@
+node_modules
diff --git a/java/EchoMessage.class b/java/EchoMessage.class
diff --git a/java/EchoMessage.jar b/java/EchoMessage.jar
diff --git a/java/EchoMessage.java b/java/EchoMessage.java
@@ -0,0 +1,15 @@
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+
+class EchoMessage {
+    public static void main(String[] args) throws Exception{
+        System.out.println("READY");
+        while(true) {
+            BufferedReader buffer=new BufferedReader(new InputStreamReader(System.in));
+            String line=buffer.readLine();
+            System.out.println("Echo: " + line);
+        }
+        
+    }
+}
diff --git a/java/MANIFEST.MF b/java/MANIFEST.MF
@@ -0,0 +1,4 @@
+Manifest-Version: 1.0
+ImplementationVersion: 0.0.1
+Main-Class: EchoMessage
+
diff --git a/package.json b/package.json
@@ -0,0 +1,15 @@
+{
+  "name": "node-java-ipc",
+  "version": "1.0.0",
+  "description": "Node to Java Ipc using stdin, stdout and stderr, using a small and simple protocol allowing node to interact with java",
+  "main": "js/index.js",
+  "scripts": {
+    "build": "tsc",
+    "test": "tsc && node src/js/test.js"
+  },
+  "author": "Abner Oliveira",
+  "license": "MIT",
+  "dependencies": {
+    "shelljs": "^0.6.0"
+  }
+}
diff --git a/src/js/index.d.ts b/src/js/index.d.ts
diff --git a/src/js/index.js b/src/js/index.js
@@ -0,0 +1,16 @@
+var shelljs = require("shelljs");
+var javaLocation = shelljs.which("java");
+if (!javaLocation) {
+    throw new Error("Java executable not found. Check if java is installed and present in PATH environment variable");
+}
+var result = shelljs.exec("java -version");
+var javaVersion = null;
+if (result.code === 0) {
+    console.log("Java version result: ", result);
+    console.log(result.output);
+    var match = result.stderr.match(/(?!\.)(\d+(\.\d+)+)(?![\d\.])/);
+    if (match.length > 0) {
+        javaVersion = match[0];
+    }
+    console.log("JAVA VERSION: ", javaVersion);
+}
diff --git a/src/js/java_process.d.ts b/src/js/java_process.d.ts
@@ -0,0 +1,5 @@
+export declare function start(jarPath: string, args?: string[]): {
+    javaLocation: string;
+    javaVersion: String;
+    process: any;
+};
diff --git a/src/js/java_process.js b/src/js/java_process.js
@@ -0,0 +1,31 @@
+var shelljs = require("shelljs");
+function start(jarPath, args) {
+    var javaLocation = shelljs.which("java");
+    if (!javaLocation) {
+        throw new Error("Java executable not found. Check if java is installed and present in PATH environment variable");
+    }
+    var result = shelljs.exec("java -version");
+    var javaVersion = null;
+    if (result.code === 0) {
+        var match = result.stderr.match(/(?!\.)(\d+(\.\d+)+)(?![\d\.])/);
+        if (match.length > 0) {
+            javaVersion = match[0];
+        }
+        console.log("JAVA VERSION: ", javaVersion);
+    }
+    else {
+        throw new Error("Error extracting java version");
+    }
+    var spawn = require("child_process").spawn;
+    var argsJava = ["-jar", jarPath];
+    if (args) {
+        argsJava = argsJava.concat(args);
+    }
+    var child = spawn("java", argsJava);
+    return {
+        javaLocation: javaLocation,
+        javaVersion: javaVersion,
+        process: child
+    };
+}
+exports.start = start;
diff --git a/src/js/test.d.ts b/src/js/test.d.ts
diff --git a/src/js/test.js b/src/js/test.js
@@ -0,0 +1,43 @@
+var java_process = require("./java_process");
+var javaStartedProcess = java_process.start('java/EchoMessage.jar');
+console.log("Java Location", javaStartedProcess.javaLocation);
+console.log("Java Version", javaStartedProcess.javaVersion);
+var ok = false;
+var childProc = javaStartedProcess.process;
+childProc.stderr.on('data', function (err) {
+    console.error("ERROR", String(err));
+    process.exit(1);
+});
+childProc.on("error", function (payload) {
+    console.error("ERROR", String(payload));
+    process.exit(1);
+});
+childProc.on('close', function (code) {
+    console.log("child process exited with code " + code);
+});
+function sendMessage() {
+    javaStartedProcess.process.stdin.write("TEST\n");
+}
+javaStartedProcess.process.stdout.on('data', function (buffer) {
+    if (String(buffer) == 'READY') {
+        console.log("DATA FROM PROCESS OUTPUT >> ", String(buffer));
+        sendMessage();
+    }
+    else {
+        var msg = String(buffer);
+        console.log("Process Echoed this Message > ", msg);
+        if (msg == "Echo: TEST") {
+            console.info("Test OK");
+            process.exit(0);
+        }
+    }
+});
+setTimeout(function () {
+    if (ok) {
+        console.log("Execution is OK");
+        process.exit(0);
+    }
+    else {
+        console.log("Test failed!");
+    }
+}, 5000);
diff --git a/src/typescript/java_process.ts b/src/typescript/java_process.ts
@@ -0,0 +1,51 @@
+import * as child_process from "child_process";
+import * as shelljs from "shelljs";
+
+
+
+export function start(jarPath: string, args?: string[]) {
+
+
+    var javaLocation = shelljs.which("java");
+
+
+    if (!javaLocation) {
+        throw new Error("Java executable not found. Check if java is installed and present in PATH environment variable");
+    }
+
+
+    var result = shelljs.exec("java -version");
+
+
+    let javaVersion: String = null;
+
+    if (result.code === 0) {
+        let match: RegExpMatchArray = (<any>result).stderr.match(/(?!\.)(\d+(\.\d+)+)(?![\d\.])/);
+
+        if (match.length > 0) {
+            javaVersion = match[0];
+        }
+
+        console.log("JAVA VERSION: ", javaVersion);
+    } else {
+        throw new Error("Error extracting java version");
+    }
+
+    var spawn = require("child_process").spawn;
+    
+    var argsJava = ["-jar", jarPath];
+    if(args) {
+        argsJava = argsJava.concat(args)
+    }
+    var child = spawn("java", argsJava);
+
+
+    return {
+        javaLocation: javaLocation,
+        javaVersion: javaVersion,
+        process: child
+    }
+
+    //
+
+}
diff --git a/src/typescript/test.ts b/src/typescript/test.ts
@@ -0,0 +1,60 @@
+
+
+import * as java_process from "./java_process";
+
+var javaStartedProcess = java_process.start('java/EchoMessage.jar');
+
+console.log("Java Location", javaStartedProcess.javaLocation);
+console.log("Java Version", javaStartedProcess.javaVersion);
+
+var ok = false;
+
+import {ChildProcess} from "child_process";
+
+var childProc: ChildProcess = javaStartedProcess.process;
+
+childProc.stderr.on('data', (err: any) => {
+    console.error("ERROR", String(err));
+    process.exit(1); 
+});
+childProc.on("error", (payload: any) => {
+    console.error("ERROR",String(payload));
+    process.exit(1);
+});
+
+childProc.on('close', (code: any) => {
+  console.log(`child process exited with code ${code}`);
+});
+
+function sendMessage() {
+    javaStartedProcess.process.stdin.write("TEST\n");
+}
+
+javaStartedProcess.process.stdout.on('data', (buffer: string) => {
+    if (String(buffer) == 'READY') {
+        console.log("DATA FROM PROCESS OUTPUT >> ", String(buffer));
+        sendMessage();
+    } else {
+        var msg = String(buffer);
+        console.log("Process Echoed this Message > ", msg);
+        
+        if(msg == "Echo: TEST") {
+          console.info("Test OK");
+          process.exit(0);  
+        }
+        //console.info("Test OK");
+        //process.exit(0);
+        
+    }
+
+});
+
+
+setTimeout(function() {
+        if (ok) {
+            console.log("Execution is OK");
+            process.exit(0);
+        } else {
+            console.log("Test failed!");
+        }
+    }, 5000);
diff --git a/tsconfig.json b/tsconfig.json
@@ -0,0 +1,16 @@
+{
+  "compilerOptions": {
+    "target": "es5",
+    "rootDir": "src/typescript",
+    "outDir": "src/js",
+    "module": "commonjs",
+    "declaration": true,
+    "noImplicitAny": true,
+    "removeComments": true,
+    "moduleResolution": "node"
+  },
+  "exclude": [
+      "node_modules"
+  ]
+  
+}
diff --git a/typings.json b/typings.json
@@ -0,0 +1,6 @@
+{
+  "ambientDependencies": {
+    "node": "github:DefinitelyTyped/DefinitelyTyped/node/node.d.ts#1c56e368e17bb28ca57577250624ca5bd561aa81",
+    "shelljs": "github:DefinitelyTyped/DefinitelyTyped/shelljs/shelljs.d.ts#ce14ae27a020194da3d35aa3468ca1e9e5296316"
+  }
+}
diff --git a/typings/main.d.ts b/typings/main.d.ts
@@ -0,0 +1,2 @@
+/// <reference path="main/ambient/node/node.d.ts" />
+/// <reference path="main/ambient/shelljs/shelljs.d.ts" />
diff --git a/typings/main/ambient/node/node.d.ts b/typings/main/ambient/node/node.d.ts
diff --git a/typings/main/ambient/shelljs/shelljs.d.ts b/typings/main/ambient/shelljs/shelljs.d.ts
