svn commit: r1540081 - /incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsTagsUpdatingServiceTest.java

[ds...@apache.org]

Author: dsullivan
Date: Fri Nov  8 15:32:41 2013
New Revision: 1540081

URL: http://svn.apache.org/r1540081
Log:
adding StreamsTagsUpdatingServiceTest

Added:
    incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsTagsUpdatingServiceTest.java

Added: incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsTagsUpdatingServiceTest.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsTagsUpdatingServiceTest.java?rev=1540081&view=auto
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsTagsUpdatingServiceTest.java (added)
+++ incubator/streams/branches/webservice/streams-components/src/test/java/org/apache/streams/components/service/StreamsTagsUpdatingServiceTest.java Fri Nov  8 15:32:41 2013
@@ -0,0 +1,43 @@
+package org.apache.streams.components.service;
+
+import org.apache.streams.components.activitysubscriber.ActivityStreamsSubscriberWarehouse;
+import org.apache.streams.components.service.impl.StreamsTagsUpdatingServiceImpl;
+import org.apache.streams.persistence.model.ActivityStreamsSubscription;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.Set;
+
+import static org.easymock.EasyMock.*;
+import static org.hamcrest.CoreMatchers.*;
+import static org.junit.Assert.assertThat;
+
+public class StreamsTagsUpdatingServiceTest {
+
+    private StreamsTagsUpdatingService tagsUpdatingService;
+    private StreamsSubscriptionRepositoryService repositoryService;
+    private ActivityStreamsSubscriberWarehouse subscriberWarehouse;
+
+    @Before
+    public void setup(){
+        repositoryService = createMock(StreamsSubscriptionRepositoryService.class);
+        subscriberWarehouse = createMock(ActivityStreamsSubscriberWarehouse.class);
+        tagsUpdatingService = new StreamsTagsUpdatingServiceImpl(repositoryService, subscriberWarehouse);
+        }
+
+    @Test
+    public void updateTagsTest() throws Exception {
+        String subscriberId = "subscriberId";
+        String tagsJson = "{\"add\":[\"this\"], \"remove\":[\"that\"]}";
+        ActivityStreamsSubscription subscription = createMock(ActivityStreamsSubscription.class);
+        repositoryService.updateTags(subscriberId, isA(Set.class), isA(Set.class));
+        expectLastCall();
+        subscriberWarehouse.updateSubscriber(subscription);
+        expectLastCall();
+        expect(repositoryService.getSubscriptionByInRoute(subscriberId)).andReturn(subscription);
+
+        String returned = tagsUpdatingService.updateTags(subscriberId,tagsJson);
+
+        assertThat(returned,is(equalTo("Tags Updated Successfully!")));
+    }
+}