Seeing if this helps with DiceID callback

Author: jmgasper

src/main/java/com/appirio/tech/core/service/identity/representation/DiceCallbackRequest.java

@@ -0,0 +1,82 @@
+package com.appirio.tech.core.service.identity.representation;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class DiceCallbackRequest {
+	private String type;
+	private String action;
+	private String name;
+	private String email;
+    @JsonProperty(value = "connection_id")
+	private String connectionId;
+	@JsonProperty(value = "credential_exchange_id")
+	private String credentialExchangeId;
+    @JsonProperty(value = "presentation_exchange_id")
+	private String presentationExchangeId;
+    @JsonProperty(value = "schema_id")
+	private String schemaId;
+	
+    public String getConnectionId() {
+		return connectionId;
+	}
+
+	public void setConnectionId(String connectionId) {
+		this.connectionId = connectionId;
+	}
+
+	public String getCredentialExchangeId() {
+		return credentialExchangeId;
+	}
+
+	public void setCredentialExchangeId(String credentialExchangeId) {
+		this.credentialExchangeId = credentialExchangeId;
+	}
+
+	public String getPresentationExchangeId() {
+		return presentationExchangeId;
+	}
+
+	public void setPresentationExchangeId(String presentationExchangeId) {
+		this.presentationExchangeId = presentationExchangeId;
+	}
+
+	public String getSchemaId() {
+		return schemaId;
+	}
+
+	public void setSchemaId(String schemaId) {
+		this.schemaId = schemaId;
+	}
+
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+
+	public String getAction() {
+		return action;
+	}
+
+	public void setAction(String action) {
+		this.action = action;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+	
+	public String getEmail() {
+		return email;
+	}
+
+	public void setEmail(String email) {
+		this.email = email;
+	}
+}

src/main/java/com/appirio/tech/core/service/identity/resource/UserResource.java

@@ -1808,7 +1808,7 @@ private String sendDiceInvitation(UserDiceAttributes diceAttributes)
         if (response.getStatusCode() != HttpURLConnection.HTTP_OK) {
             sendSlackNotification(diceAttributes.getHandle(), "Error happened, please check the logs.");
             throw new APIRuntimeException(HttpURLConnection.HTTP_INTERNAL_ERROR,
-                    String.format("Error when calling dice connection api with body. %s %s %d %s", mapper.writeValueAsString(body), token, response.getStatusCode(),
+                    String.format("Error when calling dice connection api with body. %s %s %d %s", mapper.writeValueAsString(body), token,response.getStatusCode(),
                             response.getMessage()));
         }
         DiceInvitationResponse diceInvitation = new ObjectMapper().readValue(response.getText(),
@@ -1817,16 +1817,21 @@ private String sendDiceInvitation(UserDiceAttributes diceAttributes)
     }
 
     @POST
-    @Path("/dice-status")
+    @Path("/dice-callback")
     @Timed
-    public ApiResponse diceStatus(@Valid PostPutRequest<DiceStatusRequest> postRequest,
+    public ApiResponse diceStatus(@Valid PostPutRequest<DiceCallbackRequest> postRequest,
             @Context HttpServletRequest request) {
-        logger.info(String.format("Dice status request: %s %s", postRequest, request));
+        logger.info(String.format("Dice callback: %s %s", postRequest, request));
         if (!diceAuth.isValidAPIKey(request)) {
             throw new APIRuntimeException(SC_FORBIDDEN, "Forbidden");
         }
-        checkParam(postRequest);
-        DiceStatusRequest status = postRequest.getParam();
+        
+        if (postRequest == null) {
+            return ApiResponseFactory.createResponse(
+                createValidationResult(true, "Connection success"));
+        }
+
+        DiceCallbackRequest status = postRequest.getParam();
         if (status.getType() == null) {
             logger.info(String.format("Dice status missing type: %s %s", postRequest, request));
             throw new APIRuntimeException(SC_BAD_REQUEST, String.format(MSG_TEMPLATE_MANDATORY, "type"));
@@ -1860,6 +1865,47 @@ public ApiResponse diceStatus(@Valid PostPutRequest<DiceStatusRequest> postReque
         return ApiResponseFactory.createResponse("SUCCESS");
     }
 
+    @POST
+    @Path("/dice-status")
+    @Timed
+    public ApiResponse diceStatus(@Valid PostPutRequest<DiceStatusRequest> postRequest,
+            @Context HttpServletRequest request) {
+        if (!diceAuth.isValidAPIKey(request)) {
+            throw new APIRuntimeException(SC_FORBIDDEN, "Forbidden");
+        }
+        checkParam(postRequest);
+        DiceStatusRequest status = postRequest.getParam();
+        if (status.getEvent() == null) {
+            throw new APIRuntimeException(SC_BAD_REQUEST, String.format(MSG_TEMPLATE_MANDATORY, "event"));
+        }
+        if (status.getConnectionId() == null || status.getConnectionId().isEmpty()) {
+            throw new APIRuntimeException(SC_BAD_REQUEST, String.format(MSG_TEMPLATE_MANDATORY, "connectionId"));
+        }
+        logger.info(status);
+        switch (status.getEvent()) {
+            case "connection-invitation":
+                handleConnectionCreatedEvent(status.getConnectionId(), status.getEmailId(), status.getShortUrl());
+                break;
+            case "connection-response":
+                handleConnectionAcceptedEvent(status.getConnectionId());
+                break;
+            case "credential-issuance":
+                handleCredentialIssuanceEvent(status.getConnectionId());
+                break;
+            case "connection-declined":
+                handleConnectionDeclinedEvent(status.getConnectionId());
+                break;
+            case "credential-declined":
+                handleCredentialDeclinedEvent(status.getConnectionId());
+                break;
+            default:
+                throw new APIRuntimeException(SC_BAD_REQUEST,
+                        String.format("%s is not valid event", status.getEvent()));
+        }
+
+        return ApiResponseFactory.createResponse("SUCCESS");
+    }
+
     private void handleConnectionCreatedEvent(String connectionId, String emailId, String shortUrl) {
         if (emailId == null || emailId.isEmpty()) {
             throw new APIRuntimeException(SC_BAD_REQUEST, String.format(MSG_TEMPLATE_MANDATORY, "emailId"));