feat: add webhooks

src/dropwizardWebhooks/java/gg/top/webhooks/dropwizard/TopggWebhookEventListener.java

@@ -0,0 +1,25 @@
+package gg.top.webhooks.dropwizard;
+
+import jakarta.ws.rs.core.Response;
+import gg.top.webhooks.payload.IntegrationCreatePayload;
+import gg.top.webhooks.payload.IntegrationDeletePayload;
+import gg.top.webhooks.payload.TestPayload;
+import gg.top.webhooks.payload.VoteCreatePayload;
+
+public interface TopggWebhookEventListener {
+  default Response onIntegrationCreate(final IntegrationCreatePayload payload, final String trace) {
+    return Response.status(Response.Status.NO_CONTENT).build();
+  }
+
+  default Response onIntegrationDelete(final IntegrationDeletePayload payload, final String trace) {
+    return Response.status(Response.Status.NO_CONTENT).build();
+  }
+
+  default Response onTest(final TestPayload payload, final String trace) {
+    return Response.status(Response.Status.NO_CONTENT).build();
+  }
+
+  default Response onVoteCreate(final VoteCreatePayload payload, final String trace) {
+    return Response.status(Response.Status.NO_CONTENT).build();
+  }
+}

src/dropwizardWebhooks/java/gg/top/webhooks/dropwizard/TopggWebhooks.java

@@ -0,0 +1,133 @@
+package gg.top.webhooks.dropwizard;
+
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.time.OffsetDateTime;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HexFormat;
+import java.util.logging.Logger;
+import java.util.stream.Collectors;
+
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+
+import com.fatboyindustrial.gsonjavatime.OffsetDateTimeConverter;
+import com.google.common.io.ByteStreams;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonIOException;
+import com.google.gson.JsonSyntaxException;
+
+import gg.top.webhooks.payload.IntegrationCreatePayload;
+import gg.top.webhooks.payload.IntegrationDeletePayload;
+import gg.top.webhooks.payload.Payload;
+import gg.top.webhooks.payload.TestPayload;
+import gg.top.webhooks.payload.VoteCreatePayload;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.WebApplicationException;
+import jakarta.ws.rs.core.Context;
+import jakarta.ws.rs.core.Response;
+
+public abstract class TopggWebhooks implements TopggWebhookEventListener {
+  private static final Logger logger = Logger.getLogger(TopggWebhooks.class.getName());
+
+  private byte[] secret;
+  private final Gson gson;
+
+  public TopggWebhooks(final String secret) {
+    this.secret = secret.getBytes(StandardCharsets.UTF_8);
+    this.gson =
+        new GsonBuilder()
+            .registerTypeAdapter(OffsetDateTime.class, new OffsetDateTimeConverter())
+            .create();
+  }
+
+  public String getSecret() {
+    return new String(secret, StandardCharsets.UTF_8);
+  }
+
+  public void setSecret(final String newSecret) {
+    secret = newSecret.getBytes(StandardCharsets.UTF_8);
+  }
+
+  @POST
+  @SuppressWarnings("UseSpecificCatch")
+  public Response handle(@Context HttpServletRequest request) throws WebApplicationException {
+    String body = "";
+
+    try {
+      final String signatureHeader = request.getHeader("x-topgg-signature");
+
+      assert signatureHeader != null;
+
+      final HashMap<String, String> parsedSignature =
+          Arrays.stream(signatureHeader.split(","))
+              .map(part -> part.split("=", 2))
+              .collect(
+                  Collectors.toMap(
+                      part -> part[0].trim(),
+                      part -> part[1].trim(),
+                      (existing, replacement) -> replacement,
+                      HashMap::new));
+
+      final String signature = parsedSignature.get("v1");
+      final String timestamp = parsedSignature.get("t");
+
+      assert signature != null && timestamp != null;
+
+      final SecretKeySpec key = new SecretKeySpec(secret, "HmacSHA256");
+      final Mac hmac = Mac.getInstance("HmacSHA256");
+
+      hmac.init(key);
+
+      body = new String(ByteStreams.limit(request.getInputStream(), 2 * 1024 * 1024).readAllBytes(), StandardCharsets.UTF_8);
+      final byte[] digest =
+          hmac.doFinal(String.format("%s.%s", timestamp, body).getBytes(StandardCharsets.UTF_8));
+
+      if (!signature.equals(HexFormat.of().formatHex(digest))) {
+        return Response.status(Response.Status.UNAUTHORIZED)
+            .entity("Invalid Authorization")
+            .build();
+      }
+
+      final Payload payload = gson.fromJson(body, Payload.class);
+      final String trace = request.getHeader("x-topgg-trace");
+
+      try {
+        return switch (payload.getType()) {
+          case "integration.create" ->
+              onIntegrationCreate(payload.getData(gson, IntegrationCreatePayload.class), trace);
+          case "integration.delete" ->
+              onIntegrationDelete(payload.getData(gson, IntegrationDeletePayload.class), trace);
+          case "webhook.test" -> onTest(payload.getData(gson, TestPayload.class), trace);
+          case "vote.create" -> onVoteCreate(payload.getData(gson, VoteCreatePayload.class), trace);
+          default -> Response.status(Response.Status.BAD_REQUEST).entity("Bad Request").build();
+        };
+      } catch (final Throwable ignored) {
+        return Response.status(Response.Status.INTERNAL_SERVER_ERROR)
+            .entity("Internal Server Error")
+            .build();
+      }
+    } catch (final NoSuchAlgorithmException
+        | InvalidKeyException
+        | ArrayIndexOutOfBoundsException
+        | AssertionError
+        | JsonSyntaxException
+        | JsonIOException
+        | IOException error) {
+      if (error instanceof NoSuchAlgorithmException || error instanceof InvalidKeyException) {
+        throw new WebApplicationException("Unable to find HMAC SHA-256 algorithm", error);
+      } else if (error instanceof JsonSyntaxException) {
+        logger.warning(String.format("Unable to parse Top.gg webhook payload. Please report this bug to the SDK maintainers.\nCause: %s\n--- BEGIN BODY DUMP ---\n%s\n--- END BODY DUMP ---", error.getMessage(), body));
+
+        return Response.status(Response.Status.NO_CONTENT).build();
+      }
+
+      return Response.status(Response.Status.BAD_REQUEST).entity("Bad Request").build();
+    }
+  }
+}

