mirror of
https://github.com/wahyd4/ruby-sdk.git
synced 2026-08-09 21:06:19 +10:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
69c5eadede | ||
|
|
9969818797 | ||
|
|
44dcf0b622 | ||
|
|
6bf653f116 | ||
|
|
1b0491a2c9 | ||
|
|
821d2363b3 | ||
|
|
e8fb64e7ec | ||
|
|
adb20cd815 | ||
|
|
fb9eb56bc0 | ||
|
|
813f57241d | ||
|
|
4a86397b3d | ||
|
|
fbea6bd019 | ||
|
|
ed6525a35e | ||
|
|
9d4316650d | ||
|
|
5713ad93e4 | ||
|
|
63a89b57ae | ||
|
|
65d71d12ae | ||
|
|
5332645665 | ||
|
|
946442f782 | ||
|
|
8e4805cf68 | ||
|
|
78147d76f8 | ||
|
|
2bb0514df4 | ||
|
|
0bca27457a | ||
|
|
b21833779e | ||
|
|
a64fb3a63e | ||
|
|
0d2f2f23dd | ||
|
|
d0b4fb7412 | ||
|
|
40bf2cfbbb | ||
|
|
4e80a5ec98 | ||
|
|
4fbfdbf472 | ||
|
|
d14fe23e45 | ||
|
|
3d0578cb88 | ||
|
|
09b8921d20 | ||
|
|
7d65b22e2e | ||
|
|
8b000c0a98 | ||
|
|
f93e50c838 | ||
|
|
b8f43a1ded | ||
|
|
804fa4d5b6 | ||
|
|
0f2466d4c2 | ||
|
|
93c3cb8dea | ||
|
|
3cccf69b61 | ||
|
|
b98cec1433 | ||
|
|
a29cfe5a71 | ||
|
|
a70b6f5313 |
+5
-2
@@ -5,5 +5,8 @@ rvm:
|
||||
- 2.1.1
|
||||
- jruby-19mode
|
||||
before_script:
|
||||
- export QINIU_ACCESS_KEY=LGRqJsjX7LAvtdtX6hhyxs861lS57HwnOQmJsOuX
|
||||
- export QINIU_SECRET_KEY=g_OxhuN5iJ1O7BoA6YdXyF6zSszk34UZFKDfdIIW
|
||||
- export QINIU_ACCESS_KEY=QWYn5TFQsLLU1pL5MFEmX3s5DmHdUThav9WyOWOm
|
||||
- export QINIU_SECRET_KEY=Bxckh6FA-Fbs9Yt3i3cbKVK22UPBmAOHJcL95pGz
|
||||
gemfile:
|
||||
- Gemfile
|
||||
- rails3/Gemfile
|
||||
|
||||
+23
-1
@@ -1,5 +1,27 @@
|
||||
## CHANGE LOG
|
||||
|
||||
### v6.5.0
|
||||
|
||||
- 为 Qiniu::Auth 添加一个异常处理逻辑,在 Access Key 和 Secret Key 未正常设置(nil 值)的情况下给出正确提示。[https://github.com/qiniu/ruby-sdk/pull/126](https://github.com/qiniu/ruby-sdk/pull/126)
|
||||
|
||||
### v6.4.2
|
||||
|
||||
- gem 兼容性调整 。 [https://github.com/qiniu/ruby-sdk/pull/122](https://github.com/qiniu/ruby-sdk/pull/122)
|
||||
|
||||
- 上传策略参数调整 。 [https://github.com/qiniu/ruby-sdk/pull/120](https://github.com/qiniu/ruby-sdk/pull/120)
|
||||
|
||||
### v6.4.1
|
||||
|
||||
- 将 mime-types 的依赖版本升级到 2.4.3 。 [https://github.com/qiniu/ruby-sdk/pull/113](https://github.com/qiniu/ruby-sdk/pull/113)
|
||||
|
||||
### v6.4.0
|
||||
|
||||
- 为 put_with_put_policy() 添加 opts 参数,允许使用 :content_type 键指定上传文件的 mime type。 [https://github.com/qiniu/ruby-sdk/pull/111](https://github.com/qiniu/ruby-sdk/pull/111)
|
||||
|
||||
### v6.3.2
|
||||
|
||||
- 调整上传host。 [https://github.com/qiniu/ruby-sdk/pull/103](https://github.com/qiniu/ruby-sdk/pull/103)
|
||||
|
||||
### v6.3.1
|
||||
|
||||
- 为过期方法添加说明。 [https://github.com/qiniu/ruby-sdk/pull/98](https://github.com/qiniu/ruby-sdk/pull/98)
|
||||
@@ -21,7 +43,7 @@
|
||||
### v6.2.2
|
||||
|
||||
- 为/pfop接口添加`pipeline`参数,用于指明使用哪个命名转码队列。 [https://github.com/qiniu/ruby-sdk/pull/92](https://github.com/qiniu/ruby-sdk/pull/92)
|
||||
- 为authorize_download_url()添加`:fop`参数,用于生成含数据处理指令的授权下载URL。
|
||||
- 为authorize_download_url()添加`:fop`参数,用于生成含数据处理指令的授权下载URL。
|
||||
|
||||
### v6.2.1
|
||||
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
source 'https://rubygems.org'
|
||||
|
||||
# Specify your gem's dependencies in qiniu-s3.gemspec
|
||||
gemspec
|
||||
# Specify your gem's dependencies in qiniu.gemspec
|
||||
gemspec :name => 'qiniu'
|
||||
|
||||
# platforms :jruby do
|
||||
# gem "jruby-openssl"
|
||||
|
||||
+24
-17
@@ -1,30 +1,37 @@
|
||||
PATH
|
||||
remote: .
|
||||
specs:
|
||||
qiniu (6.3.1)
|
||||
json (~> 1.7)
|
||||
qiniu (6.5.0)
|
||||
json (~> 1.8)
|
||||
mime-types (~> 1.19)
|
||||
rest-client (~> 1.6)
|
||||
rest-client (~> 1.7.3)
|
||||
ruby-hmac (~> 0.4)
|
||||
|
||||
GEM
|
||||
remote: https://rubygems.org/
|
||||
specs:
|
||||
diff-lcs (1.1.3)
|
||||
diff-lcs (1.2.5)
|
||||
fakeweb (1.3.0)
|
||||
json (1.8.1)
|
||||
mime-types (1.23)
|
||||
rake (10.0.3)
|
||||
rest-client (1.6.7)
|
||||
mime-types (>= 1.16)
|
||||
rspec (2.12.0)
|
||||
rspec-core (~> 2.12.0)
|
||||
rspec-expectations (~> 2.12.0)
|
||||
rspec-mocks (~> 2.12.0)
|
||||
rspec-core (2.12.2)
|
||||
rspec-expectations (2.12.1)
|
||||
diff-lcs (~> 1.1.3)
|
||||
rspec-mocks (2.12.2)
|
||||
json (1.8.2)
|
||||
mime-types (1.25.1)
|
||||
netrc (0.10.3)
|
||||
rake (10.4.2)
|
||||
rest-client (1.7.3)
|
||||
mime-types (>= 1.16, < 3.0)
|
||||
netrc (~> 0.7)
|
||||
rspec (3.2.0)
|
||||
rspec-core (~> 3.2.0)
|
||||
rspec-expectations (~> 3.2.0)
|
||||
rspec-mocks (~> 3.2.0)
|
||||
rspec-core (3.2.2)
|
||||
rspec-support (~> 3.2.0)
|
||||
rspec-expectations (3.2.0)
|
||||
diff-lcs (>= 1.2.0, < 2.0)
|
||||
rspec-support (~> 3.2.0)
|
||||
rspec-mocks (3.2.1)
|
||||
diff-lcs (>= 1.2.0, < 2.0)
|
||||
rspec-support (~> 3.2.0)
|
||||
rspec-support (3.2.2)
|
||||
ruby-hmac (0.4.0)
|
||||
|
||||
PLATFORMS
|
||||
|
||||
@@ -15,7 +15,7 @@
|
||||
|
||||
在您 Ruby 应用程序的 `Gemfile` 文件中,添加如下一行代码:
|
||||
|
||||
gem 'qiniu', '~> 6.3.1'
|
||||
gem 'qiniu', '~> 6.4.1'
|
||||
|
||||
然后,在应用程序所在的目录下,可以运行 `bundle` 安装依赖包:
|
||||
|
||||
|
||||
+1
-2
@@ -64,12 +64,11 @@ module Qiniu
|
||||
opts[:enable_resumable_upload] = true unless opts.has_key?(:enable_resumable_upload)
|
||||
|
||||
if opts[:enable_resumable_upload] && File::size(source_file) > Config.settings[:block_size]
|
||||
code, data, raw_headers = Storage.upload_with_token(opts[:uptoken],
|
||||
code, data, raw_headers = Storage.resumable_upload_with_token(opts[:uptoken],
|
||||
opts[:file],
|
||||
opts[:bucket],
|
||||
opts[:key],
|
||||
opts[:mime_type],
|
||||
opts[:note],
|
||||
opts[:customer],
|
||||
opts[:callback_params],
|
||||
opts[:rotate])
|
||||
|
||||
+18
-3
@@ -25,6 +25,18 @@ module Qiniu
|
||||
# 默认授权期1小时
|
||||
return Time.now.to_i + DEFAULT_AUTH_SECONDS
|
||||
end # calculate_deadline
|
||||
|
||||
def calculate_hmac_sha1_digest(sk, str)
|
||||
begin
|
||||
sign = HMAC::SHA1.new(sk).update(str).digest
|
||||
rescue RuntimeError => e
|
||||
raise RuntimeError, "Please set Qiniu's access_key and secret_key before authorize any tokens."
|
||||
rescue
|
||||
raise
|
||||
else
|
||||
return sign
|
||||
end
|
||||
end
|
||||
end # class << self
|
||||
|
||||
class PutPolicy
|
||||
@@ -49,7 +61,9 @@ module Qiniu
|
||||
:return_url => "returnUrl" ,
|
||||
:return_body => "returnBody" ,
|
||||
:callback_url => "callbackUrl" ,
|
||||
:callback_host => "callbackHost" ,
|
||||
:callback_body => "callbackBody" ,
|
||||
:callback_body_type => "callbackBodyType" ,
|
||||
:persistent_ops => "persistentOps" ,
|
||||
:persistent_notify_url => "persistentNotifyUrl" ,
|
||||
:persistent_pipeline => "persistentPipeline" ,
|
||||
@@ -58,6 +72,7 @@ module Qiniu
|
||||
:deadline => "deadline" ,
|
||||
:insert_only => "insertOnly" ,
|
||||
:fsize_limit => "fsizeLimit" ,
|
||||
:callback_fetch_key => "callbackFetchKey" ,
|
||||
:detect_mime => "detectMime" ,
|
||||
:mime_limit => "mimeLimit"
|
||||
} # PARAMS
|
||||
@@ -166,7 +181,7 @@ module Qiniu
|
||||
end
|
||||
|
||||
### 生成数字签名
|
||||
sign = HMAC::SHA1.new(secret_key).update(download_url).digest
|
||||
sign = calculate_hmac_sha1_digest(secret_key, download_url)
|
||||
encoded_sign = Utils.urlsafe_base64_encode(sign)
|
||||
|
||||
### 生成下载授权凭证
|
||||
@@ -216,7 +231,7 @@ module Qiniu
|
||||
end
|
||||
|
||||
### 生成数字签名
|
||||
sign = HMAC::SHA1.new(secret_key).update(signing_str).digest
|
||||
sign = calculate_hmac_sha1_digest(secret_key, signing_str)
|
||||
encoded_sign = Utils.urlsafe_base64_encode(sign)
|
||||
|
||||
### 生成管理授权凭证
|
||||
@@ -235,7 +250,7 @@ module Qiniu
|
||||
encoded_put_policy = Utils.urlsafe_base64_encode(put_policy.to_json)
|
||||
|
||||
### 生成数字签名
|
||||
sign = HMAC::SHA1.new(secret_key).update(encoded_put_policy).digest
|
||||
sign = calculate_hmac_sha1_digest(secret_key, encoded_put_policy)
|
||||
encoded_sign = Utils.urlsafe_base64_encode(sign)
|
||||
|
||||
### 生成上传授权凭证
|
||||
|
||||
+5
-3
@@ -20,7 +20,8 @@ module Qiniu
|
||||
:content_type => 'application/x-www-form-urlencoded',
|
||||
:auth_url => "https://acc.qbox.me/oauth2/token",
|
||||
:rs_host => "http://rs.qiniu.com",
|
||||
:up_host => "http://upload.qiniu.com",
|
||||
:rsf_host => "http://rsf.qbox.me",
|
||||
:up_host => "http://up.qiniu.com",
|
||||
:pub_host => "http://pu.qbox.me:10200",
|
||||
:eu_host => "http://eu.qbox.me",
|
||||
:access_key => "",
|
||||
@@ -33,13 +34,14 @@ module Qiniu
|
||||
:tmpdir => Dir.tmpdir + File::SEPARATOR + 'QiniuRuby'
|
||||
}
|
||||
|
||||
REQUIRED_OPTION_KEYS = [:access_key, :secret_key]
|
||||
REQUIRED_OPTION_KEYS = [:access_key, :secret_key, :up_host]
|
||||
|
||||
attr_reader :settings, :default_params
|
||||
|
||||
def load config_file
|
||||
if File.exist?(config_file)
|
||||
config_options = YAML.load_file(config_file)
|
||||
config_options.symbolize_keys!
|
||||
initialize_connect(config_options)
|
||||
else
|
||||
raise MissingConfError, config_file
|
||||
@@ -47,7 +49,7 @@ module Qiniu
|
||||
end
|
||||
|
||||
def initialize_connect options = {}
|
||||
@settings = DEFAULT_OPTIONS.merge(options)
|
||||
@settings = DEFAULT_OPTIONS.merge!(options)
|
||||
REQUIRED_OPTION_KEYS.each do |opt|
|
||||
raise MissingArgsError, [opt] unless @settings.has_key?(opt)
|
||||
end
|
||||
|
||||
+62
-24
@@ -1,10 +1,48 @@
|
||||
# -*- encoding: utf-8 -*-
|
||||
# vim: sw=2 ts=2
|
||||
|
||||
require 'qiniu/adt'
|
||||
require 'qiniu/http'
|
||||
|
||||
module Qiniu
|
||||
module Storage
|
||||
class ListPolicy
|
||||
include ADT::Policy
|
||||
|
||||
private
|
||||
def initialize(bucket,
|
||||
limit = 1000,
|
||||
prefix = '',
|
||||
delimiter = '')
|
||||
@bucket = bucket
|
||||
@limit = limit
|
||||
@prefix = prefix
|
||||
@delimiter = delimiter
|
||||
end # initialize
|
||||
|
||||
public
|
||||
PARAMS = {
|
||||
# 字符串类型参数
|
||||
:bucket => "bucket",
|
||||
:prefix => "prefix",
|
||||
:delimiter => "delimiter",
|
||||
:marker => "marker",
|
||||
|
||||
# 数值类型参数
|
||||
:limit => "limit"
|
||||
} # PARAMS
|
||||
|
||||
PARAMS.each_pair do |key, fld|
|
||||
attr_accessor key
|
||||
end
|
||||
|
||||
def params
|
||||
return PARAMS
|
||||
end # params
|
||||
|
||||
alias :to_s :to_query_string
|
||||
end # class ListPolicy
|
||||
|
||||
class << self
|
||||
include Utils
|
||||
|
||||
@@ -14,22 +52,6 @@ module Qiniu
|
||||
return HTTP.management_post(url)
|
||||
end # buckets
|
||||
|
||||
PRIVATE_BUCKET = 0
|
||||
PUBLIC_BUCKET = 1
|
||||
|
||||
def mkbucket(bucket_name, is_public = PUBLIC_BUCKET)
|
||||
url = Config.settings[:rs_host] + '/mkbucket2/' + bucket_name + '/public/' + is_public.to_s
|
||||
return HTTP.management_post(url)
|
||||
end # mkbucket
|
||||
|
||||
def make_a_private_bucket(bucket_name)
|
||||
return mkbucket(bucket_name, PRIVATE_BUCKET)
|
||||
end # make_a_private_bucket
|
||||
|
||||
def make_a_public_bucket(bucket_name)
|
||||
return mkbucket(bucket_name, PUBLIC_BUCKET)
|
||||
end # make_a_public_bucket
|
||||
|
||||
def stat(bucket, key)
|
||||
url = Config.settings[:rs_host] + '/stat/' + encode_entry_uri(bucket, key)
|
||||
return HTTP.management_post(url)
|
||||
@@ -60,11 +82,6 @@ module Qiniu
|
||||
return HTTP.management_post(url)
|
||||
end # delete
|
||||
|
||||
def drop(bucket)
|
||||
url = Config.settings[:rs_host] + "/drop/#{bucket}"
|
||||
return HTTP.management_post(url)
|
||||
end # drop
|
||||
|
||||
def batch(command, bucket, keys)
|
||||
execs = []
|
||||
keys.each do |key|
|
||||
@@ -107,6 +124,26 @@ module Qiniu
|
||||
save_as(bucket, key, source_image_url, mogrify_params_string)
|
||||
end # image_mogrify_save_as
|
||||
|
||||
def list(list_policy)
|
||||
url = Config.settings[:rsf_host] + '/list?' + list_policy.to_query_string()
|
||||
|
||||
resp_code, resp_body, resp_headers = HTTP.management_post(url)
|
||||
if resp_code == 0 || resp_code > 299 then
|
||||
has_more = false
|
||||
return resp_code, resp_body, resp_headers, has_more, list_policy
|
||||
end
|
||||
|
||||
has_more = (resp_body['marker'].is_a?(String) && resp_body['marker'] != '')
|
||||
if has_more then
|
||||
new_list_policy = list_policy.clone()
|
||||
new_list_policy.marker = resp_body['marker']
|
||||
else
|
||||
new_list_policy = list_policy
|
||||
end
|
||||
|
||||
return resp_code, resp_body, resp_headers, has_more, new_list_policy
|
||||
end # list
|
||||
|
||||
private
|
||||
|
||||
def _generate_cp_or_mv_opstr(command, source_bucket, source_key, target_bucket, target_key)
|
||||
@@ -117,12 +154,13 @@ module Qiniu
|
||||
|
||||
def _batch_cp_or_mv(command, *op_args)
|
||||
execs = []
|
||||
op_args.each do |e|
|
||||
op_args.each do |e|
|
||||
execs << 'op=' + _generate_cp_or_mv_opstr(command, e[0], e[1], e[2], e[3]) if e.size == 4
|
||||
end
|
||||
end
|
||||
url = Config.settings[:rs_host] + "/batch"
|
||||
return HTTP.management_post(url, execs.join("&"))
|
||||
end # _batch_cp_or_mv
|
||||
end
|
||||
|
||||
end # class << self
|
||||
end # module Storage
|
||||
end # module Qiniu
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
# -*- encoding: utf-8 -*-
|
||||
|
||||
require 'qiniu/http'
|
||||
|
||||
module Qiniu
|
||||
module Misc
|
||||
class << self
|
||||
|
||||
Executable → Regular
+13
-4
@@ -47,15 +47,23 @@ module Qiniu
|
||||
def upload_with_token_2(uptoken,
|
||||
local_file,
|
||||
key = nil,
|
||||
x_vars = nil)
|
||||
x_vars = nil,
|
||||
opts = {})
|
||||
### 构造URL
|
||||
url = Config.settings[:up_host]
|
||||
url[/\/*$/] = ''
|
||||
url += '/'
|
||||
|
||||
### 构造HTTP Body
|
||||
file = File.new(local_file, 'rb')
|
||||
if not opts[:content_type].nil?
|
||||
file.define_singleton_method("content_type") do
|
||||
opts[:content_type]
|
||||
end
|
||||
end
|
||||
|
||||
post_data = {
|
||||
:file => File.new(local_file, 'rb'),
|
||||
:file => file,
|
||||
:multipart => true,
|
||||
}
|
||||
if not uptoken.nil?
|
||||
@@ -84,13 +92,14 @@ module Qiniu
|
||||
def upload_with_put_policy(put_policy,
|
||||
local_file,
|
||||
key = nil,
|
||||
x_vars = nil)
|
||||
x_vars = nil,
|
||||
opts = {})
|
||||
uptoken = Auth.generate_uptoken(put_policy)
|
||||
if key.nil? then
|
||||
key = put_policy.key
|
||||
end
|
||||
|
||||
return upload_with_token_2(uptoken, local_file, key, x_vars)
|
||||
return upload_with_token_2(uptoken, local_file, key, x_vars, opts)
|
||||
end # upload_with_put_policy
|
||||
|
||||
private
|
||||
|
||||
@@ -3,8 +3,8 @@
|
||||
module Qiniu
|
||||
module Version
|
||||
MAJOR = 6
|
||||
MINOR = 3
|
||||
PATCH = 1
|
||||
MINOR = 5
|
||||
PATCH = 0
|
||||
# Returns a version string by joining <tt>MAJOR</tt>, <tt>MINOR</tt>, and <tt>PATCH</tt> with <tt>'.'</tt>
|
||||
#
|
||||
# Example
|
||||
|
||||
+3
-3
@@ -21,9 +21,9 @@ Gem::Specification.new do |gem|
|
||||
gem.add_development_dependency "rake", ">= 0.9"
|
||||
gem.add_development_dependency "rspec", ">= 2.11"
|
||||
gem.add_development_dependency "fakeweb", "~> 1.3"
|
||||
gem.add_runtime_dependency "json", "~> 1.7"
|
||||
gem.add_runtime_dependency "rest-client", "~> 1.6"
|
||||
gem.add_runtime_dependency "mime-types", "~> 1.19"
|
||||
gem.add_runtime_dependency "json", "~> 1.8"
|
||||
gem.add_runtime_dependency "rest-client", "~> 1.7.3"
|
||||
gem.add_runtime_dependency "mime-types", "~> 2.4.3"
|
||||
gem.add_runtime_dependency "ruby-hmac", "~> 0.4"
|
||||
gem.add_runtime_dependency "jruby-openssl", "~> 0.7" if RUBY_PLATFORM == "java"
|
||||
end
|
||||
|
||||
Executable
+4
@@ -0,0 +1,4 @@
|
||||
source 'https://rubygems.org'
|
||||
|
||||
# Specify your gem's dependencies in rails3/qiniu.gemspec
|
||||
gemspec :name => 'qiniu'
|
||||
Executable
+29
@@ -0,0 +1,29 @@
|
||||
# -*- encoding: utf-8 -*-
|
||||
|
||||
require File.expand_path('../../lib/qiniu/version', __FILE__)
|
||||
|
||||
Gem::Specification.new do |gem|
|
||||
gem.authors = ["why404","BluntBlade"]
|
||||
gem.email = ["sdk@qiniu.com"]
|
||||
gem.description = %q{Qiniu Resource (Cloud) Storage SDK for Ruby. See: http://developer.qiniu.com/docs/v6/sdk/ruby-sdk.html}
|
||||
gem.summary = %q{Qiniu Resource (Cloud) Storage SDK for Ruby}
|
||||
gem.homepage = "https://github.com/qiniu/ruby-sdk"
|
||||
|
||||
gem.files = `git ls-files`.split($\)
|
||||
gem.executables = gem.files.grep(%r{^bin/}).map{ |f| File.basename(f) }
|
||||
gem.test_files = gem.files.grep(%r{^(test|spec|features)/})
|
||||
gem.name = "qiniu"
|
||||
gem.require_paths = ["lib"]
|
||||
gem.version = Qiniu::Version.to_s
|
||||
gem.license = "MIT"
|
||||
|
||||
# specify any dependencies here; for example:
|
||||
gem.add_development_dependency "rake", ">= 0.9"
|
||||
gem.add_development_dependency "rspec", ">= 2.11"
|
||||
gem.add_development_dependency "fakeweb", "~> 1.3"
|
||||
gem.add_runtime_dependency "json", "~> 1.8"
|
||||
gem.add_runtime_dependency "rest-client", "~> 1.7.3"
|
||||
gem.add_runtime_dependency "mime-types", "~> 1.19"
|
||||
gem.add_runtime_dependency "ruby-hmac", "~> 0.4"
|
||||
gem.add_runtime_dependency "jruby-openssl", "~> 0.7" if RUBY_PLATFORM == "java"
|
||||
end
|
||||
+38
-11
@@ -7,20 +7,13 @@ require 'qiniu/storage'
|
||||
require 'digest/sha1'
|
||||
|
||||
module Qiniu
|
||||
module Auth
|
||||
module Auth
|
||||
describe Auth do
|
||||
|
||||
before :all do
|
||||
@bucket = 'RubySDK-Test-Private'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
|
||||
### 尝试创建Bucket
|
||||
result = Qiniu::Storage.make_a_private_bucket(@bucket)
|
||||
puts result.inspect
|
||||
@bucket = 'rubysdk'
|
||||
end
|
||||
|
||||
after :all do
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
### 测试私有资源下载
|
||||
@@ -75,7 +68,41 @@ module Qiniu
|
||||
puts data.inspect
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
end # module Storage
|
||||
end # module Auth
|
||||
|
||||
module Exception_Auth
|
||||
describe Exception_Auth, :not_set_ak_sk => true do
|
||||
### 测试未设置 ak/sk 的异常抛出情况
|
||||
context ".not_set_ak_sk" do
|
||||
it "should works" do
|
||||
puts Qiniu::Config.instance_variable_get("@settings").inspect
|
||||
|
||||
begin
|
||||
uptoken = Qiniu::Auth.generate_uptoken({})
|
||||
rescue => e
|
||||
e.message.should == "Please set Qiniu's access_key and secret_key before authorize any tokens."
|
||||
else
|
||||
fail "Not raise any exception."
|
||||
end
|
||||
|
||||
begin
|
||||
download_url = Qiniu::Auth.authorize_download_url("http://test.qiniudn.com/a_private_file")
|
||||
rescue => e
|
||||
e.message.should == "Please set Qiniu's access_key and secret_key before authorize any tokens."
|
||||
else
|
||||
fail "Not raise any exception."
|
||||
end
|
||||
|
||||
begin
|
||||
acctoken = Qiniu::Auth.generate_acctoken("http://rsf.qbox.me/list")
|
||||
rescue => e
|
||||
e.message.should == "Please set Qiniu's access_key and secret_key before authorize any tokens."
|
||||
else
|
||||
fail "Not raise any exception."
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end # module Exception_Auth
|
||||
end # module Qiniu
|
||||
|
||||
@@ -10,15 +10,7 @@ module Qiniu
|
||||
describe Fop do
|
||||
|
||||
before :all do
|
||||
|
||||
### 复用RubySDK-Test-Storage空间
|
||||
@bucket = 'RubySDK-Test-Storage'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
|
||||
### 尝试创建空间
|
||||
result = Qiniu.mkbucket(@bucket)
|
||||
puts result.inspect
|
||||
|
||||
@bucket = 'rubysdk'
|
||||
pic_fname = "image_logo_for_test.png"
|
||||
@key = make_unique_key_in_bucket(pic_fname)
|
||||
|
||||
@@ -57,7 +49,6 @@ module Qiniu
|
||||
end
|
||||
|
||||
after :all do
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
context ".info" do
|
||||
|
||||
@@ -12,12 +12,7 @@ module Qiniu
|
||||
describe Storage do
|
||||
|
||||
before :all do
|
||||
@bucket = 'RubySDK-Test-Management'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
|
||||
### 尝试创建Bucket
|
||||
result = Qiniu.mkbucket(@bucket)
|
||||
puts result.inspect
|
||||
@bucket = 'rubysdk'
|
||||
|
||||
@key = Digest::SHA1.hexdigest((Time.now.to_i+rand(100)).to_s)
|
||||
@key = make_unique_key_in_bucket(@key)
|
||||
@@ -26,7 +21,6 @@ module Qiniu
|
||||
end
|
||||
|
||||
after :all do
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
### 准备数据
|
||||
|
||||
@@ -10,16 +10,10 @@ module Qiniu
|
||||
describe Misc do
|
||||
|
||||
before :all do
|
||||
### 复用RubySDK-Test-Management空间
|
||||
@bucket = 'RubySDK-Test-Management'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
|
||||
result = Qiniu.mkbucket(@bucket)
|
||||
puts result.inspect
|
||||
@bucket = 'rubysdk'
|
||||
end
|
||||
|
||||
after :all do
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
context ".set_protected" do
|
||||
|
||||
+1
-10
@@ -12,15 +12,7 @@ module Qiniu
|
||||
describe Persistance do
|
||||
|
||||
before :all do
|
||||
### 复用RubySDK-Test-Storage空间
|
||||
@bucket = 'RubySDK-Test-Storage'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
|
||||
### 尝试创建空间
|
||||
code, data, headers = Qiniu::Storage.make_a_public_bucket(@bucket)
|
||||
puts code.inspect
|
||||
puts data.inspect
|
||||
puts headers.inspect
|
||||
@bucket = 'rubysdk'
|
||||
|
||||
pic_fname = "image_logo_for_test.png"
|
||||
@key = make_unique_key_in_bucket(pic_fname)
|
||||
@@ -44,7 +36,6 @@ module Qiniu
|
||||
end
|
||||
|
||||
after :all do
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
context ".pfop" do
|
||||
|
||||
+27
-45
@@ -9,15 +9,10 @@ module Qiniu
|
||||
describe Qiniu do
|
||||
|
||||
before :all do
|
||||
@bucket = 'RubySDK-Test'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
@bucket = 'rubysdk'
|
||||
|
||||
@test_image_bucket = @bucket
|
||||
|
||||
### 尝试创建Bucket
|
||||
result = Qiniu.mkbucket(@bucket)
|
||||
puts result.inspect
|
||||
|
||||
@key = Digest::SHA1.hexdigest Time.now.to_s
|
||||
@key = make_unique_key_in_bucket(@key)
|
||||
|
||||
@@ -34,13 +29,12 @@ module Qiniu
|
||||
end
|
||||
|
||||
after :all do
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
context ".buckets" do
|
||||
it "should works" do
|
||||
result = Qiniu.buckets
|
||||
result.should_not be_false
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -48,7 +42,7 @@ module Qiniu
|
||||
context ".set_protected" do
|
||||
it "should works" do
|
||||
result = Qiniu.set_protected(@bucket, 1)
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -56,7 +50,7 @@ module Qiniu
|
||||
context ".set_separator" do
|
||||
it "should works" do
|
||||
result = Qiniu.set_separator(@bucket, "-")
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -64,7 +58,7 @@ module Qiniu
|
||||
context ".set_style" do
|
||||
it "should works" do
|
||||
result = Qiniu.set_style(@bucket, "small.jpg", "imageMogr/auto-orient/thumbnail/!120x120r/gravity/center/crop/!120x120/quality/80")
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -72,7 +66,7 @@ module Qiniu
|
||||
context ".unset_style" do
|
||||
it "should works" do
|
||||
result = Qiniu.unset_style(@bucket, "small.jpg")
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -88,7 +82,7 @@ module Qiniu
|
||||
:enable_crc32_check => true
|
||||
}
|
||||
result = Qiniu.upload_file(upload_opts)
|
||||
result.should_not be_false
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
|
||||
@@ -138,24 +132,22 @@ module Qiniu
|
||||
File.unlink(localfile) if File.exists?(localfile)
|
||||
#expect
|
||||
puts result1.inspect
|
||||
result1.should_not be_false
|
||||
result1.should_not be_empty
|
||||
expect(result1).to_not be_empty
|
||||
#stat
|
||||
result2 = Qiniu.stat(@bucket, key)
|
||||
puts result2.inspect
|
||||
result2.should_not be_false
|
||||
expect(result2).to_not be_empty
|
||||
#delete
|
||||
result3 = Qiniu.delete(@bucket, key)
|
||||
puts result3.inspect
|
||||
result3.should_not be_false
|
||||
expect(result3).to eq(true)
|
||||
end
|
||||
end
|
||||
|
||||
context ".stat" do
|
||||
it "should works" do
|
||||
result = Qiniu.stat(@bucket, @key)
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -163,8 +155,7 @@ module Qiniu
|
||||
context ".get" do
|
||||
it "should works" do
|
||||
result = Qiniu.get(@bucket, @key, "qiniu_spec.rb", 10)
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -172,8 +163,7 @@ module Qiniu
|
||||
context ".download" do
|
||||
it "should works" do
|
||||
result = Qiniu.download(@bucket, @key, "rs_spec.rb", 10)
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -181,8 +171,7 @@ module Qiniu
|
||||
context ".batch" do
|
||||
it "should works" do
|
||||
result = Qiniu.batch("stat", @bucket, [@key])
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -190,8 +179,7 @@ module Qiniu
|
||||
context ".batch_stat" do
|
||||
it "should works" do
|
||||
result = Qiniu.batch_stat(@bucket, [@key])
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -199,8 +187,7 @@ module Qiniu
|
||||
context ".batch_get" do
|
||||
it "should works" do
|
||||
result = Qiniu.batch_get(@bucket, [@key])
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -208,8 +195,7 @@ module Qiniu
|
||||
context ".batch_download" do
|
||||
it "should works" do
|
||||
result = Qiniu.batch_download(@bucket, [@key])
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -242,42 +228,40 @@ module Qiniu
|
||||
context ".move" do
|
||||
it "should works" do
|
||||
result = Qiniu.move(@bucket, @key, @bucket, @key2)
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
|
||||
result2 = Qiniu.stat(@bucket, @key2)
|
||||
result2.should_not be_false
|
||||
expect(result2).to_not be_empty
|
||||
|
||||
result3 = Qiniu.move(@bucket, @key2, @bucket, @key)
|
||||
result3.should_not be_false
|
||||
expect(result3).to eq(true)
|
||||
end
|
||||
end
|
||||
|
||||
context ".copy" do
|
||||
it "should works" do
|
||||
result = Qiniu.copy(@bucket, @key, @bucket, @key2)
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
|
||||
result3 = Qiniu.delete(@bucket, @key2)
|
||||
result3.should_not be_false
|
||||
expect(result3).to eq(true)
|
||||
end
|
||||
end
|
||||
|
||||
context ".delete" do
|
||||
it "should works" do
|
||||
result = Qiniu.delete(@bucket, @key)
|
||||
result.should_not be_false
|
||||
expect(result).to eq(true)
|
||||
end
|
||||
end
|
||||
|
||||
context ".image_info" do
|
||||
it "should works" do
|
||||
data = Qiniu.get(@test_image_bucket, @test_image_key)
|
||||
data.should_not be_false
|
||||
data.should_not be_empty
|
||||
expect(data).to_not be_empty
|
||||
puts data.inspect
|
||||
result = Qiniu.image_info(data["url"])
|
||||
result.should_not be_false
|
||||
result.should_not be_empty
|
||||
expect(result).to_not be_empty
|
||||
puts result.inspect
|
||||
end
|
||||
end
|
||||
@@ -285,8 +269,7 @@ module Qiniu
|
||||
context ".image_mogrify_save_as" do
|
||||
it "should works" do
|
||||
data = Qiniu.get(@test_image_bucket, @test_image_key)
|
||||
data.should_not be_false
|
||||
data.should_not be_empty
|
||||
expect(data).to_not be_empty
|
||||
puts data.inspect
|
||||
|
||||
dest_key = "cropped-" + @test_image_key
|
||||
@@ -301,8 +284,7 @@ module Qiniu
|
||||
:auto_orient => true
|
||||
}
|
||||
result2 = Qiniu.image_mogrify_save_as(@test_image_bucket, dest_key, src_img_url, mogrify_options)
|
||||
result2.should_not be_false
|
||||
result2.should_not be_empty
|
||||
expect(result2).to_not be_empty
|
||||
puts result2.inspect
|
||||
end
|
||||
end
|
||||
|
||||
@@ -11,12 +11,7 @@ module Qiniu
|
||||
describe Storage do
|
||||
|
||||
before :all do
|
||||
@bucket = 'RubySDK-Test-Storage'
|
||||
@bucket = make_unique_bucket(@bucket)
|
||||
|
||||
### 尝试创建Bucket
|
||||
result = Qiniu.mkbucket(@bucket)
|
||||
puts result.inspect
|
||||
@bucket = 'rubysdk'
|
||||
|
||||
@key = Digest::SHA1.hexdigest((Time.now.to_i+rand(100)).to_s)
|
||||
@key = make_unique_key_in_bucket(@key)
|
||||
@@ -53,8 +48,6 @@ module Qiniu
|
||||
File.unlink(@localfile_4m) if File.exists?(@localfile_4m)
|
||||
File.unlink(@localfile_8m) if File.exists?(@localfile_8m)
|
||||
File.unlink(@localfile_1m) if File.exists?(@localfile_1m)
|
||||
|
||||
### 不删除Bucket以备下次使用
|
||||
end
|
||||
|
||||
### 测试单文件直传
|
||||
|
||||
@@ -26,8 +26,8 @@ module Qiniu
|
||||
context ".send_request_with" do
|
||||
it "should works" do
|
||||
FakeWeb.allow_net_connect = false
|
||||
FakeWeb.register_uri(:get, "http://docs.qiniutek.com/", :body => {:abc => 123}.to_json)
|
||||
res = Utils.send_request_with 'http://docs.qiniutek.com/', nil, :method => :get
|
||||
FakeWeb.register_uri(:get, "http://develoepr.qiniu.com/", :body => {:abc => 123}.to_json)
|
||||
res = Utils.send_request_with 'http://develoepr.qiniu.com/', nil, :method => :get
|
||||
res.should == [200, {"abc" => 123}, {}]
|
||||
end
|
||||
|
||||
@@ -35,9 +35,9 @@ module Qiniu
|
||||
context "upstream return http #{code}" do
|
||||
it "should raise RestClient::RequestFailed" do
|
||||
FakeWeb.allow_net_connect = false
|
||||
FakeWeb.register_uri(:get, "http://docs.qiniutek.com/", :status => code)
|
||||
FakeWeb.register_uri(:get, "http://develoepr.qiniu.com/", :status => code)
|
||||
lambda {
|
||||
res = Utils.send_request_with 'http://docs.qiniutek.com/', nil, :method => :get
|
||||
res = Utils.send_request_with 'http://develoepr.qiniu.com/', nil, :method => :get
|
||||
}.should raise_error RestClient::RequestFailed
|
||||
end
|
||||
end
|
||||
|
||||
@@ -8,6 +8,9 @@ RSpec.configure do |config|
|
||||
config.before :all do
|
||||
Qiniu.establish_connection! :access_key => ENV["QINIU_ACCESS_KEY"], :secret_key => ENV["QINIU_SECRET_KEY"]
|
||||
end
|
||||
config.before :each, :not_set_ak_sk => true do
|
||||
Qiniu.establish_connection! :access_key => nil, :secret_key => nil
|
||||
end
|
||||
end
|
||||
|
||||
def make_unique_bucket (bucket)
|
||||
|
||||
Reference in New Issue
Block a user