Skip to content

Commit

Permalink
Fix codefactor
Browse files Browse the repository at this point in the history
  • Loading branch information
definite committed Apr 12, 2018
1 parent 02f473a commit 9ca4436
Show file tree
Hide file tree
Showing 3 changed files with 39 additions and 28 deletions.
20 changes: 13 additions & 7 deletions JenkinsHelper.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,16 +13,20 @@

from typing import List, Any # noqa: F401 # pylint: disable=unused-import
# We need to import 'List' and 'Any' for mypy to work
from ZanataFunctions import UrlHelper, logging_init
from .ZanataFunctions import UrlHelper, logging_init

ZANATA_JENKINS = {
'server': os.environ.get('JENKINS_URL'),
'user': os.environ.get('ZANATA_JENKINS_USER'),
'token': os.environ.get('ZANATA_JENKINS_TOKEN'),
}
assert ZANATA_JENKINS['server'], "Missing environment 'JENKINS_URL'"
assert ZANATA_JENKINS['user'], "Missing environment 'ZANATA_JENKINS_USER'"
assert ZANATA_JENKINS['token'], "Missing environment 'ZANATA_JENKINS_TOKEN'"

if not ZANATA_JENKINS['server']:
raise AssertionError("Missing environment 'JENKINS_URL'")
if not ZANATA_JENKINS['user']:
raise AssertionError("Missing environment 'ZANATA_JENKINS_USER'")
if not ZANATA_JENKINS['token']:
raise AssertionError("Missing environment 'ZANATA_JENKINS_TOKEN'")


class JenkinsJobBuild(object):
Expand Down Expand Up @@ -76,7 +80,8 @@ def list_artifacts_related_paths(self, artifact_path_pattern='.*'):
that matches the path pattern"""
if not self.content:
self.load()
assert self.content, "Failed to load build from %s" % self.url
if not self.content:
raise AssertionError("Failed to load build from %s" % self.url)
return map(
lambda y: y['relativePath'],
filter(
Expand Down Expand Up @@ -160,7 +165,8 @@ def get_last_successful_build(self):
if not self.content:
self.load()

assert self.content, "Failed to load job from %s" % self.url
if not self.content:
raise AssertionError("Failed to load job from %s" % self.url)
return JenkinsJobBuild(
self,
int(self.get_elem('lastSuccessfulBuild/number')),
Expand Down Expand Up @@ -263,5 +269,5 @@ def parse():
if __name__ == '__main__':
logging_init()

args = parse()
args = parse() # pylint: disable=invalid-name
args.func()
21 changes: 11 additions & 10 deletions ZanataFunctions.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,12 @@
import os
import subprocess # nosec
import sys
import urllib2 # noqa: F401 # pylint: disable=unused-import
import urlparse # noqa: F401 # pylint: disable=unused-import
import urllib2 # noqa: F401 # pylint: disable=import-error,unused-import
import urlparse # noqa: F401 # pylint: disable=import-error,unused-import

SCRIPT_DIR = os.path.dirname(os.path.realpath(__file__))
ZANATA_ENV_FILE = os.path.join(SCRIPT_DIR, 'zanata-env.sh')
BASH_CMD = '/bin/bash'


def logging_init(level=logging.INFO):
Expand All @@ -26,8 +27,8 @@ def logging_init(level=logging.INFO):
def read_env(filename):
# type (str) -> dict
"""Read environment variables by sourcing a bash file"""
proc = subprocess.Popen(
['bash', '-c',
proc = subprocess.Popen( # nosec
[BASH_CMD, '-c',
"source %s && set -o posix && set" % (filename)],
stdout=subprocess.PIPE)
return {kv[0]: kv[1] for kv in map(
Expand Down Expand Up @@ -94,7 +95,7 @@ def run_command(self, command, sudo=False):
('sudo ' if sudo else '') + command]
logging.info(' '.join(cmd_list))

subprocess.check_call(cmd_list)
subprocess.check_call(cmd_list) # nosec

def scp_to_remote(
self, source_path, dest_path,
Expand All @@ -112,7 +113,7 @@ def scp_to_remote(

logging.info(' '.join(cmd_list))

subprocess.check_call(cmd_list)
subprocess.check_call(cmd_list) # nosec


class UrlHelper(object):
Expand Down Expand Up @@ -157,14 +158,14 @@ def download_file(url, dest_file='', dest_dir='.'):
raise

logging.info("Downloading to %s from %s", target_path, url)
response = urllib2.urlopen(url)
response = urllib2.urlopen(url) # nosec
chunk_count = 0
with open(target_path, 'wb') as out_file:
while True:
buffer = response.read(chunk)
if not buffer:
buf = response.read(chunk)
if not buf:
break
out_file.write(buffer)
out_file.write(buf)
chunk_count += 1
if chunk_count % 100 == 0:
sys.stderr.write('#')
Expand Down
26 changes: 15 additions & 11 deletions ZanataWar.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,13 @@

import argparse
import os
import urlparse
from ZanataFunctions import logging_init
from ZanataFunctions import SshHost
from ZanataFunctions import UrlHelper
from JenkinsHelper import JenkinsJobBuild # noqa: E501,F401 # pylint: disable=unused-import
from JenkinsHelper import JenkinsServer
import urlparse # pylint: disable=import-error
# python3-pylint does not do well on importing python2 module
from .ZanataFunctions import logging_init
from .ZanataFunctions import SshHost
from .ZanataFunctions import UrlHelper
from .JenkinsHelper import JenkinsJobBuild # noqa: E501,F401 # pylint: disable=unused-import
from .JenkinsHelper import JenkinsServer


class ZanataWar(object):
Expand Down Expand Up @@ -52,7 +53,8 @@ def download(
dest_dir=None):
# type (str, str) -> None
"""Download WAR file from .download_url"""
assert self.download_url, "war download_url is not set."
if not self.download_url:
raise AssertionError("war download_url is not set.")
target_file = dest_file
if not target_file:
url_dict = urlparse.urlparse(self.download_url)
Expand All @@ -62,7 +64,7 @@ def download(
UrlHelper.download_file(self.download_url, target_file, target_dir)
self.local_path = os.path.join(target_dir, target_file)

def scp_to_server(
def scp_to_server( # pylint: disable=too-many-arguments
self, dest_host,
dest_path=None,
identity_file=None,
Expand All @@ -72,8 +74,10 @@ def scp_to_server(
# type (str, str, str, bool, bool, str) -> None
"""SCP to Zanata server"""
local_path = source_path if source_path else self.local_path
assert local_path, "source_path is missing"
assert os.path.isfile(local_path), local_path + " does not exist"
if not local_path:
raise AssertionError("source_path is missing")
if not os.path.isfile(local_path):
raise AssertionError(local_path + " does not exist")

if dest_path:
target_path = dest_path
Expand Down Expand Up @@ -190,5 +194,5 @@ def parse():
# Set logging
logging_init()

args = parse()
args = parse() # pylint: disable=invalid-name
args.func()

0 comments on commit 9ca4436

Please sign in to comment.