add tests for PubSubService

pom.xml

@@ -255,7 +255,7 @@
 		<dependency>
 			<groupId>org.slf4j</groupId>
 			<artifactId>slf4j-api</artifactId>
-			<version>1.7.12</version>
+			<version>1.7.30</version>
 		</dependency>
 
 		<dependency>
@@ -483,5 +483,11 @@
 			<version>2.0.11-beta</version>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.mock-server</groupId>
+			<artifactId>mockserver-junit-rule</artifactId>
+			<version>5.11.1</version>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
 </project>

src/test/java/com/commafeed/backend/service/PubSubServiceTest.java

@@ -0,0 +1,104 @@
+package com.commafeed.backend.service;
+
+import com.commafeed.CommaFeedConfiguration;
+import com.commafeed.backend.feed.FeedQueues;
+import com.commafeed.backend.model.Feed;
+import org.apache.http.HttpHeaders;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Answers;
+import org.mockito.Mock;
+import org.mockito.runners.MockitoJUnitRunner;
+import org.mockserver.client.MockServerClient;
+import org.mockserver.junit.MockServerRule;
+import org.mockserver.model.MediaType;
+
+import static org.mockito.Mockito.*;
+import static org.mockserver.model.HttpRequest.request;
+import static org.mockserver.model.HttpResponse.response;
+
+@RunWith(MockitoJUnitRunner.class)
+public class PubSubServiceTest {
+
+    PubSubService underTest;
+
+    @Rule
+    public MockServerRule mockServerRule = new MockServerRule(this, 22441);
+    public MockServerClient mockServerClient;
+
+    @Mock(answer = Answers.RETURNS_DEEP_STUBS)
+    CommaFeedConfiguration config;
+
+    @Mock
+    FeedQueues queues;
+
+    @Mock
+    Feed feed;
+
+
+    @Before
+    public void init() {
+        underTest = new PubSubService(config, queues);
+
+        // setup feed
+        feed = mock(Feed.class);
+        when(feed.getPushHub()).thenReturn("http://localhost:22441/hub");
+        when(feed.getPushTopic()).thenReturn("foo");
+
+        // setup config
+        when(config.getApplicationSettings().getPublicUrl()).thenReturn("http://localhost:22441/hub");
+    }
+
+    @Test
+    public void subscribe_200() {
+        // Arrange
+        mockServerClient
+                .when(request().withMethod("POST"))
+                .respond(response().withStatusCode(200));
+
+        // Act
+        underTest.subscribe(feed);
+
+        // Assert
+        mockServerClient.verify(request()
+                .withContentType(MediaType.APPLICATION_FORM_URLENCODED)
+                .withHeader(HttpHeaders.USER_AGENT, "CommaFeed")
+                .withMethod("POST")
+                .withPath("/hub"));
+        verify(feed, never()).setPushTopic(anyString());
+        verifyZeroInteractions(queues);
+    }
+
+    @Test
+    public void subscribe_400_withPushpressError() {
+        // Arrange
+        mockServerClient
+                .when(request().withMethod("POST"))
+                .respond(response().withStatusCode(400).withBody(" is value is not allowed.  You may only subscribe to"));
+
+        // Act
+        underTest.subscribe(feed);
+
+        // Assert
+        verify(feed).setPushTopic(anyString());
+        verify(queues).giveBack(feed);
+    }
+
+    @Test
+    public void subscribe_400_withoutPushpressError() {
+        // Arrange
+        mockServerClient
+                .when(request().withMethod("POST"))
+                .respond(response().withStatusCode(400));
+
+        // Act
+        underTest.subscribe(feed);
+
+        // Assert
+        verify(feed, never()).setPushTopic(anyString());
+        verifyZeroInteractions(queues);
+    }
+
+}