#!/bin/perl

#

# Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).

# All rights reserved.

# This component and the accompanying materials are made available

# under the terms of "Eclipse Public License v1.0"

# which accompanies this distribution, and is available

# at the URL "http://www.eclipse.org/legal/epl-v10.html".

#

# Initial Contributors:

# Nokia Corporation - initial contribution.

#

# Contributors:

#

# Description:

#

# script to process one or more changes implemented via a single Synergy task importing code from an external system (e.g., Subversion or  a zip file):

#	- checks that the task is in completed state

#	- associates the task to the change object

#	- (optionally) sets "external task id(s)" -attribute to a value supplied

#	- (optionally) moves the change to the next state (provided on the command line), including setting modifiable_in to integration_db

#

# Usage 1: 	If a change id is provided as argument, the script process a single change object as above

#			perl change2released.pl -user username -change "xx1xx1#23456" -task 213 

#

# Usage 2: 	If an input file is provided as arguments, the script will read change ids (and optional external task ids) from the filw and

#		process all the changes listed in the file

#		with those tasks and transition the change to the target state 

#

#

my $program_name;

BEGIN {

    # Get the name of the program executable:

    ($program_name) = $0 =~ m{([^/]+)$};

}

my $VERSION = do { (my $v = q%version: 1 %) =~ s/.*://; sprintf("%d.%02d", 0, split(/\./, $v)) };

use FindBin qw($Bin $Script);

use lib "$Bin/lib";

use ChangeSynergy::csapi;

use Getopt::Long;

use Data::Dumper;

my $username = "";

my $password = "";

my $crId = "";

my $taskId = "";

my $newState = "";

my $protocol = "https";

#my $host = "sachswww.nmp.nokia.com";

my $host = "trchswww.nmp.nokia.com";

#my $port = "58613";

my $port = "58602";

#my $db = "/nokia/sa_nmp/groups/gscm/dbs/sa1trqa2";

my $db = "/nokia/tr_nmp/groups/gscm/dbs/tr1jrt";

my $inFile = "";

# read options

my $result = GetOptions ("user=s" => \$username,

                         "password=s" => \$password,

                         "debug" => \$debug,

                         "preview" => \$preview,

                         "version" => \$show_version,

                         "protocol=s" => \$protocol,

                         "host=s" => \$host,

                         "port=s" => \$port,

                         "db=s" => \$db,

                         "in=s" => \$inFile,

                         "state=s" => \$newState,

                         "task=s" => \$taskId,

                         "change=s" => \$crId);

print "$program_name ver. $VERSION\n";

# Handle standard command line parameters

if ($show_version) {

	# Exit immediately after having printed version information

	exit 0;

} 

if (!$taskId)

{

	die "Error: No Task Id provided\n";

}

# Get the password from the terminal unless already provided on the command line

unless ($password) {

	eval {

		require Term::ReadKey;

		print STDERR "CIM Password for user '$username' (input will be hidden): "; 

		Term::ReadKey::ReadMode('noecho');

		$password = Term::ReadKey::ReadLine(0);

		Term::ReadKey::ReadMode('normal'); 

		print STDERR "\n";

	};

	if ($@) {

		print STDERR "Warning: Perl module Term::ReadKey not available." .

			" Password echo cannot be switched off!\n";

		print STDERR "CIM Password for user '$username': "; 

		$password = <STDIN>;

	}		

	chomp $password;

}

print "Using $protocol://$host:$port, database $db\n";

my $externalTaskAttribute = "external_task_ids";

my $aUser;

my $csapi = new ChangeSynergy::csapi();

my $globals = new ChangeSynergy::Globals();

sub displayCRData

{

	my $cr = shift;

	my $j = $cr->getDataSize();

	for($i=0;$i<$j;$i++)

	{

		print "\t" . $cr->getDataObject($i)->getName() . ": " . $cr->getDataObject($i)->getValue() . "\n";

	}

} 

sub associateTaskToChange

{

	my $crId = shift;

	my $taskId = shift;

	# check if the task exists

	my $tmp = $csapi->QueryStringData($aUser, "Basic Summary", "cvtype='task' and task('$taskId\')", "task_synopsis|status|release");

	my $j = $tmp->getDataSize();

	if ($j)

	{

		my $taskData = $tmp->getDataObject(0);

		my $taskStatus = $taskData->getDataObjectByName("status")->getValue();

		my $taskRelease = $taskData->getDataObjectByName("release")->getValue();

		if ($debug)

		{

			for($i=0;$i<$j;$i++)

			{

				print "\tinstance:\t" . $taskData->getDataObjectByName("instance")->getValue() . "\n";

				print "\tstatus:  \t" . "$taskStatus\n";

				print "\trelease:  \t" . "$taskRelease\n";

				print "\tsynopsis:\t" . $taskData->getDataObjectByName("task_synopsis")->getValue() . "\n";

				#my $j2 = $taskData->getDataSize();

				#for($i2=0;$i2<$j2;$i2++)

				#{

				#	print "\t" . $taskData->getDataObject($i2)->getName() . ": " . $taskData->getDataObject($i2)->getValue() . "\n";

				#}

			}

		}

		if ($taskStatus ne 'completed')

		{

			die "Error: task is not completed\n";

		}

		if (!$preview)

		{

			print "Associating Task \'$taskId\' to Change \'$crId\'\n";

			my $result = $csapi->CreateRelation($aUser, "TRUE", $crId, $taskId, "associated_task", $globals->{CCM_PROBLEM_TASK});

			print $result->getResponseData() . "\n";

		}

		else

		{

			print "Would associate Task \'$taskId\' to Change \'$crId\'\n";

		}

	}

	else

	{

		die "Error: task \'$taskId\' does not exist\n";

	}

} 

# main program 

eval

{

	$csapi->setUpConnection("$protocol", "$host", "$port");

	$aUser = $csapi->Login("$username", "$password", "User", "$db");

  print "eval11\n";

	# 1. find all the change objects to process

	my @crTable = ();

	my %extTaskIdTable = ();

	my $query = "";

	if ($crId)

	{

		if ($debug)

		{

			print "Using Change id: \"$crId\"\n";

		}

        push(@crTable, $crId);

	}

	elsif ($inFile)

	{

		my $fh;

		my $extTaskId = "";

		open($fh, $inFile) or die "Failed to read input file $inFile: $!\n";

		if ($debug)

		{

			print "Using input file: \"$inFile\"\n";

		}

		while (<$fh>) {

			chomp;

			# Skip comments and blanks

			next if (substr($_, 0, 1) eq '#' || /^\s*$/);

			($crId, $extTaskId) = split(/[\s]+/, $_);

			if ($debug)

			{

				print "Read Change id \"$crId\"\n";

				if ($extTaskId) 

				{

					print "- external task id \"$extTaskId\"\n";

				}

			}

			push(@crTable, $crId);

			if ($extTaskId) 

			{

				$extTaskIdTable{$crId} = $extTaskId;

			}

		}

	}

	else

	{

        die "No change id or input file provided\n";

	}

	# 2. Loop over the change objects and process them

	foreach $crId (@crTable)

	{

		my @taskList = ();

		print "Processing change: \'$crId\'\n";

		# 3. find the tasks to associate with this change object

		if ($taskId)

		{

			# use the one from the command line

			print "Using task: \'$taskId\'\n";

			push(@taskList, $taskId);

		}

		# 4: 	associate all tasks and change the state

		# 	bail out on failure and move to the next CR

		eval

		{

			foreach $t (@taskList)

			{

				print "Processing task \'$t\'\n";

				&associateTaskToChange($crId, $t);

			}

			my $externalTaskId = $extTaskIdTable{$crId};

			my $crData = $csapi->GetCRData($aUser, $crId, "crstatus|integration_db|modifiable_in|$externalTaskAttribute");

			if ($newState)

			{

				my $crStatus = "change_" . $newState;

				if (!$preview)

				{

					print "Transitioning Change \'$crId\' to $crStatus\n";

				}

				else

				{

					print "Would transition Change \'$crId\' to $crStatus\n";

				}

				# get the transition form

				# my $crData = $csapi->GetCRData($aUser, $crId, "crstatus|integration_db|modifiable_in|$externalTaskAttribute");

				my $tmp = $csapi->TransitionCRData($aUser, $crId, $crData->getTransitionLink(1)->getTransition());

				if ($debug)

			 	{

					&displayCRData($tmp);

				}

				# set the status on the form

				$tmp->getDataObjectByName("crstatus")->setValue($crStatus);

		  		# $tmp->getDataObjectByName("crstatus")->setValue($cr->getTransitionLink(1)->getToState());

				if (!$preview)

				{

					# transition the CR

					$result = $csapi->TransitionCR($aUser, $tmp);

					print $result->getResponseData() . "\n";

				}

				# and finally, set the modifiable in

				my $integration_db = $crData->getDataObjectByName("integration_db")->getValue();

				if (!$preview)

				{

					print "Setting modifiable_in to " . $integration_db . "\n";

					$crData->getDataObjectByName("modifiable_in")->setValue($integration_db);

				}

				else

				{

					print "Would set modifiable_in to " . $integration_db . "\n";

				}

			}

			if (!$preview)

			{

				if ($externalTaskId)

				{

					print "Setting $externalTaskAttribute to " . $externalTaskId . "\n";

					$crData->getDataObjectByName($externalTaskAttribute)->setValue($externalTaskId);

				}

				$result = $csapi->ModifyCR($aUser, $crData);

				print $result->getResponseData() . "\n";

			}

			else

			{

				if ($externalTaskId)

				{

					print "Would set $externalTaskAttribute to " . $externalTaskId . "\n";

				}

			}

		};

		if ($@)

		{

			print $@;

		}

	}

};

if ($@)

{

	print $@;

}