# encoding: utf-8
require 'cloudfiles'

module CarrierWave
  module Storage

    ##
    # Uploads things to Rackspace Cloud Files webservices using the Rackspace libraries (cloudfiles gem). 
    # In order for CarrierWave to connect to Cloud Files, you'll need to specify an username, api key
    # and container
    #
    #     CarrierWave.configure do |config|
    #       config.cloud_files_username = "xxxxxx"
    #       config.cloud_files_api_key = "xxxxxx"
    #       config.cloud_files_container = "my_container"
    #     end
    #
    #
    # You can set the access policy for the uploaded files:
    #
    #     CarrierWave.configure do |config|
    #       config.s3_access_policy = 'public-read'
    #     end
    #
    #
    class CloudFiles < Abstract

      class File

        def initialize(uploader, base, path)
          @uploader = uploader
          @path = path
          @base = base
        end

        ##
        # Returns the current path/filename of the file on Cloud Files. 
        #
        # === Returns
        #
        # [String] A path
        #
        def path
          @path
        end

        ##
        # Reads the contents of the file from Cloud Files
        #
        # === Returns
        #
        # [String] contents of the file
        #
        def read
          object = cf_container.object(@path)
          @content_type = object.content_type
          object.data
        end

        ##
        # Remove the file from Cloud Files
        #
        def delete
          cf_container.delete_object(@path)
        end

        ##
        # Returns the url on the Cloud Files CDN.  Note that the parent container must be marked as
        # public for this to work.
        #
        # === Returns
        #
        # [String] file's url
        #
        def url
          cf_container.object(@path).public_url
        end

        #def metadata
        #  s3_object.metadata
        #end

        def content_type
          cf_container.object(@path).content_type
        end

        def content_type=(new_content_type)
          headers["content-type"] = new_content_type
        end

        ##
        # Writes the supplied data into the object on Cloud Files.
        #
        # === Returns
        #
        # boolean
        #
        def store(data,headers={})
          object = cf_container.create_object(@path)
          object.write(data,headers)
        end

        private

          def headers
            @headers ||= {  }
          end

          def container
            @uploader.cloud_files_container
          end

          def connection
            @base.connection
          end
          
          def cf_connection
            @cf_connection ||= ::CloudFiles::Connection.new(@uploader.cloud_files_username, @uploader.cloud_files_api_key)
          end

          def cf_container
            if @cf_container
              @cf_container
            else
              @cf_container = cf_connection.create_container(container)
              @cf_container.make_public
              @cf_container
            end
          end
          

      end

      ##
      # Store the file on Cloud Files
      #
      # === Parameters
      #
      # [file (CarrierWave::SanitizedFile)] the file to store
      #
      # === Returns
      #
      # [CarrierWave::Storage::RightS3::File] the stored file
      #
      def store!(file)
        cloud_files_options = {'Content-Type' => file.content_type}
        f = CarrierWave::Storage::CloudFiles::File.new(uploader, self, uploader.store_path)
        f.store(file.read,cloud_files_options)
        f
      end

      # Do something to retrieve the file
      #
      # @param [String] identifier uniquely identifies the file
      #
      # [identifier (String)] uniquely identifies the file
      #
      # === Returns
      #
      # [CarrierWave::Storage::RightS3::File] the stored file
      #
      def retrieve!(identifier)
        CarrierWave::Storage::CloudFiles::File.new(uploader, self, uploader.store_path(identifier))
      end


    end # CloudFiles
  end # Storage
end # CarrierWave