src/eclipseJettyWebhooks/java/gg/top/webhooks/eclipsejetty/TopggWebhookEventListener.java

@@ -0,0 +1,33 @@
+package gg.top.webhooks.eclipsejetty;
+
+import jakarta.servlet.http.HttpServletResponse;
+import gg.top.webhooks.payload.IntegrationCreatePayload;
+import gg.top.webhooks.payload.IntegrationDeletePayload;
+import gg.top.webhooks.payload.TestPayload;
+import gg.top.webhooks.payload.VoteCreatePayload;
+
+public interface TopggWebhookEventListener {
+  default void onIntegrationCreate(
+      final HttpServletResponse response,
+      final IntegrationCreatePayload payload,
+      final String trace) {
+    response.setStatus(HttpServletResponse.SC_NO_CONTENT);
+  }
+
+  default void onIntegrationDelete(
+      final HttpServletResponse response,
+      final IntegrationDeletePayload payload,
+      final String trace) {
+    response.setStatus(HttpServletResponse.SC_NO_CONTENT);
+  }
+
+  default void onTest(
+      final HttpServletResponse response, final TestPayload payload, final String trace) {
+    response.setStatus(HttpServletResponse.SC_NO_CONTENT);
+  }
+
+  default void onVoteCreate(
+      final HttpServletResponse response, final VoteCreatePayload payload, final String trace) {
+    response.setStatus(HttpServletResponse.SC_NO_CONTENT);
+  }
+}

src/eclipseJettyWebhooks/java/gg/top/webhooks/eclipsejetty/TopggWebhooks.java

