#--
# =============================================================================== 
# Copyright (c) 2005, Christopher Kleckner
# All rights reserved
#
# This file is part of the Rio library for ruby.
#
# Rio is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# Rio is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with Rio; if not, write to the Free Software
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
# =============================================================================== 
#++
#
# To create the documentation for Rio run the command
#  rake rdoc
# from the distribution directory. Then point your browser at the 'doc/rdoc' directory.
#
# Suggested Reading
# * RIO::Doc::SYNOPSIS
# * RIO::Doc::INTRO
# * RIO::Doc::HOWTO
# * RIO::Rio
#
# <b>Rio is pre-alpha software. 
# The documented interface and behavior is subject to change without notice.</b>


#require 'fileutils'

module RIO
  module IOH #:nodoc: all
    class Base
      attr :ios
      def initialize(ios,*args)
        @ios = ios
      end
      def initialize_copy(*args)
        #p callstr('ioh:initialize_copy',*args)
        super
        @ios = @ios.clone unless @ios.nil?
      end
      def callstr(func,*args)
        self.class.to_s+'['+self.to_s+']'+'.'+func.to_s+'('+args.join(',')+')'
      end
      def handle() @ios end
      def open?() not closed? end
    end
    class Stream < Base
      attr_reader :iostack
      def initialize(iosp,*args)
        super
        @iostack = [@ios]
      end
      def initialize_copy(*args)
        #p callstr('ioh_stream:initialize_copy',*args)
        super
        @iostack = @iostack.map { |io| io.nil? || io.equal?(@ios) ? io : io.clone }
      end
      def copy_blksize() 
        if @ios.respond_to? :stat
          sz = @ios.stat.blksize
          sz = nil if sz.nil? || sz == 0
        end
        sz || 512 
      end

      def handle() @iostack[-1] end
      def close()  handle.close unless self.closed? end
      def closed?() handle.nil? or handle.closed? end
      def eof?() closed? or handle.eof? end
      def copy_stream(dst)
        #p callstr('copy_stream',dst)
        blksize = _stream_blksize(handle,dst)
        until handle.eof?
          dst.print(handle.read(blksize))
        end
        self
      end

      extend Forwardable
      def_instance_delegators(:handle,:binmode,:stat,:rewind,
                              :each,:each_byte,:each_line,:gets,:getc,
                              :read,:readlines,:readline,:sysread,
                              :<<,:print,:printf,:puts,:putc,:write,:syswrite,
                              :pos,:pos=,:lineno,
                              :fileno,
                              :close_read,:close_write,
                              :fsync,:sync,:sync=,:fcntl,:ioctl)
      def method_missing(sym,*args,&block)
        #p callstr('method_missing',sym,*args)
        handle.__send__(sym,*args,&block)
      end
      DEFAULT_BLKSIZE = 1024
      def _stream_blksize(*streams)
        sizes = []
        streams.each do |s|
          next unless s.kind_of?(::IO)
          next unless s.respond_to?(:stat)
          size = _stat_blksize(s.stat)
          sizes << size if size
        end
        sizes.min || DEFAULT_BLKSIZE
      end
      def _stat_blksize(st)
        s = st.blksize
        return nil unless s
        return nil if s == 0
        s
      end
    end
    class Dir < Base
      def close
        #p "#{callstr('close')} ios=#{@ios}"
        unless @ios.nil?
          @ios.close
          @ios = nil
        end
      end
      def closed?() @ios.nil? end
      extend Forwardable
      def_instance_delegators(:handle,
                              :each,:read,
                              :pos,:pos=,:tell,:seek,:rewind)
    end
  end
end
__END__