mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
Fixed #875: Loosen multi_json version.
This commit is contained in:
parent
b98f3a1ffe
commit
dcefc2d7de
133 changed files with 170 additions and 190 deletions
6
Rakefile
6
Rakefile
|
@ -189,11 +189,11 @@ task :changelog do
|
|||
changelog << ''
|
||||
|
||||
require 'multi_json'
|
||||
github_repo_data = MultiJson.load(Excon.get('http://github.com/api/v2/json/repos/show/fog/fog').body)
|
||||
github_repo_data = Fog::JSON.decode(Excon.get('http://github.com/api/v2/json/repos/show/fog/fog').body)
|
||||
data = github_repo_data['repository'].reject {|key, value| !['forks', 'open_issues', 'watchers'].include?(key)}
|
||||
github_collaborator_data = MultiJson.load(Excon.get('http://github.com/api/v2/json/repos/show/fog/fog/collaborators').body)
|
||||
github_collaborator_data = Fog::JSON.decode(Excon.get('http://github.com/api/v2/json/repos/show/fog/fog/collaborators').body)
|
||||
data['collaborators'] = github_collaborator_data['collaborators'].length
|
||||
rubygems_data = MultiJson.load(Excon.get('https://rubygems.org/api/v1/gems/fog.json').body)
|
||||
rubygems_data = Fog::JSON.decode(Excon.get('https://rubygems.org/api/v1/gems/fog.json').body)
|
||||
data['downloads'] = rubygems_data['downloads']
|
||||
stats = []
|
||||
for key in data.keys.sort
|
||||
|
|
4
bin/fog
4
bin/fog
|
@ -23,10 +23,8 @@ end
|
|||
|
||||
if ARGV.length > 1
|
||||
|
||||
require 'multi_json'
|
||||
|
||||
result = instance_eval(ARGV[1..-1].join(' '))
|
||||
puts(MultiJson.dump(result))
|
||||
puts(Fog::JSON.encode(result))
|
||||
|
||||
else
|
||||
|
||||
|
|
|
@ -44,7 +44,7 @@ Gem::Specification.new do |s|
|
|||
s.add_dependency('builder')
|
||||
s.add_dependency('excon', '~>0.13.0')
|
||||
s.add_dependency('formatador', '~>0.2.0')
|
||||
s.add_dependency('multi_json', '~>1.3')
|
||||
s.add_dependency('multi_json', '~>1.0')
|
||||
s.add_dependency('mime-types')
|
||||
s.add_dependency('net-scp', '~>1.0.4')
|
||||
s.add_dependency('net-ssh', '>=2.1.3')
|
||||
|
|
|
@ -66,7 +66,6 @@ module Fog
|
|||
|
||||
def initialize(options={})
|
||||
require 'fog/core/parser'
|
||||
require 'multi_json'
|
||||
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
|
|
|
@ -46,7 +46,6 @@ module Fog
|
|||
# * CloudFormation object with connection to AWS.
|
||||
def initialize(options={})
|
||||
require 'fog/core/parser'
|
||||
require 'multi_json'
|
||||
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
|
|
|
@ -70,8 +70,6 @@ module Fog
|
|||
# ==== Returns
|
||||
# * DynamoDB object with connection to aws
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
|
||||
if options[:aws_session_token]
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
|
@ -126,7 +124,7 @@ module Fog
|
|||
})
|
||||
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
|
||||
response
|
||||
|
|
|
@ -123,7 +123,6 @@ module Fog
|
|||
# * IAM object with connection to AWS.
|
||||
def initialize(options={})
|
||||
require 'fog/core/parser'
|
||||
require 'multi_json'
|
||||
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
|
|
|
@ -192,13 +192,12 @@ module Fog
|
|||
|
||||
def setup(credentials = {})
|
||||
requires :public_ip_address, :username
|
||||
require 'multi_json'
|
||||
require 'net/ssh'
|
||||
|
||||
commands = [
|
||||
%{mkdir .ssh},
|
||||
%{passwd -l #{username}},
|
||||
%{echo "#{MultiJson.dump(Fog::JSON.sanitize(attributes))}" >> ~/attributes.json}
|
||||
%{echo "#{Fog::JSON.encode(Fog::JSON.sanitize(attributes))}" >> ~/attributes.json}
|
||||
]
|
||||
if public_key
|
||||
commands << %{echo "#{public_key}" >> ~/.ssh/authorized_keys}
|
||||
|
|
|
@ -31,7 +31,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.BatchGetItem'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -19,7 +19,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.encode(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.BatchWriteItem'}
|
||||
)
|
||||
end
|
||||
|
|
|
@ -43,7 +43,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.CreateTable'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -33,7 +33,7 @@ module Fog
|
|||
}.merge(options)
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.DeleteItem'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -30,7 +30,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.DeleteTable'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -32,7 +32,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.DescribeTable'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -31,7 +31,7 @@ module Fog
|
|||
}.merge(options)
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.GetItem'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -17,7 +17,7 @@ module Fog
|
|||
# * 'TableNames'<~Array> - table names
|
||||
def list_tables(options = {})
|
||||
request(
|
||||
:body => MultiJson.dump(options),
|
||||
:body => Fog::JSON.encode(options),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.ListTables'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -30,7 +30,7 @@ module Fog
|
|||
}.merge(options)
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.PutItem'}
|
||||
)
|
||||
end
|
||||
|
|
|
@ -33,7 +33,7 @@ module Fog
|
|||
}.merge(options)
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.Query'}
|
||||
)
|
||||
end
|
||||
|
|
|
@ -33,7 +33,7 @@ module Fog
|
|||
}.merge(options)
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.Scan'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -38,7 +38,7 @@ module Fog
|
|||
}.merge(options)
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.UpdateItem'}
|
||||
)
|
||||
end
|
||||
|
|
|
@ -34,7 +34,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:headers => {'x-amz-target' => 'DynamoDB_20111205.UpdateTable'},
|
||||
:idempotent => true
|
||||
)
|
||||
|
|
|
@ -25,7 +25,7 @@ module Fog
|
|||
'Action' => 'PutGroupPolicy',
|
||||
'GroupName' => group_name,
|
||||
'PolicyName' => policy_name,
|
||||
'PolicyDocument' => MultiJson.dump(policy_document),
|
||||
'PolicyDocument' => Fog::JSON.encode(policy_document),
|
||||
:parser => Fog::Parsers::AWS::IAM::Basic.new
|
||||
)
|
||||
end
|
||||
|
|
|
@ -24,7 +24,7 @@ module Fog
|
|||
request(
|
||||
'Action' => 'PutUserPolicy',
|
||||
'PolicyName' => policy_name,
|
||||
'PolicyDocument' => MultiJson.dump(policy_document),
|
||||
'PolicyDocument' => Fog::JSON.encode(policy_document),
|
||||
'UserName' => user_name,
|
||||
:parser => Fog::Parsers::AWS::IAM::Basic.new
|
||||
)
|
||||
|
|
|
@ -27,7 +27,7 @@ module Fog
|
|||
:method => 'GET',
|
||||
:query => {'policy' => nil}
|
||||
})
|
||||
response.body = MultiJson.load(response.body) unless response.body.nil?
|
||||
response.body = Fog::JSON.decode(response.body) unless response.body.nil?
|
||||
end
|
||||
|
||||
end
|
||||
|
|
|
@ -27,7 +27,7 @@ module Fog
|
|||
|
||||
def post_object_hidden_fields(options = {})
|
||||
if options['policy']
|
||||
options['policy'] = Base64.encode64(MultiJson.dump(options['policy'])).gsub("\n", "")
|
||||
options['policy'] = Base64.encode64(Fog::JSON.encode(options['policy'])).gsub("\n", "")
|
||||
options['AWSAccessKeyId'] = @aws_access_key_id
|
||||
options['Signature'] = Base64.encode64(@hmac.sign(options['policy'])).gsub("\n", "")
|
||||
end
|
||||
|
|
|
@ -14,7 +14,7 @@ module Fog
|
|||
|
||||
def put_bucket_policy(bucket_name, policy)
|
||||
request({
|
||||
:body => MultiJson.dump(policy),
|
||||
:body => Fog::JSON.encode(policy),
|
||||
:expects => 204,
|
||||
:headers => {},
|
||||
:host => "#{bucket_name}.#{@host}",
|
||||
|
|
|
@ -9,7 +9,7 @@ module Fog
|
|||
request({
|
||||
'Action' => 'GetFederationToken',
|
||||
'Name' => name,
|
||||
'Policy' => MultiJson.dump(policy),
|
||||
'Policy' => Fog::JSON.encode(policy),
|
||||
'DurationSeconds' => duration,
|
||||
:idempotent => true,
|
||||
:parser => Fog::Parsers::AWS::STS::GetSessionToken.new
|
||||
|
|
|
@ -49,7 +49,6 @@ module Fog
|
|||
# ==== Returns
|
||||
# * SNS object with connection to AWS.
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
@connection_options = options[:connection_options] || {}
|
||||
|
|
|
@ -195,7 +195,6 @@ module Fog
|
|||
|
||||
def initialize(options={})
|
||||
require 'mime/types'
|
||||
require 'multi_json'
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
options[:region] ||= 'us-east-1'
|
||||
|
|
|
@ -66,7 +66,6 @@ module Fog
|
|||
# * STS object with connection to AWS.
|
||||
def initialize(options={})
|
||||
require 'fog/core/parser'
|
||||
require 'multi_json'
|
||||
|
||||
@aws_access_key_id = options[:aws_access_key_id]
|
||||
@aws_secret_access_key = options[:aws_secret_access_key]
|
||||
|
|
|
@ -62,7 +62,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@bluebox_api_key = options[:bluebox_api_key]
|
||||
@bluebox_customer_id = options[:bluebox_customer_id]
|
||||
@connection_options = options[:connection_options] || {}
|
||||
|
@ -94,7 +93,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -121,7 +121,7 @@ module Fog
|
|||
%{mkdir .ssh},
|
||||
%{echo "#{public_key}" >> ~/.ssh/authorized_keys},
|
||||
%{passwd -l #{username}},
|
||||
%{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json}
|
||||
%{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json}
|
||||
])
|
||||
rescue Errno::ECONNREFUSED
|
||||
sleep(1)
|
||||
|
|
|
@ -117,7 +117,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options)
|
||||
require 'multi_json'
|
||||
# Currently authentication and api endpoints are the same but may change
|
||||
@auth_url = options[:brightbox_auth_url] || Fog.credentials[:brightbox_auth_url] || API_URL
|
||||
@api_url = options[:brightbox_api_url] || Fog.credentials[:brightbox_api_url] || API_URL
|
||||
|
@ -134,7 +133,7 @@ module Fog
|
|||
:path => url,
|
||||
:expects => expected_responses
|
||||
}
|
||||
request_options[:body] = MultiJson.dump(options) unless options.nil?
|
||||
request_options[:body] = Fog::JSON.encode(options) unless options.nil?
|
||||
make_request(request_options)
|
||||
end
|
||||
|
||||
|
@ -147,7 +146,7 @@ module Fog
|
|||
auth_url = options[:brightbox_auth_url] || @auth_url
|
||||
|
||||
connection = Fog::Connection.new(auth_url)
|
||||
@authentication_body = MultiJson.dump({'client_id' => @brightbox_client_id, 'grant_type' => 'none'})
|
||||
@authentication_body = Fog::JSON.encode({'client_id' => @brightbox_client_id, 'grant_type' => 'none'})
|
||||
|
||||
response = connection.request({
|
||||
:path => "/token",
|
||||
|
@ -159,7 +158,7 @@ module Fog
|
|||
:method => 'POST',
|
||||
:body => @authentication_body
|
||||
})
|
||||
@oauth_token = MultiJson.load(response.body)["access_token"]
|
||||
@oauth_token = Fog::JSON.decode(response.body)["access_token"]
|
||||
return @oauth_token
|
||||
end
|
||||
|
||||
|
@ -172,7 +171,7 @@ module Fog
|
|||
response = authenticated_request(params)
|
||||
end
|
||||
unless response.body.empty?
|
||||
response = MultiJson.load(response.body)
|
||||
response = Fog::JSON.decode(response.body)
|
||||
end
|
||||
end
|
||||
|
||||
|
|
|
@ -9,7 +9,7 @@ module Fog
|
|||
:method => 'POST',
|
||||
:path => "/1.0/servers/#{identifier}/resize",
|
||||
:headers => {"Content-Type" => "application/json"},
|
||||
:body => MultiJson.dump(options)
|
||||
:body => Fog::JSON.encode(options)
|
||||
)
|
||||
end
|
||||
|
||||
|
|
|
@ -57,7 +57,6 @@ module Fog
|
|||
end
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@clodo_username = options[:clodo_username]
|
||||
end
|
||||
|
||||
|
@ -74,7 +73,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@clodo_api_key = options[:clodo_api_key]
|
||||
@clodo_username = options[:clodo_username]
|
||||
@clodo_auth_url = options[:clodo_auth_url]
|
||||
|
@ -119,7 +117,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -121,7 +121,7 @@ module Fog
|
|||
%{mkdir .ssh},
|
||||
%{echo "#{public_key}" >> ~/.ssh/authorized_keys},
|
||||
%{passwd -l #{username}},
|
||||
%{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json},
|
||||
])
|
||||
rescue Errno::ECONNREFUSED
|
||||
sleep(1)
|
||||
|
|
|
@ -30,7 +30,7 @@ module Fog
|
|||
data['server'].merge! options if options
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => [200, 202],
|
||||
:method => 'POST',
|
||||
:path => 'servers'
|
||||
|
|
|
@ -19,7 +19,7 @@ module Fog
|
|||
:expects => [204],
|
||||
:method => 'DELETE',
|
||||
:path => "servers/#{server_id}/ips",
|
||||
:body => MultiJson.dump(data)
|
||||
:body => Fog::JSON.encode(data)
|
||||
)
|
||||
end
|
||||
end
|
||||
|
|
|
@ -17,7 +17,7 @@ module Fog
|
|||
:expects => [204],
|
||||
:method => 'GET',
|
||||
:path => "servers/#{server_id}/ips/moveip",
|
||||
:body => MultiJson.dump({'ip'=>"#{ip}"})
|
||||
:body => Fog::JSON.encode({'ip'=>"#{ip}"})
|
||||
)
|
||||
end
|
||||
end
|
||||
|
|
|
@ -4,7 +4,7 @@ module Fog
|
|||
class Real
|
||||
def server_action(id, action)
|
||||
request(
|
||||
:body => MultiJson.dump(action),
|
||||
:body => Fog::JSON.encode(action),
|
||||
:expects => [204],
|
||||
:method => 'POST',
|
||||
:path => "servers/#{id}/action")
|
||||
|
|
|
@ -135,7 +135,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@cloudstack_api_key = options[:cloudstack_api_key]
|
||||
@cloudstack_secret_access_key = options[:cloudstack_secret_access_key]
|
||||
@cloudstack_session_id = options[:cloudstack_session_id]
|
||||
|
@ -165,7 +164,7 @@ module Fog
|
|||
sessionid = cookies['JSESSIONID'].first
|
||||
|
||||
# Decode the login response
|
||||
response = MultiJson.load(response.body)
|
||||
response = Fog::JSON.decode(response.body)
|
||||
|
||||
user = response['loginresponse']
|
||||
user.merge!('sessionid' => sessionid)
|
||||
|
@ -188,7 +187,7 @@ module Fog
|
|||
end
|
||||
|
||||
response = issue_request(params,headers)
|
||||
response = MultiJson.load(response.body) unless response.body.empty?
|
||||
response = Fog::JSON.decode(response.body) unless response.body.empty?
|
||||
response
|
||||
end
|
||||
|
||||
|
@ -232,7 +231,7 @@ module Fog
|
|||
})
|
||||
|
||||
rescue Excon::Errors::HTTPStatusError => error
|
||||
error_response = MultiJson.load(error.response.body)
|
||||
error_response = Fog::JSON.decode(error.response.body)
|
||||
|
||||
error_code = error_response.values.first['errorcode']
|
||||
error_text = error_response.values.first['errortext']
|
||||
|
|
|
@ -121,8 +121,7 @@ module Fog
|
|||
end
|
||||
|
||||
def to_json(options = {})
|
||||
require 'multi_json'
|
||||
MultiJson.dump(self.map {|member| member.attributes})
|
||||
Fog::JSON.encode(self.map {|member| member.attributes})
|
||||
end
|
||||
|
||||
private
|
||||
|
|
|
@ -1,3 +1,5 @@
|
|||
require 'multi_json'
|
||||
|
||||
module Fog
|
||||
module JSON
|
||||
|
||||
|
@ -16,5 +18,29 @@ module Fog
|
|||
end
|
||||
end
|
||||
|
||||
# Do the MultiJson introspection at this level so we can define our encode/decode methods and perform
|
||||
# the introspection only once rather than once per call.
|
||||
|
||||
if MultiJson.respond_to?(:dump)
|
||||
def self.encode(obj)
|
||||
MultiJson.encode(obj)
|
||||
end
|
||||
else
|
||||
def self.encode(obj)
|
||||
MultiJson.encode(obj)
|
||||
end
|
||||
end
|
||||
|
||||
if MultiJson.respond_to?(:load)
|
||||
def self.decode(obj)
|
||||
Fog::JSON.decode(obj)
|
||||
end
|
||||
else
|
||||
def self.decode(obj)
|
||||
MultiJson.decode(obj)
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
end
|
||||
end
|
|
@ -38,8 +38,7 @@ module Fog
|
|||
end
|
||||
|
||||
def to_json(options = {})
|
||||
require 'multi_json'
|
||||
MultiJson.dump(attributes)
|
||||
Fog::JSON.encode(attributes)
|
||||
end
|
||||
|
||||
def symbolize_keys(hash)
|
||||
|
|
|
@ -55,8 +55,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
|
||||
@dnsimple_email = options[:dnsimple_email]
|
||||
@dnsimple_password = options[:dnsimple_password]
|
||||
@connection_options = options[:connection_options] || {}
|
||||
|
@ -87,7 +85,7 @@ module Fog
|
|||
response = @connection.request(params.merge!({:host => @host}))
|
||||
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -14,7 +14,7 @@ module Fog
|
|||
def create_domain(name)
|
||||
body = { "domain" => { "name" => name } }
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:expects => 201,
|
||||
:method => 'POST',
|
||||
:path => '/domains'
|
||||
|
|
|
@ -36,7 +36,7 @@ module Fog
|
|||
|
||||
body["record"].merge!(options)
|
||||
|
||||
request( :body => MultiJson.dump(body),
|
||||
request( :body => Fog::JSON.encode(body),
|
||||
:expects => 201,
|
||||
:method => 'POST',
|
||||
:path => "/domains/#{domain}/records" )
|
||||
|
|
|
@ -30,7 +30,7 @@ module Fog
|
|||
|
||||
body = { "record" => options }
|
||||
|
||||
request( :body => MultiJson.dump(body),
|
||||
request( :body => Fog::JSON.encode(body),
|
||||
:expects => 200,
|
||||
:method => "PUT",
|
||||
:path => "/domains/#{domain}/records/#{record_id}" )
|
||||
|
|
|
@ -80,7 +80,6 @@ module Fog
|
|||
# * dns object with connection to aws.
|
||||
def initialize(options={})
|
||||
require 'fog/core/parser'
|
||||
require 'multi_json'
|
||||
|
||||
@dnsmadeeasy_api_key = options[:dnsmadeeasy_api_key]
|
||||
@dnsmadeeasy_secret_key = options[:dnsmadeeasy_secret_key]
|
||||
|
@ -119,7 +118,7 @@ module Fog
|
|||
end
|
||||
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
|
||||
response
|
||||
|
|
|
@ -52,7 +52,7 @@ module Fog
|
|||
:expects => 201,
|
||||
:method => "POST",
|
||||
:path => "/V1.2/domains/#{domain}/records",
|
||||
:body => MultiJson.dump(body)
|
||||
:body => Fog::JSON.encode(body)
|
||||
)
|
||||
end
|
||||
|
||||
|
|
|
@ -26,7 +26,7 @@ module Fog
|
|||
:expects => 201,
|
||||
:method => 'PUT',
|
||||
:path => "/V1.2/secondary/#{secondary_name}",
|
||||
:body => MultiJson.dump(body)
|
||||
:body => Fog::JSON.encode(body)
|
||||
)
|
||||
end
|
||||
|
||||
|
|
|
@ -46,7 +46,7 @@ module Fog
|
|||
:expects => 200,
|
||||
:method => "PUT",
|
||||
:path => "/V1.2/domains/#{domain}/records/#{record_id}",
|
||||
:body => MultiJson.dump(options)
|
||||
:body => Fog::JSON.encode(options)
|
||||
)
|
||||
end
|
||||
|
||||
|
|
|
@ -26,7 +26,7 @@ module Fog
|
|||
:expects => 201,
|
||||
:method => 'PUT',
|
||||
:path => "/V1.2/secondary/#{secondary_name}",
|
||||
:body => MultiJson.dump(body)
|
||||
:body => Fog::JSON.encode(body)
|
||||
)
|
||||
end
|
||||
|
||||
|
|
|
@ -60,8 +60,6 @@ module Fog
|
|||
|
||||
class Real
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
|
||||
@dynect_customer = options[:dynect_customer]
|
||||
@dynect_username = options[:dynect_username]
|
||||
@dynect_password = options[:dynect_password]
|
||||
|
@ -95,7 +93,7 @@ module Fog
|
|||
if response.status == 307
|
||||
response = poll_job(response)
|
||||
elsif !response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
|
||||
response
|
||||
|
|
|
@ -15,7 +15,7 @@ module Fog
|
|||
def post_record(type, zone, fqdn, rdata, options = {})
|
||||
options.merge!('rdata' => rdata)
|
||||
request(
|
||||
:body => MultiJson.dump(options),
|
||||
:body => Fog::JSON.encode(options),
|
||||
:expects => 200,
|
||||
:method => :post,
|
||||
:path => ["#{type.to_s.upcase}Record", zone, fqdn].join('/')
|
||||
|
|
|
@ -8,7 +8,7 @@ module Fog
|
|||
:expects => 200,
|
||||
:method => :post,
|
||||
:path => "Session",
|
||||
:body => MultiJson.dump({
|
||||
:body => Fog::JSON.encode({
|
||||
:customer_name => @dynect_customer,
|
||||
:user_name => @dynect_username,
|
||||
:password => @dynect_password
|
||||
|
|
|
@ -13,7 +13,7 @@ module Fog
|
|||
# * serial_style<~String> - style of serial number, in ['day', 'epoch', 'increment', 'minute']. Defaults to increment
|
||||
|
||||
def post_zone(rname, ttl, zone, options = {})
|
||||
body = MultiJson.dump({
|
||||
body = Fog::JSON.encode({
|
||||
:rname => rname,
|
||||
:token => auth_token,
|
||||
:ttl => ttl
|
||||
|
|
|
@ -14,7 +14,7 @@ module Fog
|
|||
|
||||
def put_zone(zone, options = {})
|
||||
request(
|
||||
:body => MultiJson.dump(options),
|
||||
:body => Fog::JSON.encode(options),
|
||||
:expects => 200,
|
||||
:method => :put,
|
||||
:path => 'Zone/' << zone
|
||||
|
|
|
@ -65,7 +65,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options)
|
||||
require 'multi_json'
|
||||
require 'base64'
|
||||
|
||||
@api_url = options[:glesys_api_url] || Fog.credentials[:glesys_api_url] || API_URL
|
||||
|
@ -94,7 +93,7 @@ module Fog
|
|||
}
|
||||
)
|
||||
|
||||
data.body = MultiJson.load(data.body)
|
||||
data.body = Fog::JSON.decode(data.body)
|
||||
|
||||
response_code = data.body['response']['status']['code']
|
||||
|
||||
|
|
|
@ -61,7 +61,6 @@ module Fog
|
|||
|
||||
def initialize(options={})
|
||||
require 'digest/md5'
|
||||
require 'multi_json'
|
||||
@go_grid_api_key = options[:go_grid_api_key]
|
||||
@go_grid_shared_secret = options[:go_grid_shared_secret]
|
||||
@connection_options = options[:connection_options] || {}
|
||||
|
@ -105,7 +104,7 @@ module Fog
|
|||
end
|
||||
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
|
||||
response
|
||||
|
|
|
@ -76,8 +76,8 @@ module Fog
|
|||
%{mkdir .ssh},
|
||||
%{echo "#{public_key}" >> ~/.ssh/authorized_keys},
|
||||
%{passwd -l root},
|
||||
%{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{MultiJson.dump(metadata)}" >> ~/metadata.json}
|
||||
%{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{Fog::JSON.encode(metadata)}" >> ~/metadata.json}
|
||||
])
|
||||
rescue Errno::ECONNREFUSED
|
||||
sleep(1)
|
||||
|
|
|
@ -13,7 +13,7 @@ module Fog
|
|||
data = nil
|
||||
message = nil
|
||||
else
|
||||
data = MultiJson.load(error.response.body)
|
||||
data = Fog::JSON.decode(error.response.body)
|
||||
message = data['message']
|
||||
end
|
||||
|
||||
|
@ -144,12 +144,12 @@ module Fog
|
|||
:host => @host,
|
||||
:port => @port,
|
||||
:method => 'POST',
|
||||
:body => MultiJson.dump(request_body),
|
||||
:body => Fog::JSON.encode(request_body),
|
||||
:path => @auth_path
|
||||
}
|
||||
)
|
||||
|
||||
body = MultiJson.load(response.body)
|
||||
body = Fog::JSON.decode(response.body)
|
||||
|
||||
### fish out auth_token and endpoint for the service
|
||||
auth_token = body['access']['token']['id']
|
||||
|
|
|
@ -54,7 +54,6 @@ module Fog
|
|||
include Utils
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@connection_options = options[:connection_options] || {}
|
||||
### Set an option to use the style of authentication desired; :v1 or :v2 (default)
|
||||
auth_version = options[:hp_auth_version] || :v2
|
||||
|
@ -119,7 +118,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
if !response.body.empty? && parse_json && response.headers['Content-Type'] =~ %r{application/json}
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -105,7 +105,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@hp_secret_key = options[:hp_secret_key]
|
||||
@hp_account_id = options[:hp_account_id]
|
||||
@hp_servicenet = options[:hp_servicenet]
|
||||
|
@ -167,7 +166,7 @@ module Fog
|
|||
end
|
||||
unless response.body.empty?
|
||||
begin
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
rescue MultiJson::DecodeError => error
|
||||
response.body #### the body is not in JSON format so just return it as it is
|
||||
end
|
||||
|
|
|
@ -199,8 +199,8 @@ module Fog
|
|||
%{mkdir .ssh},
|
||||
%{echo "#{public_key}" >> ~/.ssh/authorized_keys},
|
||||
%{passwd -l #{username}},
|
||||
%{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{MultiJson.dump(metadata)}" >> ~/metadata.json}
|
||||
%{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{Fog::JSON.encode(metadata)}" >> ~/metadata.json}
|
||||
])
|
||||
rescue Errno::ECONNREFUSED
|
||||
sleep(1)
|
||||
|
|
|
@ -37,7 +37,7 @@ module Fog
|
|||
end
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => 200,
|
||||
:method => 'POST',
|
||||
:path => 'os-keypairs.json'
|
||||
|
|
|
@ -38,7 +38,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => 200,
|
||||
:method => 'POST',
|
||||
:path => 'os-security-groups.json'
|
||||
|
|
|
@ -31,7 +31,7 @@ module Fog
|
|||
}
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => 200,
|
||||
:method => 'POST',
|
||||
:path => 'os-security-group-rules.json'
|
||||
|
|
|
@ -86,7 +86,7 @@ module Fog
|
|||
end
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => 202,
|
||||
:method => 'POST',
|
||||
:path => 'servers.json'
|
||||
|
|
|
@ -12,7 +12,7 @@ module Fog
|
|||
#
|
||||
def server_action(server_id, body, expects=202)
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:expects => expects,
|
||||
:method => 'POST',
|
||||
:path => "servers/#{server_id}/action.json"
|
||||
|
|
|
@ -12,7 +12,7 @@ module Fog
|
|||
# * name<~String> - New name for server
|
||||
def update_server(server_id, options = {})
|
||||
request(
|
||||
:body => MultiJson.dump({ 'server' => options }),
|
||||
:body => Fog::JSON.encode({ 'server' => options }),
|
||||
:expects => 200,
|
||||
:method => 'PUT',
|
||||
:path => "servers/#{server_id}.json"
|
||||
|
|
|
@ -126,7 +126,6 @@ module Fog
|
|||
|
||||
def initialize(options={})
|
||||
require 'mime/types'
|
||||
require 'multi_json'
|
||||
@hp_secret_key = options[:hp_secret_key]
|
||||
@hp_account_id = options[:hp_account_id]
|
||||
@hp_auth_uri = options[:hp_auth_uri]
|
||||
|
@ -189,7 +188,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
if !response.body.empty? && parse_json && response.headers['Content-Type'] =~ %r{application/json}
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -18,7 +18,6 @@ module Fog
|
|||
class Connection < Fog::Connection
|
||||
|
||||
def initialize(user, password)
|
||||
require 'multi_json'
|
||||
@user = user
|
||||
@password = password
|
||||
@endpoint = URI.parse('https://www-147.ibm.com/computecloud/enterprise/api/rest/20100331')
|
||||
|
@ -38,7 +37,7 @@ module Fog
|
|||
end
|
||||
response = super(options)
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -1,7 +1,6 @@
|
|||
require File.expand_path(File.join(File.dirname(__FILE__), '..', 'joyent'))
|
||||
require File.expand_path(File.join(File.dirname(__FILE__), 'errors'))
|
||||
require 'fog/compute'
|
||||
require 'multi_json'
|
||||
|
||||
module Fog
|
||||
module Compute
|
||||
|
@ -144,7 +143,7 @@ module Fog
|
|||
}.merge(request[:headers] || {}).merge(@header_method.call)
|
||||
|
||||
if request[:body]
|
||||
request[:body] = MultiJson.dump(request[:body])
|
||||
request[:body] = Fog::JSON.encode(request[:body])
|
||||
end
|
||||
|
||||
response = @connection.request(request)
|
||||
|
@ -161,7 +160,7 @@ module Fog
|
|||
private
|
||||
|
||||
def json_decode(body)
|
||||
parsed = MultiJson.load(body)
|
||||
parsed = Fog::JSON.decode(body)
|
||||
decode_time_attrs(parsed)
|
||||
end
|
||||
|
||||
|
|
|
@ -192,7 +192,6 @@ module Fog
|
|||
# Sets up a new key
|
||||
def setup(credentials = {})
|
||||
requires :public_key, :public_ip_address, :username
|
||||
require 'multi_json'
|
||||
|
||||
credentials[:proxy]= ssh_proxy unless ssh_proxy.nil?
|
||||
credentials[:password] = password unless self.password.nil?
|
||||
|
@ -201,7 +200,7 @@ module Fog
|
|||
commands = [
|
||||
%{mkdir .ssh},
|
||||
# %{passwd -l #{username}}, #Not sure if we need this here
|
||||
# %{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json}
|
||||
# %{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json}
|
||||
]
|
||||
if public_key
|
||||
commands << %{echo "#{public_key}" >> ~/.ssh/authorized_keys}
|
||||
|
|
|
@ -80,7 +80,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@linode_api_key = options[:linode_api_key]
|
||||
@host = options[:host] || "api.linode.com"
|
||||
@port = options[:port] || 443
|
||||
|
@ -99,7 +98,7 @@ module Fog
|
|||
response = @connection.request(params.merge!({:host => @host}))
|
||||
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
if data = response.body['ERRORARRAY'].first
|
||||
error = case data['ERRORCODE']
|
||||
when 5
|
||||
|
|
|
@ -53,7 +53,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@connection_options = options[:connection_options] || {}
|
||||
@host = options[:host] || "api.linode.com"
|
||||
@linode_api_key = options[:linode_api_key]
|
||||
|
@ -74,7 +73,7 @@ module Fog
|
|||
response = @connection.request(params.merge!({:host => @host}))
|
||||
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
if data = response.body['ERRORARRAY'].first
|
||||
error = case data['ERRORCODE']
|
||||
when 5
|
||||
|
|
|
@ -15,7 +15,7 @@ module Fog
|
|||
:label => name,
|
||||
:size => size,
|
||||
:rootPass => password,
|
||||
:stackScriptUDFResponses => MultiJson.dump(options)
|
||||
:stackScriptUDFResponses => Fog::JSON.encode(options)
|
||||
}
|
||||
)
|
||||
end
|
||||
|
|
|
@ -63,8 +63,6 @@ module Fog
|
|||
class Mock
|
||||
|
||||
def initialize(options)
|
||||
require 'multi_json'
|
||||
|
||||
@api_url = options[:ninefold_api_url] || Fog.credentials[:ninefold_api_url] || API_URL
|
||||
@ninefold_compute_key = options[:ninefold_compute_key] || Fog.credentials[:ninefold_compute_key]
|
||||
@ninefold_compute_secret = options[:ninefold_compute_secret] || Fog.credentials[:ninefold_compute_secret]
|
||||
|
@ -78,8 +76,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options)
|
||||
require 'multi_json'
|
||||
|
||||
@api_url = options[:ninefold_api_url] || Fog.credentials[:ninefold_api_url] || API_URL
|
||||
@ninefold_compute_key = options[:ninefold_compute_key] || Fog.credentials[:ninefold_compute_key]
|
||||
@ninefold_compute_secret = options[:ninefold_compute_secret] || Fog.credentials[:ninefold_compute_secret]
|
||||
|
@ -108,7 +104,7 @@ module Fog
|
|||
# Because the response is some weird xml-json thing, we need to try and mung
|
||||
# the values out with a prefix, and if there is an empty data entry return an
|
||||
# empty version of the expected type (if provided)
|
||||
response = MultiJson.load(response.body)
|
||||
response = Fog::JSON.decode(response.body)
|
||||
if options.has_key? :response_prefix
|
||||
keys = options[:response_prefix].split('/')
|
||||
keys.each do |k|
|
||||
|
|
|
@ -13,7 +13,7 @@ module Fog
|
|||
data = nil
|
||||
message = nil
|
||||
else
|
||||
data = MultiJson.load(error.response.body)
|
||||
data = Fog::JSON.decode(error.response.body)
|
||||
message = data['message']
|
||||
end
|
||||
|
||||
|
@ -91,12 +91,12 @@ module Fog
|
|||
response = connection.request({
|
||||
:expects => [200, 204],
|
||||
:headers => {'Content-Type' => 'application/json'},
|
||||
:body => MultiJson.dump(req_body),
|
||||
:body => Fog::JSON.encode(req_body),
|
||||
:host => uri.host,
|
||||
:method => 'POST',
|
||||
:path => (uri.path and not uri.path.empty?) ? uri.path : 'v2.0'
|
||||
})
|
||||
body=MultiJson.load(response.body)
|
||||
body=Fog::JSON.decode(response.body)
|
||||
|
||||
if svc = body['access']['serviceCatalog'].detect{|x| x['name'] == @compute_service_name}
|
||||
mgmt_url = svc['endpoints'].detect{|x| x['publicURL']}['publicURL']
|
||||
|
|
|
@ -87,7 +87,6 @@ module Fog
|
|||
end
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@openstack_username = options[:openstack_username]
|
||||
end
|
||||
|
||||
|
@ -104,7 +103,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@openstack_api_key = options[:openstack_api_key]
|
||||
@openstack_username = options[:openstack_username]
|
||||
@openstack_tenant = options[:openstack_tenant]
|
||||
|
@ -151,7 +149,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -175,8 +175,8 @@ module Fog
|
|||
%{mkdir .ssh},
|
||||
%{echo "#{public_key}" >> ~/.ssh/authorized_keys},
|
||||
%{passwd -l #{username}},
|
||||
%{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{MultiJson.dump(metadata)}" >> ~/metadata.json}
|
||||
%{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{Fog::JSON.encode(metadata)}" >> ~/metadata.json}
|
||||
])
|
||||
rescue Errno::ECONNREFUSED
|
||||
sleep(1)
|
||||
|
|
|
@ -29,7 +29,7 @@ module Fog
|
|||
end
|
||||
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => [200, 202],
|
||||
:method => 'POST',
|
||||
:path => 'servers.json'
|
||||
|
|
|
@ -5,7 +5,7 @@ module Fog
|
|||
|
||||
def server_action(server_id, body, expects=202)
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:expects => expects,
|
||||
:method => 'POST',
|
||||
:path => "servers/#{server_id}/action.json"
|
||||
|
|
|
@ -6,7 +6,7 @@ module Fog
|
|||
|
||||
def set_metadata(collection_name, parent_id, metadata = {})
|
||||
request(
|
||||
:body => MultiJson.dump({ 'metadata' => metadata }),
|
||||
:body => Fog::JSON.encode({ 'metadata' => metadata }),
|
||||
:expects => 200,
|
||||
:method => 'PUT',
|
||||
:path => "#{collection_name}/#{parent_id}/metadata"
|
||||
|
|
|
@ -6,7 +6,7 @@ module Fog
|
|||
|
||||
def update_meta(collection_name, parent_id, key, value)
|
||||
request(
|
||||
:body => MultiJson.dump({ 'meta' => { key => value }}),
|
||||
:body => Fog::JSON.encode({ 'meta' => { key => value }}),
|
||||
:expects => 200,
|
||||
:method => 'PUT',
|
||||
:path => "#{collection_name}/#{parent_id}/metadata/#{key}"
|
||||
|
|
|
@ -6,7 +6,7 @@ module Fog
|
|||
|
||||
def update_metadata(collection_name, parent_id, metadata = {})
|
||||
request(
|
||||
:body => MultiJson.dump({ 'metadata' => metadata }),
|
||||
:body => Fog::JSON.encode({ 'metadata' => metadata }),
|
||||
:expects => 200,
|
||||
:method => 'POST',
|
||||
:path => "#{collection_name}/#{parent_id}/metadata.json"
|
||||
|
|
|
@ -5,7 +5,7 @@ module Fog
|
|||
|
||||
def update_server(server_id, options = {})
|
||||
request(
|
||||
:body => MultiJson.dump({ 'server' => options }),
|
||||
:body => Fog::JSON.encode({ 'server' => options }),
|
||||
:expects => 200,
|
||||
:method => 'PUT',
|
||||
:path => "servers/#{server_id}.json"
|
||||
|
|
|
@ -13,7 +13,7 @@ module Fog
|
|||
data = nil
|
||||
message = nil
|
||||
else
|
||||
data = MultiJson.load(error.response.body)
|
||||
data = Fog::JSON.decode(error.response.body)
|
||||
message = data['message']
|
||||
end
|
||||
|
||||
|
|
|
@ -45,7 +45,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@connection_options = options[:connection_options] || {}
|
||||
credentials = Fog::Rackspace.authenticate(options, @connection_options)
|
||||
@auth_token = credentials['X-Auth-Token']
|
||||
|
@ -90,7 +89,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
if !response.body.empty? && parse_json && response.headers['Content-Type'] =~ %r{application/json}
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -61,7 +61,6 @@ module Fog
|
|||
end
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@rackspace_username = options[:rackspace_username]
|
||||
end
|
||||
|
||||
|
@ -78,7 +77,6 @@ module Fog
|
|||
class Real
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@rackspace_api_key = options[:rackspace_api_key]
|
||||
@rackspace_username = options[:rackspace_username]
|
||||
@rackspace_auth_url = options[:rackspace_auth_url]
|
||||
|
@ -125,7 +123,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -73,7 +73,6 @@ module Fog
|
|||
|
||||
class Real
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@rackspace_api_key = options[:rackspace_api_key]
|
||||
@rackspace_username = options[:rackspace_username]
|
||||
@rackspace_auth_url = options[:rackspace_auth_url]
|
||||
|
@ -108,7 +107,7 @@ module Fog
|
|||
raise Fog::Rackspace::Errors::ServiceUnavailable.slurp error
|
||||
end
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -97,7 +97,6 @@ module Fog
|
|||
include Shared
|
||||
|
||||
def initialize(options={})
|
||||
require 'multi_json'
|
||||
@rackspace_api_key = options[:rackspace_api_key]
|
||||
@rackspace_username = options[:rackspace_username]
|
||||
@rackspace_auth_url = options[:rackspace_auth_url]
|
||||
|
@ -136,7 +135,7 @@ module Fog
|
|||
raise ServiceError.slurp error
|
||||
end
|
||||
unless response.body.empty?
|
||||
response.body = MultiJson.load(response.body)
|
||||
response.body = Fog::JSON.decode(response.body)
|
||||
end
|
||||
response
|
||||
end
|
||||
|
|
|
@ -104,8 +104,8 @@ module Fog
|
|||
%{mkdir .ssh},
|
||||
%{echo "#{public_key}" >> ~/.ssh/authorized_keys},
|
||||
%{passwd -l #{username}},
|
||||
%{echo "#{MultiJson.dump(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{MultiJson.dump(metadata)}" >> ~/metadata.json}
|
||||
%{echo "#{Fog::JSON.encode(attributes)}" >> ~/attributes.json},
|
||||
%{echo "#{Fog::JSON.encode(metadata)}" >> ~/metadata.json}
|
||||
])
|
||||
rescue Errno::ECONNREFUSED
|
||||
sleep(1)
|
||||
|
|
|
@ -23,7 +23,7 @@ module Fog
|
|||
}
|
||||
data['image'].merge!(options)
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => 202,
|
||||
:method => 'POST',
|
||||
:path => "images"
|
||||
|
|
|
@ -56,7 +56,7 @@ module Fog
|
|||
end
|
||||
end
|
||||
request(
|
||||
:body => MultiJson.dump(data),
|
||||
:body => Fog::JSON.encode(data),
|
||||
:expects => [200, 202],
|
||||
:method => 'POST',
|
||||
:path => 'servers.json'
|
||||
|
|
|
@ -12,7 +12,7 @@ module Fog
|
|||
#
|
||||
def server_action(server_id, body, expects=202)
|
||||
request(
|
||||
:body => MultiJson.dump(body),
|
||||
:body => Fog::JSON.encode(body),
|
||||
:expects => expects,
|
||||
:method => 'POST',
|
||||
:path => "servers/#{server_id}/action.json"
|
||||
|
|
|
@ -12,7 +12,7 @@ module Fog
|
|||
# * name<~String> - New name for server
|
||||
def update_server(server_id, options = {})
|
||||
request(
|
||||
:body => MultiJson.dump({ 'server' => options }),
|
||||
:body => Fog::JSON.encode({ 'server' => options }),
|
||||
:expects => 204,
|
||||
:method => 'PUT',
|
||||
:path => "servers/#{server_id}.json"
|
||||
|
|
|
@ -25,7 +25,7 @@ module Fog
|
|||
:expects => 202,
|
||||
:method => 'POST',
|
||||
:path => "domains/#{domain_id}/records",
|
||||
:body => MultiJson.dump(data)
|
||||
:body => Fog::JSON.encode(data)
|
||||
)
|
||||
end
|
||||
end
|
||||
|
|
|
@ -39,7 +39,7 @@ module Fog
|
|||
:expects => 202,
|
||||
:method => 'POST',
|
||||
:path => 'domains',
|
||||
:body => MultiJson.dump(data)
|
||||
:body => Fog::JSON.encode(data)
|
||||
)
|
||||
end
|
||||
end
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show more
Loading…
Reference in a new issue