teagles / steam

require 'locomotive/common'

module Spec
  module Helpers

    def mongodb_site_id
      BSON::ObjectId.from_string('5943b49287f6430cadd748a3')
    end

    def reset!
      FileUtils.rm_rf(File.expand_path('../../../site', __FILE__))
    end

    def remove_logs
      FileUtils.rm_rf(File.expand_path('../../fixtures/default/log', __FILE__))
    end

    def setup_common(logger_output = nil)
      Locomotive::Common.reset
      Locomotive::Common.configure do |config|
        config.notifier = Locomotive::Common::Logger.setup(logger_output)
      end
    end

    def run_server
      require 'haml'

      output = ENV['STEAM_VERBOSE'] ? nil : File.join(default_fixture_site_path, 'log/steam.log')
      setup_common(output)

      Locomotive::Steam.configure do |config|
        config.mode           = :test
        config.adapter        = { name: :filesystem, path: default_fixture_site_path }
        # config.adapter        = { name: :'mongoDB', database: 'steam_test', hosts: ['127.0.0.1'] }
        config.asset_path     = File.expand_path(File.join(default_fixture_site_path, 'public'))
        config.serve_assets   = true
        config.minify_assets  = true
      end

      Locomotive::Common::Logger.info 'Server started...'
      Locomotive::Steam::Server.to_app
    end

    def default_fixture_site_path
      File.expand_path('../../fixtures/default/', __FILE__)
    end

    def env_for(url, opts={})
      Rack::MockRequest.env_for(url, opts)
    end

    def notification_payload_for(notification)
      payload = nil
      subscription = ActiveSupport::Notifications.subscribe(notification) do |name, start, finish, id, _payload|
        payload = _payload
      end

      yield

      ActiveSupport::Notifications.unsubscribe(subscription)

      return payload
    end

  end
end