AppsFlyer / donkey / 78

pending completion

Build # 78

Build Type

Pull #1

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/AppsFlyer/donkey/commit/<a class=hub.com/AppsFlyer/donkey/commit/7393ef48d16d39b201cb548c12fb6494ed63dc89">7393ef48d<a href="https://github.com/AppsFlyer/donkey/commit/7393ef48d16d39b201cb548c12fb6494ed63dc89">">Merge </a><a class="double-link" href="https://github.com/AppsFlyer/donkey/commit/<a class="double-link" href="https://github.com/AppsFlyer/donkey/commit/2c2adbc9be2f770b620b265cfe00f9cb2d3cfe9b">2c2adbc9b</a>">2c2adbc9b</a><a href="https://github.com/AppsFlyer/donkey/commit/7393ef48d16d39b201cb548c12fb6494ed63dc89"> into 882154018">882154018</a>

Pull Request Pull Request #1: Donkey 0.1.0 alpha

Run Details

908 of 908 new or added lines in 55 files covered. (100.0%)

970 of 1284 relevant lines covered (75.55%)

1.61 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

92.75

/src/main/java/com/appsflyer/donkey/server/ring/handler/RingRequestField.java

package com.appsflyer.donkey.server.ring.handler;

import clojure.lang.IPersistentMap;
import clojure.lang.Keyword;
import clojure.lang.RT;
import com.appsflyer.donkey.ValueExtractor;
import com.appsflyer.donkey.util.TypeConverter;
import io.vertx.core.MultiMap;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.net.SocketAddress;
import io.vertx.ext.web.RoutingContext;
import org.jetbrains.annotations.Nullable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.net.ssl.SSLPeerUnverifiedException;
import java.security.cert.Certificate;
import java.util.Locale;
import java.util.Map;
import java.util.function.Function;

import static com.appsflyer.donkey.util.TypeConverter.toPersistentMap;
import static com.appsflyer.donkey.util.TypeConverter.toUrlDecodedPersistentMap;

/**
 * The class encapsulates the logic of translating between a Vertx {@link RoutingContext}
 * and a Ring request.
 * Each element corresponds to a Ring request field. It implements getting the field's
 * name as a Keyword, and extracting the corresponding value from the RoutingContext.
 */
public enum RingRequestField implements ValueExtractor<RoutingContext> {
  
  BODY("body") {
    @Nullable
    @Override
    public byte[] from(RoutingContext ctx) {
      Buffer body = ctx.getBody();
      if (body != null) {
        return body.getBytes();
      }
      return null;
    }
  },
  CLIENT_CERT("ssl-client-cert") {
    @Nullable
    @Override
    public Certificate[] from(RoutingContext ctx) {
      try {
        if (ctx.request().isSSL()) {
          return ctx.request().sslSession().getPeerCertificates();
        }
      } catch (SSLPeerUnverifiedException e) {
        logger.warn("Caught exception getting SSL peer certificates: {}", e.getMessage());
      }
      return null;
    }
  },
  FORM_PARAMS("form-params") {
    @Nullable
    @Override
    public IPersistentMap from(RoutingContext ctx) {
      if (!ctx.request().isExpectMultipart()) {
        return null;
      }
  
      MultiMap formAttributes = ctx.request().formAttributes();
      if (formAttributes.isEmpty()) {
        return null;
      }
  
      return toUrlDecodedPersistentMap(formAttributes);
    }
  },
  HEADERS("headers") {
    private final Function<String, String> keyTransformer =
        (v) -> v.toLowerCase(Locale.ROOT);
  
    @Nullable
    @Override
    public IPersistentMap from(RoutingContext ctx) {
      MultiMap headers = ctx.request().headers();
      if (headers.isEmpty()) {
        return null;
      }
      return toPersistentMap(headers, keyTransformer, TypeConverter::stringJoiner);
    }
  },
  PATH_PARAMS("path-params") {
    @Nullable
    @Override
    public IPersistentMap from(RoutingContext ctx) {
      Map<String, String> pathParams = ctx.pathParams();
      if (pathParams.isEmpty()) {
        return null;
      }
      
      Object[] pathParamsArray = new Object[(pathParams.size() * 2)];
      int i = 0;
      for (Object obj : pathParams.entrySet()) {
        pathParamsArray[i] = ((Map.Entry<?, ?>) obj).getKey();
        pathParamsArray[i + 1] = ((Map.Entry<?, ?>) obj).getValue();
        i += 2;
      }
      return RT.mapUniqueKeys(pathParamsArray);
    }
  },
  PROTOCOL("protocol") {
    @Override
    public String from(RoutingContext ctx) {
      return HttpProtocolMapping.get(ctx.request().version());
    }
  },
  QUERY_STRING("query-string") {
    @Override
    public String from(RoutingContext ctx) {
      return ctx.request().query();
    }
  },
  REMOTE_ADDRESS("remote-addr") {
    @Nullable
    @Override
    public String from(RoutingContext ctx) {
      var forwardedFor = ctx.request().getHeader("x-forwarded-for");
      if (forwardedFor != null) {
        return forwardedFor;
      } else {
        SocketAddress remoteAddress = ctx.request().remoteAddress();
        if (remoteAddress != null) {
          return remoteAddress.toString();
        }
      }
      return null;
    }
  },
  /**
   * The request "verb", i.e GET, POST,
   */
  REQUEST_METHOD("request-method") {
    @Override
    public Keyword from(RoutingContext ctx) {
      return HttpMethodMapping.get(ctx.request().method());
    }
  },
  /**
   * The request scheme - HTTP or HTTPS
   */
  SCHEME("scheme") {
    private final Map<String, Keyword> schemeMapping =
        Map.of("http", Keyword.intern("http"),
               "https", Keyword.intern("https"));
    
    @Override
    public Keyword from(RoutingContext ctx) {
      return schemeMapping.get(ctx.request().scheme());
    }
  },
  /**
   * The hostname of the server, or the ip if a hostname cannot be determined.
   */
  SERVER_NAME("server-name") {
    @Override
    public String from(RoutingContext ctx) {
      return ctx.request().host();
    }
  },
  /**
   * The port on which the server is listening on
   */
  SERVER_PORT("server-port") {
    @Override
    public Integer from(RoutingContext ctx) {
      return ctx.request().localAddress().port();
    }
  },
  /**
   * The path part of the url.<br>
   * Example:<br>
   * {@code http://www.example.com/foo/bar => /foo/bar}
   */
  URI("uri") {
    @Override
    public String from(RoutingContext ctx) {
      return ctx.request().path();
    }
  };
  
