package de.ugoe.cs.eventbench;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;

import org.apache.commons.codec.binary.Base64;

import de.ugoe.cs.util.StringTools;
import de.ugoe.cs.util.console.Console;

public class LogPreprocessor {
	
	private boolean sessionOpen = false;
	private boolean msgIncomplete = false;
	
	private boolean base64;
	
	public LogPreprocessor() {
		this(false);
	}
	
	public LogPreprocessor(boolean base64) {
		this.base64 = base64;
	}
	
	public void convertToXml(String source, String target) throws IOException, FileNotFoundException {
		FileWriter targetFile = new FileWriter(target);
		targetFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>" + StringTools.ENDLINE);
		targetFile.write("<log>" + StringTools.ENDLINE);
		processFile(source, targetFile);
		if( sessionOpen ) {
			targetFile.write(" </session>" + StringTools.ENDLINE);
		}
		targetFile.write("</log>");
		targetFile.close();
	}
	
	
	public void convertDirToXml(String path, String target) throws IOException, FileNotFoundException {
		FileWriter targetFile = new FileWriter(target);
		targetFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>" + StringTools.ENDLINE);
		targetFile.write("<log>" + StringTools.ENDLINE);
		File folder = new File(path);
		if( !folder.isDirectory() ) {
			throw new IOException(path + " is not a directory");
		}
		String absolutPath = folder.getAbsolutePath();
		for( String filename : folder.list() ) {
			String source = absolutPath + "/" + filename;
			Console.traceln("Processing file: " + source);
			processFile(source, targetFile);
		}
		
		if( sessionOpen ) {
			targetFile.write(" </session>" + StringTools.ENDLINE);
		}
		targetFile.write("</log>");
		targetFile.close();
	}

	private void processFile(String source, FileWriter targetFile)
			throws FileNotFoundException, IOException {
		File f = new File(source);
		FileReader reader = new FileReader(f);
		char[] buffer = new char[(int) f.length()];
		reader.read(buffer);
		reader.close();
		String[] lines = (new String(buffer)).split("\n");
		String incompleteLine = "";
		// Open source and read line by line
		for( String currentLine : lines ) {
			if( currentLine.contains("UL: <session>")) {
				if( sessionOpen) {
					targetFile.write(" </session>" + StringTools.ENDLINE);
					targetFile.write(" <session>" + StringTools.ENDLINE);
				} else {
					targetFile.write(" <session>" + StringTools.ENDLINE);
					sessionOpen = true;
				}
			} else if( currentLine.contains("UL: </session>")) {
				if( sessionOpen) {
					targetFile.write(" </session>" + StringTools.ENDLINE);
					sessionOpen = false;
				}
			} else if( msgIncomplete || currentLine.contains("UL: ")) {
				
				String currentContent;
				String actualLine;
				if( msgIncomplete ) {
					actualLine = currentLine;
				} else {
					String[] splitResult = currentLine.split("UL: ");
					actualLine = splitResult[1];
				}
				if( base64 ) {
					Base64 decoder = new Base64();
					byte[] decoded = decoder.decode(actualLine);
					currentContent = new String(decoded, "UTF-16LE");
					currentContent = currentContent.substring(0, currentContent.length()-1);
				} else {
					currentContent = actualLine;
				}
				if( msgIncomplete ) {
					incompleteLine += currentContent;
					if( incompleteLine.contains("</msg>") ) {
						msgIncomplete = false;
						targetFile.write(incompleteLine + StringTools.ENDLINE);
						incompleteLine = "";
					}
				} else {
					if( currentContent.contains("<msg") && sessionOpen ) {
						if( currentContent.contains("</msg>") ) {
							targetFile.write("  " + currentContent + StringTools.ENDLINE);
						} else {
							msgIncomplete = true;
							incompleteLine += currentContent;
						}
					}
				}
			}
		}
	}

}