Amazon API Gateway Importer整合过程小结

"x-amazon-apigateway-auth" : {
    "type" : "aws_iam"
},
"x-amazon-apigateway-integration" : {
   "type" : "aws",
   "uri" : "arn:aws:apigateway:us-east-1:lambda:path/2015-03-31/functions/arn:aws:lambda:us-east-1:MY_ACCT_ID:function:helloWorld/invocations",
   "httpMethod" : "POST",
   "credentials" : "arn:aws:iam::MY_ACCT_ID:role/lambda_exec_role",
   "requestTemplates" : {
       "application/json" : "json request template 2",
       "application/xml" : "xml request template 2"
   },
   "requestParameters" : {
       "integration.request.path.integrationPathParam" : "method.request.querystring.latitude",
       "integration.request.querystring.integrationQueryParam" : "method.request.querystring.longitude"
   },
   "cacheNamespace" : "cache-namespace",
   "cacheKeyParameters" : [],
   "responses" : {
       "2\\d{2}" : {
           "statusCode" : "200",
           "responseParameters" : {
               "method.response.header.test-method-response-header" : "integration.response.header.integrationResponseHeaderParam1"
           },
           "responseTemplates" : {
               "application/json" : "json 200 response template",
               "application/xml" : "xml 200 response template"
           }
       },
       "default" : {
           "statusCode" : "400",
           "responseParameters" : {
               "method.response.header.test-method-response-header" : "'static value'"
           },
           "responseTemplates" : {
               "application/json" : "json 400 response template",
               "application/xml" : "xml 400 response template"
           }
       }
   }
}

However, I am currently stuck at using the @Extension/@ExtenstionProperty to reflect the correct json for requestTemplates and requestParameters attributes.
Both of them contain multiple name/value attributes rather than a simple name/value pair.
@Extension doesn't allow child @Extension.

import io.swagger.models.Operation;
import io.swagger.models.Path;
import io.swagger.models.Swagger;
import io.swagger.models.parameters.HeaderParameter;
import io.swagger.models.parameters.Parameter;
import io.swagger.models.parameters.QueryParameter;
import io.swagger.parser.SwaggerParser;
import io.swagger.util.Json;
import org.apache.commons.io.FileUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.IOException;
import java.nio.file.Paths;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import static java.lang.String.format;


@Component
public class AwsConverterUtils {
    private static final Logger LOGGER = LoggerFactory.getLogger(AwsConverterUtils.class);

    private static final String EXTENSION_INTEGRATION = "x-amazon-apigateway-integration";

    public String fillApiGatewayIntegration(String filePath) throws IOException {
        LOGGER.info("Attempting to create API from Swagger definition.Swagger file: {}", filePath);

        Swagger swagger = parse(filePath);
        Map<String, Path> originalPaths = swagger.getPaths();
        Map<String, Path> newPaths = new HashMap<>(originalPaths);
        swagger.setPaths(newPaths);
        Iterator<Map.Entry<String, Path>> iterator = originalPaths.entrySet().iterator();

        while (iterator.hasNext()) {
            Map.Entry<String, Path> next = iterator.next();
            //path的Key是RequestPath,value  path是各种Operation(get,post等相关操作的集合)
            Path path = next.getValue();
            String appRequestPath = next.getKey();
            LOGGER.info("requestPath:" + appRequestPath);

            //处理每个path中的数据，根据规则把aws需要的数据 填充上去
//            x-amazon-apigateway-integration
            String finalAppRequestPath = appRequestPath;
            Map<String, Operation> ops = getOperations(path);
            ops.entrySet().forEach(x -> {
                generateXAmazon(finalAppRequestPath, x.getKey(), x.getValue());
                LOGGER.info(format("with method %s", x.getKey()));
            });
        }
        String data = Json.pretty(swagger);

        String parent = Paths.get(filePath).getParent().toString();
        LOGGER.info("The file directory:" + parent);
        File awsSwaggerJson = new File(parent, "awsApiGatewaySwagger.json");
        FileUtils.write(awsSwaggerJson, data, "UTF-8");
        return awsSwaggerJson.getAbsolutePath();
    }


    private Map<String, Operation> getOperations(Path path) {
        final Map<String, Operation> ops = new HashMap<>();

        addOp(ops, "get", path.getGet());
        addOp(ops, "post", path.getPost());
        addOp(ops, "put", path.getPut());
        addOp(ops, "delete", path.getDelete());
        addOp(ops, "options", path.getOptions());
        addOp(ops, "patch", path.getPatch());

        return ops;
    }

    private void addOp(Map<String, Operation> ops, String method, Operation operation) {
        if (operation != null) {
            ops.put(method, operation);
        }
    }

    private Swagger parse(String filePath) {
        final Swagger swagger = new SwaggerParser().read(filePath);

        if (swagger != null && swagger.getPaths() != null) {
            LOGGER.info("Parsed Swagger with " + swagger.getPaths().size() + " paths");
        }
        return swagger;
    }


