module Legion::Extensions::Node::Runners::Vault
Public Instance Methods
push_vault_token(public_key:, node_name:, **)
click to toggle source
# File lib/legion/extensions/node/runners/vault.rb, line 29 def push_vault_token(public_key:, node_name:, **) return {} unless Legion::Settings[:crypt][:vault][:token] encrypted = Legion::Crypt.encrypt_from_keypair(message: Legion::Settings[:crypt][:vault][:token], pub_key: public_key) Legion::Extensions::Node::Transport::Messages::PushVaultToken.new(token: encrypted, queue_name: node_name).publish {} end
receive_vault_token(message:, **opts)
click to toggle source
# File lib/legion/extensions/node/runners/vault.rb, line 15 def receive_vault_token(message:, **opts) # rubocop:disable Metrics/AbcSize return if Legion::Settings[:crypt][:vault][:connected] Legion::Settings[:crypt][:vault][:token] = Legion::Crypt.decrypt_from_keypair(message: message) %i[protocol address port].each do |setting| next unless opts.key? setting next unless Legion::Settings[:crypt][:vault][setting].nil? Legion::Settings[:crypt][:vault][setting] = opts[setting] end Legion::Crypt.connect_vault {} end
request_token(**)
click to toggle source
# File lib/legion/extensions/node/runners/vault.rb, line 3 def request_token(**) return {} if Legion::Settings[:crypt][:vault][:connected] return {} unless Legion::Settings[:crypt][:vault][:enabled] request_vault_token end
request_vault_token(**)
click to toggle source
# File lib/legion/extensions/node/runners/vault.rb, line 10 def request_vault_token(**) Legion::Extensions::Node::Transport::Messages::RequestVaultToken.new.publish {} end