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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.application.container;
import com.yahoo.application.Networking;
import com.yahoo.application.container.processors.Rot13Processor;
import com.yahoo.component.ComponentSpecification;
import com.yahoo.container.Container;
import com.yahoo.processing.Request;
import com.yahoo.processing.Response;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import java.nio.charset.StandardCharsets;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* @author Einar M R Rosenvinge
*/
public class ContainerProcessingTest {
private static String getXML(String chainName, String... processorIds) {
String xml =
"<container version=\"1.0\">\n" +
" <processing>\n" +
" <chain id=\"" + chainName + "\">\n";
for (String processorId : processorIds) {
xml += " <processor id=\"" + processorId + "\"/>\n";
}
xml +=
" </chain>\n" +
" </processing>\n" +
" <accesslog type=\"disabled\" />" +
"</container>\n";
return xml;
}
@BeforeEach
public void resetContainer() {
Container.resetInstance();
}
@Test
void requireThatBasicProcessingWorks() {
try (JDisc container = getContainerWithRot13()) {
Processing processing = container.processing();
Request req = new Request();
req.properties().set("title", "Good day!");
Response response = processing.process(ComponentSpecification.fromString("foo"), req);
assertEquals("Tbbq qnl!", response.data().get(0).toString());
}
}
@Test
void requireThatBasicProcessingDoesNotTruncateBigResponse() {
int SIZE = 50 * 1000;
StringBuilder foo = new StringBuilder();
for (int j = 0; j < SIZE; j++) {
foo.append('b');
}
try (JDisc container = getContainerWithRot13()) {
int NUM_TIMES = 100;
for (int i = 0; i < NUM_TIMES; i++) {
com.yahoo.application.container.handler.Response response =
container.handleRequest(
new com.yahoo.application.container.handler.Request("http://foo/processing/?chain=foo&title=" + foo.toString()));
assertEquals(SIZE + 26, response.getBody().length);
}
}
}
@Test
void processing_and_rendering_works() throws Exception {
try (JDisc container = getContainerWithRot13()) {
Processing processing = container.processing();
Request req = new Request();
req.properties().set("title", "Good day!");
byte[] rendered = processing.processAndRender(ComponentSpecification.fromString("foo"),
ComponentSpecification.fromString("default"), req);
String renderedAsString = new String(rendered, StandardCharsets.UTF_8);
assertTrue(renderedAsString.contains("Tbbq qnl!"));
}
}
@Test
void requireThatUnknownChainThrows() {
assertThrows(IllegalArgumentException.class, () -> {
try (JDisc container = getContainerWithRot13()) {
container.processing().process(ComponentSpecification.fromString("unknown"), new Request());
}
});
}
@Test
void requireThatDocprocFails() {
assertThrows(UnsupportedOperationException.class, () -> {
try (JDisc container = getContainerWithRot13()) {
container.documentProcessing();
}
});
}
@Test
void requireThatSearchFails() {
assertThrows(UnsupportedOperationException.class, () -> {
try (JDisc container = getContainerWithRot13()) {
container.search();
}
});
}
private JDisc getContainerWithRot13() {
return JDisc.fromServicesXml(
getXML("foo", Rot13Processor.class.getCanonicalName()),
Networking.disable);
}
}
|