    private void generateXAmazon(String appRequestPath, String requestMethod, Operation op) {
        //检查是否需要v参数,项目中需要包含v的输入，有些接口入参没有入参，因此就没有这个参数
        List<Parameter> opParameters = op.getParameters();
        Map<String, Object> vendorExtensions = op.getVendorExtensions();
        Map<String, Object> integ;
        if (vendorExtensions.containsKey(EXTENSION_INTEGRATION)) {
            integ = Json.mapper().convertValue(vendorExtensions.get(EXTENSION_INTEGRATION), Map.class);
        } else {
            //如果没有包含x-amazon-apigateway-integration节点，则设置type，httpMethod，uri
//            "x-amazon-apigateway-integration" : {
//                "type" : "http",
//                "httpMethod" : "POST",
//                "uri" : "http://apiId.ap-southeast-1.elb.amazonaws.com/subject/{subjectId}",
            integ = new HashMap<>();
            integ.put("type", Constants.IntegrationType);
            integ.put("httpMethod", requestMethod);
            integ.put("uri", Constants.ALB_DNS + appRequestPath);
        }

        //处理responses节点
//        "responses" : {
//            "default" : {
//                "statusCode" : "200"
//            }
//        },
        String keyResponses = "responses";
        if (!integ.containsKey(keyResponses)) {
            Map<String, String> responseData = new HashMap<>();
            responseData.put("statusCode", "200");
            Map<String, Map> defaultRes = new HashMap<>();
            defaultRes.put("default", responseData);
            integ.put(keyResponses, defaultRes);
        }

//        处理requestParameters节点
//        "requestParameters" : {
//            "integration.request.path.bizId" : "method.request.path.bizId",
//            "integration.request.querystring.content" : "method.request.querystring.content"
//        }
        String keyRequestParameters = "requestParameters";
        if (integ.containsKey(keyRequestParameters)) {
            LOGGER.info("requestParameters had defined ");
            return;
        }

        String keyPrefix = "integration.request.";
        String valuePrefix = "method.request.";

        Map<String, String> requestParameters = new HashMap<>();
        for (Parameter parameter : opParameters) {
            String in = parameter.getIn();
            String paramType = in;
            if (in.equals("query")) {
                paramType = "querystring";
            }
            String name = parameter.getName();
            requestParameters.put(keyPrefix + paramType + "." + name, valuePrefix + paramType + "." + name);
        }
        Parameter authorization = new HeaderParameter();
        authorization.setIn("header");
        authorization.setName("Authorization");
        opParameters.add(authorization);
        op.setParameters(opParameters);

        requestParameters.put(keyPrefix + "header.Authorization", valuePrefix + "header.Authorization");
        LOGGER.info("automatically generate:" + requestParameters);
        integ.put(keyRequestParameters, requestParameters);
        vendorExtensions.put(EXTENSION_INTEGRATION, integ);
    }

}

import io.swagger.parser.SwaggerParser;
import io.swagger.models.Swagger;

Swagger swagger = new SwaggerParser().read("http://petstore.swagger.io/v2/swagger.json");

Swagger swagger = new SwaggerParser().read("./path/to/swagger.json");

Swagger swagger = new SwaggerCompatConverter().read("http://petstore.swagger.io/api/api-docs");

import io.swagger.models.auth.AuthorizationValue;

// ... your code

// build a authorization value
AuthorizationValue mySpecialHeader = new AuthorizationValue()
.keyName("x-special-access") // the name of the authorization to pass
.value("i-am-special") // the value of the authorization
.type("header"); // the location, as either `header` or `query`

// or in a single constructor
AuthorizationValue apiKey = new AuthorizationValue("api_key", "special-key", "header");
Swagger swagger = new SwaggerParser().read(
"http://petstore.swagger.io/v2/swagger.json",
Arrays.asList(mySpecialHeader, apiKey)
);

