Skip to content

Commit

Permalink
Black formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
psiniemi committed Jan 6, 2022
1 parent 38ef669 commit 543aa24
Show file tree
Hide file tree
Showing 13 changed files with 1,591 additions and 807 deletions.
115 changes: 61 additions & 54 deletions ec2_utils/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,66 +20,73 @@
cov = None
if "EC2_UTILS_MEASURE_COVERAGE" in environ:
from coverage import Coverage
cov = Coverage(auto_data=True, source=["ec2_utils"], branch=False,
omit=["ec2_utils/__init__.py",
"ec2_utils/elastic_c2_register_complete.py",
"ec2_utils/ec2.py"])

cov = Coverage(
auto_data=True,
source=["ec2_utils"],
branch=False,
omit=[
"ec2_utils/__init__.py",
"ec2_utils/elastic_c2_register_complete.py",
"ec2_utils/ec2.py",
],
)
cov.start()


EC2_ONLY_SCRIPT = [
'create-shell-archive.sh',
'encrypt-and-mount.sh',
'mount-and-format.sh',
'ssh-hostkeys-collect.sh',
'disk-by-drive-letter.ps1'
"create-shell-archive.sh",
"encrypt-and-mount.sh",
"mount-and-format.sh",
"ssh-hostkeys-collect.sh",
"disk-by-drive-letter.ps1",
]
EC2_ONLY = [
'account-id=ec2_utils.cli:account_id',
'associate-eip=ec2_utils.cli:associate_eip',
'attach-eni=ec2_utils.cli:attach_eni',
'availability-zone=ec2_utils.cli:availability_zone',
'cf-logical-id=ec2_utils.cli:cf_logical_id',
'cf-region=ec2_utils.cli:cf_region',
'cf-get-parameter=ec2_utils.cli:cf_get_parameter',
'cf-signal-status=ec2_utils.cli:cf_signal_status',
'cf-stack-name=ec2_utils.cli:cf_stack_name',
'cf-stack-id=ec2_utils.cli:cf_stack_id',
'clean-snapshots=ec2_utils.cli:clean_snapshots',
'create-eni=ec2_utils.cli:create_eni',
'detach-volume=ec2_utils.cli:detach_volume',
'detach-eni=ec2_utils.cli:detach_eni',
'ecs-private-ip=ec2_utils.cli:ecs_private_ip',
'first-ext-ip=ec2_utils.cli:first_ext_ip',
'get-latest-snapshot=ec2_utils.cli:latest_snapshot',
'get-tag=ec2_utils.cli:get_tag',
'get-userdata=ec2_utils.cli:get_userdata',
'instance-id=ec2_utils.cli:instance_id',
'largest-unmounted-device=ec2_utils.cli:largest_unmounted_device',
'latest-snapshot=ec2_utils.cli:latest_snapshot',
'list-attachable-enis=ec2_utils.cli:list_attachable_enis',
'list-attached-enis=ec2_utils.cli:list_attached_enis',
'list-attached-volumes=ec2_utils.cli:list_attached_volumes',
'list-compatible-subnets=ec2_utils.cli:list_compatible_subnets',
'list-local-interfaces=ec2_utils.cli:list_local_interfaces',
'list-tags=ec2_utils.cli:list_tags',
'log-to-cloudwatch=ec2_utils.cli:log_to_cloudwatch',
'logs=ec2_utils.cli:get_logs',
'prune-snapshots=ec2_utils.cli:prune_snapshots',
'prune-s3-object-versions=ec2_utils.cli:prune_object_versions',
'pytail=ec2_utils.cli:read_and_follow',
'region=ec2_utils.cli:region',
'register-private-dns=ec2_utils.cli:register_private_dns',
'snapshot-from-volume=ec2_utils.cli:snapshot_from_volume',
'stack-params-and-outputs=ec2_utils.cli:stack_params_and_outputs',
'subnet-id=ec2_utils.cli:subnet_id',
'volume-from-snapshot=ec2_utils.cli:volume_from_snapshot',
'volume-info=ec2_utils.cli:volume_info',
'wait-for-metadata=ec2_utils.cli:wait_for_metadata'
"account-id=ec2_utils.cli:account_id",
"associate-eip=ec2_utils.cli:associate_eip",
"attach-eni=ec2_utils.cli:attach_eni",
"availability-zone=ec2_utils.cli:availability_zone",
"cf-logical-id=ec2_utils.cli:cf_logical_id",
"cf-region=ec2_utils.cli:cf_region",
"cf-get-parameter=ec2_utils.cli:cf_get_parameter",
"cf-signal-status=ec2_utils.cli:cf_signal_status",
"cf-stack-name=ec2_utils.cli:cf_stack_name",
"cf-stack-id=ec2_utils.cli:cf_stack_id",
"clean-snapshots=ec2_utils.cli:clean_snapshots",
"create-eni=ec2_utils.cli:create_eni",
"detach-volume=ec2_utils.cli:detach_volume",
"detach-eni=ec2_utils.cli:detach_eni",
"ecs-private-ip=ec2_utils.cli:ecs_private_ip",
"first-ext-ip=ec2_utils.cli:first_ext_ip",
"get-latest-snapshot=ec2_utils.cli:latest_snapshot",
"get-tag=ec2_utils.cli:get_tag",
"get-userdata=ec2_utils.cli:get_userdata",
"instance-id=ec2_utils.cli:instance_id",
"largest-unmounted-device=ec2_utils.cli:largest_unmounted_device",
"latest-snapshot=ec2_utils.cli:latest_snapshot",
"list-attachable-enis=ec2_utils.cli:list_attachable_enis",
"list-attached-enis=ec2_utils.cli:list_attached_enis",
"list-attached-volumes=ec2_utils.cli:list_attached_volumes",
"list-compatible-subnets=ec2_utils.cli:list_compatible_subnets",
"list-local-interfaces=ec2_utils.cli:list_local_interfaces",
"list-tags=ec2_utils.cli:list_tags",
"log-to-cloudwatch=ec2_utils.cli:log_to_cloudwatch",
"logs=ec2_utils.cli:get_logs",
"prune-snapshots=ec2_utils.cli:prune_snapshots",
"prune-s3-object-versions=ec2_utils.cli:prune_object_versions",
"pytail=ec2_utils.cli:read_and_follow",
"region=ec2_utils.cli:region",
"register-private-dns=ec2_utils.cli:register_private_dns",
"snapshot-from-volume=ec2_utils.cli:snapshot_from_volume",
"stack-params-and-outputs=ec2_utils.cli:stack_params_and_outputs",
"subnet-id=ec2_utils.cli:subnet_id",
"volume-from-snapshot=ec2_utils.cli:volume_from_snapshot",
"volume-info=ec2_utils.cli:volume_info",
"wait-for-metadata=ec2_utils.cli:wait_for_metadata",
]
CONSOLE_ONLY = [
'ec2=ec2_utils.ec2:ec2',
'elastic-c2-register-complete=ec2_utils.elastic_c2_register_complete:main'
"ec2=ec2_utils.ec2:ec2",
"elastic-c2-register-complete=ec2_utils.elastic_c2_register_complete:main",
]
CONSOLESCRIPTS = CONSOLE_ONLY
COMMAND_MAPPINGS = {}
Expand All @@ -97,6 +104,7 @@
name, value = script.split("=")
COMMAND_MAPPINGS[name] = value


