mirror of
https://github.com/foss42/apidash.git
synced 2025-07-15 00:52:22 +08:00
Merge branch 'main' into codegen_java_httpclient
This commit is contained in:
Ankit Mahato
189
lib/codegen/java/async_http_client.dart
Normal file
189
lib/codegen/java/async_http_client.dart
Normal file
@ -0,0 +1,189 @@
|
||||
import 'dart:convert';
|
||||
import 'package:apidash/utils/har_utils.dart';
|
||||
import 'package:apidash/utils/http_utils.dart';
|
||||
import 'package:jinja/jinja.dart' as jj;
|
||||
import 'package:apidash/models/models.dart' show RequestModel;
|
||||
import 'package:apidash/consts.dart';
|
||||
|
||||
class JavaAsyncHttpClientGen {
|
||||
final String kTemplateStart = '''
|
||||
import org.asynchttpclient.*;
|
||||
|
||||
import java.io.BufferedReader;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.InputStreamReader;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.util.concurrent.ExecutionException;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
public class Main {
|
||||
public static void main(String[] args) {
|
||||
try (AsyncHttpClient asyncHttpClient = Dsl.asyncHttpClient()) {
|
||||
''';
|
||||
|
||||
final String kTemplateUrl = '''
|
||||
String url = "{{url}}";\n
|
||||
''';
|
||||
|
||||
final String kTemplateRequestCreation = '''
|
||||
Request request = asyncHttpClient
|
||||
.prepare("{{method}}", url)\n
|
||||
''';
|
||||
|
||||
final String kTemplateUrlQueryParam = '''
|
||||
.addQueryParam("{{name}}", "{{value}}")\n
|
||||
''';
|
||||
|
||||
final String kTemplateRequestHeader = '''
|
||||
.addHeader("{{name}}", "{{value}}")\n
|
||||
''';
|
||||
final String kTemplateRequestFormData = '''
|
||||
.addFormParam("{{name}}", "{{value}}")\n
|
||||
''';
|
||||
|
||||
String kTemplateRequestBodyContent = '''
|
||||
String bodyContent = "{{body}}";\n
|
||||
''';
|
||||
String kTemplateRequestBodySetup = '''
|
||||
.setBody(bodyContent)\n
|
||||
''';
|
||||
|
||||
final String kTemplateRequestEnd = """
|
||||
.build();
|
||||
ListenableFuture<Response> listenableFuture = asyncHttpClient.executeRequest(request);
|
||||
listenableFuture.addListener(() -> {
|
||||
try {
|
||||
Response response = listenableFuture.get();
|
||||
InputStream is = response.getResponseBodyAsStream();
|
||||
BufferedReader br = new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8));
|
||||
String respBody = br.lines().collect(Collectors.joining("\\n"));
|
||||
System.out.println(response.getStatusCode());
|
||||
System.out.println(respBody);
|
||||
} catch (InterruptedException | ExecutionException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}, Executors.newCachedThreadPool());
|
||||
listenableFuture.get();
|
||||
} catch (InterruptedException | ExecutionException | IOException ignored) {
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
\n
|
||||
""";
|
||||
|
||||
String? getCode(
|
||||
RequestModel requestModel,
|
||||
) {
|
||||
try {
|
||||
String result = "";
|
||||
bool hasBody = false;
|
||||
|
||||
var rec = getValidRequestUri(
|
||||
requestModel.url,
|
||||
requestModel.enabledRequestParams,
|
||||
);
|
||||
Uri? uri = rec.$1;
|
||||
|
||||
if (uri == null) {
|
||||
return "";
|
||||
}
|
||||
|
||||
var url = stripUriParams(uri);
|
||||
|
||||
// contains the HTTP method associated with the request
|
||||
var method = requestModel.method;
|
||||
|
||||
// contains the entire request body as a string if body is present
|
||||
var requestBody = requestModel.requestBody;
|
||||
|
||||
// generating the URL to which the request has to be submitted
|
||||
var templateUrl = jj.Template(kTemplateUrl);
|
||||
result += templateUrl.render({"url": url});
|
||||
|
||||
// creating request body if available
|
||||
var rM = requestModel.copyWith(url: url);
|
||||
var harJson = requestModelToHARJsonRequest(rM, useEnabled: true);
|
||||
|
||||
// if request type is not form data, the request method can include
|
||||
// a body, and the body of the request is not null, in that case
|
||||
// we need to parse the body as it is, and write it to the body
|
||||
if (!requestModel.hasFormData &&
|
||||
kMethodsWithBody.contains(method) &&
|
||||
requestBody != null) {
|
||||
var contentLength = utf8.encode(requestBody).length;
|
||||
if (contentLength > 0) {
|
||||
var templateBodyContent = jj.Template(kTemplateRequestBodyContent);
|
||||
hasBody = true;
|
||||
if (harJson["postData"]?["text"] != null) {
|
||||
result += templateBodyContent.render({
|
||||
"body": kEncoder.convert(harJson["postData"]["text"]).substring(
|
||||
1, kEncoder.convert(harJson["postData"]["text"]).length - 1)
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
var templateRequestCreation = jj.Template(kTemplateRequestCreation);
|
||||
result +=
|
||||
templateRequestCreation.render({"method": method.name.toUpperCase()});
|
||||
|
||||
// setting up query parameters
|
||||
if (uri.hasQuery) {
|
||||
var params = uri.queryParameters;
|
||||
var templateUrlQueryParam = jj.Template(kTemplateUrlQueryParam);
|
||||
params.forEach((name, value) {
|
||||
result +=
|
||||
templateUrlQueryParam.render({"name": name, "value": value});
|
||||
});
|
||||
}
|
||||
|
||||
result = kTemplateStart + result;
|
||||
|
||||
var contentType = requestModel.requestBodyContentType.header;
|
||||
var templateRequestHeader = jj.Template(kTemplateRequestHeader);
|
||||
|
||||
// especially sets up Content-Type header if the request has a body
|
||||
// and Content-Type is not explicitely set by the developer
|
||||
if (hasBody &&
|
||||
!requestModel.enabledHeadersMap.containsKey('Content-Type')) {
|
||||
result += templateRequestHeader
|
||||
.render({"name": 'Content-Type', "value": contentType});
|
||||
}
|
||||
|
||||
// setting up rest of the request headers
|
||||
var headers = requestModel.enabledHeadersMap;
|
||||
headers.forEach((name, value) {
|
||||
result += templateRequestHeader.render({"name": name, "value": value});
|
||||
});
|
||||
|
||||
// handling form data
|
||||
if (requestModel.hasFormData &&
|
||||
requestModel.formDataMapList.isNotEmpty &&
|
||||
kMethodsWithBody.contains(method)) {
|
||||
// including form data into the request
|
||||
var formDataList = requestModel.formDataMapList;
|
||||
var templateRequestFormData = jj.Template(kTemplateRequestFormData);
|
||||
for (var formDataMap in formDataList) {
|
||||
result += templateRequestFormData.render(
|
||||
{"name": formDataMap['name'], "value": formDataMap['value']});
|
||||
}
|
||||
hasBody = true;
|
||||
}
|
||||
|
||||
var templateRequestBodySetup = jj.Template(kTemplateRequestBodySetup);
|
||||
if (kMethodsWithBody.contains(method) && hasBody) {
|
||||
result += templateRequestBodySetup.render();
|
||||
}
|
||||
|
||||
var templateRequestBodyEnd = jj.Template(kTemplateRequestEnd);
|
||||
result += templateRequestBodyEnd.render();
|
||||
|
||||
return result;
|
||||
} catch (e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
||||
190
lib/codegen/java/okhttp.dart
Normal file
190
lib/codegen/java/okhttp.dart
Normal file
@ -0,0 +1,190 @@
|
||||
import 'dart:convert';
|
||||
import 'package:jinja/jinja.dart' as jj;
|
||||
import 'package:apidash/utils/utils.dart'
|
||||
show getValidRequestUri, stripUriParams;
|
||||
import '../../models/request_model.dart';
|
||||
import 'package:apidash/consts.dart';
|
||||
|
||||
class JavaOkHttpCodeGen {
|
||||
final String kTemplateStart = """
|
||||
import okhttp3.OkHttpClient;
|
||||
import okhttp3.Request;
|
||||
import okhttp3.Response;{{importForQuery}}{{importForBody}}{{importForFormData}}
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
public class Main {
|
||||
public static void main(String[] args) {
|
||||
OkHttpClient client = new OkHttpClient().newBuilder().build();
|
||||
|
||||
""";
|
||||
|
||||
final String kStringImportForQuery = """
|
||||
|
||||
import okhttp3.HttpUrl;""";
|
||||
|
||||
final String kStringImportForBody = """
|
||||
|
||||
import okhttp3.RequestBody;
|
||||
import okhttp3.MediaType;""";
|
||||
|
||||
final String kStringImportForFormData = """
|
||||
|
||||
import okhttp3.RequestBody;
|
||||
import okhttp3.MultipartBody;""";
|
||||
|
||||
final String kTemplateUrl = '''
|
||||
|
||||
String url = "{{url}}";
|
||||
|
||||
''';
|
||||
|
||||
final String kTemplateUrlQuery = '''
|
||||
|
||||
HttpUrl url = HttpUrl.parse("{{url}}").newBuilder()
|
||||
{{params}}
|
||||
.build();
|
||||
|
||||
''';
|
||||
|
||||
String kTemplateRequestBody = '''
|
||||
|
||||
MediaType mediaType = MediaType.parse("{{contentType}}");
|
||||
|
||||
RequestBody body = RequestBody.create({{body}}, mediaType);
|
||||
|
||||
''';
|
||||
|
||||
final String kStringRequestStart = """
|
||||
|
||||
Request request = new Request.Builder()
|
||||
.url(url)
|
||||
""";
|
||||
|
||||
final String kTemplateRequestEnd = """
|
||||
.{{method}}({{hasBody}})
|
||||
.build();
|
||||
|
||||
try (Response response = client.newCall(request).execute()) {
|
||||
System.out.println(response.code());
|
||||
if (response.body() != null) {
|
||||
System.out.println(response.body().string());
|
||||
}
|
||||
} catch (IOException e) {
|
||||
System.out.println(e.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
""";
|
||||
// Converting list of form data objects to kolin multi part data
|
||||
String kFormDataBody = '''
|
||||
RequestBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
|
||||
{%- for item in formDataList -%}
|
||||
{% if item.type == 'file' %}
|
||||
.addFormDataPart("{{ item.name }}",null,RequestBody.create(MediaType.parse("application/octet-stream"),new File("{{ item.value }}")))
|
||||
{%- else %}
|
||||
.addFormDataPart("{{ item.name }}","{{ item.value }}")
|
||||
{%- endif %}
|
||||
{%- endfor %}
|
||||
.build();
|
||||
|
||||
''';
|
||||
|
||||
String? getCode(
|
||||
RequestModel requestModel,
|
||||
) {
|
||||
try {
|
||||
String result = "";
|
||||
bool hasQuery = false;
|
||||
bool hasBody = false;
|
||||
bool hasFormData = false;
|
||||
|
||||
var rec = getValidRequestUri(
|
||||
requestModel.url,
|
||||
requestModel.enabledRequestParams,
|
||||
);
|
||||
Uri? uri = rec.$1;
|
||||
|
||||
if (uri != null) {
|
||||
String url = stripUriParams(uri);
|
||||
|
||||
if (uri.hasQuery) {
|
||||
var params = uri.queryParameters;
|
||||
if (params.isNotEmpty) {
|
||||
hasQuery = true;
|
||||
var templateParams = jj.Template(kTemplateUrlQuery);
|
||||
result += templateParams
|
||||
.render({"url": url, "params": getQueryParams(params)});
|
||||
}
|
||||
}
|
||||
if (!hasQuery) {
|
||||
var templateUrl = jj.Template(kTemplateUrl);
|
||||
result += templateUrl.render({"url": url});
|
||||
}
|
||||
|
||||
var method = requestModel.method;
|
||||
var requestBody = requestModel.requestBody;
|
||||
if (requestModel.hasFormData) {
|
||||
hasFormData = true;
|
||||
var formDataTemplate = jj.Template(kFormDataBody);
|
||||
|
||||
result += formDataTemplate.render({
|
||||
"formDataList": requestModel.formDataMapList,
|
||||
});
|
||||
} else if (kMethodsWithBody.contains(method) && requestBody != null) {
|
||||
var contentLength = utf8.encode(requestBody).length;
|
||||
if (contentLength > 0) {
|
||||
hasBody = true;
|
||||
String contentType = requestModel.requestBodyContentType.header;
|
||||
var templateBody = jj.Template(kTemplateRequestBody);
|
||||
result += templateBody.render({
|
||||
"contentType": contentType,
|
||||
"body": kEncoder.convert(requestBody)
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
var templateStart = jj.Template(kTemplateStart);
|
||||
var stringStart = templateStart.render({
|
||||
"importForQuery": hasQuery ? kStringImportForQuery : "",
|
||||
"importForBody": hasBody ? kStringImportForBody : "",
|
||||
"importForFormData": hasFormData ? kStringImportForFormData : ""
|
||||
});
|
||||
|
||||
result = stringStart + result;
|
||||
result += kStringRequestStart;
|
||||
|
||||
var headersList = requestModel.enabledRequestHeaders;
|
||||
if (headersList != null) {
|
||||
var headers = requestModel.enabledHeadersMap;
|
||||
if (headers.isNotEmpty) {
|
||||
result += getHeaders(headers);
|
||||
}
|
||||
}
|
||||
|
||||
var templateRequestEnd = jj.Template(kTemplateRequestEnd);
|
||||
result += templateRequestEnd.render({
|
||||
"method": method.name.toLowerCase(),
|
||||
"hasBody": (hasBody || requestModel.hasFormData) ? "body" : "",
|
||||
});
|
||||
}
|
||||
return result;
|
||||
} catch (e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
String getQueryParams(Map<String, String> params) {
|
||||
final paramStrings = params.entries.map((entry) => '.addQueryParameter("${entry.key}", "${entry.value}")').toList();
|
||||
return paramStrings.join('\n ');
|
||||
}
|
||||
|
||||
String getHeaders(Map<String, String> headers) {
|
||||
String result = "";
|
||||
for (final k in headers.keys) {
|
||||
result = """$result .addHeader("$k", "${headers[k]}")\n""";
|
||||
}
|
||||
return result;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user