Added sns implementation for sending notification regarding saml authenticated user data changes

Author: Tanishka Jain

Jenkinsfile

@@ -58,7 +58,8 @@ pipeline
                         }
                         dir('uaa/iam-k8s-utils') {
                             git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
-                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git'
+                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git',
+                                branch: 'aws-sdk-for-sns-sqs'
                         }
                         sh '''#!/bin/bash -ex
                             source uaa-cf-release/config-local/set-env.sh
@@ -110,7 +111,8 @@ pipeline
                         }
                         dir('uaa/iam-k8s-utils') {
                             git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
-                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git'
+                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git',
+                                branch: 'aws-sdk-for-sns-sqs'
                         }
                         sh '''#!/bin/bash -ex
                                 source uaa-cf-release/config-local/set-env.sh
@@ -186,7 +188,8 @@ pipeline
                         }
                         dir('uaa/iam-k8s-utils') {
                             git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
-                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git'
+                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git',
+                                branch: 'aws-sdk-for-sns-sqs'
                         }
                         sh '''#!/bin/bash -ex
                             source uaa-cf-release/config-local/set-env.sh
@@ -256,7 +259,8 @@ pipeline
                 }
                 dir('uaa/iam-k8s-utils') {
                     git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
-                        url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git'
+                        url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git',
+                        branch: 'aws-sdk-for-sns-sqs'
                 }
 
                 sh '''#!/bin/bash -ex
@@ -477,7 +481,8 @@ pipeline
                         }
                         dir('uaa/iam-k8s-utils') {
                             git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
-                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git'
+                                url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git',
+                                branch: 'aws-sdk-for-sns-sqs'
                         }
                         dir('uaa-k8s-deploy') {
                             git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
@@ -622,6 +627,7 @@ pipeline
                             dir('uaa/iam-k8s-utils') {
                                 git changelog: false, credentialsId: 'github.software.gevernova.com', poll: false,
                                 url: 'https://github.software.gevernova.com/pers/iam-k8s-utils.git'
+                                branch: 'aws-sdk-for-sns-sqs'
                             }
                             withSonarQubeEnv('SONAR_INSTANCE') {
                                 sh """

build.gradle

@@ -454,3 +454,7 @@ task jacocoRootReport(type: org.gradle.testing.jacoco.tasks.JacocoReport) {
     }
     dependsOn subprojects.test
 }
+
+tasks.withType(Test).configureEach {
+    systemProperty 'deployment.region', project.findProperty('deployment.region') ?: 'us-west-2'
+}

dependencies.gradle

@@ -21,6 +21,7 @@ versions.tomcatCargoVersion = "9.0.60"
 versions.guavaVersion = "31.1-jre"
 versions.springCloud = "2.0.9.RELEASE"
 versions.jakartaElVersion = "3.0.4"
+versions.awsSdkVersion = "2.18.0"
 
 // Dependencies (some rely on shared versions, some are shared between projects)
 libraries.apacheCommonsRngCore = "org.apache.commons:commons-rng-core:1.4"

gradle.properties

@@ -4,6 +4,8 @@ version=75.18.1
 org.gradle.jvmargs=-Dfile.encoding=utf8 -XX:+StartAttachListener -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=/var/log/uaa-tests.hprof
 org.gradle.workers.max=6
 
+deployment.region=us-west-2
+
 org.gradle.parallel=true
 
 signing.keyId=

k8s/templates/uaa.lib.yml

@@ -5,6 +5,8 @@
 ---
 issuer:
   uri: #@ data.values.issuer.uri
+deployment:
+  region: 'us-west-2'
 
 #! The secret that an external login server will use to authenticate to the uaa using the id `login`
 LOGIN_SECRET: loginsecret

k8s/templates/values/_values.yml

@@ -27,6 +27,8 @@ resources:
 
 issuer:
   uri: http://localhost:8080/uaa
+deployment:
+  region: us-west-2
 
 tomcat:
   accessLoggingEnabled: "y"

server/build.gradle

@@ -5,6 +5,7 @@ description = "CloudFoundry Identity Server JAR"
 dependencies {
     implementation(project(":cloudfoundry-identity-metrics-data"))
     implementation(project(":cloudfoundry-identity-model"))
+    implementation(project(":iam-k8s-utils"))  // Added dependency to iam-k8s-utils module
 
     implementation(libraries.tomcatJdbc)
     providedCompile(libraries.tomcatEmbed)

server/src/main/java/org/cloudfoundry/identity/uaa/authentication/event/UserLoginSuccessEvent.java

@@ -0,0 +1,35 @@
+package org.cloudfoundry.identity.uaa.events;
+
+import org.cloudfoundry.identity.uaa.user.UaaUser;
+import org.springframework.context.ApplicationEvent;
+
+/**
+ * Event published when user attributes change
+ * This event is processed asynchronously to publish SNS notifications
+ */
+public class UserAttributeChangedEvent extends ApplicationEvent {
+
+    private final UaaUser existingUser;
+    private final UaaUser updatedUser;
+
+    public UserAttributeChangedEvent(Object source, UaaUser existingUser, UaaUser updatedUser) {
+        super(source);
+        this.existingUser = existingUser;
+        this.updatedUser = updatedUser;
+    }
+
+    public UaaUser getExistingUser() {
+        return existingUser;
+    }
+
+    public UaaUser getUpdatedUser() {
+        return updatedUser;
+    }
+
+    @Override
+    public String toString() {
+        return "UserAttributeChangedEvent{" +
+                "userId=" + (updatedUser != null ? updatedUser.getId() : "null") +
+                '}';
+    }
+}