@@ -0,0 +1,140 @@
+package gg.top.webhooks.eclipsejetty;
+
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.time.OffsetDateTime;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HexFormat;
+import java.util.logging.Logger;
+import java.util.stream.Collectors;
+
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+
+import com.fatboyindustrial.gsonjavatime.OffsetDateTimeConverter;
+import com.google.common.io.ByteStreams;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonIOException;
+import com.google.gson.JsonSyntaxException;
+
+import gg.top.webhooks.payload.IntegrationCreatePayload;
+import gg.top.webhooks.payload.IntegrationDeletePayload;
+import gg.top.webhooks.payload.Payload;
+import gg.top.webhooks.payload.TestPayload;
+import gg.top.webhooks.payload.VoteCreatePayload;
+import jakarta.servlet.ServletException;
+import jakarta.servlet.http.HttpServlet;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+
+public class TopggWebhooks extends HttpServlet implements TopggWebhookEventListener {
+  private static final Logger logger = Logger.getLogger(TopggWebhooks.class.getName());
+
+  private byte[] secret;
+  private final Gson gson;
+
+  public TopggWebhooks(final String secret) {
+    this.secret = secret.getBytes(StandardCharsets.UTF_8);
+    this.gson =
+        new GsonBuilder()
+            .registerTypeAdapter(OffsetDateTime.class, new OffsetDateTimeConverter())
+            .create();
+  }
+
+  public String getSecret() {
+    return new String(secret, StandardCharsets.UTF_8);
+  }
+
+  public void setSecret(final String newSecret) {
+    secret = newSecret.getBytes(StandardCharsets.UTF_8);
+  }
+
+  @Override
+  @SuppressWarnings("UseSpecificCatch")
+  protected void doPost(final HttpServletRequest request, final HttpServletResponse response)
+      throws IOException, ServletException {
+    String body = "";
+
+    try {
+      final String signatureHeader = request.getHeader("x-topgg-signature");
+
+      assert signatureHeader != null;
+
+      final HashMap<String, String> parsedSignature =
+          Arrays.stream(signatureHeader.split(","))
+              .map(part -> part.split("=", 2))
+              .collect(
+                  Collectors.toMap(
+                      part -> part[0].trim(),
+                      part -> part[1].trim(),
+                      (existing, replacement) -> replacement,
+                      HashMap::new));
+
+      final String signature = parsedSignature.get("v1");
+      final String timestamp = parsedSignature.get("t");
+
+      assert signature != null && timestamp != null;
+
+      final SecretKeySpec key = new SecretKeySpec(secret, "HmacSHA256");
+      final Mac hmac = Mac.getInstance("HmacSHA256");
+
+      hmac.init(key);
+
+      body = new String(ByteStreams.limit(request.getInputStream(), 2 * 1024 * 1024).readAllBytes(), StandardCharsets.UTF_8);
+      final byte[] digest =
+          hmac.doFinal(String.format("%s.%s", timestamp, body).getBytes(StandardCharsets.UTF_8));
+
+      if (!signature.equals(HexFormat.of().formatHex(digest))) {
+        response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
+        response.getWriter().write("Invalid Authorization");
+
+        return;
+      }
+
+      final Payload payload = gson.fromJson(body, Payload.class);
+      final String trace = request.getHeader("x-topgg-trace");
+
+      try {
+        switch (payload.getType()) {
+          case "integration.create" ->
+              onIntegrationCreate(
+                  response, payload.getData(gson, IntegrationCreatePayload.class), trace);
+          case "integration.delete" ->
+              onIntegrationDelete(
+                  response, payload.getData(gson, IntegrationDeletePayload.class), trace);
+          case "webhook.test" -> onTest(response, payload.getData(gson, TestPayload.class), trace);
+          case "vote.create" ->
+              onVoteCreate(response, payload.getData(gson, VoteCreatePayload.class), trace);
+          default -> {
+            response.setStatus(HttpServletResponse.SC_BAD_REQUEST);
+            response.getWriter().write("Bad Request");
+          }
+        }
+      } catch (final Throwable ignored) {
+        response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
+        response.getWriter().write("Internal Server Error");
+      }
+    } catch (final NoSuchAlgorithmException
+        | InvalidKeyException
+        | ArrayIndexOutOfBoundsException
+        | AssertionError
+        | JsonSyntaxException
+        | JsonIOException
+        | IOException error) {
+      if (error instanceof NoSuchAlgorithmException || error instanceof InvalidKeyException) {
+        throw new ServletException("Unable to find HMAC SHA-256 algorithm", error);
+      } else if (error instanceof JsonSyntaxException) {
+        logger.warning(String.format("Unable to parse Top.gg webhook payload. Please report this bug to the SDK maintainers.\nCause: %s\n--- BEGIN BODY DUMP ---\n%s\n--- END BODY DUMP ---", error.getMessage(), body));
+
+        response.setStatus(HttpServletResponse.SC_NO_CONTENT);
+      } else {
+        response.setStatus(HttpServletResponse.SC_BAD_REQUEST);
+        response.getWriter().write("Bad Request");
+      }
+    }
+  }
+}

src/springBootWebhooks/java/gg/top/webhooks/springboot/TopggWebhookEventListener.java

@@ -0,0 +1,28 @@
+package gg.top.webhooks.springboot;
+
+import gg.top.webhooks.payload.IntegrationCreatePayload;
+import gg.top.webhooks.payload.IntegrationDeletePayload;
+import gg.top.webhooks.payload.TestPayload;
+import gg.top.webhooks.payload.VoteCreatePayload;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+public interface TopggWebhookEventListener<R> {
+  default ResponseEntity<R> onIntegrationCreate(
+      final IntegrationCreatePayload payload, final String trace) {
+    return ResponseEntity.status(HttpStatus.NO_CONTENT).build();
+  }
+
+  default ResponseEntity<R> onIntegrationDelete(
+      final IntegrationDeletePayload payload, final String trace) {
+    return ResponseEntity.status(HttpStatus.NO_CONTENT).build();
+  }
+
+  default ResponseEntity<R> onTest(final TestPayload payload, final String trace) {
+    return ResponseEntity.status(HttpStatus.NO_CONTENT).build();
+  }
+
+  default ResponseEntity<R> onVoteCreate(final VoteCreatePayload payload, final String trace) {
+    return ResponseEntity.status(HttpStatus.NO_CONTENT).build();
+  }
+}