Rakefile

require_relative 'bot'
require 'logger'
require 'logstash-logger'

$stdout.sync = true

desc 'Process all the opened and closed issues'
task :process_issues do
  logging_exceptions('process-issues.log') do |logger|
    Fastlane::Bot.new(logger).start(process: :issues)
  end
end

desc 'Process all the opened and closed pull requests'
task :process_prs do
  logging_exceptions('process-prs.log') do |logger|
    Fastlane::Bot.new(logger).start(process: :prs)
  end
end

desc 'Post incoming regression issues on Slack'
task :find_regressions do
  logging_exceptions('find-regressions.log') do |logger|
    Fastlane::Bot.new(logger).start(process: :regressions)
  end
end

desc 'Post unreleased changes to Slack'
task :post_unreleased_changes do
  require 'open-uri'
  require 'json'
  require 'excon'

  logging_exceptions('post-unreleased-changes.log') do |logger|
    next unless Fastlane::Bot.should_send_trivial_slack_notification?
    url = "https://rubygems.org/api/v1/gems/fastlane.json"
    rubygems_data = JSON.parse(open(url).read)
    live_version = rubygems_data["version"]

    number_of_commits = 0
    published_date = nil
    commits = JSON.parse(open("https://api.github.com/repos/fastlane/fastlane/commits").read)
    commits.each do |current|
      if current["commit"]["message"].start_with?("Version bump")
        published_date = Time.parse(current["commit"]["author"]["date"])
        break
      end
      number_of_commits += 1
    end

    number_of_days = ((Time.now - published_date) / 60.0 / 60.0 / 24.0).round
    exit if number_of_commits == 0

    diff_url = "https://github.com/fastlane/fastlane/compare/#{live_version}...master"
    logger.info("Posting to slack that #{number_of_commits} commits are pending for release since #{number_of_days} days")
    days_str = number_of_days > 4 ? "*#{number_of_days} days*" : "#{number_of_days} days" # bold if more than 4 days
    post_body = {
      text: ":ship: Last release was #{days_str} ago, with <#{diff_url}|#{number_of_commits} commits> pending for release"
    }.to_json

    response = Excon.post(ENV['ACTION_CHANNEL_SLACK_WEB_HOOK_URL'], body: post_body, headers: { "Content-Type" => "application/json" })

    if response.status == 200
      logger.info("Successfully notified the Slack room about PRs that need attention")
    else
      logger.info("Failed to notify the Slack room about PRs that need attention")
    end
  end
end

def logging_exceptions(name)
  logger = create_logger(name)
  begin
    yield logger if block_given?
  rescue => ex
    logger.fatal(ex.to_s)
    logger.fatal(ex.backtrace.join("\n"))
    raise ex
  end
end

def create_logger(name)
  if ENV['FASTLANE_ISSUE_BOT_LOG_PATH']
    LogStashLogger.new(type: :file, path: File.join(ENV['FASTLANE_ISSUE_BOT_LOG_PATH'], name), sync: true)
  else
    Logger.new(STDOUT)
  end
end