  private static final Logger logger = LoggerFactory.getLogger(RingRequestField.class.getName());
  private final Keyword keyword;
  
  RingRequestField(String field) {
    keyword = Keyword.intern(field);
  }
  
  /**
   * @return The field name as a Keyword
   */
  public Keyword keyword() {
    return keyword;
  }
}

1	package com.appsflyer.donkey.server.ring.handler;
2
3	import clojure.lang.IPersistentMap;
4	import clojure.lang.Keyword;
5	import clojure.lang.RT;
6	import com.appsflyer.donkey.ValueExtractor;
7	import com.appsflyer.donkey.util.TypeConverter;
8	import io.vertx.core.MultiMap;
9	import io.vertx.core.buffer.Buffer;
10	import io.vertx.core.net.SocketAddress;
11	import io.vertx.ext.web.RoutingContext;
12	import org.jetbrains.annotations.Nullable;
13	import org.slf4j.Logger;
14	import org.slf4j.LoggerFactory;
15
16	import javax.net.ssl.SSLPeerUnverifiedException;
17	import java.security.cert.Certificate;
18	import java.util.Locale;
19	import java.util.Map;
20	import java.util.function.Function;
21
22	import static com.appsflyer.donkey.util.TypeConverter.toPersistentMap;
23	import static com.appsflyer.donkey.util.TypeConverter.toUrlDecodedPersistentMap;
24
25	/**
26	* The class encapsulates the logic of translating between a Vertx {@link RoutingContext}
27	* and a Ring request.
28	* Each element corresponds to a Ring request field. It implements getting the field's
29	* name as a Keyword, and extracting the corresponding value from the RoutingContext.
30	*/
31	public enum RingRequestField implements ValueExtractor<RoutingContext> {	1✔
32
33	BODY("body") {	1✔
34	@Nullable
35	@Override
36	public byte[] from(RoutingContext ctx) {
37	Buffer body = ctx.getBody();	1✔
38	if (body != null) {	1✔
39	return body.getBytes();	1✔
40	}
41	return null;	1✔
42	}
43	},
44	CLIENT_CERT("ssl-client-cert") {	1✔
45	@Nullable
46	@Override
47	public Certificate[] from(RoutingContext ctx) {
48	try {
49	if (ctx.request().isSSL()) {	1✔
50	return ctx.request().sslSession().getPeerCertificates();	×
51	}
52	} catch (SSLPeerUnverifiedException e) {	1✔
53	logger.warn("Caught exception getting SSL peer certificates: {}", e.getMessage());	1✔
54	}	1✔
55	return null;	1✔
56	}
57	},
58	FORM_PARAMS("form-params") {	1✔
59	@Nullable
60	@Override
61	public IPersistentMap from(RoutingContext ctx) {
62	if (!ctx.request().isExpectMultipart()) {	1✔
63	return null;	1✔
64	}
65
66	MultiMap formAttributes = ctx.request().formAttributes();	1✔
67	if (formAttributes.isEmpty()) {	1✔
68	return null;	×
69	}
70
71	return toUrlDecodedPersistentMap(formAttributes);	1✔
72	}
73	},
74	HEADERS("headers") {	1✔
75	private final Function<String, String> keyTransformer =	1✔
76	(v) -> v.toLowerCase(Locale.ROOT);	1✔
77
78	@Nullable
79	@Override
80	public IPersistentMap from(RoutingContext ctx) {
81	MultiMap headers = ctx.request().headers();	1✔
82	if (headers.isEmpty()) {	1✔
83	return null;	×
84	}
85	return toPersistentMap(headers, keyTransformer, TypeConverter::stringJoiner);	1✔
86	}
87	},
88	PATH_PARAMS("path-params") {	1✔
89	@Nullable
90	@Override
91	public IPersistentMap from(RoutingContext ctx) {
92	Map<String, String> pathParams = ctx.pathParams();	1✔
93	if (pathParams.isEmpty()) {	1✔
94	return null;	1✔
95	}
96
97	Object[] pathParamsArray = new Object[(pathParams.size() * 2)];	1✔
98	int i = 0;	1✔
99	for (Object obj : pathParams.entrySet()) {	1✔
100	pathParamsArray[i] = ((Map.Entry<?, ?>) obj).getKey();	1✔
101	pathParamsArray[i + 1] = ((Map.Entry<?, ?>) obj).getValue();	1✔
102	i += 2;	1✔
103	}	1✔
104	return RT.mapUniqueKeys(pathParamsArray);	1✔
105	}
106	},
107	PROTOCOL("protocol") {	1✔
108	@Override
109	public String from(RoutingContext ctx) {
110	return HttpProtocolMapping.get(ctx.request().version());	1✔
111	}
112	},
113	QUERY_STRING("query-string") {	1✔
114	@Override
115	public String from(RoutingContext ctx) {
116	return ctx.request().query();	1✔
117	}
118	},
119	REMOTE_ADDRESS("remote-addr") {	1✔
120	@Nullable
121	@Override
122	public String from(RoutingContext ctx) {
123	var forwardedFor = ctx.request().getHeader("x-forwarded-for");	1✔
124	if (forwardedFor != null) {	1✔
125	return forwardedFor;	×
126	} else {
127	SocketAddress remoteAddress = ctx.request().remoteAddress();	1✔
128	if (remoteAddress != null) {	1✔
129	return remoteAddress.toString();	1✔
130	}
131	}
132	return null;	×
133	}
134	},
135	/**
136	* The request "verb", i.e GET, POST,
137	*/
138	REQUEST_METHOD("request-method") {	1✔
139	@Override
140	public Keyword from(RoutingContext ctx) {
141	return HttpMethodMapping.get(ctx.request().method());	1✔
142	}
143	},
144	/**
145	* The request scheme - HTTP or HTTPS
146	*/
147	SCHEME("scheme") {	1✔
148	private final Map<String, Keyword> schemeMapping =	1✔
149	Map.of("http", Keyword.intern("http"),	1✔
150	"https", Keyword.intern("https"));	1✔
151
152	@Override
153	public Keyword from(RoutingContext ctx) {
154	return schemeMapping.get(ctx.request().scheme());	1✔
155	}
156	},
157	/**
158	* The hostname of the server, or the ip if a hostname cannot be determined.
159	*/
160	SERVER_NAME("server-name") {	1✔
161	@Override
162	public String from(RoutingContext ctx) {
163	return ctx.request().host();	1✔
164	}
165	},
166	/**
167	* The port on which the server is listening on
168	*/
169	SERVER_PORT("server-port") {	1✔
170	@Override
171	public Integer from(RoutingContext ctx) {
172	return ctx.request().localAddress().port();	1✔
173	}
174	},
175	/**
176	* The path part of the url.<br>
177	* Example:<br>
178	* {@code http://www.example.com/foo/bar => /foo/bar}
179	*/
180	URI("uri") {	1✔
181	@Override
182	public String from(RoutingContext ctx) {
183	return ctx.request().path();	1✔
184	}
185	};
186
187	private static final Logger logger = LoggerFactory.getLogger(RingRequestField.class.getName());	1✔
188	private final Keyword keyword;
189
190	RingRequestField(String field) {	1✔
191	keyword = Keyword.intern(field);	1✔
192	}	1✔
193
194	/**
195	* @return The field name as a Keyword
196	*/
197	public Keyword keyword() {
198	return keyword;	1✔
199	}
200	}

AppsFlyer / donkey / 78

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous