Hash :
8c0d1730
Author :
Date :
2016-02-11T00:54:30
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177
defmodule ExOvh.Query.Openstack.Swift do
@moduledoc ~s"""
Helps to build queries for the openstack swift api.
The raw query can be passed into a client request.
## Example
```elixir
import ExOvh.Query.Openstack.Swift, only: [scope: 0]
account = ExOvh.Hubic.OpenstackApi.Cache.get_account()
client = ExOvh
scope = ExOvh.hubic_request(account_info(client), %{ openstack: : true })
```
"""
alias ExOvh.Hubic.OpenstackApi.Cache, as: HubicOpenstackCache
#############################
# CONTAINER RELATED REQUESTS
#############################
@doc ~s"""
GET /v1/{account}, Get account details and containers for given account
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
ExOvh.hubic_request(account_info(OpenCache.get_account(client)), %{ openstack: :true })
```
"""
@spec account_info(account :: String.t) :: [map]
def account_info(account), do: {:get, account, %{ "format" => "json" }}
@doc ~s"""
PUT /v1/{account}/{container}, Create a new container
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
ExOvh.hubic_request(create_container(OpenCache.get_account(client), "new_container"), %{ openstack: :true })
```
"""
@spec create_container(account :: String.t, container :: String.t)
:: ExOvh.Client.raw_query_t
def create_container(account, container), do: {:put, account <> "/" <> container, %{ "format" => "json" }}
@doc ~s"""
DELETE /v1/{account}/{container}, Delete a container
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
ExOvh.hubic_request(delete_container(OpenCache.get_account(client), "new_container"), %{ openstack: :true })
```
"""
@spec delete_container(account :: String.t, container :: String.t)
:: ExOvh.Client.raw_query_t
def delete_container(account, container), do: {:delete, account <> "/" <> container, %{ "format" => "json" }}
##########################
# OBJECT RELATED REQUESTS
##########################
@doc ~s"""
GET /v1/{account}/{container}, List objects in a container
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
ExOvh.hubic_request(get_objects(OpenCache.get_account(client), "default"), %{ openstack: :true })
```
"""
@spec get_objects(account :: String.t, container :: String.t)
:: ExOvh.Client.raw_query_t
def get_objects(account, container), do: {:get, account <> "/" <> container, %{ "format" => "json" }}
@doc ~s"""
GET /v1/{account}/{container}/{object}, Get/Download a specific object (file)
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
file = "server_file.txt"
container = "new_container"
ExOvh.hubic_request(get_object(OpenCache.get_account(client), container, file), %{ openstack: :true })
```
"""
@spec get_object(account :: String.t, container :: String.t, object :: String.t)
:: ExOvh.Client.raw_query_t
def get_object(account, container, object), do: {:get, account <> "/" <> container <> "/" <> object, :nil}
@doc """
PUT /v1/{account}/{container}/{object}, Create or replace an object (file)
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
account = OpenCache.get_account(client)
object_name = "client_file.txt"
client_object = Kernel.to_string(:code.priv_dir(:ex_ovh)) <> "/" <> object_name
container = "new_container"
server_object = String.replace(object_name, "client", "server")
ExOvh.hubic_request(create_object(account, container, client_object, server_object), %{ openstack: :true })
```
"""
@spec create_object(account :: String.t, container :: String.t, client_object :: String.t, server_object :: String.t)
:: ExOvh.Client.raw_query_t
def create_object(account, container, client_object, server_object) do
case File.read(client_object) do
{:ok, binary_object} ->
path = account <> "/" <> container <> "/" <> server_object
{:put, path, binary_object}
{:error, posix_error} ->
LoggingUtils.log_mod_func_line(__ENV__, :error)
LoggingUtils.log_return(posix_error, :error)
raise posix_error
end
end
@doc """
DELETE /v1/{account}/{container}/{object}, Delete an Object (Delete a file)
### Example usage
```elixir
import ExOvh.Query.Openstack.Swift
alias ExOvh.Hubic.OpenstackApi.Cache, as: OpenCache
client = ExOvh
account = OpenCache.get_account(client)
container = "new_container"
server_object = "server_file.txt"
ExOvh.hubic_request(delete_object(account, container, server_object), %{ openstack: :true })
"""
@spec delete_object(account :: String.t, container :: String.t, server_object :: String.t)
:: ExOvh.Client.raw_query_t
def delete_object(account, container, server_object) do
{:delete, account <> "/" <> container <> "/" <> server_object, :nil}
end
end