Add client functionality to force keygroupconfig update

Author: MoeweX

src/main/java/client/KeygroupRequest.java

@@ -22,6 +22,16 @@ public KeygroupRequest(String address, int port) {
 		super(address, port, PATH);
 	}
 
+	public KeygroupConfig updateLocalKeygroupConfig(KeygroupID keygroupID) throws UnirestException {
+		String target = target(keygroupID.getApp(), keygroupID.getTenant(), keygroupID.getGroup(), "update");
+		logger.info("Running get request targeting " + target);
+
+		HttpResponse<String> response =
+				Unirest.get(target).asString();
+
+		return handleObjectResponse(response, KeygroupConfig.class, logger);
+	}
+	
 	public boolean createKeygroup(KeygroupConfig keygroupConfig) throws UnirestException {
 		String target = target();
 		logger.info("Running post request targeting " + target);

src/main/java/de/hasenburg/fbase/rest/jersey/KeygroupsResource.java

@@ -1,5 +1,9 @@
 package de.hasenburg.fbase.rest.jersey;
 
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
 import javax.inject.Inject;
 import javax.ws.rs.Consumes;
 import javax.ws.rs.DELETE;
@@ -63,6 +67,33 @@ public class KeygroupsResource {
 	@Inject
 	FBase fBase;
 
+	@GET
+	@Path("{app}/{tenant}/{group}/update")
+	@Produces(MediaType.APPLICATION_JSON)
+	public Response updateLocal(@PathParam("app") String app, @PathParam("tenant") String tenant,
+			@PathParam("group") String group) {
+
+		KeygroupConfig config = null;
+		try {
+			config = fBase.namingServiceSender
+					.sendKeygroupConfigRead(new KeygroupID(app, tenant, group));
+
+			if (config == null) {
+				return Response.status(404, "Keygroup does not exist").build();
+			}
+
+			fBase.taskmanager.runUpdateKeygroupConfigTask(config, false).get(3, TimeUnit.SECONDS);
+		} catch (FBaseCommunicationException | FBaseNamingServiceException | InterruptedException
+				| ExecutionException | TimeoutException e) {
+			logger.warn(e);
+			return Response.status(500, e.getMessage()).build();
+		}
+
+		Message m = new Message();
+		m.setContent(JSONable.toJSON(config));
+		return Response.ok(JSONable.toJSON(m)).build();
+	}
+
 	@GET
 	@Path("{app}/{tenant}/{group}")
 	@Produces(MediaType.APPLICATION_JSON)