local moon = require('busted.moon')
local path = require('pl.path')
local dir = require('pl.dir')
local tablex = require('pl.tablex')
local pretty = require('pl.pretty')
local wrap_done = require('busted.done').new

-- globals
settimeout = nil

-- exported module table
local busted = {}
busted._COPYRIGHT   = "Copyright (c) 2013 Olivine Labs, LLC."
busted._DESCRIPTION = "A unit testing framework with a focus on being easy to use. http://www.olivinelabs.com/busted"
busted._VERSION     = "Busted 1.10.0"

-- set defaults
busted.defaultoutput = path.is_windows and "plain_terminal" or "utf_terminal"
busted.defaultpattern = '_spec'
busted.defaultlua = 'luajit'
busted.lpathprefix = "./src/?.lua;./src/?/?.lua;./src/?/init.lua"
busted.cpathprefix = path.is_windows and "./csrc/?.dll;./csrc/?/?.dll;" or "./csrc/?.so;./csrc/?/?.so;"
require('busted.languages.en')-- Load default language pack

-- platform detection
local system, sayer_pre, sayer_post
if pcall(require, 'ffi') then
  system = require('ffi').os
elseif path.is_windows then
  system = 'Windows'
else
  system = io.popen('uname -s'):read('*l')
end

if system == 'Linux' then
  sayer_pre = 'espeak -s 160 '
  sayer_post = ' > /dev/null 2>&1'
elseif system and system:match('^Windows') then
  sayer_pre = 'echo '
  sayer_post = ' | ptts'
else
  sayer_pre = 'say '
  sayer_post = ''
end
system = nil

local options = {}
local current_context
local test_is_async
local current_test_filename

-- report a test-process error as a failed test
local internal_error = function(description, err)
  local tag = ""

  if options.tags and #options.tags > 0 then
    -- tags specified; must insert a tag to make sure the error gets displayed
    tag = " #"..options.tags[1]
  end

  if not current_context then
    busted.reset()
  end

  busted.describe("Busted process errors occured" .. tag, function()
    busted.it(description .. tag, function()
      error(err)
    end)
  end)
end

-- returns current time in seconds
busted.gettime = os.clock
if pcall(require, "socket") then
  busted.gettime = package.loaded["socket"].gettime
end

local language = function(lang)
  if lang then
    busted.messages = require('busted.languages.'..lang)
    require('luassert.languages.'..lang)
  end
end

-- load the outputter as set in the options, revert to default if it fails
local getoutputter  -- define first to enable recursion
getoutputter = function(output, opath, default)
  local success, out, f
  if output:match(".lua$") then
    f = function()
      return loadfile(path.normpath(path.join(opath, output)))()
    end
  else
    f = function()
      return require('busted.output.'..output)()
    end
  end

  success, out = pcall(f)

  if not success then
    if not default then
      -- even default failed, so error out the hard way
      return error("Failed to open the busted default output; " .. tostring(output) .. ".\n"..out)
    else
      internal_error("Unable to open output module; requested option '--output=" .. tostring(output).."'.", out)
      -- retry with default outputter
      return getoutputter(default, opath)
    end
  end
  return out
end

-- acquire set of test files from the options specified
local gettestfiles = function(root_file, pattern)
  local filelist

  if path.isfile(root_file) then
    filelist = { root_file }
  elseif path.isdir(root_file) then
    local pattern = pattern ~= "" and pattern or busted.defaultpattern
    filelist = dir.getallfiles(root_file)

    filelist = tablex.filter(filelist, function(filename)
      return path.basename(filename):find(pattern)
    end)

    filelist = tablex.filter(filelist, function(filename)
      if path.is_windows then
        return not filename:find('%\\%.%w+.%w+')
      else
        return not filename:find('/%.%w+.%w+')
      end
    end)
  else
    filelist = {}
  end

  return filelist
end

