Read CS credentials from file
This commit is contained in:
parent
4f91c9aa87
commit
20d33cc1af
1
.gitignore
vendored
1
.gitignore
vendored
@ -1,2 +1,3 @@
|
|||||||
config.yml
|
config.yml
|
||||||
|
cs_credentials.json
|
||||||
pids
|
pids
|
||||||
|
|||||||
@ -3,20 +3,26 @@ development: &defaults
|
|||||||
riak: &riak_defaults
|
riak: &riak_defaults
|
||||||
host: localhost
|
host: localhost
|
||||||
http_port: 8098
|
http_port: 8098
|
||||||
|
riak_cs:
|
||||||
|
credentials_file: "cs_credentials.json"
|
||||||
|
endpoint: "http://cs.example.com:8080"
|
||||||
buckets:
|
buckets:
|
||||||
data: rs_data
|
data: rs_data
|
||||||
directories: rs_directories
|
directories: rs_directories
|
||||||
binaries: rs_binaries
|
binaries: rs_binaries
|
||||||
|
cs_binaries: rs.binaries
|
||||||
authorizations: rs_authorizations
|
authorizations: rs_authorizations
|
||||||
opslog: rs_opslog
|
opslog: rs_opslog
|
||||||
|
|
||||||
test:
|
test:
|
||||||
|
<<: *defaults
|
||||||
riak:
|
riak:
|
||||||
<<: *riak_defaults
|
<<: *riak_defaults
|
||||||
buckets:
|
buckets:
|
||||||
data: rs_data_test
|
data: rs_data_test
|
||||||
directories: rs_directories_test
|
directories: rs_directories_test
|
||||||
binaries: rs_binaries_test
|
binaries: rs_binaries_test
|
||||||
|
cs_binaries: rs.binaries.test
|
||||||
authorizations: rs_authorizations_test
|
authorizations: rs_authorizations_test
|
||||||
opslog: rs_opslog_test
|
opslog: rs_opslog_test
|
||||||
|
|
||||||
|
|||||||
@ -9,11 +9,14 @@ module RemoteStorage
|
|||||||
|
|
||||||
::Riak.url_decoding = true
|
::Riak.url_decoding = true
|
||||||
|
|
||||||
attr_accessor :settings, :server
|
attr_accessor :settings, :server, :cs_credentials
|
||||||
|
|
||||||
def initialize(settings, server)
|
def initialize(settings, server)
|
||||||
self.settings = settings
|
self.settings = settings
|
||||||
self.server = server
|
self.server = server
|
||||||
|
|
||||||
|
credentials = File.read(settings['riak_cs']['credentials_file'])
|
||||||
|
self.cs_credentials = JSON.parse(credentials)
|
||||||
end
|
end
|
||||||
|
|
||||||
def authorize_request(user, directory, token, listing=false)
|
def authorize_request(user, directory, token, listing=false)
|
||||||
@ -435,8 +438,8 @@ module RemoteStorage
|
|||||||
def cs_client
|
def cs_client
|
||||||
@cs_client ||= Fog::Storage.new({
|
@cs_client ||= Fog::Storage.new({
|
||||||
:provider => 'AWS',
|
:provider => 'AWS',
|
||||||
:aws_access_key_id => settings['riak_cs']['access_key'],
|
:aws_access_key_id => cs_credentials['key_id'],
|
||||||
:aws_secret_access_key => settings['riak_cs']['secret_key'],
|
:aws_secret_access_key => cs_credentials['key_secret'],
|
||||||
:endpoint => settings['riak_cs']['endpoint']
|
:endpoint => settings['riak_cs']['endpoint']
|
||||||
})
|
})
|
||||||
end
|
end
|
||||||
|
|||||||
@ -69,11 +69,18 @@ if app.settings.riak
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def cs_credentials
|
||||||
|
@cs_credentials ||= begin
|
||||||
|
credentials = File.read(app.settings.riak['riak_cs']['credentials_file'])
|
||||||
|
JSON.parse(credentials)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
def cs_client
|
def cs_client
|
||||||
@cs_client ||= Fog::Storage.new({
|
@cs_client ||= Fog::Storage.new({
|
||||||
:provider => 'AWS',
|
:provider => 'AWS',
|
||||||
:aws_access_key_id => app.settings.riak['riak_cs']['access_key'],
|
:aws_access_key_id => cs_credentials['key_id'],
|
||||||
:aws_secret_access_key => app.settings.riak['riak_cs']['secret_key'],
|
:aws_secret_access_key => cs_credentials['key_secret'],
|
||||||
:endpoint => app.settings.riak['riak_cs']['endpoint']
|
:endpoint => app.settings.riak['riak_cs']['endpoint']
|
||||||
})
|
})
|
||||||
end
|
end
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user