forked from unofficial-mirrors/znc
Browse Source
Old key got leaked due to https://developer.github.com/changes/2014-04-25-user-content-security/ This commit tests that the key is not leaked anymore1.6.x
Alexey Sokolov
8 years ago
3 changed files with 126 additions and 5 deletions
Binary file not shown.
@ -0,0 +1,120 @@
@@ -0,0 +1,120 @@
|
||||
# https://github.com/dmakhno/travis_after_all/tree/b7172bca92d6dcfcec2a0eacdf14eb5f3a1ad627 |
||||
|
||||
# The MIT License (MIT) |
||||
# |
||||
# Copyright (c) 2014 Dmytro Makhno |
||||
# |
||||
# Permission is hereby granted, free of charge, to any person obtaining a copy of |
||||
# this software and associated documentation files (the "Software"), to deal in |
||||
# the Software without restriction, including without limitation the rights to |
||||
# use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of |
||||
# the Software, and to permit persons to whom the Software is furnished to do so, |
||||
# subject to the following conditions: |
||||
# |
||||
# The above copyright notice and this permission notice shall be included in all |
||||
# copies or substantial portions of the Software. |
||||
# |
||||
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
||||
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS |
||||
# FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR |
||||
# COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER |
||||
# IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
||||
# CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. |
||||
|
||||
import os |
||||
import json |
||||
import time |
||||
import logging |
||||
|
||||
try: |
||||
import urllib.request as urllib2 |
||||
except ImportError: |
||||
import urllib2 |
||||
|
||||
log = logging.getLogger("travis.leader") |
||||
log.addHandler(logging.StreamHandler()) |
||||
log.setLevel(logging.INFO) |
||||
|
||||
TRAVIS_JOB_NUMBER = 'TRAVIS_JOB_NUMBER' |
||||
TRAVIS_BUILD_ID = 'TRAVIS_BUILD_ID' |
||||
POLLING_INTERVAL = 'LEADER_POLLING_INTERVAL' |
||||
|
||||
build_id = os.getenv(TRAVIS_BUILD_ID) |
||||
polling_interval = int(os.getenv(POLLING_INTERVAL, '5')) |
||||
|
||||
#assume, first job is the leader |
||||
is_leader = lambda job_number: job_number.endswith('.1') |
||||
|
||||
if not os.getenv(TRAVIS_JOB_NUMBER): |
||||
# seems even for builds with only one job, this won't get here |
||||
log.fatal("Don't use defining leader for build without matrix") |
||||
exit(1) |
||||
elif is_leader(os.getenv(TRAVIS_JOB_NUMBER)): |
||||
log.info("This is a leader") |
||||
else: |
||||
#since python is subprocess, env variables are exported back via file |
||||
with open(".to_export_back", "w") as export_var: |
||||
export_var.write("BUILD_MINION=YES") |
||||
log.info("This is a minion") |
||||
exit(0) |
||||
|
||||
|
||||
class MatrixElement(object): |
||||
def __init__(self, json_raw): |
||||
self.is_finished = json_raw['finished_at'] is not None |
||||
self.is_succeeded = json_raw['result'] == 0 |
||||
self.number = json_raw['number'] |
||||
self.is_leader = is_leader(self.number) |
||||
|
||||
|
||||
def matrix_snapshot(): |
||||
""" |
||||
:return: Matrix List |
||||
""" |
||||
response = urllib2.build_opener().open("https://api.travis-ci.org/builds/{0}".format(build_id)).read() |
||||
raw_json = json.loads(response) |
||||
matrix_without_leader = [MatrixElement(element) for element in raw_json["matrix"]] |
||||
return matrix_without_leader |
||||
|
||||
|
||||
def wait_others_to_finish(): |
||||
def others_finished(): |
||||
""" |
||||
Dumps others to finish |
||||
Leader cannot finish, it is working now |
||||
:return: tuple(True or False, List of not finished jobs) |
||||
""" |
||||
snapshot = matrix_snapshot() |
||||
finished = [el.is_finished for el in snapshot if not el.is_leader] |
||||
return reduce(lambda a, b: a and b, finished), [el.number for el in snapshot if |
||||
not el.is_leader and not el.is_finished] |
||||
|
||||
while True: |
||||
finished, waiting_list = others_finished() |
||||
if finished: break |
||||
log.info("Leader waits for minions {0}...".format(waiting_list)) # just in case do not get "silence timeout" |
||||
time.sleep(polling_interval) |
||||
|
||||
|
||||
try: |
||||
wait_others_to_finish() |
||||
|
||||
final_snapshot = matrix_snapshot() |
||||
log.info("Final Results: {0}".format([(e.number, e.is_succeeded) for e in final_snapshot])) |
||||
|
||||
BUILD_AGGREGATE_STATUS = 'BUILD_AGGREGATE_STATUS' |
||||
others_snapshot = [el for el in final_snapshot if not el.is_leader] |
||||
if reduce(lambda a, b: a and b, [e.is_succeeded for e in others_snapshot]): |
||||
os.environ[BUILD_AGGREGATE_STATUS] = "others_succeeded" |
||||
elif reduce(lambda a, b: a and b, [not e.is_succeeded for e in others_snapshot]): |
||||
log.error("Others Failed") |
||||
os.environ[BUILD_AGGREGATE_STATUS] = "others_failed" |
||||
else: |
||||
log.warn("Others Unknown") |
||||
os.environ[BUILD_AGGREGATE_STATUS] = "unknown" |
||||
#since python is subprocess, env variables are exported back via file |
||||
with open(".to_export_back", "w") as export_var: |
||||
export_var.write("BUILD_LEADER=YES {0}={1}".format(BUILD_AGGREGATE_STATUS, os.environ[BUILD_AGGREGATE_STATUS])) |
||||
|
||||
except Exception as e: |
||||
log.fatal(e) |
||||
Loading…
Reference in new issue