def _to_str(data):
ret = data
decode_method = getattr(data, "decode", None)
Expand All @@ -107,11 +115,10 @@ def _to_str(data):
ret = _to_str(base64.b64encode(data))
return str(ret)


def _to_bytes(data):
ret = data
encode_method = getattr(data, "encode", None)
if callable(encode_method):
ret = data.encode("utf-8")
return bytes(ret)


11 changes: 8 additions & 3 deletions ec2_utils/block_devices.py
Original file line number Diff line number Diff line change
@@ -1,28 +1,33 @@
from glob import glob


def linux_block_devices():
for device_size in glob("/sys/block/*/size"):
with open(device_size, "r") as sf:
yield device_size.split("/")[3], int(sf.readlines()[0]) * 512


def linux_block_devices_largest_first():
devs = [dev for dev in linux_block_devices()]
devs.sort(key = lambda dev: dev[1], reverse=True)
devs.sort(key=lambda dev: dev[1], reverse=True)
return devs


def linux_unmounted_block_devices():
for dev in linux_block_devices():
if not linux_is_dev_mounted(dev[0]):
yield dev


def linux_unmounted_block_devices_largest_first():
devs = [dev for dev in linux_unmounted_block_devices()]
devs.sort(key = lambda dev: dev[1], reverse=True)
devs.sort(key=lambda dev: dev[1], reverse=True)
return devs


def linux_is_dev_mounted(device):
with open("/proc/mounts", "r") as mounts:
for mount in mounts.readlines():
if mount.startswith(("/dev/" + device)):
return True
return False
return False
Loading

0 comments on commit 543aa24

Please sign in to comment.