/*
 * TaskInspector.java
 */
package org.ngbw.utils;


import java.io.IOException;
import java.sql.SQLException;

import org.ngbw.sdk.database.ConnectionManager;
import org.ngbw.sdk.database.DriverConnectionSource;
import org.ngbw.sdk.database.RunningTask;
import org.ngbw.sdk.database.Task;


/**
 *
 * @author
 *
 */
public class RunningTaskInspector
{

	public static void inspect(String jobhandle, int runNumber) throws IOException, SQLException, Exception
	{
		RunningTask inspected = RunningTask.find(jobhandle, runNumber);

		if (inspected == null) {
			System.err.println("Couldn't find a running task with that id");

			return;
		}

		inspect(inspected);
	}

	public static void inspect(RunningTask inspected) throws IOException, SQLException
	{
		System.out.println("JobHandle: " + inspected.getJobhandle());
		System.out.println("RunNumber: " + inspected.getRunNumber());
		//System.out.println("WorkingDir: " + inspected.getWorkspace());
		System.out.println("OutputDesc: " + inspected.getOutputDesc());
	}

	public static void main(String[] args)
	{
		try {
			if (args.length != 1)
				throw new Exception("usage: RunningTask jobhandle [ runnumber ]");

			ConnectionManager.setConnectionSource(new DriverConnectionSource());

			String jobhandle = args[0];
			int runNumber;

			if (args.length < 2) {
				Task task = Task.findTaskByJobHandle(jobhandle);

				if (task == null)
					throw new Exception("Couldn't find a task for job handle " + jobhandle);

				runNumber = task.runs().last().getRunNumber();
			}
			else
				runNumber = Integer.parseInt(args[1]);

			inspect(jobhandle, runNumber);
		}
		catch (Exception err) {
			err.printStackTrace(System.err);

			System.exit(-1);
		}
	}

}