/*
 * Copyright (c) 2007-2010 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:
 *
 * External Filter Data Writer
 *
 */
package com.nokia.traceviewer.engine.dataprocessor;

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;

import com.nokia.traceviewer.engine.TraceProperties;
import com.nokia.traceviewer.engine.TraceViewerGlobals;

/**
 * External Filter Data Writer sends data to Processes output stream
 */
public class ExternalFilterDataWriter {

	/**
	 * Output stream writer
	 */
	private final BufferedWriter writer;

	/**
	 * Constructor
	 * 
	 * @param os
	 *            output stream
	 */
	public ExternalFilterDataWriter(OutputStream os) {
		OutputStreamWriter osw = new OutputStreamWriter(os);
		writer = new BufferedWriter(osw);
	}

	/**
	 * Writes trace to Process input stream
	 * 
	 * @param properties
	 *            trace properties
	 */
	public void writeTrace(TraceProperties properties) {
		try {
			StringBuffer buf = new StringBuffer();
			if (properties.timestampString != null) {
				buf.append(properties.timestampString);
				buf.append(TraceViewerGlobals.getTraceViewer()
						.getDataProcessorAccess().getTimestampParser()
						.getTimeFromPreviousString(
								properties.timeFromPreviousTrace));
				buf.append('\t');
			}
			if (properties.traceString != null) {
				buf.append(properties.traceString);
			}
			buf.append('\n');
			writer.write(buf.toString());

			// Flush when last trace is written
			if (properties.lastTrace) {
				writer.flush();
			}
		} catch (IOException e) {
			// If writing goes wrong, shut down possible progressbar
			e.printStackTrace();
			closeProgressBar();
		}
	}

	/**
	 * Closes progressbar
	 */
	private void closeProgressBar() {
		if (TraceViewerGlobals.getTraceViewer().getDataProcessorAccess()
				.getFilterProcessor().isProcessingFilter()) {

			// Close progressbar
			TraceViewerGlobals.getTraceViewer().getView().closeProgressBar(
					TraceViewerGlobals.getTraceViewer()
							.getDataProcessorAccess().getFilterProcessor()
							.getFilterDialog().getProgressBar());
		}
	}

	/**
	 * Shuts down the writer
	 */
	public void shutDown() {
		try {
			writer.close();
		} catch (IOException e) {
			// If writing goes wrong, shut down possible progressbar
			// e.printStackTrace();
			closeProgressBar();
		}
	}
}