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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.tuscany.sca.binding.atom;
import java.util.Date;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import junit.framework.Assert;
import org.apache.abdera.model.Link;
import org.apache.tuscany.sca.binding.atom.collection.Collection;
import org.apache.tuscany.sca.data.collection.Entry;
import org.apache.tuscany.sca.data.collection.Item;
import org.apache.tuscany.sca.node.Contribution;
import org.apache.tuscany.sca.node.ContributionLocationHelper;
import org.apache.tuscany.sca.node.Node;
import org.apache.tuscany.sca.node.NodeFactory;
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
/**
* Test cases for using an Atom feed that does not implement
* the Collections interface but does have a getAll() method.
*
* @version $Rev$ $Date$
*/
public class AtomFeedNonCollectionTest {
/**
* Used to generate unique IDs for the feed entries.
*/
private static final AtomicInteger ID_GEN = new AtomicInteger();
/**
* Data used for creating test feed entries.
*/
private static final String[] FEED_ENTRY_TITLES = {"Apache Tuscany", "Apache"};
/**
* Data used for creating test feed entries.
*/
private static final String[] FEED_ENTRY_CONTENT = {"This is Apache Tuscany", "This is Apache"};
/**
* Data used for creating test feed entries.
*/
private static final String[] FEED_ENTRY_LINK = {"http://tuscany.apache.org", "http://www.apache.org"};
/**
* The number of test feed entries.
*/
private static final int FEED_ENTRY_COUNT = FEED_ENTRY_TITLES.length;
protected static Node scaProviderNode;
protected static Node scaConsumerNode;
private static CustomerClient testService;
@BeforeClass
public static void init() throws Exception {
try {
//System.out.println(">>>AtomFeedNonCollectionTest.init entry");
String contribution = ContributionLocationHelper.getContributionLocation(AtomFeedNonCollectionTest.class);
scaProviderNode = NodeFactory.newInstance().createNode("org/apache/tuscany/sca/binding/atom/ProviderNonCollection.composite", new Contribution("provider", contribution));
scaProviderNode.start();
scaConsumerNode = NodeFactory.newInstance().createNode("org/apache/tuscany/sca/binding/atom/Consumer.composite", new Contribution("consumer", contribution));
scaConsumerNode.start();
testService = scaConsumerNode.getService(CustomerClient.class, "CustomerClient");
} catch (Exception e) {
e.printStackTrace();
}
}
@AfterClass
public static void destroy() throws Exception {
if (scaConsumerNode != null) {
scaConsumerNode.stop();
}
if (scaProviderNode != null) {
scaProviderNode.stop();
}
}
/**
* Make sure everything has been initialized correctly.
*/
@SuppressWarnings("unchecked")
@Before
public void testPrelim() {
Assert.assertNotNull(scaConsumerNode);
Assert.assertNotNull(scaProviderNode);
Assert.assertNotNull(testService);
// Add some entries to the Atom feed
final Entry<Object, Object>[] testEntries = new Entry[FEED_ENTRY_COUNT];
for (int i = 0; i < FEED_ENTRY_COUNT; i++) {
testEntries[i] = createFeedEntry(FEED_ENTRY_TITLES[i], FEED_ENTRY_CONTENT[i], FEED_ENTRY_LINK[i]);
}
CustomerNonCollectionImpl.entries = testEntries;
}
/**
* Post test cleanup
*/
@After
public void testPostCleanup()
{
// Clear any old feed entries that have been added by previous tests
CustomerNonCollectionImpl.entries = null;
}
/**
* Test that we can retrieve entries from a feed that does not implement
* the Collection interface.
*/
@Test
public void testThatCanGetFeedEntriesFromNonCollectionImplementation() {
// Get the entries from the feed
final Collection resourceCollection = testService.getCustomerCollection();
Assert.assertNotNull(resourceCollection);
final List<org.apache.abdera.model.Entry> entries = resourceCollection.getFeed().getEntries();
// Validate the feed entries
Assert.assertNotNull(entries);
Assert.assertEquals(FEED_ENTRY_COUNT, entries.size());
for (int i = 0; i < FEED_ENTRY_COUNT; i++) {
final org.apache.abdera.model.Entry entry = entries.get(i);
Assert.assertEquals(FEED_ENTRY_TITLES[i], entry.getTitle());
Assert.assertEquals(FEED_ENTRY_CONTENT[i], entry.getContent());
final List<Link> links = entry.getLinks();
Assert.assertNotNull(links);
Assert.assertEquals(1, links.size());
final Link link = links.get(0);
final String linkStr = link.getHref().toString();
Assert.assertEquals(FEED_ENTRY_LINK[i], linkStr);
}
}
/**
* Tests that the title of the feed can be set by the title
* attribute on the binding.atom
*/
@Test
public void testThatFeedTitleSet() {
final String expectedFeedTitle = "Atom binding Non Collection";
// Get the title of the feed
final Collection resourceCollection = testService.getCustomerCollection();
Assert.assertNotNull(resourceCollection);
final String feedTitle = resourceCollection.getFeed().getTitle();
// Validate the title
Assert.assertEquals(expectedFeedTitle, feedTitle);
}
/**
* Tests that the description of the feed can be set by the description
* attribute on the binding.atom
*/
@Test
public void testThatFeedDescriptionSet() {
final String expectedFeedDescription = "Feed used for unit testing";
// Get the description of the feed
final Collection resourceCollection = testService.getCustomerCollection();
Assert.assertNotNull(resourceCollection);
final String feedDescription = resourceCollection.getFeed().getSubtitle();
// Validate the description
Assert.assertEquals(expectedFeedDescription, feedDescription);
}
/**
* Creates a feed entry.
*
* @param title Title for the feed entry
* @param content Contents of the feed entry
* @param link Link for the feed entry
* @return A new feed entry.
*/
private Entry<Object, Object> createFeedEntry(String title, String content, String link) {
final Item item = new Item(title, content, link, null, new Date());
final Entry<Object, Object> entry = new Entry<Object, Object>(nextFeedID(), item);
return entry;
}
/**
* Generates the feed entry ID.
*
* @return Next feed entry ID
*/
private String nextFeedID() {
return Integer.toString(ID_GEN.incrementAndGet());
}
}
|
