mirror/keycloak
1
0
Fork 0
mirror of https://github.com/keycloak/keycloak.git synced 2025-12-16 20:15:46 -06:00
Code Issues Packages Projects Releases Wiki Activity

Rename workflow events

Browse Source 
- USER_ADDED -> USER_CREATED
- USER_ROLE_ADDED -> USER_ROLE_GRANTED
- USER_ROLE_REMOVED -> USER_ROLE_REVOKED

Closes #44879

Signed-off-by: Stefan Guilhen <sguilhen@redhat.com>
This commit is contained in:
Stefan Guilhen
2025-12-12 11:41:26 -03:00
committed by Pedro Igor
parent 7858e6ff6b
commit 22c144dd30
13 changed files with 47 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server-spi-private/src/main/java/org/keycloak/models/workflow/ResourceOperationType.java
View File

@@ -22,14 +22,14 @@ import static org.keycloak.models.utils.KeycloakModelUtils.GROUP_PATH_SEPARATOR;
public enum ResourceOperationType {
USER_ADDED(List.of(OperationType.CREATE, EventType.REGISTER)),
USER_CREATED(List.of(OperationType.CREATE, EventType.REGISTER)),
USER_AUTHENTICATED(List.of(EventType.LOGIN), userLoginPredicate()),
USER_FEDERATED_IDENTITY_ADDED(List.of(FederatedIdentityCreatedEvent.class), fedIdentityPredicate()),
USER_FEDERATED_IDENTITY_REMOVED(List.of(FederatedIdentityRemovedEvent.class), fedIdentityPredicate()),
USER_GROUP_MEMBERSHIP_ADDED(List.of(GroupMemberJoinEvent.class), groupMembershipPredicate()),
USER_GROUP_MEMBERSHIP_REMOVED(List.of(GroupModel.GroupMemberLeaveEvent.class), groupMembershipPredicate()),
USER_ROLE_ADDED(List.of(RoleGrantedEvent.class), roleMembershipPredicate()),
USER_ROLE_REMOVED(List.of(RoleModel.RoleRevokedEvent.class), roleMembershipPredicate()),
USER_ROLE_GRANTED(List.of(RoleGrantedEvent.class), roleMembershipPredicate()),
USER_ROLE_REVOKED(List.of(RoleModel.RoleRevokedEvent.class), roleMembershipPredicate()),
AD_HOC(List.of(new Class[] {}));
private final List<Object> types;

4
tests/base/src/test/java/org/keycloak/tests/workflow/AddRequiredActionTest.java
View File

@@ -14,7 +14,7 @@ import org.awaitility.Awaitility;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.hasSize;
@@ -26,7 +26,7 @@ public class AddRequiredActionTest extends AbstractWorkflowTest {
@Test
public void testStepRun() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create()
.of(AddRequiredActionStepProviderFactory.ID)

6
tests/base/src/test/java/org/keycloak/tests/workflow/AdhocWorkflowTest.java
View File

@@ -21,7 +21,7 @@ import org.keycloak.testframework.util.ApiUtil;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.hasItems;
@@ -200,7 +200,7 @@ public class AdhocWorkflowTest extends AbstractWorkflowTest {
@Test
public void testDeactivateWorkflowForResource() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("One")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create()
.of(SetUserAttributeStepProviderFactory.ID)
@@ -214,7 +214,7 @@ public class AdhocWorkflowTest extends AbstractWorkflowTest {
)
.build()).close();
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("Two")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create()
.of(SetUserAttributeStepProviderFactory.ID)

6
tests/base/src/test/java/org/keycloak/tests/workflow/BrokeredUserSessionRefreshTimeWorkflowTest.java
View File

@@ -69,8 +69,8 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_AUTHENTICATED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.allOf;
@@ -133,7 +133,7 @@ public class BrokeredUserSessionRefreshTimeWorkflowTest extends AbstractWorkflow
public void testInvalidateWorkflowOnIdentityProviderRemoval() {
String workflowId;
try (Response response = consumerRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.toString(), USER_AUTHENTICATED.toString())
.onEvent(USER_CREATED.toString(), USER_AUTHENTICATED.toString())
.onCondition(IDP_CONDITION)
.withSteps(
WorkflowStepRepresentation.create().of(DeleteUserStepProviderFactory.ID)
@@ -171,7 +171,7 @@ public class BrokeredUserSessionRefreshTimeWorkflowTest extends AbstractWorkflow
@Test
public void tesRunStepOnFederatedUser() {
consumerRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.toString(), USER_AUTHENTICATED.toString())
.onEvent(USER_CREATED.toString(), USER_AUTHENTICATED.toString())
.onCondition(IDP_CONDITION)
.withSteps(
WorkflowStepRepresentation.create().of(DeleteUserStepProviderFactory.ID)

4
tests/base/src/test/java/org/keycloak/tests/workflow/GroupMembershipJoinWorkflowTest.java
View File

@@ -31,8 +31,8 @@ import org.keycloak.testframework.util.ApiUtil;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_AUTHENTICATED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.allOf;
@@ -106,7 +106,7 @@ public class GroupMembershipJoinWorkflowTest extends AbstractWorkflowTest {
String workflowId;
try (Response response = managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.toString(), USER_AUTHENTICATED.toString())
.onEvent(USER_CREATED.toString(), USER_AUTHENTICATED.toString())
.onCondition(GROUP_CONDITION)
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)

4
tests/base/src/test/java/org/keycloak/tests/workflow/NotificationStepTest.java
View File

@@ -39,7 +39,7 @@ import org.keycloak.tests.utils.MailUtils;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -60,7 +60,7 @@ public class NotificationStepTest extends AbstractWorkflowTest {
public void testNotifyUserStepWithCustomMessageOverride() throws IOException {
// Create workflow: disable at 7 days, notify 2 days before (at day 5) with custom message
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.withConfig("message", "<p>Dear ${user.firstName} ${user.lastName}, </p>\n" +

6
tests/base/src/test/java/org/keycloak/tests/workflow/RoleBasedStepTest.java
View File

@@ -31,7 +31,7 @@ import org.awaitility.Awaitility;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.containsInAnyOrder;
@@ -60,7 +60,7 @@ public class RoleBasedStepTest extends AbstractWorkflowTest {
List<String> expectedRoles = Stream.concat(expectedRealmRoles.stream(), expectedClientRoles.stream()).toList();
create(WorkflowRepresentation.withName("grant-roles")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create()
.of(GrantRoleStepProviderFactory.ID)
@@ -91,7 +91,7 @@ public class RoleBasedStepTest extends AbstractWorkflowTest {
grantRole(user, "realm-role-a", "realm-role-b", "realm-role-c", "myclient/client-role-a", "myclient/client-role-c");
create(WorkflowRepresentation.withName("revoke-roles")
.onEvent(ResourceOperationType.USER_ROLE_REMOVED.name())
.onEvent(ResourceOperationType.USER_ROLE_REVOKED.name())
.withSteps(
WorkflowStepRepresentation.create()
.of(RevokeRoleStepProviderFactory.ID)

4
tests/base/src/test/java/org/keycloak/tests/workflow/RoleWorkflowConditionTest.java
View File

@@ -84,7 +84,7 @@ public class RoleWorkflowConditionTest extends AbstractWorkflowTest {
}
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("test-role-workflow")
.onEvent(ResourceOperationType.USER_ROLE_ADDED.name())
.onEvent(ResourceOperationType.USER_ROLE_GRANTED.name())
.onCondition(RoleWorkflowConditionFactory.ID + "(testRole)")
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
@@ -165,7 +165,7 @@ public class RoleWorkflowConditionTest extends AbstractWorkflowTest {
.reduce((a, b) -> a + " AND " + b).orElse(null);
WorkflowRepresentation expectedWorkflow = WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ROLE_ADDED.name())
.onEvent(ResourceOperationType.USER_ROLE_GRANTED.name())
.onCondition(roleCondition)
.withSteps(
WorkflowStepRepresentation.create()

4
tests/base/src/test/java/org/keycloak/tests/workflow/StepRunnerScheduledTaskTest.java
View File

@@ -43,7 +43,7 @@ import org.keycloak.testframework.realm.UserConfigBuilder;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -71,7 +71,7 @@ public class StepRunnerScheduledTaskTest extends AbstractWorkflowTest {
RealmResource realm = adminClient.realm(realmName);
realm.workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(SetUserAttributeStepProviderFactory.ID)
.after(Duration.ofDays(5))

2
tests/base/src/test/java/org/keycloak/tests/workflow/UserAttributeWorkflowConditionTest.java
View File

@@ -154,7 +154,7 @@ public class UserAttributeWorkflowConditionTest extends AbstractWorkflowTest {
.orElse(null);
WorkflowRepresentation expectedWorkflow = WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.name())
.onEvent(ResourceOperationType.USER_CREATED.name())
.onCondition(attributeCondition)
.withSteps(
WorkflowStepRepresentation.create()

4
tests/base/src/test/java/org/keycloak/tests/workflow/UserResourceTypeSelectorTest.java
View File

@@ -20,7 +20,7 @@ import org.keycloak.testframework.mail.annotations.InjectMailServer;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.keycloak.tests.workflow.WorkflowManagementTest.findEmailByRecipient;
import static org.junit.jupiter.api.Assertions.assertFalse;
@@ -37,7 +37,7 @@ public class UserResourceTypeSelectorTest extends AbstractWorkflowTest {
@Test
public void testDisableUserBasedOnCreationDate() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))

8
tests/base/src/test/java/org/keycloak/tests/workflow/UserSessionRefreshTimeWorkflowTest.java
View File

@@ -39,8 +39,8 @@ import org.keycloak.testframework.realm.UserConfigBuilder;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_AUTHENTICATED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.keycloak.tests.workflow.WorkflowManagementTest.findEmailByRecipient;
import static org.keycloak.tests.workflow.WorkflowManagementTest.findEmailsByRecipient;
import static org.keycloak.tests.workflow.WorkflowManagementTest.verifyEmailContent;
@@ -63,7 +63,7 @@ public class UserSessionRefreshTimeWorkflowTest extends AbstractWorkflowTest {
@Test
public void testDisabledUserAfterInactivityPeriod() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.toString(), USER_AUTHENTICATED.toString())
.onEvent(USER_CREATED.toString(), USER_AUTHENTICATED.toString())
.concurrency().restartInProgress("true") // this setting enables restarting the workflow
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
@@ -138,7 +138,7 @@ public class UserSessionRefreshTimeWorkflowTest extends AbstractWorkflowTest {
@Test
public void testMultipleWorkflows() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.toString(), USER_AUTHENTICATED.toString())
.onEvent(USER_CREATED.toString(), USER_AUTHENTICATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -147,7 +147,7 @@ public class UserSessionRefreshTimeWorkflowTest extends AbstractWorkflowTest {
.build())
.build()).close();
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow_2")
.onEvent(USER_ADDED.toString(), USER_AUTHENTICATED.toString())
.onEvent(USER_CREATED.toString(), USER_AUTHENTICATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(10))

36
tests/base/src/test/java/org/keycloak/tests/workflow/WorkflowManagementTest.java
View File

@@ -81,7 +81,7 @@ import org.hamcrest.Matchers;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import static org.keycloak.models.workflow.ResourceOperationType.USER_ADDED;
import static org.keycloak.models.workflow.ResourceOperationType.USER_CREATED;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.containsInAnyOrder;
@@ -116,7 +116,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testCreate() {
WorkflowRepresentation expectedWorkflow = WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -187,7 +187,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
String workflowId;
try (Response response = workflows.create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -390,7 +390,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
String[] workflowNames = {"alpha-workflow", "beta-workflow", "gamma-workflow", "delta-workflow"};
for (String name : workflowNames) {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName(name)
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -476,7 +476,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testWorkflowDoesNotFallThroughStepsInSingleRun() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -675,7 +675,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
// create a test workflow
String workflowId;
try (Response response = managedRealm.admin().workflows().create(WorkflowRepresentation.withName("test-workflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -772,7 +772,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testRestartWorkflow() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -841,7 +841,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testRestartFromPosition() {
try (Response response = managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -858,7 +858,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
is("No scheduled step found if restarting at position 1"));
}
try (Response response = managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -875,7 +875,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
is("No scheduled step found if restarting at position 2"));
}
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -975,7 +975,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testRestartFromLastStep() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(ResourceOperationType.USER_ADDED.toString())
.onEvent(ResourceOperationType.USER_CREATED.toString())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -1076,7 +1076,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
public void testRunImmediateWorkflow() {
// create a test workflow with no time conditions - should run immediately when scheduled
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(SetUserAttributeStepProviderFactory.ID)
.withConfig("message", "message")
@@ -1102,7 +1102,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testFailCreateWorkflowWithNegativeTime() {
WorkflowRepresentation workflow = WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(SetUserAttributeStepProviderFactory.ID)
.after(Duration.ofDays(-5))
@@ -1119,7 +1119,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
public void testNotifyUserStepSendsEmailWithDefaultDisableMessage() {
// Create workflow: disable at 10 days, notify 3 days before (at day 7)
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(7))
@@ -1147,7 +1147,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
public void testNotifyUserStepSendsEmailWithDefaultDeleteMessage() {
// Create workflow: delete at 30 days, notify 15 days before (at day 15)
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(15))
@@ -1175,7 +1175,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
public void testNotifyUserStepWithCustomMessageOverride() {
// Create workflow: disable at 7 days, notify 2 days before (at day 5) with custom message
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -1204,7 +1204,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
@Test
public void testNotifyUserStepSkipsUsersWithoutEmailButLogsWarning() {
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(5))
@@ -1235,7 +1235,7 @@ public class WorkflowManagementTest extends AbstractWorkflowTest {
public void testCompleteUserLifecycleWithMultipleNotifications() {
// Create workflow: just disable at 30 days with one notification before
managedRealm.admin().workflows().create(WorkflowRepresentation.withName("myworkflow")
.onEvent(USER_ADDED.name())
.onEvent(USER_CREATED.name())
.withSteps(
WorkflowStepRepresentation.create().of(NotifyUserStepProviderFactory.ID)
.after(Duration.ofDays(15))