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

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);
    }

}