public
/
j7s_branch_trigger
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Move some code around. Send the hash instead of the ref.

This commit is contained in:
James Pace 2023-02-15 20:10:43 -05:00
parent fc4c02a019
commit 33eed3cedb
1 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
j7s_branch_trigger/j7s_branch_trigger.py
View File

@ -29,11 +29,23 @@ def main():
def job():
loop(repo, pattern, url, data_file)
schedule.every(loop_time).minutes.do(job)
logging.debug('Doing initial run.')
schedule.run_all()
logging.debug('Starting loop.')
while True:
schedule.run_pending()
time.sleep(1)
def loop(repo, pattern, request_url, data_file):
logging.debug('Looking at {} for {}.'.format(repo, pattern))
all_branches = git_ls(repo)
logging.debug('All branches: {}'.format(all_branches))
concerned_branches = find_concerned_branches(all_branches, pattern)
logging.debug('Concerned branches for {}: {}'.format(pattern, concerned_branches))
last_time = load_last_time(data_file)
compare_branches(last_time, concerned_branches, request_url)
save_this_time(data_file, concerned_branches)
def git_ls(repo):
cmd = 'git ls-remote {repo}'.format(repo=repo)
output = subprocess.run(cmd, shell=True, stdout=subprocess.PIPE)
@ -76,20 +88,10 @@ def compare_branches(last_time, this_time, url):
last_hash = last_time.get(branch, None)
if my_hash != last_hash:
logging.debug('Branch {} has new hash.'.format(branch))
r = requests.post(url, json={"branch": branch})
r = requests.post(url, json={"hash": my_hash})
if r.status_code != 200:
logging.warning("Something went wrong on request.")
def loop(repo, pattern, request_url, data_file):
logging.debug('Looking at {} for {}.'.format(repo, pattern))
all_branches = git_ls(repo)
logging.debug('All branches: {}'.format(all_branches))
concerned_branches = find_concerned_branches(all_branches, pattern)
logging.debug('Concerned branches for {}: {}'.format(pattern, concerned_branches))
last_time = load_last_time(data_file)
compare_branches(last_time, concerned_branches, request_url)
save_this_time(data_file, concerned_branches)
def get_config():
repo = os.environ.get('J7S_REPO', None)
url = os.environ.get('J7S_URL', None)
@ -100,4 +102,3 @@ def get_config():
loop_time = float(os.environ.get('J7S_LOOPTIME', 1.0))
return (repo, url, data_file, pattern, loop_time)