def sync_megaphone()

in cronjobs/src/commands/sync_megaphone.py [0:0]
48 lines of code
14 McCabe index (conditional complexity)

def sync_megaphone(event, context):
    min_sync_interval = int(
        os.getenv("MIN_SYNC_INTERVAL_SECONDS", "300")  # 5 min by default.
    )
    max_sync_interval = int(
        os.getenv("MAX_SYNC_INTERVAL_SECONDS", "1200")  # 20 min by default.
    )
    rs_server = event.get("server") or os.getenv("SERVER")
    rs_timestamp = get_remotesettings_timestamp(rs_server)

    megaphone_url = event.get("megaphone_url") or os.getenv("MEGAPHONE_URL")
    megaphone_reader_auth = event.get("megaphone_reader_auth") or os.getenv(
        "MEGAPHONE_READER_AUTH"
    )
    megaphone_broadcaster_auth = event.get("megaphone_broadcaster_auth") or os.getenv(
        "MEGAPHONE_BROADCASTER_AUTH"
    )
    broadcaster_id = event.get("broadcaster_id") or os.getenv(
        "BROADCASTER_ID", BROADCASTER_ID
    )
    channel_id = event.get("channel_id") or os.getenv("CHANNEL_ID", CHANNEL_ID)
    broadcast_id = f"{broadcaster_id}/{channel_id}"

    megaphone_client = Megaphone(
        megaphone_url, megaphone_reader_auth, megaphone_broadcaster_auth, broadcast_id
    )
    megaphone_timestamp = megaphone_client.get_version()
    print(f"Remote Settings: {rs_timestamp}; Megaphone: {megaphone_timestamp}")

    if int(rs_timestamp) <= int(megaphone_timestamp):
        print("Timestamps are in sync. Nothing to do.")
        return

    # Do not push timestamp if one was published recently.
    # This allows us to:
    # - debounce many publications close together
    # - decorrelate the frequency of the cronjob from the interval between two notifications
    # - if changes are published continously for too long and megaphone becomes outdated, sync.
    rs_age_seconds = (
        utcnow() - datetime.fromtimestamp(int(rs_timestamp) / 1000, timezone.utc)
    ).total_seconds()
    megaphone_age_seconds = (
        utcnow() - datetime.fromtimestamp(int(megaphone_timestamp) / 1000, timezone.utc)
    ).total_seconds()

    if (diff := min_sync_interval - rs_age_seconds) > 0:
        print(f"A change was published recently (<{min_sync_interval}).", end=" ")
        if megaphone_age_seconds < max_sync_interval:
            print(
                f"Megaphone is {megaphone_age_seconds} seconds old (<{max_sync_interval}). "
                f"Can wait {diff} more seconds."
            )
            return
        else:
            print(
                f"Megaphone is {megaphone_age_seconds} seconds old (>{max_sync_interval}). Sync!"
            )

    megaphone_client.send_version(f'"{rs_timestamp}"')