local is_terra = function(fname)
  return fname:find(".t", #fname-2, true) and true or false
end

-- runs a testfile, loading its tests
local load_testfile = function(filename)
  current_test_filename = filename
  local old_TEST = _TEST
  _TEST = busted._VERSION

  local success, err = pcall(function() 
    local chunk,err
    if moon.is_moon(filename) then
      if moon.has_moon then
        chunk,err = moon.loadfile(filename)
      else
        chunk = function()
          busted.describe("Moon script not installed", function()
            busted.pending("File not tested because 'moonscript' isn't installed; "..tostring(filename))
          end)
        end
      end
    elseif is_terra(filename) then
      if terralib then
        chunk,err = terralib.loadfile(filename)
      else
        chunk = function()
          busted.describe("Not running tests under Terra", function()
            pending("File not tested because tests are not being run with 'terra'; "..tostring(filename))
          end)
        end
      end
    else
      chunk,err = loadfile(filename)
    end
    
    if not chunk then
      error(err,2)
    end
    chunk()
  end)

  if not success then
    internal_error("Failed executing testfile; " .. tostring(filename), err)
  end

  _TEST = old_TEST
end

local play_sound = function(failures)
  if busted.messages.failure_messages and #busted.messages.failure_messages > 0 and
    busted.messages.success_messages and #busted.messages.success_messages > 0 then

    math.randomseed(os.time())

    if failures and failures > 0 then
      io.popen(sayer_pre.."\""..busted.messages.failure_messages[math.random(1, #busted.messages.failure_messages)]:format(failures).."\""..sayer_post)
    else
      io.popen(sayer_pre.."\""..busted.messages.success_messages[math.random(1, #busted.messages.success_messages)].."\""..sayer_post)
    end
  end
end

local get_fname = function(short_src)
  return short_src:match('%"(.-)%"') -- matches first string within double quotes
end

--=============================
-- Test engine
--=============================

local suite = {
  tests = {},       -- list holding all tests
  done = {},        -- list (boolean) indicating test was completed (either succesful or failed)
  started = {},     -- list (boolean) indicating test was started
  test_index = 1,
  loop = require('busted.loop.default')
}

-- execute a list of steps (functions)
-- each step gets a callback parameter to commence to the next step
busted.step = function(...)
  local steps = { ... }
  if #steps == 1 and type(steps[1]) == 'table' then
    steps = steps[1]
  end

  local i = 0

  local do_next
  do_next = function()
    i = i + 1
    if steps[i] then 
      return steps[i](do_next) -- tail call to preserve stackspace
    end
  end

  do_next()
end

-- Required to use on async callbacks. So busted can catch any errors and mark test as failed
busted.async = function(f)
  test_is_async = true
  if not f then
    -- this allows async() to be called on its own to mark any test as async.
    return
  end
  local test = suite.tests[suite.test_index]

  local safef = function(...)
    local result = { suite.loop.pcall(f, ...) }

    if result[1] then
      return unpack(result, 2)
    else
      local err = result[2]
      if type(err) == "table" then
        err = pretty.write(err)
      end

      local stack_trace = debug.traceback("", 2)
      err, stack_trace = moon.rewrite_traceback(err, stack_trace)

      test.status.type = 'failure'
      test.status.trace = stack_trace
      test.status.err = err
-- TODO: line below tests 'test.done' to be function, but done may also be a table, callable. Yet no tests failed...      
      assert(type(test.done) == 'function', 'non-test step failed (before/after/etc.):\n'..err)
      test.done()
    end
  end

  return safef
end

local match_tags = function(testName)
  if #options.tags > 0 then

    for t = 1, #options.tags do
      if testName:find(options.tags[t]) then
        return true
      end
    end

    return false
  else
    -- default to true if no tags are set
    return true
  end
end

local match_excluded_tags = function(testName)
  if #options.excluded_tags > 0 then

    for t = 1, #options.excluded_tags do
      if testName:find(options.excluded_tags[t]) then
        return true
      end
    end

  end

  -- By default we return false so that Busted will not exclude a test
  -- unless explicitly told to do so.
  return false
end

-- wraps test callbacks (it, for_each, setup, etc.) to ensure that sync
-- tests also call the `done` callback to mark the test/step as complete
local syncwrapper = function(f)
  return function(done, ...)
    test_is_async = nil
    f(done, ...)
    if not test_is_async then
      -- async function wasn't called, so it is a sync test/function
      -- hence must call it ourselves
      done()
    end
  end
end

local next_test

next_test = function()
  if #suite.done == #suite.tests     then return end  -- suite is complete
  if suite.started[suite.test_index] then return end  -- current test already started
    
  suite.started[suite.test_index] = true

  local this_test = suite.tests[suite.test_index]
  this_test.index = suite.test_index
  

  assert(this_test, this_test.index..debug.traceback('', 1))

  local steps = {}

  local execute_test = function(do_next)
    local timer
    local finally_callback

    finally = function(f)
      finally_callback = f
    end

    local done = function()
      if timer then
        timer:stop()
        timer = nil
      end
      if this_test.done_trace then
        if this_test.status.err == nil then
          local stack_trace = debug.traceback("", 2)
          err, stack_trace = moon.rewrite_traceback(err, stack_trace)

          this_test.status.err = 'test already "done":"'..this_test.name..'"'
          this_test.status.err = this_test.status.err..'. First called from '..this_test.done_trace
          this_test.status.type = 'failure'
          this_test.status.trace = stack_trace
        end
        return
      end

      assert(this_test.index <= #suite.tests, 'invalid test index: '..this_test.index)

      suite.done[this_test.index] = true
      -- keep done trace for easier error location when called multiple times
      local done_trace = debug.traceback("", 2)
      local err, done_trace = moon.rewrite_traceback(nil, done_trace)

      this_test.done_trace = pretty.write(done_trace)

      if not options.defer_print then
        busted.output.currently_executing(this_test.status, options)
      end

      this_test.context:decrement_test_count()
      if finally_callback then
 	      finally_callback()
	      finally_callback = nil
      end
      do_next()
    end

    if suite.loop.create_timer then
--TODO: global `settimeout` is created for an `it()` test, but never deleted, so it remains in the global namespace
--TODO: timeouts should also be available for before/after/before_each/after_each      
      settimeout = function(timeout)
        if not timer then
          timer = suite.loop.create_timer(timeout,function()
            if not this_test.done_trace then
              this_test.status.type = 'failure'
              this_test.status.trace = ''
              this_test.status.err = 'test timeout elapsed ('..timeout..'s)'
              done()
            end
          end)
        end
      end
    else
      settimeout = nil
    end

    this_test.done = done

    local trace
    local ok, err = xpcall(
      function()
        this_test.f(wrap_done(done))
      end,
      function(err)
        trace = debug.traceback("", 2)
        return err
      end)
    if ok then
      -- test returned, set default timer if one hasn't been set already
      if settimeout and not timer and not this_test.done_trace then
--TODO: parametrize constant!
        settimeout(1.0)
      end
    else
      if type(err) == "table" then
        err = pretty.write(err)
      end

      -- remove all frames after the last frame found in the test file
      local lines = {}
      local j = 0
      local last_j = nil
      for line in trace:gmatch("[^\r\n]+") do
        j = j + 1
        lines[j] = line
        local fname, lineno = line:match('%s+([^:]+):(%d+):')
        if fname == current_test_filename then
          last_j = j
        end
      end
      trace = table.concat(lines, trace:match("[\r\n]+"), 1, last_j)

      err, trace = moon.rewrite_traceback(err, trace)

      this_test.status.type = 'failure'
      this_test.status.trace = trace
      this_test.status.err = err
      done()
    end
  end

  local check_before = function(context)
    if context.before then
      local execute_before = function(do_next)
        context.before(wrap_done(
          function()
            context.before = nil
            do_next()
          end))
      end

      table.insert(steps, execute_before)
    end
  end

  local parents = this_test.context.parents

  for p=1, #parents do
    check_before(parents[p])
  end

  check_before(this_test.context)

  for p=1, #parents do
    if parents[p].before_each then
      table.insert(steps, parents[p].before_each)
    end
  end

  if this_test.context.before_each then
    table.insert(steps, this_test.context.before_each)
  end

  table.insert(steps, execute_test)

  if this_test.context.after_each then
    table.insert(steps, this_test.context.after_each)
  end

  local post_test = function(do_next)
    local post_steps = {}

    local check_after = function(context)
      if context.after then
        if context:all_tests_done() then
          local execute_after = function(do_next)
            context.after(wrap_done(
              function()
                context.after = nil
                do_next()
              end))
          end

          table.insert(post_steps, execute_after)
        end
      end
    end

    for p=#parents, 1, -1 do
      if parents[p].after_each then
        table.insert(post_steps, parents[p].after_each)
      end
    end

    check_after(this_test.context)

    for p=#parents, 1, -1 do
      check_after(parents[p])
    end

    local forward = function(do_next)
      suite.test_index = suite.test_index + 1
      next_test()
      do_next()
    end

    table.insert(post_steps, forward)
    busted.step(post_steps)
  end

  table.insert(steps, post_test)
  busted.step(steps)
end

local create_context = function(desc)
  return {
    desc = desc,
    parents = {},
    test_count = 0,
    increment_test_count = function(self)
      self.test_count = self.test_count + 1
      for _, parent in ipairs(self.parents) do
        parent.test_count = parent.test_count + 1
      end
    end,

    decrement_test_count = function(self)
      self.test_count = self.test_count - 1
      for _, parent in ipairs(self.parents) do
        parent.test_count = parent.test_count - 1
      end
    end,

    all_tests_done = function(self)
      return self.test_count == 0
    end,

    add_parent = function(self, parent)
      table.insert(self.parents, parent)
      if parent.desc ~= "" then
        self.desc = parent.desc .. " / " .. self.desc
      end
    end
  }
end


busted.describe = function(desc, more)
  local context = create_context(desc)

  for _, parent in ipairs(current_context.parents) do
    context:add_parent(parent)
  end

  context:add_parent(current_context)

  local old_context = current_context

  current_context = context
  more()

  current_context = old_context
end

busted.setup = function(before_func)
  assert(type(before_func) == "function", "Expected function, got "..type(before_func))
  current_context.before = syncwrapper(before_func)
end

busted.before_each = function(before_func)
  assert(type(before_func) == "function", "Expected function, got "..type(before_func))
  current_context.before_each = syncwrapper(before_func)
end

busted.teardown = function(after_func)
  assert(type(after_func) == "function", "Expected function, got "..type(after_func))
  current_context.after = syncwrapper(after_func)
end

busted.after_each = function(after_func)
  assert(type(after_func) == "function", "Expected function, got "..type(after_func))
  current_context.after_each = syncwrapper(after_func)
end

local function buildInfo(debug_info)
  local info = {
    source = debug_info.source,
    short_src = debug_info.short_src,
    linedefined = debug_info.linedefined,
  }

  local fname = get_fname(info.short_src)

  if fname and moon.is_moon(fname) then
    info.linedefined = moon.rewrite_linenumber(fname, info.linedefined) or info.linedefined
  end

  return info
end

busted.pending = function(name)
  local test = {
    context = current_context,
    name = current_context.desc .. " / " .. name
  }

  if match_excluded_tags(test.name) then
    return
  end

  test.context:increment_test_count()

  local debug_info = debug.getinfo(2)
  test.f = syncwrapper(function() end)

  test.status = {
    description = test.name,
    type = 'pending',
    info = buildInfo(debug_info)
  }

  if match_tags(test.name) then
    table.insert(suite.tests, test)
  end
end

busted.it = function(name, test_func)
  assert(type(test_func) == "function", "Expected function, got "..type(test_func))

  local test = {
    context = current_context,
    name = current_context.desc .. " / " .. name
  }

  if match_excluded_tags(test.name) then
    return
  end

  test.context:increment_test_count()

  local debug_info = debug.getinfo(test_func)
  test.f = syncwrapper(test_func)

  test.status = {
    description = test.name,
    type = 'success',
    info = buildInfo(debug_info)
  }

  if match_tags(test.name) then
    table.insert(suite.tests, test)
  end
end

busted.reset = function()
  current_context = create_context('')

  suite = {
    tests = {},
    done = {},
    started = {},
    test_index = 1,
    loop = require('busted.loop.default')
  }

  busted.output = busted.output_reset
end

busted.setloop = function(loop)
  if type(loop) == 'string' then
     suite.loop = require('busted.loop.'..loop)
  else
     assert(loop.step)
     suite.loop = loop
  end
end

busted.run_internal_test = function(describe_tests)
  local suite_bak = suite
  local output_bak = busted.output
  local current_context_bak = current_context
  busted.reset()

  busted.output = require 'busted.output.stub'()
  suite = {
    tests = {},
    done = {},
    started = {},
    test_index = 1,
    loop = require('busted.loop.default')
  }

  if type(describe_tests) == 'function' then
     describe_tests()
  else
     load_testfile(describe_tests)
  end

  repeat
    next_test()
    suite.loop.step()
  until #suite.done == #suite.tests

  local statuses = {}

  for _, test in ipairs(suite.tests) do
    table.insert(statuses, test.status)
  end

  suite = suite_bak
  current_context = current_context_bak
  busted.output = output_bak

  return statuses
end

-- test runner
busted.run = function(got_options)
  options = got_options

  language(options.lang)
  busted.output = getoutputter(options.output, options.fpath, busted.defaultoutput)
  busted.output_reset = busted.output  -- store in case we need a reset
  -- if no filelist given, get them
  options.filelist = options.filelist or gettestfiles(options.root_file, options.pattern)
  -- load testfiles

  local ms = busted.gettime()

  local statuses = {}
  local failures = 0
  local suites = {}
  local tests = 0

  local function run_suite(s)
    local old_TEST = _TEST
    _TEST = busted._VERSION
    
    suite = s
    repeat
      next_test()
      suite.loop.step()
    until #suite.done == #suite.tests
    
    _TEST = old_TEST

    for _, test in ipairs(suite.tests) do
      table.insert(statuses, test.status)
      if test.status.type == 'failure' then
        failures = failures + 1
      end
    end
  end

  -- there's already a test! probably an error
  if #suite.tests > 0 then
    run_suite(suite)
  end

  for i, filename in ipairs(options.filelist) do
    busted.reset()
    load_testfile(filename)
    tests = tests + #suite.tests
    suites[i] = suite
  end

  if not options.defer_print then
    print(busted.output.header('global', tests))
  end

  for _, s in ipairs(suites) do
    run_suite(s)
  end

  --final run time
  ms = busted.gettime() - ms

  local status_string = busted.output.formatted_status(statuses, options, ms)

  if options.sound then
    play_sound(failures)
  end

  if tests == 0 then failures = 1 end -- no tests found, so exitcode should be non-zero
  return status_string, failures
end

return setmetatable(busted, {
  __call = function(self, ...)
    return busted.run(...)
  end
 })