ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Revert "Fixing bugs in ssh known_host fetching"

Browse source 
This reverts commit 21c127c581.
This commit is contained in:
James Cammarata 2015-12-17 12:42:53 -05:00
parent 8db4415e2e
commit 586208234c
1 changed files with 8 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
lib/ansible/plugins/connection/ssh.py
View file

@ -60,15 +60,11 @@ def split_args(argstring):
""" """
return [to_unicode(x.strip()) for x in shlex.split(to_bytes(argstring)) if x.strip()] return [to_unicode(x.strip()) for x in shlex.split(to_bytes(argstring)) if x.strip()]
def get_ssh_opts(host, play_context): def get_ssh_opts(play_context):
# FIXME: caching may help here # FIXME: caching may help here
opts_dict = dict() opts_dict = dict()
try: try:
remote_addr = play_context.remote_addr cmd = ['ssh', '-G', play_context.remote_addr]
if not remote_addr:
remote_addr = host.address
cmd = ['ssh', '-G', remote_addr]
res = subprocess.check_output(cmd) res = subprocess.check_output(cmd)
for line in res.split('\n'): for line in res.split('\n'):
if ' ' in line: if ' ' in line:
@ -141,7 +137,7 @@ def host_in_known_hosts(host, ssh_opts):
return False return False
def fetch_ssh_host_key(host, play_context, ssh_opts): def fetch_ssh_host_key(play_context, ssh_opts):
keyscan_cmd = ['ssh-keyscan'] keyscan_cmd = ['ssh-keyscan']
if play_context.port: if play_context.port:
@ -150,11 +146,7 @@ def fetch_ssh_host_key(host, play_context, ssh_opts):
if boolean(ssh_opts.get('hashknownhosts', 'no')): if boolean(ssh_opts.get('hashknownhosts', 'no')):
keyscan_cmd.append('-H') keyscan_cmd.append('-H')
remote_addr = play_context.remote_addr keyscan_cmd.append(play_context.remote_addr)
if not remote_addr:
remote_addr = host.address
keyscan_cmd.append(remote_addr)
p = subprocess.Popen(keyscan_cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, close_fds=True) p = subprocess.Popen(keyscan_cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, close_fds=True)
(stdout, stderr) = p.communicate() (stdout, stderr) = p.communicate()
@ -202,13 +194,8 @@ class Connection(ConnectionBase):
@staticmethod @staticmethod
def fetch_and_store_key(host, play_context): def fetch_and_store_key(host, play_context):
ssh_opts = get_ssh_opts(host, play_context) ssh_opts = get_ssh_opts(play_context)
if not host_in_known_hosts(play_context.remote_addr, ssh_opts):
remote_addr = play_context.remote_addr
if not remote_addr:
remote_addr = host.address
if not host_in_known_hosts(remote_addr, ssh_opts):
display.debug("host %s does not have a known host key, fetching it" % host) display.debug("host %s does not have a known host key, fetching it" % host)
# build the list of valid host key types, for use later as we scan for keys. # build the list of valid host key types, for use later as we scan for keys.
@ -217,7 +204,7 @@ class Connection(ConnectionBase):
# attempt to fetch the key with ssh-keyscan. More than one key may be # attempt to fetch the key with ssh-keyscan. More than one key may be
# returned, so we save all and use the above list to determine which # returned, so we save all and use the above list to determine which
host_key_data = fetch_ssh_host_key(host, play_context, ssh_opts).strip().split('\n') host_key_data = fetch_ssh_host_key(play_context, ssh_opts).strip().split('\n')
host_keys = dict() host_keys = dict()
for host_key in host_key_data: for host_key in host_key_data:
(host_info, key_type, key_hash) = host_key.strip().split(' ', 3) (host_info, key_type, key_hash) = host_key.strip().split(' ', 3)
@ -242,7 +229,7 @@ class Connection(ConnectionBase):
# prompt the user to add the key # prompt the user to add the key
# if yes, add it, otherwise raise AnsibleConnectionFailure # if yes, add it, otherwise raise AnsibleConnectionFailure
display.display("\nThe authenticity of host %s (%s) can't be established." % (host.name, remote_addr)) display.display("\nThe authenticity of host %s (%s) can't be established." % (host.name, play_context.remote_addr))
display.display("%s key fingerprint is SHA256:%s." % (key_type.upper(), sha256(decoded_key).digest().encode('base64').strip())) display.display("%s key fingerprint is SHA256:%s." % (key_type.upper(), sha256(decoded_key).digest().encode('base64').strip()))
display.display("%s key fingerprint is MD5:%s." % (key_type.upper(), key_data)) display.display("%s key fingerprint is MD5:%s." % (key_type.upper(), key_data))
response = display.prompt("Are you sure you want to continue connecting (yes/no)? ") response = display.prompt("Are you sure you want to continue connecting (yes/no)? ")