feat: add option to generate clound event request in HTTP Sender Even…

README.md

@@ -96,6 +96,7 @@ Configuration values:
 | `backoffMaxInterval` | N | 60000 | Maximum back off time in milliseconds |
 | `backoffMultiplier` | N | 1.5 | Multiplier value (E.g. 1.5 is 50% increase per back off) |
 | `backoffRandomizationFactor` | N | 0.5 | Randomization factor (E.g. 0.5 results in a random period ranging between 50% below and 50% above the retry interval) |
+| `cloudEventEnabled` | N | false | Generate a cloud event request to Http Server |
 
 ### Adding Configuration to your EventListenerProvider
 

src/main/java/io/phasetwo/keycloak/events/HttpSenderEventListenerProvider.java

@@ -16,6 +16,8 @@
 import org.apache.http.impl.client.HttpClients;
 import org.keycloak.broker.provider.util.LegacySimpleHttp;
 import org.keycloak.models.KeycloakSession;
+import org.keycloak.representations.idm.AdminEventRepresentation;
+import org.keycloak.representations.idm.EventRepresentation;
 import org.keycloak.util.JsonSerialization;
 
 @JBossLog
@@ -30,6 +32,7 @@ public class HttpSenderEventListenerProvider extends SenderEventListenerProvider
   protected static final String BACKOFF_MAX_INTERVAL = "backoffMaxInterval";
   protected static final String BACKOFF_MULTIPLIER = "backoffMultiplier";
   protected static final String BACKOFF_RANDOMIZATION_FACTOR = "backoffRandomizationFactor";
+  protected static final String CLOUD_EVENTS_ENABLED = "cloudEventEnabled";
 
   public HttpSenderEventListenerProvider(KeycloakSession session, ScheduledExecutorService exec) {
     super(session, exec);
@@ -54,6 +57,10 @@ String getTargetUri() {
     return config.get(TARGET_URI).toString();
   }
 
+  Boolean getCloudEventsEnabled() {
+    return getBooleanOr(config, CLOUD_EVENTS_ENABLED, false);
+  }
+
   Optional<String> getSharedSecret() {
     return Optional.ofNullable(config.get(SHARED_SECRET)).map(Object::toString);
   }
@@ -78,6 +85,32 @@ protected void send(
               request.header(
                   "X-Keycloak-Signature",
                   hmacFor(task.getEvent(), secret, algorithm.orElse(HMAC_SHA256_ALGORITHM))));
+
+      if (getCloudEventsEnabled()) {
+        Object eventObject = null;
+        eventObject = task.getEvent();
+        if (eventObject instanceof EventRepresentation) {
+          EventRepresentation event = (EventRepresentation) eventObject;
+          request
+              .header("content-type", "application/json")
+              .header("ce-specversion", "1.0")
+              .header("ce-source", "keycloak")
+              .header("ce-type", event.getType())
+              .header("ce-id", event.getRealmId() + "-" + event.getTime())
+              .header("ce-partitionkey", event.getRealmId());
+
+        } else {
+          AdminEventRepresentation event = (AdminEventRepresentation) eventObject;
+          request
+              .header("content-type", "application/json")
+              .header("ce-specversion", "1.0")
+              .header("ce-source", "keycloak")
+              .header("ce-type", event.getOperationType() + "-" + event.getResourceType())
+              .header("ce-id", event.getRealmId() + "-" + event.getTime())
+              .header("ce-partitionkey", event.getRealmId());
+        }
+      }
+
       LegacySimpleHttp.Response response = request.asResponse();
       int status = response.getStatus();
       log.debugf("sent to %s (%d)", targetUri, status);

src/main/java/io/phasetwo/keycloak/events/WebhookSenderEventListenerProvider.java

@@ -159,7 +159,8 @@ private ExtendedAdminEvent completeAdminEventAttributes(String uid, Event event)
   private ExtendedAdminEvent completeAdminEventAttributes(String uid, AdminEvent adminEvent) {
     RealmModel eventRealm = session.realms().getRealm(adminEvent.getRealmId());
     RealmModel authRealm = session.realms().getRealm(adminEvent.getAuthDetails().getRealmId());
-    ExtendedAdminEvent extendedAdminEvent = new ExtendedAdminEvent(uid, adminEvent, eventRealm, authRealm);
+    ExtendedAdminEvent extendedAdminEvent =
+        new ExtendedAdminEvent(uid, adminEvent, eventRealm, authRealm);
     // add always missing agent username
     ExtendedAuthDetails extendedAuthDetails = extendedAdminEvent.getAuthDetails();
     if (!Strings.isNullOrEmpty(extendedAuthDetails.getUserId())) {

src/main/java/io/phasetwo/keycloak/representation/ExtendedAdminEvent.java

@@ -36,7 +36,8 @@ private static String createType(Event event) {
 
   public ExtendedAdminEvent() {}
 
-  public ExtendedAdminEvent(String uid, AdminEvent event, RealmModel eventRealm, RealmModel authRealm) {
+  public ExtendedAdminEvent(
+      String uid, AdminEvent event, RealmModel eventRealm, RealmModel authRealm) {
     this.uid = uid;
     this.type = createType(event);
 

src/test/java/io/phasetwo/keycloak/Helpers.java

@@ -88,18 +88,15 @@ public static String createWebhook(
   }
 
   public static void removeWebhook(
-	      Keycloak keycloak,
-	      CloseableHttpClient httpClient,
-	      String baseUrl,
-	      String webhookId)
-	      throws Exception {
+      Keycloak keycloak, CloseableHttpClient httpClient, String baseUrl, String webhookId)
+      throws Exception {
 
-	    LegacySimpleHttp.Response response =
-	        LegacySimpleHttp.doDelete(baseUrl + "/" + webhookId, httpClient)
-	            .auth(keycloak.tokenManager().getAccessTokenString())
-	            .asResponse();
-	    assertThat(response.getStatus(), is(204));
-	  }
+    LegacySimpleHttp.Response response =
+        LegacySimpleHttp.doDelete(baseUrl + "/" + webhookId, httpClient)
+            .auth(keycloak.tokenManager().getAccessTokenString())
+            .asResponse();
+    assertThat(response.getStatus(), is(204));
+  }
 
   public static String urlencode(String u) {
     try {