/*
 * Licensed to jclouds, Inc. (jclouds) under one or more
 * contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  jclouds licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package org.jclouds.vcloud.director.v1_5.features;

import static org.testng.Assert.assertEquals;
import static org.testng.Assert.assertNull;
import static org.testng.Assert.fail;

import java.net.URI;

import javax.ws.rs.core.HttpHeaders;

import org.jclouds.http.HttpRequest;
import org.jclouds.http.HttpResponse;
import org.jclouds.vcloud.director.v1_5.VCloudDirectorException;
import org.jclouds.vcloud.director.v1_5.VCloudDirectorMediaType;
import org.jclouds.vcloud.director.v1_5.domain.Error;
import org.jclouds.vcloud.director.v1_5.domain.Reference;
import org.jclouds.vcloud.director.v1_5.domain.Task;
import org.jclouds.vcloud.director.v1_5.domain.TasksList;
import org.jclouds.vcloud.director.v1_5.internal.VCloudDirectorAdminApiExpectTest;
import org.jclouds.vcloud.director.v1_5.user.VCloudDirectorApi;
import org.testng.annotations.Test;

/**
 * Test the {@link TaskApi} by observing its side effects.
 * 
 * @author grkvlt@apache.org
 */
@Test(groups = { "unit", "user" }, singleThreaded = true, testName = "TaskApiExpectTest")
public class TaskApiExpectTest extends VCloudDirectorAdminApiExpectTest {

   @Test
   public void testTaskListForValidOrg() {
      HttpRequest taskRequest = HttpRequest.builder()
              .method("GET")
              .endpoint(endpoint + "/tasksList/6f312e42-cd2b-488d-a2bb-97519cd57ed0")
              .addHeader("Accept", "*/*")
              .addHeader("x-vcloud-authorization", token)
              .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

      HttpResponse taskResponse = HttpResponse.builder()
              .statusCode(200)
              .payload(payloadFromResourceWithContentType("/task/taskslist.xml", VCloudDirectorMediaType.TASKS_LIST + ";version=1.5"))
              .build();
      
      HttpRequest orgRequest = HttpRequest.builder().method("GET")
            .endpoint(endpoint + "/org/6f312e42-cd2b-488d-a2bb-97519cd57ed0")
            .addHeader("Accept", "*/*")
            .addHeader("x-vcloud-authorization", token)
            .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

		HttpResponse orgResponse = HttpResponse.builder()
            .statusCode(200)
            .payload(payloadFromResourceWithContentType("/org/org.xml", VCloudDirectorMediaType.TASKS_LIST + ";version=1.5"))
            .build();

      VCloudDirectorApi api = requestsSendResponses(loginRequest, sessionResponse, taskRequest, taskResponse, orgRequest, orgResponse);

      TasksList expected = TasksList.builder()
              .name("Tasks Lists")
              .type("application/vnd.vmware.vcloud.tasksList+xml")
              .href(URI.create("https://vcloudbeta.bluelock.com/api/tasksList/6f312e42-cd2b-488d-a2bb-97519cd57ed0"))
              .task(taskOne())
              .task(taskTwo())
              .build();

      assertEquals(api.getTaskApi().getTaskList(URI.create("https://vcloudbeta.bluelock.com/api/org/6f312e42-cd2b-488d-a2bb-97519cd57ed0")), expected);
   }

   @Test
   public void testTaskListForInvalidOrgId() {
      HttpRequest taskRequest = HttpRequest.builder().method("GET")
              .endpoint(endpoint + "/tasksList/NOTAUUID")
              .addHeader("Accept", "*/*")
              .addHeader("x-vcloud-authorization", token).build();

      HttpResponse taskResponse = HttpResponse.builder().build();
      
      HttpRequest orgRequest = HttpRequest.builder().method("GET")
            .endpoint(endpoint + "/org/NOTAUUID")
            .addHeader("Accept", "*/*")
            .addHeader("x-vcloud-authorization", token)
            .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

      HttpResponse orgResponse = HttpResponse.builder()
            .statusCode(400)
            .payload(payloadFromResourceWithContentType("/org/error400.xml", VCloudDirectorMediaType.ERROR + ";version=1.5"))
            .build();

      VCloudDirectorApi api = requestsSendResponses(loginRequest, sessionResponse, taskRequest, taskResponse, orgRequest, orgResponse);

      Error expected = Error.builder()
            .message("validation error on field 'id': String value has invalid format or length")
            .majorErrorCode(400)
            .minorErrorCode("BAD_REQUEST")
            .build();

      try {
         api.getTaskApi().getTaskList(URI.create("https://vcloudbeta.bluelock.com/api/org/NOTAUUID"));
         fail("Should give HTTP 400 error");
      } catch (VCloudDirectorException vde) {
         assertEquals(vde.getError(), expected);
      } catch (Exception e) {
         fail("Should have thrown a VCloudDirectorException");
      }
   }

   @Test
   public void testTaskListForNotFoundOrgId() {
      HttpRequest taskRequest = HttpRequest.builder().method("GET")
            .endpoint(endpoint + "/tasksList/aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee")
            .addHeader("Accept", "*/*")
            .addHeader("x-vcloud-authorization", token)
            .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

      HttpResponse taskResponse = HttpResponse.builder().build();
      
      HttpRequest orgRequest = HttpRequest.builder().method("GET")
            .endpoint(endpoint + "/org/aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee")
            .addHeader("Accept", "*/*")
            .addHeader("x-vcloud-authorization", token)
            .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

      HttpResponse orgResponse = HttpResponse.builder()
            .statusCode(403)
            .payload(payloadFromResourceWithContentType("/org/error403-fake.xml", VCloudDirectorMediaType.ERROR + ";version=1.5"))
            .build();

      VCloudDirectorApi api = requestsSendResponses(loginRequest, sessionResponse, taskRequest, taskResponse, orgRequest, orgResponse);

		assertNull(api.getTaskApi().getTaskList(URI.create("https://vcloudbeta.bluelock.com/api/org/aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee")));
   }

