aurora/start_observer.py at main · tias112/aurora · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
from kiruna.mag_service import MagWatcher
from kiruna.mag_service import watcher_service
from kiruna.mag_service import bz_watcher_service
from monitor import background_monitor_q
from client.irf_client import IRFClient
from client.noaa_client import NOAAClient
from client.telegram_bot import bot_main
from config import settings
import sys
import threading
import re
import time
import warnings

if __name__ == "__main__":
    warnings.filterwarnings(action='ignore', message='Python 3.6 is no longer supported')

    night_time = settings.night_time.split(":") if settings.night_time else None

    print("notifier for aurora has been started")

    kiruna_watcher = MagWatcher(freq=settings.freq_sec, utc_shift=settings.utc_shift, night_start=int(night_time[0]),
                                night_end=int(night_time[1]))
    idf_client = IRFClient()
    noaa_client = NOAAClient()
    print(noaa_client.process(kiruna_watcher.current_ts_utc))  # TODO: calculate based on response
    # start watching kiruna
    t1 = threading.Thread(target=watcher_service, args=(kiruna_watcher, idf_client))
    t1.daemon = True
    t2 = threading.Thread(target=bz_watcher_service, args=(kiruna_watcher, noaa_client))
    t2.daemon = True
    t1.start()
    t2.start()
    time.sleep(5)
    # start notifier job
    t3 = threading.Thread(target=background_monitor_q,
                          args=(settings.limit_q, kiruna_watcher, settings.bot_token.get_secret_value(), settings.bot_chat_id))
    t3.daemon = True
    t3.start()
    bot_main(settings.bot_token.get_secret_value())
    t1.do_run = False  # not necessarily as all services are daemons
    t2.do_run = False
    t3.do_run = False