/**************************************************************************
 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
 *                                                                        *
 * Author: The ALICE Off-line Project.                                    *
 * Contributors are mentioned in the code where appropriate.              *
 *                                                                        *
 * Permission to use, copy, modify and distribute this software and its   *
 * documentation strictly for non-commercial purposes is hereby granted   *
 * without fee, provided that the above copyright notice appears in all   *
 * copies and that both the copyright notice and this permission notice   *
 * appear in the supporting documentation. The authors make no claims     *
 * about the suitability of this software for any purpose. It is          *
 * provided "as is" without express or implied warranty.                  *
 **************************************************************************/

// $Id$
// $MpId: AliMpDataStreams.cxx,v 1.12 2006/05/23 13:09:54 ivana Exp $
// Category: basic

//-----------------------------------------------------------------------------
// Class AliMpDataStreams
// ----------------------
// Class for providing mapping data streams
// Se detailed description in the header file.
// Author: Ivana Hrivnacova; IPN Orsay
//-----------------------------------------------------------------------------

#include "AliMpDataStreams.h"
#include "AliMpDataMap.h"
#include "AliMpFiles.h"

#include "AliLog.h"

#include <TMap.h>
#include <TFile.h>
#include <TObjString.h>
#include <TString.h>
#include <Riostream.h>

#include <string>

/// \cond CLASSIMP
ClassImp(AliMpDataStreams)
/// \endcond

AliMpDataStreams* AliMpDataStreams::fgInstance = 0;

//
// static methods
//

//______________________________________________________________________________
AliMpDataStreams* AliMpDataStreams::Instance()
{
/// Return its instance

  if ( ! fgInstance ) {
    fgInstance = new AliMpDataStreams();
  }  
    
  return fgInstance;
}    

//
// ctor, dtor
//


//______________________________________________________________________________
AliMpDataStreams::AliMpDataStreams() 
  : TObject(),
    fMap(0),
    fReadFromFiles(kTRUE)
{
/// Standard and default constructor

}

//______________________________________________________________________________
AliMpDataStreams::~AliMpDataStreams() 
{
/// Destructor

  delete fMap;

  fgInstance = 0;
}

//
// public methods
//

/*
//______________________________________________________________________________
TString AliMpDataStreams::GetDataStream(const TString& path) const
{
/// Return the string with data in the mapping file spcified with path

  // Cut top from the path 
  string top = AliMpFiles::GetTop().Data();
  string fullDataPath = path.Data();
  string dataPath = string(fullDataPath, top.size()+1);

  cout << "Go to get value for " << dataPath.c_str() << endl;
  
  // Find string object in the map
  TObject* object = fMap->GetValue(dataPath.c_str());
  if ( ! object ) {
    AliErrorStream() 
      << "Cannot find data for mapping file " << dataPath << endl;
    return "";
  }   
  
  cout << "Got: " << object << endl;   
  
  return ((TObjString*)object)->String();
}
*/

//______________________________________________________________________________
istream& AliMpDataStreams::CreateDataStream(const TString& path) const
{
/// Return the string with data in the mapping file spcified with path.
/// Both full path in the file system and a short path (without 
/// $LICE_ROOT/mapping/data string) can be used.


  if ( fReadFromFiles ) {                                                                
    AliDebugStream(2) << "Opening file " << path.Data() << endl;
    ifstream* fileBuffer = new ifstream();
    fileBuffer->open(path.Data());
    if ( ! fileBuffer->good() ) {	
       AliErrorStream() 
         << "Cannot open file " << path.Data() << endl;
    }     
    return *fileBuffer;
  }
  else {
    AliDebugStream(2) << "Opening stream " << path.Data() << endl;

    // Cut top from the path 
    string top = AliMpFiles::GetTop().Data();
    string fullDataPath = path.Data();
    string dataPath = fullDataPath;
    if ( dataPath.find(top) != string::npos )
      dataPath.erase(0, top.size()+6);

    istringstream* stringBuffer 
      = new istringstream(fMap->Get(dataPath).Data());
    return *stringBuffer;
   }    
}

//______________________________________________________________________________
Bool_t  AliMpDataStreams::IsDataStream(const TString& path) const
{
/// Return true, if data with given path exists

  if ( fReadFromFiles ) {                                                                
    ifstream fileBuffer(path.Data());
    return fileBuffer.good();
  }
  else {
    // Cut top from the path 
    string top = AliMpFiles::GetTop().Data();
    string fullDataPath = path.Data();
    string dataPath = fullDataPath;
    if ( dataPath.find(top) != string::npos )
      dataPath.erase(0, top.size()+6);

    // std::map implementation
    // return fMap->GetMap().find(dataPath) != fMap->GetMap().end();
    return ( fMap->Get(dataPath, kFALSE) != "" );
  }
}      


//______________________________________________________________________________
void  AliMpDataStreams::SetDataMap(AliMpDataMap* map)
{
/// Set the data map and switch off readFromFiles

  if ( fMap && fMap != map ) delete fMap;

  fMap = map;
  fReadFromFiles = kFALSE;
}  

//______________________________________________________________________________
void  AliMpDataStreams::SetReadFromFiles(Bool_t readFromFiles)
{
/// Set option to read data from files

  if ( ! fMap && ! readFromFiles ) {
    AliWarningStream()
      << "Setting ignored: " << endl
      << "Selected reading from streams, but data map has not been yet defined"
      << endl;
      
    return;  
  }     

  fReadFromFiles = readFromFiles;
}  

//______________________________________________________________________________
Bool_t AliMpDataStreams::GetReadFromFiles() const
{ 
/// Return the info where the data are loaded from

  return fReadFromFiles; 
}