/*
* Copyright (c) 2009 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:
*
*/
using System;
using System.Text;
using System.IO;
using System.Collections.Generic;
using CrashItemLib.Crash.Container;
using CrashItemLib.PluginAPI;
using SymbianUtils.DataBuffer;
using SymbianUtils.DataBuffer.Primer;
using SymbianUtils;
using DExcPlugin.Extractor;
using DExcPlugin.Descriptor;
using DExcPlugin.Plugin;
using DExcPlugin.Transformer;

namespace DExcPlugin.Reader
{
    internal class DExcReader : CFFReader
	{
		#region Constructors
        public DExcReader( DExcPluginImp aEngine, DExcDescriptor aDescriptor )
		:   base( aEngine, aDescriptor )
		{
            iTraceExtractor.StateChanged += new DExcExtractor.EventHandler( TraceExtractor_StateChanged );
        }
        #endregion

        #region From CFFReader
        public override void NativeReadInit()
        {
            throw new NotSupportedException();
        }

        public override void TraceReadInit()
        {
            // Check if there is an stk file with the same name
            string stackFile = DExcDescriptor.StackFileName;
            if ( File.Exists( stackFile ) )
            {
                iTraceExtractor.Init( stackFile );
            }
            else
            {
                iTraceExtractor.Init();
            }
        }

        public override bool TraceReadOffer( CFFTraceLine aLine )
        {
            bool consumed = iTraceExtractor.Offer( aLine, aLine.LineNumber );
            return consumed;
        }

        public override void TraceReadComplete()
        {
            // This flushes any pending raw data items in the interpreter.
            iTraceExtractor.Finialize();
            
            base.NotifyEvent( TEvent.EReadingComplete );
        }
        #endregion

        #region Properties
        public DExcPluginImp DExcEngine
        {
            get { return base.Plugin as DExcPluginImp; }
        }

        public DExcDescriptor DExcDescriptor
        {
            get { return base.Descriptor as DExcDescriptor; }
        }
        #endregion

        #region Observer - Trace interpreter
        private void TraceExtractor_StateChanged( DExcExtractor.TEvent aEvent, DExcExtractor aExtractor )
        {
            // This event is notified when the extractor has obtained one entire D_EXC crash
            if ( aEvent == DExcExtractor.TEvent.EEventExtractedAllData )
            {
                DExcExtractedData data = aExtractor.CurrentData;
                DExcTransformer transformer = new DExcTransformer( DExcDescriptor, base.Plugin.DataProvider, data );

                // Transform into crash container
                CIContainer container = transformer.Transform();
                if ( container != null )
                {
                    base.NotifyEvent( TEvent.EReadingContainerCreated, container );
                }

                // Get extractor ready for next file
                iTraceExtractor.Init();
            }
        }
        #endregion

        #region Internal methods
        #endregion

        #region Data members
        private DExcExtractor iTraceExtractor = new DExcExtractor();
        #endregion
    }
}