Google Storage Objects API does not support file downloads. about elixir-google-api HOT 14 CLOSED

{:ok, %Tesla.Env{body: body}} = Objects.storage_objects_get(conn, "my-bucket", "my-file.txt", [alt: "media"], decode: false)
IO.inspect(body, label: "file content")

defmodule Utils.GCS do
  alias GoogleApi.Storage.V1.Connection
  import GoogleApi.Storage.V1.RequestBuilder

  def upload_file(bucket_id, bucket_path, file_path) do
    # Authenticate.
    conn = get_conn()

    # Make the API request.
    GoogleApi.Storage.V1.Api.Objects.storage_objects_insert_simple(
      conn,
      bucket_id,
      "multipart",
      %{name: bucket_path},
      file_path
    )
  end

  def download_file(bucket_id, bucket_path) do
    conn = get_conn()

    case storage_objects_get(conn, bucket_id, bucket_path, alt: :media) do
      %Tesla.Env{body: <<"No such object:", _rest::binary>>} -> {:error, :file_not_found}
      %Tesla.Env{body: body} -> {:ok, body}
    end
  end

  defp get_conn() do
    {:ok, token} = Goth.Token.for_scope("https://www.googleapis.com/auth/cloud-platform")
    GoogleApi.Storage.V1.Connection.new(token.token)
  end

  defp storage_objects_get(connection, bucket, object, opts \\ []) do
    optional_params = %{
      :alt => :query,
      :fields => :query,
      :key => :query,
      :oauth_token => :query,
      :prettyPrint => :query,
      :quotaUser => :query,
      :userIp => :query,
      :generation => :query,
      :ifGenerationMatch => :query,
      :ifGenerationNotMatch => :query,
      :ifMetagenerationMatch => :query,
      :ifMetagenerationNotMatch => :query,
      :projection => :query,
      :userProject => :query
    }

    %{}
    |> method(:get)
    |> url("/storage/v1/b/{bucket}/o/{object}", %{
      "bucket" => URI.encode_www_form(bucket),
      "object" => URI.encode_www_form(object)
    })
    |> add_optional_params(optional_params, opts)
    |> Enum.into([])
    |> (&Connection.request(connection, &1)).()
  end
end

defmodule Googly.Storage do
  def download_file(bucket, name) do
    url = "https://www.googleapis.com/download/storage/v1/b/#{bucket}/o/#{name}?alt=media"
    GoogleApi.Gax.Request.new()
    |> GoogleApi.Gax.Request.url(url)
    |> Googly.Storage.Client.execute()
  end
end

defmodule Googly.Storage.Client do
  alias GoogleApi.Storage.V1.{
    Connection,
  }

  def config(), do: Application.fetch_env!(:googly, Googly.Storage)

  def connection() do
    case Goth.Token.for_scope(config().scope) do
      {:ok, %{token: token}} -> Connection.new(token)
      err -> raise "Failed to acquire google storage token - #{inspect(err)}"
    end
  end

  def execute(req) do
    Connection.execute(connection(), req)
  end
end

defmodule Utils.GCS do
  alias GoogleApi.Gax.Request
  alias GoogleApi.Storage.V1.{Connection, Api}

  def upload_file(bucket_id, bucket_path, file_path) do
    conn = get_conn()
    Api.Objects.storage_objects_insert_simple(
      conn,
      bucket_id,
      "multipart",
      %{name: bucket_path},
      file_path
    )
  end

  def download_file(bucket_id, object_path) do
    conn = get_conn()
    case storage_objects_get(conn, bucket_id, object_path, alt: :media) do
      {:error, %Tesla.Env{body: <<"No such object:", _rest::binary>>}} -> {:error, :file_not_found}
      {:ok, %Tesla.Env{body: body}} -> {:ok, body}
    end
  end

  # For Authentication
  defp get_conn() do
    {:ok, token} = Goth.Token.for_scope("https://www.googleapis.com/auth/cloud-platform")
    Connection.new(token.token)
  end

  # Fetch the Object
  defp storage_objects_get(connection, bucket, object, opts \\ []) do
    optional_params = %{
      :alt => :query,
      :fields => :query,
      :key => :query,
      :oauth_token => :query,
      :prettyPrint => :query,
      :quotaUser => :query,
      :userIp => :query,
      :generation => :query,
      :ifGenerationMatch => :query,
      :ifGenerationNotMatch => :query,
      :ifMetagenerationMatch => :query,
      :ifMetagenerationNotMatch => :query,
      :projection => :query,
      :userProject => :query
    }

    request = Request.new()
    |> Request.method(:get)
    |> Request.url("/storage/v1/b/{bucket}/o/{object}", %{
      "bucket" => URI.encode_www_form(bucket),
      "object" => URI.encode_www_form(object)
    })
    |> Request.add_optional_params(optional_params, opts)

    connection
    |> Connection.execute(request)
  end
end