GetMailFromIvanti.java

package Jvakt;
/*
 * 2025-05-08 V.02 Michael Ekdal		Adjusted the log output.
 * 2025-04-25 V.01 Michael Ekdal		Reading mail from Ivanti about resolved incidents and update Jvakt DB.
 */

import jakarta.mail.*;
import jakarta.mail.search.*;
//import Jvakt.Message;
import java.util.*;

import Jvakt.Message;

import java.io.*;
import java.net.InetAddress;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class GetMailFromIvanti {

	//	static boolean newMsgId = false;
	static String DBUrl = "jdbc:postgresql://localhost:5433/Jvakt";
	static Connection conn = null;
	static String database = "jVakt";
	static String dbuser   = "jVakt";
	static String dbpassword = "";
	static String dbhost   = "localhost";
	static String dbport   = "5433";


	static boolean msgFixat = false;
	static boolean swHtml = false;
	static boolean swHelp = false;
	static boolean swOkSender = false;
	static boolean swPrio = false;
	static boolean swMailcheck = true;
	static boolean swDormant = false;
	static boolean swId = false;
	static boolean swDelete = false;
	static boolean swOKtot = false;
	static String mimeType;
	static String msgId;
	static String t_id;

	//	static boolean swSunet = false;

	static boolean swSerious = false;
	static boolean swShow = false;
	static boolean swRun = true;

	static String from;
	static String subject;
	static String body;
	static int antal;
	static int detached;
	static String agent = null;
	static String jvhost   = "localhost";
	static String jvport   = "1956";
	static int jvporti ;
	static String jvrc   = "";
	static String uname;
	static String pwd;
	static String imaphost;
	static String imapport;
	static String imapssl;
	static String imaprw;
	static String imapFolder;
	static String senders;
	static String sender;
	static List<String> listSenders;
	static String exSubjects;
	static String exSubject;
	static List<String> listExsubjects;

	static String config = null;
	static File configF;

	static InetAddress inet;

	public static void main(String[] args) {

		String version = "GetMailFromIvanti ";
		version += getVersion()+".02";

		for (int i=0; i<args.length; i++) {
			if (args[i].equalsIgnoreCase("-config")) config = args[++i];
			if (args[i].equalsIgnoreCase("-help")) swHelp = true;
			if (args[i].equalsIgnoreCase("-?")) swHelp = true;
			if (args[i].equalsIgnoreCase("-norun")) swRun = false;
			if (args[i].equalsIgnoreCase("-nomailcheck")) swMailcheck = false;
			if (args[i].equalsIgnoreCase("-id")) swId = true;
			if (args[i].equalsIgnoreCase("-delete")) swDelete = true;
			if (args[i].equalsIgnoreCase("-show")) swShow = true;

		}

		if (swHelp) {
			System.out.println("--- GetMailFromIvanti --- ");
			System.out.println("by Michael Ekdal Perstorp Sweden.\n");
			System.out.println("Analyses mail from Ivanti and updates the Jvakt dadtabase");

			System.out.println("\n\nThe parameters and their meaning are:\n"+
					"\n-config 		\tThe directory of the input files. Like: \"-dir c:\\Temp\" "+
					"\n-norun  		\tTo turn of the status update in Jvakt." +
					"\n-nomailcheck \tDo not read an analyze the mails. Only log-on the mail server to verify it is possible." +
					"\n-id          \tCreates an ID in the Jvakt server showing the status of the mail server. OK when able to log-on, ERR when not." +
					"\n-delete      \tWhen a mai is found, delete it! ( the default is to mark it as seen )"+ 
					"\n-show   		\tA verbose log showing the response from the server."
					);

			System.exit(4);
		}

		if (config == null ) 	configF = new File("PlugIvantiSM.properties");
		else 					configF = new File(config,"PlugIvantiSM.properties");
		System.out.println("\n"+new Date()+" ----- Jvakt: Version: "+version);
		System.out.println(new Date()+" -config file: "+configF);

		Properties props = new Properties();
		getProps();  // get Jvakt properties


		if (swRun) {
			SendMsg jm = new SendMsg(jvhost, jvporti);  // Check if JvaktServer is available and if dormant.
			jvrc = jm.open();
			System.out.println(new Date()+" Jvakt server status: "+jvrc);
			if (jvrc.toLowerCase().startsWith("dormant")) swDormant = true;
			if (jvrc.toLowerCase().startsWith("failed")) {
				swRun = false;
				swDormant = true;
				System.out.println(new Date()+" ----- Access to  Jvakt failed! \"run\" set to false !!");
			}
			jm.close();
		}

		//		System.exit(4);


		if (swDormant) {
			System.out.println(new Date()+" *** Jvakt in DORMANT mode, GetMailFromIvanti exiting *** ");
			System.exit(4);			
		}

		String provider = "imap";  // plain
		int    imapPort = 993; // secure

		Address[] adr;

		try {


			imapPort = Integer.parseInt(imapport);
			// Connect to the imap4 server
			if (imapssl.startsWith("N")) {
				props.put("mail.imap.ssl.enable", "false");  // plain
				provider = "imap"; 
				System.out.println(new Date()+" *** imap plain connection selected *** ");
			}
			else {
				props.put("mail.imap.ssl.enable", "true");   // secure
				provider = "imaps"; 
				System.out.println(new Date()+" *** imaps secure connection selected *** ");
			}

			props.put("mail.imap.ssl.trust", "*");
			props.put("mail.imaps.ssl.trust", "*");

			System.out.println(new Date()+" Initiating connection to imap4 server....");
			System.out.println(new Date()+" Connection... " + imaphost+":"+imapport+"  User: "+uname);
			Session session = Session.getDefaultInstance(props, null);
			Store store = session.getStore(provider);
			try {
				store.connect(imaphost, imapPort, uname, pwd);
			} catch (Exception e) {
				System.out.println(new Date()+" Connection to " + imaphost+":"+imapport+"  User "+uname+"  Pass "+pwd+" failed!");
				System.out.println(e);
				if (swId) sendJv("GetMail2Jvakt_"+imaphost+"_"+uname , "ERR" , "T", "Connection to imap4 server "+imaphost+" user "+uname+" failed!" );
				System.exit(8);
			}
			System.out.println(new Date()+" Connection to imap4 server established.");
			if (swId) sendJv("GetMailFromIvanti_"+imaphost+"_"+uname , "OK" , "T", "Connection to imap4 server "+imaphost+" user "+uname+" established." );

			if (swRun) {
				// Open the folder
				System.out.println(new Date()+" Open folder: " + imapFolder+ " (store folder separator "+store.getDefaultFolder().getSeparator()+" )");
				Folder inbox = store.getFolder(imapFolder);
				if (inbox == null) {
					System.out.println(new Date()+" Mailbox folder "+imapFolder+" not found!");
					System.exit(1);
				}

				if (imaprw.startsWith("Y") && swRun && swMailcheck) {
					System.out.println(new Date()+" Opens "+imapFolder+" READ_WRITE");
					inbox.open(Folder.READ_WRITE);  // remove the marked messages from the server
				}
				else {
					System.out.println(new Date()+" Opens "+imapFolder+" READ_ONLY");
					inbox.open(Folder.READ_ONLY);
				}

				// Get the messages from the server
				// Fetch all messages from inbox folder
				//			javax.mail.Message[] messages = inbox.getMessages();
				// Fetch unseen messages from inbox folder
				jakarta.mail.Message[] messages = null;
				messages = inbox.search(new FlagTerm(new Flags(Flags.Flag.SEEN), false));

				//	        System.out.println("\n------------ NewMessageCount " + inbox.getNewMessageCount() + " ------------");
				//	        System.out.println("------------ UnreadMessageCount " + inbox.getUnreadMessageCount() + " ------------");

				System.out.println(new Date()+" *** Number of mails-> " +messages.length);

				if (swMailcheck) {
					for (int i = 0; i < messages.length; i++) {
						adr = messages[i].getFrom(); 
						from = null;
						if (adr != null) {
							//					System.out.println("adr null ");
							for (int j = 0; j < adr.length; j++) {
								from = adr[j].toString();
							}
						} else {
							from = "unknown";
						}
						System.out.println("\n"+new Date()+" >>> Mail from From: " + from );
						//	        if (from == null) subject = "null.";  2013-05-23
						if (from == null) from = "null.";
						subject = messages[i].getSubject();
						if (subject == null) subject = "null.";
						mimeType = messages[i].getContentType();
						System.out.println(new Date()+" MimeType> " + mimeType);
						System.out.println(new Date()+" Subject: " + subject);
						//				if (from.contains("postmaster@internal.perscorp.com")) continue;
						body = null;
						swHtml = false;
						Object o = null;
						//				if (messages[i].isMimeType("text/plain") || messages[i].isMimeType("text/html") || messages[i].isMimeType("multipart/alternative")  || messages[i].isMimeType("multipart/mixed")  ) {
						//				if (messages[i].isMimeType("text/plain") || messages[i].isMimeType("text/html") ) {
						if (mimeType.toLowerCase().indexOf("text/plain")>=0 || mimeType.toLowerCase().indexOf("text/html")>=0) {
							try {
								o = messages[i].getContent();
								body = (String)o;
							} catch (IOException e) {
								body = "";
							}
							if (messages[i].isMimeType("text/html")) swHtml = true;  
						}
						if (messages[i].getContentType().startsWith("multipart")) {
							System.out.println(new Date()+" *** multipart ");
							Multipart mp = (Multipart)messages[i].getContent();
							System.out.println(new Date()+" ***Count> " + mp.getCount());

							for (int j=0, n=mp.getCount(); j<n; j++) {
								Part part = mp.getBodyPart(j);
								System.out.println(new Date()+" *** Attachment Descript : "+part.getDescription());
								System.out.println(new Date()+" *** Attachment ContentType : "+part.getContentType());
								if (part.getContentType().contains("text/plain")) {
									body = part.getContent().toString();
//									System.out.println(new Date()+" *** Attachment Content : "+body);
								}
							}									
						}

						if (body == null) body = "null.";

						//********************************
						//************** analyse start *****

						System.out.println(new Date()+" From-> " + from);
						System.out.println(new Date()+" Subject-> " + subject);
						System.out.println(new Date()+" Body-> " + body);

						msgFixat = false;
						swOkSender = false;
						swPrio = false;

						for(Object object : listSenders) { 
							sender = (String)object;
							sender = sender.trim().toLowerCase();
							if (from.toLowerCase().indexOf(sender) >= 0) swOkSender = true;
							if (sender.compareTo("*")==0) swOkSender = true;
						}


						if (swOkSender) {
							System.out.println(new Date()+"  - Sender "+from+" is accepted");

							if (messages[i].getContentType().toLowerCase().startsWith("multipart")) {
								//						System.out.println("*** multipart ");
								Multipart mp = (Multipart)messages[i].getContent();
								//						System.out.println("*** Count> " + mp.getCount());

								for (int j=0, n=mp.getCount(); j<n; j++) {
									Part part = mp.getBodyPart(j);
									//							System.out.println("*** Attachment Descript : "+part.getDescription());
									//							System.out.println("*** Attachment ContentType : "+part.getContentType());
									if (part.getContentType().toLowerCase().contains("text/plain")) {
										body = part.getContent().toString();
										//								System.out.println("*** Attachment Content : \n"+body);
									}
								}									
							}

							for(Object object : listExsubjects) { 
								exSubject = (String)object;
								exSubject = exSubject.trim().toLowerCase();
								if (subject.toLowerCase().indexOf(exSubject) >= 0) {
									swOkSender = false;
									System.out.println(" - but subject '"+exSubject+"' is exempted!");
								}
								if (body.toLowerCase().indexOf(exSubject) >= 0) {
									swOkSender = false;
									System.out.println(" - but body '"+exSubject+"' is exempted!");
								}
							}

							if (swOkSender) {
//								System.out.println(new Date()+"  - swOkSender");
								if (subject.toLowerCase().indexOf("is resolved") >= 0) {
									System.out.println(new Date()+"  - is resolved");

									String id[];
									id = null;

									int bodyindex = body.toLowerCase().indexOf("jvakt-id:");
									if (bodyindex >= 0) {
										bodyindex=bodyindex+9;
//										System.out.println(new Date()+" Jvakt-id::"+bodyindex);
//										System.out.println("body::"+body.substring(bodyindex,bodyindex+100));
										id = body.substring(bodyindex,bodyindex+100).split(";");
										id[0] = id[0].trim();
										System.out.println("id::"+id[0]);
										if (!id[0].isEmpty() && imaprw.startsWith("Y") && swRun) {
											msgFixat=updDBSTS(id[0]);
										}
									}

									if (id == null) {
										bodyindex = body.toLowerCase().indexOf("description:");
										id = null;
										if (bodyindex >= 0) {
											bodyindex=bodyindex+12;
//											System.out.println(new Date()+" Description::"+bodyindex);
//											System.out.println("body::"+body.substring(bodyindex,bodyindex+100));
											id = body.substring(bodyindex,bodyindex+100).split(" - ");
											id[0] = id[0].trim();
											System.out.println("id::"+id[0]);
											if (!id[0].isEmpty() && imaprw.startsWith("Y") && swRun ) {
												msgFixat=updDBSTS(id[0]);
											}
										}
									}
								}
							}



						}
						else System.out.println(new Date()+"  - Sender "+from+" is NOT accepted"); 

						if (msgFixat && imaprw.startsWith("Y") && swRun) { 
							if (swDelete) {
								System.out.println(new Date()+" * Mark as DELETED ");
								messages[i].setFlag(Flags.Flag.DELETED, true);						
							}
							else {
								System.out.println(new Date()+" * Mark as SEEN ");
								messages[i].setFlag(Flags.Flag.SEEN, true); 
							}
						}

						if (!msgFixat && swRun && imaprw.startsWith("Y")) {
							System.out.println("* Mail ignored ");
							messages[i].setFlag(Flags.Flag.SEEN, false); 
						}

						//************ Analyze stop ******
						//*******************************
					}
				}
				// Close the connection
				if (imaprw.startsWith("Y") && swRun && swMailcheck ) {
					System.out.println(new Date()+" Close Mailbox folder "+imapFolder+" with option true");
					inbox.close(true);  // remove the marked messages from the server
				}
				else {
					System.out.println(new Date()+" Close Mailbox folder "+imapFolder+" with option false");
					inbox.close(false);
				}
			}
			store.close();
			swOKtot = true;
		}
		catch (Exception ex) {
			ex.printStackTrace();
			swOKtot = false;
		}

		if ( swRun ) {
			if (swOKtot ) try {sendSTS(true);}  catch (IOException e) { e.printStackTrace();}
			else 	      try {sendSTS(false);} catch (IOException e) { e.printStackTrace();}
		}

	} 

	// End of program

	static protected void sendJv( String ID, String STS, String type, String msg) throws IOException {
		Message jmsg = new Message();
		SendMsg jm = new SendMsg(jvhost, jvporti);
		System.out.println(jm.open());
		jmsg.setId(ID);
		jmsg.setRptsts(STS);
		jmsg.setBody(msg);
		jmsg.setType(type);
		jmsg.setAgent(agent);
		if (swSerious) {
			jmsg.setPrio(20);
			swSerious = false;
		} else jmsg.setPrio(30);

		if (jm.sendMsg(jmsg)) {
			System.out.println("-- Rpt Delivered -- " + ID +" - "+ STS +" - "+ type +" - "+ agent);
			msgFixat = true;
		}
		else     {
			System.out.println("-- Rpt Failed --");
			msgFixat = false;
		}
		jm.close();
	}

	static void getProps() {

		Properties prop = new Properties();
		InputStream input = null;
		try {
			input = new FileInputStream(configF);
			prop.load(input);
			// get the property value and print it out
			jvport   = prop.getProperty("jvport");
			jvhost   = prop.getProperty("jvhost");
			jvporti  = Integer.parseInt(jvport);

			database = prop.getProperty("database");
			dbuser   = prop.getProperty("dbuser");
			dbpassword = prop.getProperty("dbpassword");
			if (dbpassword.startsWith("==y")) {
				byte[] decodedBytes = Base64.getDecoder().decode(dbpassword.substring(3));
				String decodedString = new String(decodedBytes);
				dbpassword=decodedString;
			}
			dbhost   = prop.getProperty("dbhost");
			dbport   = prop.getProperty("dbport");

			uname    = prop.getProperty("smtpuser");
			pwd      = prop.getProperty("smtppwd");
			if (pwd.startsWith("==y")) {
				byte[] decodedBytes = Base64.getDecoder().decode(pwd.substring(3));
				String decodedString = new String(decodedBytes);
				pwd=decodedString;
			}
			imaphost = prop.getProperty("imaphost");
			imapport = prop.getProperty("imapport");
			imapssl = prop.getProperty("imapSSL");
			imaprw = prop.getProperty("imapRW");
			imapFolder = prop.getProperty("imapFolder");
			senders = prop.getProperty("senders");

			String[] senderAddr = senders.split("\\,");

			listSenders = new ArrayList<String>();  // Alla mailadresser.
			System.out.println(new Date()+" -- Accepted senders --");
			for(int i=0 ; i<senderAddr.length;i++) {
				System.out.println(senderAddr[i]);
				listSenders.add(senderAddr[i]);
			}

			exSubjects = prop.getProperty("exsubjects");
			String[] exSubjectsStrings = exSubjects.split("\\,"); // All no-wanted subjects

			listExsubjects = new ArrayList<String>();
			System.out.println(new Date()+" -- exempted subjects --");
			for(int i=0 ; i<exSubjectsStrings.length;i++) {
				System.out.println(exSubjectsStrings[i]);
				listExsubjects.add(exSubjectsStrings[i]);
			}


			//			int imapporti = Integer.parseInt(imapport);

			System.out.println(new Date()+" getProps jvport:" + jvport + "  jvhost:"+jvhost) ;
		} catch (IOException ex) {
			ex.printStackTrace();
		}
		try {
			inet = InetAddress.getLocalHost();
			System.out.println(new Date()+" -- Inet: "+inet);
			agent = inet.toString();
		}
		catch (Exception e) { System.out.println(e);  }

	}

	static private String getVersion() {
		String version = "0";
		try { 
			Class<?> c1 = Class.forName("Jvakt.Version",false,ClassLoader.getSystemClassLoader());
			Version ver = new Version();
			version = ver.getVersion();
		} 
		catch (java.lang.ClassNotFoundException ex) {
			version = "?";
		}
		return version;
	}

	// sends status to the Jvakt server
	static protected void sendSTS( boolean STS) throws IOException {
		System.out.println("--- Connecting to "+jvhost+":"+jvport);
		Message jmsg = new Message();
		SendMsg jm = new SendMsg(jvhost, jvporti);
		//			System.out.println(jm.open()); 
		jm.open(); 
		jmsg.setId("Jvakt-GetMailFromIvanti");
		if (STS) {
			jmsg.setBody("The GetMailFromIvanti program is working. "+configF.getCanonicalPath());
			jmsg.setRptsts("OK");
		}
		else {
			jmsg.setBody("The GetMailFromIvanti program is not working! "+configF.getCanonicalPath());
			jmsg.setRptsts("ERR");
		}
		jmsg.setType("T");

		inet = InetAddress.getLocalHost();
		//			System.out.println("-- Inet: "+inet);
		agent = inet.toString();

		jmsg.setAgent(agent);
		if (!jm.sendMsg(jmsg)) System.out.println("--- Rpt to Jvakt Failed for GetMailFromIvanti ---");
		jm.close();

		System.out.println("--- Status about GetMailFromIvanti sent to "+jvhost+":"+jvport);

	}

	static protected boolean updDBSTS( String id) throws IOException {
		try {
			String SQL_UPDATE;
			PreparedStatement StmtUpdate;
			Class.forName("org.postgresql.Driver").newInstance();
			DBUrl = "jdbc:postgresql://"+dbhost+":"+dbport+"/"+database;
			System.out.println(new Date()+ "DBUrl > "+DBUrl);
			conn = DriverManager.getConnection(DBUrl,dbuser,dbpassword);
			System.out.println(new Date()+ "conn > "+conn);
			conn.setAutoCommit(false);

			SQL_UPDATE ="UPDATE CONSOLE SET RECID=? WHERE ID ilike '"+id+"'" ;
			System.out.println(new Date()+ " > "+SQL_UPDATE);
			//			logg.write(new Date()+" "+recid+ " > "+SQL_UPDATE);
			//			logg.newLine(); 
			StmtUpdate = conn.prepareStatement(SQL_UPDATE);
			StmtUpdate.setString(1, null);
			System.out.println(new Date()+" Updated records > "+StmtUpdate.executeUpdate());
			//			logg.write(new Date()+" Updated records > "+StmtUpdate.executeUpdate());
			//			logg.newLine();

			SQL_UPDATE ="UPDATE STATUS SET RECID=? WHERE ID ilike '"+id+"'";
			System.out.println(new Date()+ " > "+SQL_UPDATE);
			//			logg.write(new Date()+" "+recid+ " > "+SQL_UPDATE);
			//			logg.newLine(); 
			StmtUpdate = conn.prepareStatement(SQL_UPDATE);
			StmtUpdate.setString(1, null);
			System.out.println(new Date()+" Updated records > "+StmtUpdate.executeUpdate());
			//			logg.write(new Date()+" Updated records > "+StmtUpdate.executeUpdate());
			//			logg.newLine();


			StmtUpdate.close();
			conn.commit();
			conn.close();
		}
		catch (SQLException e) {
			System.out.println(new Date()+" SQLExeption ");
			//			logg.write(new Date()+" > "+e);
			//			logg.newLine(); 
			//			logg.write(new Date()+" > "+e.getMessage());
			//			logg.newLine(); 
			System.err.println(e);
			System.err.println(e.getMessage());
			return false;
		}
		catch (Exception e) {
			System.out.println(new Date()+" Exeption");
			//			logg.write(new Date()+" > "+e);
			//			logg.newLine(); 
			//			logg.write(new Date()+" > "+e.getMessage());
			//			logg.newLine(); 
			System.err.println(e);
			System.err.println(e.getMessage());
			return false;
		}
		return true;
	}


}