# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with this
# work for additional information regarding copyright ownership.  The ASF
# licenses this file to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the
# License for the specific language governing permissions and limitations under
# the License.


require File.expand_path(File.join(File.dirname(__FILE__), '..', 'spec_helpers'))

module CCHelper

  # monkey-patch task instance to track number of times it is run
  def instrument_task(task)
    class << task
      attr_accessor :run_count
    end
    task.run_count = 0
    task.enhance do |t|
      t.run_count += 1
    end
    task
  end

  def instrument_project(project)
    instrument_task project.compile
    instrument_task project.test.compile
    instrument_task project.resources
    project
  end

  def define_foo()
    @foo = define('foo')
    instrument_project @foo
    @foo
  end

  def foo()
    @foo
  end
end


describe Buildr::CCTask do
  include CCHelper

  it 'should default to a delay of 0.2' do
    define('foo').cc.delay.should == 0.2
  end

  it 'should compile and test:compile on initial start' do
    ['Test1.java', 'Test2.java'].map { |f| File.join('src/main/java/thepackage', f) }.
      each { |src| write src, "package thepackage; class #{src.pathmap('%n')} {}" }

    ['Test1.java', 'Test2.java'].map { |f| File.join('src/test/java/thepackage', f) }.
      each { |src| write src, "package thepackage; class #{src.pathmap('%n')} {}" }

    ['Test1.html', 'Test2.html'].map { |f| File.join('src/main/resources', f) }.
      each { |src| write src, '<html></html>' }

    define_foo()

    thread = Thread.new do
      foo.cc.invoke
    end

    wait_while { foo.test.compile.run_count != 1 }

    foo.compile.run_count.should == 1
    foo.test.compile.run_count.should == 1

    thread.exit
  end

  it 'should detect a file change' do |spec|
    write 'src/main/resources/my.properties', "# comment"
    write 'src/main/java/Example.java', "public class Example {}"
    write 'src/test/java/ExampleTest.java', "public class ExampleTest {}"

    define_foo

    thread = Thread.new do
      begin
        foo.cc.invoke
      rescue => e
        p "unexpected exception #{e.inspect}"
        p e.backtrace.join("\n")
      end
    end

    wait_while { foo.test.compile.run_count != 1 }

    foo.compile.run_count.should == 1
    foo.test.compile.run_count.should == 1
    foo.resources.run_count.should == 1

    modify_file_times(File.join(Dir.pwd, 'src/main/java/Example.java'))

    wait_while { foo.test.compile.run_count != 2 }

    foo.compile.run_count.should == 2
    foo.test.compile.run_count.should == 2
    foo.resources.run_count.should == 2

    thread.exit
  end

  # Not sure why this intermittently fails
  it 'should support subprojects', :retry => 3 do |spec|
    write 'foo/src/main/java/Example.java', "public class Example {}"
    write 'foo/src/test/java/ExampleTest.java', "public class ExampleTest {}"

    define 'container' do
      define('foo')
    end

    foo = instrument_project project("container:foo")

    thread = Thread.new do
      begin
        project("container").cc.invoke
      rescue => e
        p "unexpected exception #{e.inspect}"
        p e.backtrace.join("\n").inspect
      end
    end

    wait_while { foo.test.compile.run_count != 1 }

    foo.compile.run_count.should == 1
    foo.test.compile.run_count.should == 1
    foo.resources.run_count.should == 1

    file("foo/target/classes/Example.class").should exist

    tstamp = File.mtime("foo/target/classes/Example.class")

    modify_file_times(File.join(Dir.pwd, 'foo/src/main/java/Example.java'))
    wait_while { foo.test.compile.run_count != 2 }

    foo.compile.run_count.should == 2
    foo.test.compile.run_count.should == 2
    foo.resources.run_count.should == 2
    File.mtime("foo/target/classes/Example.class").should_not == tstamp

    thread.exit
  end

  def modify_file_times(filename)
    # Sleep prior to touch so works with filesystems with low resolutions
    t1 = File.mtime(filename)
    while t1 == File.mtime(filename)
      sleep 1
      touch filename
    end
  end

  def wait_while(&block)
    sleep_count = 0
    while block.call && sleep_count < 15
      sleep 1
      sleep_count += 1
    end
  end

  # Not sure why this intermittently fails
  it 'should support parent and subprojects', :retry => 3 do |spec|
    write 'foo/src/main/java/Example.java', "public class Example {}"
    write 'foo/src/test/java/ExampleTest.java', "public class ExampleTest {}"

    write 'bar/src/main/java/Example.java', "public class Example {}"
    write 'bar/src/test/java/ExampleTest.java', "public class ExampleTest {}"

    write 'src/main/java/Example.java', "public class Example {}"
    write 'src/test/java/ExampleTest.java', "public class ExampleTest {}"

    write 'src/main/resources/foo.txt', "content"

    define 'container' do
      define('foo')
      define('bar')
    end

    time = Time.now

    all = projects("container", "container:foo", "container:bar")
    all.each { |p| instrument_project(p) }

    thread = Thread.new do
      begin
        project("container").cc.invoke
      rescue => e
        p "unexpected exception #{e.inspect}"
        p e.backtrace.join("\n").inspect
      end
    end

    wait_while { all.any? { |p| p.test.compile.run_count != 1 } }

    all.each do |p|
      p.compile.run_count.should == 1
      p.test.compile.run_count.should == 1
      p.resources.run_count.should == 1
    end

    file("foo/target/classes/Example.class").should exist
    tstamp = File.mtime("foo/target/classes/Example.class")

    modify_file_times('foo/src/main/java/Example.java')
    wait_while { project("container:foo").test.compile.run_count != 2 }

    project("container:foo").tap do |p|
      p.compile.run_count.should == 2
      p.test.compile.run_count.should == 2
      p.resources.run_count.should == 2
    end

    wait_while { project("container").resources.run_count != 2 }

    project("container").tap do |p|
      p.compile.run_count.should == 1 # not_needed
      p.resources.run_count.should == 2
    end
    File.mtime("foo/target/classes/Example.class").should_not == tstamp

    modify_file_times('src/main/java/Example.java')

    wait_while { project("container").resources.run_count != 3 }

    project("container").tap do |p|
      p.compile.run_count.should == 2
      p.resources.run_count.should == 3
    end

    thread.exit
  end
end