package org.gcube.common.gxrest.request;

import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;

import java.io.IOException;
import java.io.InputStream;
import java.util.Map;
import java.util.Properties;
import java.util.WeakHashMap;

import javax.ws.rs.client.Entity;
import javax.ws.rs.core.MediaType;

import org.gcube.common.gxrest.response.inbound.GXInboundResponse;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.BlockJUnit4ClassRunner;

/**
 * Test cases for {@link GXWebTargetAdapterRequest#newHTTPSRequest(String)}
 * 
 * @author Manuele Simi (ISTI-CNR)
 *
 */
@RunWith(BlockJUnit4ClassRunner.class)
public class GXWebTargetAdapterHTTPSRequestTest {

	private GXWebTargetAdapterRequest request;

    // private GXWebTargetAdapterRequest requestWithProtocol;


    public static String DEFAULT_TEST_SCOPE = "";

	static String DEFAULT_RM_URL = "";

	static String DEFAULT_RR_URL = "";

	private static boolean skipTest = false;

	static {
		Properties properties = new Properties();
		try (InputStream input = GXWebTargetAdapterRequest.class.getClassLoader().getResourceAsStream("token.props")) {
			// load the properties file
			properties.load(input);
			DEFAULT_TEST_SCOPE = properties.getProperty("DEFAULT_SCOPE_TOKEN");
			if (DEFAULT_TEST_SCOPE.isEmpty())
				skipTest = true;
			DEFAULT_RM_URL = properties.getProperty("RM_URL");
			DEFAULT_RR_URL = properties.getProperty("RR_URL");
		} catch (IOException | NullPointerException e) {
			skipTest = true;
		}
	}
	@BeforeClass
	public static void beforeClass() throws Exception {
		if (!skipTest)
			setContext(DEFAULT_TEST_SCOPE);
	}

	public static void setContext(String token) throws Exception {
		if (skipTest || DEFAULT_TEST_SCOPE.isEmpty()) {
			skipTest = true;
			return;
		} else {
			//SecurityTokenProvider.instance.set(token);
		}
	}

	@AfterClass
	public static void afterClass() throws Exception {
		//SecurityTokenProvider.instance.reset();
	}

	/**
	 * Test method for {@link GXHTTPStringRequest#newRequest(String)}.
	 */
	@Before
	public void testNewRequest() {
		request  = GXWebTargetAdapterRequest.newHTTPSRequest(DEFAULT_RM_URL).from("GXRequestTest");
		// requestWithProtocol  = GXWebTargetAdapterRequest.newHTTPSRequest(DEFAULT_RM_URL, "").from("GXRequestTest");
	}

	/**
	 * Test method for {@link GXWebTargetAdapterRequest#put()}.
	 */
	@Test
	public void testPut() {
		if (skipTest)
			return;
		//fail("Not yet implemented");
	}

	/**
	 * Test method for {@link GXWebTargetAdapterRequest#delete()}.
	 */
	@Test
	public void testDelete() {
		if (skipTest)
			return;
		//fail("Not yet implemented");
	}

	/**
	 * Test method for {@link GXWebTargetAdapterRequest#post()}.
	 */
	@Test
	public void testPost() {
		if (skipTest)
			return;
		String context ="{\"@class\":\"Context\",\"header\":{\"@class\":\"Header\",\"uuid\":\"6f86dc81-2f59-486b-8aa9-3ab5486313c4\",\"creator\":null,\"modifiedBy\":\"gxRestTest\",\"creationTime\":null,\"lastUpdateTime\":null},\"name\":\"gxTest\",\"parent\":null,\"children\":[]}";
		Map<String,Object[]> queryParams = new WeakHashMap<>();
		queryParams.put("rrURL", new String[]{DEFAULT_RR_URL});
		try {
			GXInboundResponse response = request.path("gxrest")
					.header("User-Agent", this.getClass().getSimpleName())
					.header("Another header", "another value")
					.queryParams(queryParams).post(Entity.entity(context, MediaType.APPLICATION_JSON + ";charset=UTF-8"));
			assertTrue("Unexpected returned code.", response.hasCREATEDCode());
				if (response.hasGXError()) {
					if (response.hasException()) {
						try {
							throw response.getException();
						} catch (ClassNotFoundException e) {
							//that's OK, we can tolerate this
						} catch (Exception e) {
							e.printStackTrace();
							throw e;
						}
					}
				} else {
					if (response.hasCREATEDCode()) {
						System.out.println("Resource successfully created!");
						System.out.println("Returned message: " + response.getStreamedContentAsString());
					} else {
						System.out.println("Resource creation failed. Returned status:" + response.getHTTPCode());
						//if you want to use the original responser
						 response.getSource();
						//then consume the response
					}
				}

		} catch (Exception e) {
			e.printStackTrace();
			fail("Failed to send a POST request");
		}
	}

	/**
	 * Test method for {@link GXWebTargetAdapterRequest#head()}.
	 */
	@Test
	public void testHead() {
		if (skipTest)
			return;
		//fail("Not yet implemented");
	}

	/**
	 * Test method for {@link GXWebTargetAdapterRequest#get()}.
	 */
	@Test
	public void testGet() {
		if (skipTest)
			return;
		//fail("Not yet implemented");
	}

}