
import signal

def run_main_scheduler(scheduler):
	"""
	Start and run an AsyncScheduler (or compatible object), and handle
	SIGINT or SIGTERM by calling its terminate() method and waiting
	for it to clean up after itself. If SIGINT or SIGTERM is received,
	return signum, else return None. Any previous SIGINT or SIGTERM
	signal handlers are automatically saved and restored before
	returning.
	"""

	received_signal = []

	def sighandler(signum, frame):
		signal.signal(signal.SIGINT, signal.SIG_IGN)
		signal.signal(signal.SIGTERM, signal.SIG_IGN)
		received_signal.append(signum)
		scheduler.terminate()

	earlier_sigint_handler = signal.signal(signal.SIGINT, sighandler)
	earlier_sigterm_handler = signal.signal(signal.SIGTERM, sighandler)

	try:
		scheduler.start()
		scheduler.wait()
	finally:
		# Restore previous handlers
		if earlier_sigint_handler is not None:
			signal.signal(signal.SIGINT, earlier_sigint_handler)
		else:
			signal.signal(signal.SIGINT, signal.SIG_DFL)
		if earlier_sigterm_handler is not None:
			signal.signal(signal.SIGTERM, earlier_sigterm_handler)
		else:
			signal.signal(signal.SIGTERM, signal.SIG_DFL)

	if received_signal:
		return received_signal[0]
	return None