added a test to prove a zeebe worker value picks up the tenant ids

Author: jonathanlukas

spring-client-zeebe/src/test/java/io/camunda/zeebe/spring/client/bean/ClassInfoTest.java

@@ -8,6 +8,46 @@
 
 public class ClassInfoTest {
 
+  @Test
+  public void getBeanInfo() throws Exception {
+    final WithDeploymentAnnotation withDeploymentAnnotation = new WithDeploymentAnnotation();
+
+    final ClassInfo beanInfo = beanInfo(withDeploymentAnnotation);
+
+    assertThat(beanInfo.getBean()).isEqualTo(withDeploymentAnnotation);
+    assertThat(beanInfo.getBeanName()).isEqualTo("withDeploymentAnnotation");
+    assertThat(beanInfo.getTargetClass()).isEqualTo(WithDeploymentAnnotation.class);
+  }
+
+  @Test
+  public void hasZeebeeDeploymentAnnotation() throws Exception {
+    assertThat(beanInfo(new WithDeploymentAnnotation()).hasClassAnnotation(Deployment.class))
+        .isTrue();
+  }
+
+  @Test
+  public void hasNoZeebeeDeploymentAnnotation() throws Exception {
+    assertThat(beanInfo(new WithoutDeploymentAnnotation()).hasClassAnnotation(Deployment.class))
+        .isFalse();
+  }
+
+  @Test
+  public void hasZeebeWorkerMethod() throws Exception {
+    assertThat(beanInfo(new WithZeebeWorker()).hasMethodAnnotation(JobWorker.class)).isTrue();
+  }
+
+  @Test
+  public void hasNotZeebeWorkerMethod() throws Exception {
+    assertThat(beanInfo("normal String").hasMethodAnnotation(JobWorker.class)).isFalse();
+  }
+
+  private ClassInfo beanInfo(final Object bean) {
+    return ClassInfo.builder()
+        .bean(bean)
+        .beanName(Introspector.decapitalize(bean.getClass().getSimpleName()))
+        .build();
+  }
+
   @Deployment(resources = "classpath*:/1.bpmn")
   public static class WithDeploymentAnnotation {}
 
@@ -45,57 +85,22 @@ public void handle(@Variable String var1, @Variable int var2) {}
   }
 
   public static class WithZeebeWorkerVariablesComplexType {
+    @JobWorker(type = "bar", timeout = 100L, fetchVariables = "var2", autoComplete = false)
+    public void handle(@Variable String var1, @Variable ComplexTypeDTO var2) {}
+
     public static class ComplexTypeDTO {
       private String var1;
       private String var2;
     }
-
-    @JobWorker(type = "bar", timeout = 100L, fetchVariables = "var2", autoComplete = false)
-    public void handle(@Variable String var1, @Variable ComplexTypeDTO var2) {}
   }
 
   public static class NoPropertiesSet {
     @JobWorker
     public void handle() {}
   }
 
-  @Test
-  public void getBeanInfo() throws Exception {
-    final WithDeploymentAnnotation withDeploymentAnnotation = new WithDeploymentAnnotation();
-
-    final ClassInfo beanInfo = beanInfo(withDeploymentAnnotation);
-
-    assertThat(beanInfo.getBean()).isEqualTo(withDeploymentAnnotation);
-    assertThat(beanInfo.getBeanName()).isEqualTo("withDeploymentAnnotation");
-    assertThat(beanInfo.getTargetClass()).isEqualTo(WithDeploymentAnnotation.class);
-  }
-
-  @Test
-  public void hasZeebeeDeploymentAnnotation() throws Exception {
-    assertThat(beanInfo(new WithDeploymentAnnotation()).hasClassAnnotation(Deployment.class))
-        .isTrue();
-  }
-
-  @Test
-  public void hasNoZeebeeDeploymentAnnotation() throws Exception {
-    assertThat(beanInfo(new WithoutDeploymentAnnotation()).hasClassAnnotation(Deployment.class))
-        .isFalse();
-  }
-
-  @Test
-  public void hasZeebeWorkerMethod() throws Exception {
-    assertThat(beanInfo(new WithZeebeWorker()).hasMethodAnnotation(JobWorker.class)).isTrue();
-  }
-
-  @Test
-  public void hasNotZeebeWorkerMethod() throws Exception {
-    assertThat(beanInfo("normal String").hasMethodAnnotation(JobWorker.class)).isFalse();
-  }
-
-  private ClassInfo beanInfo(final Object bean) {
-    return ClassInfo.builder()
-        .bean(bean)
-        .beanName(Introspector.decapitalize(bean.getClass().getSimpleName()))
-        .build();
+  public static class TenantBound {
+    @JobWorker(tenantIds = "tenant-1")
+    public void handle() {}
   }
 }

spring-client-zeebe/src/test/java/io/camunda/zeebe/spring/client/bean/value/factory/ReadZeebeWorkerValueTest.java

@@ -1,5 +1,6 @@
 package io.camunda.zeebe.spring.client.bean.value.factory;
 
+import static org.assertj.core.api.Assertions.*;
 import static org.junit.jupiter.api.Assertions.assertArrayEquals;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -43,6 +44,21 @@ public void applyOnWithZeebeWorker() {
     assertEquals(methodInfo, zeebeWorkerValue.get().getMethodInfo());
   }
 
+  @Test
+  void shouldReadTenantIds() {
+    // given
+    final ZeebeWorkerAnnotationProcessor annotationProcessor = createDefaultAnnotationProcessor();
+    final MethodInfo methodInfo = extract(ClassInfoTest.TenantBound.class);
+
+    // when
+    final Optional<ZeebeWorkerValue> zeebeWorkerValue =
+        annotationProcessor.readJobWorkerAnnotationForMethod(methodInfo);
+
+    // then
+    assertTrue(zeebeWorkerValue.isPresent());
+    assertThat(zeebeWorkerValue.get().getTenantIds()).containsOnly("tenant-1");
+  }
+
   @Test
   public void applyOnWithZeebeWorkerAllValues() {
     // given