xenofem/python-zulip-api
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Change Humbug => Zulip in zephyr_mirror states.

Browse source 
(imported from commit 67542cd2ba93ff4b03c99b59645b7d22ed937337)
This commit is contained in:
Tim Abbott 2013-08-06 15:34:20 -04:00
parent 4cd4c6897b
commit 84aa7d4230
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
bots/zephyr_mirror_backend.py
View file

@ -73,7 +73,7 @@ class RandomExponentialBackoff(CountingBackoff):
DEFAULT_SITE = "https://api.zulip.com" DEFAULT_SITE = "https://api.zulip.com"
class States: class States:
Startup, HumbugToZephyr, ZephyrToHumbug, ChildSending = range(4) Startup, ZulipToZephyr, ZephyrToZulip, ChildSending = range(4)
CURRENT_STATE = States.Startup CURRENT_STATE = States.Startup
def to_humbug_username(zephyr_username): def to_humbug_username(zephyr_username):
@ -836,11 +836,11 @@ def parse_args():
return parser.parse_args() return parser.parse_args()
def die_gracefully(signal, frame): def die_gracefully(signal, frame):
if CURRENT_STATE == States.HumbugToZephyr or CURRENT_STATE == States.ChildSending: if CURRENT_STATE == States.ZulipToZephyr or CURRENT_STATE == States.ChildSending:
# this is a child process, so we want os._exit (no clean-up necessary) # this is a child process, so we want os._exit (no clean-up necessary)
os._exit(1) os._exit(1)
if CURRENT_STATE == States.ZephyrToHumbug: if CURRENT_STATE == States.ZephyrToZulip:
try: try:
# zephyr=>humbug processes may have added subs, so run cancelSubs # zephyr=>humbug processes may have added subs, so run cancelSubs
zephyr._z.cancelSubs() zephyr._z.cancelSubs()
@ -938,14 +938,14 @@ or specify the --api-key-file option.""" % (options.api_key_file,))))
if options.forward_from_humbug: if options.forward_from_humbug:
child_pid = os.fork() child_pid = os.fork()
if child_pid == 0: if child_pid == 0:
CURRENT_STATE = States.HumbugToZephyr CURRENT_STATE = States.ZulipToZephyr
# Run the humbug => zephyr mirror in the child # Run the humbug => zephyr mirror in the child
configure_logger(logger, "humbug=>zephyr") configure_logger(logger, "humbug=>zephyr")
humbug_to_zephyr(options) humbug_to_zephyr(options)
sys.exit(0) sys.exit(0)
else: else:
child_pid = None child_pid = None
CURRENT_STATE = States.ZephyrToHumbug CURRENT_STATE = States.ZephyrToZulip
import zephyr import zephyr
logger_name = "zephyr=>humbug" logger_name = "zephyr=>humbug"