Skip to content

Commit 7cfb5ca

Browse files
committed
Do not rely on element argument
1 parent dc88dd3 commit 7cfb5ca

File tree

2 files changed

+20
-16
lines changed
  • src
    • main/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/get/items
    • test/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/get/items

2 files changed

+20
-16
lines changed

src/main/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/get/items/NodeItemsGet.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public void process(Element elm, JID actorJID, IQ reqIQ, Element rsm) throws Exc
110110
return;
111111
}
112112
xmlReader = new SAXReader();
113-
if (element.element(XMLConstants.ITEM_ELEM) == null) {
113+
if (null == items.element(XMLConstants.ITEM_ELEM)) {
114114
getItems();
115115
} else {
116116
if (!getItem()) {
@@ -135,8 +135,7 @@ protected boolean isValidStanza() {
135135
}
136136

137137
private boolean getItem() throws Exception {
138-
NodeItem nodeItem = channelManager.getNodeItem(node, element.element(XMLConstants.ITEM_ELEM).attributeValue(XMLConstants.ID_ATTR));
139-
138+
NodeItem nodeItem = channelManager.getNodeItem(node, items.element(XMLConstants.ITEM_ELEM).attributeValue(XMLConstants.ID_ATTR));
140139
if (nodeItem == null) {
141140
if (!Configuration.getInstance().isLocalNode(node)) {
142141
makeRemoteRequest();
@@ -192,7 +191,7 @@ private void getItems() throws Exception {
192191
parentOnly = true;
193192
}
194193

195-
String maxItems = element.attributeValue(XMLConstants.MAX_ITEMS_ATTR);
194+
String maxItems = items.attributeValue(XMLConstants.MAX_ITEMS_ATTR);
196195

197196
if (maxItems != null) {
198197
maxItemsToReturn = Integer.parseInt(maxItems);

src/test/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/get/items/NodeItemsGetTest.java

Lines changed: 17 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -416,29 +416,34 @@ public void canRetrieveSingleItem() throws Exception {
416416
Mockito.when(channelManager.nodeExists(Mockito.anyString()))
417417
.thenReturn(true);
418418

419-
NodeItem item = new NodeItemImpl(node, id, new Date(), payload);
419+
NodeItem dbItem = new NodeItemImpl(node, id, new Date(), payload);
420420
Mockito.when(
421-
channelManager.getNodeItem(Mockito.anyString(),
422-
Mockito.anyString())).thenReturn(item);
421+
channelManager.getNodeItem(Mockito.eq(node),
422+
Mockito.eq(id))).thenReturn(dbItem);
423423

424+
IQ request = this.request.createCopy();
425+
Element item = request.getChildElement().element("items").addElement("item");
426+
item.addAttribute("id", id);
427+
System.out.println(request.toXML());
424428
itemsGet.process(element, jid, request, null);
425-
Packet response = queue.poll();
429+
IQ response = (IQ) queue.poll();
426430

427-
Element element = response.getElement();
431+
Element element = response.getChildElement();
432+
Element items = element.element("items");
428433

429-
Assert.assertEquals(IQ.Type.result.toString(),
430-
element.attributeValue("type"));
431-
Assert.assertEquals(node, element.element("pubsub").element("items")
434+
Assert.assertEquals(IQ.Type.result,
435+
response.getType());
436+
Assert.assertEquals(node, items
432437
.attributeValue("node"));
433438

434-
Assert.assertEquals(1, element.element("pubsub").element("items")
439+
Assert.assertEquals(1, items
435440
.nodeCount());
436-
Assert.assertEquals(node, element.element("pubsub").element("items")
441+
Assert.assertEquals(node, items
437442
.attributeValue("node"));
438-
Assert.assertEquals(id, element.element("pubsub").element("items")
443+
Assert.assertEquals(id, items
439444
.element("item").attributeValue("id"));
440445
Assert.assertEquals("entry text",
441-
element.element("pubsub").element("items").element("item")
446+
items.element("item")
442447
.elementText("entry"));
443448
}
444449

0 commit comments

Comments
 (0)