/*
This script reads the Job Log for the executing instance and finds all Error and (optionally) Warning messages that have been logged. It combines these into a
string and stores them in the ErrorMessagesForInstance Job Variable so they can be used in a notification message.

The user account that the job is running under must have a login in adTempus, with permission to read the job.

By default the script includes Warning messages. To include only errors, set IncludeWarningMessages=false below.
*/
using System;
using System.Text;
using System.Linq;
using System.Collections.Generic;
using ArcanaDevelopment.adTempus.ApplicationIntegration;
using ArcanaDevelopment.adTempus.Client;
using ArcanaDevelopment.adTempus.Shared;


namespace UserScript
{
    public class UserScript : ArcanaDevelopment.adTempus.ApplicationIntegration.UserScriptBase
    {
		//Set to true to include warning messages, or false to include error messages only
		private static readonly bool IncludeWarningMessages=true;
		
        public override Object Run()
        {
			//get the identity of the running instance from the JobVariable. Note that this won't be set if you test the script outside of a running job, so this will fail.
			var instanceOID=new OID(ClassID.ExecutionHistoryItem,Guid.Parse(adTempus.JobVariables["ADJobInstance"]));
			
			var messageString=new StringBuilder();
			
			//connect to adTempus using the API. Note that the use account used for the job must have permission to log in to adTempus and view the job
			using(var scheduler=Scheduler.Connect(adTempus.JobVariables["ServerAndInstanceName"],LoginAuthenticationType.Windows, "", ""))
			{
				using(var context=scheduler.NewDataContext())
				{
					//Get the ExecutionHistoryItem representing the active instance (documentation.arcanadev.com/adtempus/api/5.1/ArcanaDevelopment.adTempus.Client~ArcanaDevelopment.adTempus.Client.ExecutionHistoryItem.htm)
					var instance=(ExecutionHistoryItem)context.GetObject(instanceOID);

					var messages=instance.LogMessages.OrderBy(msg => msg.RecordID);	//sort in ascending order. Don't use timestamp because messages may all end up with the same timestamp if they're logged in quick succession.
					foreach(var message in messages)
					{
						if(message.MessageType == MessageType.Error || (IncludeWarningMessages && message.MessageType== MessageType.Warning))
						{
							if(message.MessageType==MessageType.Error)
							{
								messageString.Append("Error: ");
							}
							else if (message.MessageType == MessageType.Warning)
							{
								messageString.Append("Warning: ");
							}
					
							messageString.AppendLine(message.Message);
						}
					}
					
					//store the messages in a variable
					adTempus.JobVariables.Add("ErrorMessagesForInstance", messageString.ToString(), false);
				}
			}
			return 0;
        }
    }
}