//  Copyright (c) 2008 Chris Miceli <cmicel1@cct.lsu.edu>
// 
//  Distributed under the Boost Software License, 
//  Version 1.0. (See accompanying LICENSE file 
//  or copy at http://www.boost.org/LICENSE_1_0.txt)

#include <saga/saga/url.hpp>
#include <saga/saga/exception.hpp>

#include "hdfs_file_adaptor_dir.hpp"

namespace hdfs_file_adaptor
{
  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_get_url (saga::url & url)
  {
     saga::url u;
     {
         instance_data data (this);
         u = data->location_;
     }
     // complete url
     if (u.get_scheme().empty())
         u.set_scheme("hdfs");
     if (u.get_host().empty())
         u.set_host("localhost");
    
     url = u.get_url();
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_get_cwd (saga::url & cwd)
  {
     instance_data idata (this);
     saga::url result(idata->location_);
     boost::filesystem::path name (result.get_path(), boost::filesystem::native);
     result.set_path(name.branch_path().string());
    
     // complete url
     if (result.get_scheme().empty())
         result.set_scheme("hdfs");
     if (result.get_host().empty())
         result.set_host("localhost");
    
     cwd = result;
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_get_name (saga::url & name)
  {
     instance_data idata (this);
    
     saga::url current_url(idata->location_);
     saga::url u (idata->location_.get_path());
     boost::filesystem::path myname (u.get_path(), boost::filesystem::native);
     name = myname.leaf();
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_is_dir (bool & is_dir)
  {
     instance_data idata (this);
     is_dir = false;
  
     saga::url url(idata->location_);
     boost::filesystem::path path (idata->location_.get_path(), boost::filesystem::native);
     if(hdfsExists(fs_, path.string().c_str()) == 0)
     {
        //Check to see if it is a directory
        hdfsFileInfo *info;
        instance_data idata(this);
      
        info = hdfsGetPathInfo(fs_, path.string().c_str());
        if(info == NULL)
        {
           SAGA_ADAPTOR_THROW("file_cpi_impl::init failed",
                            saga::NoSuccess);
        }
        if(info->mKind == kObjectKindDirectory)
           is_dir = true;
        hdfsFreeFileInfo(info, 1);
     }
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_is_entry (bool & is_entry)
  {
     instance_data idata (this);
     is_entry = false;
   
     saga::url url(idata->location_);
     boost::filesystem::path path (idata->location_.get_path(), boost::filesystem::native);
     if(hdfsExists(fs_, path.string().c_str()) == 0)
     {
        //Check to see if it is a directory
        hdfsFileInfo *info;
        instance_data idata(this);
      
        info = hdfsGetPathInfo(fs_, path.string().c_str());
        if(info == NULL)
        {
           SAGA_ADAPTOR_THROW("file_cpi_impl::init failed",
                            saga::NoSuccess);
        }
        if(info->mKind == kObjectKindFile)
           is_entry = true;
        hdfsFreeFileInfo(info, 1);
     }
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_is_link (bool & is_link)
  {
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_read_link (saga::url & target)
  {
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_link (saga::impl::void_t & ret, 
                                saga::url            dest, 
                                int                  flags)
  {
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_copy (saga::impl::void_t & ret, 
                                saga::url            dest, 
                                int                  flags)
  {    
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_move (saga::impl::void_t & ret, 
                                saga::url            dest, 
                                int                  flags)
  {
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_remove (saga::impl::void_t & ret, 
                                  int                  flags)
  {
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

  ///////////////////////////////////////////////////////////////////////////////
  //
  void dir_cpi_impl::sync_close (saga::impl::void_t & ret, 
                                 double               timeout)
  {
    SAGA_ADAPTOR_THROW ("Not Implemented", saga::NotImplemented);
  }

} // namespace