def deps do
  [
    {:lib_oss, "~> 0.2"}
  ]
end

defmodule MyApp.Oss do
  use LibOss, otp_app: :my_app
end

# config/config.exs
config :my_app, MyApp.Oss,
  endpoint: "oss-cn-beijing.aliyuncs.com",
  access_key_id: System.get_env("OSS_ACCESS_KEY_ID"),
  access_key_secret: System.get_env("OSS_ACCESS_KEY_SECRET")

# lib/my_app/application.ex
def start(_type, _args) do
  children = [
    MyApp.Oss
  ]
  
  Supervisor.start_link(children, strategy: :one_for_one)
end

# 上传文件
{:ok, content} = File.read("document.pdf")
MyApp.Oss.put_object("my-bucket", "docs/document.pdf", content)

# 下载文件
{:ok, content} = MyApp.Oss.get_object("my-bucket", "docs/document.pdf")

# 删除文件
MyApp.Oss.delete_object("my-bucket", "docs/document.pdf")

# 列出文件
{:ok, result} = MyApp.Oss.list_objects_v2("my-bucket", prefix: "docs/")

defmodule FileUploader do
  def upload_large_file(bucket, key, file_path) do
    with {:ok, upload_id} <- MyApp.Oss.initiate_multipart_upload(bucket, key),
         {:ok, parts} <- upload_parts(bucket, key, upload_id, file_path),
         :ok <- MyApp.Oss.complete_multipart_upload(bucket, key, upload_id, parts) do
      :ok
    else
      error ->
        MyApp.Oss.abort_multipart_upload(bucket, key, upload_id)
        error
    end
  end
  
  defp upload_parts(bucket, key, upload_id, file_path) do
    file_path
    |> File.stream!([], 5_242_880)  # 5MB chunks
    |> Stream.with_index(1)
    |> Task.async_stream(fn {chunk, part_number} ->
         MyApp.Oss.upload_part(bucket, key, upload_id, part_number, chunk)
       end, max_concurrency: 3)
    |> Enum.reduce_while({:ok, []}, fn
         {:ok, {:ok, etag}}, {:ok, acc} -> 
           {:cont, {:ok, [{part_number, etag} | acc]}}
         _, _ -> 
           {:halt, {:error, :upload_failed}}
       end)
  end
end

# 生成前端上传令牌
expire_time = System.system_time(:second) + 3600
conditions = [
  ["content-length-range", 0, 10485760],  # 10MB限制
  ["starts-with", "$key", "uploads/"]     # 路径限制
]

{:ok, token} = MyApp.Oss.get_token("my-bucket", expire_time, conditions)

# 返回给前端的数据
%{
  "OSSAccessKeyId" => token.access_key_id,
  "policy" => token.policy,
  "signature" => token.signature,
  "host" => "https://my-bucket.oss-cn-beijing.aliyuncs.com",
  "key" => "uploads/${filename}"
}

# 批量删除文件
files_to_delete = ["temp/file1.txt", "temp/file2.txt", "temp/file3.txt"]
MyApp.Oss.delete_multiple_objects("my-bucket", files_to_delete)

# 批量获取文件信息
files = ["doc1.txt", "doc2.txt", "doc3.txt"]
file_info = files
|> Task.async_stream(fn file ->
     MyApp.Oss.head_object("my-bucket", file)
   end, max_concurrency: 10)
|> Enum.map(fn {:ok, result} -> result end)

config :my_app, MyApp.Oss,
  # 必需配置
  endpoint: "oss-cn-beijing.aliyuncs.com",
  access_key_id: "your_access_key_id", 
  access_key_secret: "your_access_key_secret",
  
  # 可选配置
  timeout: 30_000,           # 请求超时时间
  pool_size: 10,             # 连接池大小
  debug: false               # 调试模式