Initial commit: bositao cloud (jnpf-java-cloud-v6x)

刘光辉

6 小时以前 06f314545ac3514d7ce28939920866ae8188d31c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package jnpf.limsService.impl;
 
import jnpf.lims.api.model.TestWorkItemRequestIdentityActorRequest;
import jnpf.lims.api.model.TestWorkItemRequestIdentityBatch;
import jnpf.lims.api.model.TestWorkItemRequestIdentityRequest;
import org.junit.Test;
 
import java.util.Collections;
import java.util.concurrent.atomic.AtomicReference;
 
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertSame;
 
public class LimsTestWorkItemRequestIdentityActorServiceImplTest {
 
    @Test
    public void routesTheInternalLookupToTheRequestedTenantAndAlwaysClearsIt() {
        TestWorkItemRequestIdentityBatch expected = new TestWorkItemRequestIdentityBatch();
        AtomicReference<String> routedTenant = new AtomicReference<>();
        AtomicReference<String> serviceTenant = new AtomicReference<>();
        AtomicReference<Boolean> cleared = new AtomicReference<>(false);
        LimsTestWorkItemRequestIdentityActorServiceImpl service =
                new LimsTestWorkItemRequestIdentityActorServiceImpl(
                        (tenantId, request) -> {
                            serviceTenant.set(tenantId);
                            return expected;
                        }, new LimsTestWorkItemRequestIdentityActorServiceImpl.TenantRoute() {
                            @Override public void switchTo(String tenantId) {
                                routedTenant.set(tenantId);
                            }
                            @Override public void clear() {
                                cleared.set(true);
                            }
                        });
        TestWorkItemRequestIdentityRequest request = new TestWorkItemRequestIdentityRequest();
        request.setTestWorkItemIds(Collections.singletonList("item-1"));
        TestWorkItemRequestIdentityActorRequest actor =
                new TestWorkItemRequestIdentityActorRequest();
        actor.setTenantId(" tenant-a ");
        actor.setRequest(request);
 
        TestWorkItemRequestIdentityBatch actual = service.resolve(actor);
 
        assertSame(expected, actual);
        assertEquals("tenant-a", routedTenant.get());
        assertEquals("tenant-a", serviceTenant.get());
        assertEquals(Boolean.TRUE, cleared.get());
    }
}