Merge pull request #163 from windard/add_java_asynchttp

add java async http client

Author: reynolek

src/targets/java/asynchttp.js

@@ -0,0 +1,55 @@
+/**
+ * @description
+ * Asynchronous Http and WebSocket Client library for Java
+ *
+ * @author
+ * @windard
+ *
+ * for any questions or issues regarding the generated code snippet, please open an issue mentioning the author.
+ */
+
+'use strict'
+
+var CodeBuilder = require('../../helpers/code-builder')
+
+module.exports = function (source, options) {
+  var opts = Object.assign({
+    indent: '  '
+  }, options)
+
+  var code = new CodeBuilder(opts.indent)
+
+  code.push('AsyncHttpClient client = new DefaultAsyncHttpClient();')
+
+  code.push(`client.prepare${source.method[0].toUpperCase()}${source.method.substring(1).toLowerCase()}("${source.fullUrl}")`)
+
+  // Add headers, including the cookies
+  var headers = Object.keys(source.allHeaders)
+
+  // construct headers
+  if (headers.length) {
+    headers.forEach(function (key) {
+      code.push(1, '.setHeader("%s", "%s")', key, source.allHeaders[key])
+    })
+  }
+
+  if (source.postData.text) {
+    code.push(1, '.setBody(%s)', JSON.stringify(source.postData.text))
+  }
+
+  code.push(1, '.execute()')
+  code.push(1, '.toCompletableFuture()')
+  code.push(1, '.thenAccept(System.out::println)')
+  code.push(1, '.join();')
+  code.blank()
+  code.push('client.close();')
+
+  return code.join()
+}
+
+module.exports.info = {
+  key: 'asynchttp',
+  title: 'AsyncHttp',
+  link: 'https://github.com/AsyncHttpClient/async-http-client',
+  description: 'Asynchronous Http and WebSocket Client library for Java'
+}

src/targets/java/index.js

@@ -9,5 +9,7 @@ module.exports = {
   },
 
   okhttp: require('./okhttp'),
-  unirest: require('./unirest')
+  unirest: require('./unirest'),
+  asynchttp: require('./asynchttp')
+
 }

test/fixtures/available-targets.json

@@ -196,6 +196,12 @@
         "title": "Unirest",
         "link": "http://unirest.io/java.html",
         "description": "Lightweight HTTP Request Client Library"
+      },
+      {
+        "key": "asynchttp",
+        "title": "AsyncHttp",
+        "link": "https://github.com/AsyncHttpClient/async-http-client",
+        "description": "Asynchronous Http and WebSocket Client library for Java"
       }
     ]
   },

test/fixtures/output/java/asynchttp/application-form-encoded.java

@@ -0,0 +1,10 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.preparePost("http://mockbin.com/har")
+  .setHeader("content-type", "application/x-www-form-urlencoded")
+  .setBody("foo=bar&hello=world")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();

test/fixtures/output/java/asynchttp/application-json.java

@@ -0,0 +1,10 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.preparePost("http://mockbin.com/har")
+  .setHeader("content-type", "application/json")
+  .setBody("{\"number\":1,\"string\":\"f\\\"oo\",\"arr\":[1,2,3],\"nested\":{\"a\":\"b\"},\"arr_mix\":[1,\"a\",{\"arr_mix_nested\":{}}],\"boolean\":false}")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();

test/fixtures/output/java/asynchttp/cookies.java

@@ -0,0 +1,9 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.preparePost("http://mockbin.com/har")
+  .setHeader("cookie", "foo=bar; bar=baz")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();

test/fixtures/output/java/asynchttp/custom-method.java

@@ -0,0 +1,8 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.preparePropfind("http://mockbin.com/har")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();

test/fixtures/output/java/asynchttp/full.java

@@ -0,0 +1,12 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.preparePost("http://mockbin.com/har?foo=bar&foo=baz&baz=abc&key=value")
+  .setHeader("cookie", "foo=bar; bar=baz")
+  .setHeader("accept", "application/json")
+  .setHeader("content-type", "application/x-www-form-urlencoded")
+  .setBody("foo=bar")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();

test/fixtures/output/java/asynchttp/headers.java

@@ -0,0 +1,10 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.prepareGet("http://mockbin.com/har")
+  .setHeader("accept", "application/json")
+  .setHeader("x-foo", "Bar")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();

test/fixtures/output/java/asynchttp/https.java

@@ -0,0 +1,8 @@
+AsyncHttpClient client = new DefaultAsyncHttpClient();
+client.prepareGet("https://mockbin.com/har")
+  .execute()
+  .toCompletableFuture()
+  .thenAccept(System.out::println)
+  .join();
+
+client.close();