module Blobsterix

# File lib/blobsterix.rb, line 160
def self.allow_chunked_stream
  !!@allow_chunked_stream
end

# File lib/blobsterix.rb, line 164
def self.allow_chunked_stream=(obj)
  @allow_chunked_stream=obj
end

# File lib/blobsterix.rb, line 282
def self.at_exit(&proc)
  (@at_exit_callback||=[]).push(proc)
end

# File lib/blobsterix.rb, line 144
def self.cache
  @cache ||= Storage::Cache.new(cache_dir)
end

# File lib/blobsterix.rb, line 148
def self.cache=(obj)
  @cache = obj
end

# File lib/blobsterix.rb, line 201
def self.cache_checker
   @@cache_checker||=lambda{|blob_access, meta_data, last_accessed_at, created_at|
      false
   }
end

# File lib/blobsterix.rb, line 197
def self.cache_checker=(obj)
   @@cache_checker=obj
end

# File lib/blobsterix.rb, line 128
def self.cache_dir
  @cache_dir||=root.join("cache")
end

# File lib/blobsterix.rb, line 132
def self.cache_dir=(obj)
  @cache_dir=obj
end

# File lib/blobsterix.rb, line 231
def self.cache_fatal_error(blob_access)
  StatusInfo.cache_error+=1
  StatusInfo.cache_access+=1
  event("cache.fatal_error", :blob_access => blob_access)
end

# File lib/blobsterix.rb, line 237
def self.cache_hit(blob_access)
  StatusInfo.cache_hit+=1
  StatusInfo.cache_access+=1
  event("cache.hit",:blob_access => blob_access)
end

# File lib/blobsterix.rb, line 225
def self.cache_miss(blob_access)
  StatusInfo.cache_miss+=1
  StatusInfo.cache_access+=1
  event("cache.miss", :blob_access => blob_access)
end

# File lib/blobsterix.rb, line 140
def self.cache_original=(obj)
  @cache_original=obj
end

# File lib/blobsterix.rb, line 136
def self.cache_original?
  @cache_original||=false
end

# File lib/blobsterix.rb, line 181
def self.decrypt_trafo(blob_access,trafo_string,logger)
  @decrypt_trafo||=lambda{|b,t,l|t}
  if !trafo_string
    return @decrypt_trafo
  end
  @decrypt_trafo.call(blob_access, trafo_string, logger)
end

# File lib/blobsterix.rb, line 169
def self.decrypt_trafo=(obj)
  @decrypt_trafo=obj
end

# File lib/blobsterix.rb, line 221
def self.encryption_error(blob_access)
  event("encryption.error",:blob_access => blob_access)
end

# File lib/blobsterix.rb, line 217
def self.event(name,hash)
  storage_event_listener.call(name,hash)
end

# File lib/blobsterix.rb, line 108
def self.logger
  Thread.current[:in_fiber_logger] ||= BlobsterixLogger.new((@logger||Logger.new(STDOUT)),Logable.next_id)
end

# File lib/blobsterix.rb, line 104
def self.logger=(obj)
  @logger=obj
end

# File lib/blobsterix.rb, line 96
def self.root
  @root ||= Pathname.new(BLOBSTERIX_ROOT)
end

# File lib/blobsterix.rb, line 100
def self.root_gem
  @root_gem ||= Pathname.new(BLOBSTERIX_GEM_DIR)
end

# File lib/blobsterix.rb, line 286
def self.run_at_exit
  (@at_exit_callback||=[]).each do |proc|
    proc.call
  end
end

# File lib/blobsterix.rb, line 173
def self.secret_key_store
  @secret_key_store
end

# File lib/blobsterix.rb, line 177
def self.secret_key_store=(obj)
  @secret_key_store=obj
end

# File lib/blobsterix.rb, line 120
def self.storage
  @storage ||= Storage::FileSystem.new(storage_dir)
end

# File lib/blobsterix.rb, line 124
def self.storage=(obj)
  @storage = obj
end

# File lib/blobsterix.rb, line 255
def self.storage_delete(blob_access)
  event("storage.delete",:blob_access => blob_access)
end

# File lib/blobsterix.rb, line 112
def self.storage_dir
  @storage_dir||=root.join("contents")
end

# File lib/blobsterix.rb, line 116
def self.storage_dir=(obj)
  @storage_dir=obj
end

# File lib/blobsterix.rb, line 211
def self.storage_event_listener
  @storage_event_listener||=lambda{|target, hash|
    logger.info("#{target}: #{hash.inspect}")
  }
end

# File lib/blobsterix.rb, line 207
def self.storage_event_listener=(obj)
  @storage_event_listener=obj
end

# File lib/blobsterix.rb, line 243
def self.storage_read(blob_access)
  event("storage.read",:blob_access => blob_access)
end

# File lib/blobsterix.rb, line 247
def self.storage_read_fail(blob_access)
  event("storage.read_fail",:blob_access => blob_access)
end

# File lib/blobsterix.rb, line 251
def self.storage_write(blob_access)
  event("storage.write",:blob_access => blob_access)
end

# File lib/blobsterix.rb, line 189
def self.transformation
  @transformation ||= Blobsterix::Transformations::TransformationManager.new
end

# File lib/blobsterix.rb, line 193
def self.transformation=(obj)
  @transformation=obj
end

# File lib/blobsterix.rb, line 152
def self.use_x_send_file
  !!@use_x_send_file
end

# File lib/blobsterix.rb, line 156
def self.use_x_send_file=(obj)
  @use_x_send_file=obj
end

# File lib/blobsterix.rb, line 259
def self.wait_for(op = nil)
  fiber = Fiber.current
  EM.defer(Proc.new {
      begin
        op.call
      rescue Exception => e
        e
      end
    },
    Proc.new {|result|
          fiber.resume result
        })
   result = Fiber.yield
   raise result if result.is_a? Exception
   result
end

# File lib/blobsterix.rb, line 276
def self.wait_for_next(op = nil)
  EM.next_tick do
    wait_for(op)
  end
end