# encoding: utf-8
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.

require_relative 'spec_helper'

include MsRestAzure
include Azure::ARM::Resources

describe 'Resources' do
  before(:each) do
    @resource_helper = ResourceHelper.new()
    @client = @resource_helper.resource_client.resources
    @resource_group = @resource_helper.create_resource_group
    @resource_type = 'sites'
    @resource_provider = 'Microsoft.Web'
    @resource_api_version = '2015-07-01'
    @resource_identity = 'Microsoft.Web/sites'
    @resource_name = 'testresource'
  end

  after(:each) do
    @resource_helper.delete_resource_group(@resource_group.name)
  end

  it 'should create resource' do
    params = build_resource_params(@resource_name)

    result = @client.create_or_update_async(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        @resource_name,
        @resource_api_version,
        params
    ).value!
    expect(result.response.status).to eq(200)
    expect(result.body).not_to be_nil
    expect(result.body.location).to eq(params.location)
    expect(result.body.type).to eq(@resource_identity)
  end

  it 'should get resource' do
    resource = create_resource

    result = @client.get_async(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        resource.name,
        @resource_api_version
    ).value!
    expect(result.body).not_to be_nil
    expect(result.body.name).to eq(resource.name)
    expect(result.body.type).to eq(@resource_identity)
  end

  it 'should raise an error when attempting to get resource without any parameters' do
    expect{@client.get(nil, nil, nil, nil, nil, nil)}.to raise_error(ArgumentError)
  end

  it 'should check existence of resource' do
    pending('Skip for now since this method isn\'t supported by server - HTTP 405 is returned')
    resource = create_resource

    result = @client.check_existence(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        resource.name,
        @resource_api_version
    ).value!
    expect(result.body).to be_truthy
  end

  it 'should raise an error when attempting invoke get, create_or_update, check_existence or delete without api version' do
    params = build_resource_params(@resource_name)

    expect{@client.create_or_update(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        @resource_name,
        nil,
        params)}.to raise_error(ArgumentError)

    expect{@client.get(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        @resource_name,
        nil
    )}.to raise_error(ArgumentError)

    expect{@client.check_existence(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        @resource_name,
        nil
    )}.to raise_error(ArgumentError)

    expect{@client.delete(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        @resource_name,
        nil
    )}.to raise_error(ArgumentError)
  end

  it 'should list resources' do
    result = @client.list_async.value!
    expect(result.body.value).not_to be_nil
    expect(result.body.value).to be_a(Array)

    while !result.body.next_link.nil? && !result.body.next_link.empty?  do
      result = @client.list_next(result.body.next_link).value!
      expect(result.body.value).not_to be_nil
      expect(result.body.value).to be_a(Array)
    end
  end

  it 'should filter resources and work with top parameter' do
    filter = "tagName eq 'tagName' and tagValue eq 'tagValue'"

    result = @client.list_async(filter, 1).value!
    expect(result.body.value).not_to be_nil
    expect(result.body.value).to be_a(Array)

    while !result.body.next_link.nil? && !result.body.next_link.empty?.empty? do
      result = @client.list_next(result.body.next_link).value!
      expect(result.body.value).not_to be_nil
      expect(result.body.value).to be_a(Array)
    end
  end

  it 'should move resources' do
    target_resource_group_name = 'RubySDKTest_azure_mgmt_resources1'
    params = Azure::ARM::Resources::Models::ResourceGroup.new()
    params.location = 'westus'

    target_rg = @resource_helper.resource_client.resource_groups.create_or_update_async(target_resource_group_name, params).value!.body
    resource = create_resource

    params = Models::ResourcesMoveInfo.new
    params.target_resource_group = target_rg.id
    params.resources = [resource.id]

    result = @client.move_resources_async(@resource_group.name, params).value!
    expect(result.response.status).to eq(204)

    wait_resource_move
    @resource_helper.delete_resource_group(target_resource_group_name)
  end

  it 'should delete resource' do
    resource = create_resource

    result = @client.delete_async(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        resource.name,
        @resource_api_version
    ).value!
    expect(result.response.status).to eq(200)
  end

  def create_resource
    @client.create_or_update_async(
        @resource_group.name,
        @resource_provider,
        '',
        @resource_type,
        @resource_name,
        @resource_api_version,
        build_resource_params(@resource_name)
    ).value!.body
  end

  def build_resource_params(name)
    params = Models::GenericResource.new()
    params.location = 'WestUS'
    params.properties = {
        'name' => name,
        'siteMode' => 'Limited',
        'computeMode' => 'Shared',
        'sku' => 'Free',
        'workerSize'=> 0
    }

    params
  end

  def wait_resource_move
    count = 30
    while @resource_helper.resource_client.resource_groups.get_async(@resource_group.name).value!.body.properties.provisioning_state == 'MovingResources'
      sleep(1)
      fail 'Waiting for resources to move took more than 30 requests. This seems broken' if count <= 0
      count -= 1
    end
  end
end