require 'open3'
module FaaStRuby
  module Command
    STDOUT_MUTEX = Mutex.new
    module Project
      require 'faastruby/cli/commands/project/base_command'
      require 'faastruby/server/logger'
      class Deploy < ProjectBaseCommand
        extend FaaStRuby::Logger
        def initialize(args)
          @errors = []
          @args = args
          help
          parse_options
          @options['functions'] += find_functions unless @options['functions'].any?
          @options['environment'] ||= 'stage'
          @project_yaml = YAML.load(File.read(PROJECT_YAML_FILE))['project'] rescue FaaStRuby::CLI.error("Could not find file 'project.yml'. Are you running this command from the project's folder?")
          @project_name = @project_yaml['name']
          @project_identifier = "-#{@project_yaml['identifier']}" if @project_yaml['identifier']
          @options['root_to'] ||= @project_yaml['root_to']
          @options['catch_all'] ||= @project_yaml['catch_all']
        end

        def puts(msg)
          STDOUT_MUTEX.synchronize do
            STDOUT.puts msg
          end
        end

        def run
          result = []
          errors = false
          root_folder = Dir.pwd
          jobs = []
          workspace = "#{@project_name}-#{@options['environment']}#{@project_identifier}"
          try_workspace(workspace)
          spinner = spin("Deploying project '#{@project_name}'...")
          @options['functions'].each do |function_path|
            jobs << Thread.new do
              # puts "[#{function_path}] Entering folder '#{function_path}'"
              # Dir.chdir function_path
              function_config = YAML.load(File.read("#{function_path}/faastruby.yml"))
              function_name = function_config['name']
              cmd = "cd #{function_path} && faastruby deploy-to #{workspace} --quiet"
              cmd += " --set-root" if @options['root_to'] == function_name
              cmd += " --set-catch-all" if @options['catch_all'] == function_name
              Open3.popen2(cmd) do |stdin, stdout, status_thread|
                stdout.each_line do |line|
                  puts line
                end
                FaaStRuby::CLI.error("* [#{function_path}] Deploy FAILED", color: nil) unless status_thread.value.success?
              end
            end
          end
          jobs.each{|thr| thr.join}
          spinner.stop(" Done!")
          puts "* Project URL: #{FaaStRuby.workspace_host_for(workspace)}\n\n".green
        end

        def try_workspace(workspace)
          try_to_create = Proc.new {system("faastruby create-workspace #{workspace} > /dev/null 2>&1")}
          has_credentials = system("faastruby list-workspace #{workspace} > /dev/null 2>&1")
          continue = has_credentials || try_to_create.call
          unless continue
            FaaStRuby::CLI.error("Unable to deploy project to workspace '#{workspace}'. Make sure you have the credentials, or try a different environment name.\nExample: faastruby deploy --deploy-env #{@options['environment']}-#{(rand * 100).to_i}")
          end
          true
        end

        def find_functions
          Dir.glob("**/faastruby.yml").map do |f|
            path = f.split('/')
            path.pop
            path.join('/')
          end
        end

        def self.help
          "deploy [ARGS]"
        end

        def usage
          puts "Usage: faastruby #{self.class.help}"
          puts %(
-f,--function FUNCTION_PATH    # Specify the path to the function directory in your local machine.
                               # This argument can be repeated many times for multiple functions. Example:
                               # -f path/to/function1 -f path/to/function2
-e,--env ENVIRONMENT           # ENVIRONMENT is added to the project name to compose the workspace name.
          )
        end

        def parse_options
          @options = {'functions' => []}
          while @args.any?
            option = @args.shift
            case option
            when '--root-to'
              @options['root_to'] = @args.shift
            when '--catch-all'
              @options['catch_all'] = @args.shift
            when '--function', '-f'
              @options['functions'] << @args.shift
            when '--env', '-e'
              @options['environment'] = @args.shift
            else
              FaaStRuby::CLI.error("Unknown argument: #{option}")
            end
          end
        end

      end
    end
  end
end