OP-21175: Publish user details as events to rabbitmq.

gate-web/gate-web.gradle

@@ -56,7 +56,9 @@ dependencies {
 
 
   implementation group: 'org.springframework.cloud', name: 'spring-cloud-starter-openfeign', version: '2.2.4.RELEASE'
-
+  implementation 'org.apache.camel:camel-core:3.14.1'
+  implementation 'org.apache.camel:camel-rabbitmq:3.14.1'
+  implementation 'org.apache.camel:camel-jackson:3.14.1'
 
   runtimeOnly "io.spinnaker.kork:kork-runtime"
   runtimeOnly "org.springframework.boot:spring-boot-properties-migrator"

gate-web/src/main/java/com/netflix/spinnaker/gate/config/CamelConfig.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright 2015 OpsMx, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.netflix.spinnaker.gate.config;
+
+import java.util.concurrent.TimeUnit;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.camel.CamelContext;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Slf4j
+@Configuration
+@ConditionalOnExpression("${message-broker.enabled:true}")
+public class CamelConfig {
+
+  @Autowired private UserActivityRouteBuilder userActivityRouteBuilder;
+
+  @Bean
+  public CamelContext camelContext() throws Exception {
+    CamelContext camelContext = new DefaultCamelContext();
+    camelContext.addRoutes(userActivityRouteBuilder);
+    camelContext.getShutdownStrategy().setShutdownNowOnTimeout(true);
+    camelContext.getShutdownStrategy().setTimeout(5);
+    camelContext.getShutdownStrategy().setTimeUnit(TimeUnit.SECONDS);
+    camelContext.start();
+    return camelContext;
+  }
+
+  @Bean
+  public ProducerTemplate producerTemplate(CamelContext camelContext) {
+    return camelContext.createProducerTemplate();
+  }
+}

gate-web/src/main/java/com/netflix/spinnaker/gate/config/CamelRouteConfig.java

@@ -0,0 +1,21 @@
+/*
+ * Copyright 2015 OpsMx, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.netflix.spinnaker.gate.config;
+
+public interface CamelRouteConfig {
+  String getUserActivityQueueEndPoint();
+}

gate-web/src/main/java/com/netflix/spinnaker/gate/config/MessageBrokerProperties.java

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2015 OpsMx, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.netflix.spinnaker.gate.config;
+
+import lombok.Data;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "message-broker")
+@ConditionalOnExpression("${message-broker.enabled:true}")
+@EnableConfigurationProperties({
+  MessageBrokerProperties.class,
+  MessageBrokerProperties.Endpoint.class
+})
+public class MessageBrokerProperties {
+
+  private boolean enabled;
+  private String username;
+  private String password;
+  private String host;
+  private String port;
+  private Endpoint endpoint;
+
+  @Data
+  @Configuration
+  @ConditionalOnExpression("${message-broker.enabled:true}")
+  @ConfigurationProperties(prefix = "message-broker.endpoint")
+  public static class Endpoint {
+    private String name;
+  }
+}

gate-web/src/main/java/com/netflix/spinnaker/gate/config/RabbitMQConfig.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright 2015 OpsMx, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.netflix.spinnaker.gate.config;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConditionalOnExpression("${message-broker.enabled:true}")
+@ConditionalOnProperty(value = "message-broker.endpoint.name", havingValue = "rabbitmq")
+public class RabbitMQConfig implements CamelRouteConfig {
+
+  @Autowired private MessageBrokerProperties messageBrokerProperties;
+  private static final String isdExchange = "isd.userLoginDetails";
+  private String directUserActivity = "userLoginDetails";
+
+  @Override
+  public String getUserActivityQueueEndPoint() {
+    return messageBrokerProperties.getEndpoint().getName()
+        + ":"
+        + isdExchange
+        + "?queue="
+        + directUserActivity
+        + "&autoDelete=false&routingKey="
+        + directUserActivity
+        + "&declare=true&durable=true&exchangeType=direct&hostname="
+        + messageBrokerProperties.getHost()
+        + "&portNumber="
+        + messageBrokerProperties.getPort()
+        + "&username="
+        + messageBrokerProperties.getUsername()
+        + "&password="
+        + messageBrokerProperties.getPassword();
+  }
+}

gate-web/src/main/java/com/netflix/spinnaker/gate/config/UserActivityRouteBuilder.java

@@ -0,0 +1,41 @@
+/*
+ * Copyright 2015 OpsMx, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.netflix.spinnaker.gate.config;
+
+import static com.opsmx.spinnaker.gate.constant.CamelEndpointConstant.directUserActivity;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConditionalOnExpression("${message-broker.enabled:true}")
+public class UserActivityRouteBuilder extends RouteBuilder {
+
+  private final String userActivity = "userActivity";
+  @Autowired private CamelRouteConfig camelRouteConfig;
+
+  @Override
+  public void configure() throws Exception {
+
+    from(directUserActivity)
+        .id(userActivity)
+        .to(camelRouteConfig.getUserActivityQueueEndPoint())
+        .end();
+  }
+}

gate-web/src/main/java/com/opsmx/spinnaker/gate/audit/AuditHandler.java

@@ -20,5 +20,5 @@
 
 public interface AuditHandler {
 
-  void publishEvent(AuditEventType auditEventType, Object auditData);
+  String publishEvent(AuditEventType auditEventType, Object auditData);
 }

gate-web/src/main/java/com/opsmx/spinnaker/gate/audit/AuditRestApiHandler.java

@@ -16,10 +16,12 @@
 
 package com.opsmx.spinnaker.gate.audit;
 
+import com.google.gson.Gson;
 import com.opsmx.spinnaker.gate.enums.AuditEventType;
 import com.opsmx.spinnaker.gate.feignclient.AuditService;
 import com.opsmx.spinnaker.gate.model.OesAuditModel;
 import java.util.UUID;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.cloud.openfeign.EnableFeignClients;
@@ -28,16 +30,21 @@
 @Component
 @EnableFeignClients(basePackageClasses = AuditService.class)
 @ConditionalOnExpression("${services.auditservice.enabled:true}")
+@Slf4j
 public class AuditRestApiHandler implements AuditHandler {
 
   @Autowired private AuditService auditService;
+  Gson gson = new Gson();
 
   @Override
-  public void publishEvent(AuditEventType auditEventType, Object auditData) {
+  public String publishEvent(AuditEventType auditEventType, Object auditData) {
     OesAuditModel oesAuditModel = new OesAuditModel();
     oesAuditModel.setEventId(UUID.randomUUID().toString());
     oesAuditModel.setAuditData(auditData);
     oesAuditModel.setEventType(auditEventType);
     auditService.publishAuditData(oesAuditModel, "OES");
+    String model = gson.toJson(oesAuditModel, OesAuditModel.class);
+    log.debug("model: {}", model);
+    return model;
   }
 }

gate-web/src/main/java/com/opsmx/spinnaker/gate/audit/AuthenticationAuditListener.java

@@ -16,15 +16,18 @@
 
 package com.opsmx.spinnaker.gate.audit;
 
+import com.google.gson.Gson;
+import com.opsmx.spinnaker.gate.constant.CamelEndpointConstant;
 import com.opsmx.spinnaker.gate.enums.AuditEventType;
 import com.opsmx.spinnaker.gate.model.AuditData;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Optional;
+import com.opsmx.spinnaker.gate.model.OesAuditModel;
+import java.util.*;
 import java.util.stream.Collectors;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.camel.ProducerTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.actuate.security.AbstractAuthenticationAuditListener;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.security.authentication.AbstractAuthenticationToken;
@@ -38,6 +41,9 @@
 public class AuthenticationAuditListener extends AbstractAuthenticationAuditListener {
 
   @Autowired private AuditHandler auditHandler;
+  @Autowired @Lazy private ProducerTemplate template;
+
+  Gson gson = new Gson();
 
   @Async
   @Override
@@ -56,11 +62,15 @@ public void onApplicationEvent(AbstractAuthenticationEvent event) {
       if (event.getAuthentication().isAuthenticated()
           && event instanceof AuthenticationSuccessEvent) {
         log.debug("publishEvent AuthenticationSuccessEvent");
-        auditHandler.publishEvent(AuditEventType.AUTHENTICATION_SUCCESSFUL_AUDIT, event);
+        template.asyncSendBody(
+            CamelEndpointConstant.directUserActivity,
+            auditHandler.publishEvent(AuditEventType.AUTHENTICATION_SUCCESSFUL_AUDIT, event));
       } else if (!event.getAuthentication().isAuthenticated()
           && event instanceof AbstractAuthenticationFailureEvent) {
         log.debug("publishEvent AbstractAuthenticationFailureEvent");
-        auditHandler.publishEvent(AuditEventType.AUTHENTICATION_FAILURE_AUDIT, event);
+        template.asyncSendBody(
+            CamelEndpointConstant.directUserActivity,
+            auditHandler.publishEvent(AuditEventType.AUTHENTICATION_FAILURE_AUDIT, event));
       } else if (event instanceof LogoutSuccessEvent) {
         if (event
             .getAuthentication()
@@ -73,10 +83,16 @@ public void onApplicationEvent(AbstractAuthenticationEvent event) {
         }
         log.debug("publishEvent LogoutSuccessEvent");
         auditHandler.publishEvent(AuditEventType.SUCCESSFUL_USER_LOGOUT_AUDIT, event);
+        AbstractAuthenticationToken auth = (AbstractAuthenticationToken) event.getAuthentication();
+        String name = auth.getName();
+        template.asyncSendBody(
+            CamelEndpointConstant.directUserActivity,
+            getOesAuditModel(
+                name, event.getTimestamp(), AuditEventType.SUCCESSFUL_USER_LOGOUT_AUDIT));
       }
 
     } catch (Exception e) {
-      log.error("Exception occured while capturing audit events : {}", e);
+      log.error("Exception occurred while capturing audit events : {}", e);
     }
   }
 
@@ -88,7 +104,23 @@ private void handleAuthenticationEvent(
         Optional.ofNullable(auth.getAuthorities()).orElse(new ArrayList<>()).stream()
             .map(GrantedAuthority::getAuthority)
             .collect(Collectors.toList());
-    AuditData data = new AuditData(name, roles);
+    AuditData data = new AuditData(name, roles, event.getTimestamp());
     auditHandler.publishEvent(eventType, data);
+    template.asyncSendBody(
+        CamelEndpointConstant.directUserActivity,
+        getOesAuditModel(name, event.getTimestamp(), eventType));
+  }
+
+  private String getOesAuditModel(String name, Long timestamp, AuditEventType eventType) {
+    OesAuditModel oesAuditModel = new OesAuditModel();
+    Map<String, Object> date = new HashMap<>();
+    date.put("userName", name);
+    date.put("timestamp", timestamp);
+    oesAuditModel.setEventId(UUID.randomUUID().toString());
+    oesAuditModel.setAuditData(date);
+    oesAuditModel.setEventType(eventType);
+    String model = gson.toJson(oesAuditModel, OesAuditModel.class);
+    log.debug("model: {}", model);
+    return model;
   }
 }