   @Test
   public void testGetTaskForTaskRef() {
      HttpRequest taskRequest = HttpRequest.builder()
              .method("GET")
              .endpoint(endpoint + "/task/5fcd2af3-d0ec-45ce-9451-8c585a2c766b")
              .addHeader("Accept", "*/*")
              .addHeader("x-vcloud-authorization", token)
              .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

      HttpResponse taskResponse = HttpResponse.builder()
              .statusCode(200)
              .payload(payloadFromResourceWithContentType("/task/task.xml", VCloudDirectorMediaType.TASK + ";version=1.5"))
              .build();

      VCloudDirectorApi api = requestsSendResponses(loginRequest, sessionResponse, taskRequest, taskResponse);

      URI taskUri = URI.create(endpoint + "/task/5fcd2af3-d0ec-45ce-9451-8c585a2c766b");
      
      //TODO: incorrect relationship, as task should not have a nested task container!!
      Task expected = taskOne();

      assertEquals(api.getTaskApi().getTask(taskUri), expected);
   }

   @Test
   public void testCancelTaskByTaskRef() {
      HttpRequest taskRequest = HttpRequest.builder()
            .method("POST")
            .endpoint(endpoint + "/task/5fcd2af3-d0ec-45ce-9451-8c585a2c766b/action/cancel")
            .addHeader("Accept", "*/*")
            .addHeader("x-vcloud-authorization", token)
            .addHeader(HttpHeaders.COOKIE, "vcloud-token=" + token).build();

      HttpResponse taskResponse = HttpResponse.builder()
            .statusCode(200)
            .build();

      VCloudDirectorApi api = requestsSendResponses(loginRequest, sessionResponse, taskRequest, taskResponse);

      URI taskUri = URI.create(endpoint + "/task/5fcd2af3-d0ec-45ce-9451-8c585a2c766b");
      
      api.getTaskApi().cancelTask(taskUri);
   }

   public static Task taskOne() {
      return Task.builder()
		            .type("application/vnd.vmware.vcloud.task+xml")
		            .name("task")
		            .id("urn:vcloud:task:5fcd2af3-d0ec-45ce-9451-8c585a2c766b")
		            .href(URI.create("https://vcloudbeta.bluelock.com/api/task/5fcd2af3-d0ec-45ce-9451-8c585a2c766b"))
		            .status("success")
		            .operation("Created Catalog QunyingTestCatalog(7212e451-76e1-4631-b2de-ba1dfd8080e4)")
		            .operationName("catalogCreateCatalog")
		            .startTime(dateService.iso8601DateParse("2012-02-07T00:16:28.450-05:00"))
		            .endTime(dateService.iso8601DateParse("2012-02-07T00:16:28.867-05:00"))
		            .expiryTime(dateService.iso8601DateParse("2012-05-07T00:16:28.450-04:00"))
		            .owner(Reference.builder()
		                  .type("application/vnd.vmware.vcloud.catalog+xml")
		                  .name("QunyingTestCatalog")
		                  .href(URI.create("https://vcloudbeta.bluelock.com/api/catalog/7212e451-76e1-4631-b2de-ba1dfd8080e4"))
		                  .build())
		            .user(Reference.builder()
		                  .type("application/vnd.vmware.admin.user+xml")
		                  .name("JClouds")
		                  .href(URI.create("https://vcloudbeta.bluelock.com/api/org/6f312e42-cd2b-488d-a2bb-97519cd57ed0"))
		                  .build())
		            .org(Reference.builder()
		                  .type("application/vnd.vmware.vcloud.org+xml")
		                  .name("JClouds")
		                  .href(URI.create("https://vcloudbeta.bluelock.com/api/org/6f312e42-cd2b-488d-a2bb-97519cd57ed0"))
		                  .build())
		            .build();
   }
   
   public static Task taskTwo() {
      return Task.builder()
		            .type("application/vnd.vmware.vcloud.task+xml")
		            .name("task")
		            .id("urn:vcloud:task:bd22e745-9c2a-4f82-a954-0e35b6f76ba5")
		            .href(URI.create("https://vcloudbeta.bluelock.com/api/task/bd22e745-9c2a-4f82-a954-0e35b6f76ba5"))
		            .status("success")
		            .operation("Enabled User (967d317c-4273-4a95-b8a4-bf63b78e9c69)")
		            .operationName("jobEnable")
		            .startTime(dateService.iso8601DateParse("2012-02-06T17:30:38.507-05:00"))
		            .endTime(dateService.iso8601DateParse("2012-02-06T17:30:38.507-05:00"))
		            .expiryTime(dateService.iso8601DateParse("2012-05-06T17:30:38.507-04:00"))
		            .user(Reference.builder()
		                  .type("application/vnd.vmware.admin.user+xml")
		                  .name("adrian@jclouds.org")
		                  .href(URI.create("https://vcloudbeta.bluelock.com/api/admin/user/8c360b93-ed25-4c9a-8e24-d48cd9966d93"))
		                  .build())
		            .org(Reference.builder()
		                  .type("application/vnd.vmware.vcloud.org+xml")
		                  .name("JClouds")
		                  .href(URI.create("https://vcloudbeta.bluelock.com/api/org/6f312e42-cd2b-488d-a2bb-97519cd57ed0"))
		                  .build())
		            .build();
   }
}