/*

 Einstein@Home Log file processor

 Reads lines from the job log file and computes credits received. A sum of
 the total credit can be printed, or a list of daily totals for graphing.

 NOTES:
	Does not take into account where credits for a task have been changed.
	There is no way to detect invalid/error tasks just from the job log.

 28-Mar-2013: Initial version
 14-Apr-2013: Updated command line argument handling
 25-May-2013: Print error messages to stderr
 27-May-2013: Updated for BRP5 tasks

 (c) Copyright Neil Newell 2013

*/

import java.io.*;
import java.nio.charset.Charset;

public class jl {

	static String jobfile = "job_log_einstein.phys.uwm.edu.txt";
//	static String srvpath = "/diskless/wb6/";
//	static String hostpath = "/home/nk/BOINC/";
	static String hostpath = "";

	static double points,total;

	public enum Mode { PLOT,TOTAL }

/************************* main *************************/

	public static void main(String[] args) {

		int i;
		Mode mode = Mode.TOTAL;

		for (i=0;i<args.length;i++) {
			if (args[i].equals("-t"))
				mode = Mode.TOTAL;
			else if (args[i].equals("-p"))
				mode = Mode.PLOT;
			else if (args[i].charAt(0) != '-')
				jobfile = args[i];
			else {
				XPERR("ERROR: Unknown argument '" + args[i] + "'");
				System.exit(1);
			}
		}

		try {

			int curday=0,ndays=0;
			points = total = 0.0;
			Double avg = 0.0;
			Double alpha = 1.0;

			String line;
			BufferedReader br;

			String s = hostpath + jobfile;

			FileInputStream fin = new FileInputStream(s);

			br = new BufferedReader(new InputStreamReader(fin, Charset.forName("UTF-8")));

			while ((line = br.readLine()) != null) {

				i = process(line);	// Process line, adding points to class total; returns day number

				if (curday==0)		// Start-up handling
					curday = i;

				if (i != curday) {	// If day has changed

					ndays++;

					avg = points * alpha + avg * (1.0-alpha);	// Update daily average

					if ((alpha = 1.0/(double) ndays) < 1.0/12.0) // Update filter co-efficient for first N days
						alpha = 1.0/12.0;

					if (mode == Mode.PLOT)
						System.out.format("%6d %12.1f %12.1f\n",i,points,avg);

					curday = i;
					points = 0;
					}
				// N.B We don't print points for last day, as it's incomplete */

			}
		} catch (IOException e) {
			XPERR("I/O error (missing file?)");
		}

	if (mode == Mode.TOTAL)
		System.out.format("Total: %.1f\n",total);
	}

/******************************** process *************************/

	static int process(String line) {
		int secs,day;
		String s;
		double credit;

		s = jobfield(0,line);		// Get job time (seconds)

		secs = Integer.parseInt(s);
		day = (int) secs/(24*60*60);	// Job day

		s = jobfield(8,line);		// Job name

/* Determine job type and add points to total */

		if (s.indexOf("p2030") == 0) { // BRP4
			credit = 500.0;
		}
		else if (s.indexOf("PA005") == 0) { // BRP5
			credit = 4000.0;
		}
		else if (s.indexOf("LATeah00") == 0) { // GRP
			credit = 80.0;
		}
		else if (s.indexOf("h1_0") == 0) { // GWS6: 251.2
			credit = 251.2;
		}
		else {
			XPERR("WARNING - Unknown job: " + s);
			credit = 0.0;
		}

		points += credit;
		total += credit;

		return day;
	}

/************************* jobfield *************************/

/* Return string containing specified field from the passed input line */

	static String jobfield(int findex,String jobline) {
		String result="";
		int fcount = 0;
		for (int i = 0; i < jobline.length();i++) {
			if (jobline.charAt(i) == ' ') {
				if (fcount == findex)
					break;
				result = "";
				fcount++;
			} else {
				result += jobline.charAt(i);
			}
		}
		if (fcount == findex)
			return result;

		return "";

	}

/************************* XP *************************/

	static void XP(int i) {
		String s = new String("") + i;
		System.out.println(s);
	}

	static void XP(String sin) {
		String s = new String("") + sin;
		System.out.println(s);
	}

	static void XP(String fmt,int ... v) {
		String s = new String("Format string:") + fmt;
		System.out.print(s);
		for (int i=0;i<v.length;i++) {
			System.out.print(" " + v[i]);
		}
		System.out.println();
	}

	static void XPERR(String fmt,int ... v) {
		String s = new String("") + fmt;
		System.err.print(s);
		for (int i=0;i<v.length;i++) {
			System.err.print(" " + v[i]);
		}
		System.err.println();
	}
}