package unittest;

import java.util.*;

import org.jbpm.api.*;
import org.jbpm.api.job.*;
import org.jbpm.api.task.*;

import org.jbpm.test.*;


public class X10ExceptionTaskTest extends JbpmTestCase {
    protected void setUp() throws Exception {
        super.setUp();
        identityService.createUser("johnsmith", "johnsmith", "johnsmith");
        deployJpdlXmlString(
            "<process name='X10ExceptionTaskTest' xmlns='http://jbpm.org/4.0/jpdl'>"
            + "   <start name='start1' g='93,78,48,48' continue='async'>"
            + "      <transition name='to Test Task' to='Test Task' g='1,-20'/>"
            + "   </start>" + "   <end name='end1' g='315,236,48,48'/>"
            + "   <task name='Test Task' g='178,159,92,52' assignee='johnsmith'>"
            + "   <notification>" + "    <to users='${task.assignee}'/>"
            + "    <cc addresses='invalid@email@address'/>"
            + "    <subject>${task.name}</subject>" + "    <text>"
            + "      <![CDATA[Hi ${task.assignee},"
            + "      Task '${task.name}' has been assigned to you."
            + "      ${task.description}" + "      Sent by JBoss jBPM"
            + "      ]]>" + "    </text>" + "   </notification>"
            + "   <transition name='to end1' to='end1' g='-6,-22'/>"
            + " </task>" + "</process>");
    }

    protected void tearDown() throws Exception {
        identityService.deleteUser("johnsmith");
        super.tearDown();
    }

    public void testDefault() throws Exception {
        ProcessInstance processInstance = executionService
            .startProcessInstanceByKey("X10ExceptionTaskTest");
        String processInstanceId = processInstance.getId();
        int retries = 0;

        while (retries < 3) {
            retries++;

            try {
                List<Job> jobs = managementService.createJobQuery().list();
                Job job = jobs.get(0);
                managementService.executeJob(job.getId());

                break;
            } catch (Exception e) {
                System.out.println(e);
            }
        }

        List<Task> tasks = taskService.createTaskQuery().list();
        assertEquals(0, tasks.size());
    }
}