# encoding: utf-8
$LOAD_PATH.unshift '../lib'

require 'th_mauve'
require 'mauve/datamapper'
require 'mauve/server'
require 'mauve/configuration'
require 'mauve/configuration_builder'
require 'mauve/configuration_builders'

class TcMauveDatabasePeculiarities < Mauve::UnitTest
  include Mauve

  def setup
    super
    setup_database
    @temp_db = "mauve_test.#{Array.new(10) { rand(36).to_s(36) }.join}"
  end

  def teardown
    teardown_database
    super
  end

  def test_encoding
    #
    # Don't test unless the DB URL has been set.
    #
    return unless @db_url

    config = <<EOF
server {
  database "#{@db_url}"
}
EOF

    Configuration.current = ConfigurationBuilder.parse(config)
    Server.instance.setup

    x = {}
    x['en'] = 'Please rush me my portable walrus polishing kit!'
    x['fi'] = 'Ole hyvä kiirehtiä minulle kannettavan mursu kiillotukseen pakki!'
    x['jp'] = '私に私のポータブルセイウチの研磨キットを急いでください！'

    %w(UTF-8 WINDOWS-1252 SJIS).each do |enc|
      x.each do |lang, str|
        assert_nothing_raised("Failed to use iconv to convert to #{enc}") do
          str = str.encode(enc, invalid: :replace, undef: :replace, replace: '?')
        end

        alert = Alert.new(
          alert_id: "#{lang}:#{enc}",
          source: 'test',
          subject: str
        )

        assert_nothing_raised("failed to insert #{enc}") { alert.save }
      end
    end
  end
end

class TcMauveDatabasePostgresPeculiarities < TcMauveDatabasePeculiarities
  def setup
    super

    if ENV['POSTGRES_URL']
      @db_url = ENV['POSTGRES_URL']
      @temp_db = nil
    else
      system("createdb #{@temp_db} --encoding UTF8")
      unless $?.success?
        msg = "Skipping postgres tests, as DB creation (#{@temp_db}) failed."
        @temp_db = nil
        omit(msg)
      end
      # @pg_conn = PGconn.open(:dbname => @temp_db)
      @db_url = "postgres:///#{@temp_db}"
    end
  end

  def teardown
    super
    (system("dropdb #{@temp_db}") || puts("Failed to drop #{@temp_db}")) if @temp_db
  end

  def test_reminders_only_go_once
    config = <<EOF
server {
  database "#{@db_url}"
  use_notification_buffer  false
}

notification_method("email") {
  debug!
  deliver_to_queue []
  disable_normal_delivery!
}

person ("test1") {
  email "test1@example.com"
  all { email }
  suppress_notifications_after( 1 => 1 )
}

alert_group("default") {
  notify("test1") {
    during{ true }
    every 1.minute
  }
}
EOF
    Configuration.current = ConfigurationBuilder.parse(config)
    notification_buffer = Configuration.current.notification_methods['email'].deliver_to_queue
    Server.instance.setup

    a = Alert.new(
      alert_id: 'test',
      source: 'test',
      subject: 'test'
    )

    assert(a.raise!, 'raise was not successful')
    assert(a.saved?)
    assert_equal(1, notification_buffer.length)
    notification_buffer.pop

    10.times do
      Timecop.freeze(Time.now + 1.minute)
      5.times do
        AlertChanged.all.each do |ac|
          assert(ac.poll)
        end
      end
      assert_equal(1, notification_buffer.length)
      notification_buffer.pop
    end
  end
end

class TcMauveDatabaseSqlite3Peculiarities < TcMauveDatabasePeculiarities
  def setup
    super
    # @pg_conn = PGconn.open(:dbname => @temp_db)
    @db_url = 'sqlite3::memory:'
  end

  #
  # This just makes sure our mixin has been added to the SqliteAdapter.
  #
  def test_has_mixin
    assert DataMapper::Adapters::SqliteAdapter.private_instance_methods.include?(:with_connection_old)
    assert DataMapper::Adapters::SqliteAdapter.public_instance_methods.include?(:synchronize)
  end
end