import com.github.tomakehurst.wiremock.junit.WireMockRule;

import com.pubnub.api.PubNub;

import com.pubnub.api.PubNubException;

import com.pubnub.api.endpoints.TestHarness;

import com.pubnub.api.endpoints.pubsub.Publish;

import org.junit.Before;

import org.junit.Rule;

import org.junit.Test;

import java.io.IOException;

import static com.github.tomakehurst.wiremock.client.WireMock.*;

import static org.junit.Assert.assertEquals;

/**

* Created by tukunare on 7/5/2016.

*/

public class PubNubExceptionTest extends TestHarness {

@Rule

public WireMockRule wireMockRule = new WireMockRule();

private PubNub pubnub;

private Publish instance;

@Before

public void beforeEach() throws IOException {

pubnub = this.createPubNubInstance(8080);

instance = pubnub.publish();

wireMockRule.start();

}

@Test

public void testPubnubError() throws PubNubException, InterruptedException {

stubFor(get(urlPathEqualTo("/publish/myPublishKey/mySubscribeKey/0/coolChannel/0/%22hi%22"))

.willReturn(aResponse().withStatus(404).withBody("[1,\"Sent\",\"14598111595318003\"]")));

int statusCode = -1;

try {

instance.channel("coolChannel").message(new Object()).sync();

}

catch (PubNubException error) {

statusCode = error.getStatusCode();

}

assertEquals(0, statusCode);

}

}