#--
# ===========================================================================
# Copyright (c) 2005-2017 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
# =========================================================================== 
#++
#


#require 'fileutils'

module RIO
  module IOH #:nodoc: all
    class Base
      attr_accessor :ios
      def initialize(ios,*args)
        @ios = ios
      end
      def initialize_copy(other)
        #p callstr('ioh:initialize_copy',other)
        super
        @ios = other.ios.clone unless other.ios.nil?
      end
      def callstr(func,*args)
        self.class.to_s+'['+self.to_s+']'+'.'+func.to_s+'('+args.join(',')+')'
      end
      def ior() ios end
      def iow() ios end
      def handle() ios end
       def open?() not closed? end
    end




    class Stream < Base
      #attr_reader :iostack
      attr_accessor :hindex
      def initialize(iosp,*args)
        super
      end
      def initialize_copy(*args)
        #p callstr('ioh_stream:initialize_copy',*args)
        super
      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() ios end
      def close()  handle.close unless self.closed? end
      def closed?() ios.nil? or ios.closed? end
      def eof?()  ios.nil? or ios.closed? or ios.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
      def puts(*args)
        handle.puts(*args)
      end
      def each_bytes(nb,&block)
        until handle.eof?
          break unless s = handle.read(nb)
          yield s
        end
        self
      end
      extend RIO::Fwd
      
      fwd_readers :handle,
                  :binmode,
                  :stat,
                  :rewind,
                  :each,
                  :each_byte,
                  :gets,
                  :getc,
                  :each_line,
                  :read,
                  :readlines,
                  :readline,
                  :sysread,
                  :print,
                  :printf,
                  :putc,
                  :write,
                  :syswrite,
                  :fileno,
                  :close_read,
                  :close_write,
                  :fsync,
                  :fcntl,
                  :ioctl,
                  :<<

      fwd :handle,
          :pos,
          :lineno,
          :sync
          
      def set_encoding(*args)
        handle.set_encoding(*args)
      end

      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
      def each(&block)
        while filename = handle.read
          yield filename
        end
      end

      extend RIO::Fwd
      fwd :handle, :pos
      fwd_readers :handle,
                  :read,
                  :tell,
                  :seek,
                  :rewind
    end
  end
end
__END__