(Build %(build_id)s was submitted by %(principal)s at %(inserted_at)s.)""" % values
return msg
+def submit_completion_msg(succeeded, values, verbose=True, success=lambda x: x, failure=lambda x: x):
+ values = dict(values)
+ if succeeded:
+ values['result'] = success(values['result'])
+ else:
+ values['result'] = failure(values['result'])
+ msg = """Submission of %(commit)s to be built in %(pocket)s %(result)s.
+Build submitted by %(principal)s.""" % values
+ return msg
+
+def repo_creation_msg(succeeded, values, verbose=True, success=lambda x: x, failure=lambda x: x):
+ values = dict(values)
+ assert succeeded
+ msg = '%(principal)s just created a new repository, %(category)s/%(name)s.git' % values
+ return msg
+
# Names of hooks
POST_BUILD = 'post-build'
FAILED_BUILD = 'failed-build'
+POST_SUBMIT = 'post-submit'
+FAILED_SUBMIT = 'failed-submit'
+POST_ADD_REPO = 'post-add-repo'
# Types of communication
message_generators = {
ZEPHYR : { POST_BUILD : build_completion_msg,
- FAILED_BUILD : build_completion_msg },
+ FAILED_BUILD : build_completion_msg,
+ POST_SUBMIT : submit_completion_msg,
+ FAILED_SUBMIT : submit_completion_msg,
+ POST_ADD_REPO : repo_creation_msg },
MAIL : { POST_BUILD : build_completion_msg,
- FAILED_BUILD : build_completion_msg }
+ FAILED_BUILD : build_completion_msg,
+ POST_SUBMIT : submit_completion_msg,
+ FAILED_SUBMIT : submit_completion_msg,
+ POST_ADD_REPO : repo_creation_msg }
}
def zephyr_escape(m):
hook_config = config.build.hooks.post_build
elif prog == FAILED_BUILD:
hook_config = config.build.hooks.failed_build
+ elif prog == POST_SUBMIT:
+ hook_config = config.build.hooks.post_submit
+ elif prog == FAILED_SUBMIT:
+ hook_config = config.build.hooks.failed_submit
+ elif prog == POST_ADD_REPO:
+ hook_config = config.build.hooks.post_add_repo
else:
parser.error('hook script invoked with unrecognized name %s' % prog)
return 2
assert prog == FAILED_BUILD
values['result'] = 'failed'
succeeded = False
+ elif prog in [POST_SUBMIT, FAILED_SUBMIT]:
+ if len(args) != 4:
+ parser.set_usage('Usage: %prog [options] pocket package commit principal')
+ parser.print_help()
+ return 2
+ values = { 'pocket' : args[0],
+ 'package' : args[1],
+ 'commit' : args[2],
+ 'principal' : args[3],
+ 'default_instance' : 'submission',
+ 'default_subject' : 'Submission %(result)s: %(package)s %(version)s in %(pocket)s'}
+ if prog == POST_SUBMIT:
+ values['result'] = 'succeeded'
+ succeeded = True
+ else:
+ values['result'] = 'failed'
+ succeeded = False
+ elif prog in [POST_ADD_REPO]:
+ if len(args) != 3:
+ parser.set_usage('Usage: %prog [options] category name principal')
+ parser.print_help()
+ return 3
+ values = { 'category' : args[0],
+ 'name' : args[1],
+ 'principal' : args[2],
+ 'default_instance' : 'new-repo',
+ 'default_subject' : 'New repository %(category)s/%(name)s'}
+ succeeded = True
else:
raise AssertionError('Impossible state')