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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.model.container.processing.test;
import com.yahoo.config.model.builder.xml.test.DomBuilderTest;
import com.yahoo.vespa.model.builder.xml.dom.chains.processing.DomProcessingBuilder;
import com.yahoo.vespa.model.container.component.chain.ChainedComponent;
import com.yahoo.vespa.model.container.component.chain.Chains;
import com.yahoo.vespa.model.container.processing.ProcessingChain;
import com.yahoo.vespa.model.container.processing.Processor;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.w3c.dom.Element;
import java.util.Collection;
import static org.junit.jupiter.api.Assertions.assertEquals;
/**
* @author bratseth
* @author gjoranv
*/
public class ProcessingChainsTest extends DomBuilderTest {
private Chains<ProcessingChain> processingChains;
@BeforeEach
public void setupProcessingChains() {
DomProcessingBuilder processingBuilder = new DomProcessingBuilder(null);
processingBuilder.build(root.getDeployState(), root, servicesXml());
processingChains = (Chains<ProcessingChain>)root.getChildren().get("processing");
}
private Element servicesXml() {
return parse(
"<processing>",
" <processor id='processor1' class='com.yahoo.test.Processor1' />",
" <renderer id='renderer1' class='com.yahoo.renderer.Renderer'/>",
" <chain id='default'>",
" <processor idref='processor1'/>",
" <processor id='processor2' class='com.yahoo.test.Processor2'/>",
" </chain>",
"</processing>");
}
@Test
void testProcessingChainConfiguration() {
ProcessingChain defaultChain = processingChains.allChains().getComponent("default");
assertEquals("default", defaultChain.getId().stringValue());
assertEquals(1, defaultChain.getInnerComponents().size());
Collection<ChainedComponent<?>> outerProcessors = processingChains.getComponentGroup().getComponents();
assertEquals(1, outerProcessors.size());
assertEquals("processor1", outerProcessors.iterator().next().getComponentId().toString());
Collection<Processor> innerProcessors = defaultChain.getInnerComponents();
assertEquals("processor2", innerProcessors.iterator().next().getComponentId().toString());
}
@Test
void require_that_processors_have_correct_class() {
ChainedComponent<?> processor1 = processingChains.getComponentGroup().getComponents().iterator().next();
assertEquals("com.yahoo.test.Processor1", processor1.model.bundleInstantiationSpec.classId.stringValue());
ProcessingChain defaultChain = processingChains.allChains().getComponent("default");
Processor processor2 = defaultChain.getInnerComponents().iterator().next();
assertEquals("com.yahoo.test.Processor2", processor2.model.bundleInstantiationSpec.classId.stringValue());
}
}
|