String swaggerString = Json.pretty(swagger);

  },
  "definitions": {
    "Empty": {
      "type": "object"
    }
  },
  "x-amazon-apigateway-documentation": {

"paths": {
"/subject/{bizId}/complaint": {
.....
,
"/subject/{subjectId}/profile": {
"get": {

Import the format of the data above, will cause the wrong below：

Your API was not imported due to errors in the Swagger file.
Unable to create resource at path '/subject/{subjectId}/profile': A sibling ({bizId}) of this resource already has a variable path part -- only one is allowed
Additionally, these warnings were found:
No responses specified for 'POST /subject/{bizId}/complaint'

    public void importApi(String filePath, String region, String stage) throws FileNotFoundException {
        ArrayList<String> commandList = newArrayList("java", "-jar");
        String absolutePath = ResourceUtils.getFile(ResourceUtils.CLASSPATH_URL_PREFIX).getAbsolutePath();
        LOGGER.info("absolutePath:{}",absolutePath);
        File awsImporterFile = ResourceUtils.getFile("classpath:lib/aws-apigateway-importer-1.0.3-SNAPSHOT-jar-with-dependencies.jar");
        commandList.add(awsImporterFile.getAbsolutePath());
        commandList.add("--create");
        commandList.add(filePath);
        commandList.add("--region");

        if (StringUtils.isBlank(region)) {//region 必须有
            region = Regions.AP_SOUTHEAST_1.getName();
        }
        commandList.add(region);

        if (StringUtils.isNotBlank(stage)) {//deploy optional
            commandList.add(" --deploy ");
            commandList.add(stage);
        }

        LOGGER.info(" {}", commandList);
        execCmd(commandList);
        LOGGER.info("success to do import ");
    }


    public boolean execCmd(ArrayList<String> commandList) {//List中第个元素是按空格分隔的命令的各部分组成
        try {
            ProcessBuilder pb = new ProcessBuilder(commandList);
            pb.redirectErrorStream(true);
            Map<String, String> env = pb.environment();//设置环境变量，重要
            env.put("AWS_ACCESS_KEY_ID", s3AccessProperty.getAccessKeyId());
            env.put("AWS_SECRET_ACCESS_KEY", s3AccessProperty.getSecretAccessKey());
            LOGGER.info("env:{}", env);
            Process process = pb.start();

            OutputProcessor error = new OutputProcessor(process.getErrorStream());
            OutputProcessor input = new OutputProcessor(process.getInputStream());
            error.start();
            input.start();
            int exitCode = process.waitFor();//阻塞，直到命令执行结束（成功 or 失败）
            if (exitCode == 0) {
                return true;
            }
            LOGGER.info("Failed to perform the command.{}", exitCode);
            return false;
        } catch (Exception e) {
            LOGGER.info("{}", e.getMessage(), e);
            return false;
        }
    }

    /**
     * Executes the specified string command in a separate process with the
     * specified environment.
     *
     * <p>This is a convenience method.  An invocation of the form
     * <tt>exec(command, envp)</tt>
     * behaves in exactly the same way as the invocation
     * <tt>{@link #exec(String, String[], File) exec}(command, envp, null)</tt>.
     *
     * @param   command   a specified system command.
     *
     * @param   envp      array of strings, each element of which
     *                    has environment variable settings in the format
     *                    <i>name</i>=<i>value</i>, or
     *                    <tt>null</tt> if the subprocess should inherit
     *                    the environment of the current process.
     *
     * @return  A new {@link Process} object for managing the subprocess
     *
     * @throws  SecurityException
     *          If a security manager exists and its
     *          {@link SecurityManager#checkExec checkExec}
     *          method doesn't allow creation of the subprocess
     *
     * @throws  IOException
     *          If an I/O error occurs
     *
     * @throws  NullPointerException
     *          If <code>command</code> is <code>null</code>,
     *          or one of the elements of <code>envp</code> is <code>null</code>
     *
     * @throws  IllegalArgumentException
     *          If <code>command</code> is empty
     *
     * @see     #exec(String[], String[], File)
     * @see     ProcessBuilder
     */
    public Process exec(String command, String[] envp) throws IOException {
        return exec(command, envp, null);
    }

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class LinuxTimeSetter {
        public void runLinuxScript() throws IOException {
            //通过exec 来运行Linux shell脚本：在这个demo中 setDate.sh 是和 LinuxTimeSetter 在同一个文件夹中
                String[] command = new String[]{"sudo","./setDate.sh","2010-10-10","12:12:12"};
                Process proc = Runtime.getRuntime().exec(command);
                BufferedReader br = new BufferedReader(new InputStreamReader(proc.getInputStream()));
                String text = null;
                //输出操作结果
                while ((text = br.readLine()) != null) {
                        System.out.println(text);
                }
        }

        public void runWindosScript() throws IOException {
//              Process proc = Runtime.getRuntime().exec("cmd /c dir");
                Process proc = Runtime.getRuntime().exec("cmd /c date /t");
                BufferedReader br = new BufferedReader(new InputStreamReader(proc
                                .getInputStream()));
                // BufferedInputStream bis = new
                // BufferedInputStream(proc.getInputStream());
                String text = null;
                while ((text = br.readLine()) != null) {
                        System.out.println(text);
                }
        }

        public static void main(String[] args) {
                String osName = System.getProperty("os.name").toLowerCase();
                System.out.println(osName);
                LinuxTimeSetter runner = new LinuxTimeSetter();
                try {
                        if (osName.contains("linux")) {
                                runner.runLinuxScript();
                        } else if (osName.matches("^(?i)Windows.*$")) {
                                runner.runWindosScript();
                        }
                } catch (IOException e) {
                        e.printStackTrace();
                }
        }
}