@@ -34,32 +34,34 @@ public class TestService {
3434 "tags" ,
3535 "filtering" ,
3636 "migrations" ,
37- "event-sampling"
37+ "event-sampling" ,
38+ "inline-context" ,
39+ "anonymous-redaction"
3840 };
39-
41+
4042 static final Gson gson = new GsonBuilder ().serializeNulls ().create ();
4143
4244 static final OkHttpClient client = new OkHttpClient ();
43-
45+
4446 private final Map <String , SdkClientEntity > clients = new ConcurrentHashMap <String , SdkClientEntity >();
4547 private final AtomicInteger clientCounter = new AtomicInteger (0 );
4648 private final String clientVersion ;
47-
49+
4850 private TestService () {
4951 LDClient dummyClient = new LDClient ("" , new LDConfig .Builder ().offline (true ).build ());
5052 clientVersion = dummyClient .version ();
5153 try {
5254 dummyClient .close ();
5355 } catch (Exception e ) {}
5456 }
55-
57+
5658 @ SuppressWarnings ("serial" )
5759 public static class BadRequestException extends Exception {
5860 public BadRequestException (String message ) {
5961 super (message );
6062 }
6163 }
62-
64+
6365 public static void main (String [] args ) throws Exception {
6466 TestService service = new TestService ();
6567
@@ -70,7 +72,7 @@ public static void main(String[] args) throws Exception {
7072 .addRegex ("POST" , Pattern .compile ("/clients/(.*)" ), ctx -> service .postClientCommand (diableKeepAlive (ctx )))
7173 .addRegex ("DELETE" , Pattern .compile ("/clients/(.*)" ), ctx -> service .deleteClient (diableKeepAlive (ctx )));
7274
73- HttpServer server = HttpServer .start (PORT , router );
75+ HttpServer server = HttpServer .start (PORT , router );
7476 server .getRecorder ().setEnabled (false ); // don't accumulate a request log
7577
7678 System .out .println ("Listening on port " + PORT );
@@ -97,21 +99,21 @@ private void forceQuit() {
9799 System .out .println ("Test harness has told us to quit" );
98100 System .exit (0 );
99101 }
100-
102+
101103 private void postCreateClient (RequestContext ctx ) {
102104 CreateInstanceParams params = readJson (ctx , CreateInstanceParams .class );
103105
104106 String clientId = String .valueOf (clientCounter .incrementAndGet ());
105107 SdkClientEntity client = new SdkClientEntity (this , params );
106108
107109 clients .put (clientId , client );
108-
110+
109111 ctx .addHeader ("Location" , "/clients/" + clientId );
110112 }
111113
112114 private void postClientCommand (RequestContext ctx ) {
113115 CommandParams params = readJson (ctx , CommandParams .class );
114-
116+
115117 String clientId = ctx .getPathParam (0 );
116118 SdkClientEntity client = clients .get (clientId );
117119 if (client == null ) {
@@ -131,9 +133,9 @@ private void postClientCommand(RequestContext ctx) {
131133 client .logger .error ("Unexpected exception: {}" , e );
132134 ctx .setStatus (500 );
133135 }
134- }
136+ }
135137 }
136-
138+
137139 private void deleteClient (RequestContext ctx ) {
138140 String clientId = ctx .getPathParam (0 );
139141 SdkClientEntity client = clients .get (clientId );
@@ -143,11 +145,11 @@ private void deleteClient(RequestContext ctx) {
143145 client .close ();
144146 }
145147 }
146-
148+
147149 private <T > T readJson (RequestContext ctx , Class <T > paramsClass ) {
148150 return gson .fromJson (ctx .getRequest ().getBody (), paramsClass );
149151 }
150-
152+
151153 private void writeJson (RequestContext ctx , Object data ) {
152154 String json = gson .toJson (data );
153155 Handlers .bodyJson (json ).apply (ctx );
0 commit comments