# encoding: UTF-8
#
# Copyright 2015 Shawn Neal <sneal@sneal.net>
#
# Licensed 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_relative 'command_executor'

module WinRM
  module FS
    module Core
      # Uploads the given source file to a temp file in 8k chunks
      class FileUploader
        def initialize(command_executor)
          @command_executor = command_executor
        end

        # Uploads the given file to the specified temp file as base64 encoded.
        #
        # @param [String] Path to the local source file on this machine
        # @param [String] Path to the file on the target machine
        # @return [Integer] Count of bytes uploaded
        def upload(local_file, remote_file)
          @command_executor.run_powershell(prepare_script(remote_file))
          do_upload(local_file, dos_path(remote_file))
        end

        private

        def do_upload(local_file, remote_file)
          bytes_copied = 0
          base64_array = base64_content(local_file)
          base64_array.each_slice(8000 - remote_file.size) do |chunk|
            @command_executor.run_cmd("echo #{chunk.join} >> \"#{remote_file}\"")
            bytes_copied += chunk.count
            yield bytes_copied, base64_array.count if block_given?
          end
          base64_array.length
        end

        def base64_content(local_file)
          base64_host_file = Base64.encode64(IO.binread(local_file)).gsub("\n", '')
          base64_host_file.chars.to_a
        end

        def dos_path(path)
          # TODO: convert all env vars
          path = path.gsub(/\$env:TEMP/, '%TEMP%')
          path.gsub(/\\/, '/')
        end

        # rubocop:disable Metrics/MethodLength
        def prepare_script(remote_file)
          <<-EOH
            $p = $ExecutionContext.SessionState.Path
            $path = $p.GetUnresolvedProviderPathFromPSPath("#{remote_file}")

            # if the file exists, truncate it
            if (Test-Path $path -PathType Leaf) {
              '' | Set-Content $path
            }

            # ensure the target directory exists
            $dir = [System.IO.Path]::GetDirectoryName($path)
            if (!(Test-Path $dir -PathType Container)) {
              mkdir $dir -ErrorAction SilentlyContinue | Out-Null
            }
          EOH
        end
        # rubocop:enable Metrics/MethodLength
      end
    end
  end
end