require_relative 'base'
require_relative 'exceptions'

# @api documented
class GdsApi::AssetManager < GdsApi::Base
  # Creates an asset given a hash with one +file+ attribute
  #
  # Makes a +POST+ request to the asset manager api to create an asset.
  #
  # The asset must be provided as a +Hash+ with a single +file+ attribute that
  # behaves like a +File+ object. The +content-type+ that the asset manager will
  # subsequently serve will be based *only* on the file's extension (derived
  # from +#path+). If you supply a +content-type+ via, for example
  # +ActionDispatch::Http::UploadedFile+ or another multipart wrapper, it will
  # be ignored.
  #
  # @param asset [Hash] The attributes for the asset to send to the api. Must
  #   contain +file+, which behaves like a +File+. All other attributes will be
  #   ignored.
  # @return [GdsApi::Response] The wrapped http response from the api. Behaves
  #   both as a +Hash+ and an +OpenStruct+, and responds to the following:
  #     :id           the URL of the asset
  #     :name         the filename of the asset that will be served
  #     :content_type the content_type of the asset
  #     :file_url     the URL from which the asset will be served when it has
  #                   passed a virus scan
  #     :state        One of 'unscanned', 'clean', or 'infected'. Unless the state is
  #                   'clean' the asset at the :file_url will 404
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  #
  # @example Upload a file from disk
  #   response = asset_manager.create_asset(file: File.new('image.jpg', 'r'))
  #   response['id']           #=> "http://asset-manager.dev.gov.uk/assets/576bbc52759b74196b000012"
  #   response['content_type'] #=> "image/jpeg"
  # @example Upload a file from a Rails param, (typically a multipart wrapper)
  #    params[:file] #=> #<ActionDispatch::Http::UploadedFile:0x007fc60b43c5c8
  #                      # @content_type="application/foofle",
  #                      # @original_filename="cma_case_image.jpg",
  #                      # @tempfile="spec/support/images/cma_case_image.jpg">
  #
  #    # Though we sent a file with a +content_type+ of 'application/foofle',
  #    # this was ignored
  #    response = asset_manager.create_asset(file: params[:file])
  #    response['content_type'] #=> "image/jpeg"
  def create_asset(asset)
    post_multipart("#{base_url}/assets", asset: asset)
  end

  # Creates a Whitehall asset given a hash with +file+ & +legacy_url_path+
  # (required) and +legacy_etag+ & +legacy_last_modified+ (optional) attributes
  #
  # Makes a +POST+ request to the asset manager api to create a Whitehall asset.
  #
  # The asset must be provided as a +Hash+ with a +file+ attribute that behaves
  # like a +File+ object and a +legacy_url_path+ attribute. The +content-type+
  # that the asset manager will subsequently serve will be based *only* on the
  # file's extension (derived from +#path+). If you supply a +content-type+ via,
  # for example +ActionDispatch::Http::UploadedFile+ or another multipart
  # wrapper, it will be ignored.
  #
  # The +legacy_url_path+ attribute is used to specify the public URL path at
  # which the asset should be served by the Asset Manager. This differs from
  # `#create_asset` where Asset Manager itself determines the public URL path to
  # be used and returns that to the publishing app in the response. This
  # endpoint is intended to be an interim measure which will help us migrate
  # assets from Whitehall into Asset Manager without needing to change the URLs.
  # The end goal is for Asset Manager to determine the public URL path for all
  # assets including Whitehall assets. At that point this endpoint will become
  # redundant and should be removed.
  #
  # There may be restrictions on the format of the `legacy_url_path`. If the
  # supplied path is not valid, a `GdsApi::HTTPUnprocessableEntity` exception
  # will be raised.
  #
  # The optional +legacy_etag+ & +legacy_last_modified+ attributes allow the
  # client to specify the values that should be used in the `ETag` &
  # `Last-Modified` response headers when the asset is requested via its public
  # URL. They are only intended to be used for migrating existing Whitehall
  # assets to Asset Manager so that we can avoid wholesale cache invalidation.
  # New Whitehall assets should not specify values for these attributes; Asset
  # Manager will generate suitable values.
  #
  # Note: this endpoint should only be used by the Whitehall Admin app and not
  # by any other publishing apps.
  #
  # @param asset [Hash] The attributes for the asset to send to the api. Must
  #   contain +file+, which behaves like a +File+, and +legacy_url_path+, a
  #   +String+. May contain +legacy_etag+, a +String+, and
  #   +legacy_last_modified+, a +Time+ object. All other attributes will be
  #   ignored.
  #
  # @return [GdsApi::Response] The wrapped http response from the api. Behaves
  #   both as a +Hash+ and an +OpenStruct+, and responds to the following:
  #     :id           the URL of the asset
  #     :name         the filename of the asset that will be served
  #     :content_type the content_type of the asset
  #     :file_url     the URL from which the asset will be served when it has
  #                   passed a virus scan
  #     :state        One of 'unscanned', 'clean', or 'infected'. Unless the state is
  #                   'clean' the asset at the :file_url will redirect to a
  #                   placeholder
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  #
  # @example Upload a file from disk
  #   response = asset_manager.create_asset(
  #     file: File.new('image.jpg', 'r'),
  #     legacy_url_path: '/government/uploads/path/to/image.jpg'
  #   )
  #   response['id']           #=> "http://asset-manager.dev.gov.uk/assets/576bbc52759b74196b000012"
  #   response['content_type'] #=> "image/jpeg"
  # @example Upload a file from a Rails param, (typically a multipart wrapper)
  #    params[:file] #=> #<ActionDispatch::Http::UploadedFile:0x007fc60b43c5c8
  #                      # @content_type="application/foofle",
  #                      # @original_filename="cma_case_image.jpg",
  #                      # @tempfile="spec/support/images/cma_case_image.jpg">
  #
  #    # Though we sent a file with a +content_type+ of 'application/foofle',
  #    # this was ignored
  #    response = asset_manager.create_asset(
  #      file: params[:file]
  #      legacy_url_path: '/government/uploads/path/to/cma_case_image.jpg'
  #    )
  #    response['content_type'] #=> "image/jpeg"
  def create_whitehall_asset(asset)
    post_multipart("#{base_url}/whitehall_assets", asset: asset)
  end

  # Fetches a Whitehall asset given the legacy URL path
  #
  # @param legacy_url_path [String] The Whitehall asset identifier.
  # @return [GdsApi::Response] A response object containing the parsed JSON
  #   response. If the asset cannot be found, +GdsApi::HTTPNotFound+ will be
  #   raised.
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  def whitehall_asset(legacy_url_path)
    get_json("#{base_url}/whitehall_assets/#{Addressable::URI.encode(legacy_url_path)}")
  end

  # Updates an asset given a hash with one +file+ attribute
  #
  # Makes a +PUT+ request to the asset manager api to update an asset.
  #
  # The asset must be provided as a +Hash+ with a single +file+ attribute that
  # behaves like a +File+ object. The +content-type+ that the asset manager will
  # subsequently serve will be based *only* on the file's extension (derived
  # from +#path+). If you supply a +content-type+ via, for example
  # +ActionDispatch::Http::UploadedFile+ or another multipart wrapper, it will
  # be ignored.
  #
  # @param id [String] The asset identifier (a UUID).
  # @param asset [Hash] The attributes for the asset to send to the api. Must
  #   contain +file+, which behaves like a +File+. All other attributes will be
  #   ignored.
  # @return [GdsApi::Response] The wrapped http response from the api. Behaves
  #   both as a +Hash+ and an +OpenStruct+, and responds to the following:
  #     :id           the URL of the asset
  #     :name         the filename of the asset that will be served
  #     :content_type the content_type of the asset
  #     :file_url     the URL from which the asset will be served when it has
  #                   passed a virus scan
  #     :state        One of 'unscanned', 'clean', or 'infected'. Unless the state is
  #                   'clean' the asset at the :file_url will 404
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  # @example Update a file from disk
  #   uuid = '594602dd-75b3-4e6f-b5d1-cacf8c4d4164'
  #   asset_manager.update_asset(uuid, file: File.new('image.jpg', 'r'))
  def update_asset(id, asset)
    put_multipart("#{base_url}/assets/#{id}", asset: asset)
  end

  # Fetches an asset given the id
  #
  # @param id [String] The asset identifier (a UUID).
  # @return [GdsApi::Response, nil] A response object containing the parsed JSON response. If
  #   the asset cannot be found, +nil+ wil be returned.
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  def asset(id)
    get_json("#{base_url}/assets/#{id}")
  end

  # Deletes an asset given an id
  #
  # Makes a +DELETE+ request to the asset manager api to delete an asset.
  #
  # @param id [String] The asset identifier (a UUID).
  # @return [GdsApi::Response] The wrapped http response from the api. Behaves
  #   both as a +Hash+ and an +OpenStruct+, and responds to the following:
  #     :id           the URL of the asset
  #     :name         the filename of the asset that will be served
  #     :content_type the content_type of the asset
  #     :file_url     the URL from which the asset will be served when it has
  #                   passed a virus scan
  #     :state        One of 'unscanned', 'clean', or 'infected'. Unless the state is
  #                   'clean' the asset at the :file_url will 404
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  # @example Delete a file from disk
  #   uuid = '594602dd-75b3-4e6f-b5d1-cacf8c4d4164'
  #   asset_manager.delete_asset(uuid)
  def delete_asset(id)
    delete_json("#{base_url}/assets/#{id}")
  end

  # Restores an asset given an id
  #
  # Makes a +POST+ request to the asset manager api to restore an asset.
  #
  # @param id [String] The asset identifier (a UUID).
  # @return [GdsApi::Response] The wrapped http response from the api. Behaves
  #   both as a +Hash+ and an +OpenStruct+, and responds to the following:
  #     :id           the URL of the asset
  #     :name         the filename of the asset that will be served
  #     :content_type the content_type of the asset
  #     :file_url     the URL from which the asset will be served when it has
  #                   passed a virus scan
  #     :state        One of 'unscanned', 'clean', or 'infected'. Unless the state is
  #                   'clean' the asset at the :file_url will 404
  #
  # @raise [HTTPErrorResponse] if the request returns an error
  # @example Restore a deleted file
  #   uuid = '594602dd-75b3-4e6f-b5d1-cacf8c4d4164'
  #   asset_manager.restore_asset(uuid)
  def restore_asset(id)
    post_json("#{base_url}/assets/#{id}/restore")
  end

private

  def base_url
    endpoint
  end
end